소켓io 구현

@@ -2,7 +2,9 @@ const fs = require('fs');
 const path = require('path');
 const path = require('path');
 const express = require('express');
 const express = require('express');
 const exphbs = require('express-handlebars');
 const exphbs = require('express-handlebars');
+const http = require('http');
 const app = require('./server');
 const app = require('./server');
+const socket = require('./socket');
 
 
 const hbs = exphbs.create({
 const hbs = exphbs.create({
     helpers: {
     helpers: {
@@ -26,4 +28,9 @@ fs.readdirSync(path.resolve(__dirname, 'routes')).forEach((name) => {
 
 
 app.use(express.static(path.resolve(__dirname, 'public')));
 app.use(express.static(path.resolve(__dirname, 'public')));
 
 
-app.listen(3429);
+let server = http.createServer(app);
+socket.init(http);
+
+server.listen(3429, () => {
+    console.log('Listening on port 3429');
+});

+const sio = require('socket.io');
+const db = require('./db');
+
+let io;
+module.exports = {
+    init(http) {
+        io = sio(http);
+        io.on('connection', (socket) => {
+            socket.on('init', (id) => {
+                db.get('subthread').find({parent: id}, {sort: '+_id'}).each((thread, _) => {
+                    socket.emit('thread', thread);
+                });
+            });
+        });
+    }
+};