module update

Author: iyerrama29

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@contentstack/webhook-listener",
-  "version": "0.0.1",
-  "description": "HTTP web server that listens to Contentstack webhooks. This is part of Contentstack DataSync.",
+  "version": "1.0.0",
+  "description": "HTTP web server that listens to Contentstack webhooks. This is part of Contentstack DataSync",
   "main": "./dist",
   "types": "./typings",
   "homepage": "https://www.contentstack.com/docs/guide/synchronization/contentstack-datasync",
@@ -43,10 +43,10 @@
   "devDependencies": {
     "@types/basic-auth": "^1.1.2",
     "@types/node": "^10.12.2",
-    "winston": "^3.1.0",
-    "jest": "^23.6.0",
+    "jest": "^24.8.0",
     "rimraf": "^2.6.2",
     "supertest": "^3.3.0",
-    "typescript": "^3.2.2"
+    "typescript": "^3.2.2",
+    "winston": "^3.1.0"
   }
 }

src/index.ts

@@ -7,14 +7,15 @@
 'use strict';
 
 import { debug as Debug } from 'debug';
-import { merge as _merge } from 'lodash';
+import { merge } from 'lodash';
 import { createListener } from './core';
 import { defaultConfig } from './defaults';
 import { logger as log, setLogger } from './logger';
 
 const debug = Debug('webhook:listener');
 let notify;
 let config: any = {};
+let appConfig: any = defaultConfig
 
 /**
  * Register a function that will get called when webhook is triggered.
@@ -38,40 +39,49 @@ export function register(consumer: any) {
  * @returns {Promise} Promise object represents http.Server
  */
 export function start(userConfig: any, customLogger?: any) {
-  if (customLogger) {
-    setLogger(customLogger);
-  }
   return new Promise((resolve, reject) => {
-    debug('start called with %O', userConfig);
-    validateConfig(userConfig);
-    // Override default with user config
-    if (userConfig) {
-      config = _merge({}, defaultConfig, userConfig);
-    } else {
-      log.info('Starting listener with default configs');
-      config = defaultConfig;
-    }
+    try {
+      if (customLogger) {
+        setLogger(customLogger);
+      }
+      debug('start called with %O', userConfig);
+      appConfig = merge(appConfig, userConfig)
+      validateConfig(appConfig);
 
-    if (!notify) {
-      log.error(
-        'Aborting start of webhook listener, since no function is provided to notify.',
-      );
-      return reject(
-        new Error(
-          `Aborting start of webhook listener, since no function is provided to notify.`,
-        ),
-      );
-    }
+      if (!notify) {
+        log.error(
+          'Aborting start of webhook listener, since no function is provided to notify.',
+        );
+        return reject(
+          new Error(
+            `Aborting start of webhook listener, since no function is provided to notify.`,
+          ),
+        );
+      }
 
-    debug('starting with config: ' + JSON.stringify(config));
-    const port = process.env.PORT || config.listener.port;
-    const server = createListener(config, notify).listen(port, () => {
-      log.info(`Server running at port ${port}`);
-    });
-    return resolve(server);
+      debug('starting with config: ' + JSON.stringify(appConfig));
+      const port = process.env.PORT || appConfig.listener.port;
+      const server = createListener(appConfig, notify).listen(port, () => {
+        log.info(`Server running at port ${port}`);
+      });
+      return resolve(server);
+    } catch (error) {
+      return reject(error)
+    }
   });
 }
 
+/**
+ * @public
+ * @method setConfig
+ * @description
+ * Sets listener library's configuration
+ * @param config Listener lib config
+ */
+export const setConfig = (config) => {
+  appConfig = merge(appConfig, config)
+}
+
 /**
  * Get configuration.
  */