CHIEFSOFT\ameye
51 lines
1.4 KiB
JavaScript
51 lines
1.4 KiB
JavaScript
'use strict';
|
|
|
|
const request = require('request');
|
|
const db = require('../app/db')
|
|
const logger = require('../app/logger');
|
|
const KafkaConfig = require("../app/kconfig");
|
|
|
|
var ebroker = {
|
|
eventNewJobPublish: function (req, res, next) {
|
|
|
|
try {
|
|
const { message } = req.body;
|
|
// console.log('THIS-> req.body -> ', req.body);
|
|
const kafka_topic ="NEW_OFFER_"+ message.assign_mode;
|
|
const kafkaConfig = new KafkaConfig();
|
|
const messages = [{ key: "offer", value: JSON.stringify(message) }];
|
|
kafkaConfig.produce(kafka_topic, 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);
|
|
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;
|