fix: Fix WebSocket to send subscribe event before unsubscribe

src/adapters/ws/web-socket-subscription.ts

@@ -23,22 +23,22 @@ export class WebSocketSubscription implements mastodon.streaming.Subscription {
   ) {}
 
   async *values(): AsyncIterableIterator<mastodon.streaming.Event> {
-    try {
-      this.logger?.log("info", "Subscribing to stream", this.stream);
+    this.logger?.log("info", "Subscribing to stream", this.stream);
 
-      for await (this.connection of this.connector) {
-        const data = this.serializer.serialize("json", {
-          type: "subscribe",
-          stream: this.stream,
-          ...this.params,
-        });
+    for await (this.connection of this.connector) {
+      const data = this.serializer.serialize("json", {
+        type: "subscribe",
+        stream: this.stream,
+        ...this.params,
+      });
 
-        this.logger?.log("debug", "↑ WEBSOCKET", data);
-        this.connection.send(data);
-        this.counter.increment(this.stream, this.params);
+      this.logger?.log("debug", "↑ WEBSOCKET", data);
+      this.connection.send(data);
+      this.counter.increment(this.stream, this.params);
 
-        const messages = toAsyncIterable(this.connection);
+      const messages = toAsyncIterable(this.connection);
 
+      try {
         for await (const message of messages) {
           const event = await this.parseMessage(message.data as string);
 
@@ -49,9 +49,9 @@ export class WebSocketSubscription implements mastodon.streaming.Subscription {
           this.logger?.log("debug", "↓ WEBSOCKET", event);
           yield event;
         }
+      } finally {
+        this.unsubscribe();
       }
-    } finally {
-      this.unsubscribe();
     }
   }
 
@@ -69,6 +69,7 @@ export class WebSocketSubscription implements mastodon.streaming.Subscription {
         ...this.params,
       });
 
+      this.logger?.log("debug", "↑ WEBSOCKET", data);
       this.connection.send(data);
     }