From 0bbb4edc088901016bf38685491cd9a9da6ebd98 Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Fri, 5 Jul 2024 19:17:39 -0400
Subject: [PATCH] adding brokers to service

---
 api/controller.js  | 16 +++++++++++++---
 api/routes.js      |  3 +++
 package.json       |  1 +
 service/ebroker.js | 36 ++++++++++++++++++++++++++++++++++++
 4 files changed, 53 insertions(+), 3 deletions(-)
 create mode 100644 service/ebroker.js

diff --git a/api/controller.js b/api/controller.js
index 994dea0..2505cd2 100644
--- a/api/controller.js
+++ b/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);
diff --git a/api/routes.js b/api/routes.js
index 81657d7..45853b7 100644
--- a/api/routes.js
+++ b/api/routes.js
@@ -15,4 +15,7 @@ module.exports = function(app) {
      app.route('/getescrows')
         .get(controller.getUsersEscrows);
 
+     app.route('/flutterOkHook')
+         .get(controller.flutterOkHook);
+
 };
\ No newline at end of file
diff --git a/package.json b/package.json
index e77d1b0..7c628cb 100644
--- a/package.json
+++ b/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",
diff --git a/service/ebroker.js b/service/ebroker.js
new file mode 100644
index 0000000..57200bd
--- /dev/null
+++ b/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;