blob: fa72abf1311f7dc9fbf18d5c24517cd970b8c05a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
# frozen_string_literal: true
module Gitlab
module Mailgun
module WebhookProcessors
class FailureLogger < Base
def execute
log_failure if permanent_failure_over_threshold? || temporary_failure_over_threshold?
end
def permanent_failure_over_threshold?
payload['event'] == 'failed' && payload['severity'] == 'permanent' &&
Gitlab::ApplicationRateLimiter.throttled?(:permanent_email_failure, scope: payload['recipient'])
end
def temporary_failure_over_threshold?
payload['event'] == 'failed' && payload['severity'] == 'temporary' &&
Gitlab::ApplicationRateLimiter.throttled?(:temporary_email_failure, scope: payload['recipient'])
end
private
def log_failure
Gitlab::ErrorTracking::Logger.error(
event: 'email_delivery_failure',
mailgun_event_id: payload['id'],
recipient: payload['recipient'],
failure_type: payload['severity'],
failure_reason: payload['reason'],
failure_code: payload.dig('delivery-status', 'code'),
failure_message: payload.dig('delivery-status', 'message')
)
end
end
end
end
end
|
