01 /*
02 * SPDX-License-Identifier: Apache-2.0
03 *
04 * Copyright 2019-2022 Andres Almiray.
05 *
06 * Licensed under the Apache License, Version 2.0 (the "License");
07 * you may not use this file except in compliance with the License.
08 * You may obtain a copy of the License at
09 *
10 * http://www.apache.org/licenses/LICENSE-2.0
11 *
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
17 */
18 package org.kordamp.gradle.plugin.oci.tasks.list
19
20 import com.oracle.bmc.objectstorage.ObjectStorageClient
21 import com.oracle.bmc.objectstorage.model.BucketSummary
22 import com.oracle.bmc.objectstorage.requests.ListBucketsRequest
23 import com.oracle.bmc.objectstorage.responses.ListBucketsResponse
24 import groovy.transform.CompileStatic
25 import org.kordamp.gradle.plugin.oci.tasks.AbstractOCITask
26 import org.kordamp.gradle.plugin.oci.tasks.interfaces.OCITask
27 import org.kordamp.gradle.plugin.oci.tasks.traits.CompartmentIdAwareTrait
28 import org.kordamp.gradle.plugin.oci.tasks.traits.NamespaceNameAwareTrait
29 import org.kordamp.gradle.plugin.oci.tasks.traits.OptionalLimitAwareTrait
30 import org.kordamp.gradle.plugin.oci.tasks.traits.OptionalPageAwareTrait
31 import org.kordamp.gradle.plugin.oci.tasks.traits.VerboseAwareTrait
32 import org.kordamp.jipsy.annotations.TypeProviderFor
33
34 import static org.kordamp.gradle.util.StringUtils.isNotBlank
35 import static org.kordamp.gradle.plugin.oci.tasks.printers.BucketSummaryPrinter.printBucketSummary
36
37 /**
38 * @author Andres Almiray
39 * @since 0.3.0
40 */
41 @CompileStatic
42 @TypeProviderFor(OCITask)
43 class ListBucketsTask extends AbstractOCITask implements CompartmentIdAwareTrait,
44 NamespaceNameAwareTrait,
45 OptionalPageAwareTrait,
46 OptionalLimitAwareTrait,
47 VerboseAwareTrait {
48 static final String TASK_DESCRIPTION = 'Lists available Buckets.'
49
50 @Override
51 protected void doExecuteTask() {
52 validateCompartmentId()
53 validateNamespaceName()
54
55 ObjectStorageClient client = createObjectStorageClient()
56 ListBucketsRequest.Builder builder = ListBucketsRequest.builder()
57 .compartmentId(getResolvedCompartmentId().get())
58 .namespaceName(getResolvedNamespaceName().get())
59
60 Integer limit = getResolvedLimit().get() ?: 1000
61 if (null != limit) {
62 builder = builder.limit(limit)
63 }
64
65 String page = getResolvedPage().orNull
66 if (isNotBlank(page)) {
67 builder = builder.page(page)
68 }
69
70 ListBucketsResponse response = client.listBuckets(builder.build())
71
72 println('Total Buckets: ' + console.cyan(response.items.size().toString()))
73 println(' ')
74 for (BucketSummary bucketSummary : response.items) {
75 println(bucketSummary.name + (getResolvedVerbose().get() ? ':' : ''))
76 if (getResolvedVerbose().get()) {
77 printBucketSummary(this, bucketSummary, 0)
78 }
79 }
80 }
81 }
|