back out export changes

Author: nhsd-david-wass

infrastructure/terraform/components/api/event_source_mapping_mi_updates.tf

@@ -1,7 +1,7 @@
 resource "aws_lambda_event_source_mapping" "mi_stream_forwarder_dynamodb" {
   event_source_arn                     = aws_dynamodb_table.mi.stream_arn
   function_name                        = module.mi_stream_forwarder.function_arn
-  starting_position                    = "LATEST"
+  starting_position                    = "TRIM_HORIZON"
   batch_size                           = 10
   maximum_batching_window_in_seconds   = 1
 

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

@@ -4,7 +4,7 @@ import { mockDeep } from "jest-mock-extended";
 import { Context, DynamoDBStreamEvent } from "aws-lambda";
 import { Deps } from "../deps";
 import { EnvVars } from "../env";
-import createHandler from "../mi-stream-forwarder";
+import { createHandler } from "../mi-stream-forwarder";
 
 describe("mi-stream-forwarder Lambda", () => {
   const mockedDeps: jest.Mocked<Deps> = {

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

@@ -1,4 +1,4 @@
-import createHandler from "./mi-stream-forwarder";
+import { createHandler } from "./mi-stream-forwarder";
 import { createDependenciesContainer } from "./deps";
 
 const container = createDependenciesContainer();

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

@@ -4,7 +4,7 @@ import { PutRecordCommand } from "@aws-sdk/client-kinesis";
 import { unmarshall } from "@aws-sdk/util-dynamodb";
 import { Deps } from "./deps";
 
-export default function createHandler(
+export  function createHandler(
   deps: Deps,
 ): Handler<DynamoDBStreamEvent> {
   return async (event: DynamoDBStreamEvent): Promise<void> => {

lambdas/mi-updates-transformer/src/__tests__/mi-updates-transformer.test.ts

@@ -7,10 +7,10 @@ import {
 } from "aws-lambda";
 import { mockDeep } from "jest-mock-extended";
 import { MI } from "@internal/datastore";
-import createHandler from "../mi-updates-transformer";
+import { createHandler } from "../mi-updates-transformer";
 import { Deps } from "../deps";
 import { EnvVars } from "../env";
-import mapMIToCloudEvent from "../mappers/mi-mapper";
+import { mapMIToCloudEvent } from "../mappers/mi-mapper";
 
 // Make crypto return consistent values, since we're calling it in both prod and test code and comparing the values
 const realCrypto = jest.requireActual("crypto");

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

@@ -1,4 +1,4 @@
-import createHandler from "./mi-updates-transformer";
+import { createHandler } from "./mi-updates-transformer";
 import { createDependenciesContainer } from "./deps";
 
 const container = createDependenciesContainer();

lambdas/mi-updates-transformer/src/mappers/__tests__/mi-mapper.test.ts

@@ -1,6 +1,6 @@
 import { $MISubmittedEvent } from "@nhsdigital/nhs-notify-event-schemas-supplier-api/src";
 import { MI } from "@internal/datastore";
-import mapMIToCloudEvent from "../mi-mapper";
+import { mapMIToCloudEvent } from "../mi-mapper";
 
 describe("mi-mapper", () => {
   it("maps an MI to an MI event", async () => {

lambdas/mi-updates-transformer/src/mappers/mi-mapper.ts

@@ -2,7 +2,7 @@ import { MI } from "@internal/datastore";
 import { MISubmittedEvent } from "@nhsdigital/nhs-notify-event-schemas-supplier-api/src";
 import { randomBytes, randomUUID } from "node:crypto";
 
-export default function mapMIToCloudEvent(mi: MI): MISubmittedEvent {
+export function mapMIToCloudEvent(mi: MI): MISubmittedEvent {
   const now = new Date().toISOString();
   const eventId = randomUUID();
   const dataschemaversion = "1.0.0";

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

@@ -4,7 +4,7 @@ import {
   PublishBatchRequestEntry,
 } from "@aws-sdk/client-sns";
 import { MISubmittedEvent } from "@nhsdigital/nhs-notify-event-schemas-supplier-api/src";
-import mapMIToCloudEvent from "./mappers/mi-mapper";
+import { mapMIToCloudEvent } from "./mappers/mi-mapper";
 import { Deps } from "./deps";
 // SNS PublishBatchCommand supports up to 10 messages per batch
 const BATCH_SIZE = 10;
@@ -22,7 +22,7 @@ function buildMessage(event: MISubmittedEvent): PublishBatchRequestEntry {
   };
 }
 
-export default function createHandler(deps: Deps): Handler<KinesisStreamEvent> {
+export function createHandler(deps: Deps): Handler<KinesisStreamEvent> {
   return async (streamEvent: KinesisStreamEvent) => {
     deps.logger.info({ description: "Received event", streamEvent });