feat: implement fetch http client

Co-authored-by: imdudu1 <[email protected]>

Author: jbl428

lib/http-interface.module.ts

@@ -1,17 +1,41 @@
 import { type DynamicModule } from '@nestjs/common';
-import { DiscoveryModule } from '@nestjs/core';
+import {
+  DiscoveryModule,
+  DiscoveryService,
+  MetadataScanner,
+} from '@nestjs/core';
+import { FetchHttpClient } from './supports/fetch-http-client';
 import { NodeFetchInjector } from './supports/node-fetch.injector';
+import { type HttpClient } from './types';
 
 export interface HttpInterfaceConfig {
   timeout?: number;
+  httpClient?: HttpClient;
 }
 
 export class HttpInterfaceModule {
   static register(config: HttpInterfaceConfig): DynamicModule {
     return {
       imports: [DiscoveryModule],
       module: HttpInterfaceModule,
-      providers: [NodeFetchInjector],
+      providers: [
+        {
+          provide: NodeFetchInjector,
+          inject: [MetadataScanner, DiscoveryService],
+          useFactory: (
+            metadataScanner: MetadataScanner,
+            discoveryService: DiscoveryService,
+          ) => {
+            const timeout = config.timeout ?? 5000;
+
+            return new NodeFetchInjector(
+              metadataScanner,
+              discoveryService,
+              config.httpClient ?? new FetchHttpClient(timeout),
+            );
+          },
+        },
+      ],
     };
   }
 }

lib/index.ts

@@ -1,3 +1,4 @@
 export * from './decorators';
 export * from './supports';
+export * from './types';
 export * from './http-interface.module';

lib/supports/fetch-http-client.spec.ts

@@ -0,0 +1,54 @@
+import { type AddressInfo } from 'node:net';
+import Fastify, { type FastifyInstance } from 'fastify';
+import { describe, test, expect, beforeAll, afterAll } from 'vitest';
+import { FetchHttpClient } from './fetch-http-client';
+
+describe('FetchHttpClient', () => {
+  let fastify: FastifyInstance;
+
+  beforeAll(async () => {
+    fastify = Fastify({ logger: false });
+
+    fastify.get('/', async (request, reply) => {
+      await reply.send({ hello: 'world' });
+    });
+
+    fastify.get('/timeout', async (request, reply) => {
+      await new Promise((resolve) => setTimeout(resolve, 10000));
+      await reply.send({ hello: 'world' });
+    });
+
+    await fastify.listen({ port: 0 });
+  });
+
+  afterAll(async () => {
+    await fastify.close();
+  });
+
+  test('should request successfully', async () => {
+    // given
+    const address = fastify.server.address() as AddressInfo;
+    const httpClient = new FetchHttpClient(5000);
+    const request = new Request(`http://localhost:${address.port}/`);
+
+    // when
+    const response = await httpClient.request(request);
+
+    // then
+    expect(await response.json()).toEqual({ hello: 'world' });
+  });
+
+  test('should throw error when timeout', async () => {
+    // given
+    const address = fastify.server.address() as AddressInfo;
+    const httpClient = new FetchHttpClient(3000);
+    const request = new Request(`http://localhost:${address.port}/timeout`);
+
+    // when
+    const doRequest = async (): Promise<Response> =>
+      await httpClient.request(request);
+
+    // then
+    await expect(doRequest).rejects.toThrowError('Request Timeout: 3000ms');
+  });
+});

lib/supports/fetch-http-client.ts

@@ -0,0 +1,23 @@
+import { type HttpClient } from '../types/http-client.interface';
+
+export class FetchHttpClient implements HttpClient {
+  #timeout: number;
+
+  constructor(timeout: number) {
+    this.#timeout = timeout;
+  }
+
+  async request(request: Request): Promise<Response> {
+    const controller = new AbortController();
+
+    return await Promise.race<Response>([
+      fetch(request, { signal: controller.signal }),
+      new Promise((resolve, reject) =>
+        setTimeout(() => {
+          controller.abort();
+          reject(new Error(`Request Timeout: ${this.#timeout}ms`));
+        }, this.#timeout),
+      ),
+    ]);
+  }
+}

lib/types/index.ts

@@ -0,0 +1,2 @@
+export * from './http-client.interface';
+export * from './http-method';

package.json

@@ -37,6 +37,7 @@
     "eslint-config-standard-with-typescript": "^34.0.1",
     "eslint-plugin-import": "^2.27.5",
     "eslint-plugin-prettier": "^4.2.1",
+    "fastify": "^4.15.0",
     "husky": "^8.0.3",
     "lint-staged": "^13.2.1",
     "prettier": "^2.8.7",