99 PublishBatchCommand ,
1010 PublishBatchRequestEntry ,
1111} from "@aws-sdk/client-sns" ;
12- import { LetterEvent } from "@nhsdigital/nhs-notify-event-schemas-supplier-api/src" ;
12+ import { LetterStatusChangeEvent } from "@nhsdigital/nhs-notify-event-schemas-supplier-api/src" ;
1313import { MetricEntry , buildEMFObject } from "@internal/helpers" ;
1414import { Letter , LetterSchema } from "@internal/datastore" ;
1515import { mapLetterToCloudEvent } from "@internal/event-builders/src" ;
@@ -33,7 +33,7 @@ export default function createHandler(deps: Deps): Handler<KinesisStreamEvent> {
3333 extractPayload ( record , deps ) ,
3434 ) ;
3535
36- const cloudEvents : LetterEvent [ ] = ddbRecords
36+ const cloudEvents : LetterStatusChangeEvent [ ] = ddbRecords
3737 . filter ( ( record ) => filterRecord ( record , deps ) )
3838 . map ( ( element ) => extractNewLetter ( element ) )
3939 . map ( ( element ) => mapLetterToCloudEvent ( element , deps . env . EVENT_SOURCE ) ) ;
@@ -59,7 +59,7 @@ export default function createHandler(deps: Deps): Handler<KinesisStreamEvent> {
5959 } ;
6060}
6161
62- function populateEventTypeMap ( cloudEvents : LetterEvent [ ] ) {
62+ function populateEventTypeMap ( cloudEvents : LetterStatusChangeEvent [ ] ) {
6363 const evtMap = new Map < string , number > ( ) ;
6464 for ( const event of cloudEvents ) {
6565 evtMap . set ( event . type , ( evtMap . get ( event . type ) || 0 ) + 1 ) ;
@@ -142,14 +142,14 @@ function extractNewLetter(record: DynamoDBRecord): Letter {
142142 return LetterSchema . parse ( unmarshall ( newImage as any ) ) ;
143143}
144144
145- function * generateBatches ( events : LetterEvent [ ] ) {
145+ function * generateBatches ( events : LetterStatusChangeEvent [ ] ) {
146146 for ( let i = 0 ; i < events . length ; i += BATCH_SIZE ) {
147147 yield events . slice ( i , i + BATCH_SIZE ) ;
148148 }
149149}
150150
151151function buildMessage (
152- event : LetterEvent ,
152+ event : LetterStatusChangeEvent ,
153153 index : number ,
154154) : PublishBatchRequestEntry {
155155 return {
0 commit comments