From 912ee47c2bbca273bf7c7f63ff94b8b84da2edfa Mon Sep 17 00:00:00 2001
From: Russell Dempsey <1173416+SgtPooki@users.noreply.github.com>
Date: Thu, 7 Mar 2024 15:47:18 -0800
Subject: [PATCH] chore: re-enable stream tests for ByteRangeContext

---
 .../test/utils/byte-range-context.spec.ts             | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/packages/verified-fetch/test/utils/byte-range-context.spec.ts b/packages/verified-fetch/test/utils/byte-range-context.spec.ts
index d96328fc..e70fa792 100644
--- a/packages/verified-fetch/test/utils/byte-range-context.spec.ts
+++ b/packages/verified-fetch/test/utils/byte-range-context.spec.ts
@@ -2,8 +2,6 @@ import { unixfs, type UnixFS } from '@helia/unixfs'
 import { stop } from '@libp2p/interface'
 import { defaultLogger, prefixLogger } from '@libp2p/logger'
 import { expect } from 'aegir/chai'
-import toIt from 'browser-readablestream-to-it'
-import all from 'it-all'
 import { ByteRangeContext } from '../../src/utils/byte-range-context.js'
 import { getStreamFromAsyncIterable } from '../../src/utils/get-stream-from-async-iterable.js'
 import { createHelia } from '../fixtures/create-offline-helia.js'
@@ -91,13 +89,15 @@ describe('ByteRangeContext', () => {
   validRanges.forEach(({ type, range, expected, body, contentRange }) => {
     it(`should correctly slice ${type} body with range ${range}`, () => {
       const context = new ByteRangeContext(logger, { Range: range })
+
       context.setBody(body)
+
       expect(context.getBody()).to.deep.equal(expected)
       expect(context.contentRangeHeaderValue).to.equal(contentRange)
     })
   })
 
-  describe.skip('handling ReadableStreams', () => {
+  describe('handling ReadableStreams', () => {
     let helia: Helia
     let fs: UnixFS
     let cid: CID
@@ -129,8 +129,9 @@ describe('ByteRangeContext', () => {
         context.fileSize = stat.fileSize
 
         context.setBody(await getBodyStream(context.offset, context.length))
-        const bodyResult = await all(toIt(context.getBody() as ReadableStream<Uint8Array>))
-        expect(bodyResult).to.deep.equal(expected)
+        const response = new Response(context.getBody())
+        const bodyResult = await response.arrayBuffer()
+        expect(new Uint8Array(bodyResult)).to.deep.equal(expected)
         expect(context.contentRangeHeaderValue).to.equal(contentRange)
       })
     })