feat: confirm registration via graphql api

.gitignore

@@ -19,7 +19,6 @@ data
 
 .history
 
-graphql.schema.json
 *.tar.gz
 .secrets
 .env*

.vscode/extensions.json

@@ -0,0 +1,5 @@
+{
+  "recommendations": [
+    "apollographql.vscode-apollo"
+  ]
+}

apollo.config.json

@@ -0,0 +1,8 @@
+{
+  "client": {
+    "service": {
+      "name": "@opencrvs/gateway",
+      "url": "http://localhost:7070/graphql"
+    }
+  }
+}

package.json

@@ -31,14 +31,8 @@
     "sort-translations": "ts-node -r tsconfig-paths/register src/sort-translations.ts"
   },
   "devDependencies": {
-    "@graphql-codegen/add": "^3.1.1",
-    "@graphql-codegen/cli": "^3.3.1",
-    "@graphql-codegen/introspection": "^3.0.1",
-    "@graphql-codegen/typescript-operations": "^3.0.4",
-    "@graphql-codegen/typescript": "^3.0.4",
     "@inquirer/editor": "^1.2.13",
     "@octokit/core": "4.2.1",
-    "@types/google-libphonenumber": "^7.4.23",
     "@types/handlebars": "^4.1.0",
     "@types/hapi__inert": "5.2.1",
     "@types/inquirer": "^9.0.7",
@@ -88,9 +82,6 @@
     "date-fns": "^2.28.0",
     "dotenv": "^16.4.5",
     "esbuild": "^0.18.9",
-    "google-libphonenumber": "^3.2.32",
-    "graphql-tag": "^2.12.6",
-    "graphql": "^16.3.0",
     "handlebars": "^4.7.7",
     "hapi-auth-jwt2": "10.4.0",
     "hapi-pino": "^9.0.0",
@@ -101,6 +92,7 @@
     "minimist": "^1.2.8",
     "node-fetch": "^2.6.1",
     "nodemailer": "^6.9.8",
+    "noop-tag": "2.0.0",
     "opener": "^1.5.1",
     "p-queue": "^6.6.2",
     "pino": "^7.0.0",

src/api/event-registration/handler.ts

@@ -9,11 +9,13 @@
  * Copyright (C) The OpenCRVS Authors located at https://github.com/opencrvs/opencrvs-core/blob/master/AUTHORS.
  */
 import * as Hapi from '@hapi/hapi'
-import fetch from 'node-fetch'
 import { logger } from '@countryconfig/logger'
-import { CONFIRM_REGISTRATION_URL } from '@countryconfig/constants'
 import { createUniqueRegistrationNumberFromBundle } from '@countryconfig/api/event-registration/service'
 import { badImplementation } from '@hapi/boom'
+import {
+  confirmRegistration
+  // rejectRegistration
+} from '@countryconfig/utils/gateway-api'
 
 export async function eventRegistrationHandler(
   request: Hapi.Request,
@@ -33,15 +35,28 @@ export async function eventRegistrationHandler(
     const bundle = request.payload as fhir.Bundle
 
     const eventRegistrationIdentifiersResponse =
-      await createUniqueRegistrationNumberFromBundle(bundle)
+      createUniqueRegistrationNumberFromBundle(bundle)
 
-    await fetch(CONFIRM_REGISTRATION_URL, {
-      method: 'POST',
-      body: JSON.stringify(eventRegistrationIdentifiersResponse),
-      headers: request.headers
-    })
+    await confirmRegistration(
+      eventRegistrationIdentifiersResponse.compositionId,
+      eventRegistrationIdentifiersResponse,
+      {
+        headers: request.headers
+      }
+    )
   } catch (err) {
-    // IF ANY ERROR OCCURS IN THIS API, THE REGISTRATION WILL BE REJECTED AND MUST BE RE-SUBMITTED BY A REGISTRAR ONCE THE ISSUE IS RESOLVED
+    // If the confirm registration endpoint throws an error, the registration will be retried through country-config
+    // If you don't want the registration to retry, you can call `rejectRegistration` from here and return 202 Accepted
+
+    // await confirmRegistration(
+    //   eventRegistrationIdentifiersResponse.compositionId,
+    //   {
+    //     reason: 'other', // Refer to the GraphQL schema for other options
+    //     comment: 'The comment that will be visible on audit log.'
+    //   },
+    //   { headers: request.headers }
+    // )
+
     logger.error(err)
 
     const boomError = badImplementation()

src/api/event-registration/service.ts

@@ -24,9 +24,7 @@ function generateRegistrationNumber(trackingId: string): string {
   return brn
 }
 
-export async function createUniqueRegistrationNumberFromBundle(
-  bundle: fhir.Bundle
-) {
+export function createUniqueRegistrationNumberFromBundle(bundle: fhir.Bundle) {
   const taskResource = getTaskResource(bundle)
 
   if (!taskResource || !taskResource.extension) {
@@ -40,7 +38,7 @@ export async function createUniqueRegistrationNumberFromBundle(
   return {
     trackingId,
     registrationNumber: generateRegistrationNumber(trackingId),
-    compositionId: getCompositionId(bundle),
+    compositionId: getCompositionId(bundle)!,
     ...(taskResource.code?.coding?.[0].code === 'BIRTH' && {
       // Some countries desire to create multiple identifiers for citizens at the point of birth registration using external systems.
       // OpenCRVS supports up to 3 additional, custom identifiers that can be created

src/constants.ts

@@ -27,9 +27,6 @@ export const SENTRY_DSN = process.env.SENTRY_DSN
 // Check if the token has been invalided in the auth service before it has expired
 // This needs to be a string to make it easy to pass as an ENV var.
 export const CHECK_INVALID_TOKEN = process.env.CHECK_INVALID_TOKEN || 'false'
-export const CONFIRM_REGISTRATION_URL =
-  process.env.CONFIRM_REGISTRATION_URL ||
-  'http://localhost:5050/confirm/registration'
 export const DEFAULT_TIMEOUT = 600000
 export const PRODUCTION = process.env.NODE_ENV === 'production'
 export const QA_ENV = process.env.QA_ENV || false

src/form/index.ts

@@ -14,12 +14,12 @@ import { birthForm } from './birth'
 import { deathForm } from './death'
 import { marriageForm } from './marriage'
 import { IForms, Event } from './types/types'
-import { fetchUserLocationHierarchy } from '@countryconfig/utils/users'
+import { fetchUserLocationHierarchy } from '@countryconfig/utils/gateway-api'
 
 export async function formHandler(req: Request): Promise<IForms> {
   const addressHierarchy = await fetchUserLocationHierarchy(
-    req.headers.authorization,
-    req.auth.credentials.sub as string
+    req.auth.credentials.sub as string,
+    { headers: req.headers }
   )
   // ====================== NOTE REGARDING MIGRATING FROM OPNCRVS v1.2 OR EARLIER ======================
 

src/utils/gateway-api.ts

@@ -0,0 +1,130 @@
+/*
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ *
+ * OpenCRVS is also distributed under the terms of the Civil Registration
+ * & Healthcare Disclaimer located at http://opencrvs.org/license.
+ *
+ * Copyright (C) The OpenCRVS Authors located at https://github.com/opencrvs/opencrvs-core/blob/master/AUTHORS.
+ */
+import { GATEWAY_URL } from '@countryconfig/constants'
+import { URL } from 'url'
+import fetch from 'node-fetch'
+import gql from 'noop-tag'
+
+const GRAPHQL_GATEWAY_URL = new URL('graphql', GATEWAY_URL)
+
+/** Communicates with opencrvs-core's GraphQL gateway */
+const post = async <T = any>({
+  query,
+  variables,
+  headers
+}: {
+  query: string
+  variables: Record<string, any>
+  headers: Record<string, any>
+}) => {
+  const response = await fetch(GRAPHQL_GATEWAY_URL, {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+      ...headers
+    },
+    body: JSON.stringify({
+      variables,
+      query
+    })
+  })
+
+  if (!response.ok) {
+    throw new Error(`not ok: ${await response.text()}`)
+  }
+
+  return response.json() as Promise<{ data: T }>
+}
+
+export const confirmRegistration = (
+  id: string,
+  variables: {
+    childIdentifiers?: Array<{ type: string; value: string }>
+    registrationNumber: string
+    trackingId: string
+  },
+  { headers }: { headers: Record<string, any> }
+) =>
+  post({
+    query: gql`
+      mutation confirmRegistration(
+        $id: ID!
+        $details: ConfirmRegistrationInput!
+      ) {
+        confirmRegistration(id: $id, details: $details)
+      }
+    `,
+    variables: {
+      id,
+      details: {
+        childIdentifiers: variables.childIdentifiers,
+        registrationNumber: variables.registrationNumber,
+        trackingId: variables.trackingId
+      }
+    },
+    headers
+  })
+
+export const rejectRegistration = (
+  id: string,
+  { reason, comment }: { reason: string; comment: string },
+  { headers }: { headers: Record<string, any> }
+) =>
+  post({
+    query: gql`
+      mutation rejectRegistration(
+        $id: ID!
+        $details: RejectRegistrationInput!
+      ) {
+        rejectRegistration(id: $id, details: $details)
+      }
+    `,
+    variables: {
+      id,
+      details: {
+        reason,
+        comment
+      }
+    },
+    headers
+  })
+
+type GetUser = {
+  getUser: {
+    primaryOffice: {
+      hierarchy: Array<{
+        id: string
+      }>
+    }
+  }
+}
+
+export const fetchUserLocationHierarchy = async (
+  userId: string,
+  { headers }: { headers: Record<string, any> }
+) => {
+  const res = await post<GetUser>({
+    query: gql`
+      query fetchUser($userId: String!) {
+        getUser(userId: $userId) {
+          primaryOffice {
+            hierarchy {
+              id
+            }
+          }
+        }
+      }
+    `,
+    variables: { userId },
+    headers
+  })
+  return res.data.getUser.primaryOffice.hierarchy.map(({ id }) => id)
+}

src/utils/index.ts

@@ -11,11 +11,9 @@
 
 import fetch from 'node-fetch'
 import { APPLICATION_CONFIG_URL, FHIR_URL } from '@countryconfig/constants'
-import { callingCountries } from 'country-data'
 import csv2json from 'csv2json'
 import { createReadStream } from 'fs'
 import fs from 'fs'
-import { PhoneNumberFormat, PhoneNumberUtil } from 'google-libphonenumber'
 import { URL } from 'url'
 import { build } from 'esbuild'
 import { memoize } from 'lodash'
@@ -160,21 +158,6 @@ export async function updateResourceInHearth(resource: fhir.ResourceBase) {
   return res.text()
 }
 
-export const convertToMSISDN = (phone: string, countryAlpha3: string) => {
-  const countryCode = callingCountries[countryAlpha3.toUpperCase()].alpha2
-
-  const phoneUtil = PhoneNumberUtil.getInstance()
-  const number = phoneUtil.parse(phone, countryCode)
-
-  return (
-    phoneUtil
-      .format(number, PhoneNumberFormat.INTERNATIONAL)
-      // libphonenumber adds spaces and dashes to phone numbers,
-      // which we do not want to keep for now
-      .replace(/[\s-]/g, '')
-  )
-}
-
 const csvStringify = promisify<Array<Record<string, any>>, Options>(stringify)
 export async function writeJSONToCSV(
   filename: string,