feat: simulate mosip returning aid

opencrvs · Nov 4, 2024 · a9ee81d · a9ee81d
1 parent 17c3b10
commit a9ee81d
Show file tree

Hide file tree

Showing 6 changed files with 69 additions and 15 deletions.
diff --git a/packages/mosip-mock/src/index.ts b/packages/mosip-mock/src/index.ts
@@ -1,21 +1,12 @@
 import Fastify from "fastify";
-import * as crypto from "crypto";
 import { env } from "./constants";
+import { createAid, createNid } from "./random-identifiers";
 
 type OpenCRVSEvent = {
   id: string;
   trackingId: string;
 };
 
-const createNid = async () => {
-  console.log("Creating NID...");
-  await new Promise((resolve) => setTimeout(resolve, 10000));
-  console.log("NID created!");
-
-  const hash = crypto.createHash("sha256");
-  return hash.digest("hex").substring(0, 16);
-};
-
 const sendNid = async ({
   token,
   eventId,
@@ -42,7 +33,7 @@ const sendNid = async ({
     );
   }
 
-  return response.json();
+  return response.text();
 };
 
 const app = Fastify();
@@ -60,7 +51,9 @@ app.post("/webhooks/opencrvs", {
       }
     );
 
-    return reply.status(202).send();
+    return reply.status(202).send({
+      aid: createAid(),
+    });
   },
 });
 

diff --git a/packages/mosip-mock/src/random-identifiers.ts b/packages/mosip-mock/src/random-identifiers.ts
@@ -0,0 +1,15 @@
+import * as crypto from "crypto";
+
+export const createNid = async () => {
+  console.log("Creating NID...");
+  await new Promise((resolve) => setTimeout(resolve, 10000));
+  console.log("NID created!");
+
+  const hash = crypto.createHash("sha256");
+  return `NID-${hash.digest("hex").substring(0, 12).toUpperCase()}`;
+};
+
+export const createAid = () => {
+  const hash = crypto.createHash("sha256");
+  return `AID-${hash.digest("hex").substring(0, 12).toUpperCase()}`;
+};
diff --git a/packages/server/src/mosip-api.ts b/packages/server/src/mosip-api.ts
@@ -33,5 +33,7 @@ export const postRecord = async ({
     );
   }
 
-  return response;
+  return response.json() as Promise<{
+    aid: string;
+  }>;
 };
diff --git a/packages/server/src/opencrvs-api.ts b/packages/server/src/opencrvs-api.ts
@@ -91,3 +91,37 @@ export const rejectRegistration = (
     },
     headers,
   });
+
+export const upsertRegistrationIdentifier = (
+  {
+    eventId,
+    identifierType,
+    identifierValue,
+  }: {
+    eventId: string;
+    identifierType: string;
+    identifierValue: string;
+  },
+  { headers }: { headers: Record<string, any> }
+) =>
+  post({
+    query: /* GraphQL */ `
+      mutation upsertRegistrationIdentifier(
+        $eventId: ID!
+        $identifierType: String!
+        $identifierValue: String!
+      ) {
+        upsertRegistrationIdentifier(
+          eventId: $eventId
+          identifierType: $identifierType
+          identifierValue: $identifierValue
+        )
+      }
+    `,
+    variables: {
+      eventId,
+      identifierType,
+      identifierValue,
+    },
+    headers,
+  });
diff --git a/packages/server/src/webhooks/mosip.ts b/packages/server/src/webhooks/mosip.ts
@@ -35,7 +35,7 @@ export const mosipHandler = async (
     {
       trackingId,
       registrationNumber,
-      childIdentifiers: [{ type: "NID", value: nid }],
+      childIdentifiers: [{ type: "MOSIP_NID", value: nid }],
     },
     { headers: { Authorization: `Bearer ${token}` } }
   );

diff --git a/packages/server/src/webhooks/opencrvs.ts b/packages/server/src/webhooks/opencrvs.ts
@@ -6,6 +6,7 @@ import {
   getTrackingId,
   ValidRecord,
 } from "@opencrvs/commons/types";
+import * as opencrvs from "../opencrvs-api";
 
 export const opencrvsRecordSchema = z
   .object({
@@ -46,10 +47,19 @@ export const opencrvsHandler = async (
 
   request.log.info({ trackingId }, "Received record from OpenCRVS");
 
-  await mosip.postRecord({
+  const { aid } = await mosip.postRecord({
     event: { id: eventId, trackingId },
     token,
   });
 
+  await opencrvs.upsertRegistrationIdentifier(
+    {
+      eventId,
+      identifierType: "MOSIP_AID",
+      identifierValue: aid,
+    },
+    { headers: { Authorization: `Bearer ${token}` } }
+  );
+
   return reply.code(202).send();
 };