consumer service

.gitignore

@@ -6,3 +6,5 @@ config.json
 docs
 *.env
 .env/
+.idea
+package-lock.json

api/controller.js

@@ -33,6 +33,17 @@ var controllers = {
             res.status(200).json({'status': 'OK', 'internal_return': 0, 'result_list': dist.result,'total_record': dist.total_record })
         });
     },
+
+    eventInterest: function(req, res) {
+        ebroker.eventInterest(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) {

api/routes.js

@@ -18,4 +18,7 @@ module.exports = function(app) {
      app.route('/flutterOkHook')
          .post(controller.flutterOkHook);
 
+    app.route('/eventInterest')
+        .post(controller.flutterOkHook);
+
 };

server.js

@@ -30,17 +30,14 @@ routes(app);
 
 // https://github.com/lemoncode21/nodejs-kafka.git
 
+//eventInterest
+
 
 kafka.consume("FLUTTER_PAYMENT_RECEIVED", (value) => {
-//txRef
-
    console.log("📨 Receive message xxxx: ", value);
-
    var obj = phpUnserialize(value);
    console.log(obj);
    console.log("📨 Receive message yyyy: ", obj.txRef);
-
-
 });
 
 app.listen(port, "0.0.0.0", function() {

service/ebroker.js

@@ -33,6 +33,32 @@ var ebroker = {
         next(null,  resultItem ); // pass control to the next handler
     },
 
+    eventInterest: function (req, res, next) {
+
+        try {
+            const { message } = req.body;
+            console.log('THIS-> req.body ->  ', req.body);
+            const kafkaConfig = new KafkaConfig();
+            const messages = [{ key: "interest", value: message }];
+
+            kafkaConfig.produce("INTEREST_MSG", messages).then(r =>{
+                console.log('THIS->RET->  ',r);
+            } );
+
+            res.status(200).json({
+                status: "Ok!",
+                message: "Message successfully send!",
+            });
+        } catch (error) {
+            console.log(error);
+        }
+
+        let resultItem ={
+            "result": [],
+            "total_record": 0
+        }
+        next(null,  resultItem ); // pass control to the next handler
+    },
     eventConsumer: function (req, res, next) {
 
         //console.log("REQ---->",req.body.uid);