added example for a node message provider

thombergs · thombergs · commit 375b46309b5f · 2018-11-12T23:00:33.000+01:00
diff --git a/pact/pact-node-messages/package-lock.json b/pact/pact-node-messages/package-lock.json
diff --git a/pact/pact-node-messages/package.json b/pact/pact-node-messages/package.json
@@ -4,13 +4,14 @@
   "description": "",
   "main": "index.js",
   "scripts": {
-    "test:consumer": "mocha consumer/*.spec.js"
+    "test:consumer": "mocha src/consumer/*.spec.js",
+    "test:provider": "mocha src/provider/*.spec.js",
+    "publish:pact": "node pact/publish.js"
   },
   "author": "Tom Hombergs",
   "license": "MIT",
   "devDependencies": {
     "@pact-foundation/pact": "^7.0.3",
-    "chai": "^4.2.0",
     "mocha": "^5.2.0"
   }
 }
diff --git a/pact/pact-node-messages/pact/publish.js b/pact/pact-node-messages/pact/publish.js
@@ -0,0 +1,13 @@
+let publisher = require('@pact-foundation/pact-node');
+let path = require('path');
+
+let opts = {
+    providerBaseUrl: 'http://localhost:8080',
+    pactFilesOrDirs: [path.resolve(process.cwd(), 'pacts')],
+    pactBroker: 'https://adesso.pact.dius.com.au/',
+    pactBrokerUsername: process.env.PACT_USERNAME,
+    pactBrokerPassword: process.env.PACT_PASSWORD,
+    consumerVersion: '2.0.0'
+};
+
+publisher.publishPacts(opts).then(() => console.log("Pacts successfully published"));
diff --git a/pact/pact-node-messages/pacts/node-message-consumer-node-message-provider.json b/pact/pact-node-messages/pacts/node-message-consumer-node-message-provider.json
@@ -0,0 +1,63 @@
+{
+  "consumer": {
+    "name": "node-message-consumer"
+  },
+  "provider": {
+    "name": "node-message-provider"
+  },
+  "messages": [
+    {
+      "description": "a hero created message",
+      "providerStates": [
+
+      ],
+      "contents": {
+        "id": 42,
+        "name": "Superman",
+        "superpower": "flying",
+        "universe": "DC"
+      },
+      "matchingRules": {
+        "body": {
+          "$.id": {
+            "matchers": [
+              {
+                "match": "type"
+              }
+            ]
+          },
+          "$.name": {
+            "matchers": [
+              {
+                "match": "type"
+              }
+            ]
+          },
+          "$.superpower": {
+            "matchers": [
+              {
+                "match": "type"
+              }
+            ]
+          },
+          "$.universe": {
+            "matchers": [
+              {
+                "match": "regex",
+                "regex": "^(DC|Marvel)$"
+              }
+            ]
+          }
+        }
+      },
+      "metaData": {
+        "content-type": "application/json"
+      }
+    }
+  ],
+  "metadata": {
+    "pactSpecification": {
+      "version": "3.0.0"
+    }
+  }
+}
diff --git a/pact/pact-node-messages/src/common/hero-created-message.js b/pact/pact-node-messages/src/common/hero-created-message.js
diff --git a/pact/pact-node-messages/src/consumer/hero-event-handler.js b/pact/pact-node-messages/src/consumer/hero-event-handler.js
diff --git a/pact/pact-node-messages/src/consumer/hero-event-handler.spec.js b/pact/pact-node-messages/src/consumer/hero-event-handler.spec.js
@@ -14,9 +14,9 @@ describe("message consumer", () => {
 
     describe("'hero created' message Handler", () => {
 
-        it("should accept a valid 'hero created' message", (done) => {
-            return messagePact
-                .expectsToReceive("a 'hero created' message")
+        it("should accept a valid hero created message", (done) => {
+            messagePact
+                .expectsToReceive("a hero created message")
                 .withContent({
                     id: Matchers.like(42),
                     name: Matchers.like("Superman"),
@@ -27,7 +27,7 @@ describe("message consumer", () => {
                     "content-type": "application/json",
                 })
                 .verify(synchronousBodyHandler(handleHeroCreatedEvent))
-                .then(done());
+                .then(done, (error) => done(error));
         });
 
     });
diff --git a/pact/pact-node-messages/src/provider/hero-event-producer.js b/pact/pact-node-messages/src/provider/hero-event-producer.js
@@ -0,0 +1,9 @@
+const HeroCreatedMessage = require('../common/hero-created-message');
+
+function produceHeroCreatedEvent(id) {
+    return new Promise((resolve, reject) => {
+        resolve({foo: "this is an invalid message that does not match the contract!"});
+    });
+}
+
+module.exports = produceHeroCreatedEvent;
diff --git a/pact/pact-node-messages/src/provider/hero-event-producer.spec.js b/pact/pact-node-messages/src/provider/hero-event-producer.spec.js
@@ -0,0 +1,33 @@
+const {MessageProviderPact} = require('@pact-foundation/pact');
+const produceHeroCreatedEvent = require('./hero-event-producer');
+const path = require('path');
+
+describe("message producer", () => {
+
+    const messagePact = new MessageProviderPact({
+        messageProviders: {
+            "a hero created message": () => produceHeroCreatedEvent(42),
+        },
+        log: path.resolve(process.cwd(), "logs"),
+        logLevel: "debug",
+        provider: "node-message-provider",
+        pactBrokerUrl: "https://adesso.pact.dius.com.au",
+        pactBrokerUsername: process.env.PACT_USERNAME,
+        pactBrokerPassword: process.env.PACT_PASSWORD,
+        publishVerificationResult: true,
+        providerVersion: '1.0.0',
+        tags: ['latest']
+    });
+
+
+    describe("'hero created' message producer", () => {
+
+        it("should create a valid hero created message", (done) => {
+            messagePact
+                .verify()
+                .then(done, (error) => done(error));
+        }).timeout(5000);
+
+    });
+
+});
