+++ /dev/null
-/*-
- * ============LICENSE_START======================================================================
- * Copyright (C) 2018, 2020-2022 Nokia. All rights reserved.
- * Copyright (C) 2018-2019 Nordix Foundation. All rights reserved.
- * ===============================================================================================
- * Licensed 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.
- * ============LICENSE_END========================================================================
- */
-
-package org.onap.dcaegen2.collectors.datafile.configuration;
-
-import java.util.Properties;
-
-import lombok.Getter;
-
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.stereotype.Component;
-
-/**
- * Holds all configuration for the DFC.
- *
- * @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on
- * 3/23/18
- * @author <a href="mailto:henrik.b.andersson@est.tech">Henrik Andersson</a>
- */
-
-@Component
-@EnableConfigurationProperties
-public class AppConfig {
-
- @Value("#{systemEnvironment}")
- Properties systemEnvironment;
-
- @Value("${app.kafka.bootstrap-servers:}")
- private String kafkaBootStrapServers;
-
- @Value("${app.kafka.collected-file-topic:}")
- public String collectedFileTopic;
-
- @Value("${app.kafka.file-ready-event-topic:}")
- public String fileReadyEventTopic;
-
- @Value("${app.kafka.client-id:undefined}")
- public String kafkaClientId;
-
- @Value("${app.collected-files-path:}")
- public String collectedFilesPath;
-
- @Value("${app.sftp.strict-host-key-checking:false}")
- public boolean strictHostKeyChecking;
-
- @Value("${app.sftp.known-hosts-file-path:}")
- public String knownHostsFilePath;
-
- @Value("${app.ssl.key-store-password-file}")
- private String clientKeyStorePassword = "";
-
- @Value("${app.ssl.key-store:}")
- private String clientKeyStore = "";
-
- @Value("${app.ssl.trust-store:}")
- private String clientTrustStore = "";
-
- @Value("${app.ssl.trust-store-password-file:}")
- private String clientTrustStorePassword;
-
- @Getter
- @Value("${app.s3.endpointOverride:}")
- private String s3EndpointOverride;
-
- @Getter
- @Value("${app.s3.accessKeyId:}")
- private String s3AccessKeyId;
-
- @Getter
- @Value("${app.s3.secretAccessKey:}")
- private String s3SecretAccessKey;
-
- @Getter
- @Value("${app.s3.bucket:}")
- private String s3Bucket;
-
- @Value("${app.s3.locksBucket:}")
- private String s3LocksBucket;
-
- @Value("${app.number-of-worker-treads:200}")
- @Getter
- private int noOfWorkerThreads;
-
- public String getS3LocksBucket() {
- return s3LocksBucket.isEmpty() ? s3Bucket : s3LocksBucket;
- }
-
- public boolean isS3Enabled() {
- return !s3EndpointOverride.isEmpty() && !s3Bucket.isEmpty();
- }
-
- public String getKafkaBootStrapServers() {
- return kafkaBootStrapServers;
- }
-
- public synchronized CertificateConfig getCertificateConfiguration() {
- return CertificateConfig.builder() //
- .trustedCa(this.clientTrustStore) //
- .trustedCaPasswordPath(this.clientTrustStorePassword) //
- .keyCert(this.clientKeyStore) //
- .keyPasswordPath(this.clientKeyStorePassword) //
- .build();
- }
-
- public synchronized SftpConfig getSftpConfiguration() {
- return SftpConfig.builder() //
- .knownHostsFilePath(this.knownHostsFilePath) //
- .strictHostKeyChecking(this.strictHostKeyChecking) //
- .build();
- }
-
-}