1 /*******************************************************************************
2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
17 * ============LICENSE_END=========================================================
19 * ECOMP is a trademark and service mark of AT&T Intellectual Property.
21 *******************************************************************************/
22 package com.att.dmf.mr.utils;
24 import javax.servlet.ServletException;
26 import org.I0Itec.zkclient.ZkClient;
27 import org.apache.curator.framework.CuratorFramework;
28 import org.springframework.beans.factory.annotation.Autowired;
29 import org.springframework.beans.factory.annotation.Qualifier;
30 import org.springframework.stereotype.Component;
32 import com.att.dmf.mr.backends.ConsumerFactory;
33 import com.att.dmf.mr.backends.MetricsSet;
34 import com.att.dmf.mr.backends.Publisher;
35 import com.att.dmf.mr.backends.kafka.KafkaConsumerCache.KafkaConsumerCacheException;
36 import com.att.dmf.mr.backends.memory.MemoryConsumerFactory;
37 import com.att.dmf.mr.backends.memory.MemoryMetaBroker;
38 import com.att.dmf.mr.backends.memory.MemoryQueue;
39 import com.att.dmf.mr.backends.memory.MemoryQueuePublisher;
40 import com.att.dmf.mr.beans.DMaaPCambriaLimiter;
41 import com.att.dmf.mr.beans.DMaaPKafkaMetaBroker;
42 import com.att.dmf.mr.beans.DMaaPZkConfigDb;
43 import com.att.dmf.mr.constants.CambriaConstants;
44 import com.att.dmf.mr.metabroker.Broker;
46 import com.att.dmf.mr.metabroker.Broker1;
47 import com.att.dmf.mr.security.DMaaPAuthenticator;
48 import com.att.dmf.mr.security.impl.DMaaPOriginalUebAuthenticator;
49 import com.att.eelf.configuration.EELFLogger;
50 import com.att.eelf.configuration.EELFManager;
51 import com.att.nsa.configs.ConfigDbException;
52 import com.att.nsa.configs.confimpl.MemConfigDb;
53 import com.att.nsa.drumlin.till.nv.rrNvReadable;
54 import com.att.nsa.drumlin.till.nv.rrNvReadable.invalidSettingValue;
55 import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
56 import com.att.nsa.limits.Blacklist;
57 import com.att.nsa.security.NsaAuthenticatorService;
59 import com.att.nsa.security.db.BaseNsaApiDbImpl;
60 import com.att.nsa.security.db.NsaApiDb;
61 import com.att.nsa.security.db.NsaApiDb.KeyExistsException;
62 import com.att.nsa.security.db.simple.NsaSimpleApiKey;
63 import com.att.nsa.security.db.simple.NsaSimpleApiKeyFactory;
66 * Class is created for all the configuration for rest and service layer
71 public class ConfigurationReader {
74 private Broker1 fMetaBroker;
75 private ConsumerFactory fConsumerFactory;
76 private Publisher fPublisher;
77 private MetricsSet fMetrics;
79 private DMaaPCambriaLimiter fRateLimiter;
80 private NsaApiDb<NsaSimpleApiKey> fApiKeyDb;
82 private DMaaPAuthenticator<NsaSimpleApiKey> fSecurityManager;
83 private NsaAuthenticatorService<NsaSimpleApiKey> nsaSecurityManager;
84 private static CuratorFramework curator;
86 private DMaaPZkConfigDb fConfigDb;
87 private MemoryQueue q;
88 private MemoryMetaBroker mmb;
89 private Blacklist fIpBlackList;
90 private Emailer fEmailer;
92 private static final EELFLogger log = EELFManager.getInstance().getLogger(ConfigurationReader.class);
96 * constructor to initialize all the values
104 * @param fConsumerFactory
109 * @param fSecurityManager
110 * @throws missingReqdSetting
111 * @throws invalidSettingValue
112 * @throws ServletException
113 * @throws KafkaConsumerCacheException
114 * @throws ConfigDbException
115 * @throws KeyExistsException
118 public ConfigurationReader(@Qualifier("propertyReader") rrNvReadable settings,
119 @Qualifier("dMaaPMetricsSet") MetricsSet fMetrics, @Qualifier("dMaaPZkClient") ZkClient zk,
120 @Qualifier("dMaaPZkConfigDb") DMaaPZkConfigDb fConfigDb, @Qualifier("kafkaPublisher") Publisher fPublisher,
121 @Qualifier("curator") CuratorFramework curator,
122 @Qualifier("dMaaPKafkaConsumerFactory") ConsumerFactory fConsumerFactory,
123 @Qualifier("dMaaPKafkaMetaBroker") Broker1 fMetaBroker,
124 @Qualifier("q") MemoryQueue q,
125 @Qualifier("mmb") MemoryMetaBroker mmb, @Qualifier("dMaaPNsaApiDb") NsaApiDb<NsaSimpleApiKey> fApiKeyDb,
127 * @Qualifier("dMaaPTranDb")
128 * DMaaPTransactionObjDB<DMaaPTransactionObj> fTranDb,
130 @Qualifier("dMaaPAuthenticatorImpl") DMaaPAuthenticator<NsaSimpleApiKey> fSecurityManager
132 throws missingReqdSetting, invalidSettingValue, ServletException, KafkaConsumerCacheException, ConfigDbException, KeyExistsException {
134 this.fMetrics = fMetrics;
136 this.fConfigDb = fConfigDb;
137 this.fPublisher = fPublisher;
138 ConfigurationReader.curator = curator;
139 this.fConsumerFactory = fConsumerFactory;
140 this.fMetaBroker = fMetaBroker;
144 this.fApiKeyDb = fApiKeyDb;
146 this.fSecurityManager = fSecurityManager;
148 long allowedtimeSkewMs=600000L;
149 String strallowedTimeSkewM= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"authentication.allowedTimeSkewMs");
150 if(null!=strallowedTimeSkewM)allowedtimeSkewMs= Long.parseLong(strallowedTimeSkewM);
153 //String strrequireSecureChannel= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"aauthentication.requireSecureChannel");
154 //if(strrequireSecureChannel!=null)requireSecureChannel=Boolean.parseBoolean(strrequireSecureChannel);
155 //this.nsaSecurityManager = new NsaAuthenticatorService<NsaSimpleApiKey>(this.fApiKeyDb, settings.getLong("authentication.allowedTimeSkewMs", 600000L), settings.getBoolean("authentication.requireSecureChannel", true));
156 //this.nsaSecurityManager = new NsaAuthenticatorService<NsaSimpleApiKey>(this.fApiKeyDb, allowedtimeSkewMs, requireSecureChannel);
161 protected void servletSetup()
162 throws rrNvReadable.missingReqdSetting, rrNvReadable.invalidSettingValue, ServletException, ConfigDbException, KeyExistsException {
166 fMetrics.setupCambriaSender();
167 // add the admin authenticator
169 final String adminSecret = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kSetting_AdminSecret);
171 if ( adminSecret != null && adminSecret.length () > 0 )
174 final NsaApiDb<NsaSimpleApiKey> adminDb = new BaseNsaApiDbImpl<NsaSimpleApiKey> ( new MemConfigDb(), new NsaSimpleApiKeyFactory() );
175 adminDb.createApiKey ( "admin", adminSecret );
177 fSecurityManager.addAuthenticator ( new DMaaPOriginalUebAuthenticator<NsaSimpleApiKey> ( adminDb, 10*60*1000 ) );
183 String type = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kBrokerType);
184 if (type==null) type = CambriaConstants.kBrokerType_Kafka;
185 if (CambriaConstants.kBrokerType_Kafka.equalsIgnoreCase(type)) {
186 log.info("Broker Type is:" + CambriaConstants.kBrokerType_Kafka);
187 } else if (CambriaConstants.kBrokerType_Memory.equalsIgnoreCase(type)) {
188 log.info("Broker Type is:" + CambriaConstants.kBrokerType_Memory);
189 fPublisher = new MemoryQueuePublisher(q, mmb);
190 //Ramkumar remove below
191 // fMetaBroker = mmb;
192 fConsumerFactory = new MemoryConsumerFactory(q);
194 throw new IllegalArgumentException(
195 "Unrecognized type for " + CambriaConstants.kBrokerType + ": " + type + ".");
197 fIpBlackList = new Blacklist ( getfConfigDb(), getfConfigDb().parse ( "/ipBlacklist" ) );
198 this.fEmailer = new Emailer();
199 log.info("Broker Type is:" + type);
201 } catch (SecurityException e) {
202 throw new ServletException(e);
207 * method returns metaBroker
211 public Broker1 getfMetaBroker() {
216 * method to set the metaBroker
220 public void setfMetaBroker(Broker1 fMetaBroker) {
221 this.fMetaBroker = fMetaBroker;
225 * method to get ConsumerFactory Object
229 public ConsumerFactory getfConsumerFactory() {
230 return fConsumerFactory;
234 * method to set the consumerfactory object
236 * @param fConsumerFactory
238 public void setfConsumerFactory(ConsumerFactory fConsumerFactory) {
239 this.fConsumerFactory = fConsumerFactory;
243 * method to get Publisher object
247 public Publisher getfPublisher() {
252 * method to set Publisher object
256 public void setfPublisher(Publisher fPublisher) {
257 this.fPublisher = fPublisher;
261 * method to get MetricsSet Object
265 public MetricsSet getfMetrics() {
270 * method to set MetricsSet Object
274 public void setfMetrics(MetricsSet fMetrics) {
275 this.fMetrics = fMetrics;
279 * method to get DMaaPCambriaLimiter object
283 public DMaaPCambriaLimiter getfRateLimiter() {
288 * method to set DMaaPCambriaLimiter object
290 * @param fRateLimiter
292 public void setfRateLimiter(DMaaPCambriaLimiter fRateLimiter) {
293 this.fRateLimiter = fRateLimiter;
297 * Method to get DMaaPAuthenticator object
301 public DMaaPAuthenticator<NsaSimpleApiKey> getfSecurityManager() {
302 return fSecurityManager;
306 * method to set DMaaPAuthenticator object
308 * @param fSecurityManager
310 public void setfSecurityManager(DMaaPAuthenticator<NsaSimpleApiKey> fSecurityManager) {
311 this.fSecurityManager = fSecurityManager;
315 * method to get rrNvReadable object
319 /*public rrNvReadable getSettings() {
324 * method to set rrNvReadable object
328 /*public void setSettings(rrNvReadable settings) {
329 this.settings = settings;
333 * method to get CuratorFramework object
337 public static CuratorFramework getCurator() {
342 * method to set CuratorFramework object
346 public static void setCurator(CuratorFramework curator) {
347 ConfigurationReader.curator = curator;
351 * method to get ZkClient object
355 public ZkClient getZk() {
360 * method to set ZkClient object
364 public void setZk(ZkClient zk) {
369 * method to get DMaaPZkConfigDb object
373 public DMaaPZkConfigDb getfConfigDb() {
378 * method to set DMaaPZkConfigDb object
382 public void setfConfigDb(DMaaPZkConfigDb fConfigDb) {
383 this.fConfigDb = fConfigDb;
387 * method to get MemoryQueue object
391 public MemoryQueue getQ() {
396 * method to set MemoryQueue object
400 public void setQ(MemoryQueue q) {
405 * method to get MemoryMetaBroker object
409 public MemoryMetaBroker getMmb() {
414 * method to set MemoryMetaBroker object
418 public void setMmb(MemoryMetaBroker mmb) {
423 * method to get NsaApiDb object
427 public NsaApiDb<NsaSimpleApiKey> getfApiKeyDb() {
432 * method to set NsaApiDb object
436 public void setfApiKeyDb(NsaApiDb<NsaSimpleApiKey> fApiKeyDb) {
437 this.fApiKeyDb = fApiKeyDb;
441 * public DMaaPTransactionObjDB<DMaaPTransactionObj> getfTranDb() { return
444 * public void setfTranDb(DMaaPTransactionObjDB<DMaaPTransactionObj>
445 * fTranDb) { this.fTranDb = fTranDb; }
448 * method to get the zookeeper connection String
453 public static String getMainZookeeperConnectionString() {
454 //return settings.getString(CambriaConstants.kSetting_ZkConfigDbServers, CambriaConstants.kDefault_ZkConfigDbServers);
456 String zkServername = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kSetting_ZkConfigDbServers);
457 if (zkServername==null) zkServername=CambriaConstants.kDefault_ZkConfigDbServers;
461 public static String getMainZookeeperConnectionSRoot(){
462 String strVal=com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kSetting_ZkConfigDbRoot);
465 strVal=CambriaConstants.kDefault_ZkConfigDbRoot;
470 public Blacklist getfIpBlackList() {
474 public void setfIpBlackList(Blacklist fIpBlackList) {
475 this.fIpBlackList = fIpBlackList;
478 public NsaAuthenticatorService<NsaSimpleApiKey> getNsaSecurityManager() {
479 return nsaSecurityManager;
482 public void setNsaSecurityManager(NsaAuthenticatorService<NsaSimpleApiKey> nsaSecurityManager) {
483 this.nsaSecurityManager = nsaSecurityManager;
486 public Emailer getSystemEmailer()
488 return this.fEmailer;