summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAbhishek Patil <abhishek.patil@t-systems.com>2023-03-31 10:39:46 +0530
committerAbhishek Patil <abhishek.patil@t-systems.com>2023-03-31 10:39:46 +0530
commit4647e3ef6c87e271794e06fb1660cad5ee72ab04 (patch)
treecfd7b52595ea2f0f500648b26293893fa4adaa76
parentdbbde62a1ee7a1f46bd9ccdf1d2c46fc90779dff (diff)
Code changes in SO api-handler for RAN Slice
Issue-ID: SO-4038 Change-Id: Ifad4e0a65dc810a753d30741a84c08081bcfd258 Signed-off-by: Patil <Abhishek.Patil@t-systems.com>
-rw-r--r--bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowType.java1
-rw-r--r--common/src/main/java/org/onap/so/moi/Attributes.java82
-rw-r--r--common/src/main/java/org/onap/so/moi/GETMoiResponse.java102
-rw-r--r--common/src/main/java/org/onap/so/moi/MoiAllocateRequest.java55
-rw-r--r--common/src/main/java/org/onap/so/moi/PlmnId.java68
-rw-r--r--common/src/main/java/org/onap/so/moi/PlmnInfo.java68
-rw-r--r--common/src/main/java/org/onap/so/moi/RANSliceSubnetProfile.java143
-rw-r--r--common/src/main/java/org/onap/so/moi/SliceProfile.java84
-rw-r--r--common/src/main/java/org/onap/so/moi/Snssai.java68
-rw-r--r--docs/api/apis/ManagedObject3gppServiceInstances.rst262
-rw-r--r--docs/api/offered_consumed_apis.rst1
-rw-r--r--docs/api/swagger/swagger.json315
-rw-r--r--graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIRestClientImpl.java12
-rw-r--r--mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java3
-rw-r--r--mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/JerseyConfiguration.java1
-rw-r--r--mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ManagedObject3gppServiceInstances.java568
-rw-r--r--mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfile.json26
-rw-r--r--mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfileBadGateWay.json26
-rw-r--r--mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/DeleteSliceProfile.json9
-rw-r--r--mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/ModifySliceProfile.json13
20 files changed, 1905 insertions, 2 deletions
diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowType.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowType.java
index 0a60724b6c..f3077882e7 100644
--- a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowType.java
+++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowType.java
@@ -32,6 +32,7 @@ public enum WorkflowType {
NETWORKCOLLECTION("NetworkCollection"),
CONFIGURATION("Configuration"),
INSTANCE_GROUP("InstanceGroup"),
+ NETWORK_SLICE_SUBNET("NetworkSliceSubnet"),
CNF("Cnf");
private final String type;
diff --git a/common/src/main/java/org/onap/so/moi/Attributes.java b/common/src/main/java/org/onap/so/moi/Attributes.java
new file mode 100644
index 0000000000..72d00c2b90
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/Attributes.java
@@ -0,0 +1,82 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.*;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"sliceProfileList"})
+public class Attributes {
+
+ @JsonProperty("sliceProfileList")
+ private List<SliceProfile> sliceProfileList = null;
+
+ @JsonProperty("operationalState")
+ private String operationalState;
+
+ @JsonProperty("administrativeState")
+ private String administrativeState;
+
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("sliceProfileList")
+ public List<SliceProfile> getSliceProfileList() {
+ return sliceProfileList;
+ }
+
+ @JsonProperty("sliceProfileList")
+ public void setSliceProfileList(List<SliceProfile> sliceProfileList) {
+ this.sliceProfileList = sliceProfileList;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperty(String name, Object value) {
+ this.additionalProperties.put(name, value);
+ }
+
+ @JsonProperty("operationalState")
+ public String getOperationalState() {
+ return operationalState;
+ }
+
+ @JsonProperty("operationalState")
+ public void setOperationalState(String operationalState) {
+ this.operationalState = operationalState;
+ }
+
+ @JsonProperty("administrativeState")
+ public String getAdministrativeState() {
+ return administrativeState;
+ }
+
+ @JsonProperty("administrativeState")
+ public void setAdministrativeState(String administrativeState) {
+ this.administrativeState = administrativeState;
+ }
+}
diff --git a/common/src/main/java/org/onap/so/moi/GETMoiResponse.java b/common/src/main/java/org/onap/so/moi/GETMoiResponse.java
new file mode 100644
index 0000000000..569b3a45a3
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/GETMoiResponse.java
@@ -0,0 +1,102 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.HashMap;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"id", "operationalState", "administrativeState", "attributes"})
+public class GETMoiResponse {
+
+ @JsonProperty("id")
+ private String id = null;
+
+ @JsonProperty("operationalState")
+ private String operationalState = null;
+
+ @JsonProperty("administrativeState")
+ private String administrativeState = null;
+
+ @Autowired
+ @JsonProperty("attributes")
+ private Attributes attributes;
+
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("id")
+ public String getId() {
+ return id;
+ }
+
+ @JsonProperty("id")
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ @JsonProperty("operationalState")
+ public String getOperationalState() {
+ return operationalState;
+ }
+
+ @JsonProperty("operationalState")
+ public void setOperationalState(String operationalState) {
+ this.operationalState = operationalState;
+ }
+
+ @JsonProperty("administrativeState")
+ public String getAdministrativeState() {
+ return administrativeState;
+ }
+
+ @JsonProperty("administrativeState")
+ public void setAdministrativeState(String administrativeState) {
+ this.administrativeState = administrativeState;
+ }
+
+ @JsonProperty("attributes")
+ public Attributes getAttributes() {
+ return attributes;
+ }
+
+ @JsonProperty("attributes")
+ public void setAttributes(Attributes attributes) {
+ this.attributes = attributes;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperties(Map<String, Object> additionalProperties) {
+ this.additionalProperties = additionalProperties;
+ }
+}
diff --git a/common/src/main/java/org/onap/so/moi/MoiAllocateRequest.java b/common/src/main/java/org/onap/so/moi/MoiAllocateRequest.java
new file mode 100644
index 0000000000..cc4f02051d
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/MoiAllocateRequest.java
@@ -0,0 +1,55 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.*;
+import java.util.HashMap;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"attributes"})
+public class MoiAllocateRequest {
+
+ @JsonProperty("attributes")
+ private Attributes attributes;
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("attributes")
+ public Attributes getAttributes() {
+ return attributes;
+ }
+
+ @JsonProperty("attributes")
+ public void setAttributes(Attributes attributes) {
+ this.attributes = attributes;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperty(String name, Object value) {
+ this.additionalProperties.put(name, value);
+ }
+
+}
diff --git a/common/src/main/java/org/onap/so/moi/PlmnId.java b/common/src/main/java/org/onap/so/moi/PlmnId.java
new file mode 100644
index 0000000000..77a44bd414
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/PlmnId.java
@@ -0,0 +1,68 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.*;
+import java.util.HashMap;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"mcc", "mnc"})
+public class PlmnId {
+
+ @JsonProperty("mcc")
+ private Integer mcc;
+ @JsonProperty("mnc")
+ private Integer mnc;
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("mcc")
+ public Integer getMcc() {
+ return mcc;
+ }
+
+ @JsonProperty("mcc")
+ public void setMcc(Integer mcc) {
+ this.mcc = mcc;
+ }
+
+ @JsonProperty("mnc")
+ public Integer getMnc() {
+ return mnc;
+ }
+
+ @JsonProperty("mnc")
+ public void setMnc(Integer mnc) {
+ this.mnc = mnc;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperty(String name, Object value) {
+ this.additionalProperties.put(name, value);
+ }
+
+}
diff --git a/common/src/main/java/org/onap/so/moi/PlmnInfo.java b/common/src/main/java/org/onap/so/moi/PlmnInfo.java
new file mode 100644
index 0000000000..bd16423d38
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/PlmnInfo.java
@@ -0,0 +1,68 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.*;
+import java.util.HashMap;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"plmnId", "snssai"})
+public class PlmnInfo {
+
+ @JsonProperty("plmnId")
+ private PlmnId plmnId;
+ @JsonProperty("snssai")
+ private Snssai snssai;
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("plmnId")
+ public PlmnId getPlmnId() {
+ return plmnId;
+ }
+
+ @JsonProperty("plmnId")
+ public void setPlmnId(PlmnId plmnId) {
+ this.plmnId = plmnId;
+ }
+
+ @JsonProperty("snssai")
+ public Snssai getSnssai() {
+ return snssai;
+ }
+
+ @JsonProperty("snssai")
+ public void setSnssai(Snssai snssai) {
+ this.snssai = snssai;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperty(String name, Object value) {
+ this.additionalProperties.put(name, value);
+ }
+
+}
diff --git a/common/src/main/java/org/onap/so/moi/RANSliceSubnetProfile.java b/common/src/main/java/org/onap/so/moi/RANSliceSubnetProfile.java
new file mode 100644
index 0000000000..dc2bac50b4
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/RANSliceSubnetProfile.java
@@ -0,0 +1,143 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.*;
+import javax.annotation.Generated;
+import java.util.HashMap;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"coverageAreaTAList", "dLLatency", "uLLatency", "resourceSharingLevel", "serviceType",
+ "maxNumberofUEs"})
+@Generated("jsonschema2pojo")
+public class RANSliceSubnetProfile {
+
+ @JsonProperty("coverageAreaTAList")
+ private Integer coverageAreaTAList;
+ @JsonProperty("latency")
+ private Integer latency;
+ @JsonProperty("dLLatency")
+ private Integer dLLatency;
+ @JsonProperty("uLLatency")
+ private Integer uLLatency;
+ @JsonProperty("resourceSharingLevel")
+ private String resourceSharingLevel;
+ @JsonProperty("serviceType")
+ private String serviceType;
+ @JsonProperty("maxNumberofUEs")
+ private Integer maxNumberofUEs;
+ @JsonProperty("areaTrafficCapDL")
+ private Integer areaTrafficCapDL;
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("coverageAreaTAList")
+ public Integer getCoverageAreaTAList() {
+ return coverageAreaTAList;
+ }
+
+ @JsonProperty("coverageAreaTAList")
+ public void setCoverageAreaTAList(Integer coverageAreaTAList) {
+ this.coverageAreaTAList = coverageAreaTAList;
+ }
+
+ @JsonProperty("dLLatency")
+ public Integer getdLLatency() {
+ return dLLatency;
+ }
+
+ @JsonProperty("dLLatency")
+ public void setdLLatency(Integer dLLatency) {
+ this.dLLatency = dLLatency;
+ }
+
+ @JsonProperty("uLLatency")
+ public Integer getuLLatency() {
+ return uLLatency;
+ }
+
+ @JsonProperty("uLLatency")
+ public void setuLLatency(Integer uLLatency) {
+ this.uLLatency = uLLatency;
+ }
+
+ @JsonProperty("resourceSharingLevel")
+ public String getResourceSharingLevel() {
+ return resourceSharingLevel;
+ }
+
+ @JsonProperty("resourceSharingLevel")
+ public void setResourceSharingLevel(String resourceSharingLevel) {
+ this.resourceSharingLevel = resourceSharingLevel;
+ }
+
+ @JsonProperty("serviceType")
+ public String getServiceType() {
+ return serviceType;
+ }
+
+ @JsonProperty("serviceType")
+ public void setServiceType(String serviceType) {
+ this.serviceType = serviceType;
+ }
+
+ @JsonProperty("maxNumberofUEs")
+ public Integer getMaxNumberofUEs() {
+ return maxNumberofUEs;
+ }
+
+ @JsonProperty("maxNumberofUEs")
+ public void setMaxNumberofUEs(Integer maxNumberofUEs) {
+ this.maxNumberofUEs = maxNumberofUEs;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperty(String name, Object value) {
+ this.additionalProperties.put(name, value);
+ }
+
+ @JsonProperty("areaTrafficCapDL")
+ public Integer getAreaTrafficCapDL() {
+ return this.areaTrafficCapDL;
+ }
+
+ @JsonProperty("latency")
+ public Integer getLatency() {
+ return latency;
+ }
+
+ @JsonProperty("latency")
+ public void setLatency(Integer latency) {
+ this.latency = latency;
+ }
+
+ @JsonProperty("areaTrafficCapDL")
+ public void setAreaTrafficCapDL(Integer areaTrafficCapDL) {
+ this.areaTrafficCapDL = areaTrafficCapDL;
+ }
+
+}
diff --git a/common/src/main/java/org/onap/so/moi/SliceProfile.java b/common/src/main/java/org/onap/so/moi/SliceProfile.java
new file mode 100644
index 0000000000..ec6104f4fe
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/SliceProfile.java
@@ -0,0 +1,84 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.*;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"sliceProfileId", "plmnInfoList", "RANSliceSubnetProfile"})
+public class SliceProfile {
+
+ @JsonProperty("sliceProfileId")
+ private String sliceProfileId = null;
+
+ @JsonProperty("plmnInfoList")
+ private List<PlmnInfo> plmnInfoList = null;
+
+ @JsonProperty("RANSliceSubnetProfile")
+ private RANSliceSubnetProfile rANSliceSubnetProfile;
+
+ @JsonProperty("sliceProfileId")
+ public String getSliceProfileId() {
+ return sliceProfileId;
+ }
+
+ @JsonProperty("sliceProfileId")
+ public void setSliceProfileId(String sliceProfileId) {
+ this.sliceProfileId = sliceProfileId;
+ }
+
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("plmnInfoList")
+ public List<PlmnInfo> getPlmnInfoList() {
+ return plmnInfoList;
+ }
+
+ @JsonProperty("plmnInfoList")
+ public void setPlmnInfoList(List<PlmnInfo> plmnInfoList) {
+ this.plmnInfoList = plmnInfoList;
+ }
+
+ @JsonProperty("RANSliceSubnetProfile")
+ public RANSliceSubnetProfile getRANSliceSubnetProfile() {
+ return rANSliceSubnetProfile;
+ }
+
+ @JsonProperty("RANSliceSubnetProfile")
+ public void setrANSliceSubnetProfile(RANSliceSubnetProfile rANSliceSubnetProfile) {
+ this.rANSliceSubnetProfile = rANSliceSubnetProfile;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperty(String name, Object value) {
+ this.additionalProperties.put(name, value);
+ }
+
+}
diff --git a/common/src/main/java/org/onap/so/moi/Snssai.java b/common/src/main/java/org/onap/so/moi/Snssai.java
new file mode 100644
index 0000000000..8ed2892817
--- /dev/null
+++ b/common/src/main/java/org/onap/so/moi/Snssai.java
@@ -0,0 +1,68 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2023 DTAG Intellectual Property. 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.so.moi;
+
+import com.fasterxml.jackson.annotation.*;
+import java.util.HashMap;
+import java.util.Map;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonPropertyOrder({"sst", "sd"})
+public class Snssai {
+
+ @JsonProperty("sst")
+ private String sst;
+ @JsonProperty("sd")
+ private String sd;
+ @JsonIgnore
+ private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @JsonProperty("sst")
+ public String getSst() {
+ return sst;
+ }
+
+ @JsonProperty("sst")
+ public void setSst(String sst) {
+ this.sst = sst;
+ }
+
+ @JsonProperty("sd")
+ public String getSd() {
+ return sd;
+ }
+
+ @JsonProperty("sd")
+ public void setSd(String sd) {
+ this.sd = sd;
+ }
+
+ @JsonAnyGetter
+ public Map<String, Object> getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ @JsonAnySetter
+ public void setAdditionalProperty(String name, Object value) {
+ this.additionalProperties.put(name, value);
+ }
+
+}
diff --git a/docs/api/apis/ManagedObject3gppServiceInstances.rst b/docs/api/apis/ManagedObject3gppServiceInstances.rst
new file mode 100644
index 0000000000..1d3336a2d1
--- /dev/null
+++ b/docs/api/apis/ManagedObject3gppServiceInstances.rst
@@ -0,0 +1,262 @@
+.. This work is licensed under a Creative Commons Attribution 4.0 International License.
+.. http://creativecommons.org/licenses/by/4.0
+.. Copyright 2023 DTAG
+
+ManagedObject3gppServiceInstances API
+=====================================
+
+Create a ManagedObject3gppServiceInstances
+++++++++++++++++++++++++++++++++++++++++++
+
++--------------------+------------------------------------------------------------+
+|Interface Definition|Description |
++====================+============================================================+
+|URI |onap/so/infra/moi/api/rest/v1/NetworkSliceSubnet/$NSSID |
++--------------------+------------------------------------------------------------+
+|Operation Type |PUT |
++--------------------+------------------------------------------------------------+
+|Content-Type |application/json |
++--------------------+------------------------------------------------------------+
+
+Request Body:
+
++-----------------------------------+---------+-----------+--------------+---------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++===================================+=========+===========+==============+=======================================+
+|ManagedObject3gppServiceInstances |M |1 |allocateMOI |Content of allocate3gppMOI object |
++-----------------------------------+---------+-----------+--------------+---------------------------------------+
+
+ManagedObject3gppServiceInstances Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|attributes |List |List of Slice Profile Attribute |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+SliceProfileList Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|plmnInfoList |List |Contains plmnInfoList |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|RANSliceSubnetProfile |Object |Contains RAN Attributes Object |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+plmnInfoList Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|plmnId |Object |Contains plmnData |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|snssai |Object |Contains snssai data |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+plmnId Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|mcc |integer |Contains mcc value |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|mnc |integer |Contains mcc value |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+snssai Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|sst |string |Contains sst |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|sd |string |Contains sd |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+RAN Attribute Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|coverageAreaTAList |integer |Contains coverageAreaTAList |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|latency |integer |desired latency of slice |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|areaTrafficCapDL |integer |Contains areaTrafficCapDL |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|resourceSharingLevel |string |describes slice sharing level |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|serviceType |string |describes serviceType |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|maxNumberofUEs |integer |describes maxNumberofUEs |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+Response:
+
++-------------------------+---------+-----------+-----------------+-------------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++=========================+=========+===========+=================+===========================================+
+|requestReferences |M |1 |Response Object |Content of Response object. |
++----------------+--------+---------+-----------+-----------------+-------------------------------------------+
+
+Response Object
+
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++===================+=========+===========+==========================+===========================================+
+|requestId |M |1 |String |Request Id. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|requestDetails |M |1 |requestDetails Object |Type of the request. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|instanceId |M |1 |requestStatus Object |Type of the request. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+
+
+
+Terminate/Deallocate a MOI
+++++++++++++++++++++++++++
+
++--------------------+------------------------------------------------------------+
+|Interface Definition|Description |
++====================+============================================================+
+|URI |onap/so/infra/moi/api/rest/v1/NetworkSliceSubnet/$NSSID |
++--------------------+------------------------------------------------------------+
+|Operation Type |DELETE |
++--------------------+------------------------------------------------------------+
+|Content-Type |application/json |
++--------------------+------------------------------------------------------------+
+
+
+Request Body:
+
++-----------------------------------+---------+-----------+--------------+---------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++===================================+=========+===========+==============+=======================================+
+|ManagedObject3gppServiceInstances |M |1 |deleteMOI |Content of deleteMOI object |
++-----------------------------------+---------+-----------+--------------+---------------------------------------+
+
+ManagedObject3gppServiceInstances Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|attributes |List |List of Slice Profile Attribute |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+SliceProfileList Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|sliceProfileId |string |slice profile id to be deleted |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+Response
+
++-------------------------+---------+-----------+-----------------+-------------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++=========================+=========+===========+=================+===========================================+
+|requestReferences |M |1 |Response Object |Content of Response object. |
++-------------------------+---------+-----------+-----------------+-------------------------------------------+
+
+Response Object
+
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++===================+=========+===========+==========================+===========================================+
+|requestId |M |1 |String |Request Id. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|requestDetails |M |1 |requestDetails Object |Type of the request. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|instanceId |M |1 |requestStatus Object |Type of the request. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+
+
+
+
+Modify a 3GPP service instance
+++++++++++++++++++++++++++++++
++--------------------+------------------------------------------------------------+
+|Interface Definition|Description |
++====================+============================================================+
+|URI |onap/so/infra/moi/api/rest/v1/NetworkSliceSubnet/$NSSID |
++--------------------+------------------------------------------------------------+
+|Operation Type |PATCH |
++--------------------+------------------------------------------------------------+
+|Content-Type |application/json |
++--------------------+------------------------------------------------------------+
+
+
+Request Body:
+
++-----------------------------------+---------+-----------+--------------+---------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++===================================+=========+===========+==============+=======================================+
+|ManagedObject3gppServiceInstances |M |1 |modifyMOI |Content of modifyMOI object |
++-----------------------------------+---------+-----------+--------------+---------------------------------------+
+
+
+ManagedObject3gppServiceInstances Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|attributes |List |List of Slice Profile Attribute |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+SliceProfileList Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|sliceProfileId |string |slice profile id to be modify |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|RANSliceSubnetProfile |Object |Contains RAN Attributes Object |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+RAN Attribute Object
+
++------------------------------+-----------------+-------------------------------------------------------------------+
+|Attribute |Content |Description |
++==============================+=================+===================================================================+
+|coverageAreaTAList |integer |Contains coverageAreaTAList |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|latency |integer |desired latency of slice |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|areaTrafficCapDL |integer |Contains areaTrafficCapDL |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|resourceSharingLevel |string |describes slice sharing level |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|serviceType |string |describes serviceType |
++------------------------------+-----------------+-------------------------------------------------------------------+
+|maxNumberofUEs |integer |describes maxNumberofUEs |
++------------------------------+-----------------+-------------------------------------------------------------------+
+
+
+Response:
+
++-------------------------+---------+-----------+-----------------+-------------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++=========================+=========+===========+=================+===========================================+
+|requestReferences |M |1 |Response Object |Content of Response object. |
++-------------------------+---------+-----------+-----------------+-------------------------------------------+
+
+Response Object
+
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|Attribute |Qualifier|Cardinality|Content |Description |
++===================+=========+===========+==========================+===========================================+
+|requestId |M |1 |String |Request Id. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|requestDetails |M |1 |requestDetails Object |Type of the request. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+
+|instanceId |M |1 |requestStatus Object |Type of the request. |
++-------------------+---------+-----------+--------------------------+-------------------------------------------+ \ No newline at end of file
diff --git a/docs/api/offered_consumed_apis.rst b/docs/api/offered_consumed_apis.rst
index 11e52e82ae..fa872dbeb4 100644
--- a/docs/api/offered_consumed_apis.rst
+++ b/docs/api/offered_consumed_apis.rst
@@ -46,3 +46,4 @@ Detailed documentation can be found here:
apis/e2eServiceInstances-api.rst
apis/onap3gppServiceInstances-api.rst
apis/consumed-apis.rst
+ apis/ManagedObject3gppServiceInstances.rst
diff --git a/docs/api/swagger/swagger.json b/docs/api/swagger/swagger.json
index ac0e523d45..1d23498bc8 100644
--- a/docs/api/swagger/swagger.json
+++ b/docs/api/swagger/swagger.json
@@ -1,7 +1,7 @@
{
"openapi": "3.0.1",
"info": {
- "title": "SO Guilin APIs",
+ "title": "SO London APIs",
"version": "3.1.2"
},
"servers": [
@@ -48,6 +48,9 @@
},
{
"name": "onapsoinfrainstanceManagement"
+ },
+ {
+ "name": "ManagedObject3gppServiceInstances"
}
],
"paths": {
@@ -3492,6 +3495,170 @@
},
"x-codegen-request-body-name": "body"
}
+ },
+ "/onap/so/infra/moi/api/rest/{version}/NetworkSliceSubnet/{NSSID}": {
+ "put": {
+ "tags": [
+ "ManagedObject3gppServiceInstances"
+ ],
+ "summary": "Create a 3GPP MOI NSSI on a version provided",
+ "operationId": "createMOI",
+ "parameters": [
+ {
+ "name": "version",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "pattern": "[vV][1]",
+ "type": "string"
+ }
+ },
+ {
+ "name": "NSSID",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "type": "string"
+ }
+ }
+ ],
+ "requestBody": {
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/createMOI"
+ }
+ }
+ },
+ "required": true
+ },
+ "responses": {
+ "default": {
+ "description": "successful operation",
+ "content": {}
+ }
+ },
+ "x-codegen-request-body-name": "body"
+ },
+ "patch": {
+ "tags": [
+ "ManagedObject3gppServiceInstances"
+ ],
+ "summary": "Modify a 3GPP MOI NSSI on a version provided",
+ "operationId": "modifyMOI",
+ "parameters": [
+ {
+ "name": "version",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "pattern": "[vV][1]",
+ "type": "string"
+ }
+ },
+ {
+ "name": "NSSID",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "type": "string"
+ }
+ }
+ ],
+ "requestBody": {
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/modifyMOI"
+ }
+ }
+ },
+ "required": true
+ },
+ "responses": {
+ "default": {
+ "description": "successful operation",
+ "content": {}
+ }
+ },
+ "x-codegen-request-body-name": "body"
+ },
+ "delete": {
+ "tags": [
+ "ManagedObject3gppServiceInstances"
+ ],
+ "summary": "delete a 3GPP MOI NSSI on a version provided",
+ "operationId": "deleteMOI",
+ "parameters": [
+ {
+ "name": "version",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "pattern": "[vV][1]",
+ "type": "string"
+ }
+ },
+ {
+ "name": "NSSID",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "type": "string"
+ }
+ }
+ ],
+ "requestBody": {
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/deleteMOI"
+ }
+ }
+ },
+ "required": true
+ },
+ "responses": {
+ "default": {
+ "description": "successful operation",
+ "content": {}
+ }
+ },
+ "x-codegen-request-body-name": "body"
+ },
+ "get": {
+ "tags": [
+ "ManagedObject3gppServiceInstances"
+ ],
+ "summary": "get the slice profile list of given nssiID",
+ "operationId": "getMOI",
+ "parameters": [
+ {
+ "name": "version",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "pattern": "[vV][1]",
+ "type": "string"
+ }
+ },
+ {
+ "name": "NSSID",
+ "in": "path",
+ "required": true,
+ "schema": {
+ "type": "string"
+ }
+ }
+ ],
+ "responses": {
+ "default": {
+ "description": "successful operation",
+ "content": {}
+ }
+ },
+ "x-codegen-request-body-name": "body"
+ }
}
},
"components": {
@@ -3659,7 +3826,7 @@
"type": "object",
"properties": {
"workflowSpecificationList": {
- "type": "array",
+ "type": "C",
"description": "List of Workflow specification data",
"items": {
"$ref": "#/components/schemas/WorkflowSpecification"
@@ -4270,6 +4437,150 @@
}
}
]
+ },
+ "createMOI": {
+ "type": "object",
+ "properties": {
+ "attributes": {
+ "type": "object",
+ "properties": {
+ "sliceProfileList": {
+ "type": "array",
+ "description": "List of slice profile attributes",
+ "items": {
+ "type": "array",
+ "description": "List of PlmnData attributes",
+ "items": {
+ "plmnid": {
+ "type": "object",
+ "properties": {
+ "mcc": {
+ "type": "integer",
+ "description": "mcc"
+ },
+ "mnc": {
+ "type": "integer",
+ "description": "mnc"
+ }
+ }
+ },
+ "snssai": {
+ "type": "object",
+ "properties": {
+ "mcc": {
+ "type": "integer",
+ "description": "mcc"
+ },
+ "mnc": {
+ "type": "integer",
+ "description": "mnc"
+ }
+ }
+ }
+ },
+ "RANSliceSubnetProfile": {
+ "type": "object",
+ "properties": {
+ "coverageAreaTAList": {
+ "type": "integer",
+ "description": "coverageAreaTAList"
+ },
+ "latency": {
+ "type": "integer",
+ "description": "latency"
+ },
+ "areaTrafficCapDL": {
+ "type": "integer",
+ "description": "areaTrafficCapDL"
+ },
+ "resourceSharingLevel": {
+ "type": "string",
+ "description": "resourceSharingLevel"
+ },
+ "serviceType": {
+ "type": "string",
+ "description": "serviceType"
+ },
+ "maxNumberofUEs": {
+ "type": "integer",
+ "description": "maxNumberofUEs"
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ },
+ "modifyMOI": {
+ "type": "object",
+ "properties": {
+ "attributes": {
+ "type": "object",
+ "properties": {
+ "sliceProfileList": {
+ "type": "array",
+ "description": "List of slice profile attributes",
+ "items": {
+ "sliceProfileId": {
+ "type": "string",
+ "description": "sliceProfileId to be modify"
+ },
+ "RANSliceSubnetProfile": {
+ "type": "object",
+ "properties": {
+ "coverageAreaTAList": {
+ "type": "integer",
+ "description": "coverageAreaTAList"
+ },
+ "latency": {
+ "type": "integer",
+ "description": "latency"
+ },
+ "areaTrafficCapDL": {
+ "type": "integer",
+ "description": "areaTrafficCapDL"
+ },
+ "resourceSharingLevel": {
+ "type": "string",
+ "description": "resourceSharingLevel"
+ },
+ "serviceType": {
+ "type": "string",
+ "description": "serviceType"
+ },
+ "maxNumberofUEs": {
+ "type": "integer",
+ "description": "maxNumberofUEs"
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ },
+ "deleteMOI": {
+ "type": "object",
+ "properties": {
+ "attributes": {
+ "type": "object",
+ "properties": {
+ "sliceProfileList": {
+ "type": "object",
+ "description": "List of slice profile attributes",
+ "properties": {
+ "sliceProfileId": {
+ "type": "string",
+ "description": "sliceProfileId to be modify"
+ }
+ }
+ }
+ }
+ }
+ }
}
}
}
diff --git a/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIRestClientImpl.java b/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIRestClientImpl.java
index bf9ad56da7..03260dbfae 100644
--- a/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIRestClientImpl.java
+++ b/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIRestClientImpl.java
@@ -36,6 +36,7 @@ import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri;
import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory;
import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder;
import org.onap.aaiclient.client.graphinventory.Format;
+import org.onap.aaiclient.client.graphinventory.entities.uri.Depth;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.fasterxml.jackson.core.type.TypeReference;
@@ -114,6 +115,17 @@ public class AAIRestClientImpl implements AAIRestClientI {
return Optional.ofNullable(response.readEntity(ServiceInstance.class));
}
+ public Optional<ServiceInstance> getServiceInstanceByIdWithDepth(String serviceInstanceId, String serviceType,
+ String globalSubscriberId) {
+ Response response =
+ new AAIResourcesClient()
+ .getFullResponse(AAIUriFactory
+ .createResourceUri(AAIFluentTypeBuilder.business().customer(globalSubscriberId)
+ .serviceSubscription(serviceType).serviceInstance(serviceInstanceId))
+ .depth(Depth.ALL));
+ return Optional.ofNullable(response.readEntity(ServiceInstance.class));
+ }
+
@Override
public void updateServiceInstance(String serviceInstanceId, String serviceType, String globalSubscriberId,
ServiceInstance serviceInstance) {
diff --git a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java
index 5d238112cc..a5f5a72cc7 100644
--- a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java
+++ b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java
@@ -49,5 +49,8 @@ public enum Action implements Actions {
addMembers,
removeMembers,
forCustomWorkflow,
+ createRanSlice,
+ modifyRanSlice,
+ deleteRanSlice,
upgradeCnf
}
diff --git a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/JerseyConfiguration.java b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/JerseyConfiguration.java
index 031e9eee2a..43fbb0b409 100644
--- a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/JerseyConfiguration.java
+++ b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/JerseyConfiguration.java
@@ -93,6 +93,7 @@ public class JerseyConfiguration extends ResourceConfig {
register(RequestConflictMapper.class);
register(WorkflowEngineConnectionMapper.class);
register(OrchestrationTasks.class);
+ register(ManagedObject3gppServiceInstances.class);
// this registration seems to be needed to get predictable
// execution behavior for the above JSON Exception Mappers
register(com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider.class);
diff --git a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ManagedObject3gppServiceInstances.java b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ManagedObject3gppServiceInstances.java
new file mode 100644
index 0000000000..605e2a8386
--- /dev/null
+++ b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ManagedObject3gppServiceInstances.java
@@ -0,0 +1,568 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (c) 2022 Deutsche telekom
+ * ================================================================================
+ * 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.so.apihandlerinfra;
+
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import io.swagger.v3.oas.annotations.OpenAPIDefinition;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.info.Info;
+import io.swagger.v3.oas.annotations.media.ArraySchema;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import org.apache.http.HttpStatus;
+import org.onap.aai.domain.yang.Relationship;
+import org.onap.aai.domain.yang.RelationshipData;
+import org.onap.aai.domain.yang.ServiceInstance;
+import org.onap.aai.domain.yang.SliceProfile;
+import org.onap.aaiclient.client.aai.AAIRestClientImpl;
+import org.onap.logging.filter.base.ErrorCode;
+import org.onap.so.apihandler.camundabeans.CamundaResponse;
+import org.onap.so.apihandler.common.*;
+import org.onap.so.apihandlerinfra.exceptions.ApiException;
+import org.onap.so.apihandlerinfra.exceptions.BPMNFailureException;
+import org.onap.so.apihandlerinfra.exceptions.RequestDbFailureException;
+import org.onap.so.apihandlerinfra.exceptions.ValidateException;
+import org.onap.so.apihandlerinfra.logging.ErrorLoggerInfo;
+import org.onap.so.moi.*;
+import org.onap.so.constants.Status;
+import org.onap.so.db.catalog.beans.Service;
+import org.onap.so.db.catalog.beans.ServiceRecipe;
+import org.onap.so.db.catalog.client.CatalogDbClient;
+import org.onap.so.db.request.beans.InfraActiveRequests;
+import org.onap.so.db.request.client.RequestsDbClient;
+import org.onap.so.logger.LogConstants;
+import org.onap.so.logger.LoggingAnchor;
+import org.onap.so.logger.MessageEnum;
+import org.onap.so.rest.catalog.beans.Vnf;
+import org.onap.so.serviceinstancebeans.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.slf4j.MDC;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+import javax.ws.rs.*;
+import javax.ws.rs.container.ContainerRequestContext;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.sql.Timestamp;
+import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+@Component
+@Path("/onap/so/infra/moi/api/rest/")
+@OpenAPIDefinition(
+ info = @Info(title = "/onap/so/infra/moi/api/rest/", description = "API Requests for 3gpp MO Instances"))
+public class ManagedObject3gppServiceInstances {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(ManagedObject3gppServiceInstances.class);
+
+ private static final String MSO_PROP_APIHANDLER_INFRA = "MSO_PROP_APIHANDLER_INFRA";
+
+ private static final String END_OF_THE_TRANSACTION = "End of the transaction, the final response is: ";
+
+ private static final String SAVE_TO_DB = "save instance to db";
+
+ private static final String URI_PREFIX = "/moi/api/rest/";
+
+ @Autowired
+ private MsoRequest msoRequest;
+
+ @Autowired
+ private CatalogDbClient catalogDbClient;
+
+ @Autowired
+ private RequestsDbClient requestsDbClient;
+
+ @Autowired
+ private RequestHandlerUtils requestHandlerUtils;
+
+ @Autowired
+ private ResponseBuilder builder;
+
+ @Autowired
+ private CamundaClient camundaClient;
+
+ @Autowired
+ private ResponseHandler responseHandler;
+
+ private AAIRestClientImpl aaiRestClient = new AAIRestClientImpl();
+
+ /**
+ * POST Requests for 3GPP MOI Service create nssi on a version provided
+ *
+ * @throws ApiException
+ */
+
+ @PUT
+ @Path("/{version:[vV][1]}/NetworkSliceSubnet/{id}")
+ @Consumes(MediaType.APPLICATION_JSON)
+ @Produces(MediaType.APPLICATION_JSON)
+ @Operation(description = "Create a 3GPP MOI NSSI on a version provided", responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ public Response allocateNssi(MoiAllocateRequest request, @PathParam("version") String version,
+ @PathParam("id") String id, @Context ContainerRequestContext requestContext) throws ApiException {
+ String requestId = requestHandlerUtils.getRequestId(requestContext);
+ HashMap<String, String> instanceIdMap = new HashMap<>();
+ instanceIdMap.put("serviceInstanceId", id);
+ return processAllocateRequest(request, Action.createRanSlice, version, requestId, instanceIdMap,
+ requestHandlerUtils.getRequestUri(requestContext, URI_PREFIX));
+ }
+
+ @PATCH
+ @Path("/{version:[vV][1]}/NetworkSliceSubnet/{id}")
+ @Consumes(MediaType.APPLICATION_JSON)
+ @Produces(MediaType.APPLICATION_JSON)
+ @Operation(description = "Modify a 3GPP MOI NSSI on a version provided", responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ public Response modifyNssi(MoiAllocateRequest request, @PathParam("version") String version,
+ @PathParam("id") String id, @Context ContainerRequestContext requestContext) throws ApiException {
+ String requestId = requestHandlerUtils.getRequestId(requestContext);
+ HashMap<String, String> instanceIdMap = new HashMap<>();
+ instanceIdMap.put("serviceInstanceId", id);
+ return processAllocateRequest(request, Action.modifyRanSlice, version, requestId, instanceIdMap,
+ requestHandlerUtils.getRequestUri(requestContext, URI_PREFIX));
+ }
+
+ /**
+ * DELETE Requests to delete 3GPP MOI Service instance on a version provided
+ *
+ * @throws ApiException
+ */
+ @DELETE
+ @Path("/{version:[vV][1]}/NetworkSliceSubnet/{id}")
+ @Consumes(MediaType.APPLICATION_JSON)
+ @Produces(MediaType.APPLICATION_JSON)
+ @Operation(description = "Delete a 3GPP MOI NSSI on a version provided", responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ public Response deleteNssi(MoiAllocateRequest request, @PathParam("version") String version,
+ @PathParam("id") String id, @Context ContainerRequestContext requestContext) throws ApiException {
+ String requestId = requestHandlerUtils.getRequestId(requestContext);
+ HashMap<String, String> instanceIdMap = new HashMap<>();
+ instanceIdMap.put("serviceInstanceId", id);
+ return processAllocateRequest(request, Action.deleteRanSlice, version, requestId, instanceIdMap,
+ requestHandlerUtils.getRequestUri(requestContext, URI_PREFIX));
+ }
+
+ /**
+ * GET Requests for 3GPP MOI Service get nssi on a version provided
+ *
+ * @throws ApiException
+ */
+ @GET
+ @Operation(description = "Find slice Profile for nssi id", responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Vnf.class)))))
+ @Path("/{version:[vV][1]}/NetworkSliceSubnet/{id}")
+ @Produces({MediaType.APPLICATION_JSON})
+ @Transactional(readOnly = true)
+ public Response getMOIAttributes(@PathParam("version") String version, @PathParam("id") String id)
+ throws ApiException {
+ GETMoiResponse mOIResponse = new GETMoiResponse();
+ String response = null;
+
+ Optional<ServiceInstance> serviceInstance = aaiRestClient.getServiceInstanceById(id, "5G", "5GCustomer");
+ if (serviceInstance.isPresent()) {
+ LOGGER.info("Id from request {}", id);
+ ServiceInstance serviceInstanceObj = serviceInstance.get();
+ mOIResponse.setId(serviceInstanceObj.getServiceInstanceId());
+ mOIResponse.setAdministrativeState(serviceInstanceObj.getOperationalStatus());
+ mOIResponse.setOperationalState(serviceInstanceObj.getOrchestrationStatus());
+
+
+ Attributes attributes = new Attributes();
+ List<org.onap.so.moi.SliceProfile> sliceProfileList = new ArrayList<org.onap.so.moi.SliceProfile>();
+
+ List<Relationship> listOfNssiRelationship = serviceInstanceObj.getRelationshipList().getRelationship();
+
+ List<Relationship> listOfNssiRelationshipAR = listOfNssiRelationship.stream()
+ .filter(relationship -> relationship.getRelatedTo().equalsIgnoreCase("allotted-resource"))
+ .collect(Collectors.toList());
+
+ for (Relationship relationship : listOfNssiRelationshipAR) {
+ org.onap.so.moi.SliceProfile sliceProfile = new org.onap.so.moi.SliceProfile();
+ for (RelationshipData relationshipData : relationship.getRelationshipData()) {
+ if (relationshipData.getRelationshipKey()
+ .equalsIgnoreCase("service-instance.service-instance-id")) {
+ String sliceProfileInstanceId = relationshipData.getRelationshipValue();
+ LOGGER.debug(">>> sliceProfileInstance: {}", sliceProfileInstanceId);
+
+ Optional<ServiceInstance> sliceProfileServiceInstance = aaiRestClient
+ .getServiceInstanceByIdWithDepth(sliceProfileInstanceId, "5G", "5GCustomer");
+ if (sliceProfileServiceInstance.isPresent()) {
+ ServiceInstance sliceProfileServiceInstanceObj = sliceProfileServiceInstance.get();
+ SliceProfile sliceProfile1 =
+ sliceProfileServiceInstanceObj.getSliceProfiles().getSliceProfile().get(0);
+ try {
+ sliceProfileList
+ .add(AAISliceProfileToMOISlice(sliceProfile1, sliceProfileServiceInstanceObj));
+ } catch (Exception e) {
+ LOGGER.info("Can not construct responce {}", e);
+ }
+
+ }
+
+
+ }
+ }
+
+ }
+
+ attributes.setSliceProfileList(sliceProfileList);
+ mOIResponse.setAttributes(attributes);
+ ObjectMapper mapper = new ObjectMapper();
+ try {
+ response = mapper.writeValueAsString(mOIResponse);
+ } catch (Exception exception) {
+ LOGGER.error("Error while creating MOIResponse JSON" + exception.getMessage());
+ }
+
+ return builder.buildResponse(HttpStatus.SC_OK, null, response, version);
+
+
+ }
+ return builder.buildResponse(HttpStatus.SC_NOT_FOUND, null, null, version);
+ }
+
+ private org.onap.so.moi.SliceProfile AAISliceProfileToMOISlice(SliceProfile sliceProfile,
+ ServiceInstance serviceInstance) {
+ org.onap.so.moi.SliceProfile sliceProfileMoi = new org.onap.so.moi.SliceProfile();
+
+ sliceProfileMoi.setSliceProfileId(sliceProfile.getProfileId());
+
+ String serviceType = serviceInstance.getServiceType();
+
+ // rANSliceSubnetProfile
+ RANSliceSubnetProfile ranSliceSubnetProfile = new RANSliceSubnetProfile();
+ ranSliceSubnetProfile.setServiceType(serviceType);
+ ranSliceSubnetProfile.setdLLatency(sliceProfile.getLatency());
+ ranSliceSubnetProfile.setCoverageAreaTAList(Integer.valueOf(sliceProfile.getCoverageAreaTAList()));
+ ranSliceSubnetProfile.setMaxNumberofUEs(sliceProfile.getMaxNumberOfUEs());
+ ranSliceSubnetProfile.setResourceSharingLevel(sliceProfile.getResourceSharingLevel());
+ ranSliceSubnetProfile.setAreaTrafficCapDL(sliceProfile.getAreaTrafficCapDL());
+
+ // plmnId
+ String[] plmnIdData = serviceInstance.getServiceInstanceLocationId().split("-");
+ PlmnId plmnId = new PlmnId();
+ plmnId.setMcc(Integer.valueOf(plmnIdData[0]));
+ plmnId.setMnc(Integer.valueOf(plmnIdData[1]));
+
+ // snssai
+ String[] snssaiData = serviceInstance.getEnvironmentContext().split("-");
+ Snssai snssai = new Snssai();
+ snssai.setSst(snssaiData[0]);
+ snssai.setSd(snssaiData[1]);
+
+ // Plmninfo
+ PlmnInfo plmnInfo = new PlmnInfo();
+ plmnInfo.setPlmnId(plmnId);
+ plmnInfo.setSnssai(snssai);
+
+ List<PlmnInfo> plmnInfoList = new ArrayList<PlmnInfo>();
+ plmnInfoList.add(plmnInfo);
+
+ sliceProfileMoi.setrANSliceSubnetProfile(ranSliceSubnetProfile);
+ sliceProfileMoi.setPlmnInfoList(plmnInfoList);
+
+ return sliceProfileMoi;
+
+ }
+
+ /**
+ * Process allocate service request and send request to corresponding workflow
+ *
+ * @param request
+ * @param action
+ * @param version
+ * @return
+ * @throws ApiException
+ */
+ private Response processAllocateRequest(MoiAllocateRequest request, Action action, String version, String requestId,
+ HashMap<String, String> instanceIdMap, String requestUri) throws ApiException {
+ String defaultServiceModelName = "UUI_DEFAULT";
+ String requestScope = ModelType.service.name();
+ String apiVersion = version.substring(1);
+ String serviceRequestJson = toString.apply(request);
+
+ ServiceInstancesRequest sir = createServiceInstanceRequest(request, requestId);
+ String requestDetails = null;
+ try {
+ requestDetails = new ObjectMapper().writeValueAsString(sir);
+ LOGGER.debug(">>> sir: {}", sir);
+ } catch (JsonProcessingException e) {
+ e.printStackTrace();
+ }
+ if (serviceRequestJson != null) {
+ InfraActiveRequests currentActiveReq = createRequestObject(request, action, requestId, Status.IN_PROGRESS,
+ requestScope, serviceRequestJson);
+ // instanceName ???
+ String instanceId = instanceIdMap.get("serviceInstanceId");
+ String instanceName = sir.getRequestDetails().getRequestInfo().getInstanceName();
+ requestHandlerUtils.checkForDuplicateRequests(action, instanceIdMap, requestScope, currentActiveReq,
+ instanceName);
+
+ requestHandlerUtils.setInstanceId(currentActiveReq, requestScope, instanceId, instanceIdMap);
+ try {
+ requestsDbClient.save(currentActiveReq);
+ } catch (Exception e) {
+ LOGGER.error("Exception occurred", e);
+ ErrorLoggerInfo errorLoggerInfo =
+ new ErrorLoggerInfo.Builder(MessageEnum.APIH_DB_ACCESS_EXC, ErrorCode.DataError)
+ .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
+ throw new RequestDbFailureException.Builder(SAVE_TO_DB, e.toString(),
+ HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).cause(e)
+ .errorInfo(errorLoggerInfo).build();
+ }
+
+ RecipeLookupResult recipeLookupResult;
+ try {
+ recipeLookupResult = getServiceInstanceOrchestrationURI("123", action, defaultServiceModelName);
+
+ LOGGER.debug("recipeLookupResult: {}", recipeLookupResult);
+ } catch (Exception e) {
+ LOGGER.error(LoggingAnchor.FOUR, MessageEnum.APIH_DB_ACCESS_EXC.toString(), MSO_PROP_APIHANDLER_INFRA,
+ ErrorCode.AvailabilityError.getValue(), "Exception while communciate with Catalog DB", e);
+ Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
+ MsoException.ServiceException, "No communication to catalog DB " + e.getMessage(),
+ ErrorNumbers.SVC_NO_SERVER_RESOURCES, null, version);
+ LOGGER.debug(END_OF_THE_TRANSACTION + response.getEntity());
+ return response;
+ }
+
+ if (recipeLookupResult == null) {
+ LOGGER.error(LoggingAnchor.FOUR, MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND.toString(),
+ MSO_PROP_APIHANDLER_INFRA, ErrorCode.DataError.getValue(), "No recipe found in DB");
+ Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
+ MsoException.ServiceException, "Recipe does not exist in catalog DB",
+ ErrorNumbers.SVC_GENERAL_SERVICE_ERROR, null, version);
+ LOGGER.debug(END_OF_THE_TRANSACTION + response.getEntity());
+ return response;
+ }
+
+ String serviceInstanceType = sir.getRequestDetails().getRequestParameters().getSubscriptionServiceType();
+ RequestClientParameter parameter;
+ try {
+ parameter = new RequestClientParameter.Builder().setRequestId(requestId).setBaseVfModule(false)
+ .setRecipeTimeout(recipeLookupResult.getRecipeTimeout()).setRequestAction(action.name())
+ .setServiceInstanceId(instanceId).setServiceType(serviceInstanceType)
+ .setRequestDetails(requestDetails).setApiVersion(version).setALaCarte(false)
+ .setRecipeParamXsd(recipeLookupResult.getRecipeParamXsd()).setApiVersion(apiVersion)
+ .setRequestUri(requestUri).build();
+ } catch (Exception e) {
+ LOGGER.error("Exception occurred", e);
+ ErrorLoggerInfo errorLoggerInfo =
+ new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, ErrorCode.SchemaError)
+ .errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
+ throw new ValidateException.Builder("Unable to generate RequestClientParamter object" + e.getMessage(),
+ HttpStatus.SC_INTERNAL_SERVER_ERROR, ErrorNumbers.SVC_BAD_PARAMETER).errorInfo(errorLoggerInfo)
+ .build();
+ }
+ return postBPELRequest(currentActiveReq, parameter, recipeLookupResult.getOrchestrationURI(), requestScope);
+ } else {
+ Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_INTERNAL_SERVER_ERROR,
+ MsoException.ServiceException, "JsonProcessingException occurred - serviceRequestJson is null",
+ ErrorNumbers.SVC_BAD_PARAMETER, null, version);
+ return response;
+ }
+ }
+
+
+ private ServiceInstancesRequest createServiceInstanceRequest(MoiAllocateRequest request, String id) {
+
+ RequestDetails requestDetails = new RequestDetails();
+ RequestInfo requestInfo = new RequestInfo();
+ requestInfo.setInstanceName("ran_nssi_" + id);
+ requestInfo.setRequestorId("MO");
+ requestInfo.setProductFamilyId("5G");
+ requestInfo.setSource("MO");
+
+ requestDetails.setRequestInfo(requestInfo);
+
+ SubscriberInfo subscriberInfo = new SubscriberInfo();
+ subscriberInfo.setGlobalSubscriberId("5GCustomer");
+ requestDetails.setSubscriberInfo(subscriberInfo);
+
+ Project project = new Project();
+ project.setProjectName("basicnw-project");
+ requestDetails.setProject(project);
+
+ OwningEntity owningEntity = new OwningEntity();
+ owningEntity.setOwningEntityId("67f2e84c-734d-4e90-a1e4-d2ffa2e75849");
+ owningEntity.setOwningEntityName("OE-5GCustomer");
+ requestDetails.setOwningEntity(owningEntity);
+
+ RequestParameters requestParameters = new RequestParameters();
+ requestParameters.setaLaCarte(false);
+ requestParameters.setSubscriptionServiceType("5G");
+
+ Map<String, Object> nssiUserParams = new HashMap<>();
+ Attributes attributes = request.getAttributes();
+ nssiUserParams.put("nssi", attributes);
+
+ Map<String, Object> homingSolution = new HashMap<>();
+ homingSolution.put("Homing_Solution", "true");
+
+ List<Map<String, Object>> userParams = new ArrayList<>();
+
+ userParams.add(nssiUserParams);
+ userParams.add(homingSolution);
+
+ requestParameters.setUserParams(userParams);
+
+ requestDetails.setRequestParameters(requestParameters);
+
+ ServiceInstancesRequest sir = new ServiceInstancesRequest();
+ sir.setServiceInstanceId(id);
+ sir.setRequestDetails(requestDetails);
+
+ return sir;
+ }
+
+ public InfraActiveRequests createRequestObject(Object request, Action action, String requestId, Status status,
+ String requestScope, String requestJson) {
+ InfraActiveRequests aq = new InfraActiveRequests();
+ try {
+ String serviceInstanceName = null;
+ String serviceInstanceId = null;
+ if (action.name().equals("ranSlice")) {
+ serviceInstanceName = "ran_nssi_" + requestId;
+ aq.setServiceInstanceName(serviceInstanceName);
+ } else if (action.name().equals("updateInstance")) {
+ LOGGER.debug(">>>>> updateInstance");
+ }
+
+ aq.setRequestId(requestId);
+ aq.setRequestAction(action.toString());
+ aq.setRequestUrl(MDC.get(LogConstants.HTTP_URL));
+ Timestamp startTimeStamp = new Timestamp(System.currentTimeMillis());
+ aq.setStartTime(startTimeStamp);
+ aq.setRequestScope(requestScope);
+ aq.setRequestBody(requestJson);
+ aq.setRequestStatus(status.toString());
+ aq.setLastModifiedBy(Constants.MODIFIED_BY_APIHANDLER);
+ } catch (Exception e) {
+ LOGGER.error("Exception when creation record request", e);
+
+ if (!status.equals(Status.FAILED)) {
+ throw e;
+ }
+ }
+ return aq;
+ }
+
+ /**
+ * Getting recipes from catalogDb
+ *
+ * @param serviceModelUUID the service model version uuid
+ * @param action the action for the service
+ * @param defaultServiceModelName default service name
+ * @return the service recipe result
+ */
+ private RecipeLookupResult getServiceInstanceOrchestrationURI(String serviceModelUUID, Action action,
+ String defaultServiceModelName) {
+
+ RecipeLookupResult recipeLookupResult = getServiceURI(serviceModelUUID, action, defaultServiceModelName);
+
+ if (recipeLookupResult != null) {
+ LOGGER.debug("Orchestration URI is: " + recipeLookupResult.getOrchestrationURI() + ", recipe Timeout is: "
+ + Integer.toString(recipeLookupResult.getRecipeTimeout()));
+ } else {
+ LOGGER.debug("No matching recipe record found");
+ }
+ return recipeLookupResult;
+ }
+
+ Function<Object, String> toString = serviceRequest -> {
+ ObjectMapper mapper = new ObjectMapper();
+ String requestAsString = null;
+ try {
+ requestAsString = mapper.writeValueAsString(serviceRequest);
+ } catch (JsonProcessingException e) {
+ LOGGER.debug("Exception while converting service request object to String {}", e);
+ }
+ return requestAsString;
+ };
+
+ /**
+ * Getting recipes from catalogDb If Service recipe is not set, use default recipe, if set , use special recipe.
+ *
+ * @param serviceModelUUID the service version uuid
+ * @param action the action of the service.
+ * @param defaultServiceModelName default service name
+ * @return the service recipe result.
+ */
+ private RecipeLookupResult getServiceURI(String serviceModelUUID, Action action, String defaultServiceModelName) {
+
+ Service defaultServiceRecord =
+ catalogDbClient.getFirstByModelNameOrderByModelVersionDesc(defaultServiceModelName);
+ // set recipe as default generic recipe
+ ServiceRecipe recipe =
+ catalogDbClient.getFirstByServiceModelUUIDAndAction(defaultServiceRecord.getModelUUID(), action.name());
+ // check the service special recipe
+ if (null != serviceModelUUID && !serviceModelUUID.isEmpty()) {
+ ServiceRecipe serviceSpecialRecipe =
+ catalogDbClient.getFirstByServiceModelUUIDAndAction(serviceModelUUID, action.name());
+ if (null != serviceSpecialRecipe) {
+ // set service special recipe.
+ recipe = serviceSpecialRecipe;
+ }
+ }
+
+ if (recipe == null) {
+ return null;
+ }
+ return new RecipeLookupResult(recipe.getOrchestrationUri(), recipe.getRecipeTimeout(), recipe.getParamXsd());
+
+ }
+
+ private Response postBPELRequest(InfraActiveRequests currentActiveReq, RequestClientParameter parameter,
+ String orchestrationURI, String requestScope) throws ApiException {
+ ResponseEntity<String> response =
+ requestHandlerUtils.postRequest(currentActiveReq, parameter, orchestrationURI);
+ LOGGER.debug("BPEL response : " + response);
+ int bpelStatus = responseHandler.setStatus(response.getStatusCodeValue());
+ String jsonResponse;
+ try {
+ responseHandler.acceptedResponse(response);
+ CamundaResponse camundaResponse = responseHandler.getCamundaResponse(response);
+ String responseBody = camundaResponse.getResponse();
+ if ("Success".equalsIgnoreCase(camundaResponse.getMessage())) {
+ jsonResponse = responseBody;
+ } else {
+ BPMNFailureException bpmnException =
+ new BPMNFailureException.Builder(String.valueOf(bpelStatus) + responseBody, bpelStatus,
+ ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).build();
+ requestHandlerUtils.updateStatus(currentActiveReq, Status.FAILED, bpmnException.getMessage());
+ throw bpmnException;
+ }
+ } catch (ApiException e) {
+ requestHandlerUtils.updateStatus(currentActiveReq, Status.FAILED, e.getMessage());
+ throw e;
+ }
+ return builder.buildResponse(HttpStatus.SC_ACCEPTED, parameter.getRequestId(), jsonResponse,
+ parameter.getApiVersion());
+ }
+}
diff --git a/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfile.json b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfile.json
new file mode 100644
index 0000000000..4ad4b8dc93
--- /dev/null
+++ b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfile.json
@@ -0,0 +1,26 @@
+{
+ "sliceProfileList": [
+ {
+ "plmnInfoList": [
+ {
+ "plmnId": {
+ "mcc": 260,
+ "mnc": 70
+ },
+ "snssai": {
+ "sst": "001",
+ "sd": "300"
+ }
+ }
+ ],
+ "rANSliceSubnetProfile": {
+ "coverageAreaTAList": 888,
+ "dLLatency": 20,
+ "uLLatency": 20,
+ "resourceSharingLevel": "SHARED",
+ "serviceType": "eMBB",
+ "maxNumberofUEs": 2000
+ }
+ }
+ ]
+} \ No newline at end of file
diff --git a/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfileBadGateWay.json b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfileBadGateWay.json
new file mode 100644
index 0000000000..ecf636d532
--- /dev/null
+++ b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/CreateSliceProfileBadGateWay.json
@@ -0,0 +1,26 @@
+{
+ "sliceProfileList": [
+ {
+ "plmnInfoList": [
+ {
+ "plmnId": {
+ "mcc": 260,
+ "mnc": 70
+ },
+ "snssai": {
+ "sst": "test",
+ "sd": "test"
+ }
+ }
+ ],
+ "rANSliceSubnetProfile": {
+ "coverageAreaTAList": "test",
+ "dLLatency": 20,
+ "uLLatency": 20,
+ "resourceSharingLevel": "SHARED",
+ "serviceType": "eMBB",
+ "maxNumberofUEs": 2000
+ }
+ }
+ ]
+} \ No newline at end of file
diff --git a/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/DeleteSliceProfile.json b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/DeleteSliceProfile.json
new file mode 100644
index 0000000000..15cc4d4989
--- /dev/null
+++ b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/DeleteSliceProfile.json
@@ -0,0 +1,9 @@
+{
+ "attributes": {
+ "sliceProfileList": [
+ {
+ "sliceProfileId": "f832ea13-04c2-4bd5-b93e-4cb7e1fd7f44"
+ }
+ ]
+ }
+} \ No newline at end of file
diff --git a/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/ModifySliceProfile.json b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/ModifySliceProfile.json
new file mode 100644
index 0000000000..f03a7beb6f
--- /dev/null
+++ b/mso-api-handlers/mso-api-handler-infra/src/test/resources/ManagedObject3gppServiceInstancesTest/ModifySliceProfile.json
@@ -0,0 +1,13 @@
+{
+ "attributes": {
+ "sliceProfileList": [{
+ "sliceProfileId": "a1e5d51f-4bcb-42f0-83e2-cde6ac0a2e66",
+ "RANSliceSubnetProfile": {
+ "coverageAreaTAList": 777,
+ "dLLatency": 200,
+ "uLLatency": 200,
+ "resourceSharingLevel":"SHARED"
+ }
+ }]
+ }
+} \ No newline at end of file