From 918ae5e5be4e059c7e5d8626c7ab5dd243221472 Mon Sep 17 00:00:00 2001
From: Nick Cuthbert <nick@cuthbert.co.za>
Date: Fri, 22 Dec 2017 13:27:04 +0200
Subject: [PATCH] Bug fix for persistence engine

---
 lib/index.js                 | 16 ++++++++--------
 package.json                 |  2 +-
 test/postgres-persistence.js |  2 +-
 3 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/lib/index.js b/lib/index.js
index 06605d1..44376e4 100644
--- a/lib/index.js
+++ b/lib/index.js
@@ -72,17 +72,17 @@ class PostgresPersistenceEngine extends AbstractPersistenceEngine {
         created_at,   
         data,          
         tags          
-      ) VALUES ($1, $2, $3, $4, $5)
+      ) VALUES ($/key/, $/sequenceNumber/, $/createdAt/, $/data:json/, $/tags/)
       RETURNING ordering;
     `;
     return this.db.one(
-      query, [
-        persistedEvent.key,
-        persistedEvent.sequenceNumber,
-        persistedEvent.createdAt,
-        persistedEvent.data,
-        persistedEvent.tags
-      ]
+      query, {
+        key: persistedEvent.key,
+        sequenceNumber: persistedEvent.sequenceNumber,
+        createdAt: persistedEvent.createdAt,
+        data: persistedEvent.data,
+        tags: persistedEvent.tags
+      }
     );
   }
 
diff --git a/package.json b/package.json
index d0231d0..3534749 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "nact-persistence-postgres",
-  "version": "4.3.0",
+  "version": "4.3.1",
   "description": "nact-persistence-postgres ⇒ nact + postresql = your services have never been so persistent",
   "main": "lib/index.js",
   "scripts": {
diff --git a/test/postgres-persistence.js b/test/postgres-persistence.js
index b87b2ef..46b6271 100644
--- a/test/postgres-persistence.js
+++ b/test/postgres-persistence.js
@@ -54,7 +54,7 @@ describe('PostgresPersistenceEngine', function () {
       const engine = new PostgresPersistenceEngine(connectionString);
       await retry(async () => {
         const event1 = new PersistedEvent({ message: 'hello' }, 1, 'test', ['a', 'b', 'c']);
-        const event2 = new PersistedEvent({ message: 'goodbye' }, 2, 'test');
+        const event2 = new PersistedEvent([ 'message', 'goodbye' ], 2, 'test');
         const event3 = new PersistedEvent({ message: 'hello' }, 1, 'test2');
         await engine.persist(event1);
         await engine.persist(event2);