feat: add urllib4 fetch

Author: killagu

index.d.ts

@@ -23,6 +23,10 @@ import {
   RequestOptions,
   HttpClientResponse as HttpClientResponseNext,
 } from 'urllib-next';
+import {
+  FetchFactory,
+  fetch,
+} from 'urllib4';
 import {
   EggCoreBase,
   FileLoaderOption,
@@ -589,6 +593,12 @@ declare module 'egg' {
      */
     httpclient: EggHttpClient;
 
+    /**
+     * node fetch
+     */
+    FetchFactory: FetchFactory;
+    fetch: typeof fetch,
+
     /**
      * Logger for Application, wrapping app.coreLogger with context infomation
      *

lib/core/fetch_factory.js

@@ -0,0 +1,16 @@
+const debug = require('util').debuglog('egg:lib:core:httpclient_next');
+
+const mainNodejsVersion = parseInt(process.versions.node.split('.')[0]);
+let FetchFactory;
+if (mainNodejsVersion >= 18) {
+  // urllib@4 only works on Node.js >= 18
+  try {
+    const urllib4 = require('urllib4');
+    FetchFactory = urllib4.FetchFactory;
+    debug('urllib4 enable');
+  } catch (err) {
+    debug('require urllib4 error: %s', err);
+  }
+}
+
+module.exports = FetchFactory;

lib/egg.js

@@ -14,6 +14,7 @@ const Messenger = require('./core/messenger');
 const DNSCacheHttpClient = require('./core/dnscache_httpclient');
 const HttpClient = require('./core/httpclient');
 const HttpClientNext = require('./core/httpclient_next');
+const FetchFactory = require('./core/fetch_factory');
 const createLoggers = require('./core/logger');
 const Singleton = require('./core/singleton');
 const utils = require('./core/utils');
@@ -51,6 +52,11 @@ class EggApplication extends EggCore {
     this.ContextHttpClient = ContextHttpClient;
     this.HttpClient = HttpClient;
     this.HttpClientNext = HttpClientNext;
+    this.FetchFactory = FetchFactory;
+    if (FetchFactory) {
+      this.FetchFactory.setClientOptions();
+      this.fetch = FetchFactory.fetch;
+    }
 
     this.loader.loadConfig();
 

test/lib/core/fetch_factory.test.js

@@ -0,0 +1,20 @@
+const assert = require('node:assert');
+const mm = require('egg-mock');
+const FetchFactory = require('../../../lib/core/fetch_factory');
+const utils = require('../../utils');
+
+describe('test/lib/core/fetch_factory.test.js', () => {
+  if (!FetchFactory) return;
+  let url;
+
+  before(async () => {
+    url = await utils.startLocalServer();
+  });
+
+  afterEach(mm.restore);
+
+  it('should fetch ok', async () => {
+    const { status } = await FetchFactory.fetch(url);
+    assert(status === 200);
+  });
+});