Added logging

Author: stevebux

lambdas/letter-stream-forwarder/src/__tests__/letter-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';
@@ -9,6 +10,7 @@ describe('letter-stream-forwarder Lambda', () => {
 
   const mockedDeps: jest.Mocked<Deps> = {
     kinesisClient: { send: jest.fn()} as unknown as KinesisClient,
+    logger: { info: jest.fn(), error: jest.fn() } as unknown as pino.Logger,
     env: {
       LETTER_CHANGE_STREAM_NAME: "test-stream",
     } as unknown as EnvVars

lambdas/letter-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/letter-stream-forwarder/src/letter-stream-forwarder.ts

@@ -1,11 +1,12 @@
 import { LetterBase } from "@internal/datastore";
-import { DynamoDBStreamEvent, Handler, DynamoDBRecord, AttributeValue } from "aws-lambda";
+import { DynamoDBStreamEvent, Handler, DynamoDBRecord } from "aws-lambda";
 import { PutRecordCommand } from "@aws-sdk/client-kinesis";
 import { Deps } from "./deps";
 import { unmarshall } from "@aws-sdk/util-dynamodb";
 
 export function createHandler(deps: Deps): Handler<DynamoDBStreamEvent> {
   return async (event: DynamoDBStreamEvent): Promise<void> => {
+    deps.logger.info({description: 'Received event', event});
     const statusChanges = event.Records
       .filter(record => record.eventName === "MODIFY")
       .filter(record => isChanged(record, 'status') || isChanged(record, 'reasonCode'));