gerrit.onap Code Review - dcaegen2/collectors/datafile.git/blob

   1 /*-
   2  * ============LICENSE_START======================================================================
   3  * Copyright (C) 2018,2019 Nordix Foundation. All rights reserved.
   4  * ===============================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
   6  * in compliance with the License. You may obtain a copy of the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software distributed under the License
  11  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
  12  * or implied. See the License for the specific language governing permissions and limitations under
  13  * the License.
  14  * ============LICENSE_END========================================================================
  15  */
  16
  17 package org.onap.dcaegen2.collectors.datafile.configuration;
  18
  19 import java.net.MalformedURLException;
  20 import java.net.URL;
  21
  22 import org.immutables.gson.Gson;
  23 import org.immutables.value.Value;
  24 import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.DmaapPublisherConfiguration;
  25 import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.ImmutableDmaapPublisherConfiguration;
  26
  27
  28 @Value.Immutable
  29 @Value.Style(redactedMask = "####")
  30 @Gson.TypeAdapters
  31 public interface PublisherConfiguration {
  32
  33     String publishUrl();
  34
  35     String logUrl();
  36
  37     String userName();
  38
  39     @Value.Redacted
  40     String passWord();
  41
  42     String trustStorePath();
  43
  44     String trustStorePasswordPath();
  45
  46     String keyStorePath();
  47
  48     String keyStorePasswordPath();
  49
  50     Boolean enableDmaapCertAuth();
  51
  52     String changeIdentifier();
  53
  54     default DmaapPublisherConfiguration toDmaap() throws MalformedURLException {
  55         URL url = new URL(publishUrl());
  56         String urlPath = url.getPath();
  57
  58         return new ImmutableDmaapPublisherConfiguration.Builder() //
  59                 .dmaapContentType("application/octet-stream") //
  60                 .dmaapPortNumber(url.getPort()) //
  61                 .dmaapHostName(url.getHost()) //
  62                 .dmaapTopicName(urlPath) //
  63                 .dmaapProtocol(url.getProtocol()) //
  64                 .dmaapUserName(this.userName()) //
  65                 .dmaapUserPassword(this.passWord()) //
  66                 .trustStorePath(this.trustStorePath()) //
  67                 .trustStorePasswordPath(this.trustStorePasswordPath()) //
  68                 .keyStorePath(this.keyStorePath()) //
  69                 .keyStorePasswordPath(this.keyStorePasswordPath()) //
  70                 .enableDmaapCertAuth(this.enableDmaapCertAuth()) //
  71                 .build();
  72     }
  73
  74 }