feat(webhook status): add endpoint for triggered webhook execution logs

Author: bethesque

db/migrations/38_create_triggered_webhooks_table.rb

@@ -12,6 +12,7 @@
       String :status, null: false
       DateTime :created_at, null: false
       DateTime :updated_at, null: false
+      add_index [:webhook_id, :trigger_uuid], unique: true, name: 'uq_triggered_webhook_wi'
       add_index [:pact_publication_id, :webhook_id, :trigger_uuid], unique: true, name: 'uq_triggered_webhook_ppi_wi'
     end
   end

lib/pact_broker/api.rb

@@ -52,6 +52,7 @@ module PactBroker
         add ['webhooks', 'provider', :provider_name, 'consumer', :consumer_name, 'status' ], Api::Resources::PactWebhooksStatus, {resource_name: "pact_webhooks"}
 
         add ['webhooks', :uuid ], Api::Resources::Webhook, {resource_name: "webhook"}
+        add ['webhooks', :uuid, 'trigger', :trigger_uuid, 'logs' ], Api::Resources::TriggeredWebhookLogs, {resource_name: "triggered_webhook_logs"}
         add ['webhooks', :uuid, 'execute' ], Api::Resources::WebhookExecution, {resource_name: "execute_webhook"}
         add ['webhooks'], Api::Resources::Webhooks, {resource_name: "webhooks"}
 

lib/pact_broker/api/resources/triggered_webhook_logs.rb

@@ -0,0 +1,36 @@
+require 'pact_broker/api/resources/base_resource'
+require 'pact_broker/webhooks/triggered_webhook'
+
+module PactBroker
+  module Api
+    module Resources
+
+      class TriggeredWebhookLogs < BaseResource
+
+        def content_types_provided
+          [["text/plain", :to_text]]
+        end
+
+        def allowed_methods
+          ["GET"]
+        end
+
+        def resource_exists?
+          triggered_webhook
+        end
+
+        def to_text
+          # Too simple to bother putting into a service
+          triggered_webhook.webhook_executions.collect(&:logs).join("\n")
+        end
+
+        def triggered_webhook
+          @triggered_webhook ||= begin
+            criteria = {webhook_uuid: identifier_from_path[:uuid], trigger_uuid: identifier_from_path[:trigger_uuid]}
+            PactBroker::Webhooks::TriggeredWebhook.where(criteria).single_record
+          end
+        end
+      end
+    end
+  end
+end

spec/lib/pact_broker/api/resources/triggered_webhook_logs_spec.rb

@@ -0,0 +1,28 @@
+require 'pact_broker/api/resources/triggered_webhook_logs'
+
+module PactBroker
+  module Api
+    module Resources
+      describe TriggeredWebhookLogs do
+
+        let(:td) { TestDataBuilder.new }
+
+        before do
+          td.create_pact_with_hierarchy
+            .create_webhook(uuid: "5432")
+            .create_triggered_webhook(trigger_uuid: "1234")
+            .create_webhook_execution(logs: "foo")
+            .create_webhook_execution(logs: "bar")
+        end
+
+        let(:path) { "/webhooks/5432/trigger/1234/logs" }
+
+        subject { get path; last_response }
+
+        it "returns the concatenated webhook execution logs" do
+          expect(subject.body).to eq "foo\nbar"
+        end
+      end
+    end
+  end
+end