package software.amazon.lightsail.distribution; import java.time.Duration; import software.amazon.awssdk.services.lightsail.LightsailClient; import software.amazon.cloudformation.proxy.AmazonWebServicesClientProxy; 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 software.amazon.lightsail.distribution.helpers.handler.DistributionHandler; import static org.assertj.core.api.Assertions.assertThat; import static org.mockito.Mockito.*; @ExtendWith(MockitoExtension.class) public class DeleteHandlerTest extends AbstractTestBase { @Mock private AmazonWebServicesClientProxy proxy; @Mock private ProxyClient proxyClient; @Mock LightsailClient sdkClient; @Mock private DistributionHandler distributionHandler; @BeforeEach public void setup() { proxy = new AmazonWebServicesClientProxy(logger, MOCK_CREDENTIALS, () -> Duration.ofSeconds(600).toMillis()); sdkClient = mock(LightsailClient.class); proxyClient = MOCK_PROXY(proxy, sdkClient); distributionHandler = mock(DistributionHandler.class); } @AfterEach public void tear_down() { } @Test public void handleRequest_SimpleSuccess() { final DeleteHandler deleteHandler = spy(new DeleteHandler()); final CallbackContext callbackContext = new CallbackContext(); final ResourceModel model = ResourceModel.builder().build(); final ResourceHandlerRequest request = ResourceHandlerRequest.builder() .desiredResourceState(model) .build(); doReturn(distributionHandler) .when(deleteHandler).getDistributionHandler(any(), any(), any(), any(), any()); when(distributionHandler.handleDelete(any())) .thenReturn(ProgressEvent.progress(model, callbackContext)); final ProgressEvent response = deleteHandler.handleRequest(proxy, request, new CallbackContext(), proxyClient, logger); verify(distributionHandler, times(1)).handleDelete(ProgressEvent.progress(model, callbackContext)); assertThat(response).isNotNull(); assertThat(response.getStatus()).isEqualTo(OperationStatus.SUCCESS); assertThat(response.getCallbackDelaySeconds()).isEqualTo(0); assertThat(response.getResourceModel()).isNull(); assertThat(response.getResourceModels()).isNull(); assertThat(response.getMessage()).isNull(); assertThat(response.getErrorCode()).isNull(); } }