appc-asdc-listener/appc-asdc-listener-bundle/src/main/java/org/openecomp/appc/sdc/listener/AsdcConfig.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : APP-C
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights
   6  *                                              reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.openecomp.appc.sdc.listener;
  23
  24 import com.att.eelf.configuration.EELFLogger;
  25 import com.att.eelf.configuration.EELFManager;
  26 import org.openecomp.sdc.api.consumer.IConfiguration;
  27
  28 import java.net.URI;
  29 import java.util.*;
  30
  31 public class AsdcConfig implements IConfiguration {
  32
  33         private String host;
  34         private String consumer;
  35         private String consumerId;
  36         private String env;
  37         private String keystorePath;
  38         private String keystorePass;
  39         private int pollingInterval; // Time between listening sessions
  40         private int pollingTimeout; // Time to listen for (dmaap timeout url param)/1000
  41         private List<String> types = new ArrayList<>(1);
  42         private String user;
  43         private String pass;
  44
  45         private URI storeOp;
  46
  47         Properties props;
  48
  49         private final EELFLogger logger = EELFManager.getInstance().getLogger(AsdcConfig.class);
  50
  51         public AsdcConfig(Properties props) throws Exception {
  52                 this.props = props;
  53                 init();
  54         }
  55
  56         private void init() throws Exception {
  57                 if (props != null) {
  58                         // Keystore for ca cert
  59                         keystorePath = props.getProperty("appc.asdc.keystore.path");
  60                         keystorePass = props.getProperty("appc.asdc.keystore.pass");
  61
  62                         // ASDC host
  63                         host = props.getProperty("appc.asdc.host");
  64                         env = props.getProperty("appc.asdc.env");
  65                         user = props.getProperty("appc.asdc.user");
  66                         pass = props.getProperty("appc.asdc.pass");
  67
  68                         // DMaaP properties
  69                         consumer = props.getProperty("appc.asdc.consumer");
  70                         consumerId = props.getProperty("appc.asdc.consumer.id");
  71
  72                         pollingInterval = Integer.valueOf(props.getProperty("interval", "60"));
  73
  74                         // Client uses cambriaClient-0.2.4 which throws non relevant (wrong)
  75                         // exceptions with times > 30s
  76                         pollingTimeout = Integer.valueOf(props.getProperty("timeout", "25"));
  77
  78                         // Anything less than 60 and we risk 429 Too Many Requests
  79                         if (pollingInterval < 60) {
  80                                 pollingInterval = 60;
  81                         }
  82
  83                         if (pollingInterval > pollingInterval) {
  84                                 logger.warn(String.format(
  85                                                 "Message acknowledgement may be delayed by %ds in the ADSC listener. [Listening Time: %s, Poll Period: %s]",
  86                                                 pollingInterval - pollingTimeout, pollingTimeout, pollingInterval));
  87                         }
  88
  89                         logParams();
  90
  91                         // Download type
  92                         types.add("APPC_CONFIG");
  93                         types.add("VF_LICENSE");
  94
  95                         storeOp = new URI(props.getProperty("appc.asdc.provider.url"));
  96                 }
  97         }
  98
  99         @Override
 100         public boolean activateServerTLSAuth() {
 101                 return false;
 102         }
 103
 104         //@Override
 105         public boolean isFilterInEmptyResources() {
 106                 return false;
 107         }
 108
 109         @Override
 110         public String getAsdcAddress() {
 111                 return host;
 112         }
 113
 114         @Override
 115         public String getConsumerGroup() {
 116                 return consumer;
 117         }
 118
 119         @Override
 120         public String getConsumerID() {
 121                 return consumerId;
 122         }
 123
 124         @Override
 125         public String getEnvironmentName() {
 126                 return env;
 127         }
 128
 129         @Override
 130         public String getKeyStorePassword() {
 131                 return keystorePass;
 132         }
 133
 134         @Override
 135         public String getKeyStorePath() {
 136                 return keystorePath;
 137         }
 138
 139         @Override
 140         public String getPassword() {
 141                 return pass;
 142         }
 143
 144         @Override
 145         public int getPollingInterval() {
 146                 return pollingInterval;
 147         }
 148
 149         @Override
 150         public int getPollingTimeout() {
 151                 return pollingTimeout;
 152         }
 153
 154         @Override
 155         public List<String> getRelevantArtifactTypes() {
 156                 return types;
 157         }
 158
 159         @Override
 160         public String getUser() {
 161                 return user;
 162         }
 163
 164         public URI getStoreOpURI() {
 165                 return storeOp;
 166         }
 167
 168         /**
 169          * Logs the relevant parameters
 170          */
 171         public void logParams() {
 172                 Map<String, String> params = new HashMap<String, String>();
 173                 params.put("ASDC Host", getAsdcAddress());
 174                 params.put("ASDC Environment", getEnvironmentName());
 175                 params.put("Consumer Name", getConsumerGroup());
 176                 params.put("Consumer ID", getConsumerID());
 177                 params.put("Poll Active Wait", String.valueOf(getPollingInterval()));
 178                 params.put("Poll Timeout", String.valueOf(getPollingTimeout()));
 179
 180                 logger.info(String.format("ASDC Params: %s", params));
 181         }
 182 }