Apply builder pattern for topic cnsmer prdcr

Modify endpoints event bus related classes to use builder pattern
in particular apply bus topic params object instead of
using parameters as it is. Rework based on commnts

Issue-ID: POLICY-1017
Change-Id: I572a72fa525cf4f664eb70d0415be73116499bd2
Signed-off-by: krisjinka <kris.jinka@samsung.com>

1 files changed, 316 insertions, 0 deletions

diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java
new file mode 100644
index 00000000..ffefcbf2
--- /dev/null
+++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java
@@ -0,0 +1,316 @@
+/*
+ * ============LICENSE_START=======================================================
+ * policy-endpoints
+ * ================================================================================
+ * Copyright (C) 2018 Samsung Electronics Co., Ltd. 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.policy.common.endpoints.event.comm.bus.internal;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Member variables of this Params class are as follows
+ * servers DMaaP servers
+ * topic DMaaP Topic to be monitored
+ * apiKey DMaaP API Key (optional)
+ * apiSecret DMaaP API Secret (optional)
+ * consumerGroup DMaaP Reader Consumer Group
+ * consumerInstance DMaaP Reader Instance
+ * fetchTimeout DMaaP fetch timeout
+ * fetchLimit DMaaP fetch limit
+ * environment DME2 Environment
+ * aftEnvironment DME2 AFT Environment
+ * partner DME2 Partner
+ * latitude DME2 Latitude
+ * longitude DME2 Longitude
+ * additionalProps Additional properties to pass to DME2
+ * useHttps does connection use HTTPS?
+ * allowSelfSignedCerts are self-signed certificates allow
+ */
+public class BusTopicParams {
+
+    public static TopicParamsBuilder builder() {
+        return new TopicParamsBuilder();
+    }
+
+    private List<String> servers;
+    private String topic;
+    private String apiKey;
+    private String apiSecret;
+    private String consumerGroup;
+    private String consumerInstance;
+    private int fetchTimeout;
+    private int fetchLimit;
+    private boolean useHttps;
+    private boolean allowSelfSignedCerts;
+
+    private String userName;
+    private String password;
+    private String environment;
+    private String aftEnvironment;
+    private String partner;
+    private String latitude;
+    private String longitude;
+    private Map<String, String> additionalProps;
+    private String partitionId;
+
+    String getPartitionId() {
+        return partitionId;
+    }
+
+    String getUserName() {
+        return userName;
+    }
+
+    String getPassword() {
+        return password;
+    }
+
+    String getEnvironment() {
+        return environment;
+    }
+
+    String getAftEnvironment() {
+        return aftEnvironment;
+    }
+
+    String getPartner() {
+        return partner;
+    }
+
+    String getLatitude() {
+        return latitude;
+    }
+
+    String getLongitude() {
+        return longitude;
+    }
+
+    Map<String, String> getAdditionalProps() {
+        return additionalProps;
+    }
+
+    List<String> getServers() {
+        return servers;
+    }
+
+    String getTopic() {
+        return topic;
+    }
+
+    String getApiKey() {
+        return apiKey;
+    }
+
+    String getApiSecret() {
+        return apiSecret;
+    }
+
+    String getConsumerGroup() {
+        return consumerGroup;
+    }
+
+    String getConsumerInstance() {
+        return consumerInstance;
+    }
+
+    int getFetchTimeout() {
+        return fetchTimeout;
+    }
+
+    int getFetchLimit() {
+        return fetchLimit;
+    }
+
+    boolean isUseHttps() {
+        return useHttps;
+    }
+
+    boolean isAllowSelfSignedCerts() {
+        return allowSelfSignedCerts;
+    }
+
+    boolean isEnvironmentNullOrEmpty() {
+        return (environment == null || environment.trim().isEmpty());
+    }
+
+    boolean isAftEnvironmentNullOrEmpty() {
+        return (aftEnvironment == null || aftEnvironment.trim().isEmpty());
+    }
+
+    boolean isLatitudeNullOrEmpty() {
+        return (latitude == null || latitude.trim().isEmpty());
+    }
+
+    boolean isLongitudeNullOrEmpty() {
+        return (longitude == null || longitude.trim().isEmpty());
+    }
+
+    boolean isConsumerInstanceNullOrEmpty() {
+        return (consumerInstance == null || consumerInstance.trim().isEmpty());
+    }
+
+    boolean isConsumerGroupNullOrEmpty() {
+        return (consumerGroup == null || consumerGroup.trim().isEmpty());
+    }
+
+    boolean isApiKeyValid() {
+        return !(apiKey == null || apiKey.trim().isEmpty());
+    }
+
+    boolean isApiSecretValid() {
+        return !(apiSecret == null || apiSecret.trim().isEmpty());
+    }
+
+    boolean isUserNameValid() {
+        return !(userName == null || userName.trim().isEmpty());
+    }
+
+    boolean isPasswordValid() {
+        return !(password == null || password.trim().isEmpty());
+    }
+
+    boolean isPartnerNullOrEmpty() {
+        return (partner == null || partner.trim().isEmpty());
+    }
+
+    boolean isServersNullOrEmpty() {
+        return (servers == null || servers.isEmpty()
+                || (servers.size() == 1 && ("".equals(servers.get(0)))));
+    }
+
+    boolean isAdditionalPropsValid() {
+        return additionalProps != null;
+    }
+
+    boolean isTopicNullOrEmpty() {
+        return (topic == null || topic.trim().isEmpty());
+    }
+
+    boolean isPartitionIdNullOrEmpty() {
+        return (partitionId == null || partitionId.trim().isEmpty());
+    }
+
+    public static class TopicParamsBuilder {
+        BusTopicParams m = new BusTopicParams();
+
+        private TopicParamsBuilder() {
+        }
+
+        public TopicParamsBuilder servers(List<String> servers) {
+            this.m.servers = servers;
+            return this;
+        }
+
+        public TopicParamsBuilder topic(String topic) {
+            this.m.topic = topic;
+            return this;
+        }
+
+        public TopicParamsBuilder apiKey(String apiKey) {
+            this.m.apiKey = apiKey;
+            return this;
+        }
+
+        public TopicParamsBuilder apiSecret(String apiSecret) {
+            this.m.apiSecret = apiSecret;
+            return this;
+        }
+
+        public TopicParamsBuilder consumerGroup(String consumerGroup) {
+            this.m.consumerGroup = consumerGroup;
+            return this;
+        }
+
+        public TopicParamsBuilder consumerInstance(String consumerInstance) {
+            this.m.consumerInstance = consumerInstance;
+            return this;
+        }
+
+        public TopicParamsBuilder fetchTimeout(int fetchTimeout) {
+            this.m.fetchTimeout = fetchTimeout;
+            return this;
+        }
+
+        public TopicParamsBuilder fetchLimit(int fetchLimit) {
+            this.m.fetchLimit = fetchLimit;
+            return this;
+        }
+
+        public TopicParamsBuilder useHttps(boolean useHttps) {
+            this.m.useHttps = useHttps;
+            return this;
+        }
+
+        public TopicParamsBuilder allowSelfSignedCerts(boolean allowSelfSignedCerts) {
+            this.m.allowSelfSignedCerts = allowSelfSignedCerts;
+            return this;
+        }
+
+        public TopicParamsBuilder userName(String userName) {
+            this.m.userName = userName;
+            return this;
+        }
+
+        public TopicParamsBuilder password(String password) {
+            this.m.password = password;
+            return this;
+        }
+
+        public TopicParamsBuilder environment(String environment) {
+            this.m.environment = environment;
+            return this;
+        }
+
+        public TopicParamsBuilder aftEnvironment(String aftEnvironment) {
+            this.m.aftEnvironment = aftEnvironment;
+            return this;
+        }
+
+        public TopicParamsBuilder partner(String partner) {
+            this.m.partner = partner;
+            return this;
+        }
+
+        public TopicParamsBuilder latitude(String latitude) {
+            this.m.latitude = latitude;
+            return this;
+        }
+
+        public TopicParamsBuilder longitude(String longitude) {
+            this.m.longitude = longitude;
+            return this;
+        }
+
+        public TopicParamsBuilder additionalProps(Map<String, String> additionalProps) {
+            this.m.additionalProps = additionalProps;
+            return this;
+        }
+
+        public TopicParamsBuilder partitionId(String partitionId) {
+            this.m.partitionId = partitionId;
+            return this;
+        }
+
+        public BusTopicParams build() {
+            return m;
+        }
+
+    }
+}
+