fix(messages): prevent message proxy from running twice

- Add state handler to message pact example

Author: mefellows

examples/messages/provider/message-provider.spec.ts

@@ -8,6 +8,13 @@ describe("Message provider tests", () => {
     messageProviders: {
       "a request for a dog": () => createDog(27),
     },
+    stateHandlers: {
+      "some state": () => {
+        // TODO: prepare system useful in order to create a dog
+        console.log('State handler: setting up "some state" for interaction')
+        return Promise.resolve(`state set to create a dog`)
+      },
+    },
     log: path.resolve(process.cwd(), "logs"),
     logLevel: "INFO",
     provider: "MyJSMessageProvider",

src/dsl/options.ts

@@ -84,7 +84,6 @@ export interface MessageProviderOptions {
   // Choices: 'overwrite' | 'update', 'none', defaults to 'overwrite'
   pactfileWriteMode?: PactfileWriteMode
 
-  providerStatesSetupUrl?: string
   pactBrokerUsername?: string
   pactBrokerPassword?: string
   customProviderHeaders?: string[]

src/messageProviderPact.ts

@@ -3,15 +3,15 @@
  */
 
 import { omit, isEmpty } from "lodash"
-import { Verifier } from "./dsl/verifier"
-import { Message, MessageDescriptor } from "./dsl/message"
+import { MessageDescriptor } from "./dsl/message"
 import logger from "./common/logger"
 import { VerifierOptions } from "@pact-foundation/pact-node"
 import { MessageProviderOptions } from "./dsl/options"
 import serviceFactory from "@pact-foundation/pact-node"
 import * as express from "express"
 import * as http from "http"
 import { MessageProvider } from "./pact"
+import { qToPromise } from "./common/utils"
 
 const bodyParser = require("body-parser")
 
@@ -67,7 +67,7 @@ export class MessageProviderPact {
         ...{ providerBaseUrl: "http://localhost:" + server.address().port },
       } as VerifierOptions
 
-      return new Verifier(opts).verifyProvider()
+      return qToPromise<any>(serviceFactory.verifyPacts(opts))
     }
   }