const express = require('express');
const http = require('http');
const socketIo = require('socket.io');
const axios = require('axios');
const port = 4001;
const index = require('./routes/index');
const app = express();
app.use(index);
const server = http.createServer(app);
const io = socketIo(server);
// socket-io
io.on('connection', socket => {
console.log('New connection');
socket.emit('init data', { data: '123' }); // server emits to clients
socket.on('disconnect', () => console.log('Client disconnected')); // on client
});
// REST
app.post('/status', (req,res) => {
...
io.emit('update data',{ data: newData });
res.send('OK');
});
// Server
server.listen(port, () => console.log(`Listening on port ${port}`));