adding brokers to service

api/controller.js

@@ -3,6 +3,8 @@
 const properties = require('../package.json')
 const redeem = require('../service/redeem');
 const wallets = require('../service/wallets');
+const ebroker  = require('../service/ebroker');
+
 const logger = require('../app/logger');
 
 var controllers = {
@@ -20,10 +22,18 @@ var controllers = {
        // res.json(dist);
         res.status(200).json({'status': 'OK', 'internal_return': 0, 'result_list': dist.result,'total_record': dist.total_record })
     });
-   }, 
+   },
 
-   
-   getUsersKidsWallets: function(req, res) {
+    flutterOkHook: function(req, res) {
+        ebroker.eventPublish(req, res, function(err, dist) {
+            if (err) {
+                res.send(err);
+            }
+            // res.json(dist);
+            res.status(200).json({'status': 'OK', 'internal_return': 0, 'result_list': dist.result,'total_record': dist.total_record })
+        });
+    },
+    getUsersKidsWallets: function(req, res) {
     wallets.getuserkidswallet(req, res, function(err, dist) {
         if (err) {
             res.send(err);

api/routes.js

@@ -15,4 +15,7 @@ module.exports = function(app) {
      app.route('/getescrows')
         .get(controller.getUsersEscrows);
 
+     app.route('/flutterOkHook')
+         .get(controller.flutterOkHook);
+
 };

package.json

@@ -17,6 +17,7 @@
       "cors": "^2.8.5",
       "cookie-parser": "^1.4.6",
       "express": "^4.17.1",
+      "kafkajs": "^2.2.4",
       "openapi-types": "^10.0.0",
       "pg": "8.7.1",
       "pg-pool": "^3.5.1",

service/ebroker.js

@@ -0,0 +1,36 @@
+'use strict';
+
+const request = require('request');
+const db = require('../app/db')
+const logger = require('../app/logger');
+
+var ebroker = {
+    eventPublish: function (req, res, next) {
+
+        //console.log("REQ---->",req.body.uid);
+        var data = {
+            "uid": req.body.uid,
+            "member_id": req.body.member_id,
+            "limit": (req.body.limit != null && req.body.limit !== "") ? req.body.limit : 20,
+            "sessionid": req.body.sessionid,
+            "page": req.body.page
+        };
+
+
+    },
+
+    eventConsumer: function (req, res, next) {
+
+        //console.log("REQ---->",req.body.uid);
+        var data = {
+            "uid": req.body.uid,
+            "member_id": req.body.member_id,
+            "limit": (req.body.limit != null && req.body.limit !== "") ? req.body.limit : 20,
+            "sessionid": req.body.sessionid,
+            "page": req.body.page
+        };
+
+
+    }
+};
+module.exports = ebroker;