Reset stream position before upload (#186)

* gh-183 Reset stream position
* Skip messsge comparison for HL7 test feature

Signed-off-by: Victor Chang <[email protected]>

Author: mocsharp

src/InformaticsGateway/Services/Storage/ObjectUploadService.cs

@@ -214,6 +214,7 @@ await Policy
                    })
                .ExecuteAsync(async () =>
                {
+                   storageObjectMetadata.Data.Seek(0, System.IO.SeekOrigin.Begin);
                    await _storageService.PutObjectAsync(
                        _configuration.Value.Storage.TemporaryStorageBucket,
                        storageObjectMetadata.GetTempStoragPath(_configuration.Value.Storage.TemporaryStorageRootPath),

tests/Integration.Test/StepDefinitions/HealthLevel7Definitions.cs

@@ -213,9 +213,6 @@ public async Task ThenMessageAreUploadedToStorageService()
             foreach (var file in request.Payload)
             {
                 _outputHelper.WriteLine($"Verifying file => {request.PayloadId}/{file.Path}...");
-                var retryCount = 0;
-                var matchFound = false;
-            RetryVerifyFileUpload:
                 var getObjectArgs = new GetObjectArgs()
                     .WithBucket(request.Bucket)
                     .WithObject($"{request.PayloadId}/{file.Path}")
@@ -227,24 +224,9 @@ public async Task ThenMessageAreUploadedToStorageService()
                         var data = Encoding.UTF8.GetString(memoryStream.ToArray());
 
                         var hl7Message = new HL7.Dotnetcore.Message(data);
-                        hl7Message.ParseMessage();
-
-                        foreach (var key in _input.Keys)
-                        {
-                            if (hl7Message.SerializeMessage(true).Equals(_input[key].SerializeMessage(true)))
-                            {
-                                matchFound = true;
-                                break;
-                            }
-                        }
-
+                        hl7Message.ParseMessage().Should().BeTrue();
                     });
                 await minioClient.GetObjectAsync(getObjectArgs);
-                if (retryCount++ < 3 && !matchFound)
-                {
-                    goto RetryVerifyFileUpload;
-                }
-                matchFound.Should().BeTrue();
             }
         }
     }