001 /*
002 * SPDX-License-Identifier: Apache-2.0
003 *
004 * Copyright 2019-2022 Andres Almiray.
005 *
006 * Licensed under the Apache License, Version 2.0 (the "License");
007 * you may not use this file except in compliance with the License.
008 * You may obtain a copy of the License at
009 *
010 * http://www.apache.org/licenses/LICENSE-2.0
011 *
012 * Unless required by applicable law or agreed to in writing, software
013 * distributed under the License is distributed on an "AS IS" BASIS,
014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
015 * See the License for the specific language governing permissions and
016 * limitations under the License.
017 */
018 package org.kordamp.gradle.plugin.oci.tasks.delete
019
020 import com.oracle.bmc.core.VirtualNetworkClient
021 import com.oracle.bmc.core.model.InternetGateway
022 import com.oracle.bmc.core.requests.DeleteInternetGatewayRequest
023 import com.oracle.bmc.core.requests.GetInternetGatewayRequest
024 import com.oracle.bmc.core.requests.ListInternetGatewaysRequest
025 import groovy.transform.CompileStatic
026 import org.kordamp.gradle.plugin.oci.tasks.AbstractOCITask
027 import org.kordamp.gradle.plugin.oci.tasks.interfaces.OCITask
028 import org.kordamp.gradle.plugin.oci.tasks.traits.CompartmentIdAwareTrait
029 import org.kordamp.gradle.plugin.oci.tasks.traits.OptionalInternetGatewayIdAwareTrait
030 import org.kordamp.gradle.plugin.oci.tasks.traits.OptionalInternetGatewayNameAwareTrait
031 import org.kordamp.gradle.plugin.oci.tasks.traits.VcnIdAwareTrait
032 import org.kordamp.gradle.plugin.oci.tasks.traits.WaitForCompletionAwareTrait
033 import org.kordamp.jipsy.annotations.TypeProviderFor
034
035 import static org.kordamp.gradle.util.StringUtils.isBlank
036 import static org.kordamp.gradle.util.StringUtils.isNotBlank
037
038 /**
039 * @author Andres Almiray
040 * @since 0.1.0
041 */
042 @CompileStatic
043 @TypeProviderFor(OCITask)
044 class DeleteInternetGatewayTask extends AbstractOCITask implements CompartmentIdAwareTrait,
045 VcnIdAwareTrait,
046 OptionalInternetGatewayIdAwareTrait,
047 OptionalInternetGatewayNameAwareTrait,
048 WaitForCompletionAwareTrait {
049 static final String TASK_DESCRIPTION = 'Deletes a InternetGateway.'
050
051 @Override
052 protected void doExecuteTask() {
053 validateInternetGatewayId()
054
055 if (isBlank(getResolvedInternetGatewayId().orNull) && isBlank(getResolvedInternetGatewayName().orNull)) {
056 throw new IllegalStateException("Missing value for either 'internetGatewayId' or 'internetGatewayName' in $path")
057 }
058
059 VirtualNetworkClient client = createVirtualNetworkClient()
060
061 // TODO: check if gateway exists
062 // TODO: check is gateway is in a 'deletable' state
063
064 if (isNotBlank(getResolvedInternetGatewayId().orNull)) {
065 InternetGateway internetGateway = client.getInternetGateway(GetInternetGatewayRequest.builder()
066 .igId(getResolvedInternetGatewayId().get())
067 .build())
068 .internetGateway
069
070 if (internetGateway) {
071 setInternetGatewayName(internetGateway.displayName)
072 deleteInternetGateway(client, internetGateway)
073 }
074 } else {
075 validateCompartmentId()
076 validateVcnId()
077
078 client.listInternetGateways(ListInternetGatewaysRequest.builder()
079 .compartmentId(getResolvedCompartmentId().get())
080 .vcnId(getResolvedVcnId().get())
081 .displayName(getResolvedInternetGatewayName().get())
082 .build())
083 .items.each { internetGateway ->
084 setInternetGatewayId(internetGateway.id)
085 deleteInternetGateway(client, internetGateway)
086 }
087 }
088 }
089
090 private void deleteInternetGateway(VirtualNetworkClient client, InternetGateway internetGateway) {
091 println("Deleting InternetGateway '${internetGateway.displayName}' with id ${internetGateway.id}")
092
093 client.deleteInternetGateway(DeleteInternetGatewayRequest.builder()
094 .igId(internetGateway.id)
095 .build())
096
097 if (getResolvedWaitForCompletion().get()) {
098 println("Waiting for InternetGateway to be ${state('Terminated')}")
099 client.waiters
100 .forInternetGateway(GetInternetGatewayRequest.builder()
101 .igId(internetGateway.id).build(),
102 InternetGateway.LifecycleState.Terminated)
103 .execute()
104 }
105
106 // TODO: remove from vcn routing table
107 }
108 }
|