Expose server handlers

[kinday]

This PR extracts WebSocket connection callback into separate handleWebsocketConnection method to BaseServer. This allows to completely bypass internal HTTP server setup and use any external server instead with minor boilerplate.

Example of integration with Fastify:

import fastifyPlugin from 'fastify-plugin'
import * as Logux from '@logux/server'

export default fastifyPlugin<{ path: string }>((fastify, options) => {
  const loguxServer = new Logux.BaseServer({
    disableHttpServer: true,
    minSubprotocol: 1,
    subprotocol: 1
  })

  loguxServer.on('authenticated', (client, latency) => {
    fastify.log.info({ key: client.key, latency, nodeId: client.nodeId, userId: client.userId }, 'client authenticated')
  })

  loguxServer.on('clientError', (error) => {
    fastify.log.error(error, 'client error')
  })

  loguxServer.on('connected', (client) => {
    fastify.log.info({ nodeId: client.nodeId, key: client.key, userId: client.userId }, 'client connected')
  })

  loguxServer.on('disconnected', (client) => {
    fastify.log.info({ nodeId: client.nodeId, key: client.key, userId: client.userId }, 'client disconnected')
  })

  loguxServer.on('error', (error) => {
    fastify.log.error(error, 'failed to process action')
  })

  loguxServer.on('fatal', (error) => {
    fastify.log.fatal(error, 'Logux crashed')
  })

  loguxServer.on('subscribing', (action) => {
    fastify.log.info(action, 'client subscribing')
  })

  loguxServer.on('report', (event, data) => {
    fastify.log.trace(data === undefined ? {} : data, `received "${event}" event`)
  })

  loguxServer.auth(async () => {
    // ...
  })

  loguxServer.channel('user/:id', {
    // ...
  })

  fastify.get(options.path, { websocket: true }, (socket, req) => {
    loguxServer.handleWebsocketConnection(socket, req.raw)
  })
})

P.S.: pnpm added packageManager field automatically and I captured it as a separate commit, can drop if this is not desireable.

[ai]

Do you need a release of this API? (for now you can use private addClient())

I am planning to add some extra features before next major release.

[kinday]

Appreciate the fast turnaround. 💖

The project I’m using that in is in early stages so I don’t mind using the fork for now.