Consistency

Author: stevebux

lambdas/authorizer/package.json

@@ -3,6 +3,7 @@
     "@aws-sdk/client-dynamodb": "^3.858.0",
     "@aws-sdk/lib-dynamodb": "^3.858.0",
     "@internal/datastore": "*",
+    "@internal/helpers": "*",
     "aws-lambda": "^1.0.7",
     "esbuild": "^0.25.11",
     "pino": "^9.7.0",

lambdas/authorizer/src/deps.ts

@@ -1,12 +1,13 @@
 import { DynamoDBClient } from "@aws-sdk/client-dynamodb";
 import { DynamoDBDocumentClient } from "@aws-sdk/lib-dynamodb";
-import pino from "pino";
+import { Logger } from "pino";
 import { SupplierRepository } from "@internal/datastore";
+import { createLogger } from "@internal/helpers/src";
 import { EnvVars, envVars } from "./env";
 
 export type Deps = {
   supplierRepo: SupplierRepository;
-  logger: pino.Logger;
+  logger: Logger;
   env: EnvVars;
 };
 
@@ -17,7 +18,7 @@ function createDocumentClient(): DynamoDBDocumentClient {
 
 function createSupplierRepository(
   documentClient: DynamoDBDocumentClient,
-  log: pino.Logger,
+  log: Logger,
   suppliersTableName: string,
 ): SupplierRepository {
   const config = {
@@ -28,7 +29,7 @@ function createSupplierRepository(
 }
 
 export function createDependenciesContainer(): Deps {
-  const log = pino();
+  const log = createLogger({ logLevel: envVars.PINO_LOG_LEVEL });
 
   return {
     supplierRepo: createSupplierRepository(

lambdas/authorizer/src/env.ts

@@ -5,6 +5,7 @@ const EnvVarsSchema = z.object({
   CLOUDWATCH_NAMESPACE: z.string(),
   APIM_SUPPLIER_ID_HEADER: z.string(),
   CLIENT_CERTIFICATE_EXPIRATION_ALERT_DAYS: z.coerce.number().int(),
+  PINO_LOG_LEVEL: z.coerce.string().optional(),
 });
 
 export type EnvVars = z.infer<typeof EnvVarsSchema>;

lambdas/letter-updates-transformer/src/deps.ts

@@ -1,10 +1,11 @@
-import pino from "pino";
+import { Logger } from "pino";
 import { SNSClient } from "@aws-sdk/client-sns";
+import { createLogger } from "@internal/helpers/src";
 import { EnvVars, envVars } from "./env";
 
 export type Deps = {
   snsClient: SNSClient;
-  logger: pino.Logger;
+  logger: Logger;
   env: EnvVars;
 };
 
@@ -13,7 +14,7 @@ function createSNSClient(): SNSClient {
 }
 
 export function createDependenciesContainer(): Deps {
-  const log = pino();
+  const log = createLogger({ logLevel: envVars.PINO_LOG_LEVEL });
 
   return {
     snsClient: createSNSClient(),

lambdas/letter-updates-transformer/src/env.ts

@@ -3,6 +3,7 @@ import { z } from "zod";
 const EnvVarsSchema = z.object({
   EVENTPUB_SNS_TOPIC_ARN: z.string(),
   EVENT_SOURCE: z.string(),
+  PINO_LOG_LEVEL: z.coerce.string().optional(),
 });
 
 export type EnvVars = z.infer<typeof EnvVarsSchema>;

lambdas/mi-updates-transformer/package.json

@@ -3,6 +3,7 @@
     "@aws-sdk/client-sns": "^3.954.0",
     "@aws-sdk/util-dynamodb": "^3.943.0",
     "@internal/datastore": "^0.1.0",
+    "@internal/helpers": "*",
     "@nhsdigital/nhs-notify-event-schemas-supplier-api": "*",
     "aws-lambda": "^1.0.7",
     "esbuild": "^0.24.0",

lambdas/mi-updates-transformer/src/deps.ts

@@ -1,10 +1,11 @@
-import pino from "pino";
+import { Logger } from "pino";
 import { SNSClient } from "@aws-sdk/client-sns";
+import { createLogger } from "@internal/helpers/src";
 import { EnvVars, envVars } from "./env";
 
 export type Deps = {
   snsClient: SNSClient;
-  logger: pino.Logger;
+  logger: Logger;
   env: EnvVars;
 };
 
@@ -13,7 +14,7 @@ function createSNSClient(): SNSClient {
 }
 
 export function createDependenciesContainer(): Deps {
-  const log = pino();
+  const log = createLogger({ logLevel: envVars.PINO_LOG_LEVEL });
 
   return {
     snsClient: createSNSClient(),

lambdas/mi-updates-transformer/src/env.ts

@@ -2,6 +2,7 @@ import { z } from "zod";
 
 const EnvVarsSchema = z.object({
   EVENTPUB_SNS_TOPIC_ARN: z.string(),
+  PINO_LOG_LEVEL: z.coerce.string().optional(),
 });
 
 export type EnvVars = z.infer<typeof EnvVarsSchema>;

lambdas/upsert-letter/src/config/deps.ts

@@ -30,7 +30,7 @@ function createLetterRepository(
 }
 
 export function createDependenciesContainer(): Deps {
-  const log = createLogger();
+  const log = createLogger({ logLevel: envVars.PINO_LOG_LEVEL });
 
   return {
     letterRepo: createLetterRepository(log, envVars),

lambdas/upsert-letter/src/config/env.ts

@@ -16,6 +16,7 @@ const EnvVarsSchema = z.object({
     const parsed = JSON.parse(str);
     return LetterVariantSchema.parse(parsed);
   }),
+  PINO_LOG_LEVEL: z.coerce.string().optional(),
 });
 
 export type EnvVars = z.infer<typeof EnvVarsSchema>;