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 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.0.0.32:5005");
//

// respond with "hello world" when a GET request is made to the homepage
app.get('/broadcast/general', (req, res) => {
   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) => {
   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')
})


const routes = require('./api/routes');
routes(app);

app.listen(port, "0.0.0.0", function() {
   logger.info('***** Server started on port: ' + port + ' *****');
});