Bug fix for persistence engine

Author: ncthbrt

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
+      }
     );
   }
 

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": {

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);