Move fetch to @lodestar/api package

packages/api/src/index.ts

@@ -10,6 +10,9 @@ export {
   HttpError,
   ApiError,
   Metrics,
+  FetchError,
+  isFetchError,
+  fetch,
 } from "./utils/client/index.js";
 export * from "./utils/routes.js";
 

packages/utils/src/fetch.ts → packages/api/src/utils/client/fetch.ts

@@ -1,5 +1,7 @@
 /**
- * Wrapper around native fetch to improve error handling
+ * Native fetch with transparent and consistent error handling
+ *
+ * [MDN Reference](https://developer.mozilla.org/docs/Web/API/fetch)
  */
 async function wrappedFetch(url: string | URL, init?: RequestInit): Promise<Response> {
   try {
@@ -11,6 +13,10 @@ async function wrappedFetch(url: string | URL, init?: RequestInit): Promise<Resp
 
 export {wrappedFetch as fetch};
 
+export function isFetchError(e: unknown): e is FetchError {
+  return e instanceof FetchError;
+}
+
 export type FetchErrorType = "failed" | "input" | "aborted" | "unknown";
 
 type FetchErrorCause = NativeFetchFailedError["cause"] | NativeFetchInputError["cause"];

packages/api/src/utils/client/httpClient.ts

@@ -1,6 +1,7 @@
-import {ErrorAborted, Logger, TimeoutError, fetch, FetchError} from "@lodestar/utils";
+import {ErrorAborted, Logger, TimeoutError} from "@lodestar/utils";
 import {ReqGeneric, RouteDef} from "../index.js";
 import {ApiClientResponse, ApiClientSuccessResponse} from "../../interfaces.js";
+import {fetch, isFetchError} from "./fetch.js";
 import {stringifyQuery, urlJoin} from "./format.js";
 import {Metrics} from "./metrics.js";
 import {HttpStatusCode} from "./httpStatusCode.js";
@@ -322,7 +323,7 @@ export class HttpClient implements IHttpClient {
 }
 
 function isAbortedError(e: Error): boolean {
-  return e instanceof FetchError && e.type === "aborted";
+  return isFetchError(e) && e.type === "aborted";
 }
 
 function getErrorMessage(errBody: string): string {

packages/api/src/utils/client/index.ts

@@ -1,2 +1,3 @@
 export * from "./client.js";
 export * from "./httpClient.js";
+export * from "./fetch.js";

packages/utils/test/unit/fetch.test.ts → packages/api/test/unit/client/fetch.test.ts

@@ -1,8 +1,7 @@
-import "../setup.js";
 import crypto from "node:crypto";
 import http from "node:http";
 import {expect} from "chai";
-import {FetchError, FetchErrorType, fetch} from "../../src/fetch.js";
+import {FetchError, FetchErrorType, fetch} from "../../../src/utils/client/fetch.js";
 
 describe("FetchError", function () {
   const port = 37421;

packages/api/test/utils/fetchOpenApiSpec.ts

@@ -1,6 +1,6 @@
 import fs from "node:fs";
 import path from "node:path";
-import {fetch} from "@lodestar/utils";
+import {fetch} from "@lodestar/api";
 import {OpenApiFile, OpenApiJson} from "./parseOpenApiSpec.js";
 
 /* eslint-disable no-console */

packages/beacon-node/src/eth1/provider/jsonRpcHttpClient.ts

@@ -1,4 +1,5 @@
-import {ErrorAborted, TimeoutError, retry, fetch} from "@lodestar/utils";
+import {fetch} from "@lodestar/api";
+import {ErrorAborted, TimeoutError, retry} from "@lodestar/utils";
 import {IGauge, IHistogram} from "../../metrics/interface.js";
 import {IJson, RpcPayload} from "../interface.js";
 import {encodeJwtToken} from "./jwt.js";

packages/beacon-node/src/execution/engine/utils.ts

@@ -1,4 +1,4 @@
-import {isFetchError} from "@lodestar/utils";
+import {isFetchError} from "@lodestar/api";
 import {IJson, RpcPayload} from "../../eth1/interface.js";
 import {IJsonRpcHttpClient} from "../../eth1/provider/jsonRpcHttpClient.js";
 import {ExecutePayloadStatus, ExecutionEngineState} from "./interface.js";

packages/beacon-node/src/monitoring/service.ts

@@ -1,5 +1,6 @@
 import {Registry} from "prom-client";
-import {ErrorAborted, Logger, TimeoutError, fetch} from "@lodestar/utils";
+import {fetch} from "@lodestar/api";
+import {ErrorAborted, Logger, TimeoutError} from "@lodestar/utils";
 import {RegistryMetricCreator} from "../metrics/index.js";
 import {HistogramExtra} from "../metrics/utils/histogram.js";
 import {defaultMonitoringOptions, MonitoringOptions} from "./options.js";

packages/beacon-node/test/e2e/api/impl/config.test.ts

@@ -1,4 +1,4 @@
-import {fetch} from "@lodestar/utils";
+import {fetch} from "@lodestar/api";
 import {ForkName, activePreset} from "@lodestar/params";
 import {chainConfig} from "@lodestar/config/default";
 import {ethereumConsensusSpecsTests} from "../../../spec/specTestVersioning.js";

packages/beacon-node/test/e2e/eth1/jsonRpcHttpClient.test.ts

@@ -2,7 +2,7 @@ import "mocha";
 import crypto from "node:crypto";
 import http from "node:http";
 import {expect} from "chai";
-import {FetchError} from "@lodestar/utils";
+import {FetchError} from "@lodestar/api";
 import {JsonRpcHttpClient} from "../../../src/eth1/provider/jsonRpcHttpClient.js";
 import {getGoerliRpcUrl} from "../../testParams.js";
 import {RpcPayload} from "../../../src/eth1/interface.js";

packages/beacon-node/test/unit/metrics/server/http.test.ts

@@ -1,4 +1,4 @@
-import {fetch} from "@lodestar/utils";
+import {fetch} from "@lodestar/api";
 import {getHttpMetricsServer, HttpMetricsServer} from "../../../../src/metrics/index.js";
 import {testLogger} from "../../../utils/logger.js";
 import {createMetricsTest} from "../utils.js";

packages/utils/src/index.ts

@@ -3,7 +3,6 @@ export * from "./assert.js";
 export * from "./bytes.js";
 export * from "./err.js";
 export * from "./errors.js";
-export * from "./fetch.js";
 export * from "./format.js";
 export * from "./logger.js";
 export * from "./map.js";

packages/validator/src/util/externalSignerClient.ts

@@ -1,7 +1,7 @@
 import {ContainerType, toHexString, ValueOf} from "@chainsafe/ssz";
+import {fetch} from "@lodestar/api";
 import {phase0, altair, capella} from "@lodestar/types";
 import {ForkSeq} from "@lodestar/params";
-import {fetch} from "@lodestar/utils";
 import {ValidatorRegistrationV1} from "@lodestar/types/bellatrix";
 import {BeaconConfig} from "@lodestar/config";
 import {computeEpochAtSlot, blindedOrFullBlockToHeader} from "@lodestar/state-transition";