chore(release): Release v0.1.2 - See CHANGELOG

restorecommerce · Feb 7, 2022 · d6774cb · d6774cb
1 parent 16c9afd
commit d6774cb
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 57 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,7 @@
+## 0.1.2 (February 7th, 2022)
+
+- up dependencies
+
 ## 0.1.1 (September 13th, 2021)
 
 - up dependencies

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restorecommerce/resource-srv",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "description": "Restore Commerce Resource Microservice",
   "main": "lib/start.js",
   "author": "n-fuse GmbH",
@@ -22,7 +22,7 @@
     "@restorecommerce/grpc-client": "^0.2.14",
     "@restorecommerce/kafka-client": "^0.2.29",
     "@restorecommerce/protos": "^0.5.0",
-    "@restorecommerce/resource-base-interface": "^0.2.3",
+    "@restorecommerce/resource-base-interface": "^0.2.5",
     "@restorecommerce/service-config": "^0.4.23",
     "lodash": "^4.17.21",
     "redis": "^4.0.3",

diff --git a/src/worker.ts b/src/worker.ts
@@ -109,11 +109,13 @@ export class Worker {
 
     await events.start();
     this.offsetStore = new OffsetStore(events, cfg, logger);
-    let redisClient: any;
+    let redisClient: RedisClientType<any, any>;
     if (cfg.get('redis')) {
       const redisConfig = cfg.get('redis');
       redisConfig.db = cfg.get('redis:db-indexes:db-resourcesCounter');
       redisClient = redis.createClient(redisConfig);
+      redisClient.on('error', (err) => logger.error('Redis Client Error', err));
+      await redisClient.connect();
     }
     const fieldGeneratorConfig: any = cfg.get('fieldHandlers:fieldGenerators');
     const bufferHandlerConfig: any = cfg.get('fieldHandlers:bufferFields');
@@ -129,6 +131,8 @@ export class Worker {
     const redisConfig = cfg.get('redis');
     redisConfig.db = cfg.get('redis:db-indexes:db-subject');
     const redisClientSubject: RedisClientType<any, any> = redis.createClient(redisConfig);
+    await redisClientSubject.on('error', (err) => logger.error('Redis Client Error', err));
+    await redisClientSubject.connect();
     for (let resourceType in resources) {
       const resourceCfg = resources[resourceType];
       const resourcesServiceConfigPrefix = resourceCfg.resourcesServiceConfigPrefix;