This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch aws-s3-console in repository https://gitbox.apache.org/repos/asf/camel.git
commit edf32532e6fa802b5a7fddbf25060f0a53c62a65 Author: Andrea Cosentino <[email protected]> AuthorDate: Thu Nov 30 11:58:11 2023 +0100 Added an AWS S3 Console, listing consumers, target bucket name and the type of auth Signed-off-by: Andrea Cosentino <[email protected]> --- .../services/org/apache/camel/dev-console/aws2-s3 | 2 + .../camel/component/aws2/s3/AWS2S3Console.java | 86 ++++++++++++++++++++++ 2 files changed, 88 insertions(+) diff --git a/components/camel-aws/camel-aws2-s3/src/generated/resources/META-INF/services/org/apache/camel/dev-console/aws2-s3 b/components/camel-aws/camel-aws2-s3/src/generated/resources/META-INF/services/org/apache/camel/dev-console/aws2-s3 new file mode 100644 index 00000000000..65131ceecda --- /dev/null +++ b/components/camel-aws/camel-aws2-s3/src/generated/resources/META-INF/services/org/apache/camel/dev-console/aws2-s3 @@ -0,0 +1,2 @@ +# Generated by camel build tools - do NOT edit this file! +class=org.apache.camel.component.aws2.s3.AWS2S3Console diff --git a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Console.java b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Console.java new file mode 100644 index 00000000000..78f35ef028e --- /dev/null +++ b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Console.java @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.camel.component.aws2.s3; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; + +import org.apache.camel.Consumer; +import org.apache.camel.Route; +import org.apache.camel.spi.annotations.DevConsole; +import org.apache.camel.support.console.AbstractDevConsole; +import org.apache.camel.util.json.JsonObject; + +@DevConsole("aws2-s3") +public class AWS2S3Console extends AbstractDevConsole { + + public AWS2S3Console() { + super("camel", "aws2-s3", "AWS S3", "AWS S3 Consumer"); + } + + @Override + protected String doCallText(Map<String, Object> options) { + StringBuilder sb = new StringBuilder(); + + List<Consumer> list = getCamelContext().getRoutes() + .stream().map(Route::getConsumer) + .filter(c -> AWS2S3Consumer.class.getName().equals(c.getClass().getName())) + .collect(Collectors.toList()); + + sb.append(String.format(" %s:%s:%s:%s\n", "bucket", "access keys", "default credentials provider", + "profile credentials provider")); + for (Consumer c : list) { + AWS2S3Consumer nc = (AWS2S3Consumer) c; + AWS2S3Configuration conf = nc.getEndpoint().getConfiguration(); + sb.append(String.format(" %s:%s:%s:%s\n", conf.getBucketName(), + (!conf.isUseDefaultCredentialsProvider() && !conf.isUseProfileCredentialsProvider()), + conf.isUseDefaultCredentialsProvider(), conf.isUseProfileCredentialsProvider())); + } + + return sb.toString(); + } + + @Override + protected JsonObject doCallJson(Map<String, Object> options) { + JsonObject root = new JsonObject(); + + List<Consumer> list = getCamelContext().getRoutes() + .stream().map(Route::getConsumer) + .filter(c -> AWS2S3Consumer.class.getName().equals(c.getClass().getName())) + .collect(Collectors.toList()); + + List<JsonObject> arr = new ArrayList<>(); + for (Consumer c : list) { + AWS2S3Consumer nc = (AWS2S3Consumer) c; + AWS2S3Configuration conf = nc.getEndpoint().getConfiguration(); + + JsonObject jo = new JsonObject(); + jo.put("bucket", conf.getBucketName()); + jo.put("access keys", !conf.isUseDefaultCredentialsProvider() && !conf.isUseProfileCredentialsProvider()); + jo.put("default credentials provider", conf.isUseDefaultCredentialsProvider()); + jo.put("profile credentials provider", conf.isUseProfileCredentialsProvider()); + arr.add(jo); + } + if (!arr.isEmpty()) { + root.put("endpoints", arr); + } + + return root; + } +}
