index.js

import debug from "debug";
import fs from "fs";

const logError = debug("tetris:error");
const logInfo = debug("tetris:info");

const initApp = (app, params, cb) => {
  const {host, port} = params;
  const handler = (req, res) => {
    console.log("handler");
  };

  app.on("request", handler);

  app.listen({host, port}, () => {
    logInfo(`tetris listen on ${params.url}`);
    cb();
  });
};

// const initEngine = io => {
//   io.on("connection", socket => {
//     logInfo("socket connected: " + socket.id);
//     socket.on("action", action => {
//       switch (action.type) {
//         case "server/ping": {
//           socket.emit("action", {type: "pong"});
//         }
//       }
//     });
//   });
// };

export const create = params => {
  return new Promise((resolve, reject) => {
    const app = require("http").createServer();

    initApp(app, params, () => {
      // const io = require("socket.io")(app);
      // const stop = cb => {
      //   io.close();
      //   app.close(() => {
      //     app.unref();
      //   });
      //   logInfo("engine stopped");
      //   cb();
      // };
      // initEngine(io);
      // resolve({stop});
    });
  });
};