49 lines
1.0 KiB
JavaScript
49 lines
1.0 KiB
JavaScript
const {res404, res500} = require('./../plugins/controllersHelperFunctions')
|
|
const {_sr} = require('./../plugins/serverResponses')
|
|
let server = null
|
|
global.io = null
|
|
module.exports.send = [
|
|
async (req, res) => {
|
|
try {
|
|
if (!server) {
|
|
server = res.connection.server
|
|
io = socket(server)
|
|
io.on('connection', async function (socket) {
|
|
|
|
socket.on('order', msg => {
|
|
io.emit('order', {
|
|
input: msg?.input,
|
|
userId: req?.user?._id
|
|
});
|
|
})
|
|
|
|
socket.on('disconnect', () => {
|
|
console.log('user disconnected');
|
|
});
|
|
})
|
|
}
|
|
return res.json({msg: 'server is set'})
|
|
} catch (error) {
|
|
console.log(error.message)
|
|
return res500(res, _sr['fa'].response.unknownError)
|
|
}
|
|
}
|
|
]
|
|
|
|
module.exports.test = [
|
|
async (req, res) => {
|
|
try {
|
|
|
|
io.emit('order', {
|
|
|
|
});
|
|
|
|
return res.json('test')
|
|
|
|
} catch (e) {
|
|
console.log(e.message)
|
|
return res500(res, _sr['fa'].response.problem)
|
|
}
|
|
}
|
|
]
|