lib/pact/app.rb in pact-1.1.0 vs lib/pact/app.rb in pact-1.1.1

@@ -5,16 +5,94 @@
 require 'rack/handler/webrick'
 
 module Pact
   class App < Thor
 
-    desc 'service', "starts a mock service"
+    desc 'verify', "Verify a pact"
+    method_option :pact_helper, aliases: "-h", desc: "Pact helper file", :required => true
+    method_option :pact_uri, aliases: "-p", desc: "Pact URI"
+
+    def verify
+      RunPactVerification.call(options)
+    end
+
+    desc 'service', "Start a mock service"
     method_option :port, aliases: "-p", desc: "Port on which to run the service"
     method_option :log, aliases: "-l", desc: "File to which to log output"
     method_option :quiet, aliases: "-q", desc: "If true, no admin messages will be shown"
 
     def service
+      RunStandaloneMockService.call(options)
+    end
+
+    private
+
+    def log message
+      puts message unless options[:quiet]
+    end
+  end
+
+  class RunPactVerification
+
+    attr_reader :options
+
+    def initialize options
+      @options = options
+    end
+
+    def self.call options
+      new(options).call
+    end
+
+
+    def call
+      setup_load_path
+      load_pact_helper
+      run_specs
+    end
+
+    private
+
+    def setup_load_path
+      require 'pact/provider/pact_spec_runner'
+      lib = Dir.pwd + "/lib" # Assume we are running from within the project root. RSpec is smarter about this.
+      $LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
+    end
+
+    def load_pact_helper
+      load options[:pact_helper]
+    end
+
+    def run_specs
+      exit_code = if options[:pact_uri]
+        run_with_pact_uri
+      else
+        run_with_configured_pacts
+      end
+      exit 1 unless exit_code == 0
+    end
+
+    def run_with_pact_uri
+      Pact::Provider::PactSpecRunner.new([{uri: options[:pact_uri]}], pact_spec_options).run
+    end
+
+    def run_with_configured_pacts
+      pact_verifications = Pact.configuration.pact_verifications
+      verification_configs = pact_verifications.collect { | pact_verification | { :uri => pact_verification.uri }}
+      raise "Please configure a pact to verify" if verification_configs.empty?
+      Pact::Provider::PactSpecRunner.new(verification_configs, options).run
+    end
+
+    def pact_spec_options
+      {criteria: SpecCriteria.call}
+    end
+
+  end
+
+  class RunStandaloneMockService
+
+    def self.call options
       service_options = {}
       if options[:log]
         log = File.open(options[:log], 'w')
         log.sync = true
         service_options[:log_file] = log
@@ -23,12 +101,28 @@
       port = options[:port] || FindAPort.available_port
       mock_service = Consumer::MockService.new(service_options)
       trap(:INT) { Rack::Handler::WEBrick.shutdown }
       Rack::Handler::WEBrick.run(mock_service, :Port => port, :AccessLog => [])
     end
+  end
 
-    private
-    def log message
-      puts message unless options[:quiet]
+  class SpecCriteria
+
+    def self.call
+      criteria = {}
+
+      description = ENV["PACT_DESCRIPTION"]
+      criteria[:description] = Regexp.new(description) if description
+
+      provider_state = ENV["PACT_PROVIDER_STATE"]
+      if provider_state
+        if provider_state.length == 0
+          criteria[:provider_state] = nil #Allow PACT_PROVIDER_STATE="" to mean no provider state
+        else
+          criteria[:provider_state] = Regexp.new(provider_state)
+        end
+      end
+
+      criteria
     end
   end
 end