@@ -190,25 +190,31 @@ public async Task GivenAPayload_WhenAllFilesAreMove_ExpectPayloadToBeAddedToNoti
190190 } ) ;
191191
192192 var correlationId = Guid . NewGuid ( ) ;
193+ var file1 = new DicomFileStorageMetadata ( correlationId . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) ) ;
194+ file1 . File . SetMoved ( "test" ) ;
195+ file1 . JsonFile . SetMoved ( "test" ) ;
196+ var file2 = new FhirFileStorageMetadata ( correlationId . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Api . Rest . FhirStorageFormat . Json ) ;
197+ file2 . File . SetMoved ( "test" ) ;
193198 var payload = new Payload ( "key" , correlationId . ToString ( ) , 0 )
194199 {
195200 RetryCount = 3 ,
196201 State = Payload . PayloadState . Move ,
197202 Files = new List < FileStorageMetadata >
198203 {
199- new DicomFileStorageMetadata ( correlationId . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) ) ,
200- new FhirFileStorageMetadata ( correlationId . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Guid . NewGuid ( ) . ToString ( ) , Api . Rest . FhirStorageFormat . Json ) ,
204+ file1 ,
205+ file2 ,
201206 } ,
202207 } ;
203208
209+
204210 var handler = new PayloadMoveActionHandler ( _serviceScopeFactory . Object , _logger . Object , _options ) ;
205211
206212 await handler . MoveFilesAsync ( payload , moveAction , notifyAction , _cancellationTokenSource . Token ) ;
207213
208214 Assert . True ( notifyEvent . Wait ( TimeSpan . FromSeconds ( 5 ) ) ) ;
209215
210- _storageService . Verify ( p => p . CopyObjectAsync ( It . IsAny < string > ( ) , It . IsAny < string > ( ) , It . IsAny < string > ( ) , It . IsAny < string > ( ) , It . IsAny < CancellationToken > ( ) ) , Times . AtLeast ( 2 ) ) ;
211- _storageService . Verify ( p => p . RemoveObjectAsync ( It . IsAny < string > ( ) , It . IsAny < string > ( ) , It . IsAny < CancellationToken > ( ) ) , Times . AtLeast ( 2 ) ) ;
216+ // _storageService.Verify(p => p.CopyObjectAsync(It.IsAny<string>(), It.IsAny<string>(), It.IsAny<string>(), It.IsAny<string>(), It.IsAny<CancellationToken>()), Times.AtLeast(2));
217+ // _storageService.Verify(p => p.RemoveObjectAsync(It.IsAny<string>(), It.IsAny<string>(), It.IsAny<CancellationToken>()), Times.AtLeast(2));
212218 }
213219 }
214220}
0 commit comments