fix: Stream retry failure due to previous open connection. (#409)

This should fix #405 or at least provide more logging to debug the issue
further if it persists.

Author: yusinto

packages/sdk/react-native/src/fromExternal/react-native-sse/EventSource.test.ts

@@ -18,6 +18,7 @@ describe('EventSource', () => {
       .mockImplementationOnce(() => 0.999);
 
     eventSource = new EventSource<EventName>(uri, { logger });
+    eventSource.onclose = jest.fn();
     eventSource.open = jest.fn();
     eventSource.onretrying = jest.fn();
   });
@@ -72,7 +73,8 @@ describe('EventSource', () => {
 
     expect(logger.debug).toHaveBeenCalledWith(expect.stringMatching(/new connection in 0 ms/i));
     expect(eventSource.onretrying).toHaveBeenCalledWith({ type: 'retry', delayMillis: 0 });
-    expect(eventSource.open).toHaveBeenCalledTimes(2);
+    expect(eventSource.open).toHaveBeenCalledTimes(1);
+    expect(eventSource.onclose).toHaveBeenCalledTimes(1);
   });
 
   test('tryConnect with delay', () => {
@@ -85,6 +87,7 @@ describe('EventSource', () => {
       expect.stringMatching(/new connection in 556 ms/i),
     );
     expect(eventSource.onretrying).toHaveBeenCalledWith({ type: 'retry', delayMillis: 556 });
-    expect(eventSource.open).toHaveBeenCalledTimes(2);
+    expect(eventSource.open).toHaveBeenCalledTimes(1);
+    expect(eventSource.onclose).toHaveBeenCalledTimes(1);
   });
 });

packages/sdk/react-native/src/fromExternal/react-native-sse/EventSource.ts

@@ -93,6 +93,7 @@ export default class EventSource<E extends string = never> {
     this.logger?.debug(`[EventSource] Will open new connection in ${delay} ms.`);
     this.dispatch('retry', { type: 'retry', delayMillis: delay });
     this.pollTimer = setTimeout(() => {
+      this.close();
       this.open();
     }, delay);
   }
@@ -315,6 +316,7 @@ export default class EventSource<E extends string = never> {
         this.onclose();
         break;
       case 'error':
+        this.logger?.debug(`[EventSource][dispatch][ERROR]: ${JSON.stringify(data)}`);
         this.onerror(data);
         break;
       case 'retry':