Redux WebSocket middleware

socketMiddleware.js

import { Socket } from './Socket';

export const createSocketMiddleware = (host, port) => store => {
  const socket = new Socket(host, port);

  socket.onopen = () => {
    store.dispatch({ type: "SOCKET_OPEN" });
  }

  socket.onclose = () => {
    store.dispatch({ type: "SOCKET_CLOSED" });
  }

  socket.onmessage = (args) => {
    let msg;
    try {
      console.log(args);
      msg = JSON.parse(args[0].data);
    } catch (err) {
      console.error(err);
      msg = args[0].data;
      console.log(args[0], msg);
    } finally {
      console.log("got a message: ", msg);
      store.dispatch({ type: "RECEIVE_MESSAGE", payload: msg });
    }
  }

  socket.onerror = () => {
    store.dispatch({ type: "SOCKET_ERROR" });
  }

  return next => action => {
    if (action.meta && action.meta === "socket") {
      switch (action.type) {
        case "CONNECT": {
          socket.connect();
          break;
        }
        case "DISCONNECT": {
          socket.disconnect();
          break;
        }
        case "SEND_MESSAGE": {
          socket.send(action.payload);
          break;
        }
        default: break;
      }
    }
    next(action);
  }
}

silky smooth