flow

packages/db/src/index.js

@@ -1,7 +1,7 @@
 import {createDatabaseConnection} from './db';
 import createDockerContainer from './docker';
 
-export {DataTypes as Types, Op} from 'sequelize';
+export {DataTypes as Types, Op, default as Sequelize} from 'sequelize';
 
 export {ModelMap} from './db';
 export {default as Model} from './model';

packages/http/src/server.js

@@ -30,26 +30,42 @@ export const createHttpServer = async (latus) => {
   // eslint-disable-next-line no-param-reassign
   latus.config['%http'] = httpServer;
   httpServer.app = app;
-  app.use((req, res, next) => {
+  const requestMiddleware = (req, res, next) => {
     latus.invokeMiddleware('@latus/http/request', req, res, next);
-  });
+  };
   const routes = arrayFlatten(latus.invokeFlat('@latus/http/routes'));
-  routes.forEach(({method, path, handler}) => app[method](path, handler));
+  routes.forEach(({method, path, handler}) => app[method](path, requestMiddleware, handler));
   // Serve latus.
-  app.use(configMiddleware(latus));
-  app.use(modulesMiddleware(latus));
+  app.get('/latus.config.js', requestMiddleware, configMiddleware(latus));
+  app.get('/latus.js', requestMiddleware, modulesMiddleware(latus));
   // eslint-disable-next-line no-eval
   if ('production' !== eval('process.env.NODE_ENV')) {
     const proxy = httpProxy.createProxyServer({
       secure: false,
       target: `http://127.0.0.1:${devPort}`,
     });
+    proxy.on('proxyRes', async (proxyRes, req, res) => {
+      if ('text/html; charset=UTF-8' === proxyRes.headers['content-type']) {
+        requestMiddleware(req, res, () => {
+          res.setHeader('Content-Type', proxyRes.headers['content-type']);
+          proxyRes.pipe(res);
+        });
+      }
+      else {
+        res.setHeader(
+          'Content-Type',
+          // ???
+          '/__webpack_hmr' === req.url ? 'text/event-stream' : proxyRes.headers['content-type'],
+        );
+        proxyRes.pipe(res);
+      }
+    });
     proxy.on('error', (err, req, res) => {
       if (res instanceof ServerResponse) {
         res.status(502).end('Bad Gateway (WDS)');
       }
     });
-    app.all('*', (req, res) => proxy.web(req, res));
+    app.all('*', (req, res) => proxy.web(req, res, {selfHandleResponse: true}));
     httpServer.on('upgrade', (req, socket, head) => proxy.ws(req, socket, head));
     httpServer.on('close', () => proxy.close());
   }

packages/socket/src/packet/socket.io-parser.js

@@ -42,7 +42,14 @@ const Encoder = (latus) => class Encoder {
   pack(packet) {
     const packetId = packet.data[0];
     const Packet = fromId(latus, packetId);
-    return deflate(Packet.pack(packet));
+    try {
+      return deflate(Packet.pack(packet));
+    }
+    catch (error) {
+      // eslint-disable-next-line no-console
+      console.error(`Couldn't pack ${Packet.name}(${JSON.stringify(packet.data[1], null, 2)})`);
+      throw error;
+    }
   }
 
 };
@@ -70,14 +77,21 @@ const Decoder = (latus) => class Decoder extends decorate(class {}) {
     const view = new Uint8Array(packet);
     const packetId = view[0];
     const Packet = fromId(latus, packetId);
-    const unpacked = Packet.unpack(packet);
-    const {data} = unpacked;
-    this.emit('decoded', {
-      type: unpacked.type,
-      data: [packetId, data],
-      id: unpacked.id,
-      nsp: unpacked.nsp,
-    });
+    try {
+      const unpacked = Packet.unpack(packet);
+      const {data} = unpacked;
+      this.emit('decoded', {
+        type: unpacked.type,
+        data: [packetId, data],
+        id: unpacked.id,
+        nsp: unpacked.nsp,
+      });
+    }
+    catch (error) {
+      // eslint-disable-next-line no-console
+      console.error(`Couldn't unpack ${Packet.name}(${view})`);
+      throw error;
+    }
   }
 
   parseJSON(obj) {