Sha256: e053b91f7dcf140446462fd7c91c5b305a71c3fdc5c146b565108bdc30d31dfd
Contents?: true
Size: 1.49 KB
Versions: 9
Compression:
Stored size: 1.49 KB
Contents
module Webhooks::Outgoing::DeliverySupport
extend ActiveSupport::Concern
included do
belongs_to :endpoint, class_name: "Webhooks::Outgoing::Endpoint"
belongs_to :event, class_name: "Webhooks::Outgoing::Event"
has_one :team, through: :endpoint unless BulletTrain::OutgoingWebhooks.parent_class_specified?
has_many :delivery_attempts, class_name: "Webhooks::Outgoing::DeliveryAttempt", dependent: :destroy, foreign_key: :delivery_id
end
ATTEMPT_SCHEDULE = {
1 => 15.seconds,
2 => 1.minute,
3 => 5.minutes,
4 => 15.minutes,
5 => 1.hour,
}
def label_string
event.short_uuid
end
def next_reattempt_delay
ATTEMPT_SCHEDULE[attempt_count]
end
def deliver_async
if still_attempting?
Webhooks::Outgoing::DeliveryJob.set(wait: next_reattempt_delay).perform_later(self)
end
end
def deliver
# TODO If we ever do away with the `async: true` default for webhook generation, then I believe this needs to
# change otherwise we'd be attempting the first delivery of webhooks inline.
if delivery_attempts.new.attempt
touch(:delivered_at)
else
deliver_async
end
end
def attempt_count
delivery_attempts.count
end
def delivered?
delivered_at.present?
end
def still_attempting?
return false if delivered?
attempt_count <= max_attempts
end
def failed?
!(delivered? || still_attempting?)
end
def name
event.short_uuid
end
def max_attempts
ATTEMPT_SCHEDULE.keys.max
end
end
Version data entries
9 entries across 9 versions & 1 rubygems