emit metrics for supplier-allocator

Author: Vlasis-Perdikidis

.gitleaksignore

@@ -25,3 +25,9 @@ debc75a97cfe551a69fd1e8694be483213322a9d:pact-contracts/pacts/letter-rendering/s
 4fa1923947bbff2387218d698d766cbb7c121a0f:pact-contracts/pacts/letter-rendering/supplier-api-letter-request-prepared.json:generic-api-key:10
 d005112adcfd286c3bef076214836dbb2fe8d0b5:.npmrc:npm-access-token:9
 d005112adcfd286c3bef076214836dbb2fe8d0b5:.npmrc:github-pat:7
+ff889d4c3f29da4468ecf1f05f467fe84d35b2a1:lambdas/supplier-mock/.aws-sam/build/SupplierMockFunction/index.js.map:ipv4:4
+ff889d4c3f29da4468ecf1f05f467fe84d35b2a1:lambdas/supplier-mock/.aws-sam/build/SupplierMockFunction/index.js:ipv4:63
+ff889d4c3f29da4468ecf1f05f467fe84d35b2a1:lambdas/supplier-mock/.aws-sam/build/SupplierMockFunction/index.js:ipv4:62
+ff889d4c3f29da4468ecf1f05f467fe84d35b2a1:lambdas/supplier-mock/.aws-sam/build/SupplierMockFunction/index.js:ipv4:60
+ff889d4c3f29da4468ecf1f05f467fe84d35b2a1:lambdas/supplier-mock/.aws-sam/build/SupplierMockFunction/index.js:ipv4:59
+ff889d4c3f29da4468ecf1f05f467fe84d35b2a1:lambdas/supplier-mock/.aws-sam/build/SupplierMockFunction/index.js:ipv4:24

lambdas/supplier-allocator/src/handler/allocate-handler.ts

@@ -144,6 +144,28 @@ function emitMetrics(
   }
 }
 
+function emitSupCampaignClientMetric(
+  letterEvent: PreparedEvents,
+  supplier: string,
+  status: MetricStatus,
+  deps: Deps,
+) {
+  const namespace = "supplier-allocator";
+  const clientId = letterEvent ? letterEvent.data.clientId : "unknown";
+  const campaignId = letterEvent ? letterEvent.data.campaignId : "unknown";
+  const dimensions: Record<string, string> = {
+    Supplier: supplier,
+    ClientId: clientId,
+    CampaignId: campaignId || "unknown",
+  };
+  const metric: MetricEntry = {
+    key: status,
+    value: 1,
+    unit: Unit.Count,
+  };
+  deps.logger.info(buildEMFObject(namespace, dimensions, metric));
+}
+
 export default function createSupplierAllocatorHandler(deps: Deps): SQSHandler {
   return async (event: SQSEvent) => {
     const batchItemFailures: SQSBatchItemFailure[] = [];
@@ -153,8 +175,9 @@ export default function createSupplierAllocatorHandler(deps: Deps): SQSHandler {
     const tasks = event.Records.map(async (record) => {
       let supplier = "unknown";
       let priority = "unknown";
+      let letterEvent: PreparedEvents | undefined;
       try {
-        const letterEvent: unknown = JSON.parse(record.body);
+        letterEvent = JSON.parse(record.body) as PreparedEvents;
 
         deps.logger.info({
           description: "Extracted letter event",
@@ -163,8 +186,8 @@ export default function createSupplierAllocatorHandler(deps: Deps): SQSHandler {
 
         validateType(letterEvent);
 
-        const supplierSpec = getSupplier(letterEvent as PreparedEvents, deps);
-        await getSupplierFromConfig(letterEvent as PreparedEvents, deps);
+        const supplierSpec = getSupplier(letterEvent, deps);
+        await getSupplierFromConfig(letterEvent, deps);
 
         supplier = supplierSpec.supplierId;
         priority = String(supplierSpec.priority);
@@ -199,6 +222,15 @@ export default function createSupplierAllocatorHandler(deps: Deps): SQSHandler {
         );
 
         incrementMetric(perAllocationSuccess, supplier, priority);
+        // increment clientid
+        // increment campaignid
+        // emit metric with current supplier, clientId and campaignId
+        emitSupCampaignClientMetric(
+          letterEvent,
+          supplier,
+          MetricStatus.Success,
+          deps,
+        );
       } catch (error) {
         deps.logger.error({
           description: "Error processing allocation of record",
@@ -208,6 +240,12 @@ export default function createSupplierAllocatorHandler(deps: Deps): SQSHandler {
         });
         incrementMetric(perAllocationFailure, supplier, priority);
         batchItemFailures.push({ itemIdentifier: record.messageId });
+        emitSupCampaignClientMetric(
+          letterEvent as PreparedEvents,
+          supplier,
+          MetricStatus.Failure,
+          deps,
+        );
       }
     });