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.collectors.datafile.exceptions.DatafileTaskException;
  25 import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.DmaapConsumerConfiguration;
  26 import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.ImmutableDmaapConsumerConfiguration;
  27
  28 @Value.Immutable
  29 @Value.Style(redactedMask = "####")
  30 @Gson.TypeAdapters
  31 public abstract class ConsumerConfiguration {
  32     @Value.Redacted
  33     public abstract String topicUrl();
  34
  35     public abstract String trustStorePath();
  36
  37     public abstract String trustStorePasswordPath();
  38
  39     public abstract String keyStorePath();
  40
  41     public abstract String keyStorePasswordPath();
  42
  43     public abstract Boolean enableDmaapCertAuth();
  44
  45     public DmaapConsumerConfiguration toDmaap() throws DatafileTaskException {
  46         try {
  47             URL url = new URL(topicUrl());
  48             String passwd = "";
  49             String userName = "";
  50             if (url.getUserInfo() != null) {
  51                 String[] userInfo = url.getUserInfo().split(":");
  52                 userName = userInfo[0];
  53                 passwd = userInfo[1];
  54             }
  55             String urlPath = url.getPath();
  56             DmaapConsumerUrlPath path = parseDmaapUrlPath(urlPath);
  57
  58             return new ImmutableDmaapConsumerConfiguration.Builder() //
  59                     .dmaapContentType("application/json") //
  60                     .dmaapPortNumber(url.getPort()) //
  61                     .dmaapHostName(url.getHost()) //
  62                     .dmaapTopicName(path.dmaapTopicName) //
  63                     .dmaapProtocol(url.getProtocol()) //
  64                     .dmaapUserName(userName) //
  65                     .dmaapUserPassword(passwd) //
  66                     .trustStorePath(this.trustStorePath()) //
  67                     .trustStorePasswordPath(this.trustStorePasswordPath()) //
  68                     .keyStorePath(this.keyStorePath()) //
  69                     .keyStorePasswordPath(this.keyStorePasswordPath()) //
  70                     .enableDmaapCertAuth(this.enableDmaapCertAuth()) //
  71                     .consumerId(path.consumerId) //
  72                     .consumerGroup(path.consumerGroup) //
  73                     .timeoutMs(-1) //
  74                     .messageLimit(-1) //
  75                     .build();
  76         } catch (MalformedURLException e) {
  77             throw new DatafileTaskException("Could not parse the URL", e);
  78         }
  79     }
  80
  81     private class DmaapConsumerUrlPath {
  82         final String dmaapTopicName;
  83         final String consumerGroup;
  84         final String consumerId;
  85
  86         DmaapConsumerUrlPath(String dmaapTopicName, String consumerGroup, String consumerId) {
  87             this.dmaapTopicName = dmaapTopicName;
  88             this.consumerGroup = consumerGroup;
  89             this.consumerId = consumerId;
  90         }
  91     }
  92
  93     private DmaapConsumerUrlPath parseDmaapUrlPath(String urlPath) throws DatafileTaskException {
  94         String[] tokens = urlPath.split("/"); // UrlPath: /events/unauthenticated.VES_NOTIFICATION_OUTPUT/OpenDcae-c12/C12
  95         if (tokens.length != 5) {
  96             throw new DatafileTaskException("The path has incorrect syntax: " + urlPath);
  97         }
  98
  99         final String dmaapTopicName =  tokens[1] + "/" + tokens[2]; // ex. // /events/unauthenticated.VES_NOTIFICATION_OUTPUT
 100         final String consumerGroup = tokens[3]; // ex. OpenDcae-c12
 101         final String consumerId = tokens[4]; // ex. C12
 102         return new DmaapConsumerUrlPath(dmaapTopicName, consumerGroup, consumerId);
 103     }
 104
 105 }