From 2fd5878cee94dac134a77af214e44ff7d01af7cc Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Sun, 25 Aug 2024 09:28:25 -0400
Subject: [PATCH] Add more event

---
 server.js | 64 ++++++++++++++++++++++++++++++++++++++++++++++---------
 1 file changed, 54 insertions(+), 10 deletions(-)

diff --git a/server.js b/server.js
index c7b1c40..60f373d 100644
--- a/server.js
+++ b/server.js
@@ -32,17 +32,60 @@ routes(app);
 
 //eventInterest
 
+kafka.consume("NEW_OFFER_110011", (value) => {
+   try {
+      console.log("Receive NEW_OFFER_110011 message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
+   } catch (exceptionVar) {
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
 kafka.consume("NEW_OFFER_110022", (value) => {
    try {
       console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
       const obj = JSON.parse(value);
-      //var obj = phpUnserialize(value);
-    // var obj = JSON.stringify(value);
-     console.log(  obj);
-     //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
-     //     console.log("We need contact people that did this job: ", obj.depend_uid);
-     //
-     //  }
+      console.log(  obj);
+      //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
+      //     console.log("We need contact people that did this job: ", obj.depend_uid);
+      //
+      //  }
+   } catch (exceptionVar) {
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
+kafka.consume("NEW_OFFER_110033", (value) => {
+   try {
+      console.log("Receive NEW_OFFER_110033 message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
+   } catch (exceptionVar) {
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
+
+kafka.consume("NEW_OFFER_110055", (value) => {
+   try {
+      console.log("Receive NEW_OFFER_110055 message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
+   } catch (exceptionVar) {
+      console.log(" Error ", exceptionVar.message);
+   }
+});
+
+kafka.consume("SENDMONEY_RECEIVED", (value) => {
+   try {
+      console.log("Receive SENDMONEY_RECEIVED message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
+
    } catch (exceptionVar) {
       console.log(" Error ", exceptionVar.message);
    }
@@ -51,6 +94,8 @@ kafka.consume("NEW_OFFER_110022", (value) => {
 kafka.consume("INTEREST_MSG", (value) => {
    try {
       console.log("Receive INTEREST_MSG message xxxx: ", value);
+      const obj = JSON.parse(value);
+      console.log(  obj);
       // var obj = phpUnserialize(value);
       // console.log(obj);
 
@@ -62,7 +107,8 @@ kafka.consume("INTEREST_MSG", (value) => {
 kafka.consume("FLUTTER_PAYMENT_RECEIVED", (value) => {
    try {
       console.log("Receive FLUTTER_PAYMENT_RECEIVED message xxxx: ", value);
-      var obj = phpUnserialize(value);
+      // var obj = phpUnserialize(value);
+      const obj = JSON.parse(value);
       console.log(obj);
       console.log("Receive message yyyy: ", obj.txRef);
    } catch (exceptionVar) {
@@ -71,8 +117,6 @@ kafka.consume("FLUTTER_PAYMENT_RECEIVED", (value) => {
 });
 
 
-
-
 app.listen(port, "0.0.0.0", function() {
    logger.info('***** Server started on port: ' + port + ' *****');
 });