Add support to consume, process pm message from DB

- Add support for analysing pm data
- Add support to trigger closed loop
- Add support for configDb Interface Implementation
- Add support for Intelligent slicing

Issue-ID: DCAEGEN2-2255
Signed-off-by: dhebeha <dhebeha.mj71@wipro.com>
Change-Id: I185dbb6da45ae6ee74f0a090e2d604914163588b

4 files changed, 367 insertions, 0 deletions

diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AAI.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AAI.java
new file mode 100644
index 00000000..73d94d75
--- /dev/null
+++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AAI.java
@@ -0,0 +1,61 @@
+/*******************************************************************************
+ *  ============LICENSE_START=======================================================
+ *  slice-analysis-ms
+ *  ================================================================================
+ *   Copyright (C) 2020 Wipro Limited.
+ *   ==============================================================================
+ *     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.slice.analysis.ms.models.policy;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** 
+ * Model class for the AAI Object 
+ */
+public class AAI {
+	@JsonProperty("vserver.is-closed-loop-disabled")
+	private String vserverIsClosedLoopDisabled;
+	@JsonProperty("vserver.prov-status")
+	private String vserverProvStatus;
+	@JsonProperty("vserver.vserver-name")
+	private String vserverVserverName;
+
+	public String getVserverIsClosedLoopDisabled() {
+		return vserverIsClosedLoopDisabled;
+	}
+
+	public void setVserverIsClosedLoopDisabled(String vserverIsClosedLoopDisabled) {
+		this.vserverIsClosedLoopDisabled = vserverIsClosedLoopDisabled;
+	}
+
+	public String getVserverProvStatus() {
+		return vserverProvStatus;
+	}
+
+	public void setVserverProvStatus(String vserverProvStatus) {
+		this.vserverProvStatus = vserverProvStatus;
+	}
+
+	public String getVserverVserverName() {
+		return vserverVserverName;
+	}
+
+	public void setVserverVserverName(String vserverVserverName) {
+		this.vserverVserverName = vserverVserverName;
+	}
+
+}
diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AdditionalProperties.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AdditionalProperties.java
new file mode 100644
index 00000000..0d4e4bd8
--- /dev/null
+++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AdditionalProperties.java
@@ -0,0 +1,75 @@
+/*******************************************************************************
+ *  ============LICENSE_START=======================================================
+ *  slice-analysis-ms
+ *  ================================================================================
+ *   Copyright (C) 2020 Wipro Limited.
+ *   ==============================================================================
+ *     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.slice.analysis.ms.models.policy;
+
+import java.util.List;
+import java.util.Map;
+
+/** 
+ * Model class for the AdditionalProperties Object 
+ */
+public class AdditionalProperties<T> {
+	private String modifyAction;
+	private List<String> snssaiList;
+	private String sliceProfileId;
+	private T resourceConfig;
+	private Map<String, String> nsiInfo;
+	private String scriptName;
+	public String getModifyAction() {
+		return modifyAction;
+	}
+	public void setModifyAction(String modifyAction) {
+		this.modifyAction = modifyAction;
+	}
+	public List<String> getSnssaiList() {
+		return snssaiList;
+	}
+	public void setSnssaiList(List<String> snssaiList) {
+		this.snssaiList = snssaiList;
+	}
+	public String getSliceProfileId() {
+		return sliceProfileId;
+	}
+	public void setSliceProfileId(String sliceProfileId) {
+		this.sliceProfileId = sliceProfileId;
+	}
+	public T getResourceConfig() {
+		return resourceConfig;
+	}
+	public void setResourceConfig(T resourceConfig) {
+		this.resourceConfig = resourceConfig;
+	}
+	public Map<String, String> getNsiInfo() {
+		return nsiInfo;
+	}
+	public void setNsiInfo(Map<String, String> nsiInfo) {
+		this.nsiInfo = nsiInfo;
+	}
+	public String getScriptName() {
+		return scriptName;
+	}
+	public void setScriptName(String scriptName) {
+		this.scriptName = scriptName;
+	}
+
+
+}
diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/OnsetMessage.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/OnsetMessage.java
new file mode 100644
index 00000000..671a9561
--- /dev/null
+++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/OnsetMessage.java
@@ -0,0 +1,136 @@
+/*******************************************************************************
+ *  ============LICENSE_START=======================================================
+ *  slice-analysis-ms
+ *  ================================================================================
+ *   Copyright (C) 2020 Wipro Limited.
+ *   ==============================================================================
+ *     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.slice.analysis.ms.models.policy;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** 
+ * Model class for the OnsetMessage Object 
+ */
+public class OnsetMessage {
+
+	private String closedLoopControlName;
+	private Long closedLoopAlarmStart;
+	private String closedLoopEventClient;
+	private String closedLoopEventStatus;
+	private String requestID;
+
+	@JsonProperty("target_type")
+	private String targetType;   
+
+	@JsonProperty("AAI")
+	private AAI aai;
+
+	private String target;
+	private Payload payload;
+	private String from;
+	private String version;
+
+	public String getClosedLoopControlName() {
+		return closedLoopControlName;
+	}
+
+	public void setClosedLoopControlName(String closedLoopControlName) {
+		this.closedLoopControlName = closedLoopControlName;
+	}
+
+	public Long getClosedLoopAlarmStart() {
+		return closedLoopAlarmStart;
+	}
+
+	public void setClosedLoopAlarmStart(Long closedLoopAlarmStart) {
+		this.closedLoopAlarmStart = closedLoopAlarmStart;
+	}
+
+	public String getClosedLoopEventClient() {
+		return closedLoopEventClient;
+	}
+
+	public void setClosedLoopEventClient(String closedLoopEventClient) {
+		this.closedLoopEventClient = closedLoopEventClient;
+	}
+
+	public String getClosedLoopEventStatus() {
+		return closedLoopEventStatus;
+	}
+
+	public void setClosedLoopEventStatus(String closedLoopEventStatus) {
+		this.closedLoopEventStatus = closedLoopEventStatus;
+	}
+
+	public String getRequestID() {
+		return requestID;
+	}
+
+	public void setRequestID(String requestID) {
+		this.requestID = requestID;
+	}
+
+	public String getTargetType() {
+		return targetType;
+	}
+
+	public void setTargetType(String targetType) {
+		this.targetType = targetType;
+	}
+
+	public String getTarget() {
+		return target;
+	}
+
+	public void setTarget(String target) {
+		this.target = target;
+	}
+
+	public AAI getAai() {
+		return aai;
+	}
+
+	public void setAai(AAI aAI) {
+		this.aai = aAI;
+	}
+
+	public Payload getPayload() {
+		return payload;
+	}
+
+	public void setPayload(Payload payload) {
+		this.payload = payload;
+	}
+
+	public String getFrom() {
+		return from;
+	}
+
+	public void setFrom(String from) {
+		this.from = from;
+	}
+
+	public String getVersion() {
+		return version;
+	}
+
+	public void setVersion(String version) {
+		this.version = version;
+	}
+
+}
diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/Payload.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/Payload.java
new file mode 100644
index 00000000..57aab994
--- /dev/null
+++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/Payload.java
@@ -0,0 +1,95 @@
+/*******************************************************************************
+ *  ============LICENSE_START=======================================================
+ *  slice-analysis-ms
+ *  ================================================================================
+ *   Copyright (C) 2020 Wipro Limited.
+ *   ==============================================================================
+ *     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.slice.analysis.ms.models.policy;
+
+/** 
+ * Model class for the Paylaod Object 
+ */
+public class Payload {
+
+	private String name;
+	private String serviceInstanceID;
+	private String globalSubscriberId;
+	private String subscriptionServiceType;
+	private String networkType;
+	private AdditionalProperties<?> additionalProperties;
+
+
+	public String getName() {
+		return name;
+	}
+
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+
+	public String getServiceInstanceID() {
+		return serviceInstanceID;
+	}
+
+
+	public void setServiceInstanceID(String serviceInstanceId) {
+		this.serviceInstanceID = serviceInstanceId;
+	}
+
+
+	public String getGlobalSubscriberId() {
+		return globalSubscriberId;
+	}
+
+
+	public void setGlobalSubscriberId(String globalSubscriberId) {
+		this.globalSubscriberId = globalSubscriberId;
+	}
+
+
+	public String getSubscriptionServiceType() {
+		return subscriptionServiceType;
+	}
+
+
+	public void setSubscriptionServiceType(String subscriptionServiceType) {
+		this.subscriptionServiceType = subscriptionServiceType;
+	}
+
+
+	public String getNetworkType() {
+		return networkType;
+	}
+
+
+	public void setNetworkType(String networkType) {
+		this.networkType = networkType;
+	}
+
+
+	public AdditionalProperties<?> getAdditionalProperties() {
+		return additionalProperties;
+	}
+
+
+	public void setAdditionalProperties(AdditionalProperties<?> additionalProperties) {
+		this.additionalProperties = additionalProperties;
+	}
+
+}