Integrate Socket Stream with Socket.IO

[LefanTan]

Hi folks!

I'm curious if anyone have setup socket.io-stream (https://www.npmjs.com/package/socket.io-stream) with TsED's SocketIO implementation before?

[Romakita]

Hello @LefanTan
Actually, you can use that manually, by using the $onConnection hook:

@SocketService("/room")
@SocketUseBefore(AuthSocketMiddleware)
@SocketUseAfter(ErrorHandlerSocketMiddleware)
export class RoomWS {
  // tslint:disable-next-line: no-unused-variable
  constructor(@IO private io: Server) {}

  $onConnection(socket: IOSocket, nsp: Namespace) {
    ss(socket).on('profile-image', this.handleStream.bind(this));
  }
  
  handleStream(stream, data) {
      var filename = path.basename(data.name);
      stream.pipe(fs.createWriteStream(filename));
  }
}

See you
Romain