?

src/channel/Channel.ts

@@ -293,7 +293,7 @@ export class Channel extends EventEmitter {
             }
         });
 
-        this.on("a", (msg: ServerEvents["a"], socket: Socket) => {
+        this.on("message", (msg: ServerEvents["a"], socket: Socket) => {
             if (!msg.message) return;
 
             let outgoing: ClientEvents["a"] = {

src/ws/Socket.ts

@@ -106,21 +106,20 @@ export class Socket extends EventEmitter {
         this.desiredChannel.set = set;
 
         let channel;
-        try {
+        for (const ch of channelList) {
-            for (const ch of channelList.values()) {
+            if (ch.getID() == _id) {
-                if (ch.getID() == this.desiredChannel._id) {
                 channel = ch;
-                    break;
             }
         }
-        } catch (err) {}
+
+        logger.debug("Found channel:", channel);
 
         // Does channel exist?
         if (channel) {
             // Exists, join normally
             channel.join(this);
         } else {
-            // Doesn't exist, join with crown
+            // Doesn't exist, create
             channel = new Channel(
                 this.desiredChannel._id,
                 this.desiredChannel.set

src/ws/events/user/handlers/a.ts

@@ -7,6 +7,6 @@ export const a: ServerEventListener<"a"> = {
         const ch = socket.getCurrentChannel();
         if (!ch) return;
 
-        ch.emit("a", msg, socket);
+        ch.emit("message", msg, socket);
     }
 };