app/services/alert_management/sync_alert_service_data_service.rb


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
55
56

# frozen_string_literal: true

module AlertManagement
  class SyncAlertServiceDataService
    # @param alert_service [AlertsService]
    def initialize(alert_service)
      @alert_service = alert_service
    end

    def execute
      http_integration = find_http_integration

      result = if http_integration
                 update_integration_data(http_integration)
               else
                 create_integration
               end

      result ? ServiceResponse.success : ServiceResponse.error(message: 'Update failed')
    end

    private

    attr_reader :alert_service

    def find_http_integration
      AlertManagement::HttpIntegrationsFinder.new(
        alert_service.project,
        endpoint_identifier: ::AlertManagement::HttpIntegration::LEGACY_IDENTIFIER
      )
      .execute
      .first
    end

    def create_integration
      new_integration = AlertManagement::HttpIntegration.create(
        project_id: alert_service.project_id,
        name: 'HTTP endpoint',
        endpoint_identifier: AlertManagement::HttpIntegration::LEGACY_IDENTIFIER,
        active: alert_service.active,
        encrypted_token: alert_service.data.encrypted_token,
        encrypted_token_iv: alert_service.data.encrypted_token_iv
      )

      new_integration.persisted?
    end

    def update_integration_data(http_integration)
      http_integration.update(
        active: alert_service.active,
        encrypted_token: alert_service.data.encrypted_token,
        encrypted_token_iv: alert_service.data.encrypted_token_iv
      )
    end
  end
end