From 0160aad9b8b047f7c4cf65489728e3cb28c7d459 Mon Sep 17 00:00:00 2001
From: Valentin Genev <vgenev@gmail.com>
Date: Wed, 4 Mar 2020 15:45:46 +0200
Subject: [PATCH] Release/v9.3.1 snapshot (#193)

* added actions for separate position topics
---
 package-lock.json   |  2 +-
 package.json        |  5 +++--
 src/enums/events.js |  2 ++
 src/enums/kafka.js  | 16 ++++++++++++----
 4 files changed, 18 insertions(+), 7 deletions(-)

diff --git a/package-lock.json b/package-lock.json
index 4dfaa7a5..e1d78fa1 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,6 +1,6 @@
 {
   "name": "@mojaloop/central-services-shared",
-  "version": "9.3.0",
+  "version": "9.3.1-snapshot",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {
diff --git a/package.json b/package.json
index b174daba..793a1eae 100644
--- 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
index d3e76636..2d1321e9 100644
--- 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
index a145f5a6..a66aea99 100644
--- 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,