discourse/app/jobs/regular/push_notification.rb

# frozen_string_literal: true

module Jobs
  class PushNotification < ::Jobs::Base
    def execute(args)
      notification = args["payload"]
      notification["url"] = UrlHelper.absolute_without_cdn(
        Discourse.base_path + notification["post_url"],
      )
      notification.delete("post_url")

      payload = {
        secret_key: SiteSetting.push_api_secret_key,
        url: Discourse.base_url,
        title: SiteSetting.title,
        description: SiteSetting.site_description,
      }

      clients = args["clients"]
      clients
        .group_by { |r| r[1] }
        .each do |push_url, group|
          notifications = group.map { |client_id, _| notification.merge(client_id: client_id) }

          next unless push_url.present?

          result =
            Excon.post(
              push_url,
              body: payload.merge(notifications: notifications).to_json,
              headers: {
                "Content-Type" => "application/json",
                "Accept" => "application/json",
              },
            )

          if result.status != 200
            # we failed to push a notification ... log it
            Rails.logger.warn(
              "Failed to push a notification to #{push_url} Status: #{result.status}: #{result.status_line}",
            )
          end
        end
    end
  end
end