1 files changed, 0 insertions, 168 deletions
diff --git a/asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1802/SdcCatalogMigration.java b/asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1802/SdcCatalogMigration.java
deleted file mode 100644
index 43399b616d..0000000000
--- a/asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/tasks/mig1802/SdcCatalogMigration.java
+++ /dev/null
@@ -1,168 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * SDC
- * ================================================================================
- * Copyright (C) 2019 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.openecomp.sdc.asdctool.migration.tasks.mig1802;
-
-import fj.data.Either;
-import org.apache.commons.collections.ListUtils;
-import org.apache.tinkerpop.gremlin.structure.Direction;
-import org.openecomp.sdc.asdctool.migration.core.DBVersion;
-import org.openecomp.sdc.asdctool.migration.core.task.Migration;
-import org.openecomp.sdc.asdctool.migration.core.task.MigrationResult;
-import org.openecomp.sdc.be.dao.janusgraph.JanusGraphOperationStatus;
-import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
-import org.openecomp.sdc.be.dao.jsongraph.JanusGraphDao;
-import org.openecomp.sdc.be.dao.jsongraph.types.EdgeLabelEnum;
-import org.openecomp.sdc.be.dao.jsongraph.types.JsonParseFlagEnum;
-import org.openecomp.sdc.be.dao.jsongraph.types.VertexTypeEnum;
-import org.openecomp.sdc.be.dao.jsongraph.utils.IdBuilderUtils;
-import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
-import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
-import org.openecomp.sdc.be.model.jsonjanusgraph.operations.TopologyTemplateOperation;
-import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaElementOperation;
-import org.openecomp.sdc.common.log.wrappers.Logger;
-import org.springframework.stereotype.Component;
-
-import java.math.BigInteger;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.stream.Collectors;
-
-@Component
-public class SdcCatalogMigration implements Migration {
-    private static final Logger LOGGER = Logger.getLogger(SdcCatalogMigration.class);
-    private static final List<ResourceTypeEnum> EXCLUDE_TYPES = Arrays.asList(ResourceTypeEnum.VFCMT, ResourceTypeEnum.Configuration);
-
-    private ToscaElementOperation toscaElementOperation;
-    private JanusGraphDao janusGraphDao;
-
-    public SdcCatalogMigration(TopologyTemplateOperation toscaElementOperation, JanusGraphDao janusGraphDao) {
-        this.toscaElementOperation = toscaElementOperation;
-        this.janusGraphDao = janusGraphDao;
-    }
-
-    @Override
-    public String description() {
-        return "optimize sdc catalog vertices";
-    }
-
-    @Override
-    public DBVersion getVersion() {
-        return DBVersion.from(BigInteger.valueOf(1802), BigInteger.valueOf(0));
-    }
-
-    @Override
-    public MigrationResult migrate() {
-        JanusGraphOperationStatus status = null;
-        try {
-            status = getOrCreateCatalogRoot()
-                    .either(this::associateCatalogRootToCatalogElements,
-                            err -> {LOGGER.error("failed to create catalog root. err: {}", err); return err;});
-            return status == JanusGraphOperationStatus.OK ? MigrationResult.success() : MigrationResult.error("failed to create and associate catalog root. error: " + status);
-        } finally {
-            commitOrRollBack(status);
-        }
-    }
-
-    private void commitOrRollBack(JanusGraphOperationStatus status) {
-        if (status == JanusGraphOperationStatus.OK) {
-            janusGraphDao.commit();
-        } else {
-            janusGraphDao.rollback();
-        }
-    }
-
-    private Either<GraphVertex, JanusGraphOperationStatus> getOrCreateCatalogRoot() {
-        LOGGER.info("creating or getting catalog root vertex");
-        return janusGraphDao.getVertexByLabel(VertexTypeEnum.CATALOG_ROOT)
-                .right()
-                .bind(this::createRootCatalogVertexOrError);
-    }
-
-
-    private Either<GraphVertex, JanusGraphOperationStatus> createRootCatalogVertexOrError(JanusGraphOperationStatus janusGraphOperationStatus) {
-        return janusGraphOperationStatus == JanusGraphOperationStatus.NOT_FOUND ? createRootCatalogVertex() : Either.right(
-            janusGraphOperationStatus);
-    }
-
-    private Either<GraphVertex, JanusGraphOperationStatus> createRootCatalogVertex() {
-        LOGGER.info("Creating root catalog vertex");
-        GraphVertex catalogRootVertex = new GraphVertex(VertexTypeEnum.CATALOG_ROOT);
-        catalogRootVertex.setUniqueId(IdBuilderUtils.generateUniqueId());
-        return janusGraphDao.createVertex(catalogRootVertex);
-    }
-
-    private Either<List<GraphVertex>, JanusGraphOperationStatus> getAllCatalogVertices() {
-        LOGGER.info("fetching all catalog resources");
-        return toscaElementOperation.getListOfHighestComponents(ComponentTypeEnum.RESOURCE, EXCLUDE_TYPES, JsonParseFlagEnum.ParseMetadata)
-                .right()
-                .bind(this::errOrEmptyListIfNotFound)
-                .left()
-                .bind(this::getAllCatalogVertices);
-    }
-
-    private Either<List<GraphVertex>, JanusGraphOperationStatus> errOrEmptyListIfNotFound(JanusGraphOperationStatus err) {
-        return JanusGraphOperationStatus.NOT_FOUND.equals(err) ? Either.left(new ArrayList<>()) : Either.right(err);
-    }
-
-    @SuppressWarnings("unchecked")
-    private Either<List<GraphVertex>, JanusGraphOperationStatus> getAllCatalogVertices(List<GraphVertex> allResourceCatalogVertices) {
-        LOGGER.info("number of resources: {}", allResourceCatalogVertices.size());
-        LOGGER.info("fetching all catalog services");
-        return toscaElementOperation.getListOfHighestComponents(ComponentTypeEnum.SERVICE, EXCLUDE_TYPES, JsonParseFlagEnum.ParseMetadata)
-                .right()
-                .bind(this::errOrEmptyListIfNotFound)
-                .left()
-                .map(allServiceVertices -> ListUtils.union(allServiceVertices, allResourceCatalogVertices));
-    }
-
-    private JanusGraphOperationStatus associateCatalogRootToCatalogElements(GraphVertex root) {
-        return getAllCatalogVertices()
-                .either(catalogVertices -> associateCatalogRootToCatalogElements(root, catalogVertices),
-                        err -> err);
-    }
-
-    private JanusGraphOperationStatus associateCatalogRootToCatalogElements(GraphVertex root, List<GraphVertex> catalogElements) {
-        LOGGER.info("number of catalog elements: {}", catalogElements.size());
-        LOGGER.info("connect all catalog elements to root edge");
-        List<GraphVertex> nonConnectedElements = catalogElements.stream().filter(this::edgeNotAlreadyExists).collect(Collectors.toList());
-        int numOfCreatedEdges = 0;
-        for (GraphVertex catalogElement : nonConnectedElements) {
-                JanusGraphOperationStatus
-                    edgeCreationStatus = janusGraphDao
-                    .createEdge(root, catalogElement, EdgeLabelEnum.CATALOG_ELEMENT, null);
-                if (edgeCreationStatus != JanusGraphOperationStatus.OK) {
-                    LOGGER.error("failed to create edge from catalog element to vertex {}", catalogElement.getUniqueId());
-                    return edgeCreationStatus;
-                }
-                LOGGER.debug("created edge from catalog root to element {}", catalogElement.getUniqueId());
-                numOfCreatedEdges++;
-        }
-        LOGGER.info("number edges created: {}", numOfCreatedEdges);
-        return JanusGraphOperationStatus.OK;
-    }
-
-    private boolean edgeNotAlreadyExists(GraphVertex catalogElement) {
-        return !catalogElement.getVertex().edges(Direction.IN, EdgeLabelEnum.CATALOG_ELEMENT.name()).hasNext();
-    }
-
-
-}