chore: remove got dependency

packages/cli/package.json

@@ -78,7 +78,6 @@
     "deepmerge": "^4.3.1",
     "ethers": "^6.7.0",
     "find-up": "^6.3.0",
-    "got": "^11.8.6",
     "inquirer": "^9.1.5",
     "js-yaml": "^4.1.0",
     "prom-client": "^15.1.0",

packages/cli/src/networks/index.ts

@@ -1,5 +1,4 @@
 import fs from "node:fs";
-import got from "got";
 import {ENR} from "@chainsafe/enr";
 import {SLOTS_PER_EPOCH} from "@lodestar/params";
 import {ApiError, getClient} from "@lodestar/api";
@@ -107,8 +106,8 @@ export async function fetchBootnodes(network: NetworkName): Promise<string[]> {
   if (bootnodesFileUrl === null) {
     return [];
   }
-
-  const bootnodesFile = await got.get(bootnodesFileUrl).text();
+  const res = await fetch(bootnodesFileUrl);
+  const bootnodesFile = await res.text();
   return parseBootnodesFile(bootnodesFile);
 }
 

packages/cli/src/util/file.ts

@@ -1,8 +1,5 @@
 import fs from "node:fs";
 import path from "node:path";
-import stream from "node:stream";
-import {promisify} from "node:util";
-import got from "got";
 import yaml from "js-yaml";
 const {load, dump, FAILSAFE_SCHEMA, Type} = yaml;
 
@@ -129,8 +126,9 @@ export async function downloadOrCopyFile(pathDest: string, urlOrPathSrc: string)
  */
 export async function downloadFile(pathDest: string, url: string): Promise<void> {
   if (!fs.existsSync(pathDest)) {
-    mkdir(path.dirname(pathDest));
-    await promisify(stream.pipeline)(got.stream(url), fs.createWriteStream(pathDest));
+    const res = await fetch(url);
+    const buffer = new Uint8Array(await res.arrayBuffer());
+    await fs.promises.writeFile(pathDest, buffer);
   }
 }
 
