File tree 1 file changed +8
-11
lines changed
tests/Integration.Test/StepDefinitions
1 file changed +8
-11
lines changed Original file line number Diff line number Diff line change @@ -197,6 +197,9 @@ public async Task ThenMessageAreUploadedToStorageService()
197
197
198
198
foreach ( var file in request . Payload )
199
199
{
200
+ var retryCount = 0 ;
201
+ var matchFound = false ;
202
+ RetryVerifyFileUpload :
200
203
var getObjectArgs = new GetObjectArgs ( )
201
204
. WithBucket ( request . Bucket )
202
205
. WithObject ( $ "{ request . PayloadId } /{ file . Path } ")
@@ -210,7 +213,6 @@ public async Task ThenMessageAreUploadedToStorageService()
210
213
var hl7Message = new HL7 . Dotnetcore . Message ( data ) ;
211
214
hl7Message . ParseMessage ( ) ;
212
215
213
- var matchFound = false ;
214
216
foreach ( var key in _input . Keys )
215
217
{
216
218
if ( hl7Message . HL7Message . Equals ( _input [ key ] . SerializeMessage ( true ) ) )
@@ -219,19 +221,14 @@ public async Task ThenMessageAreUploadedToStorageService()
219
221
break ;
220
222
}
221
223
}
222
- if ( ! matchFound )
223
- {
224
- _outputHelper . WriteLine ( $ "HL7 message on MinIO: { hl7Message . HL7Message } ") ;
225
- _outputHelper . WriteLine ( $ "HL7 message in memory:") ;
226
224
227
- foreach ( var file in _input . Values )
228
- {
229
- _outputHelper . WriteLine ( $ "file=>{ file . SerializeMessage ( true ) } ") ;
230
- }
231
- }
232
- matchFound . Should ( ) . BeTrue ( ) ;
233
225
} ) ;
234
226
await minioClient . GetObjectAsync ( getObjectArgs ) ;
227
+ if ( retryCount ++ < 3 && ! matchFound )
228
+ {
229
+ goto RetryVerifyFileUpload ;
230
+ }
231
+ matchFound . Should ( ) . BeTrue ( ) ;
235
232
}
236
233
}
237
234
}
You can’t perform that action at this time.
0 commit comments