Started work on webhooks

Author: bethesque

db/migrations/12_create_webhooks_table.rb

@@ -0,0 +1,19 @@
+Sequel.migration do
+  change do
+    create_table(:webhooks) do
+      primary_key :id
+      String :method, null: false
+      String :url, null: false
+      String :body
+      foreign_key :consumer_id, :pacticipants, null: false
+      foreign_key :provider_id, :pacticipants, null: false
+    end
+
+    create_table(:webhooks_headers) do
+      String :name, null: false
+      String :value
+      foreign_key :webhook_id, :webhooks, null: false
+      primary_key [:webhook_id, :name], :name=>:webhooks_headers_pk
+    end
+  end
+end

lib/pact_broker/models/webhook.rb

@@ -0,0 +1,44 @@
+module PactBroker
+
+  module Models
+
+    class Webhook
+      attr_accessor :id, :consumer_id, :provider_id, :request
+    end
+
+    class WebhookRequest
+      attr_accessor :method, :url, :headers, :body
+
+      def execute
+        #TODO make it work with https
+        #TODO validation of method
+        req = http_request
+
+        headers.each do | header |
+          req[header.name] = header.value
+        end
+        req.body = body
+        response = Net::HTTP.start(uri.hostname, uri.port) do |http|
+          http.request req
+        end
+
+      end
+
+      private
+
+      def http_request
+        Net::HTTP.const_get(method.capitalize).new(uri)
+      end
+
+      def uri
+        URI(url)
+      end
+    end
+
+    class WebhookRequestHeader
+      attr_accessor :id, :name, :value
+    end
+
+  end
+
+end

lib/pact_broker/models/webhook_request.rb

@@ -0,0 +1,65 @@
+require 'pact_broker/models/webhook_request_header'
+require 'pact_broker/logging'
+
+module PactBroker
+
+  module Models
+
+    class WebhookRequestError < StandardError; end
+
+    class WebhookRequest
+
+      include PactBroker::Logging
+
+      attr_accessor :method, :url, :headers, :body
+
+      def initialize attributes = {}
+        @method = attributes.fetch(:method)
+        @url = attributes.fetch(:url)
+        @headers = attributes[:headers]
+        @body = attributes[:body]
+      end
+
+      def execute
+        #TODO make it work with https
+        #TODO validation of method
+        req = http_request
+
+        headers.each do | header |
+          req[header.name] = header.value
+        end
+        req.body = body
+
+        logger.info "Making webhook request #{to_s}"
+        response = Net::HTTP.start(uri.hostname, uri.port) do |http|
+          http.request req
+        end
+
+        logger.info "Received response status=#{response.code} body=#{response.body}"
+
+        if Net::HTTPOK === response
+          true
+        else
+          raise WebhookRequestError.new("status=#{response.code} body=#{response.body}")
+        end
+
+      end
+
+      private
+
+      def to_s
+        "#{method.upcase} #{url}, headers=#{headers}, body=#{body}"
+      end
+
+      def http_request
+        Net::HTTP.const_get(method.capitalize).new(url)
+      end
+
+      def uri
+        URI(url)
+      end
+    end
+
+  end
+
+end

lib/pact_broker/models/webhook_request_header.rb

@@ -0,0 +1,13 @@
+module PactBroker
+  module Models
+    class WebhookRequestHeader
+
+      attr_accessor :name, :value
+
+      def initialize name, value
+        @name = name
+        @value = value
+      end
+    end
+  end
+end

pact_broker.gemspec

@@ -38,5 +38,6 @@ Gem::Specification.new do |gem|
   gem.add_development_dependency 'fakefs', '~>0.4'
   gem.add_development_dependency 'rspec-fire', '~>1.2.0'
   gem.add_development_dependency 'mysql2', '~>0.3.15'
+  gem.add_development_dependency 'webmock'
 
 end

spec/lib/pact_broker/models/webhook_request_spec.rb

@@ -0,0 +1,66 @@
+require 'spec_helper'
+require 'pact_broker/models/webhook_request'
+require 'webmock/rspec'
+
+module PactBroker
+
+  module Models
+
+    describe WebhookRequest do
+
+      subject { WebhookRequest.new(method: 'POST',
+        url: 'http://example.org/hook',
+        headers: [WebhookRequestHeader.new('Content-type', 'text/plain')],
+        body: 'body')}
+
+      describe "execute" do
+
+        let!(:http_request) do
+          stub_request(:post, "http://example.org/hook").
+            with(:headers => {'Content-Type'=>'text/plain'}, :body => 'body').
+            to_return(:status => 200, :body => "respbod", :headers => {})
+        end
+
+        it "executes the configured request" do
+          subject.execute
+          expect(http_request).to have_been_made
+        end
+
+        it "logs the request" do
+          allow(PactBroker.logger).to receive(:info)
+          expect(PactBroker.logger).to receive(:info).with(/POST.*example.*text.*body/)
+          subject.execute
+        end
+
+        it "logs the response" do
+          allow(PactBroker.logger).to receive(:info)
+          expect(PactBroker.logger).to receive(:info).with(/response.*200.*respbod/)
+          subject.execute
+        end
+
+        context "when the request is successful" do
+          it "returns true" do
+            expect(subject.execute).to be true
+          end
+        end
+
+        context "when the request is not successful" do
+
+          let!(:http_request) do
+            stub_request(:post, "http://example.org/hook").
+              with(:headers => {'Content-Type'=>'text/plain'}, :body => 'body').
+              to_return(:status => 500, :body => "An error")
+          end
+
+          it "raises an error" do
+            expect { subject.execute }.to raise_error WebhookRequestError, /500.*An error/
+          end
+        end
+
+      end
+
+    end
+
+  end
+
+end