Files
WrenchEventConsumer/server.js
T
CHIEFSOFT\ameye 4033e32fba New consumer
2024-08-25 05:01:11 -04:00

77 lines
2.1 KiB
JavaScript

const express = require('express');
const cors = require('cors');
const cookieParser = require('cookie-parser');
const bodyParser = require('body-parser');
const logger = require('./app/logger');
const port = process.env.PORT || 3000;
const KafkaConfig = require("./app/kconfig");
const phpUnserialize = require('phpunserialize');
const kafka = new KafkaConfig();
const app = express();
// create application/json parser
var jsonParser = bodyParser.json(); // express.json();
// create application/x-www-form-urlencoded parser
var urlencodedParser = bodyParser.urlencoded({ extended: false }); // express.bodyParser({extended: true});
app.use(urlencodedParser);
app.use(jsonParser);
app.use(cors());
app.use(cookieParser());
// parse application/vnd.api+json as json
app.use(bodyParser.json({ type: 'application/vnd.api+json' }))
const routes = require('./api/routes');
routes(app);
// https://github.com/lemoncode21/nodejs-kafka.git
//eventInterest
kafka.consume("NEW_OFFER_110022", (value) => {
try {
console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
var obj = phpUnserialize(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);
}
} catch (exceptionVar) {
console.log(" Error ", exceptionVar.message);
}
});
kafka.consume("INTEREST_MSG", (value) => {
try {
console.log("Receive INTEREST_MSG message xxxx: ", value);
var obj = phpUnserialize(value);
console.log(obj);
} catch (exceptionVar) {
console.log(" Error ", exceptionVar.message);
}
});
kafka.consume("FLUTTER_PAYMENT_RECEIVED", (value) => {
try {
console.log("Receive FLUTTER_PAYMENT_RECEIVED message xxxx: ", value);
var obj = phpUnserialize(value);
console.log(obj);
console.log("Receive message yyyy: ", obj.txRef);
} catch (exceptionVar) {
console.log("Error ", exceptionVar.message);
}
});
app.listen(port, "0.0.0.0", function() {
logger.info('***** Server started on port: ' + port + ' *****');
});