package software.amazon.lookoutvision.project; import java.time.Duration; import org.mockito.ArgumentMatchers; import software.amazon.awssdk.core.SdkClient; import software.amazon.awssdk.services.lookoutvision.LookoutVisionClient; import software.amazon.awssdk.services.lookoutvision.model.DescribeProjectResponse; import software.amazon.awssdk.services.lookoutvision.model.ProjectDescription; import software.amazon.cloudformation.exceptions.ResourceNotFoundException; import software.amazon.cloudformation.proxy.AmazonWebServicesClientProxy; import software.amazon.cloudformation.proxy.Logger; import software.amazon.cloudformation.proxy.OperationStatus; import software.amazon.cloudformation.proxy.ProgressEvent; import software.amazon.cloudformation.proxy.ProxyClient; import software.amazon.cloudformation.proxy.ResourceHandlerRequest; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.Mock; import org.mockito.junit.jupiter.MockitoExtension; import static org.assertj.core.api.Assertions.assertThat; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.doThrow; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.atLeastOnce; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verifyNoMoreInteractions; @ExtendWith(MockitoExtension.class) public class ReadHandlerTest { private ReadHandler handler; @Mock private AmazonWebServicesClientProxy proxy; @Mock private ProxyClient proxyClient; @Mock private LookoutVisionClient lookoutVisionClient; @Mock private Logger logger; @BeforeEach public void setup() { handler = new ReadHandler(); proxy = mock(AmazonWebServicesClientProxy.class); logger = mock(Logger.class); } @Test public void handleRequest_Success() { final String projectName = "projectName"; final String projectArn = "arn:aws:lookoutvision:us-east-1:111111111111:project/projectName"; final DescribeProjectResponse describeResponse = DescribeProjectResponse.builder() .projectDescription(ProjectDescription.builder() .projectArn(projectArn) .projectName(projectName) .build()) .build(); doReturn(describeResponse) .when(proxy) .injectCredentialsAndInvokeV2( ArgumentMatchers.any(), ArgumentMatchers.any() ); doReturn(lookoutVisionClient) .when(proxyClient) .client(); final ResourceModel expectedOutputModel = ResourceModel.builder() .projectName(projectName) .arn(projectArn) .build(); final ResourceHandlerRequest request = ResourceHandlerRequest.builder() .desiredResourceState(ResourceModel.builder() .projectName(projectName) .build()) .build(); final ProgressEvent response = handler.handleRequest(proxy, request, null, proxyClient, logger); assertThat(response).isNotNull(); assertThat(response.getStatus()).isEqualTo(OperationStatus.SUCCESS); assertThat(response.getCallbackContext()).isNull(); assertThat(response.getCallbackDelaySeconds()).isEqualTo(0); assertThat(response.getResourceModels()).isNull(); assertThat(response.getResourceModel()).isEqualToComparingFieldByField(expectedOutputModel); assertThat(response.getMessage()).isNull(); assertThat(response.getErrorCode()).isNull(); } @Test public void handleRequest_FailureNotFound_WithException() { doThrow(software.amazon.awssdk.services.lookoutvision.model.ResourceNotFoundException.class) .when(proxy) .injectCredentialsAndInvokeV2( ArgumentMatchers.any(), ArgumentMatchers.any() ); doReturn(lookoutVisionClient) .when(proxyClient) .client(); final ResourceHandlerRequest request = ResourceHandlerRequest.builder() .desiredResourceState(ResourceModel.builder() .projectName("projectName") .build()) .build(); assertThrows(ResourceNotFoundException.class, () -> handler.handleRequest(proxy, request, null, proxyClient, logger)); } @Test public void handleRequest_FailureNotFound_NullProjectNameInput() { ResourceModel inputModel = ResourceModel.builder() .build(); final ResourceHandlerRequest request = ResourceHandlerRequest.builder() .desiredResourceState(inputModel) .build(); assertThrows(ResourceNotFoundException.class, () -> handler.handleRequest(proxy, request, null, proxyClient, logger)); } @Test public void handleRequest_FailureNotFound_NullModel() { final ResourceHandlerRequest request = ResourceHandlerRequest.builder() .build(); assertThrows(ResourceNotFoundException.class, () -> handler.handleRequest(proxy, request, null, proxyClient, logger)); } }