Sock-state NPM

Overview

Sock State allows you to create Redux-like stores that can be updated and subscribed to over Web Sockets.

This enables distributed computing with Javascript without having to rely on workarounds such as shared stdout streams, HTTP long-polling, and so forth.

Usage Overview

Create a Reducer just like you do with Redux:

export const chatAppReducer = (state, action) => {
  if (state == null)
    return { messages: [] }

  switch (action.type) {
    case 'addMessage':
      return { messages: state.messages.concat(action.payload) }
    default:
      return state
  }
}

Create a Store Server with a Topic that uses the Reducer:

import { createStoreServer } from 'sock-state'

const server = createStoreServer({
  host: 'localhost',
  port: 4000,
  topics: { chatApp: { reducer: chatAppReducer } },
})

Create Store Clients and connect them to the Store Server:

import { createNodeStoreClient } from 'sock-state/lib/client/node'

const addMessage = message => ({
  type: 'addMessage',
  payload: message,
})

const client1 = createNodeStoreClient({ host: 'localhost', port: 4000 })
const client2 = createNodeStoreClient({ host: 'localhost', port: 4000 })

client1.connect()
client2.connect()

Subscribe Store Clients to Topics (using the Reducer), and listen for Topic events (e.g. state changes):

const client1Topic = storeClient.topic('chatApp')
const client2Topic = storeClient.topic('chatApp')

client1Topic.on('state-change', chatAppReducer, state => {
  console.log('client 1 new state:', state.messages)
})
client2Topic.on('state-change', chatAppReducer, state => {
  console.log('client 2 new state:', state.messages)
})

Dispatch actions to Topics to update their state:

const addMessage = message => ({
  type: 'addMessage',
  payload: message,
})

client2Topic.dispatch(addMessage('Hello Client 2'))
client2Topic.dispatch(addMessage('Hello Client 1'))

Dynamic Topics

Topics can be added to and removed from the server. Any clients subscribed to a topic that is deleted will be notified and automatically unsusbcribe from it. Basic example:

const server = createStoreServer({
  host: 'localhost',
  port: 4000,
})
server.addTopic({ name: 'chatApp', reducer: ... })
server.deleteTopic('chatApp')

Accepting/Rejecting Connections

Connections to the server can be accepted or rejected conditionally. This can be used for basic authentication. Basic example:

const server = createStoreServer({
  host: 'localhost',
  port: 4000,
  connectionAcceptor: (webSocket, request) => {
    const isIpAllowed = checkIp(request.socket.remoteAddress)
    return {
      accepted: isIpAllowed,
      reason: isIpAllowed ? undefined : 'IP Address banned',
    }
  }
})

Event Listening

Various events can be listened for. Basic example:

const storeServer = createStoreServer({
  host: 'localhost',
  port: 4000,
  reporter: {
    ...,
    onClientAccepted: client => console.log(`Client ${client.shortUuid} connected (IP: ${client.req.socket.remoteAddress}).`),
    ...
  },
})

storeServer.server.on('message', (msgData, client) => {
  console.log(`Message recieved from client ${client.shortUuid}: ${msgData}`)
})