feat(#9835): implement postResource for creation

Author: apoorvapendse

shared-libs/cht-datasource/src/remote/libs/data-context.ts

@@ -83,3 +83,28 @@ export const getResources = (context: RemoteDataContext, path: string) => async
     throw error;
   }
 };
+
+/** @internal */
+export const postResource = (context: RemoteDataContext, path: string) => async <T>(
+  body: Record<string, unknown>,
+): Promise<T> => {
+  try {
+    const response = await fetch(`${context.url}/${path}`, {
+      method: 'POST', 
+      headers: {
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify(body)});
+    if (response.status === 400) {
+      const errorMessage = await response.text();
+      throw new InvalidArgumentError(errorMessage);
+    } else if (!response.ok) {
+      throw new Error(response.statusText);
+    }
+
+    return (await response.json()) as T;
+  } catch (error) {
+    logger.error(`Failed to post ${JSON.stringify(body)} to ${context.url}/${path}.`, error);
+    throw error;
+  }
+};

shared-libs/cht-datasource/test/remote/libs/data-context.spec.ts

@@ -7,7 +7,8 @@ import {
   getResources,
   getRemoteDataContext,
   isRemoteDataContext,
-  RemoteDataContext
+  RemoteDataContext,
+  postResource
 } from '../../../src/remote/libs/data-context';
 import { DataContext, InvalidArgumentError } from '../../../src';
 
@@ -173,6 +174,70 @@ describe('remote context lib', () => {
     });
   });
 
+  describe('postResource', () => {
+    it('throws InvalidArgumentError if the Bad Request - 400 status is returned', async () => {
+      const path = 'path';
+      const qualifier = {
+        name: 'user-1',
+        contact: {
+          _id: '1',
+          parent: {
+            _id: '2'
+          }
+        }
+      };
+      const errorMsg = `Missing or empty required fields [${JSON.stringify(qualifier)}].`;
+      fetchResponse.ok = false;
+      fetchResponse.status = 400;
+      fetchResponse.statusText = errorMsg;
+
+      fetchResponse.text.resolves(errorMsg);
+      const expectedError = new InvalidArgumentError(errorMsg);
+      await expect(postResource(context, path)(qualifier)).to.be.rejectedWith(errorMsg);
+
+      expect(fetchStub.calledOnceWithExactly(`${context.url}/${path}`, 
+        {
+          method: 'POST', 
+          headers: {
+            'Content-Type': 'application/json',
+          },
+          body: JSON.stringify(qualifier)})).to.be.true;
+      
+      expect(fetchResponse.text.called).to.be.true;
+      expect(fetchResponse.json.notCalled).to.be.true;
+      expect(loggerError.args[0]).to.deep.equal([
+        `Failed to post ${JSON.stringify(qualifier)} to ${context.url}/${path}.`,
+        expectedError
+      ]);
+    });
+
+    it('creates a resource for valid req body and path', async () => {
+      const path = 'path';
+      const qualifier = {
+        name: 'city-1',
+        type: 'place'
+      };
+
+      const expoected_response = {...qualifier, _id: '1', _rev: '1', _reported_date: 123123123 };
+      fetchResponse.ok = true;
+      fetchResponse.status = 200;
+      fetchResponse.json.resolves(expoected_response);
+
+      const response = await postResource(context, path)(qualifier);
+
+      expect(response).to.deep.equal(expoected_response);
+      expect(fetchStub.calledOnceWithExactly(`${context.url}/${path}`,
+        {
+          method: 'POST', 
+          headers: {
+            'Content-Type': 'application/json',
+          },
+          body: JSON.stringify(qualifier)})).to.be.true;
+
+      expect(fetchResponse.json.calledOnceWithExactly()).to.be.true;
+    });
+  });
+
   describe('getResources', () => {
     const params = {abc: 'xyz'};
     const stringifiedParams = new URLSearchParams(params).toString();