@@ -140,8 +138,9 @@ export async function downloadFile(pathDest: string, url: string): Promise<void>
  */
 export async function downloadOrLoadFile(pathOrUrl: string): Promise<Uint8Array> {
   if (isUrl(pathOrUrl)) {
-    const res = await got.get(pathOrUrl, {encoding: "binary"});
-    return res.rawBody;
+    const res = await fetch(pathOrUrl);
+    const rawBody = new Uint8Array(await res.arrayBuffer())
+    return rawBody;
   } else {
     return fs.promises.readFile(pathOrUrl);
   }

packages/cli/test/utils/simulation/beacon_clients/lighthouse.ts

@@ -1,6 +1,5 @@
 import {writeFile} from "node:fs/promises";
 import path from "node:path";
-import got, {RequestError} from "got";
 import yaml from "js-yaml";
 import {HttpClient} from "@lodestar/api";
 import {getClient} from "@lodestar/api/beacon";
@@ -92,10 +91,10 @@ export const generateLighthouseBeaconNode: BeaconNodeGenerator<BeaconClient.Ligh
       },
       health: async () => {
         try {
-          await got.get(`http://127.0.0.1:${ports.beacon.httpPort}/eth/v1/node/health`);
+          await fetch(`http://127.0.0.1:${ports.beacon.httpPort}/eth/v1/node/health`);
           return {ok: true};
         } catch (err) {
-          if (err instanceof RequestError && err.code !== "ECONNREFUSED") {
+          if (err instanceof Error && !err.message.includes('ECONNREFUSED')) {
             return {ok: true};
           }
           return {ok: false, reason: (err as Error).message, checkId: "/eth/v1/node/health query"};

packages/cli/test/utils/simulation/beacon_clients/lodestar.ts

@@ -1,7 +1,6 @@
 /* eslint-disable @typescript-eslint/naming-convention */
 import {writeFile} from "node:fs/promises";
 import path from "node:path";
-import got from "got";
 import {getClient} from "@lodestar/api/beacon";
 import {chainConfigToJson} from "@lodestar/config";
 import {LogLevel} from "@lodestar/utils";
@@ -96,7 +95,7 @@ export const generateLodestarBeaconNode: BeaconNodeGenerator<BeaconClient.Lodest
       },
       health: async () => {
         try {
-          await got.get(`http://${address}:${ports.beacon.httpPort}/eth/v1/node/health`);
+          await fetch(`http://${address}:${ports.beacon.httpPort}/eth/v1/node/health`);
           return {ok: true};
         } catch (err) {
           return {ok: false, reason: (err as Error).message, checkId: "eth/v1/node/health query"};

packages/cli/test/utils/simulation/execution_clients/geth.ts

@@ -1,7 +1,6 @@
 /* eslint-disable @typescript-eslint/naming-convention */
 import {writeFile} from "node:fs/promises";
 import path from "node:path";
-import got from "got";
 import {ZERO_HASH} from "@lodestar/state-transition";
 import {
   EL_GENESIS_ACCOUNT,
@@ -155,7 +154,18 @@ export const generateGethNode: ExecutionNodeGenerator<ExecutionClient.Geth> = (o
     },
     health: async () => {
       try {
-        await got.post(ethRpcPublicUrl, {json: {jsonrpc: "2.0", method: "net_version", params: [], id: 67}});
+        await fetch(ethRpcPublicUrl, {
+          method: 'POST',
+          headers: {
+            'Content-Type': 'application/json'
+          },
+          body: JSON.stringify({
+            jsonrpc: "2.0",
+            method: "net_version",
+            params: [],
+            id: 67
+          })
+        });
         return {ok: true};
       } catch (err) {
         return {ok: false, reason: (err as Error).message, checkId: "JSON RPC query net_version"};

packages/cli/test/utils/simulation/execution_clients/nethermind.ts

@@ -1,7 +1,6 @@
 /* eslint-disable @typescript-eslint/naming-convention */
 import {writeFile} from "node:fs/promises";
 import path from "node:path";
-import got from "got";
 import {ZERO_HASH} from "@lodestar/state-transition";
 import {Eth1ProviderWithAdmin} from "../Eth1ProviderWithAdmin.js";
 import {ExecutionClient, ExecutionNodeGenerator, JobOptions, RunnerType} from "../interfaces.js";
@@ -102,7 +101,18 @@ export const generateNethermindNode: ExecutionNodeGenerator<ExecutionClient.Neth
     },
     health: async () => {
       try {
-        await got.post(ethRpcPublicUrl, {json: {jsonrpc: "2.0", method: "net_version", params: [], id: 67}});
+        await fetch(ethRpcPublicUrl, {
+          method: 'POST',
+          headers: {
+            'Content-Type': 'application/json'
+          },
+          body: JSON.stringify({
+            jsonrpc: "2.0",
+            method: "net_version",
+            params: [],
+            id: 67
+          })
+        });
         return {ok: true};
       } catch (err) {
         return {ok: false, reason: (err as Error).message, checkId: "JSON RPC query net_version"};

packages/cli/test/utils/simulation/validator_clients/lighthouse.ts

@@ -1,6 +1,5 @@
 import path from "node:path";
 import {writeFile} from "node:fs/promises";
-import got, {RequestError} from "got";
 import yaml from "js-yaml";
 import {getClient as keyManagerGetClient} from "@lodestar/api/keymanager";
 import {chainConfigToJson} from "@lodestar/config";
@@ -82,10 +81,10 @@ export const generateLighthouseValidatorNode: ValidatorNodeGenerator<ValidatorCl
       },
       health: async () => {
         try {
-          await got.get(`http://127.0.0.1:${ports.validator.keymanagerPort}/lighthouse/health`);
+          await fetch(`http://127.0.0.1:${ports.validator.keymanagerPort}/lighthouse/health`);
           return {ok: true};
         } catch (err) {
-          if (err instanceof RequestError) {
+          if (err instanceof Error && !err.message.includes('ECONNREFUSED')) {
             return {ok: true};
           }
           return {ok: false, reason: (err as Error).message, checkId: "/lighthouse/health query"};

packages/cli/test/utils/simulation/validator_clients/lodestar.ts

@@ -1,7 +1,6 @@
 /* eslint-disable @typescript-eslint/naming-convention */
 import {writeFile} from "node:fs/promises";
 import path from "node:path";
-import got from "got";
 import {getClient as keyManagerGetClient} from "@lodestar/api/keymanager";
 import {chainConfigToJson} from "@lodestar/config";
 import {LogLevel} from "@lodestar/utils";
@@ -70,7 +69,7 @@ export const generateLodestarValidatorNode: ValidatorNodeGenerator<ValidatorClie
       },
       health: async () => {
         try {
-          await got.get(`http://127.0.0.1:${ports.validator.keymanagerPort}/eth/v1/keystores`);
+          await fetch(`http://127.0.0.1:${ports.validator.keymanagerPort}/eth/v1/keystores`);
           return {ok: true};
         } catch (err) {
           return {ok: false, reason: (err as Error).message, checkId: "eth/v1/keystores query"};

packages/state-transition/test/utils/testFileCache.ts

@@ -1,6 +1,5 @@
 import fs from "node:fs";
 import path from "node:path";
-import got from "got";
 import {ApiError, getClient} from "@lodestar/api";
 import {NetworkName, networksChainConfig} from "@lodestar/config/networks";
 import {createChainForkConfig, ChainForkConfig} from "@lodestar/config";
@@ -103,12 +102,13 @@ async function downloadTestFile(fileId: string): Promise<Buffer> {
   const fileUrl = `${TEST_FILES_BASE_URL}/${fileId}`;
   // eslint-disable-next-line no-console
   console.log(`Downloading file ${fileUrl}`);
-
-  const res = await got(fileUrl, {responseType: "buffer"}).catch((e: Error) => {
-    e.message = `Error downloading ${fileUrl}: ${e.message}`;
-    throw e;
-  });
-  return res.body;
+  try {
+    const res = await fetch(fileUrl);
+    const buffer = Buffer.from(await res.arrayBuffer());
+    return buffer
+  } catch (e) {
+    throw `Error downloading ${fileUrl}: ${e}`;
+  }
 }
 
 async function tryEach<T>(promises: (() => Promise<T>)[]): Promise<T> {