fix: Prevent throwing unecessary errors

#58

src/client/Client.ts

@@ -4,11 +4,12 @@ import api from "../util/api";
 import Room from "../room/Room";
 import User from "../user/User";
 import channelApi from "../util/channelApi";
+import { EventEmitter } from "ws";
 
 /**
  * Represents the client.
  */
-export default class Client {
+export default class Client extends EventEmitter {
   private readonly ws = new WebSocketManager(this);
 
   /**
@@ -98,3 +99,11 @@ export default class Client {
     return new User(this.ws, user_);
   }
 }
+
+export default interface Client extends EventEmitter {
+  /** Emitted when the client violates Ribbon's protocol. */
+  on(eventName: "nope", listener: (reason: string) => void): this;
+
+  /** Emitted when the client gets kicked by the server. */
+  on(eventName: "kick", listener: (reason: string) => void): this;
+}

src/ws/WebSocketManager.ts

@@ -142,12 +142,12 @@ export default class WebSocketManager extends EventEmitter {
 
     this.socket = new WebSocket(`wss://${this.spool.host}${endpoint}`, ribbon.spools.token);
 
-    this.socket.on("error", (err: string) => {
-      throw new Error(err);
-    });
+    // this.socket.on("error", (err: string) => {
+    //   throw new Error(err);
+    // });
 
     this.socket.on("close", () => {
-      this.mayReconnect && this.connect(true); // i guess temporary fix on silent disconnect
+      this.mayReconnect && this.connect(true);
     });
 
     this.socket.on("open", () => {

src/ws/commands/kick.ts

@@ -1,8 +1,8 @@
 import WebSocketManager from "../WebSocketManager";
 
 export default function (ws: WebSocketManager, { data: { reason } }: any) {
-  clearInterval(ws.heartbeat);
   ws.mayReconnect = false;
+  clearInterval(ws.heartbeat);
   ws.socket?.close();
-  throw new Error(reason);
+  ws.client.emit("kick", reason);
 }

src/ws/commands/nope.ts

@@ -1,9 +1,8 @@
 import WebSocketManager from "../WebSocketManager";
 
 export default function (ws: WebSocketManager, { reason }: any) {
-  clearInterval(ws.heartbeat);
   ws.mayReconnect = false;
+  clearInterval(ws.heartbeat);
   ws.socket?.close();
-
-  throw new Error(reason);
+  ws.client.emit("nope", reason);
 }