Merge pull request #18 from sparrowapp-dev/SPRW-931-test-flow-internal-feedback-ticket

feat: implement http request image support for cloud agent [SPRW-931]

Author: Astitva877

src/proxy/http/http.service.ts

@@ -14,6 +14,85 @@ export class HttpService {
     return { buffer: bstr, mime };
   }
 
+  private getStatusText(statusCode: number): string {
+    const statusMap: Record<number, string> = {
+      // 1xx Informational
+      100: 'Continue',
+      101: 'Switching Protocols',
+      102: 'Processing',
+      103: 'Early Hints',
+  
+      // 2xx Success
+      200: 'OK',
+      201: 'Created',
+      202: 'Accepted',
+      203: 'Non-Authoritative Information',
+      204: 'No Content',
+      205: 'Reset Content',
+      206: 'Partial Content',
+      207: 'Multi-Status',
+      208: 'Already Reported',
+      226: 'IM Used',
+  
+      // 3xx Redirection
+      300: 'Multiple Choices',
+      301: 'Moved Permanently',
+      302: 'Found',
+      303: 'See Other',
+      304: 'Not Modified',
+      305: 'Use Proxy',
+      307: 'Temporary Redirect',
+      308: 'Permanent Redirect',
+  
+      // 4xx Client Errors
+      400: 'Bad Request',
+      401: 'Unauthorized',
+      402: 'Payment Required',
+      403: 'Forbidden',
+      404: 'Not Found',
+      405: 'Method Not Allowed',
+      406: 'Not Acceptable',
+      407: 'Proxy Authentication Required',
+      408: 'Request Timeout',
+      409: 'Conflict',
+      410: 'Gone',
+      411: 'Length Required',
+      412: 'Precondition Failed',
+      413: 'Payload Too Large',
+      414: 'URI Too Long',
+      415: 'Unsupported Media Type',
+      416: 'Range Not Satisfiable',
+      417: 'Expectation Failed',
+      418: `I\'m a teapot`,
+      421: 'Misdirected Request',
+      422: 'Unprocessable Entity',
+      423: 'Locked',
+      424: 'Failed Dependency',
+      425: 'Too Early',
+      426: 'Upgrade Required',
+      428: 'Precondition Required',
+      429: 'Too Many Requests',
+      431: 'Request Header Fields Too Large',
+      451: 'Unavailable For Legal Reasons',
+  
+      // 5xx Server Errors
+      500: 'Internal Server Error',
+      501: 'Not Implemented',
+      502: 'Bad Gateway',
+      503: 'Service Unavailable',
+      504: 'Gateway Timeout',
+      505: 'HTTP Version Not Supported',
+      506: 'Variant Also Negotiates',
+      507: 'Insufficient Storage',
+      508: 'Loop Detected',
+      509: 'Bandwidth Limit Exceeded',
+      510: 'Not Extended',
+      511: 'Network Authentication Required'
+    };
+  
+    return statusMap[statusCode] || 'Unknown Status';
+  }
+
   async makeHttpRequest({
     url,
     method,
@@ -128,24 +207,44 @@ export class HttpService {
           method: config.method,
           headers: config.headers,
           data: config.data,
+          responseType: 'arraybuffer',
         });
-        const resp = {
-          status:
-            response.status + ' ' + (response.statusText || 'Unknown Status'),
-          data: response.data,
+
+        let contentType = response.headers['content-type'];
+        let responseData = "";
+        if (contentType?.startsWith('image/')) {
+          const base64 = Buffer.from(response.data).toString('base64');
+          responseData = `data:${contentType};base64,${base64}`;
+        } else {
+           responseData =  Buffer.from(response.data).toString('utf-8');           
+        }
+
+        return {
+          status: response.status + ' ' + (response.statusText || this.getStatusText(response.status)),
+          data: `${responseData}`,
           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,
-        };
+         try{
+           const responseData = Buffer.from(axiosError.response?.data).toString('utf-8'); 
+         return {
+           status: axiosError.response?.status
+             ? axiosError.response?.status +
+               ' ' +
+               (axiosError.response?.statusText || this.getStatusText(axiosError.response?.status))
+             : null,
+           data: responseData || { message: axiosError.message },
+           headers: axiosError.response?.headers,
+         };
+
+         }
+         catch(e){
+          return {
+            status: null,
+            data: { message: axiosError.message },
+            headers: axiosError.response?.headers,
+          };
+         }
       }
     } catch (error: any) {
       console.error('HTTP Service Error:', error);