discourse/app/jobs/regular/push_notification.rb

module Jobs
  class PushNotification < Jobs::Base
    def execute(args)
      notification = args["payload"]
      notification["url"] = UrlHelper.absolute_without_cdn(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 do |client_id, _|
          notification.merge({
            client_id: client_id
          })
        end

        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