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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
# frozen_string_literal: true
module Integrations
class SlackEventWorker
include ApplicationWorker
EVENTS = {
'app_home_opened' => SlackEvents::AppHomeOpenedService
}.freeze
feature_category :integrations
data_consistency :delayed
urgency :low
deduplicate :until_executed
idempotent!
worker_has_external_dependencies!
def self.event?(slack_event)
EVENTS.key?(slack_event)
end
def perform(args)
args = args.with_indifferent_access
log_extra_metadata_on_done(:slack_event, args[:slack_event])
log_extra_metadata_on_done(:slack_user_id, args.dig(:params, :event, :user))
log_extra_metadata_on_done(:slack_workspace_id, args.dig(:params, :team_id))
unless self.class.event?(args[:slack_event])
Sidekiq.logger.error(
message: 'Unknown slack_event',
slack_event: args[:slack_event]
)
return
end
# Ensure idempotency by taking out an exclusive lease keyed to `params.event_id`.
# The `event_id` is "a unique identifier for this specific event, globally unique
# across all workspaces" and guaranteed to be present as part of the Slack event JSON schema.
# See https://api.slack.com/types/event.
lease = Gitlab::ExclusiveLease.new("slack_event:#{args[:params][:event_id]}", timeout: 1.hour.to_i)
return unless lease.try_obtain
service_class = EVENTS[args[:slack_event]]
response = service_class.new(args[:params]).execute
lease.cancel if response.error?
rescue StandardError => e
lease.cancel
raise e
end
end
end
|
