refactor: revert the changes for react-native

Author: joker23

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

@@ -38,12 +38,7 @@ describe('EventSource', () => {
       abort: jest.fn(),
     };
 
-    const xhrSpy = jest.spyOn(window, 'XMLHttpRequest').mockImplementation(() => mockXhr as XMLHttpRequest);
-    // Preserve static constants that EventSource reads from the constructor reference.
-    // @ts-ignore
-    xhrSpy.LOADING = 3;
-    // @ts-ignore
-    xhrSpy.DONE = 4;
+    jest.spyOn(window, 'XMLHttpRequest').mockImplementation(() => mockXhr as XMLHttpRequest);
 
     eventSource = new EventSource<EventName>(uri, { logger });
     eventSource.onclose = jest.fn();
@@ -140,232 +135,4 @@ describe('EventSource', () => {
 
     expect(mockXhr.open).toHaveBeenLastCalledWith('GET', `${uri}?basis=initial`, true);
   });
-
-  test('calls onopen with parsed response headers', () => {
-    const onopen = jest.fn();
-    eventSource.onopen = onopen;
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = '';
-
-    jest.runAllTimers();
-
-    mockXhr.readyState = 4;
-    mockXhr.status = 200;
-    mockXhr.onreadystatechange();
-
-    expect(onopen).toHaveBeenCalledTimes(1);
-    expect(onopen).toHaveBeenCalledWith(
-      expect.objectContaining({
-        type: 'open',
-        headers: expect.objectContaining({
-          'x-ld-fd-fallback': 'true',
-          'x-ld-fd-fallback-ttl': '60',
-        }),
-      }),
-    );
-  });
-
-  test('calls onopen with parsed response headers during streaming (onprogress, pre-DONE)', () => {
-    const onopen = jest.fn();
-    eventSource.onopen = onopen;
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = '';
-
-    jest.runAllTimers();
-
-    // Simulate a chunk arriving while the connection is still LOADING (readyState 3).
-    // This is the real runtime path for a live stream: DONE (readyState 4) only
-    // fires once the connection closes, so gating 'open' on DONE would mean the
-    // event, and the fallback headers it carries, never fires during normal streaming.
-    mockXhr.readyState = 3;
-    mockXhr.status = 200;
-    mockXhr.onprogress();
-
-    expect(onopen).toHaveBeenCalledTimes(1);
-    expect(onopen).toHaveBeenCalledWith(
-      expect.objectContaining({
-        type: 'open',
-        headers: expect.objectContaining({
-          'x-ld-fd-fallback': 'true',
-          'x-ld-fd-fallback-ttl': '60',
-        }),
-      }),
-    );
-  });
-
-  test('dispatches open exactly once when onprogress precedes an onreadystatechange DONE', () => {
-    const onopen = jest.fn();
-    eventSource.onopen = onopen;
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = '';
-
-    jest.runAllTimers();
-
-    // onprogress observes the connection first (LOADING) and transitions to OPEN.
-    mockXhr.readyState = 3;
-    mockXhr.status = 200;
-    mockXhr.onprogress();
-
-    // A later onreadystatechange at DONE must not re-dispatch open: the status is
-    // already OPEN (no longer CONNECTING), so its open-dispatch guard is a no-op.
-    mockXhr.readyState = 4;
-    mockXhr.status = 200;
-    mockXhr.onreadystatechange();
-
-    expect(onopen).toHaveBeenCalledTimes(1);
-  });
-
-  test('calls retryAndHandleError with parsed response headers on an error response', () => {
-    const retryAndHandleError = jest.fn(() => false);
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = 'error body';
-
-    const es = new EventSource<EventName>(uri, { logger, retryAndHandleError });
-    es.onerror = jest.fn();
-
-    jest.runAllTimers();
-
-    mockXhr.readyState = 4;
-    mockXhr.status = 500;
-    mockXhr.onreadystatechange();
-
-    expect(retryAndHandleError).toHaveBeenCalledTimes(1);
-    expect(retryAndHandleError).toHaveBeenCalledWith(
-      expect.objectContaining({
-        status: 500,
-        message: 'error body',
-        headers: expect.objectContaining({
-          'x-ld-fd-fallback': 'true',
-          'x-ld-fd-fallback-ttl': '60',
-        }),
-      }),
-    );
-  });
-
-  test('dispatches error with status and headers from onprogress mid-stream', () => {
-    const onerror = jest.fn();
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = 'error body';
-
-    eventSource.onerror = onerror;
-
-    jest.runAllTimers();
-
-    // readyState 3 (LOADING), not DONE, so this exercises onprogress's
-    // error branch rather than onreadystatechange's.
-    mockXhr.readyState = 3;
-    mockXhr.status = 500;
-    mockXhr.onprogress();
-
-    expect(onerror).toHaveBeenCalledWith(
-      expect.objectContaining({
-        status: 500,
-        headers: expect.objectContaining({
-          'x-ld-fd-fallback': 'true',
-          'x-ld-fd-fallback-ttl': '60',
-        }),
-      }),
-    );
-  });
-
-  test('dispatches error with status and headers from onreadystatechange before retrying', () => {
-    const onerror = jest.fn();
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = 'error body';
-
-    eventSource.onerror = onerror;
-
-    jest.runAllTimers();
-
-    mockXhr.readyState = 4;
-    mockXhr.status = 500;
-    mockXhr.onreadystatechange();
-
-    expect(onerror).toHaveBeenCalledWith(
-      expect.objectContaining({
-        status: 500,
-        headers: expect.objectContaining({
-          'x-ld-fd-fallback': 'true',
-          'x-ld-fd-fallback-ttl': '60',
-        }),
-      }),
-    );
-  });
-
-  test('invokes retryAndHandleError from onprogress when the connection never reaches DONE', () => {
-    const retryAndHandleError = jest.fn(() => false);
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = 'error body';
-
-    const es = new EventSource<EventName>(uri, { logger, retryAndHandleError });
-    es.onerror = jest.fn();
-
-    jest.runAllTimers();
-
-    // readyState never advances to DONE for this attempt, so
-    // onreadystatechange never fires; onprogress must drive the retry
-    // on its own.
-    mockXhr.readyState = 3;
-    mockXhr.status = 500;
-    mockXhr.onprogress();
-
-    expect(retryAndHandleError).toHaveBeenCalledTimes(1);
-    expect(retryAndHandleError).toHaveBeenCalledWith(
-      expect.objectContaining({
-        status: 500,
-        message: 'error body',
-        headers: expect.objectContaining({
-          'x-ld-fd-fallback': 'true',
-          'x-ld-fd-fallback-ttl': '60',
-        }),
-      }),
-    );
-  });
-
-  test('does not invoke retryAndHandleError twice when onprogress and onreadystatechange observe the same failed attempt', () => {
-    const retryAndHandleError = jest.fn(() => false);
-
-    mockXhr.getAllResponseHeaders = jest.fn(
-      () => 'X-Ld-Fd-Fallback: true\r\nX-Ld-Fd-Fallback-Ttl: 60\r\nContent-Type: text/event-stream',
-    );
-    mockXhr.responseText = 'error body';
-
-    const es = new EventSource<EventName>(uri, { logger, retryAndHandleError });
-    es.onerror = jest.fn();
-
-    jest.runAllTimers();
-
-    // onprogress observes the error first (LOADING), then the same response
-    // reaches DONE via onreadystatechange. retryAndHandleError must fire
-    // exactly once for this attempt despite both handlers seeing the error.
-    mockXhr.readyState = 3;
-    mockXhr.status = 500;
-    mockXhr.onprogress();
-
-    mockXhr.readyState = 4;
-    mockXhr.onreadystatechange();
-
-    expect(retryAndHandleError).toHaveBeenCalledTimes(1);
-  });
 });