chore: update any-signal to latest version (#7628)

- Update any-signal to latest version
[v4.1.1](https://github.com/jacobheun/any-signal/releases/tag/v4.1.1)
- Immediately reject if signal is already aborted without executing
`asyncFn`

---------

Co-authored-by: Matthew Keil <github@mail.matthewkeil.com>
Co-authored-by: Nazar Hussain <nazarhussain@gmail.com>
Co-authored-by: matthewkeil <me@matthewkeil.com>
Co-authored-by: Nico Flaig <nflaig@protonmail.com>

Author: 4 people

packages/utils/package.json

@@ -37,7 +37,7 @@
   "types": "lib/index.d.ts",
   "dependencies": {
     "@chainsafe/as-sha256": "^1.1.0",
-    "any-signal": "3.0.1",
+    "any-signal": "^4.1.1",
     "bigint-buffer": "^1.1.5",
     "case": "^1.6.3",
     "js-yaml": "^4.1.0"

packages/utils/src/timeout.ts

@@ -1,12 +1,16 @@
 import {anySignal} from "any-signal";
-import {TimeoutError} from "./errors.js";
+import {ErrorAborted, TimeoutError} from "./errors.js";
 import {sleep} from "./sleep.js";
 
 export async function withTimeout<T>(
   asyncFn: (timeoutAndParentSignal?: AbortSignal) => Promise<T>,
   timeoutMs: number,
   signal?: AbortSignal
 ): Promise<T> {
+  if (signal?.aborted) {
+    throw new ErrorAborted();
+  }
+
   const timeoutAbortController = new AbortController();
   const timeoutAndParentSignal = anySignal([timeoutAbortController.signal, ...(signal ? [signal] : [])]);
 

packages/utils/test/unit/timeout.test.ts

@@ -1,4 +1,4 @@
-import {afterEach, describe, expect, it} from "vitest";
+import {afterEach, describe, expect, it, vi} from "vitest";
 import {ErrorAborted, TimeoutError} from "../../src/errors.js";
 import {withTimeout} from "../../src/timeout.js";
 
@@ -71,4 +71,15 @@ describe("withTimeout", () => {
       ErrorAborted
     );
   });
+
+  it("Should immediately reject if signal is already aborted without executing asyncFn", async () => {
+    const controller = new AbortController();
+    controller.abort();
+
+    const asyncFnSpy = vi.fn(() => pause(shortTimeoutMs, data));
+
+    await expect(withTimeout(asyncFnSpy, longTimeoutMs, controller.signal)).rejects.toThrow(ErrorAborted);
+
+    expect(asyncFnSpy).not.toHaveBeenCalled();
+  });
 });

yarn.lock

@@ -4113,11 +4113,6 @@ ansi-styles@^6.1.0:
   resolved "https://registry.yarnpkg.com/ansi-styles/-/ansi-styles-6.2.1.tgz#0e62320cf99c21afff3b3012192546aacbfb05c5"
   integrity sha512-bN798gFfQX+viw3R7yrGWRqnrN2oRkEkUjjl4JNn4E8GxxbjtG3FbrEIIY3l8/hrwUwIeCZvi4QuOTP4MErVug==
 
-any-signal@3.0.1:
-  version "3.0.1"
-  resolved "https://registry.yarnpkg.com/any-signal/-/any-signal-3.0.1.tgz#49cae34368187a3472e31de28fb5cb1430caa9a6"
-  integrity sha512-xgZgJtKEa9YmDqXodIgl7Fl1C8yNXr8w6gXjqK3LW4GcEiYT+6AQfJSE/8SPsEpLLmcvbv8YU+qet94UewHxqg==
-
 any-signal@^4.1.1:
   version "4.1.1"
   resolved "https://registry.yarnpkg.com/any-signal/-/any-signal-4.1.1.tgz#928416c355c66899e6b2a91cad4488f0324bae03"
@@ -13664,4 +13659,3 @@ zod@^3.21.4:
   version "3.23.0"
   resolved "https://registry.yarnpkg.com/zod/-/zod-3.23.0.tgz#a25dab5052702834233e0041e9dd8b6a8480e744"
   integrity sha512-OFLT+LTocvabn6q76BTwVB0hExEBS0IduTr3cqZyMqEDbOnYmcU+y0tUAYbND4uwclpBGi4I4UUBGzylWpjLGA==
-