module WolfCore::Integrations::WebhooksOperations

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

def get_event_name(params:)
  message = params["Message"] || {}
  message = JSON.parse(message) if message.is_a?(String)
  message["event_name"]
end

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

def get_object_id(params:)
  message = params["Message"] || {}
  message = JSON.parse(message) if message.is_a?(String)
  message["object_id"]
end

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

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")
  custom_values = [payload["attributes"]] if custom_values.blank?
  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

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

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

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