tweak internal loggin

Author: coyotte508

packages/hub/src/utils/XetBlob.spec.ts

@@ -95,6 +95,7 @@ describe("XetBlob", () => {
 				}
 				return fetch(url, opts);
 			},
+			internalLogging: true,
 		});
 
 		const xetDownload = await blob.slice(0, 200_000).arrayBuffer();
@@ -122,6 +123,7 @@ describe("XetBlob", () => {
 			},
 			hash: "7b3b6d07673a88cf467e67c1f7edef1a8c268cbf66e9dd9b0366322d4ab56d9b",
 			size: 5_234_139_343,
+			internalLogging: true,
 		});
 
 		const xetDownload = await blob.slice(10_000_000, 10_100_000).arrayBuffer();
@@ -296,7 +298,15 @@ describe("XetBlob", () => {
 								}
 								case "fetch.co": {
 									fetchCount++;
-									return new Response(mergedChunks);
+									return new Response(
+										// new ReadableStream({
+										// 	pull(controller) {
+										// 		controller.enqueue(mergedChunks);
+										// 		controller.close();
+										// 	},
+										// })
+										mergedChunks
+									);
 								}
 								default:
 									throw new Error("Unhandled URL");

packages/hub/src/utils/XetBlob.ts

@@ -22,6 +22,7 @@ type XetBlobCreateOptions = {
 	 * For intenral tests
 	 */
 	debug?: (arg: { event: "read" }) => void;
+	internalLogging?: boolean;
 } & Partial<CredentialsParams>;
 
 export interface ReconstructionInfo {
@@ -81,10 +82,6 @@ interface ChunkHeader {
 
 const CHUNK_HEADER_BYTES = 8;
 
-const log = (...args: unknown[]) => {
-	console.log(...args);
-};
-
 /**
  * XetBlob is a blob implementation that fetches data directly from the Xet storage
  */
@@ -96,6 +93,7 @@ export class XetBlob extends Blob {
 	hash: string;
 	start = 0;
 	end = 0;
+	internalLogging = false;
 	reconstructionInfo: ReconstructionInfo | undefined;
 	debug: XetBlobCreateOptions["debug"];
 
@@ -109,6 +107,7 @@ export class XetBlob extends Blob {
 		this.end = params.size;
 		this.hash = params.hash;
 		this.debug = params.debug;
+		this.internalLogging = params.internalLogging ?? false;
 		this.hubUrl;
 	}
 
@@ -130,6 +129,7 @@ export class XetBlob extends Blob {
 		blob.end = this.end;
 		blob.reconstructionInfo = this.reconstructionInfo;
 		blob.debug = this.debug;
+		blob.internalLogging = this.internalLogging;
 
 		return blob;
 	}
@@ -205,6 +205,7 @@ export class XetBlob extends Blob {
 			rangeList.add(term.range.start, term.range.end);
 		}
 		const debug = this.debug;
+		const log = this.internalLogging ? console.log : () => {};
 
 		async function* readData(
 			reconstructionInfo: ReconstructionInfo,