Showing
2 changed files
with
2 additions
and
2 deletions
... | @@ -27,9 +27,8 @@ fs.readdirSync(path.resolve(__dirname, 'routes')).forEach((name) => { | ... | @@ -27,9 +27,8 @@ fs.readdirSync(path.resolve(__dirname, 'routes')).forEach((name) => { |
27 | }); | 27 | }); |
28 | 28 | ||
29 | let server = http.createServer(app); | 29 | let server = http.createServer(app); |
30 | -socket.init(http); | 30 | +socket.init(server); |
31 | 31 | ||
32 | -//app.use(express.static(path.resolve(__dirname, 'public'))); | ||
33 | 32 | ||
34 | server.listen(3429, () => { | 33 | server.listen(3429, () => { |
35 | console.log('Listening on port 3429'); | 34 | console.log('Listening on port 3429'); | ... | ... |
... | @@ -7,6 +7,7 @@ module.exports = { | ... | @@ -7,6 +7,7 @@ module.exports = { |
7 | io = sio(http); | 7 | io = sio(http); |
8 | io.on('connection', (socket) => { | 8 | io.on('connection', (socket) => { |
9 | socket.on('init', (id) => { | 9 | socket.on('init', (id) => { |
10 | + console.log(`init ${id}`); | ||
10 | db.get('subthread').find({parent: id}, {sort: '+_id'}).each((thread, _) => { | 11 | db.get('subthread').find({parent: id}, {sort: '+_id'}).each((thread, _) => { |
11 | socket.emit('thread', thread); | 12 | socket.emit('thread', thread); |
12 | }); | 13 | }); | ... | ... |
-
Please register or login to post a comment