discourse/app/jobs/regular/push_notification.rb

39 lines
1.1 KiB
Ruby

# frozen_string_literal: true
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
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