fix responses resolving more than one awaiter promise (#65)

fix responses resolving more than one awaiter promise
hopefully fixing #32

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unversioned
 
+- Bugfix: Fixed a single server message resolving/rejecting more than one promise (e.g. cases where many messages were sent to the same channel, the first success/error response would resolve/reject all the waiting promises) (#32, #65)
+
 ## v4.0.1
 
 - Bugfix: Fixed exception if new unstable "flags" parsing failed because of an out-of-bounds index.

lib/await/await-response.ts

@@ -85,7 +85,6 @@ export class ResponseAwaiter {
     });
 
     this.subscribeTo("close", this.onConnectionClosed);
-    this.subscribeTo("message", this.onConnectionMessage);
     this.joinPendingResponsesQueue();
   }
 
@@ -199,12 +198,17 @@ export class ResponseAwaiter {
     }
   }
 
-  private onConnectionMessage(msg: IRCMessage): void {
+  // returns true if something matched, preventing "later" matchers from
+  // running against that message
+  public onConnectionMessage(msg: IRCMessage): boolean {
     if (this.config.failure(msg)) {
       this.reject(new MessageError(`Bad response message: ${msg.rawSource}`));
+      return true;
     } else if (this.config.success(msg)) {
       this.resolve(msg);
+      return true;
     }
+    return false;
   }
 
   private subscribeTo(

lib/client/connection.ts

@@ -64,6 +64,15 @@ export class SingleConnection extends BaseClient {
 
     replyToServerPing(this);
     handleReconnectMessage(this);
+
+    this.on("message", (msg) => {
+      for (const awaiter of this.pendingResponses) {
+        const stop = awaiter.onConnectionMessage(msg);
+        if (stop) {
+          break;
+        }
+      }
+    });
   }
 
   public connect(): void {