V0.0.10

package.json

@@ -1,5 +1,5 @@
 {
-  "name": "service-communication-wrapper",
+  "name": "@quizizz/service-communication",
   "version": "1.0.0",
   "description": "A communication wrapper to support any interservice communication",
   "main": "index.js",

src/http/index.js

@@ -93,22 +93,29 @@ class HttpCommunication {
     }
 
     async makeRequest(params) {
-      const { route, method, request } = params;
+      const { route, method, request, headers = {} } = params;
       const requestURL = this.createRequestURL(route, request.query);
       let response;
       const requestContext = this.contextStorage ? this.contextStorage.getStore() : null;
+      let finalHeaders = {};
 
       if (requestContext) {
-        this.axiosConfig.headers = {
+        finalHeaders = {
           ...this.axiosConfig.headers,
           ...this.populateHeadersFromContext(requestContext),
-        }
+          ...headers,
+        };
       }
 
+      const axiosConfig = {
+        ...this.axiosConfig,
+        headers: finalHeaders,
+      };
+
       const req = {
         method,
         url: requestURL,
-        ...this.axiosConfig,
+        ...axiosConfig,
       }
       if (request.body) {
         req['data'] = request.body;
@@ -119,47 +126,52 @@ class HttpCommunication {
       return response.data;
     }
 
-    async post(route, request) {
+    async post(route, request, headers = {}) {
       const data = await this.makeRequest({
         method: 'post',
         route,
         request,
+        headers,
       });
       return data;
     }
 
-    async put(route, request) {
+    async put(route, request, headers = {}) {
       const data = await this.makeRequest({
         method: 'put',
         route,
         request,
+        headers,
       });
       return data;
     }
 
-    async patch(route, request) {
+    async patch(route, request, headers = {}) {
       const data = await this.makeRequest({
         method: 'patch',
         route,
         request,
+        headers,
       });
       return data;
     }
 
-    async delete(route, request) {
+    async delete(route, request, headers = {}) {
       const data = await this.makeRequest({
         method: 'delete',
         route,
         request,
+        headers,
       });
       return data;
     }
 
-    async get(route, request = {}) {
+    async get(route, request = {}, headers = {}) {
       const data = await this.makeRequest({
         method: 'get',
         route,
         request,
+        headers,
       });
       return data;
     }

types/index.d.ts

@@ -24,7 +24,7 @@ export class HttpCommunication {
      * @typeParam T - Response type provided by the callee
      * @returns Returns response of the get request
      */
-    get<T>(route: string, request?: { query: Record<string, string> }): Promise<T>;
+    get<T>(route: string, request?: { query: Record<string, string> }, headers?: Record<string, unknown>): Promise<T>;
 
     /**
      * Http Put Request
@@ -33,7 +33,7 @@ export class HttpCommunication {
      * @typeParam T - Response type provided by the callee
      * @returns Returns response of the put request
      */
-    put<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }): Promise<T>;
+    put<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }, headers?: Record<string, unknown>): Promise<T>;
 
     /**
      * Http Delete Request
@@ -42,7 +42,7 @@ export class HttpCommunication {
      * @typeParam T - Response type provided by the callee
      * @returns Returns response of the put request
      */
-    delete<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }): Promise<T>;
+    delete<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }, headers?: Record<string, unknown>): Promise<T>;
 
      /**
      * Http Patch Request
@@ -51,7 +51,7 @@ export class HttpCommunication {
      * @typeParam T - Response type provided by the callee
      * @returns Returns response of the put request
      */
-    patch<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }): Promise<T>;
+    patch<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }, headers?: Record<string, unknown>): Promise<T>;
 
     /**
      * Http Post Request
@@ -60,5 +60,5 @@ export class HttpCommunication {
      * @typeParam T - Response type provided by the callee
      * @returns Returns response of the post request
      */
-    post<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }): Promise<T>;
+    post<T>(route: string, request: { query: Record<string, string>, body: Record<string, unknown> }, headers?: Record<string, unknown>): Promise<T>;
 }