Thingz

Author: ncthbrt

lib/index.js

@@ -26,12 +26,14 @@ class PostgresPersistenceEngine extends AbstractPersistenceEngine {
   }
 
   static mapDbModelToSnapshotDomainModel (dbSnapshot) {
-    return new PersistedSnapshot(
-      dbSnapshot.data,
-      Number.parseInt(dbSnapshot.sequence_nr),
-      dbSnapshot.persistence_key,
-      Number.parseInt(dbSnapshot.created_at)
-    );
+    if (dbSnapshot) {
+      return new PersistedSnapshot(
+        dbSnapshot.data,
+        Number.parseInt(dbSnapshot.sequence_nr),
+        dbSnapshot.persistence_key,
+        Number.parseInt(dbSnapshot.created_at)
+      );
+    }
   }
 
   events (persistenceKey, offset = 0, limit = null, tags) {
@@ -108,12 +110,12 @@ class PostgresPersistenceEngine extends AbstractPersistenceEngine {
         RETURNING ordering;
       `;
     return this.db.one(
-        query, [
-          persistedSnapshot.key,
-          persistedSnapshot.sequenceNumber,
-          persistedSnapshot.createdAt,
-          persistedSnapshot.data
-        ]
+      query, [
+        persistedSnapshot.key,
+        persistedSnapshot.sequenceNumber,
+        persistedSnapshot.createdAt,
+        persistedSnapshot.data
+      ]
     );
   }
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "nact-persistence-postgres",
-  "version": "4.0.0",
+  "version": "4.0.1",
   "description": "nact-persistence-postgres ⇒ nact + postresql = your services have never been so persistent",
   "main": "lib/index.js",
   "scripts": {

test/postgres-persistence.js

@@ -4,6 +4,7 @@ const chai = require('chai');
 const chaiAsPromised = require('chai-as-promised');
 chai.use(chaiAsPromised);
 chai.should();
+const expect = chai.expect;
 const { Promise } = require('bluebird');
 const delay = Promise.delay;
 const { PostgresPersistenceEngine } = require('../lib');
@@ -117,6 +118,11 @@ describe('PostgresPersistenceEngine', function () {
       const result = await engine.latestSnapshot('test3');
       result.should.deep.equal(snapshot3);
     });
+
+    it('should be able to correct handle cases where no snapshot is available', async function () {
+      const result = await engine.latestSnapshot('test4');
+      expect(result).to.equal(undefined);
+    });
   });
 
   describe('#events', async function () {