Release/v9.3.1 snapshot (#193)

* added actions for separate position topics
mojaloop · Mar 4, 2020 · 0160aad · 0160aad
1 parent 3983b4f
commit 0160aad
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 7 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@mojaloop/central-services-shared",
-  "version": "9.3.0",
+  "version": "9.3.1-snapshot",
   "description": "Shared code for central services",
   "main": "src/index.js",
   "scripts": {
@@ -54,7 +54,8 @@
     "immutable": "3.8.2",
     "lodash": "4.17.15",
     "mustache": "4.0.0",
-    "raw-body": "2.4.1"
+    "raw-body": "2.4.1",
+    "winston": "^3.2.1"
   },
   "devDependencies": {
     "@hapi/hapi": "19.1.1",

diff --git a/src/enums/events.js b/src/enums/events.js
@@ -67,6 +67,8 @@ const Event = {
     LIMIT_ADJUSTMENT: 'limit-adjustment',
     LOOKUP: 'lookup',
     POSITION: 'position',
+    POSITION_PREPARE: 'position-prepare',
+    POSITION_FULFIL: 'position-fulfil',
     PREPARE: 'prepare',
     PREPARE_DUPLICATE: 'prepare-duplicate',
     PROCESSING: 'processing',

diff --git a/src/enums/kafka.js b/src/enums/kafka.js
@@ -142,11 +142,11 @@ const TopicMap = {
   position: {
     'bulk-commit': {
       functionality: transferEventType.TRANSFER,
-      action: transferEventAction.POSITION
+      action: transferEventAction.POSITION_FULFIL
     },
     'bulk-prepare': {
       functionality: transferEventType.TRANSFER,
-      action: transferEventAction.POSITION
+      action: transferEventAction.POSITION_PREPARE
     },
     'bulk-timeout-received': {
       functionality: transferEventType.TRANSFER,
@@ -158,11 +158,19 @@ const TopicMap = {
     },
     prepare: {
       functionality: transferEventType.TRANSFER,
-      action: transferEventAction.POSITION
+      action: transferEventAction.POSITION_PREPARE
     },
     commit: {
       functionality: transferEventType.TRANSFER,
-      action: transferEventAction.POSITION
+      action: transferEventAction.POSITION_FULFIL
+    },
+    'position-prepare': {
+      functionality: transferEventType.TRANSFER,
+      action: transferEventAction.POSITION_PREPARE
+    },
+    'position-fulfil': {
+      functionality: transferEventType.TRANSFER,
+      action: transferEventAction.POSITION_FULFIL
     },
     'timeout-reserved': {
       functionality: transferEventType.TRANSFER,