Module: WolfCore::Integrations::WebhooksOperations

Defined in:
lib/wolf_core/application/integrations/webhooks_operations.rb

Instance Method Summary collapse

Instance Method Details

#build_body_from_params(params:, id_key:, include_changes: false) ⇒ Object 



48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 48

def build_body_from_params(params:, id_key:, include_changes: false)
  body = {
    event_name: get_event_name(params: params),
    id_key => get_object_id(params: params)
  }
  if include_changes
    payload = get_payload(params: params)
    body[:changes] = payload&.dig('changes')
  end
  body
end

#get_event_name(params:) ⇒ Object 



15
16
17
18
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 15

def get_event_name(params:)
  message = JSON.parse(params['Message'] || {})
  message['event_name']
end

#get_event_type(params:) ⇒ Object 



11
12
13
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 11

def get_event_type(params:)
  params['Type']
end

#get_object_id(params:) ⇒ Object 



60
61
62
63
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 60

def get_object_id(params:)
  params = JSON.parse(params['Message'] || '{}')
  params['object_id']
end

#get_payload(params:, event_type: nil) ⇒ Object 



4
5
6
7
8
9
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 4

def get_payload(params:, event_type: nil)
  event_type ||= get_event_type(params: params)
  return if event_type == 'SubscriptionConfirmation'
  params = JSON.parse(params['Message'] || '{}')
  JSON.parse(params['payload'] || '{}')
end

#group_custom_values_by_custom_requirement_group(payload:, jobseeker_file_custom_requirement_ids:, reference_form_custom_requirement_ids:, disclosure_form_custom_requirement_ids:) ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 65

def group_custom_values_by_custom_requirement_group(
  payload:,
  jobseeker_file_custom_requirement_ids:,
  reference_form_custom_requirement_ids:,
  disclosure_form_custom_requirement_ids:
)
  custom_values = payload.dig('changes', 'custom_values')
  if custom_values.blank?
    custom_values = [ payload['attributes'] ]
  end

  custom_values.group_by do |custom_value|
    custom_requirement_group = if jobseeker_file_custom_requirement_ids.include?(custom_value['custom_requirement_id'].to_s)
      'jobseeker_file'
    elsif reference_form_custom_requirement_ids.include?(custom_value['custom_requirement_id'].to_s)
      'reference_form'
    elsif disclosure_form_custom_requirement_ids.include?(custom_value['custom_requirement_id'].to_s)
      'disclosure_form'
    elsif custom_value['user_category'] == 'Freelancer'
      'jobseeker'
    elsif custom_value['user_category'] == 'Campaign'
      'order'
    else
      'unknown_group'
    end

    custom_requirement_group
  end
end

#process_webhook(params:) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 37

def process_webhook(params:)
  event_type = get_event_type(params: params)
  if event_type == 'SubscriptionConfirmation'
    url = params['SubscribeURL']
    subscription_confirmation_request(url: url)
  elsif event_type == 'Notification'
    event_name = get_event_name(params: params)
    yield(event_name)
  end
end

#subscription_confirmation_request(url:) ⇒ Object 



30
31
32
33
34
35
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 30

def subscription_confirmation_request(url:)
  safe_http_get(
    url: url,
    error_message: "Can not confirm subscription",
  )
end

#validate_user_is_not_admin(params:) ⇒ Object 



20
21
22
23
24
25
26
27
28
 
# File 'lib/wolf_core/application/integrations/webhooks_operations.rb', line 20

def validate_user_is_not_admin(params:)
  event_type = get_event_type(params: params)
  return if event_type == 'SubscriptionConfirmation'

  user_id = params.dig('invoker', 'user_id').to_s
  return unless user_id == ENV['WOLF_ADMIN_ID'].to_s

  raise_service_error("Ignoring event from user id #{user_id}")
end