fix: NCWF-1 401 (#6)

Co-authored-by: shahdlala66 <shahd.lala66@gmail.com>
Co-authored-by: Lala, Shahd <Shahd.Lala@sybit.de>
Reviewed-on: #6

src/app/services/game-stream.service.ts

@@ -10,6 +10,7 @@ export class GameStreamService {
   private readonly destroyRef = inject(DestroyRef);
   private streamSubscription: Subscription | null = null;
   private pollSubscription: Subscription | null = null;
+  private lastGameStateHash: string | null = null;
 
   startStreaming(
     gameId: string,
@@ -20,7 +21,10 @@ export class GameStreamService {
       .streamGame(gameId)
       .pipe(takeUntilDestroyed(this.destroyRef))
       .subscribe({
-        next: (event) => onEvent(event),
+        next: (event) => {
+          this.lastGameStateHash = JSON.stringify(event);
+          onEvent(event);
+        },
         error: () => {
           onStreamError();
           this.startPolling(gameId, onEvent);
@@ -37,7 +41,7 @@ export class GameStreamService {
       return;
     }
 
-    this.pollSubscription = interval(1500)
+    this.pollSubscription = interval(5000)
       .pipe(
         startWith(0),
         switchMap(() => this.gameApi.getGame(gameId)),
@@ -45,11 +49,16 @@ export class GameStreamService {
       )
       .subscribe({
         next: (game) => {
-          const event: GameStreamEvent = {
-            type: 'gameFull',
-            game
-          };
-          onEvent(event);
+          // Only emit if game state changed to avoid unnecessary updates
+          const stateHash = JSON.stringify(game.state);
+          if (this.lastGameStateHash !== stateHash) {
+            this.lastGameStateHash = stateHash;
+            const event: GameStreamEvent = {
+              type: 'gameFull',
+              game
+            };
+            onEvent(event);
+          }
         }
       });
   }
@@ -59,5 +68,6 @@ export class GameStreamService {
     this.pollSubscription?.unsubscribe();
     this.streamSubscription = null;
     this.pollSubscription = null;
+    this.lastGameStateHash = null;
   }
 }

src/app/services/stream-handler.service.ts

@@ -84,8 +84,19 @@ export class StreamHandlerService {
         }
       };
 
+      // Set timeout to fallback if WebSocket doesn't connect quickly
+      const connectionTimeoutId = setTimeout(() => {
+        if (!connected && !fallbackActive) {
+          console.warn(`[StreamHandler] WebSocket timeout for ${gameId}, attempting NDJSON fallback`);
+          ws.close();
+          void startNdjsonFallback();
+        }
+      }, 3000);
+
       ws.onopen = () => {
         connected = true;
+        clearTimeout(connectionTimeoutId);
+        console.log(`[StreamHandler] WebSocket connected for ${gameId}`);
       };
 
       ws.onmessage = (message) => {
@@ -97,19 +108,23 @@ export class StreamHandlerService {
       };
 
       ws.onerror = (error) => {
-        console.warn(`[StreamHandler] WebSocket error for ${gameId}, attempting NDJSON fallback:`, error);
-        if (!connected) {
+        console.warn(`[StreamHandler] WebSocket error for ${gameId}:`, error);
+        clearTimeout(connectionTimeoutId);
+        if (!connected && !fallbackActive) {
           void startNdjsonFallback();
         }
       };
 
       ws.onclose = () => {
+        clearTimeout(connectionTimeoutId);
         console.warn(`[StreamHandler] WebSocket closed for ${gameId}, connected=${connected}`);
-        if (!connected) {
+        if (connected) {
+          // Connection was established but closed, stream is complete
+          observer.complete();
+        } else if (!fallbackActive) {
+          // Connection never established, try fallback
           console.log(`[StreamHandler] Starting NDJSON fallback for ${gameId}`);
           void startNdjsonFallback();
-        } else {
-          observer.complete();
         }
       };