logging

Author: nhsd-david-wass

lambdas/mi-stream-forwarder/src/__tests__/mi-stream-forwarder.test.ts

@@ -1,4 +1,5 @@
 import { KinesisClient } from '@aws-sdk/client-kinesis';
+import * as pino from "pino";
 import { mockDeep } from 'jest-mock-extended';
 import { DynamoDBStreamEvent, Context } from 'aws-lambda';
 import { Deps } from '../deps';
@@ -10,6 +11,7 @@ describe('mi-stream-forwarder Lambda', () => {
 
   const mockedDeps: jest.Mocked<Deps> = {
     kinesisClient: { send: jest.fn()} as unknown as KinesisClient,
+    logger: { info: jest.fn(), warn: jest.fn(), error: jest.fn() } as unknown as pino.Logger,
     env: {
       MI_CHANGE_STREAM_ARN: "test-stream",
     } as unknown as EnvVars

lambdas/mi-stream-forwarder/src/deps.ts

@@ -1,14 +1,17 @@
+import pino from 'pino';
 import { KinesisClient } from '@aws-sdk/client-kinesis';
 import { envVars, EnvVars } from './env';
 
 export type Deps = {
   kinesisClient: KinesisClient;
+  logger: pino.Logger;
   env: EnvVars;
 };
 
 export function createDependenciesContainer(): Deps {
   return {
     kinesisClient: new KinesisClient({}),
+    logger: pino(),
     env: envVars,
   };
 }

lambdas/mi-stream-forwarder/src/mi-stream-forwarder.ts

@@ -3,9 +3,11 @@ import { DynamoDBStreamEvent, Handler } from "aws-lambda";
 import { PutRecordCommand } from "@aws-sdk/client-kinesis";
 import { Deps } from "./deps";
 import { unmarshall } from "@aws-sdk/util-dynamodb";
+import { Logger } from "pino";
 
 export function createHandler(deps: Deps): Handler<DynamoDBStreamEvent> {
   return async (event: DynamoDBStreamEvent): Promise<void> => {
+    deps.logger.info({description: "Received event", event});
     const insertedRecords = event.Records
       .filter(record => record.eventName === "INSERT");