mirror of
https://framagit.org/tykayn/mastodon.git
synced 2023-08-25 08:33:12 +02:00
38 lines
875 B
Ruby
38 lines
875 B
Ruby
|
# frozen_string_literal: true
|
||
|
|
||
|
class Webhooks::DeliveryWorker
|
||
|
include Sidekiq::Worker
|
||
|
include JsonLdHelper
|
||
|
|
||
|
sidekiq_options queue: 'push', retry: 16, dead: false
|
||
|
|
||
|
def perform(webhook_id, body)
|
||
|
@webhook = Webhook.find(webhook_id)
|
||
|
@body = body
|
||
|
@response = nil
|
||
|
|
||
|
perform_request
|
||
|
rescue ActiveRecord::RecordNotFound
|
||
|
true
|
||
|
end
|
||
|
|
||
|
private
|
||
|
|
||
|
def perform_request
|
||
|
request = Request.new(:post, @webhook.url, body: @body)
|
||
|
|
||
|
request.add_headers(
|
||
|
'Content-Type' => 'application/json',
|
||
|
'X-Hub-Signature' => "sha256=#{signature}"
|
||
|
)
|
||
|
|
||
|
request.perform do |response|
|
||
|
raise Mastodon::UnexpectedResponseError, response unless response_successful?(response) || response_error_unsalvageable?(response)
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def signature
|
||
|
OpenSSL::HMAC.hexdigest(OpenSSL::Digest.new('sha256'), @webhook.secret, @body)
|
||
|
end
|
||
|
end
|