feat: implement body injecting

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

Author: jbl428

lib/decorators/request-body.decorator.ts

@@ -1,7 +1,7 @@
 import { REQUEST_BODY_METADATA } from "./constants";
 import { MetadataMap } from "../types/metadata-map";
 
-export type RequestBodyMetadata = Map<number, string | undefined>;
+export type RequestBodyMetadata = MetadataMap<number, string | undefined>;
 
 export function RequestBody(key?: string): ParameterDecorator {
   return (target, propertyKey, parameterIndex) => {

lib/node-fetch.injector.spec.ts

@@ -10,6 +10,7 @@ import {
   PathVariable,
   PostExchange,
   PutExchange,
+  RequestBody,
   RequestParam,
 } from "./decorators";
 import { StubDiscoveryService } from "./fixture/stub-discovery.service";
@@ -215,4 +216,54 @@ describe("NodeFetchInjector", () => {
     expect(httpClient.requestInfo).toHaveLength(1);
     expect(httpClient.requestInfo[0].method).toBe(method);
   });
+
+  test("should include body", async () => {
+    // given
+    @HttpInterface()
+    class SampleClient {
+      @PostExchange("https://example.com/api")
+      async request(@RequestBody("name") name: string): Promise<string> {
+        return "request";
+      }
+    }
+    const instance = discoveryService.addProvider(SampleClient);
+    httpClient.addResponse({ status: "ok" });
+    nodeFetchInjector.onModuleInit();
+
+    // when
+    await instance.request("userName");
+
+    // then
+    expect(httpClient.requestInfo).toHaveLength(1);
+    expect(await httpClient.requestInfo[0].text()).toBe('{"name":"userName"}');
+    expect(httpClient.requestInfo[0].headers.get("Content-Type")).toBe(
+      "application/json"
+    );
+  });
+
+  test("should include body provided by json", async () => {
+    // given
+    @HttpInterface()
+    class SampleClient {
+      @PostExchange("https://example.com/api")
+      async request(
+        @RequestBody() body: Record<string, unknown>
+      ): Promise<string> {
+        return "request";
+      }
+    }
+    const instance = discoveryService.addProvider(SampleClient);
+    httpClient.addResponse({ status: "ok" });
+    nodeFetchInjector.onModuleInit();
+
+    // when
+    await instance.request({ name: "userName" });
+
+    // then
+    expect(httpClient.requestInfo).toHaveLength(1);
+    expect(await httpClient.requestInfo[0].text()).toBe('{"name":"userName"}');
+    expect(httpClient.requestInfo[0].headers.get("Content-Type")).toBe(
+      "application/json"
+    );
+  });
 });

lib/node-fetch.injector.ts

@@ -7,10 +7,13 @@ import {
   type HttpExchangeMetadata,
   PATH_VARIABLE_METADATA,
   type PathVariableMetadata,
+  REQUEST_BODY_METADATA,
   REQUEST_PARAM_METADATA,
+  type RequestBodyMetadata,
   type RequestParamMetadata,
 } from "./decorators";
 import { HttpClient } from "./types/http-client.interface";
+import { TupleArrayBuilder } from "./utils/tuple-array-builder";
 import { URLBuilder } from "./utils/url-builder";
 
 @Injectable()
@@ -53,8 +56,34 @@ export class NodeFetchInjector implements OnModuleInit {
           const requestParamMetadata = getMetadata<RequestParamMetadata>(
             REQUEST_PARAM_METADATA
           );
+          const requestBodyMetadata = getMetadata<RequestBodyMetadata>(
+            REQUEST_BODY_METADATA
+          );
 
           wrapper.instance[methodName] = async (...args: any[]) => {
+            const payload = requestBodyMetadata
+              ?.toArray()
+              .reduce(
+                (
+                  acc: Record<string, unknown>,
+                  [index, value]: [number, any]
+                ) => {
+                  if (typeof value !== "undefined") {
+                    acc[value] = args[index];
+                    return acc;
+                  }
+
+                  TupleArrayBuilder.of<string, unknown>(args[index]).forEach(
+                    ([k, v]) => {
+                      acc[k] = v;
+                    }
+                  );
+
+                  return acc;
+                },
+                {}
+              );
+
             const urlBuilder = new URLBuilder(
               baseUrl,
               httpExchangeMetadata.url,
@@ -69,6 +98,14 @@ export class NodeFetchInjector implements OnModuleInit {
               .request(
                 new Request(urlBuilder.build(), {
                   method: httpExchangeMetadata.method,
+                  headers:
+                    typeof payload !== "undefined"
+                      ? { "Content-Type": "application/json" }
+                      : undefined,
+                  body:
+                    typeof payload !== "undefined"
+                      ? JSON.stringify(payload)
+                      : undefined,
                 })
               )
               .then(async (response) => await response.json());