chore: replace axios with native node fetch (#4644)

Author: 2heal1

package.json

@@ -179,7 +179,7 @@
     "storybook": "8.6.17",
     "tapable": "2.3.0",
     "typedoc": "0.28.17",
-    "undici": "7.18.2",
+    "undici": "7.24.7",
     "unplugin": "3.0.0"
   },
   "devDependencies": {

packages/dts-plugin/package.json

@@ -71,8 +71,8 @@
     "@module-federation/third-party-dts-extractor": "workspace:*",
     "adm-zip": "0.5.10",
     "ansi-colors": "4.1.3",
-    "axios": "1.15.0",
     "isomorphic-ws": "5.0.0",
+    "undici": "7.24.7",
     "node-schedule": "2.1.1",
     "ws": "8.18.0"
   },

packages/dts-plugin/src/core/lib/DTSManager.advance.spec.ts

@@ -1,10 +1,10 @@
 import AdmZip from 'adm-zip';
-import axios from 'axios';
 import dirTree from 'directory-tree';
 import { readFileSync, rmSync } from 'fs';
 import { join } from 'path';
 import { describe, expect, it, vi, beforeAll } from 'vitest';
 import { DTSManager } from './DTSManager';
+import * as utils from './utils';
 const TEST_DIT_DIR = 'dist-test';
 
 describe('DTSManager advance usage', () => {
@@ -97,15 +97,20 @@ describe('DTSManager advance usage', () => {
       remoteOptions.typesFolder,
     );
     const apiFile = `${apiDistFolder}.d.ts`;
-    // const prevAxiosGet = axios.get;
-    axios.get = (url) => {
+    vi.spyOn(utils, 'nativeFetch').mockImplementation((url) => {
       if (url.includes('.d.ts')) {
-        return vi
-          .fn()
-          .mockResolvedValueOnce({ data: readFileSync(apiFile, 'utf8') })();
+        return Promise.resolve({
+          data: readFileSync(apiFile, 'utf8'),
+          status: 200,
+          headers: {},
+        } as any);
       }
-      return vi.fn().mockResolvedValueOnce({ data: zip.toBuffer() })();
-    };
+      return Promise.resolve({
+        data: zip.toBuffer(),
+        status: 200,
+        headers: {},
+      } as any);
+    });
 
     await dtsManager.consumeTypes();
 

packages/dts-plugin/src/core/lib/DTSManager.general.spec.ts

@@ -1,15 +1,14 @@
 import { describe, expect, it, vi, beforeEach } from 'vitest';
 import { DTSManager } from './DTSManager';
-import axios from 'axios';
 import fs from 'fs';
 import path from 'path';
 import { UpdateMode } from '../../server/constant';
 import { ThirdPartyExtractor } from '@module-federation/third-party-dts-extractor';
 import { HostOptions, RemoteInfo } from '../interfaces/HostOptions';
 import { RemoteOptions } from '../interfaces/RemoteOptions';
 import { downloadTypesArchive } from './archiveHandler';
+import * as utils from './utils';
 
-vi.mock('axios');
 vi.mock('fs/promises');
 vi.mock('fs');
 vi.mock('./archiveHandler');
@@ -143,7 +142,11 @@ describe('DTSManager General Tests', () => {
         },
       };
 
-      vi.mocked(axios.get).mockResolvedValueOnce(manifestResponse);
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
+        data: manifestResponse.data,
+        status: 200,
+        headers: {},
+      } as any);
 
       const remoteInfo: RemoteInfo = {
         name: 'test',
@@ -169,7 +172,11 @@ describe('DTSManager General Tests', () => {
         },
       };
 
-      vi.mocked(axios.get).mockResolvedValueOnce(manifestResponse);
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
+        data: manifestResponse.data,
+        status: 200,
+        headers: {},
+      } as any);
 
       const remoteInfo: RemoteInfo = {
         name: 'test',
@@ -184,7 +191,9 @@ describe('DTSManager General Tests', () => {
     });
 
     it('should handle manifest fetch errors', async () => {
-      vi.mocked(axios.get).mockRejectedValueOnce(new Error('Network error'));
+      vi.spyOn(utils, 'nativeFetch').mockRejectedValueOnce(
+        new Error('Network error'),
+      );
 
       const remoteInfo: RemoteInfo = {
         name: 'test',
@@ -210,7 +219,11 @@ describe('DTSManager General Tests', () => {
         },
       };
 
-      vi.mocked(axios.get).mockResolvedValueOnce(manifestResponse);
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
+        data: manifestResponse.data,
+        status: 200,
+        headers: {},
+      } as any);
 
       const remoteInfo: RemoteInfo = {
         name: 'test',
@@ -346,7 +359,11 @@ describe('DTSManager General Tests', () => {
         type PackageType<T> = T extends 'REMOTE_ALIAS_IDENTIFIER/Component' ? typeof import('REMOTE_ALIAS_IDENTIFIER/Component') : any;
       `;
 
-      vi.mocked(axios.get).mockResolvedValueOnce({ data: apiTypeContent });
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
+        data: apiTypeContent,
+        status: 200,
+        headers: {},
+      } as any);
       vi.spyOn(fs, 'writeFileSync');
 
       // @ts-expect-error only need timeout, which is not required
@@ -390,7 +407,9 @@ describe('DTSManager General Tests', () => {
         apiTypeUrl: 'http://example.com/api.d.ts',
       };
 
-      vi.mocked(axios.get).mockRejectedValueOnce(new Error('Network error'));
+      vi.spyOn(utils, 'nativeFetch').mockRejectedValueOnce(
+        new Error('Network error'),
+      );
       vi.spyOn(fs, 'writeFileSync');
 
       await dtsManager.downloadAPITypes(remoteInfo, '/tmp/types');

packages/dts-plugin/src/core/lib/DTSManager.spec.ts

@@ -1,11 +1,11 @@
 import AdmZip from 'adm-zip';
-import axios from 'axios';
 import dirTree from 'directory-tree';
 import { rmSync, existsSync } from 'fs';
 import { join } from 'path';
 import { describe, expect, it, vi, beforeAll } from 'vitest';
 import { DTSManager } from './DTSManager';
 import { UpdateMode } from '../../server/constant';
+import * as utils from './utils';
 
 const TEST_DIT_DIR = 'dist-test';
 
@@ -326,7 +326,11 @@ describe('DTSManager', () => {
       const distFolder = join(projectRoot, TEST_DIT_DIR, typesFolder);
       const zip = new AdmZip();
       zip.addLocalFolder(distFolder);
-      axios.get = vi.fn().mockResolvedValueOnce({ data: zip.toBuffer() });
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
+        data: zip.toBuffer(),
+        status: 200,
+        headers: {},
+      } as any);
       await dtsManager.consumeTypes();
 
       expect(
@@ -337,7 +341,7 @@ describe('DTSManager', () => {
     });
 
     it('no delete exist remote types if fetch new remote types failed', async () => {
-      axios.get = vi.fn().mockRejectedValue(new Error('error'));
+      vi.spyOn(utils, 'nativeFetch').mockRejectedValueOnce(new Error('error'));
       await dtsManager.consumeTypes();
       expect(
         dirTree(targetFolder, {
@@ -492,7 +496,11 @@ describe('DTSManager', () => {
     const distFolder = join(projectRoot, TEST_DIT_DIR, typesFolder);
     const zip = new AdmZip();
     zip.addLocalFolder(distFolder);
-    axios.get = vi.fn().mockResolvedValueOnce({ data: zip.toBuffer() });
+    vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
+      data: zip.toBuffer(),
+      status: 200,
+      headers: {},
+    } as any);
 
     await dtsManager.updateTypes({
       remoteName: 'remote',

packages/dts-plugin/src/core/lib/DTSManager.ts

@@ -27,7 +27,7 @@ import {
   HOST_API_TYPES_FILE_NAME,
 } from '../constant';
 import { fileLog, logger } from '../../server';
-import { axiosGet, cloneDeepOptions, isDebugMode } from './utils';
+import { nativeFetch, cloneDeepOptions, isDebugMode } from './utils';
 import { UpdateMode } from '../../server/constant';
 
 export const MODULE_DTS_MANAGER_IDENTIFIER = 'MF DTS Manager';
@@ -222,7 +222,7 @@ class DTSManager {
         return remoteInfo as Required<RemoteInfo>;
       }
       const url = remoteInfo.url;
-      const res = await axiosGet(url, {
+      const res = await nativeFetch(url, {
         timeout: hostOptions.timeout,
         family: hostOptions.family,
       });
@@ -299,7 +299,7 @@ class DTSManager {
     }
     try {
       const url = apiTypeUrl;
-      const res = await axiosGet(url, {
+      const res = await nativeFetch(url, {
         timeout: hostOptions.timeout,
         family: hostOptions.family,
       });

packages/dts-plugin/src/core/lib/archiveHandler.test.ts

@@ -3,14 +3,13 @@ import type { RemoteOptions } from '../interfaces/RemoteOptions';
 import type { TsConfigJson } from '../interfaces/TsConfigJson';
 
 import AdmZip from 'adm-zip';
-import axios, { AxiosResponse, InternalAxiosRequestConfig } from 'axios';
 import {
   existsSync,
   mkdirSync,
   mkdtempSync,
-  readFileSync,
   rmSync,
   writeFileSync,
+  readFileSync,
 } from 'fs';
 import os from 'os';
 import { join } from 'path';
@@ -31,6 +30,7 @@ import {
   retrieveTypesZipPath,
 } from './archiveHandler';
 import { fileLog } from '../../server';
+import * as utils from './utils';
 
 describe('archiveHandler', () => {
   const tmpDir = mkdtempSync(join(os.tmpdir(), 'archive-handler'));
@@ -283,15 +283,13 @@ describe('archiveHandler', () => {
         Buffer.from('export declare const bar: number;'),
       );
 
-      const mockResponse: AxiosResponse<Buffer> = {
-        data: zip.toBuffer(),
-        status: 200,
-        statusText: 'OK',
-        headers: {},
-        config: {} as InternalAxiosRequestConfig,
-        request: {} as XMLHttpRequest,
-      };
-      vi.spyOn(axios, 'get').mockResolvedValueOnce(mockResponse);
+      const nativeFetchMock = vi
+        .spyOn(utils, 'nativeFetch')
+        .mockResolvedValueOnce({
+          data: zip.toBuffer(),
+          status: 200,
+          headers: {},
+        } as any);
 
       const result = await downloadTypesArchive(hostOptions)([
         destinationFolder,
@@ -300,38 +298,35 @@ describe('archiveHandler', () => {
 
       expect(result).toEqual([destinationFolder, archivePath]);
       expect(existsSync(join(archivePath, 'sample.d.ts'))).toBeTruthy();
-      expect(axios.get).toHaveBeenCalledTimes(1);
-      // Only verify the URL and responseType
-      const axiosGetMock = vi.mocked(axios.get);
-      const [[url, options]] = axiosGetMock.mock.calls;
+      expect(nativeFetchMock).toHaveBeenCalledTimes(1);
+      const [[url, options]] = nativeFetchMock.mock.calls;
       expect(url).toBe(new URL(fileToDownload).href);
       expect(options.responseType).toBe('arraybuffer');
     });
 
     it('should retry on network failure up to maxRetries', async () => {
       const error = new Error('Network error');
-      vi.spyOn(axios, 'get').mockRejectedValue(error);
+      const nativeFetchMock = vi
+        .spyOn(utils, 'nativeFetch')
+        .mockRejectedValue(error);
 
       await expect(() =>
         downloadTypesArchive(hostOptions)([destinationFolder, fileToDownload]),
       ).rejects.toThrowError(/Network error/);
 
-      expect(axios.get).toHaveBeenCalledTimes(hostOptions.maxRetries);
+      expect(nativeFetchMock).toHaveBeenCalledTimes(hostOptions.maxRetries);
     });
 
     it('should handle empty archives gracefully', async () => {
       const archivePath = join(tmpDir, destinationFolder);
       const zip = new AdmZip();
       // Add an empty directory to the archive
       zip.addFile('.keep', Buffer.from(''));
-      vi.spyOn(axios, 'get').mockResolvedValueOnce({
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
         data: zip.toBuffer(),
         status: 200,
-        statusText: 'OK',
         headers: {},
-        config: {} as InternalAxiosRequestConfig,
-        request: {} as XMLHttpRequest,
-      } as AxiosResponse<Buffer>);
+      } as any);
 
       const result = await downloadTypesArchive(hostOptions)([
         destinationFolder,
@@ -349,14 +344,11 @@ describe('archiveHandler', () => {
 
       const zip = new AdmZip();
       zip.addFile('new.d.ts', Buffer.from('new content'));
-      vi.spyOn(axios, 'get').mockResolvedValueOnce({
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
         data: zip.toBuffer(),
         status: 200,
-        statusText: 'OK',
         headers: {},
-        config: {} as InternalAxiosRequestConfig,
-        request: {} as XMLHttpRequest,
-      } as AxiosResponse<Buffer>);
+      } as any);
 
       await downloadTypesArchive(hostOptions)([
         destinationFolder,
@@ -377,14 +369,11 @@ describe('archiveHandler', () => {
 
       const zip = new AdmZip();
       zip.addFile('new.d.ts', Buffer.from('new content'));
-      vi.spyOn(axios, 'get').mockResolvedValueOnce({
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
         data: zip.toBuffer(),
         status: 200,
-        statusText: 'OK',
         headers: {},
-        config: {} as InternalAxiosRequestConfig,
-        request: {} as XMLHttpRequest,
-      } as AxiosResponse<Buffer>);
+      } as any);
 
       await downloadTypesArchive(options)([destinationFolder, fileToDownload]);
 
@@ -397,26 +386,25 @@ describe('archiveHandler', () => {
         ...hostOptions,
         abortOnError: false,
       };
-      vi.spyOn(axios, 'get').mockRejectedValue(new Error('Network error'));
+      const nativeFetchMock = vi
+        .spyOn(utils, 'nativeFetch')
+        .mockRejectedValue(new Error('Network error'));
 
       const result = await downloadTypesArchive(options)([
         destinationFolder,
         fileToDownload,
       ]);
 
       expect(result).toBeUndefined();
-      expect(axios.get).toHaveBeenCalledTimes(options.maxRetries);
+      expect(nativeFetchMock).toHaveBeenCalledTimes(options.maxRetries);
     });
 
     it('should handle malformed zip data', async () => {
-      vi.spyOn(axios, 'get').mockResolvedValueOnce({
+      vi.spyOn(utils, 'nativeFetch').mockResolvedValueOnce({
         data: Buffer.from('not a valid zip file'),
         status: 200,
-        statusText: 'OK',
         headers: {},
-        config: {} as InternalAxiosRequestConfig,
-        request: {} as XMLHttpRequest,
-      } as AxiosResponse<Buffer>);
+      } as any);
 
       await expect(() =>
         downloadTypesArchive(hostOptions)([destinationFolder, fileToDownload]),