Method setupSocket

src/utils/pipeTransport.ts:183–210

* Shared handler for both UDS and TCP sockets.

(socket: Socket)

   * Shared handler for both UDS and TCP sockets.
   */
  private setupSocket(socket: Socket): void {
    this.clients.add(socket)
    this.emit('connection', socket)

    attachNdjsonFramer<PipeMessage>(socket, msg => {
      this.emit('message', msg)
      const reply = (replyMsg: PipeMessage) => {
        replyMsg.from = replyMsg.from ?? this.name
        replyMsg.ts = replyMsg.ts ?? new Date().toISOString()
        if (!socket.destroyed) {
          socket.write(JSON.stringify(replyMsg) + '\n')
        }
      }
      for (const handler of this.handlers) {
        handler(msg, reply)
      }
    })

    socket.on('close', () => {
      this.clients.delete(socket)
      this.emit('disconnect', socket)
    })

    socket.on('error', err => {
      this.clients.delete(socket)
      logError(err)
    })
  }

  /**
   * Start listening for incoming connections.