void shouldThrowExceptionWhenInvalidCsv()

in src/it/java/com/epam/digital/data/platform/kafkaapi/core/listener/AsyncDataLoadKafkaListenerIT.java [147:176]

25 lines of code
1 McCabe index (conditional complexity)


  void shouldThrowExceptionWhenInvalidCsv(String file, String details) {
    InputStream resourceAsStream1 = AsyncDataLoadKafkaListenerIT.class.getResourceAsStream(file);
    InputStream resourceAsStream2 = AsyncDataLoadKafkaListenerIT.class.getResourceAsStream(file);
    FileDataDto fileDataDto = FileDataDto.builder()
        .content(resourceAsStream1)
        .build();
    when(lowcodeFileDataStorageService.loadByKey(anyString())).thenReturn(fileDataDto);
    when(datafactoryFileDataStorageService.save(anyString(), any())).thenReturn(
        mock(FileMetadataDto.class));

    var payload = getAsyncDataLoadRequest(
        DigestUtils.sha256Hex(IOUtils.toByteArray(Objects.requireNonNull(resourceAsStream2))));
    var message = MessageBuilder
        .withPayload(payload)
        .copyHeaders(buildHeaders())
        .build();

    var result = listener.asyncDataLoad(message);

    var expectedResultPayload = getResponseMessage(Status.OPERATION_FAILED, details).getPayload();
    var resultPayload = objectMapper.readValue(result.getPayload(), AsyncDataLoadResponse.class);

    assertEquals(expectedResultPayload.getDetails(), resultPayload.getDetails());
    assertEquals(expectedResultPayload.getStatus(), resultPayload.getStatus());

    verify(handler, never()).upsert(any());
    verify(transactionManager).rollback(any());
    verify(lowcodeFileDataStorageService).loadByKey(anyString());
    verify(datafactoryFileDataStorageService).save(anyString(), any());
  }