1234567891011121314151617181920212223242526272829303132333435363738394041424344 |
- # frozen_string_literal: true
- class ActivityPub::DeliveryWorker
- include Sidekiq::Worker
- sidekiq_options queue: 'push', retry: 5, dead: false
- HEADERS = { 'Content-Type' => 'application/activity+json' }.freeze
- def perform(json, source_account_id, inbox_url)
- @json = json
- @source_account = Account.find(source_account_id)
- @inbox_url = inbox_url
- perform_request
- raise Mastodon::UnexpectedResponseError, @response unless response_successful?
- failure_tracker.track_success!
- rescue => e
- failure_tracker.track_failure!
- raise e.class, "Delivery failed for #{inbox_url}: #{e.message}", e.backtrace[0]
- end
- private
- def build_request
- request = Request.new(:post, @inbox_url, body: @json)
- request.on_behalf_of(@source_account, :uri)
- request.add_headers(HEADERS)
- end
- def perform_request
- @response = build_request.perform.flush
- end
- def response_successful?
- @response.code > 199 && @response.code < 300
- end
- def failure_tracker
- @failure_tracker ||= DeliveryFailureTracker.new(@inbox_url)
- end
- end
|