socket-request-server

Simple WebSocket request/response server

INSTALL

npm i --save socket-request-server

usage

basic

import server from 'socket-request-server'
server(
  { port: 6000, keepValue: false },
  {
    date: ({ send }) => response.send(new Date())
  }
)

Custom http server

import { server } from 'socket-request-server'
import { createServer } from 'http' // optional

const httpServer = createServer() // define your own http server
server(
  { httpServer, port: 6000 },
  {
    user: ({ email, password }, response) => {
      // response.connection.socket._peername
      if (!email || !password) {
        response.error(`Expected email & password to be defined`)
      } else {
        // do something
        response.send('some value')
      }
    }
  }
)

customEvent

import server from 'socket-request-server'

server(
  { port: 6000 },
  {
    // does nothing when a customEvent is detected
    ping: ({ email, password }, response) => {
      response.send(true)
    }
  }
)

const connection = server.connections()[0]
const messageId = uuid()

const data = JSON.stringify({
  url: 'ping',
  status: 200,
  value: message,
  id: messageId,
  customMessage: true
})

const onmessage = (message) => {
  let data
  if (message.type) {
    switch (message.type) {
      case 'binary':
        data = message.binaryData.toString()
        break
      case 'utf8':
        data = message.utf8Data
        break
    }
  }

  const { route, params, url, id } = JSON.parse(data)
  if (id === messageId) {
    // do something ...
    connection.removeListener('message', onmessage)
  }
}
connection.on('message', onmessage)
connection.send(data)
connection.publish('topic', message)