flow: fixes

packages/core/src/gather.js

@@ -10,7 +10,7 @@ export const gatherWithLatus = (
   context,
   {
     transformer = camelCase,
-  },
+  } = {},
 ) => (latus) => (
   Object.fromEntries(context.keys().map((path) => {
     const M = context(path).default;

packages/redux/src/index.js

@@ -1,4 +1,4 @@
-import {ensureUniqueReduction} from '@latus/core';
+import {ensureUniqueReduction, gatherWithLatus} from '@latus/core';
 
 import configureStore from './store';
 
@@ -17,7 +17,13 @@ export default {
   hooks: {
     '@latus/core/starting': async (latus) => {
       latus.set('%slices', await ensureUniqueReduction(latus, '@latus/redux/slices'));
-      latus.set('%store', await configureStore(latus));
+      const defaultState = 'client' === process.env.SIDE
+        ? latus.get('@latus/redux/client.defaultState')
+        : {};
+      latus.set('%store', await configureStore(latus, {defaultState}));
     },
+    '@latus/socket/packets': gatherWithLatus(
+      require.context('./packets', false, /\.js$/),
+    ),
   },
 };

packages/redux/src/server.js

@@ -3,12 +3,9 @@ import {ensureUniqueReduction} from '@latus/core';
 export default {
   hooks: {
     '@latus/http/plugins': async (req, latus) => ({
-      '@latus/redux/client': req
+      '@latus/redux/client': {
-        ? {
+        defaultState: await ensureUniqueReduction(latus, '@latus/redux/defaultState', req),
-          defaultState: await ensureUniqueReduction(latus, '@latus/redux/defaultState', req),
+      },
-        }
-        : {}
-      ,
     }),
   },
 };

packages/redux/src/store.js

@@ -3,7 +3,7 @@ import reduceReducers from 'reduce-reducers';
 
 import effectsMiddleware from './effects';
 
-export default async function configureStore(latus) {
+export default async function configureStore(latus, {defaultState = {}}) {
   const options = {
     enhancers: [
       '@latus/redux/defaultEnhancers',
@@ -14,7 +14,6 @@ export default async function configureStore(latus) {
     ],
   };
   latus.invokeFlat('@latus/redux/store', options);
-  const {defaultState} = latus.config['@latus/redux/client'];
   const slices = latus.get('%slices');
   const reducers = latus.invokeFlat('@latus/redux/reducers').concat(combineReducers(slices));
   const reducer = reduceReducers({}, ...reducers);

packages/socket/src/socket-server.js

@@ -1,9 +1,13 @@
+import D from 'debug';
 import proxyaddr from 'proxy-addr';
 import SocketIoServer from 'socket.io';
 
+import normalize from './normalize';
 import ServerSocket from './socket';
 import SocketIoParser from './packet/socket.io-parser';
 
+const debug = D('@latus/socket/server/sockets');
+
 export default class SocketServer {
 
   constructor(httpServer, latus) {
@@ -56,9 +60,22 @@ export default class SocketServer {
     this.latus.invokeSequential('@latus/socket/connect', serverSocket);
   }
 
-  send(packet, channel = '/') {
+  static send(latus, nsp, packetOrDehydrated) {
+    const packet = normalize(latus, packetOrDehydrated);
+    debug('sending packet %s(%j)', packet.constructor.type, packet.data);
     const {id} = packet.constructor;
-    this.io.sockets.to(channel).binary(true).emit(id, packet.data);
+    nsp.binary(true).emit(id, packet.data);
+  }
+
+  send(packet) {
+    return this.constructor.send(this.latus, this.io.sockets, packet);
+  }
+
+
+  to(room) {
+    return {
+      send: (packet) => this.constructor.send(this.latus, this.io.of(room), packet),
+    };
   }
 
 }