Middleware for Redux that routes actions to and from a server

distributed-state-index.js

import { createSocketMiddleware } from 'redux-socket-middleware'

const store = createStore(
  reducer,
  applyMiddleware(
    createSocketMiddleware((action) => store.dispatch(action), 'http://localhost:3030')
  )
)

redux-socket-middleware.js

import io from 'socket.io-client'

const getMiddleware = (socket) => (store) => (next) => (action) => {
  socket.emit('action', action)
  return next(action)
}

const bindDispatch = (socket, dispatch) => {
  socket.on('action', (action) => {
    !action.remote && dispatch(Object.assign({}, action, {remote: true}))
  })
}

const init = (socket) => socket.emit('init')

export const createSocketMiddleware = (dispatch, url = null, preload = true) => {
  const socket = io.connect(url)
  bindDispatch(socket, dispatch)
  preload && init(socket)
  return getMiddleware(socket)
}