mastodon/app/models/web/push_subscription.rb

# frozen_string_literal: true
# == Schema Information
#
# Table name: web_push_subscriptions
#
#  id         :bigint(8)        not null, primary key
#  endpoint   :string           not null
#  key_p256dh :string           not null
#  key_auth   :string           not null
#  data       :json
#  created_at :datetime         not null
#  updated_at :datetime         not null
#

require 'webpush'

class Web::PushSubscription < ApplicationRecord
  has_one :session_activation

  def push(notification)
    I18n.with_locale(session_activation.user.locale || I18n.default_locale) do
      push_payload(message_from(notification), 48.hours.seconds)
    end
  end

  def pushable?(notification)
    data&.key?('alerts') && data['alerts'][notification.type.to_s]
  end

  def as_payload
    payload = { id: id, endpoint: endpoint }
    payload[:alerts] = data['alerts'] if data&.key?('alerts')
    payload
  end

  def access_token
    find_or_create_access_token.token
  end

  private

  def push_payload(message, ttl = 5.minutes.seconds)
    # TODO: Make sure that the payload does not
    # exceed 4KB - Webpush::PayloadTooLarge

    Webpush.payload_send(
      message: Oj.dump(message),
      endpoint: endpoint,
      p256dh: key_p256dh,
      auth: key_auth,
      ttl: ttl,
      vapid: {
        subject: "mailto:#{::Setting.site_contact_email}",
        private_key: Rails.configuration.x.vapid_private_key,
        public_key: Rails.configuration.x.vapid_public_key,
      }
    )
  end

  def message_from(notification)
    serializable_resource = ActiveModelSerializers::SerializableResource.new(notification, serializer: Web::NotificationSerializer, scope: self, scope_name: :current_push_subscription)
    serializable_resource.as_json
  end

  def find_or_create_access_token
    Doorkeeper::AccessToken.find_or_create_for(
      Doorkeeper::Application.find_by(superapp: true),
      session_activation.user_id,
      Doorkeeper::OAuth::Scopes.from_string('read write follow'),
      Doorkeeper.configuration.access_token_expires_in,
      Doorkeeper.configuration.refresh_token_enabled?
    )
  end
end