You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
87 lines
2.5 KiB
87 lines
2.5 KiB
# frozen_string_literal: true |
|
|
|
class Api::Web::PushSubscriptionsController < Api::Web::BaseController |
|
before_action :require_user!, except: :destroy |
|
before_action :set_push_subscription, only: :update |
|
before_action :destroy_previous_subscriptions, only: :create, if: :prior_subscriptions? |
|
after_action :update_session_with_subscription, only: :create |
|
|
|
def create |
|
@push_subscription = ::Web::PushSubscription.create!(web_push_subscription_params) |
|
|
|
render json: @push_subscription, serializer: REST::WebPushSubscriptionSerializer |
|
end |
|
|
|
def update |
|
@push_subscription.update!(data: data_params) |
|
render json: @push_subscription, serializer: REST::WebPushSubscriptionSerializer |
|
end |
|
|
|
def destroy |
|
push_subscription = ::Web::PushSubscription.find_by_token_for(:unsubscribe, params[:id]) |
|
push_subscription&.destroy |
|
|
|
head 200 |
|
end |
|
|
|
private |
|
|
|
def active_session |
|
@active_session ||= current_session |
|
end |
|
|
|
def destroy_previous_subscriptions |
|
active_session.web_push_subscription.destroy! |
|
active_session.update!(web_push_subscription: nil) |
|
end |
|
|
|
def prior_subscriptions? |
|
active_session.web_push_subscription.present? |
|
end |
|
|
|
def subscription_data |
|
default_subscription_data.tap do |data| |
|
data.deep_merge!(data_params) if params[:data] |
|
end |
|
end |
|
|
|
def default_subscription_data |
|
{ |
|
policy: 'all', |
|
alerts: Notification::TYPES.index_with { alerts_enabled }, |
|
}.deep_stringify_keys |
|
end |
|
|
|
def alerts_enabled |
|
# Mobile devices do not support regular notifications, so we enable push notifications by default |
|
active_session.detection.device.mobile? || active_session.detection.device.tablet? |
|
end |
|
|
|
def update_session_with_subscription |
|
active_session.update!(web_push_subscription: @push_subscription) |
|
end |
|
|
|
def set_push_subscription |
|
@push_subscription = ::Web::PushSubscription.find(params[:id]) |
|
end |
|
|
|
def subscription_params |
|
@subscription_params ||= params.expect(subscription: [:standard, :endpoint, keys: [:auth, :p256dh]]) |
|
end |
|
|
|
def web_push_subscription_params |
|
{ |
|
access_token_id: active_session.access_token_id, |
|
data: subscription_data, |
|
endpoint: subscription_params[:endpoint], |
|
key_auth: subscription_params[:keys][:auth], |
|
key_p256dh: subscription_params[:keys][:p256dh], |
|
standard: subscription_params[:standard] || false, |
|
user_id: active_session.user_id, |
|
} |
|
end |
|
|
|
def data_params |
|
@data_params ||= params.expect(data: [:policy, alerts: Notification::TYPES]) |
|
end |
|
end
|
|
|