chore: Release v1.2.5 - See CHANGELOG

restorecommerce · Nov 23, 2023 · 7c7a776 · 7c7a776
1 parent 726cba5
commit 7c7a776
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 7 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,7 @@
+## 1.2.5 (November 23rd, 2023)
+
+- add redis job store and register job meta for emitting jobDone / jobFailed (for processing pending notifications job) 
+
 ## 1.2.4 (November 23rd, 2023)
 
 - added separate queue for processing pending notification jobs

diff --git a/cfg/config.json b/cfg/config.json
@@ -4,7 +4,10 @@
     "offsetStoreInterval": 1000,
     "db-indexes": {
       "db-offsetStore": 0,
-      "db-subject": 4
+      "db-subject": 4,
+      "db-reccurTime": 7,
+      "db-repeatJobId": 8,
+      "db-jobStore": 1
     }
   },
   "client": {
@@ -38,8 +41,11 @@
       "versionResponse": {
         "messageObject": "io.restorecommerce.commandinterface.CommandResponse"
       },
-      "queuedJob": {
-        "messageObject": "io.restorecommerce.job.ScheduledJob"
+      "jobDone": {
+        "messageObject": "io.restorecommerce.job.JobDone"
+      },
+      "jobFailed": {
+        "messageObject": "io.restorecommerce.job.JobFailed"
       },
       "topics": {
         "notificationReq": {

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restorecommerce/notification-srv",
-  "version": "1.2.4",
+  "version": "1.2.5",
   "description": "Restorecommerce notification microservice",
   "main": "lib/start.js",
   "author": "n-fuse GmbH",

diff --git a/src/service.ts b/src/service.ts
@@ -33,9 +33,12 @@ import {
 } from '@restorecommerce/rc-grpc-clients/dist/generated-server/io/restorecommerce/resource_base';
 import * as fs from 'fs';
 import { runWorker } from '@restorecommerce/scs-jobs';
+import {
+  protoMetadata as jobMeta
+} from '@restorecommerce/rc-grpc-clients/dist/generated-server/io/restorecommerce/job';
 
 
-registerProtoMeta(NotificationReqMeta, CommandInterfaceMeta, reflectionMeta);
+registerProtoMeta(NotificationReqMeta, CommandInterfaceMeta, reflectionMeta, jobMeta);
 const SEND_MAIL_EVENT = 'sendEmail';
 const HEALTH_CHECK_CMD_EVENT = 'healthCheckCommand';
 const VERSION_CMD_EVENT = 'versionCommand';