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 @Value.Immutable
  28 @Value.Style(redactedMask = "####")
  29 @Gson.TypeAdapters
  30 public interface PublisherConfiguration {
  31
  32     String publishUrl();
  33
  34     String logUrl();
  35
  36     String userName();
  37
  38     @Value.Redacted
  39     String passWord();
  40
  41     String trustStorePath();
  42
  43     String trustStorePasswordPath();
  44
  45     String keyStorePath();
  46
  47     String keyStorePasswordPath();
  48
  49     Boolean enableDmaapCertAuth();
  50
  51     String changeIdentifier();
  52
  53     /**
  54      * Get the publisher configuration in SDK format.
  55      *
  56      * @return a <code>DmaapPublisherConfiguration</code> contining the publisher configuration.
  57      * @throws MalformedURLException if the publish URL is malformed.
  58      */
  59     default DmaapPublisherConfiguration toDmaap() throws MalformedURLException {
  60         URL url = new URL(publishUrl());
  61         String urlPath = url.getPath();
  62
  63         return new ImmutableDmaapPublisherConfiguration.Builder() //
  64             .endpointUrl(publishUrl()) //
  65             .dmaapContentType("application/octet-stream") //
  66             .dmaapPortNumber(url.getPort()) //
  67             .dmaapHostName(url.getHost()) //
  68             .dmaapTopicName(urlPath) //
  69             .dmaapProtocol(url.getProtocol()) //
  70             .dmaapUserName(this.userName()) //
  71             .dmaapUserPassword(this.passWord()) //
  72             .trustStorePath(this.trustStorePath()) //
  73             .trustStorePasswordPath(this.trustStorePasswordPath()) //
  74             .keyStorePath(this.keyStorePath()) //
  75             .keyStorePasswordPath(this.keyStorePasswordPath()) //
  76             .enableDmaapCertAuth(this.enableDmaapCertAuth()) //
  77             .build();
  78     }
  79 }