feat(message pact): add DSL for configuring Message Pact verifications

lib/pact/consumer/configuration/dsl.rb

@@ -1,7 +1,6 @@
 require 'pact/consumer/configuration/service_consumer'
 
 module Pact
-
   module Consumer
     module DSL
       def service_consumer name, &block

lib/pact/provider/configuration/dsl.rb

@@ -1,4 +1,5 @@
 require 'pact/provider/configuration/service_provider_dsl'
+require 'pact/provider/configuration/message_provider_dsl'
 
 module Pact
 
@@ -8,6 +9,10 @@ module DSL
       def service_provider name, &block
         Configuration::ServiceProviderDSL.build(name, &block)
       end
+
+      def message_provider name, &block
+        Configuration::MessageProviderDSL.build(name, &block)
+      end
     end
   end
-end
+end

lib/pact/provider/configuration/message_provider_dsl.rb

@@ -0,0 +1,32 @@
+require 'pact/provider/configuration/service_provider_dsl'
+
+module Pact
+  module Provider
+    module Configuration
+      class MessageProviderDSL < ServiceProviderDSL
+        class RackToMessageAdapter
+          def initialize(message_builder)
+            @message_builder = message_builder
+          end
+
+          def call(env)
+            request_body_json = JSON.parse(env['rack.input'].read)
+            contents = @message_builder.call(request_body_json['description'])
+            [200, {"Content-Type" => "application/json"}, [{ contents: contents }.to_json]]
+          end
+        end
+
+        def initialize name
+          super
+          @mapper_block = lambda { |args|  }
+        end
+
+        dsl do
+          def builder &block
+            self.app_block = lambda { RackToMessageAdapter.new(block)  }
+          end
+        end
+      end
+    end
+  end
+end

pact.gemspec

@@ -45,4 +45,5 @@ Gem::Specification.new do |gem|
   gem.add_development_dependency 'appraisal', '~> 2.2'
   gem.add_development_dependency 'conventional-changelog', '~> 1.3'
   gem.add_development_dependency 'bump', '~> 0.5'
+  gem.add_development_dependency 'pact-message'
 end

spec/support/message_spec_helper.rb

@@ -0,0 +1,41 @@
+require 'pact/message'
+
+# Example data store
+
+class DataStore
+  def self.greeting_recipient= greeting_recipient
+    @greeting_recipient = greeting_recipient
+  end
+
+  def self.greeting_recipient
+    @greeting_recipient
+  end
+end
+
+# Example message producer
+
+class BarProvider
+  def create_message
+    {
+      text: "Hello #{DataStore.greeting_recipient}"
+    }
+  end
+end
+
+# Provider states
+
+Pact.provider_states_for "Foo" do
+  provider_state "a world exists" do
+    set_up do
+      DataStore.greeting_recipient = "world"
+    end
+  end
+end
+
+CONFIG = {
+  "a message" => lambda { BarProvider.new.create_message }
+}
+
+Pact.message_provider "Bar" do
+  builder { |description| CONFIG[description].call }
+end

tasks/message-test.rake

@@ -0,0 +1,5 @@
+require 'pact/tasks'
+
+Pact::VerificationTask.new(:message) do | pact |
+  pact.uri 'spec/pacts/foo-bar-message.json', pact_helper: 'spec/support/message_spec_helper.rb'
+end

tasks/pact-test.rake

@@ -80,6 +80,7 @@ namespace :pact do
 		Rake::Task['pact:verify:term_v2'].execute
 		Rake::Task['pact:verify:test_app_with_provider_state_params'].execute
 		Rake::Task['pact:verify:test_app:wip'].execute
+		Rake::Task['pact:verify:message'].execute
 	end
 
 	desc "All the verification tests with active support loaded"