1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
/*
* ================================================================================
* Copyright (c) 2019-2020 China Mobile. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*
*/
package org.onap.dcae.analytics.tca.web;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Stream;
import org.onap.dcae.analytics.model.AnalyticsProfile;
import org.onap.dcae.analytics.model.TcaModelConstants;
import org.onap.dcae.analytics.model.configbindingservice.BaseConfigBindingServiceProperties;
import org.onap.dcae.analytics.model.configbindingservice.ConfigBindingServiceConstants;
import org.springframework.core.env.Environment;
import lombok.Data;
import lombok.ToString;
/**
* @author Kai Lu
*/
public class TcaAppProperties extends BaseConfigBindingServiceProperties {
private final Environment environment;
public TcaAppProperties(final Environment environment) {
this.environment = environment;
}
/**
* TCA Application properties
*/
@Data
public static class Tca {
private String policy;
private Integer processingBatchSize = TcaModelConstants.DEFAULT_TCA_PROCESSING_BATCH_SIZE;
private Boolean enableAbatement = TcaModelConstants.DEFAULT_ABATEMENT_ENABLED;
private Boolean enableEcompLogging = TcaModelConstants.DEFAULT_ECOMP_LOGGING_ENABLED;
private Aai aai = new Aai();
}
/**
* A&AI properties
*/
@Data
@ToString(exclude = "password")
public static class Aai {
private Boolean enableEnrichment = TcaModelConstants.DEFAULT_AAI_ENRICHMENT_ENABLED;
private String url;
private String username;
private String password;
private String proxyUrl = null;
private Boolean ignoreSSLValidation = TcaModelConstants.DEFAULT_TCA_AAI_IGNORE_SSL_VALIDATION;
private String genericVnfPath = TcaModelConstants.DEFAULT_TCA_AAI_GENERIC_VNF_PATH;
private String nodeQueryPath = TcaModelConstants.DEFAULT_TCA_AAI_NODE_QUERY_PATH;
}
public Tca getTca() {
Tca tca = new Tca();
tca.setPolicy(environment.getProperty(ConfigBindingServiceConstants.POLICY));
tca.setProcessingBatchSize(environment.getProperty(ConfigBindingServiceConstants.PROCESSINGBATCHSIZE, Integer.class));
tca.setEnableAbatement(environment.getProperty(ConfigBindingServiceConstants.ENABLEABATEMENT, Boolean.class));
tca.setEnableEcompLogging(environment.getProperty(ConfigBindingServiceConstants.EnableEcompLogging, Boolean.class));
Aai aai = tca.getAai();
aai.setEnableEnrichment(environment.getProperty(ConfigBindingServiceConstants.EnableEnrichment, Boolean.class));
aai.setUrl(environment.getProperty(ConfigBindingServiceConstants.AAIURL));
aai.setUsername(environment.getProperty(ConfigBindingServiceConstants.AAIUSERNAME));
aai.setPassword(environment.getProperty(ConfigBindingServiceConstants.AAIPASSWORD));
aai.setGenericVnfPath(ConfigBindingServiceConstants.AAIGENERICVNFPATH);
aai.setNodeQueryPath(environment.getProperty(ConfigBindingServiceConstants.AAINODEQUERYPATH));
tca.setAai(aai);
return tca;
}
@Override
public Map<String, PublisherDetails> getStreamsPublishes() {
DmaapInfo dmaapInfo = new DmaapInfo();
dmaapInfo.setTopicUrl(environment.getProperty(ConfigBindingServiceConstants.PUBTOPICURL));
PublisherDetails detail = new PublisherDetails();
detail.setType(environment.getProperty(ConfigBindingServiceConstants.PUBTYPE));
detail.setDmaapInfo(dmaapInfo);
streamsPublishes.put(ConfigBindingServiceConstants.PUBKEY, detail);
return streamsPublishes;
}
@Override
public Map<String, SubscriberDetails> getStreamsSubscribes() {
DmaapInfo dmaapInfo = new DmaapInfo();
dmaapInfo.setTopicUrl(environment.getProperty(ConfigBindingServiceConstants.SUBTOPICURL));
AutoAdjusting autoAdjust = new AutoAdjusting();
autoAdjust.setStepUp(environment.getProperty(ConfigBindingServiceConstants.SUBAUTOADJUSTINGSTEPUP, Integer.class));
autoAdjust.setStepDown(environment.getProperty(ConfigBindingServiceConstants.SUBAUTOADJUSTINGSTEPDOWN, Integer.class));
autoAdjust.setMax(environment.getProperty(ConfigBindingServiceConstants.SUBAUTOADJUSTINGMAX, Integer.class));
autoAdjust.setMin(environment.getProperty(ConfigBindingServiceConstants.SUBAUTOADJUSTINGMIN, Integer.class));
Polling poll = new Polling();
poll.setAutoAdjusting(autoAdjust);
poll.setFixedRate(environment.getProperty(ConfigBindingServiceConstants.SUBFIXEDRATE, Integer.class));
SubscriberDetails detail = new SubscriberDetails();
detail.setType(environment.getProperty(ConfigBindingServiceConstants.SUBTYPE));
detail.setDmaapInfo(dmaapInfo);
detail.setPolling(poll);
detail.setConsumerGroup(environment.getProperty(ConfigBindingServiceConstants.SUBCONSUMERGROUP));
detail.setMessageLimit(environment.getProperty(ConfigBindingServiceConstants.SUBMESSAGELIMIT, Integer.class));
detail.setTimeout(environment.getProperty(ConfigBindingServiceConstants.SUBTIMEOUT, Integer.class));
List<String> consumerIds = new ArrayList<>();
consumerIds.add(environment.getProperty(ConfigBindingServiceConstants.SUBCONSUMERIDS0));
consumerIds.add(environment.getProperty(ConfigBindingServiceConstants.SUBCONSUMERIDS1));
detail.setConsumerIds(consumerIds);
streamsSubscribes.put(ConfigBindingServiceConstants.SUBKEY, detail);
return streamsSubscribes;
}
public boolean isConfigBindingServiceProfileActive() {
return Stream.of(environment.getActiveProfiles())
.anyMatch(profile ->
profile.equalsIgnoreCase(AnalyticsProfile.CONFIG_BINDING_SERVICE_PROFILE_NAME));
}
}
|
