@@ -110,7 +110,9 @@ describe('sqs-trigger-lambda', () => {
110110 } ) ;
111111
112112 it ( 'should process multiple messages successfully' , async ( ) => {
113- mockUploadToPdm . send . mockResolvedValue ( { outcome : 'sent' } ) ;
113+ mockRandomUUID . mockReturnValueOnce ( '11111111-1111-1111-1111-111111111111' ) ;
114+ mockRandomUUID . mockReturnValueOnce ( '22222222-2222-2222-2222-222222222222' ) ;
115+ mockUploadToPdm . send . mockResolvedValue ( { outcome : 'sent' , resourceId : 'resource-123' } ) ;
114116 const handler = createHandler ( {
115117 uploadToPdm : mockUploadToPdm ,
116118 eventPublisher : mockEventPublisher ,
@@ -131,6 +133,19 @@ describe('sqs-trigger-lambda', () => {
131133 expect ( result . batchItemFailures ) . toEqual ( [ ] ) ;
132134 expect ( mockUploadToPdm . send ) . toHaveBeenCalledTimes ( 2 ) ;
133135 expect ( mockEventPublisher . sendEvents ) . toHaveBeenCalledTimes ( 1 ) ;
136+ expect ( mockEventPublisher . sendEvents ) . toHaveBeenCalledWith (
137+ expect . arrayContaining ( [
138+ expect . objectContaining ( {
139+ type : 'uk.nhs.notify.digital.letters.pdm.resource.submitted.v1' ,
140+ id : '11111111-1111-1111-1111-111111111111' ,
141+ } ) ,
142+ expect . objectContaining ( {
143+ type : 'uk.nhs.notify.digital.letters.pdm.resource.submitted.v1' ,
144+ id : '22222222-2222-2222-2222-222222222222' ,
145+ } ) ,
146+ ] ) ,
147+ expect . anything ( ) ,
148+ ) ;
134149 expect ( mockLogger . info ) . toHaveBeenCalledWith (
135150 expect . objectContaining ( {
136151 retrieved : 2 ,
0 commit comments