1 files changed, 203 insertions, 0 deletions
diff --git a/mod2/catalog-service/src/main/java/org/onap/dcaegen2/platform/mod/web/service/policymodel/PolicyModelServiceImpl.java b/mod2/catalog-service/src/main/java/org/onap/dcaegen2/platform/mod/web/service/policymodel/PolicyModelServiceImpl.java
new file mode 100644
index 0000000..58fc447
--- /dev/null
+++ b/mod2/catalog-service/src/main/java/org/onap/dcaegen2/platform/mod/web/service/policymodel/PolicyModelServiceImpl.java
@@ -0,0 +1,203 @@
+/*
+ * ============LICENSE_START=======================================================
+ *  org.onap.dcae
+ *  ================================================================================
+ *  Copyright (c) 2020 AT&T 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.dcaegen2.platform.mod.web.service.policymodel;
+
+import lombok.Setter;
+import lombok.extern.slf4j.Slf4j;
+import org.onap.dcaegen2.platform.mod.model.exceptions.ErrorMessages;
+import org.onap.dcaegen2.platform.mod.model.exceptions.policymodel.PolicyModelConflictException;
+import org.onap.dcaegen2.platform.mod.model.exceptions.policymodel.PolicyModelDistributionEnvNotFoundException;
+import org.onap.dcaegen2.platform.mod.model.exceptions.policymodel.PolicyModelNotFoundException;
+import org.onap.dcaegen2.platform.mod.model.policymodel.DistributionInfo;
+import org.onap.dcaegen2.platform.mod.model.policymodel.PolicyModel;
+import org.onap.dcaegen2.platform.mod.model.policymodel.PolicyModelDistributionEnv;
+import org.onap.dcaegen2.platform.mod.model.restapi.MetadataRequest;
+import org.onap.dcaegen2.platform.mod.model.restapi.PolicyModelCreateRequest;
+import org.onap.dcaegen2.platform.mod.model.restapi.PolicyModelUpdateRequest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Policy Model Service implementation
+ */
+
+@Service
+@Setter
+@Slf4j
+public class PolicyModelServiceImpl implements PolicyModelService {
+
+    @Value("${dev.server}")
+    private String devServer;
+
+    @Value("${dev.port}")
+    private String devServerPort;
+
+    @Value("${dev.user}")
+    private String devServerUser;
+
+    @Value("${dev.password}")
+    private String devServerPassword;
+
+    @Autowired
+    private PolicyModelGateway policyModelGateway;
+
+    /**
+     * Lists all Policy Models
+     *
+     * @return
+     */
+    @Override
+    public List<PolicyModel> getAll() {
+        return policyModelGateway.findAll();
+    }
+
+    /**
+     * List a Policy Model by policyModel ID
+     *
+     * @param id
+     * @return
+     */
+    @Override
+    public PolicyModel getPolicyModelById(String id) {
+        return policyModelGateway.findById(id).orElseThrow(() -> new PolicyModelNotFoundException(String.format("Policy Model with id %s not found", id)));
+    }
+
+    /**
+     * creates a Policy Model
+     *
+     * @param request
+     * @return
+     */
+    @Override
+    @Transactional
+    public PolicyModel createPolicyModel(PolicyModelCreateRequest request, String user) {
+        checkIfPMNameAndVersionAlreadyExists(request.getName(), request.getVersion());
+        PolicyModel policyModel = new PolicyModel();
+        policyModel.setName(request.getName());
+        policyModel.setContent(request.getContent());
+        policyModel.setVersion(request.getVersion());
+        policyModel.setOwner(request.getOwner());
+        policyModel.setMetadata(getMetadataFields(request.getMetadata(), user));
+        return policyModelGateway.save(policyModel);
+    }
+
+    /**
+     * Update a Policy Model
+     *
+     * @param request
+     * @param modelId
+     * @return
+     */
+    @Override
+    public PolicyModel updatePolicyModel(PolicyModelUpdateRequest request, String modelId, String user) {
+        PolicyModel policyModel = getPolicyModelById(modelId);
+        updateFields(request, policyModel,user);
+        return policyModelGateway.save(policyModel);
+
+    }
+
+
+    /**
+     * Cerifies if a Policy Model Exist
+     *
+     * @param pmName
+     * @param pmVersion
+     * @return
+     */
+    private void checkIfPMNameAndVersionAlreadyExists(String pmName, String pmVersion) {
+        if (policyModelGateway.findByNameAndVersion(pmName, pmVersion).isPresent())
+            throw new PolicyModelConflictException(ErrorMessages.POLICYMODEL_NAME_VERSION_CONFLICT_MESSAGE);
+    }
+
+    /**
+     * creates a Policy Model Metadata
+     *
+     * @param metadata
+     * @param user
+     * @return
+     */
+    private MetadataRequest getMetadataFields(MetadataRequest metadata, String user) {
+        MetadataRequest metadataFields = MetadataRequest.builder().build();
+        metadataFields.setCreatedBy(user);
+        metadataFields.setCreatedOn(new Date());
+        if(metadata != null) {
+            if (metadata.getNotes() != null)
+                metadataFields.setNotes(metadata.getNotes());
+            if (metadata.getLabels() != null)
+                metadataFields.setLabels(metadata.getLabels());
+        }
+        return metadataFields;
+    }
+
+
+    /**
+     * Updates a Policy Model
+     *
+     * @param request
+     * @param policyModel
+     * @param user
+     * @return
+     */
+    private void updateFields(PolicyModelUpdateRequest request, PolicyModel policyModel, String user) {
+        String name = request.getName();
+        String version = request.getVersion();
+        if (!(name.equalsIgnoreCase(policyModel.getName()) && version.equalsIgnoreCase(policyModel.getVersion()))) {
+            checkIfPMNameAndVersionAlreadyExists(name, version);
+            policyModel.setName(name);
+            policyModel.setVersion(version);
+        }
+        if (request.getOwner() != null) {
+            policyModel.setOwner(request.getOwner());
+        }
+
+        if (request.getContent() != null) {
+            policyModel.setContent(request.getContent());
+        }
+        if (request.getMetadata() != null) {
+            updateMetadata(request,user);
+            policyModel.setMetadata(request.getMetadata());
+        }
+    }
+
+
+    /**
+     * Updates a Policy Model Metadata
+     *
+     * @param request
+     * @param user
+     * @return
+     */
+    private void updateMetadata(PolicyModelUpdateRequest request, String user) {
+        MetadataRequest metadataRequest = request.getMetadata();
+        metadataRequest.setUpdatedBy(user);
+        metadataRequest.setUpdatedOn(new Date());
+    }
+
+
+}