Class SocketLatest

packages/webapp-next/common/services/Socket.ts:3–33

import { connect, Socket as SocketIOSocket } from "socketio-latest";

export default class SocketLatest {
  socket: SocketIOSocket;

  constructor(serverUrl: string) {
    this.socket = connect(serverUrl, {
      withCredentials: true,
      reconnection: false,
    });
    this.socket.on("disconnect", (err) => {
      console.log("disconnected from server", err);
    });
    this.socket.on("connect", () => {
      console.log("connected!!!!");
    });
  }

  disconnect() {
    if (this.socket) this.socket.disconnect();
  }

  subscribe(event: string, cb: (error: string | null, msg: any) => void) {
    if (!this.socket) return true;
    this.socket.on(event, (msg: any) => {
      return cb(null, msg);
    });
  }

  emit(event: string, data?: any) {
    if (this.socket) this.socket.emit(event, data);
  }
}