From 880b1a36bbf0c62c75d57d0db3e683e120467759 Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Sun, 25 Aug 2024 10:55:05 -0400
Subject: [PATCH] docker process path

---
 app/assign_action.js | 19 +++++++++++++++++++
 server.js            |  7 +++----
 2 files changed, 22 insertions(+), 4 deletions(-)
 create mode 100644 app/assign_action.js

diff --git a/app/assign_action.js b/app/assign_action.js
new file mode 100644
index 0000000..ea491ae
--- /dev/null
+++ b/app/assign_action.js
@@ -0,0 +1,19 @@
+const db = require('../app/db')
+const logger = require('../app/logger');
+const redeem = require("../service/redeem");
+
+
+var assign_action ={
+
+    processLinedJobs: function(req) {
+
+        console.log("Receive NEW_OFFER_110022 message processLinedJobs ************************ : ", req);
+        //  if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
+        //     console.log("We need contact people that did this job: ", obj.depend_uid);
+        //
+        //  }
+},
+
+};
+
+module.exports = assign_action;
\ No newline at end of file
diff --git a/server.js b/server.js
index 60f373d..702459a 100644
--- a/server.js
+++ b/server.js
@@ -7,6 +7,8 @@ const port = process.env.PORT || 3000;
 const KafkaConfig = require("./app/kconfig");
 const phpUnserialize = require('phpunserialize');
 
+const  assign_action = require('./app/assign_action');
+
 const kafka = new KafkaConfig();
 
 const app = express();
@@ -48,10 +50,7 @@ kafka.consume("NEW_OFFER_110022", (value) => {
       console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
       const obj = JSON.parse(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);
-      //
-      //  }
+      assign_action.processLinedJobs(ojb);
    } catch (exceptionVar) {
       console.log(" Error ", exceptionVar.message);
    }