chore: rebase restore support onto latest main

Author: 0xCaso

src/tempo/client/SessionManager.test.ts

@@ -938,13 +938,10 @@ describe('Session', () => {
         // drain
       }
 
-      const calledHeaders = (mockFetch.mock.calls[0]![1] as RequestInit).headers as Record<
-        string,
-        string
-      >
-      expect(calledHeaders['content-type']).toBe('application/json')
-      expect(calledHeaders['x-custom']).toBe('value')
-      expect(calledHeaders.Accept).toBe('text/event-stream')
+      const calledHeaders = new Headers((mockFetch.mock.calls[0]![1] as RequestInit).headers)
+      expect(calledHeaders.get('content-type')).toBe('application/json')
+      expect(calledHeaders.get('x-custom')).toBe('value')
+      expect(calledHeaders.get('accept')).toBe('text/event-stream')
     })
   })
 
@@ -1085,15 +1082,6 @@ describe('Session', () => {
           },
         })
 
-        onChannelUpdate?.({
-          channelId,
-          salt: '0x01' as Hex,
-          cumulativeAmount: 5_000_000n,
-          escrowContract: '0x0000000000000000000000000000000000000001' as Address,
-          chainId: 4217,
-          opened: true,
-        })
-
         await s.fetch('https://api.example.com/data')
         await s.close()
 

src/tempo/client/SessionManager.ts

@@ -217,12 +217,12 @@ export function sessionManager(parameters: sessionManager.Parameters): SessionMa
 
     async sse(input, init) {
       const { onReceipt, signal, ...fetchInit } = init ?? {}
+      const headers = new Headers(fetchInit.headers)
+      headers.set('Accept', 'text/event-stream')
+
       const sseInit = {
         ...fetchInit,
-        headers: {
-          ...Fetch.normalizeHeaders(fetchInit.headers),
-          Accept: 'text/event-stream',
-        },
+        headers,
         ...(signal ? { signal } : {}),
       }