Integration Test Demo givenUploadTasksOnUserCreation

givenUploadTasksOnUserCreation.java

    private List<UUID> givenUploadTasksOnUserCreation() {
        sqsTestHelper.givenAPublishedUserCreatedMessageAwaitedToBeConsumed(testUserCreatedMessage);

        final UserDocumentUploadTaskDto[] response = httpRequestHelper.whenGetUploadTasksForUser(tenantUser(testUserCreatedMessage.getUserUuid()))
                .then()
                .statusCode(HttpStatus.OK.value())
                .extract().body().as(UserDocumentUploadTaskDto[].class);

        final List<NotificationMessageDto> notificationMessageDtos = sqsTestHelper.retrieveNotificationMessages();
        assertThat(notificationMessageDtos).hasSize(1);
        assertThat(notificationMessageDtos.get(0).getUserId()).isEqualTo(testUserCreatedMessage.getUserUuid());

        assertThat(response).containsExactlyInAnyOrderElementsOf(buildExpectedResponse(testUserCreatedMessage));
        return Arrays.asList(response).stream().map(UserDocumentUploadTaskDto::getDocumentId).collect(Collectors.toList());
    }