fix(server): restored server messages
This commit is contained in:
@ -3,12 +3,31 @@ const spiderCall = require('./spider')
|
||||
const dbPatcher = require('./dbPatcher')
|
||||
const startSphinx = require('./sphinx')
|
||||
|
||||
const http = require('http')
|
||||
const express = require('express');
|
||||
const app = express();
|
||||
const server = http.Server(app);
|
||||
const io = require('socket.io')(server);
|
||||
|
||||
server.listen(appConfig.httpPort);
|
||||
console.log('Listening web server on', appConfig.httpPort, 'port')
|
||||
|
||||
app.use(express.static('web', {index: false}));
|
||||
|
||||
const socketMessages = {}
|
||||
|
||||
io.on('connection', (socket) =>
|
||||
{
|
||||
for(const message in socketMessages)
|
||||
{
|
||||
socket.on(message, socketMessages[message])
|
||||
}
|
||||
})
|
||||
|
||||
sphinx = startSphinx(() => {
|
||||
dbPatcher(() => {
|
||||
spider = spiderCall((...data) => {
|
||||
|
||||
}, (message, callback) => {
|
||||
|
||||
spider = spiderCall((...data) => io.sockets.emit(...data), (message, callback) => {
|
||||
socketMessages[message] = callback
|
||||
}, './', '0.7.1', 'development')
|
||||
}, null, sphinx)
|
||||
}, './', () => {})
|
Reference in New Issue
Block a user