CHIEFSOFT\ameye
88 lines
2.9 KiB
JavaScript
88 lines
2.9 KiB
JavaScript
const express = require('express');
|
|
const cors = require('cors');
|
|
const cookieParser = require('cookie-parser');
|
|
|
|
const dotenv = require('dotenv');
|
|
const env = dotenv.config();
|
|
|
|
const bodyParser = require('body-parser');
|
|
const logger = require('./app/logger');
|
|
const port = process.env.PORT || 3000;
|
|
const KafkaConfig = require("./app/kconfig");
|
|
const io = require("socket.io-client");
|
|
|
|
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 socket = io.connect(process.env.SOCKET_URL);
|
|
//const socket = io.connect("http://10.10.10.13:5005");
|
|
|
|
logger.info('***** Server process.env.SOCKET_URL ********* ', process.env.SOCKET_URL);
|
|
|
|
|
|
|
|
// respond with "hello world" when a GET request is made to the homepage
|
|
app.get('/broadcast/general', (req, res) => {
|
|
logger.info('***** Server PROVISION GENERAL MESSAGE ********* ');
|
|
const room = 'merms_global_events';
|
|
const message_action = 'refresh_all_actions';
|
|
socket.emit("join_room", room);
|
|
socket.emit("send_message", {message_action, room});
|
|
res.send('hello world')
|
|
})
|
|
|
|
app.get('/broadcast/selected', (req, res) => {
|
|
logger.info('***** Server PROVISION SELECTED MESSAGE ********* ');
|
|
const room = 'merms_selected_events';
|
|
const message_action = 'refresh_selected_actions';
|
|
socket.emit("join_room", room);
|
|
socket.emit("send_message", {message_action, room});
|
|
res.send('hello world')
|
|
})
|
|
|
|
app.get('/broadcast/provisioning', (req, res) => {
|
|
logger.info('***** Server PROVISION STEPS MESSAGE ********* ');
|
|
|
|
// const room = req.query.product_uid;
|
|
// socket.emit("join_room", room);
|
|
// socket.emit("send_message", {message_action, room});
|
|
|
|
const message_action = 'refresh_provision_actions';
|
|
const room = "PROVISION_" + req.query.product_uid
|
|
logger.info("SENDING TO ROOM ",room);
|
|
socket.emit("join_room", room);
|
|
socket.emit("send_message", {message_action, room});
|
|
|
|
res.send('hello world')
|
|
})
|
|
|
|
// // respond with "hello world" when a GET request is made to the homepage
|
|
// app.get('/broadcast/general', (req, res) => {
|
|
// logger.info('***** Server PROVISION GENERAL MESSAGE ********* ');
|
|
// const room = 'merms_global_events';
|
|
// const message_action = 'refresh_all_actions';
|
|
// socket.emit("join_room", room);
|
|
// socket.emit("send_message", { message_action , room });
|
|
// res.send('hello world')
|
|
// })
|
|
|
|
const routes = require('./api/routes');
|
|
routes(app);
|
|
|
|
app.listen(port, "0.0.0.0", function () {
|
|
logger.info('***** Server started on port: ' + port + ' *****');
|
|
});
|