From c5c67a841ecc97a88fe304202e07600197f405b5 Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Sun, 25 Aug 2024 11:04:24 -0400
Subject: [PATCH] see external call

---
 app/assign_action.js | 10 ++++------
 server.js            |  6 ++++--
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/app/assign_action.js b/app/assign_action.js
index 76375a3..70b6ef6 100644
--- a/app/assign_action.js
+++ b/app/assign_action.js
@@ -1,18 +1,16 @@
 const db = require('../app/db')
 const logger = require('../app/logger');
-const redeem = require("../service/redeem");
-
 
 var assign_action ={
 
-    processLinedJobs(req) {
+    processLinedJobs(value) {
 
-        console.log("Receive NEW_OFFER_110022 message processLinedJobs ************************ : ", req);
+        console.log("Receive NEW_OFFER_110022 message processLinedJobs ************************ : ", revalueq);
         //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
         //     console.log("We need contact people that did this job: ", obj.depend_uid);
         //
-        //  }
-},
+    //  }
+    },
 
 };
 
diff --git a/server.js b/server.js
index 702459a..76b11ba 100644
--- a/server.js
+++ b/server.js
@@ -47,10 +47,12 @@ kafka.consume("NEW_OFFER_110011", (value) => {
 
 kafka.consume("NEW_OFFER_110022", (value) => {
    try {
-      console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
+     // console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
       const obj = JSON.parse(value);
-      console.log(  obj);
+      console.log( "**Receive NEW_OFFER_110022 message : ", obj);
+      console.log("START -----------------------------------------");
       assign_action.processLinedJobs(ojb);
+      console.log("END   -----------------------------------------");
    } catch (exceptionVar) {
       console.log(" Error ", exceptionVar.message);
    }