X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=src%2Fdb%2Fpostgres%2Flistener.js;h=1ce3b3b3a99616ac8a645bcd3b7686ffa8dcc967;hb=8cd88ab4087a7fab2ccd6e231c64d7f0f1299f26;hp=4baf5d082de3bc1d507ef441ddc795af014e8470;hpb=33897b863a84ff7d248888f83dc100a96cd9bc49;p=websub-hub

diff --git a/src/db/postgres/listener.js b/src/db/postgres/listener.js
index 4baf5d0..1ce3b3b 100644
--- a/src/db/postgres/listener.js
+++ b/src/db/postgres/listener.js
@@ -23,7 +23,10 @@ class PostgresListener {
     this.logger = logger;
     this.db = db;
 
-    this.options = Object.assign({}, defaultOptions, options);
+    this.options = {
+      ...defaultOptions,
+      ...options,
+    };
     this.notificationEventName = 'notification';
 
     this.connection = null;
@@ -83,7 +86,7 @@ class PostgresListener {
 
   /**
    * Notify callback.
-   * @param {Object} data
+   * @param {object} data listener notification
    */
   async _onNotification(data) {
     const _scope = _fileScope('_onNotification');
@@ -98,8 +101,8 @@ class PostgresListener {
 
   /**
    * Notify callback and attempt to reconnect.
-   * @param {*} error
-   * @param {*} event
+   * @param {*} error error
+   * @param {*} event event
    */
   async _onConnectionLost(error, event) {
     const _scope = _fileScope('_onConnectionLost');
@@ -122,8 +125,8 @@ class PostgresListener {
 
   /**
    * Schedule an attempt to establish a connection.
-   * @param {Number} delay
-   * @param {Number} retriesRemaining
+   * @param {number} delay reconnect delay
+   * @param {number} retriesRemaining retry countdown
    */
   async _reconnect(delay, retriesRemaining) {
     const _scope = _fileScope('_reconnect');