Add latest changes from gitlab-org/gitlab@13-2-stable-ee

1 files changed, 66 insertions, 0 deletions

diff --git a/lib/pager_duty/webhook_payload_parser.rb b/lib/pager_duty/webhook_payload_parser.rb
new file mode 100644
index 00000000000..573fb36f0ca
--- /dev/null
+++ b/lib/pager_duty/webhook_payload_parser.rb
@@ -0,0 +1,66 @@
+# frozen_string_literal: true
+
+module PagerDuty
+  class WebhookPayloadParser
+    def initialize(payload)
+      @payload = payload
+    end
+
+    def self.call(payload)
+      new(payload).call
+    end
+
+    def call
+      Array(payload['messages']).map { |msg| parse_message(msg) }
+    end
+
+    private
+
+    attr_reader :payload
+
+    def parse_message(message)
+      {
+        'event' => message['event'],
+        'incident' => parse_incident(message['incident'])
+      }
+    end
+
+    def parse_incident(incident)
+      return {} if incident.blank?
+
+      {
+        'url' => incident['html_url'],
+        'incident_number' => incident['incident_number'],
+        'title' => incident['title'],
+        'status' => incident['status'],
+        'created_at' => incident['created_at'],
+        'urgency' => incident['urgency'],
+        'incident_key' => incident['incident_key'],
+        'assignees' => reject_empty(parse_assignees(incident)),
+        'impacted_services' => reject_empty(parse_impacted_services(incident))
+      }
+    end
+
+    def parse_assignees(incident)
+      Array(incident['assignments']).map do |a|
+        {
+          'summary' => a.dig('assignee', 'summary'),
+          'url' => a.dig('assignee', 'html_url')
+        }
+      end
+    end
+
+    def parse_impacted_services(incident)
+      Array(incident['impacted_services']).map do |is|
+        {
+          'summary' => is['summary'],
+          'url' => is['html_url']
+        }
+      end
+    end
+
+    def reject_empty(entities)
+      Array(entities).reject { |e| e['summary'].blank? && e['url'].blank? }
+    end
+  end
+end