Skip to content

Instantly share code, notes, and snippets.

View MemoAlfa's full-sized avatar

Memo Alaloush MemoAlfa

View GitHub Profile
@Test
void whenATENANTUserCreatedMessageIsConsumed_UserUploadsRequiredDocuments_OperatorAcceptedThem_ShouldPublishDocumentUploadCompletedMessageDto() throws IOException {
testUserCreatedMessage = testUserCreatedMessage.toBuilder().userType(UserType.TENANT).build();
final List<UUID> userDocumentUploadIds = givenUploadTasksOnUserCreation();
givenUserSuccessFullyUploadedRequiredDocuments(userDocumentUploadIds);
givenOperatorAcceptedAllDocuments(userDocumentUploadIds);
final List<DocumentUploadCompletedMessageDto> documentUploadCompletedMessageDto = sqsTestHelper.retrieveDocumentUploadCompletedMessageDto();
assertThat(documentUploadCompletedMessageDto).hasSize(1);