Skip to content

Commit c762f1c

Browse files
committed
gh-347 Update unit test
Signed-off-by: Victor Chang <[email protected]>
1 parent 5391dc2 commit c762f1c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/InformaticsGateway/Test/Services/Connectors/PayloadAssemblerTest.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,18 +116,18 @@ public async Task GivenAPayloadAssembler_WhenDisposed_ExpectResourceToBeCleanedU
116116
}
117117

118118
[RetryFact(10, 200)]
119-
public async Task GivenAPayloadThatHasNotCompleteUploads_WhenProcessedByTimedEvent_ExpectToBeAddedToQueue()
119+
public async Task GivenAPayloadThatHasNotCompleteUploads_WhenProcessedByTimedEvent_ExpectToBeRemovedFromQueue()
120120
{
121121
var payloadAssembler = new PayloadAssembler(_options, _logger.Object, _serviceScopeFactory.Object);
122122

123123
var file = new TestStorageInfo(Guid.NewGuid().ToString(), Guid.NewGuid().ToString(), "file1", ".txt");
124-
file.File.SetUploaded("bucket");
125124

126125
await payloadAssembler.Queue("A", file, 1);
127126
await Task.Delay(1001);
128127
payloadAssembler.Dispose();
129128

130-
_repository.Verify(p => p.UpdateAsync(It.Is<Payload>(p => p.State == Payload.PayloadState.Move), It.IsAny<CancellationToken>()), Times.Once());
129+
_repository.Verify(p => p.UpdateAsync(It.Is<Payload>(p => p.State == Payload.PayloadState.Move), It.IsAny<CancellationToken>()), Times.Never());
130+
_logger.VerifyLoggingMessageBeginsWith("Payload deleted due to upload failure(s)", LogLevel.Error, Times.Once());
131131
}
132132

133133
[RetryFact(10, 200)]

0 commit comments

Comments
 (0)