Merge pull request #17 from sparrowapp-dev/feat/implement-graphql-proxy-service

feat: implement graphql proxy [#16]

Author: Astitva877

src/proxy/graphql/graphql.controller.ts

@@ -0,0 +1,43 @@
+import {
+  Controller,
+  Post,
+  Body,
+  Headers,
+  Query,
+  Req,
+  Res,
+  HttpException,
+  HttpStatus,
+} from '@nestjs/common';
+import { GraphqlService } from './graphql.service';
+import { Request, Response } from 'express';
+
+@Controller('proxy')
+export class GraphqlController {
+  constructor(private readonly graphqlService: GraphqlService) {}
+
+  @Post('graphql-request')
+  async handleHttpRequest(
+    @Body('url') url: string,
+    @Body('method') method: string,
+    @Body('headers') headers: string,
+    @Body('body') body: any,
+    @Body('contentType') contentType: string,
+    @Req() req: Request,
+    @Res() res: Response,
+  ) {
+    try {
+      const response = await this.graphqlService.makeGraphqlRequest({
+        url,
+        method,
+        headers,
+        body,
+        contentType,
+      });
+
+      return res.status(200).send(response);
+    } catch (error) {
+      throw new HttpException(error.message, HttpStatus.BAD_GATEWAY);
+    }
+  }
+}

src/proxy/graphql/graphql.module.ts

@@ -0,0 +1,11 @@
+import { Module } from '@nestjs/common';
+import { GraphqlController } from './graphql.controller';
+import { GraphqlService } from './graphql.service';
+import { HttpModule as NestHttpModule } from '@nestjs/axios';
+
+@Module({
+  imports: [NestHttpModule],
+  controllers: [GraphqlController],
+  providers: [GraphqlService],
+})
+export class GraphqlModule {}

src/proxy/graphql/graphql.service.ts

@@ -0,0 +1,94 @@
+import { Injectable } from '@nestjs/common';
+import { HttpService as NestHttpService } from '@nestjs/axios';
+
+@Injectable()
+export class GraphqlService {
+  constructor(private readonly httpService: NestHttpService) {}
+
+  async makeGraphqlRequest({
+    url,
+    method,
+    headers,
+    body,
+    contentType,
+  }: {
+    url: string;
+    method: string;
+    headers: string;
+    body: any;
+    contentType: string;
+  }): Promise<{ status: string; data: any; headers: any }> {
+    try {
+      // Parse headers from stringified JSON
+      const parsedHeaders: Record<string, string> = {};
+      let headersArray;
+
+      try {
+        headersArray = JSON.parse(headers);
+        if (Array.isArray(headersArray)) {
+          headersArray.forEach((item: any) => {
+            parsedHeaders[item.key] = item.value;
+          });
+        }
+      } catch (headerError) {
+        console.error('Error parsing headers:', headerError);
+        throw new Error('Invalid headers format');
+      }
+
+      // Prepare the request configuration
+      const config: any = {
+        url,
+        method,
+        headers: parsedHeaders,
+        data: null,
+      };
+
+      // Handle body based on content type
+      try {
+        switch (contentType) {
+          case 'application/json':
+            config.data = typeof body === 'string' ? JSON.parse(body) : body;
+            break;
+
+          default:
+            break;
+        }
+      } catch (bodyError) {
+        console.error('Error processing request body:', bodyError);
+        throw new Error('Invalid request body format');
+      }
+
+      // Add custom user agent
+      config.headers['User-Agent'] = 'SparrowRuntime/1.0.0';
+      
+      try {
+        const response = await this.httpService.axiosRef({
+          url: config.url,
+          method: config.method,
+          headers: config.headers,
+          data: config.data,
+        });
+        const resp = {
+          status:
+            response.status + ' ' + (response.statusText || 'Unknown Status'),
+          data: response.data,
+          headers: response.headers,
+        };
+        return resp;
+      } catch (axiosError: any) {
+        return {
+          status: axiosError.response?.status
+            ? axiosError.response?.status +
+              ' ' +
+              (axiosError.response?.statusText || 'Unknown Status')
+            : null,
+          data: axiosError.response?.data || { message: axiosError.message },
+          headers: axiosError.response?.headers,
+        };
+      }
+    } catch (error: any) {
+      console.error('HTTP Service Error:', error);
+      throw new Error(error.message || 'Unknown error occurred');
+    }
+  }
+}

src/proxy/proxy.module.ts

@@ -2,8 +2,9 @@ import { Module } from '@nestjs/common';
 import { SocketIoModule } from './socketio/socketio.module';
 import { HttpModule } from './http/http.module';
 import { WebSocketModule } from './websocket/websocket.module';
+import { GraphqlModule } from "./graphql/graphql.module";
 
 @Module({
-  imports: [HttpModule, SocketIoModule, WebSocketModule],
+  imports: [HttpModule, SocketIoModule, WebSocketModule, GraphqlModule],
 })
 export class ProxyModule {}