VSE: Create an anchor in the given dataspace

Issue-ID: CPS-42
https://jira.onap.org/browse/CPS-42

Signed-off-by: Rishi Chail <rishi.chail@est.tech>
Change-Id: If67be6f13889808da4d9fe830595766af67e4fdf

1 files changed, 72 insertions, 0 deletions

diff --git a/cps-ri/src/main/java/org/onap/cps/spi/impl/FragmentPersistenceServiceImpl.java b/cps-ri/src/main/java/org/onap/cps/spi/impl/FragmentPersistenceServiceImpl.java
new file mode 100755
index 000000000..47d98c92b
--- /dev/null
+++ b/cps-ri/src/main/java/org/onap/cps/spi/impl/FragmentPersistenceServiceImpl.java
@@ -0,0 +1,72 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2020 Nordix Foundation. 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.

+ *

+ * SPDX-License-Identifier: Apache-2.0

+ * ============LICENSE_END=========================================================

+ */

+

+package org.onap.cps.spi.impl;

+

+import org.onap.cps.api.model.AnchorDetails;

+import org.onap.cps.exceptions.CpsNotFoundException;

+import org.onap.cps.exceptions.CpsValidationException;

+import org.onap.cps.spi.FragmentPersistenceService;

+import org.onap.cps.spi.entities.Dataspace;

+import org.onap.cps.spi.entities.Fragment;

+import org.onap.cps.spi.entities.ModuleEntity;

+import org.onap.cps.spi.repository.DataspaceRepository;

+import org.onap.cps.spi.repository.FragmentRepository;

+import org.onap.cps.spi.repository.ModuleRepository;

+import org.springframework.beans.factory.annotation.Autowired;

+import org.springframework.dao.DataIntegrityViolationException;

+import org.springframework.stereotype.Component;

+

+@Component

+public class FragmentPersistenceServiceImpl implements FragmentPersistenceService {

+

+    @Autowired

+    private DataspaceRepository dataspaceRepository;

+

+    @Autowired

+    private FragmentRepository fragmentRepository;

+

+    @Autowired

+    private ModuleRepository moduleRepository;

+

+    @Override

+    public String createAnchor(final AnchorDetails anchorDetails) {

+        try {

+            final Dataspace dataspace = dataspaceRepository.getByName(anchorDetails.getDataspace());

+            final ModuleEntity moduleEntity =

+                moduleRepository.getByDataspaceAndNamespaceAndRevision(dataspace,

+                anchorDetails.getNamespace(), anchorDetails.getRevision());

+

+            final Fragment fragment = Fragment.builder().xpath(anchorDetails.getAnchorName())

+                .anchorName(anchorDetails.getAnchorName())

+                .dataspace(dataspace).module(moduleEntity).build();

+

+            fragmentRepository.save(fragment);

+            return anchorDetails.getAnchorName();

+        } catch (final CpsNotFoundException ex) {

+            throw new CpsValidationException("Validation Error",

+                String.format("Dataspace and/or Module do not exist."));

+        } catch (final DataIntegrityViolationException ex) {

+            throw new CpsValidationException("Duplication Error",

+                String.format("Anchor with name %s already exist in dataspace %s.",

+                    anchorDetails.getAnchorName(), anchorDetails.getDataspace()));

+        }

+    }

+}
\ No newline at end of file