Merge branch 'main' into feat/support-novita-async-t2v

Author: viktor2077

README.md

@@ -97,8 +97,8 @@ You can run our packages with vanilla JS, without any bundler, by using a CDN or
 
 ```html
 <script type="module">
-    import { InferenceClient } from 'https://cdn.jsdelivr.net/npm/@huggingface/[email protected].0/+esm';
-    import { createRepo, commit, deleteRepo, listFiles } from "https://cdn.jsdelivr.net/npm/@huggingface/[email protected].1/+esm";
+    import { InferenceClient } from 'https://cdn.jsdelivr.net/npm/@huggingface/[email protected].1/+esm';
+    import { createRepo, commit, deleteRepo, listFiles } from "https://cdn.jsdelivr.net/npm/@huggingface/[email protected].2/+esm";
 </script>
 ```
 

packages/gguf/package.json

@@ -1,7 +1,7 @@
 {
 	"name": "@huggingface/gguf",
 	"packageManager": "[email protected]",
-	"version": "0.1.16",
+	"version": "0.1.17",
 	"description": "a GGUF parser that works on remotely hosted files",
 	"repository": "https://github.com/huggingface/huggingface.js.git",
 	"publishConfig": {

packages/hub/package.json

@@ -1,7 +1,7 @@
 {
 	"name": "@huggingface/hub",
 	"packageManager": "[email protected]",
-	"version": "2.0.1",
+	"version": "2.0.2",
 	"description": "Utilities to interact with the Hugging Face hub",
 	"repository": "https://github.com/huggingface/huggingface.js.git",
 	"publishConfig": {

packages/hub/src/utils/sha256.ts

@@ -96,9 +96,20 @@ export async function* sha256(
 			try {
 				const poolSize = typeof opts?.useWebWorker === "object" ? opts.useWebWorker.poolSize : undefined;
 				const worker = await getWorker(poolSize);
-				return yield* eventToGenerator<number, string>((yieldCallback, returnCallback, rejectCallack) => {
-					worker.addEventListener("message", (event) => {
+
+				// Define handlers to allow removal
+				let messageHandler: (event: MessageEvent) => void;
+				let errorHandler: (event: ErrorEvent) => void;
+
+				const cleanup = () => {
+					worker.removeEventListener("message", messageHandler);
+					worker.removeEventListener("error", errorHandler);
+				};
+
+				return yield* eventToGenerator<number, string>((yieldCallback, returnCallback, rejectCallback) => {
+					messageHandler = (event: MessageEvent) => {
 						if (event.data.sha256) {
+							cleanup();
 							freeWorker(worker, poolSize);
 							returnCallback(event.data.sha256);
 						} else if (event.data.progress) {
@@ -107,18 +118,47 @@ export async function* sha256(
 							try {
 								opts.abortSignal?.throwIfAborted();
 							} catch (err) {
+								cleanup();
 								destroyWorker(worker);
-								rejectCallack(err);
+								rejectCallback(err);
 							}
 						} else {
+							cleanup();
 							destroyWorker(worker);
-							rejectCallack(event);
+							rejectCallback(event);
 						}
-					});
-					worker.addEventListener("error", (event) => {
+					};
+
+					errorHandler = (event: ErrorEvent) => {
+						cleanup();
 						destroyWorker(worker);
-						rejectCallack(event.error);
-					});
+						rejectCallback(event.error);
+					};
+
+					// Handle external abort signal if it aborts before any worker message
+					if (opts?.abortSignal) {
+						try {
+							opts.abortSignal?.throwIfAborted();
+						} catch (err) {
+							cleanup();
+							destroyWorker(worker);
+							rejectCallback(opts.abortSignal.reason ?? new DOMException("Aborted", "AbortError"));
+							return;
+						}
+
+						const abortListener = () => {
+							cleanup();
+							destroyWorker(worker);
+
+							rejectCallback(opts.abortSignal?.reason ?? new DOMException("Aborted", "AbortError"));
+							opts.abortSignal?.removeEventListener("abort", abortListener);
+						};
+
+						opts.abortSignal.addEventListener("abort", abortListener);
+					}
+
+					worker.addEventListener("message", messageHandler);
+					worker.addEventListener("error", errorHandler);
 					worker.postMessage({ file: buffer });
 				});
 			} catch (err) {