first commit

server.js

@@ -0,0 +1,48 @@
+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
+
+
+kafka.consume("FLUTTER_PAYMENT_RECEIVED", (value) => {
+//txRef
+
+   console.log("📨 Receive message xxxx: ", value);
+
+   var obj = phpUnserialize(value);
+   console.log(obj);
+   console.log("📨 Receive message yyyy: ", obj.txRef);
+
+
+});
+
+app.listen(port, "0.0.0.0", function() {
+   logger.info('***** Server started on port: ' + port + ' *****');
+});