feat: handle graphql variable

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

Author: jbl428

lib/builders/http-request.builder.ts

@@ -47,7 +47,7 @@ export class HttpRequestBuilder {
       this.pathVariableBuilder,
       this.requestParamBuilder,
     );
-    const payload = this.payloadBuilder.build(args);
+    const payload = this.payloadBuilder.build(args, this.gqlQuery);
     const headers = this.requestHeaderBuilder?.build(args);
 
     return new Request(urlBuilder.build(), {

lib/builders/payload.builder.ts

@@ -19,9 +19,9 @@ export class PayloadBuilder {
     return undefined;
   }
 
-  build(args: any[]): BodyInit | undefined {
+  build(args: any[], gqlQuery?: string): BodyInit | undefined {
     return (
-      this.requestBodyBuilder?.build(args) ??
+      this.requestBodyBuilder?.build(args, gqlQuery) ??
       this.requestFormBuilder?.build(args)
     );
   }

lib/builders/request-body.builder.spec.ts

@@ -37,4 +37,23 @@ describe('RequestBodyBuilder', () => {
     // then
     expect(actual).toBe('{"foo":"bar"}');
   });
+
+  test('should include gql query', () => {
+    // given
+    const builder = new RequestBodyBuilder(0, 'name');
+    const args = ['param'];
+    const gqlQuery = /* GraphQL */ `
+      query hello($name: String!) {
+        hello(name: $name)
+      }
+    `;
+
+    // when
+    const actual = builder.build(args, gqlQuery);
+
+    // then
+    expect(actual).toBe(
+      JSON.stringify({ query: gqlQuery, variables: { name: 'param' } }),
+    );
+  });
 });

lib/builders/request-body.builder.ts

@@ -13,7 +13,7 @@ export class RequestBodyBuilder {
     this.metadata.push([index, [key, defaultValue]]);
   }
 
-  build(args: any[]): string {
+  build(args: any[], gqlQuery?: string): string {
     const result = this.metadata.reduce<Record<string, any>>(
       (acc, [index, [key, defaultValue]]) => {
         if (key != null) {
@@ -32,6 +32,8 @@ export class RequestBodyBuilder {
       {},
     );
 
-    return JSON.stringify(result);
+    return JSON.stringify(
+      gqlQuery != null ? { query: gqlQuery, variables: result } : result,
+    );
   }
 }

lib/supports/node-fetch.injector.spec.ts

@@ -17,6 +17,7 @@ import {
   RequestHeader,
   RequestParam,
 } from '../decorators';
+import { GraphQLExchange } from '../decorators/graphql-exchange.decorator';
 import { ResponseBody } from '../decorators/response-body.decorator';
 import { StubDiscoveryService } from '../fixtures/stub-discovery.service';
 import { StubHttpClient } from '../fixtures/stub-http-client';
@@ -428,4 +429,36 @@ describe('NodeFetchInjector', () => {
     expect(httpClient.requestInfo).toHaveLength(1);
     expect(httpClient.requestInfo[0].headers.get('Cookie')).toBe('BAR');
   });
+
+  test('should make graphql request', async () => {
+    // given
+    const query = /* GraphQL */ `
+      query hello($name: String!) {
+        hello(name: $name)
+      }
+    `;
+    @HttpInterface('https://example.com')
+    class SampleClient {
+      @GraphQLExchange(query)
+      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: 'int' });
+
+    // then
+    expect(httpClient.requestInfo).toHaveLength(1);
+    expect(await httpClient.requestInfo[0].json()).toEqual({
+      query,
+      variables: { name: 'int' },
+    });
+  });
 });