aboutsummaryrefslogtreecommitdiffstats
path: root/aai-traversal/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'aai-traversal/src/main/java')
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/config/DmaapConfig.java20
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbEdgeGroup.java439
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbMeth.java3643
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/ModelBasedProcessing.java169
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/RelationshipGraph.java299
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/SearchGraph.java108
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSInInterceptor.java21
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSOutInterceptor.java31
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/rest/search/SearchProvider.java11
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/rest/ueb/UEBNotification.java2
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/util/RestURL.java704
-rw-r--r--aai-traversal/src/main/java/org/openecomp/aai/util/StoreNotificationEvent.java22
12 files changed, 161 insertions, 5308 deletions
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/config/DmaapConfig.java b/aai-traversal/src/main/java/org/openecomp/aai/config/DmaapConfig.java
index a33e653..45406ec 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/config/DmaapConfig.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/config/DmaapConfig.java
@@ -5,16 +5,16 @@
* Copyright (C) 2017 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.
+ * 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=========================================================
*/
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbEdgeGroup.java b/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbEdgeGroup.java
deleted file mode 100644
index 56a9a4b..0000000
--- a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbEdgeGroup.java
+++ /dev/null
@@ -1,439 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * Copyright (C) 2017 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.aai.dbgraphgen;
-
-import java.io.UnsupportedEncodingException;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.commons.collections.map.MultiValueMap;
-import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
-import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource;
-import org.apache.tinkerpop.gremlin.structure.Edge;
-import org.apache.tinkerpop.gremlin.structure.Vertex;
-
-import org.openecomp.aai.dbgen.DbMeth;
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.exceptions.AAIExceptionWithInfo;
-import org.openecomp.aai.ingestModel.DbMaps;
-import org.openecomp.aai.ingestModel.IngestModelMoxyOxm;
-import org.openecomp.aai.serialization.db.EdgeRule;
-import org.openecomp.aai.serialization.db.EdgeRules;
-import org.openecomp.aai.serialization.db.EdgeType;
-import org.openecomp.aai.serialization.db.MultiplicityRule;
-import org.openecomp.aai.serialization.db.exceptions.NoEdgeRuleFoundException;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.thinkaurelius.titan.core.TitanEdge;
-import com.thinkaurelius.titan.core.TitanTransaction;
-import com.thinkaurelius.titan.core.TitanVertex;
-
-public class DbEdgeGroup {
-
- private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(DbEdgeGroup.class);
-
- /**
- * Replace edge group.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param scope the scope
- * @param relatedNodesMultiMap the related nodes multi map
- * @param apiVersion the api version
- * @throws AAIException the AAI exception
- */
- public static void replaceEdgeGroup( String transId,
- String fromAppId,
- TitanTransaction graph,
- TitanVertex startVert,
- String scope,
- MultiValueMap relatedNodesMultiMap, // supports multiple entries for same nodetype
- String apiVersion ) throws AAIException{
-
- // --------------------------------------------------------------------
- // NOTE --- This routine is only used for "cousin" relationships.
- // --------------------------------------------------------------------
-
- /*
- * scope can be one of these:
- * a) "ALL_COUSIN_REL"
- * b) "ONLY_PASSED_COUSINS_REL" (only look at the edge types that are
- * represented in the passed list of relationships)
- *
- * Given a startNode and a list of relationshipInfo, we need to check the database and then,
- * 1) Delete any in-scope db relationships which are not represented in the relationshipList.
- * So, for ALL_COUSIN_REL, we would delete any db relationship that had an edge with
- * parentOf = false if it was not represented in the passed Relationship List.
- * For ONLY_PASSED_COUSINS_REL - we'd do the same as above, but only for edges that match the
- * type in the passed relationshipList. We'd leave any others alone.
- * 2) Then, Persist (add/update) all the remaining passed-in relationships.
- */
-
- if( !scope.equals("ALL_COUSIN_REL") && !scope.equals("ONLY_PASSED_COUSINS_REL") ){
- throw new AAIException("AAI_6120", "Illegal scope parameter passed: [" + scope + "].");
- }
-
- HashMap <String,String> vidToNodeTypeInDbHash = new HashMap <String,String>();
- HashMap <String,String> nodeTypeInReqHash = new HashMap <String,String>();
- HashMap <String,TitanEdge> vidToEdgeInDbHash = new HashMap <String,TitanEdge>();
- HashMap <String,TitanVertex> vidToTargetVertexHash = new HashMap <String,TitanVertex>();
-
- //------------------------------------------------------------------------------------------------------------
- // 1) First -- look what is currently in the db --
- // "cousins" => grab all nodes connected to startVertex that have edges with param: isParent = false.
- //------------------------------------------------------------------------------------------------------------
- GraphTraversalSource conPipeTraversal = startVert.graph().traversal();
- GraphTraversal<Vertex, Edge> conPipe = conPipeTraversal.V(startVert).bothE().has("isParent",false);
- // Note - it's ok if nothing is found
- if( conPipe != null ){
- while( conPipe.hasNext() ){
- TitanEdge ed = (TitanEdge) conPipe.next();
- TitanVertex cousinV = ed.otherVertex(startVert);
- String vid = cousinV.id().toString();
- String noTy = cousinV.<String>property("aai-node-type").orElse(null);
- vidToNodeTypeInDbHash.put(vid, noTy);
- vidToEdgeInDbHash.put(vid, ed);
-
- LOGGER.info("Found connected cousin vid(s) in db: [" + cousinV.id().toString() + "]");
- }
- }
-
- //------------------------------------------------------------------------------------------------------------
- //2) Get a List of the Titan nodes that the end-state list wants to be connected to
- //------------------------------------------------------------------------------------------------------------
- ArrayList <TitanVertex> targetConnectedToVertList = new ArrayList<TitanVertex>();
- if( relatedNodesMultiMap != null ) {
-
- Set entrySet = relatedNodesMultiMap.entrySet();
- Iterator it = entrySet.iterator();
- //System.out.println(" Object key Object value");
- while (it.hasNext()) {
- Map.Entry mapEntry = (Map.Entry) it.next();
- String rel2Nt = (String) mapEntry.getKey();
- int i = 0;
- ArrayList <HashMap<String, Object>> propList = ((ArrayList<HashMap<String, Object>>)relatedNodesMultiMap.get(rel2Nt));
- while (i < propList.size()) {
- HashMap<String, Object> propFilterHash = (HashMap<String, Object>) propList.get(i++);
-
- TitanVertex targetVert;
-
- try {
- targetVert = DbMeth.getUniqueNodeWithDepParams( transId,
- fromAppId,
- graph,
- rel2Nt,
- propFilterHash,
- apiVersion );
- } catch (AAIException e) {
- if (e.getErrorObject().getErrorCode().equals("6114"))
- throw new AAIExceptionWithInfo("AAI_6129",
- e,
- "Node of type " + rel2Nt + " not found for properties:" + propFilterHash.toString(),
- propFilterHash,
- rel2Nt);
- else
- throw e;
- }
-
- targetConnectedToVertList.add(targetVert);
-
- String vid = targetVert.id().toString();
- String noTy = targetVert.<String>property("aai-node-type").orElse(null);
- nodeTypeInReqHash.put(noTy, "");
- vidToTargetVertexHash.put(vid, targetVert);
-
- LOGGER.info("They request edges to these vids:[" + targetVert.id().toString() + "]");
- }
- }
- }
-
- //-------------------------------------------------------------------------------------------------------------------
- // 3) Compare what is in the DB with what they are requesting as an end-state.
- // If any are found in the db-list but not the new-list, delete them from the db (conditionally - based on scope)
- //-------------------------------------------------------------------------------------------------------------------
- String startVtxNT = startVert.<String>property("aai-node-type").orElse(null);
- for( Map.Entry<String, TitanEdge> entry : vidToEdgeInDbHash.entrySet() ){
- String vertId = entry.getKey();
- TitanEdge dbEd = entry.getValue();
- if( ! vidToTargetVertexHash.containsKey(vertId) ){
- if( scope.equals("ALL_COUSIN_REL") ){
- LOGGER.info("We will DELETE existing DB-edge to vids = [" + entry.getKey() + "]");
- DbMeth.removeAaiEdge(transId, fromAppId, graph, dbEd);
- }
- else if( scope.equals("ONLY_PASSED_COUSINS_REL") ){
- // If they use "ONLY_PASSED_COUSINS_REL" scope, they want us to delete an edge ONLY if:
- // a) this edge is the same type that they passed in (but goes to a different endpoint)
- // AND b) this additional edge would break the multiplicity edge rule.
- String ntInDb = vidToNodeTypeInDbHash.get(vertId);
- if( nodeTypeInReqHash.containsKey(ntInDb) && additionalEdgeWouldBreakMultEdgeRule(startVtxNT, ntInDb) ){
- LOGGER.info("We will DELETE existing DB-edge to vids = [" + entry.getKey() + "]");
- DbMeth.removeAaiEdge(transId, fromAppId, graph, dbEd);
- }
- }
- }
- }
-
- //---------------------------------------------------------------
- // 4) add/update (persist) all the relations on the new-list
- //---------------------------------------------------------------
- for( Map.Entry<String, TitanVertex> entry : vidToTargetVertexHash.entrySet() ){
- LOGGER.info("Call persistAaiEdge on edge(s) going to vids = " + "[" + entry.getKey() + "]");
- TitanVertex targV = entry.getValue();
- DbMeth.persistAaiEdge(transId, fromAppId, graph, startVert, targV, apiVersion, "cousin");
- }
-
- return;
-
-}// End replaceEdgeGroup()
-
-
-/**
- * Additional edge would break mult edge rule.
- *
- * @param startNodeType the start node type
- * @param endNodeType the end node type
- * @return the boolean
- * @throws AAIException the AAI exception
- */
-private static Boolean additionalEdgeWouldBreakMultEdgeRule( String startNodeType, String endNodeType )
- throws AAIException {
- // Return true if a second edge from the startNodeType to the endNodeType would
- // break a multiplicity edge rule.
- // Ie. Adding an edge to a second tenant (endNode) from a vserver (startNode) node would be flagged by this
- // if we have our multiplicity rule set up for the "vserver-tenant" edge set up as "Many2One" or if
- // it was set up the other way, "tenant-vserver" as "One2Many" or even if it was "One2One". In any of
- // those scenarios, the addition of an edge from a particular vserver to an additional tenant node
- // would break the rule.
-
- EdgeRule edgeRule = null;
- boolean reversed = false;
-
- if (EdgeRules.getInstance().hasEdgeRule(startNodeType, endNodeType)) {
- } else if (EdgeRules.getInstance().hasEdgeRule(endNodeType, startNodeType)) {
- reversed = true;
- }
-
- try {
- edgeRule = EdgeRules.getInstance().getEdgeRule(EdgeType.COUSIN, startNodeType, endNodeType);
- } catch (NoEdgeRuleFoundException e) {
- return false;
- }
-
-
- if (edgeRule.getMultiplicityRule().equals(MultiplicityRule.ONE2ONE)) {
- return true;
- } else if (reversed && edgeRule.getMultiplicityRule().equals(MultiplicityRule.ONE2MANY)) {
- return true;
- } else if (!reversed && edgeRule.getMultiplicityRule().equals(MultiplicityRule.MANY2ONE)) {
- return true;
- } else {
- return false;
- }
-
-
-}// end of additionalEdgeWouldBreakMultEdgeRule()
-
-/**
- * Delete edge group.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param relatedNodesMultiMap the related nodes multi map
- * @param apiVersion the api version
- * @return void
- * @throws AAIException the AAI exception
- */
-public static void deleteEdgeGroup( String transId,
- String fromAppId,
- TitanTransaction graph,
- TitanVertex startVert,
- MultiValueMap relatedNodesMultiMap,
- String apiVersion ) throws AAIException{
- // --------------------------------------------------------------------
- // NOTE - This routine is only used for "cousin" relationships.
- // ALSO - an edge deletion will fail if that edge was needed by
- // the node on one of the sides for uniqueness. We're just
- // being careful here - so far, I don't think a cousin-edge
- // is ever used for this kind of dependency.
- // --------------------------------------------------------------------
-
- HashMap <String,TitanEdge> cousinVidToEdgeInDbHash = new HashMap <String,TitanEdge>();
- String startVertNT = startVert.<String>property("aai-node-type").orElse(null);
- String startVertVid = startVert.id().toString();
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(apiVersion);
- Collection <String> startVertDepNTColl = dbMaps.NodeDependencies.get(startVertNT);
-
- //-----------------------------------------------------------------------------------------------------
- // Get a list of vertexes that are attached to the startVert as "cousins" and the connecting edges
- //-----------------------------------------------------------------------------------------------------
- GraphTraversalSource conPipeTraversal = startVert.graph().traversal();
- GraphTraversal<Vertex, Edge> conPipe = conPipeTraversal.V(startVert).bothE().has("isParent",false);
- if( conPipe != null ){
- while( conPipe.hasNext() ){
- TitanEdge ed = (TitanEdge) conPipe.next();
- TitanVertex cousinV = ed.otherVertex(startVert);
- String vid = cousinV.id().toString();
- cousinVidToEdgeInDbHash.put(vid, ed);
- }
- }
-
- //-------------------------------------------------------------
- // Look through the Relationship info passed in.
- // Delete edges as requested if they check-out as cousins.
- //-------------------------------------------------------------
- Boolean isFirst = true;
- String msg = "Deleting edges from vid = " + startVertVid + "(" + startVertNT + "), to these: [";
- if( relatedNodesMultiMap != null ) {
- Set entrySet = relatedNodesMultiMap.entrySet();
- Iterator it = entrySet.iterator();
- //System.out.println(" Object key Object value");
- while (it.hasNext()) {
- Map.Entry mapEntry = (Map.Entry) it.next();
- String rel2Nt = (String) mapEntry.getKey();
- HashMap<String, Object> propFilterHash = (HashMap<String, Object>)((ArrayList) relatedNodesMultiMap.get(rel2Nt)).get(0);
- TitanVertex otherEndVert = DbMeth.getUniqueNodeWithDepParams( transId, fromAppId, graph, rel2Nt, propFilterHash, apiVersion );
- String otherNT = otherEndVert.<String>property("aai-node-type").orElse(null);
- String reqDelConnectedVid = otherEndVert.id().toString();
- if( !cousinVidToEdgeInDbHash.containsKey(reqDelConnectedVid) ){
- throw new AAIException("AAI_6127", "COUSIN Edge between " + startVertVid + " (" + startVertNT + ") and " + reqDelConnectedVid +
- "(" + otherNT + ") not found. ");
- }
- else {
- // This was a cousin edge. But before we delete it, we will check to make
- // sure it doesn't have a unique-dependency issue (need to check in two directions)
- Iterator <String> ntItr1 = startVertDepNTColl.iterator();
- if( ntItr1.hasNext() ){
- while( ntItr1.hasNext() ){
- if( ntItr1.next().equals(otherNT) ){
- throw new AAIException("AAI_6126", "Edge between " + startVertVid + " and " + reqDelConnectedVid +
- " cannot be deleted because of a uniqueness-dependancy between nodeTypes, " +
- startVertNT + " and " + otherNT);
- }
- }
- }
-
- Collection <String> depNTColl = dbMaps.NodeDependencies.get(otherNT);
- Iterator <String> ntItr2 = depNTColl.iterator();
- if( ntItr2.hasNext() ){
- while( ntItr2.hasNext() ){
- if( ntItr2.next().equals(startVertNT) ){
- throw new AAIException("AAI_6126", "Edge between " + startVertVid + " and " + reqDelConnectedVid +
- " cannot be deleted because of a uniqueness-dependancy between nodeTypes: " +
- otherNT + " and " + startVertNT);
- }
- }
- }
-
- // It's OK to delete this edge as requested.
- if( ! isFirst ){
- msg = msg + ", ";
- }
- isFirst = false;
- msg = msg + reqDelConnectedVid + "(" + otherNT + ")";
- TitanEdge targetDelEdge = cousinVidToEdgeInDbHash.get(reqDelConnectedVid);
- DbMeth.removeAaiEdge(transId, fromAppId, graph, targetDelEdge);
- }
- }
- }
-
- msg = msg + "]";
-
- LOGGER.info(msg);
-
- return;
-
-}// End deleteEdgeGroup()
-
-
-/**
- * Gets the edge group.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param vidToNodeTypeHash the vid to node type hash
- * @param vidToVertexHash the vid to vertex hash
- * @param scope the scope
- * @param apiVersion the api version
- * @return void
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
-public static void getEdgeGroup( String transId,
- String fromAppId,
- TitanTransaction graph,
- TitanVertex startVert,
- HashMap <String,String> vidToNodeTypeHash,
- HashMap <String,TitanVertex> vidToVertexHash,
- String scope,
- String apiVersion ) throws AAIException, UnsupportedEncodingException{
-
- LOGGER.debug("scope={}", scope);
- LOGGER.debug("vid={}", startVert.id().toString());
- LOGGER.debug("nodetype={}", startVert.property("aai-node-type").orElse(null).toString());
-
- /*
- * scope can be one of these:
- * 1) "ONLY_COUSIN_REL" <-- This is the only one supported for now
- * 2) "ALL_COUSIN_AND_CHILDREN_REL"
- * 3) "ONLY_CHILDREN"
- * 4) "USES_RESOURCE"
- *
- * Given a startNode and the scope, we need to return relationships that we find in the DB
- */
-
- if( !scope.equals("ONLY_COUSIN_REL") ){
- throw new AAIException("AAI_6120", "Illegal scope parameter passed: [" + scope + "].");
- }
-
- //------------------------------------------------------------------------------------------------------------
- // Grab "first-layer" vertexes from the in the db --
- // "cousins" => grab all nodes connected to startVertex that have edges with param: isParent = false.
- // "children" => grab nodes via out-edge with isParent = true (NOT YET SUPPORTED)
- //------------------------------------------------------------------------------------------------------------
- Iterable<Vertex> qResult = startVert.query().has("isParent",false).vertices();
- Iterator <Vertex> resultI = qResult.iterator();
-
- while( resultI.hasNext() ){
- TitanVertex cousinV = (TitanVertex)resultI.next();
- //showPropertiesForNode( transId, fromAppId, cousinV );
-
- String vid = cousinV.id().toString();
- String noTy = cousinV.<String>property("aai-node-type").orElse(null);
- vidToNodeTypeHash.put(vid, noTy);
- vidToVertexHash.put(vid, cousinV);
-
- LOGGER.debug("Found connected cousin vid(s) in db: " + "[" + cousinV.id().toString() + "]");
- }
-
-}// End getEdgeGroup()
-
-
-}
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbMeth.java b/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbMeth.java
deleted file mode 100644
index bbcee63..0000000
--- a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/DbMeth.java
+++ /dev/null
@@ -1,3643 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * Copyright (C) 2017 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.aai.dbgraphgen;
-
-import java.net.Inet4Address;
-import java.net.Inet6Address;
-import java.net.InetAddress;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__;
-import org.apache.tinkerpop.gremlin.structure.Direction;
-import org.apache.tinkerpop.gremlin.structure.Edge;
-import org.apache.tinkerpop.gremlin.structure.Vertex;
-import org.apache.tinkerpop.gremlin.structure.VertexProperty;
-
-import org.openecomp.aai.dbmodel.DbEdgeRules;
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.ingestModel.DbMaps;
-import org.openecomp.aai.ingestModel.IngestModelMoxyOxm;
-import org.openecomp.aai.serialization.db.EdgeRule;
-import org.openecomp.aai.serialization.db.EdgeRules;
-import org.openecomp.aai.util.AAIConfig;
-import org.openecomp.aai.util.AAIConstants;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.google.common.net.InetAddresses;
-import com.thinkaurelius.titan.core.TitanEdge;
-import com.thinkaurelius.titan.core.TitanGraph;
-import com.thinkaurelius.titan.core.TitanTransaction;
-import com.thinkaurelius.titan.core.TitanVertex;
-
-
-/**
- * General Database-level Utility class. These methods deal with the database one dataNode / Edge at a time.
- * Transactions are managed at a higher level by the calling classes by passing in a TitanTransaction object.
- */
-public class DbMeth{
-
- private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(DbMeth.class);
-
- /**
- * Patch aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param depNodeVal the dep node val
- * @param apiVersion the api version
- * @return TitanVertex
- * @throws AAIException the AAI exception
- */
- public static TitanVertex patchAaiNode(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, TitanVertex depNodeVal, String apiVersion ) throws AAIException{
- // If they're calling patchAaiNode, then we only want to add/update the properties that they
- // pass us in the propHash. If there are others already in the DB, we leave them alone.
-
- // Note: to be really official, we'd throw an error if the node wasn't already in the db.
- boolean[] objectExists = new boolean[1];
- objectExists[0] = true;
- Boolean patchOnly = true;
- TitanVertex tv = persistAaiNodeBASE(transId, fromAppId, graph, nodeType, propHash, depNodeVal, patchOnly, apiVersion, objectExists);
- return( tv );
-
- } // end of patchAaiNode()
-
- /**
- * Patch aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param depNodeVal the dep node val
- * @return the titan vertex
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanVertex patchAaiNode(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, TitanVertex depNodeVal) throws AAIException{
- return patchAaiNode( transId, fromAppId, graph, nodeType,
- propHash, depNodeVal, null );
- }
-
- /**
- * Persist aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param depNodeVal the dep node val
- * @param patchOnly the patch only
- * @param apiVersion the api version
- * @return the titan vertex
- * @throws AAIException the AAI exception
- */
- public static TitanVertex persistAaiNode(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, TitanVertex depNodeVal, Boolean patchOnly, String apiVersion) throws AAIException{
- boolean[] objectExists = new boolean[1];
- objectExists[0] = false;
- return persistAaiNodeBASE( transId, fromAppId, graph, nodeType,
- propHash, depNodeVal, patchOnly, apiVersion, objectExists);
- }
-
- /**
- * Persist aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param addIfNotFound the add if not found
- * @param depNodeVal the dep node val
- * @param apiVersion the api version
- * @return the titan vertex
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanVertex persistAaiNode(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, Boolean addIfNotFound, TitanVertex depNodeVal, String apiVersion) throws AAIException{
- // If they're calling persistAaiNode, then we want to make the Db look like whatever they pass us. That is, if
- // there is already a record in the DB, but they do not pass some of the existing properties, they should
- // be cleared from the DB. Since we want to take care of all properties, we pass patchOnly = false
- Boolean patchOnly = false;
- boolean[] objectExists = new boolean[1];
- objectExists[0] = false;
- TitanVertex tv = persistAaiNodeBASE(transId, fromAppId, graph, nodeType, propHash, depNodeVal, patchOnly, apiVersion, objectExists);
- return( tv );
- }
-
- /**
- * Persist aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param addIfNotFound the add if not found
- * @param depNodeVal the dep node val
- * @return the titan vertex
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanVertex persistAaiNode(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, Boolean addIfNotFound, TitanVertex depNodeVal) throws AAIException{
- // If they're calling persistAaiNode, then we want to make the Db look like whatever they pass us. That is, if
- // there is already a record in the DB, but they do not pass some of the existing properties, they should
- // be cleared from the DB. Since we want to take care of all properties, we pass patchOnly = false
- Boolean patchOnly = false;
- boolean[] objectExists = new boolean[1];
- objectExists[0] = false;
- TitanVertex tv = persistAaiNodeBASE(transId, fromAppId, graph, nodeType, propHash, depNodeVal, patchOnly, null, objectExists);
- return( tv );
- } // end of persistAaiNode()
-
- /**
- * Persist aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param addIfNotFound the add if not found
- * @param depNodeVal the dep node val
- * @param apiVersion the api version
- * @param objectExists the object exists
- * @return TitanVertex
- * @throws AAIException the AAI exception
- */
- public static TitanVertex persistAaiNode(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, Boolean addIfNotFound, TitanVertex depNodeVal, String apiVersion, boolean[] objectExists) throws AAIException{
- Boolean patchOnly = false;
- // If they're calling persistAaiNode, then we want to make the Db look like whatever they pass us. That is, if
- // there is already a record in the DB, but they do not pass some of the existing properties, they should
- // be cleared from the DB. Since we want to take care of all properties, we pass patchOnly = false
- TitanVertex tv = persistAaiNodeBASE(transId, fromAppId, graph, nodeType, propHash, depNodeVal, patchOnly, apiVersion, objectExists, null);
- return( tv );
- }
-
- /**
- * Persist aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param addIfNotFound the add if not found
- * @param depNodeVal the dep node val
- * @param apiVersion the api version
- * @param objectExists the object exists
- * @param thisNodeVertex the this node vertex
- * @return the titan vertex
- * @throws AAIException the AAI exception
- */
- public static TitanVertex persistAaiNode(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, Boolean addIfNotFound, TitanVertex depNodeVal, String apiVersion, boolean[] objectExists, TitanVertex thisNodeVertex) throws AAIException{
- Boolean patchOnly = false;
- // If they're calling persistAaiNode, then we want to make the Db look like whatever they pass us. That is, if
- // there is already a record in the DB, but they do not pass some of the existing properties, they should
- // be cleared from the DB. Since we want to take care of all properties, we pass patchOnly = false
- TitanVertex tv = persistAaiNodeBASE(transId, fromAppId, graph, nodeType, propHash, depNodeVal, patchOnly, apiVersion, objectExists, thisNodeVertex);
- return( tv );
- }
-
- /**
- * Persist aai node BASE.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param depNodeVal the dep node val
- * @param patchOnly the patch only
- * @param apiVersion the api version
- * @param objectExists the object exists
- * @return the titan vertex
- * @throws AAIException the AAI exception
- */
- public static TitanVertex persistAaiNodeBASE(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, TitanVertex depNodeVal, Boolean patchOnly,
- String apiVersion, boolean[] objectExists) throws AAIException{
- return persistAaiNodeBASE(transId, fromAppId, graph, nodeType, propHash, depNodeVal, patchOnly, apiVersion, objectExists, null);
- }
-
- /**
- * Persist aai node BASE.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propHash the prop hash
- * @param depNodeVal the dep node val
- * @param patchOnly the patch only
- * @param apiVersion the api version
- * @param objectExists the object exists
- * @param thisNodeVertex the this node vertex
- * @return the titan vertex
- * @throws AAIException the AAI exception
- */
- public static TitanVertex persistAaiNodeBASE(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap <String,Object> propHash, TitanVertex depNodeVal, Boolean patchOnly,
- String apiVersion, boolean[] objectExists, TitanVertex thisNodeVertex) throws AAIException{
-
- if( graph == null ){
- throw new AAIException("AAI_6101", "null graph object passed to persistAaiNodeBASE()");
- }
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- boolean useDepNode = false;
- String resourceVersion = null;
- if( propHash.containsKey("resource-version") ){
- resourceVersion = (String)(propHash.get("resource-version"));
- }
- String aaiUniqueKeyVal = null;
- if( propHash.containsKey("aai-unique-key") ){
- // Note -- we are assuming that nobody is monkeying with this. The 16-07 first-pass theory
- // is that the REST layer is always gonna generate this or pass it through.
- aaiUniqueKeyVal = (String)(propHash.get("aai-unique-key"));
- propHash.remove("aai-unique-key");
- }
-
- if( needsADepNode4Uniqueness(transId, fromAppId, nodeType, apiVersion) ){
- // This kind of node needs a dependent node (for uniqueness)
- if( depNodeVal == null ){
- // They should have passed in the node that this one depends on
- throw new AAIException("AAI_6109", "null dependentNode object passed to persistAaiNodeBASE() but " + nodeType + " requires one.");
- }
- else if( ! nodeTypeACanDependOnB(transId, fromAppId, nodeType, depNodeVal.<String>property("aai-node-type").orElse(null), apiVersion) ){
- // They should have passed in the right type of node as the dependent node
- throw new AAIException("AAI_6109", "dependentNode of type " + depNodeVal.<String>property("aai-node-type").orElse(null) + " passed to persistAaiNodeBASE() for nodeType" + nodeType + ".");
- }
- useDepNode = true;
- }
- else {
- depNodeVal = null;
- }
-
- // Note: as of 1607, we no longer validate property names since that's covered by the REST layer.
- // Same goes for required fields (as of 1602)
-
- // Special ip-address validation for ipAddr nodes only... This will go away when we go to YANG and
- // do validations like this up at that layer.
- if( nodeType.equals("ipaddress") ){
- // Note - this will throw an exception if the ipAddress is using a bad format
- ipAddressFormatOK( transId, fromAppId, (String)propHash.get("addr"), (String)propHash.get("version") );
- }
-
- // Use the key-fields/dependentNode to check if this is an add or an update
- // We assume that all NodeTypes at least one key-property defined. A dependentNode is optional.
- if( ! dbMaps.NodeKeyProps.containsKey(nodeType) ){
- // Problem if no key Properties defined for this nodeType
- String defVer = AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP);
- throw new AAIException("AAI_6105", "No node-key-properties defined in dbMaps for nodeType = " + nodeType + " (ver=" + defVer + ")");
- }
-
- Boolean hasAltKey1 = false;
- HashMap <String,Object>nodeAltKey1PropsHash = new HashMap<String,Object>();
- Collection <String> altKey1Props = getNodeAltKey1PropNames(transId, fromAppId, nodeType, apiVersion);
- if( altKey1Props != null ){
- Iterator <String> altKey1PropI = altKey1Props.iterator();
- while( altKey1PropI.hasNext() ){
- String propName = altKey1PropI.next();
- // NOTE: alt-keys are not always required fields. If it is null or blank, we won't
- // do alt-key checks on it.
- Object value = propHash.get(propName);
- if( value != null && !value.toString().equals("") ){
- hasAltKey1 = true;
- nodeAltKey1PropsHash.put(propName, value);
- }
- }
- }
- HashMap <String,Object>nodeKeyPropsHash = new HashMap<String,Object>();
- Collection <String> keyProps = getNodeKeyPropNames(transId, fromAppId, nodeType, apiVersion);
- Iterator <String> keyPropI = keyProps.iterator();
- while( keyPropI.hasNext() ){
- String propName = keyPropI.next();
-
- Object value = propHash.get(propName);
- nodeKeyPropsHash.put(propName, value);
- }
-
- // Check if this node is already in the database based on the Primary Key Info
- TitanVertex existingVert = thisNodeVertex;
- boolean foundTheNodeInDb = true;
-
- if (existingVert == null) {
- try {
- existingVert = getUniqueNode( transId, fromAppId, graph, nodeType, nodeKeyPropsHash, depNodeVal, apiVersion );
- }
- catch (AAIException e) {
- if (e.getErrorObject().getErrorCode().equals("6114")) {
- foundTheNodeInDb = false;
- }
- else {
- throw e;
- }
- }
- }
-
- // this is so the notification knows whether or not the operation was an UPDATE or a CREATe
- objectExists[0] = foundTheNodeInDb;
- if( foundTheNodeInDb ){
- // A record was found in the DB using the PK.
- if( needToDoResourceVerCheck(apiVersion, patchOnly) ){
- // Need to check that they knew what they were updating
- String existingResVer = existingVert.<String>property("resource-version").orElse(null);
- if( resourceVersion == null || resourceVersion.equals("") ){
- throw new AAIException("AAI_6130", "Resource-version not passed for update of = " + nodeType + ", " + nodeKeyPropsHash.toString());
- }
- else if( (existingResVer != null) && !resourceVersion.equals(existingResVer) ){
- throw new AAIException("AAI_6131", "Resource-version " + resourceVersion + " MISMATCH WITH EXISTING " + existingResVer + " for update of = " + nodeType + ", " + nodeKeyPropsHash.toString());
- }
- }
-
- // Need to ensure that the Alternate key isn't changing to a value that points to a different existing node.
- // It is ok if it points to nothing -- that would just be an update for this node. It's also ok if
- // it points to this (existing) node - that just means that it wasn't being updated.
- if( hasAltKey1 ){
- try {
- TitanVertex chkVert = getUniqueNode( transId, fromAppId, graph, nodeType, nodeAltKey1PropsHash, depNodeVal, apiVersion );
- if( ! chkVert.id().toString().equals(existingVert.id().toString()) ){
- throw new AAIException("AAI_6117", "In-Use AlternateKey value passed for update of nodeType = " + nodeType);
- }
- }
- catch (AAIException e) {
- if(! e.getErrorObject().getErrorCode().equals("6114") ){
- throw e;
- }
- }
- }
- }
- else {
- // Note not in the DB -- This will be an ADD of a new node
- // a) make sure they didn't say they were just doing "patchOnly" which cannot be an ADD.
- // b) if there is an alternate key, we need to make sure the AK isn't already in use by somebody else.
- if( patchOnly ){
- String depMsg = "";
- if( useDepNode ){
- depMsg = " plus dependent node. ";
- }
- throw new AAIException("AAI_6114", "Patch Request, but no Node of type " + nodeType + " found for properties: [" + propHash + "] " + depMsg);
- }
-
- if( needToDoResourceVerCheck(apiVersion, patchOnly) && (resourceVersion != null) && !resourceVersion.equals("") ){
- throw new AAIException("AAI_6131", "Resource-version was passed in, but this is an ADD of a " + nodeType + ", with these params: " + nodeKeyPropsHash.toString());
- }
- if( hasAltKey1 ){
- try {
- getUniqueNode( transId, fromAppId, graph, nodeType, nodeAltKey1PropsHash, depNodeVal, apiVersion );
- // Since the Primary Key for this nodeType wasn't found in the DB yet, the fact that
- // we are able to find a record (no "6114" exception thrown) using the Alternate-Key is an error.
- // We can't create a new node that uses an AK that's already in use.
- throw new AAIException("AAI_6117", "Conflicting Key and Alternate-Key values passed for add of nodeType = " + nodeType);
- }
- catch (AAIException e) {
- if(! e.getErrorObject().getErrorCode().equals("6114") ){
- throw e;
- }
- }
- }
- }
-
- // ------------- Done with checking. Do the add or update to the dB -----------------------
-
- if( foundTheNodeInDb ){
- long unixTimeNow = System.currentTimeMillis() / 1000L;
- // ----- This is an UPDATE ------
-
-
- String existingSourceOfTruth = fromAppId; // default value if we can't get the old one
- Object tmpOb = existingVert.<Object>property("source-of-truth").orElse(null);
- if( tmpOb != null ){
- existingSourceOfTruth = tmpOb.toString();
- }
- long existingCreateTs = unixTimeNow; // default value if we can't get the old one
- tmpOb = existingVert.<Object>property("aai-created-ts").orElse(null);
- if( tmpOb != null ){
- existingCreateTs = (long) tmpOb;
- }
-
- String msg = "UPDATE vertex of type = [" + nodeType + "] ";
- if( useDepNode ){
- String depNType = depNodeVal.<String>property("aai-node-type").orElse(null);
- HashMap <String, Object> depNodePropKeysHash = getNodeKeyPropHash(transId, fromAppId, graph, depNodeVal);
- LOGGER.info("UPDATE existing node: type = " + nodeType + ", key(s) = [" + nodeKeyPropsHash +
- "] which rides on dependent node: type = " + depNType + ", with key(s) = [" + depNodePropKeysHash + "].");
- }
- else {
- LOGGER.info("UPDATE existing node: type = " + nodeType + ", key(s) = [" + nodeKeyPropsHash + "] (no dep. node).");
- }
- String removeList = "";
- if( ! patchOnly ){
- // They are updating an existing record, and they want us to "process all defined properties" (not just patch)
- // So we will see if the node has any properties that were not passed-in. Those need to be removed.
- Collection <String> propCol = dbMaps.NodeProps.get(nodeType);
- Iterator <String> propIter = propCol.iterator();
- while( propIter.hasNext() ){
- String propName = propIter.next();
- if( ! propHash.containsKey(propName) && !DbEdgeRules.ReservedPropNames.containsKey(propName)){
- if( thisPropertyWasPutByNewerVersionOfCode(apiVersion, nodeType, propName) ){
- // we must be using an older version of code here - but the property that
- // has not been passed in this persist call is one that this older version of
- // the database did not know about. So leave it alone.
- }
- else {
- removeList = removeList + "," + propName;
- existingVert.property(propName).remove();
- }
- }
- }
- }
- if( !removeList.equals("") ){
- LOGGER.info("Removed these props on update: [" + removeList + "]");
- }
- for( Map.Entry<String, Object> entry : propHash.entrySet() ){
- // update the parameters that have been passed in (except the key-properties)
- // taking away the key-property check. We will now allow this since
- // the keys were used to identify this node, so they should be good and
- // there are times when Titan resolves conflicts by only using the
- // data set in an update - and was losing our key info...
- // Similar to the change noted below.
- //if( ! nodeKeyPropsHash.containsKey(entry.getKey()) ){
- // existingVert.setProperty( entry.getKey(), entry.getValue() );
- //}
- if( ! entry.getKey().equals("resource-version") ){
- boolean nonSingleCardinality = false;
- boolean setSoNoDupes = false;
- if( checkPropCardinality(entry.getKey(), "Set") ){
- nonSingleCardinality = true;
- setSoNoDupes = true;
- }
- else if( checkPropCardinality(entry.getKey(), "List") ){
- nonSingleCardinality = true;
- }
-
- Iterator <Object> valIter = null;
- if( nonSingleCardinality ){
- String className = entry.getValue().getClass().getSimpleName();
- if( className.equals("ArrayList") ){
- valIter = ((ArrayList)(entry.getValue())).iterator();
- }
- else if( className.equals("List") ){
- valIter = ((List)(entry.getValue())).iterator();
- }
- else if( className.equals("Set") ){
- valIter = ((Set)(entry.getValue())).iterator();
- }
- }
-
- if( nonSingleCardinality ){
- // This property has Cardinality of List or Set - which need to be handled carefully
- // Note -- for Lists or Sets, we assume they are of dataType String - that is all
- // the Rest layer supports at the moment (16-02)
- ArrayList <String> currentData = new ArrayList <String> ();
- if( patchOnly ){
- // When patching - gotta know what's already in the db
- Iterator<VertexProperty<Object>> existingPropsIter = (existingVert.properties(entry.getKey()));
- if( existingPropsIter != null ){
- while( existingPropsIter.hasNext() ){
- String existingVal = existingPropsIter.next().value().toString();
- currentData.add( existingVal );
- }
- }
- }
- else {
- // Since this is not a patch-update, we first have to clear out what is currently in the db.
- existingVert.property(entry.getKey()).remove();
- }
-
- if( valIter != null ){
- while( valIter.hasNext() ){
- Object thisVal = valIter.next();
- if( setSoNoDupes ){
- // For Sets, we need to check that the data isn't already in the db or wasn't passed
- // in to us twice in the propHash. Otherwise Titan throws an exception (instead of just ignoring it...)
- if( !currentData.contains(thisVal) ){
- // We don't have this data yet, so add it to the Set
- existingVert.property( entry.getKey(), thisVal );
- currentData.add( thisVal.toString() );
- }
- }
- else {
- // For List data types, it's ok to have duplicate values in the db (why would we want this?)
- existingVert.property( entry.getKey(), thisVal );
- }
- }
- }
- }
- else {
- // This is a normal, "Cardinality = SINGLE" kind of property
- // ResourceVersion is not populated based on passed-in data, it is set along with other internal properties below.
- //Object cleanVal = convertTypeIfNeeded( entry.getKey(), entry.getValue() );
- //existingVert.setProperty( entry.getKey(), cleanVal );
- // ********************************
- existingVert.property( entry.getKey(), entry.getValue() );
- }
- }
- }
-
- // DEBUG - trying to deal with the case where simultaneous PUTs
- // cause our db to wind up with a vertex that does not have these three properties filled in.
- existingVert.property( "aai-node-type", nodeType );
- existingVert.property( "aai-created-ts", existingCreateTs );
- existingVert.property( "source-of-truth", existingSourceOfTruth );
-
- if( aaiUniqueKeyVal != null ){
- existingVert.property( "aai-unique-key", aaiUniqueKeyVal );
- }
-
- existingVert.property( "aai-last-mod-ts", unixTimeNow );
- String resVers = "" + unixTimeNow;
- existingVert.property( "resource-version", resVers );
- existingVert.property( "last-mod-source-of-truth", fromAppId );
-
- LOGGER.info(msg + ", [aai-last-mod-ts]/[" + unixTimeNow + "]");
-
- return( existingVert );
- }
- else{
- // ----- Not found in the DB, This must be an ADD ------
- if( DbEdgeRules.NodeTypeCategory.containsKey(nodeType) ){
- throw new AAIException("AAI_6120", "nodeTypeCategory " + nodeType + " cannot be used to ADD a node. Need to pass a valid nodeType");
- }
-
- TitanVertex tiVnew = graph.addVertex( nodeType );
-
- String msg = "ADD vertex of type = [" + nodeType + "] ";
- if( depNodeVal != null ){
- String depNType = depNodeVal.<String>property("aai-node-type").orElse(null);
- HashMap <String, Object> depNodePropKeysHash = getNodeKeyPropHash(transId, fromAppId, graph, depNodeVal);
- msg = msg + " onto dependent node: type = " + depNType + ", which has key(s) = [" + depNodePropKeysHash +
- "]. New Node Prop/values = ";
- }
- else {
- msg = msg + " Note: no dependent node. New Node Prop/values = ";
- }
- boolean first = true;
- for( Map.Entry<String, Object> entry : propHash.entrySet() ){
- if( ! entry.getKey().equals("resource-version") ){
- if( first ){
- msg = msg + " [" + entry.getKey() + "]/[" + entry.getValue() + "]";
- first = false;
- }
- else {
- msg = msg + ", [" + entry.getKey() + "]/[" + entry.getValue() + "]";
- }
-
- boolean nonSingleCardinality = false;
- boolean setSoNoDupes = false;
- if( checkPropCardinality(entry.getKey(), "Set") ){
- nonSingleCardinality = true;
- setSoNoDupes = true;
- }
- else if( checkPropCardinality(entry.getKey(), "List") ){
- nonSingleCardinality = true;
- }
-
- Iterator <Object> valIter = null;
- if( nonSingleCardinality ){
- String className = entry.getValue().getClass().getSimpleName();
- if( className.equals("ArrayList") ){
- valIter = ((ArrayList)(entry.getValue())).iterator();
- }
- else if( className.equals("List") ){
- valIter = ((List)(entry.getValue())).iterator();
- }
- else if( className.equals("Set") ){
- valIter = ((Set)(entry.getValue())).iterator();
- }
- }
-
- if( nonSingleCardinality ){
- // This property has Cardinality of List or Set - which need to be handled carefully
- ArrayList <String> currentData = new ArrayList <String> ();
- if( valIter != null ){
- while( valIter.hasNext() ){
- Object thisVal = valIter.next();
- if( setSoNoDupes ){
- // For Sets, we need to check that they're not passing us duplicate data in propHash.
- // Otherwise Titan throws an exception (instead of just ignoring it...)
- if( !currentData.contains(thisVal) ){
- // We don't have this data yet, so add it to the Set
- tiVnew.property( entry.getKey(), thisVal );
- currentData.add( thisVal.toString() );
- }
- }
- else {
- // For List data types, it's ok to have duplicate values in the db (why would we want this?)
- tiVnew.property( entry.getKey(), thisVal );
- }
- }
- }
- }
- else {
- // This is a normal, "Cardinality = SINGLE" kind of property
- // ResourceVersion is not populated based on passed-in data, it is set along with other internal properties below.
- tiVnew.property( entry.getKey(), entry.getValue() );
- }
- }
- }
-
- tiVnew.property( "aai-node-type", nodeType );
- //long unixTime = System.currentTimeMillis() / 1000L;
- long unixTime = System.currentTimeMillis();
- tiVnew.property( "aai-created-ts", unixTime );
- tiVnew.property( "aai-last-mod-ts", unixTime );
- String resVers = "" + unixTime;
- tiVnew.property( "resource-version", resVers );
- tiVnew.property( "source-of-truth", fromAppId );
- tiVnew.property( "last-mod-source-of-truth", fromAppId );
- if( aaiUniqueKeyVal != null ){
- tiVnew.property( "aai-unique-key", aaiUniqueKeyVal );
- }
-
- LOGGER.info(msg + ", [aai-created-ts]/[" + unixTime + "]");
- return( tiVnew );
- }
-
- } // end of persistAaiNodeBASE()
-
-
- /**
- * Need to do resource ver check.
- *
- * @param apiVersion the api version
- * @param patchOnlyFlag the patch only flag
- * @return the boolean
- * @throws AAIException the AAI exception
- */
- public static Boolean needToDoResourceVerCheck(String apiVersion, Boolean patchOnlyFlag)
- throws AAIException{
-
- if( patchOnlyFlag ){
- // we do not do resource checking for patch requests.
- return false;
- }
-
- String resourceCheckOnFlag = AAIConfig.get(AAIConstants.AAI_RESVERSION_ENABLEFLAG);
-
- int apiVerInt = cleanUpApiVersion(apiVersion);
-
- if( (resourceCheckOnFlag != null) && resourceCheckOnFlag.equals("true") ){
- // Only do the check if the resource enable flag is set to "true"
- if( apiVerInt > 4 ){
- // We're only doing the resource version checks for v5 and later
- return true;
- }
- }
-
- return false;
- }// End needToDoResourceVerCheck()
-
-
- /**
- * Clean up api version.
- *
- * @param apiVersionString the api version string
- * @return the int
- * @throws AAIException the AAI exception
- */
- private static int cleanUpApiVersion( String apiVersionString ) throws AAIException {
- // Note: we expect an apiVersion to start with the letter "v", followed by an integer.
-
- int versionInt = 0;
- String verStr = apiVersionString;
- if( (apiVersionString == null) || (apiVersionString.length() < 2) ){
- // Passed in version doesn't look right
- verStr = org.openecomp.aai.util.AAIApiVersion.get();
- }
- versionInt = getVerNumFromVerString( verStr );
-
- return versionInt;
- }
-
- /**
- * Gets the ver num from ver string.
- *
- * @param versionString the version string
- * @return the ver num from ver string
- * @throws AAIException the AAI exception
- */
- private static int getVerNumFromVerString( String versionString )throws AAIException {
- int versionInt = 0;
- if( versionString == null || versionString.length() < 2 ){
- throw new AAIException("AAI_6121", " Bad Version (format) passed to getVerNumFromVerString: [" + versionString + "].");
- }
-
- int strLen = versionString.length();
- // We assume that a version looks like "v" followed by an integer
- if( ! versionString.substring(0,1).equals("v") ){
- String detail = " Bad Version (format) passed to getVerNumFromVerString: [" + versionString + "].";
- throw new AAIException("AAI_6121", detail);
- }
- else {
- String intPart = versionString.substring(1,strLen);
- try {
- versionInt = Integer.parseInt( intPart );
- }
- catch( Exception e ){
- String detail = " Bad Version passed to getVerNumFromVerString: [" + versionString + "].";
- throw new AAIException("AAI_6121", detail);
- }
- }
- return versionInt;
- }
-
-
- /**
- * Gets the node key prop names.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param apiVersion the api version
- * @return HashMap of keyProperties
- * @throws AAIException the AAI exception
- */
- public static Collection <String> getNodeKeyPropNames( String transId, String fromAppId, String nodeType, String apiVersion ) throws AAIException{
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- Collection <String> keyProps = new ArrayList <String>();
- if( dbMaps.NodeKeyProps.containsKey(nodeType) ){
- keyProps = dbMaps.NodeKeyProps.get(nodeType);
- }
- else if( DbEdgeRules.NodeTypeCategory.containsKey(nodeType) ){
- // The passed-in nodeType was really a nodeCategory, so we need to look up the key params
- Collection <String> nTypeCatCol = DbEdgeRules.NodeTypeCategory.get(nodeType);
- Iterator <String> catItr = nTypeCatCol.iterator();
- String catInfo = "";
- if( catItr.hasNext() ){
- // For now, we only look for one.
- catInfo = catItr.next();
- }
- else {
- String defVer = AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP);
- throw new AAIException("AAI_6105", "Required Property name(s) not found for nodeType = " + nodeType+ " (ver=" + defVer + ")");
- }
-
- String [] flds = catInfo.split(",");
- if( flds.length != 4 ){
- throw new AAIException("AAI_6121", "Bad EdgeRule.NodeTypeCategory data for nodeType = [" + nodeType + "].");
- }
-
- String keyPropsString = flds[0];
- String [] propNames = keyPropsString.split("\\|");
- for( int i = 0; i < propNames.length; i++ ){
- keyProps.add(propNames[i]);
- }
- }
- else {
- String defVer = AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP);
- throw new AAIException("AAI_6105", "Required Property name(s) not found for nodeType = " + nodeType+ " (ver=" + defVer + ")");
- }
-
- return keyProps;
-
- }// end of getNodeKeyPropNames
-
- /**
- * Gets the node key prop names.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @return the node key prop names
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static Collection <String> getNodeKeyPropNames( String transId, String fromAppId, String nodeType ) throws AAIException{
- return getNodeKeyPropNames( transId, fromAppId, nodeType, null);
- }
-
- /**
- * Gets the node alt key 1 prop names.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param apiVersion the api version
- * @return HashMap of keyProperties
- * @throws AAIException the AAI exception
- */
- public static Collection <String> getNodeAltKey1PropNames( String transId, String fromAppId, String nodeType, String apiVersion ) throws AAIException{
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- Collection <String> altKey1Props = new ArrayList <String>();
- if( dbMaps.NodeAltKey1Props.containsKey(nodeType) ){
- altKey1Props = dbMaps.NodeAltKey1Props.get(nodeType);
- }
- else if( DbEdgeRules.NodeTypeCategory.containsKey(nodeType) ){
- // The passed-in nodeType was really a nodeCategory, so we need to look up the key params
- Collection <String> nTypeCatCol = DbEdgeRules.NodeTypeCategory.get(nodeType);
- Iterator <String> catItr = nTypeCatCol.iterator();
- String catInfo = "";
- if( catItr.hasNext() ){
- catInfo = catItr.next();
- String [] flds = catInfo.split(",");
- if( flds.length != 4 ){
- throw new AAIException("AAI_6121", "Bad EdgeRule.NodeTypeCategory data (itemCount=" + flds.length + ") for nodeType = [" + nodeType + "].");
- }
-
- String altKeyPropsString = flds[1];
- String [] propNames = altKeyPropsString.split("\\|");
- for( int i = 0; i < propNames.length; i++ ){
- altKey1Props.add(propNames[i]);
- }
- }
- }
-
- return altKey1Props;
-
- }// end of getNodeAltKey1PropNames
-
- /**
- * Gets the node alt key 1 prop names.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @return the node alt key 1 prop names
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static Collection <String> getNodeAltKey1PropNames( String transId, String fromAppId, String nodeType ) throws AAIException{
- return getNodeAltKey1PropNames( transId, fromAppId, nodeType, null);
- }
-
-
- /**
- * Gets the unique node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param keyPropsHash the key props hash
- * @param depNodeVal the dep node val
- * @param apiVersion the api version
- * @return TitanVertex
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanVertex getUniqueNode( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> keyPropsHash, TitanVertex depNodeVal, String apiVersion ) throws AAIException{
-
- // NOTE - this is really for use by the PersistNode method -- it is looking to see if
- // a node exists in the database given either Primary or Alternate Key data and dependent
- // node data (if required for uniqueness).
-
- // Note - the passed in nodeType could really be a nodeTypeCategory ---
- Boolean nodeTypeIsCategory = DbEdgeRules.NodeTypeCategory.containsKey(nodeType);
-
- Boolean useDepNode = false;
- if( needsADepNode4Uniqueness(transId, fromAppId, nodeType, apiVersion) ){
- // This kind of node depends on another node for uniqueness
- if( depNodeVal == null ){
- // They should have passed in the node that this one depends on
- throw new AAIException("AAI_6109", "null dependentNode object passed to getUniqueNode() but " + nodeType + " requires one.");
- }
- else if( ! nodeTypeACanDependOnB(transId, fromAppId, nodeType, depNodeVal.<String>property("aai-node-type").orElse(null), apiVersion) ){
- // They should have passed in the right type of node as the dependent node
- throw new AAIException("AAI_6109", "dependentNode of type " + depNodeVal.<String>property("aai-node-type").orElse(null) + " passed to getUniqueNode() for nodeType" + nodeType + ".\n");
- }
- useDepNode = true;
- }
- else {
- depNodeVal = null;
- }
-
- // We assume that all NodeTypes have at least one key-property defined. A dependentNode is optional.
- // Note - instead of key-properties (the primary key properties), a user could pass
- // alternate-key values if they are defined for the nodeType.
- ArrayList<String> kName = new ArrayList<String>();
- ArrayList<Object> kVal = new ArrayList<Object>();
-
- Collection <String> keyProps = getNodeKeyPropNames(transId, fromAppId, nodeType, apiVersion);
- Iterator <String> keyPropI = keyProps.iterator();
- Boolean haveSomePrimKeyProps = false;
- Boolean primaryKeyComplete = true;
- while( keyPropI.hasNext() ){
- haveSomePrimKeyProps = true;
-
- String propName = keyPropI.next();
- if( ! keyPropsHash.containsKey(propName) ){
- primaryKeyComplete = false;
- }
- else {
- Object valObj = keyPropsHash.get(propName);
- if( valObj == null ){
- primaryKeyComplete = false;
- }
- else {
- String value = valObj.toString();
- if( value == null || value.equals("") ){
- // They passed the property name, but no value
- primaryKeyComplete = false;
- }
- }
- }
- }
-
- int i = -1;
- if( haveSomePrimKeyProps && primaryKeyComplete ){
- keyPropI = keyProps.iterator();
- while( keyPropI.hasNext() ){
- String propName = keyPropI.next();
- String value = (keyPropsHash.get(propName)).toString();
- i++;
- kName.add(i, propName);
- kVal.add(i, (Object)value);
- }
- }
- else {
- // See if they're using the alternate key
- Collection <String> altKey1Props = getNodeAltKey1PropNames(transId, fromAppId, nodeType, apiVersion);
- Iterator <String> altKey1PropI = altKey1Props.iterator();
- Boolean haveSomeAltKey1Props = false;
- Boolean altKey1Complete = true;
- while( altKey1PropI.hasNext() ){
- haveSomeAltKey1Props = true;
- String propName = altKey1PropI.next();
- if( ! keyPropsHash.containsKey(propName) ){
- altKey1Complete = false;
- }
- else {
- Object valObj = keyPropsHash.get(propName);
- if( valObj == null ){
- altKey1Complete = false;
- }
- else {
- String value = valObj.toString();
- if( value == null || value.equals("") ){
- // They passed the property name, but no value
- altKey1Complete = false;
- }
- }
- }
- }
- if( haveSomeAltKey1Props && altKey1Complete ){
- altKey1PropI = altKey1Props.iterator();
- while( altKey1PropI.hasNext() ){
- String propName = altKey1PropI.next();
- String value = (keyPropsHash.get(propName)).toString();
- i++;
- kName.add(i, propName);
- kVal.add(i, (Object)value);
- }
- }
- }
-
- int topPropIndex = i;
- TitanVertex tiV = null;
- String propsAndValuesForMsg = "";
- if( !useDepNode ){
- // There is no node that this type of node depends on, so we can look for it based
- // solely on the Aai-defined key fields.
- Iterable <?> verts = null;
-
- if( topPropIndex == -1 ){
- // Problem if no key Properties defined for this nodeType
- String defVer = AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP);
- throw new AAIException("AAI_6105", "Bad or Incomplete Key Property params: (" + keyPropsHash.toString() +
- ") for nodeType: " + nodeType + " (ver=" + defVer + ")");
- }
- else if( topPropIndex == 0 ){
- if (nodeTypeIsCategory) // dont know real type
- verts= graph.query().has(kName.get(0),kVal.get(0)).vertices();
- else // need this to find dvs switch: dvs.switch-name and port-group.switch-name issue
- verts= graph.query().has(kName.get(0),kVal.get(0)).has("aai-node-type",nodeType).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ") ";
- }
- else if( topPropIndex == 1 ){
- verts = graph.query().has(kName.get(0),kVal.get(0)).has(kName.get(1),kVal.get(1)).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ", "
- + kName.get(1) + " = " + kVal.get(1) + ") ";
- }
- else if( topPropIndex == 2 ){
- verts= graph.query().has(kName.get(0),kVal.get(0)).has(kName.get(1),kVal.get(1)).has(kName.get(2),kVal.get(2)).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ", "
- + kName.get(1) + " = " + kVal.get(1) + ", "
- + kName.get(2) + " = " + kVal.get(2) + ") ";
- }
- else if( topPropIndex == 3 ){
- verts= graph.query().has(kName.get(0),kVal.get(0)).has(kName.get(1),kVal.get(1)).has(kName.get(2),kVal.get(2)).has(kName.get(3),kVal.get(3)).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ", "
- + kName.get(1) + " = " + kVal.get(1) + ", "
- + kName.get(2) + " = " + kVal.get(2) + ", "
- + kName.get(3) + " = " + kVal.get(3) + ") ";
- }
- else {
- String emsg = " We only support 4 keys per nodeType for now \n";
- throw new AAIException("AAI_6114", emsg);
- }
-
- Iterator <?> vertI = verts.iterator();
- if( vertI != null && vertI.hasNext()) {
- // We found a vertex that meets the input criteria.
- tiV = (TitanVertex) vertI.next();
-
- if( vertI.hasNext() ){
- // Since this routine is looking for a unique node for the given input values, if
- // more than one is found - it's a problem.
- throw new AAIException("AAI_6112", "More than one Node found by getUniqueNode for params: " + propsAndValuesForMsg);
- }
- }
- else {
- // No Vertex was found for this key - throw a not-found exception
- throw new AAIException("AAI_6114", "No Node of type " + nodeType + " found for properties: " + propsAndValuesForMsg);
- }
- }
- else {
- // Need to use the dependent vertex to look for this one.
- // filter this to the actual keys because
- HashMap<String,Object> onlyKeysHash = new HashMap<String,Object>();
-
- Collection <String> onlyKeyProps = getNodeKeyPropNames(transId, fromAppId, nodeType, apiVersion);
-
- Iterator <String> onlyKeyPropsI = onlyKeyProps.iterator();
-
- while( onlyKeyPropsI.hasNext() ){
- String keyName = onlyKeyPropsI.next();
- onlyKeysHash.put(keyName, keyPropsHash.get(keyName));
- }
-
- propsAndValuesForMsg = onlyKeysHash.toString() + " combined with a Dependent [" + depNodeVal.<String>property("aai-node-type").orElse(null) + "] node.";
- ArrayList<TitanVertex> resultList = DbMeth.getConnectedNodes(transId, fromAppId, graph, nodeType, onlyKeysHash,
- depNodeVal, apiVersion, false);
- if( resultList.size() > 1 ){
- // More than one vertex found when we thought there should only be one.
- throw new AAIException("AAI_6112", "More than one Node found by getUniqueNode for params: " + propsAndValuesForMsg);
- }
- else if( resultList.size() == 1 ){
- tiV = resultList.get(0);
- }
- }
-
- if( tiV == null ){
- // No Vertex was found for this key - throw a not-found exception
- throw new AAIException("AAI_6114", "No Node of type " + nodeType + " found for properties: " + propsAndValuesForMsg);
- }
- else {
- if( !DbEdgeRules.NodeTypeCategory.containsKey(nodeType) ){
- // The nodeType passed in was a real one, not a nodeTypeCategory, so we will
- // use it as part of the query to make sure we find the right type of node.
- // This can be an issue if they're using nodeTypes covered by a nodeTypeCategory but
- // pass in the wrong nodeType. We don't want them to ask for one thing and get the other.
- String foundNodeType = tiV.<String>property("aai-node-type").orElse(null);
- if( foundNodeType != null && !foundNodeType.equals(nodeType) ){
- throw new AAIException("AAI_6114", "No Node of type " + nodeType + " found for properties: " + propsAndValuesForMsg + " (did find a " + foundNodeType + " though.)");
- }
- }
-
- return tiV;
- }
-
- }// End of getUniqueNode()
-
- /**
- * Gets the unique node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param keyPropsHash the key props hash
- * @param depNodeVal the dep node val
- * @return the unique node
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanVertex getUniqueNode( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> keyPropsHash, TitanVertex depNodeVal) throws AAIException {
- return getUniqueNode( transId, fromAppId, graph, nodeType,
- keyPropsHash, depNodeVal, null );
- }
- // End getUniqueNode()
-
-
- /**
- * Gets the unique node with dep params.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param nodePropsHash the node props hash
- * @param apiVersion the api version
- * @return TitanVertex
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanVertex getUniqueNodeWithDepParams( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> nodePropsHash, String apiVersion )
- throws AAIException{
- /*
- * This method uses the nodePropsHash to walk back over dependent nodes until it finds one that
- * does not depend on any other for uniqueness. It uses the getUniqueNode() method as it finds
- * dependent nodes. NOTE -- it is passed a hash of all the nodeProperties -- for itself and
- * for any dependent nodes that it will need to find. There are some types of nodes that can
- * depend on more than one node, we assume that there wouldn't be a case where BOTH types of
- * dependent nodes are in the trail that we need to traverse. Ie. an ipaddress can depend on
- * either a vserver or pserver. NOTE this case can now happen -- nodePropsHash
- * should now be sent as a LinkedHashMap in this case so we can search in order.
- */
-
- // NOTE ALSO -- We're currently supporting 6 layers of dependency. We never thought there would be this
- // many layers before hitting a node-type that would be uniquely identifiable on it's own. So the
- // code is a little ugly with all these nested if-then-else's. Since we're supporting so many
- // layers, it should be re-written so we can support "n" layers instead of having to go in hear
- // and adding code... But as of 15-07, we really don't NEED more than 5.
-
- // NOTE: The passed in nodeType could really be a nodeTypeCategory --
- // The calls to figureDepNodeTypeForRequest() below will deal with it for the dep nodes, the
- // call to getUniqueNode() takes care of it for the node itself.
-
- TitanVertex nullVert = null;
- String depNodeType = figureDepNodeTypeForRequest( transId, fromAppId, nodeType, nodePropsHash, apiVersion );
- if( depNodeType.equals("")){
- // This kind of node does not depend on another node for uniqueness, so
- // we can just use the "getUniqueNode()" method to get it.
- HashMap <String,Object> thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, nodeType, nodePropsHash, apiVersion);
- return( getUniqueNode(transId, fromAppId, graph, nodeType, thisNodeTypeParamHash, nullVert, apiVersion) );
- }
- else {
- // Will need to find the second-layer dependent node
- String secondLayerDepNodeType = figureDepNodeTypeForRequest( transId, fromAppId, depNodeType, nodePropsHash, apiVersion );
- if( secondLayerDepNodeType.equals("")){
- // This second-layer kind of node does not depend on another node for uniqueness.
- // So once we find the second-layer node, we can use it to get the top-layer guy.
- HashMap <String,Object> thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, depNodeType, nodePropsHash, apiVersion);
- TitanVertex secLayerDepVert = getUniqueNode(transId, fromAppId, graph, depNodeType, thisNodeTypeParamHash, nullVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, nodeType, nodePropsHash, apiVersion);
- return( getUniqueNode(transId, fromAppId, graph, nodeType, thisNodeTypeParamHash, secLayerDepVert, apiVersion) );
- }
- else {
- // Will need to find the third-layer dependent node
- /// String thirdLayerDepNodeType = dbMaps.NodeDependencies.get(secondLayerDepNodeType);
- String thirdLayerDepNodeType = figureDepNodeTypeForRequest( transId, fromAppId, secondLayerDepNodeType, nodePropsHash, apiVersion );
-
- if( thirdLayerDepNodeType.equals("")){
- // This third-layer kind of node does not depend on another node for uniqueness.
- // So we can find it, and then use it to find the second-layer and then use that to find the top guy.
- HashMap <String,Object> thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, secondLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex thirdLayerDepVert = getUniqueNode(transId, fromAppId, graph, secondLayerDepNodeType, thisNodeTypeParamHash, nullVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, depNodeType, nodePropsHash, apiVersion);
- TitanVertex secLayerDepVert = getUniqueNode(transId, fromAppId, graph, depNodeType, thisNodeTypeParamHash, thirdLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, nodeType, nodePropsHash, apiVersion);
-
- return( getUniqueNode(transId, fromAppId, graph, nodeType, thisNodeTypeParamHash, secLayerDepVert, apiVersion) );
- }
- else {
- // Will need to find the third-layer dependent node
- String forthLayerDepNodeType = figureDepNodeTypeForRequest( transId, fromAppId, thirdLayerDepNodeType, nodePropsHash, apiVersion );
- if( forthLayerDepNodeType == null || forthLayerDepNodeType.equals("")){
- // This forth-layer kind of node does not depend on another node for uniqueness.
- // So we can find it, and then use it to find the third, then second-layer and then use that to find the top guy.
- HashMap <String,Object> thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, thirdLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex forthLayerDepVert = getUniqueNode(transId, fromAppId, graph, thirdLayerDepNodeType, thisNodeTypeParamHash, nullVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, secondLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex thirdLayerDepVert = getUniqueNode(transId, fromAppId, graph, secondLayerDepNodeType, thisNodeTypeParamHash, forthLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, depNodeType, nodePropsHash, apiVersion);
- TitanVertex secLayerDepVert = getUniqueNode(transId, fromAppId, graph, depNodeType, thisNodeTypeParamHash, thirdLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, nodeType, nodePropsHash, apiVersion);
- return( getUniqueNode(transId, fromAppId, graph, nodeType, thisNodeTypeParamHash, secLayerDepVert, apiVersion) );
- }
- else {
- // Will need to find the forth-layer dependent node
- String fifthLayerDepNodeType = figureDepNodeTypeForRequest( transId, fromAppId, forthLayerDepNodeType, nodePropsHash, apiVersion );
- if( fifthLayerDepNodeType == null || fifthLayerDepNodeType.equals("")){
- // This fifth-layer kind of node does not depend on another node for uniqueness.
- // So we can find it, and then use it to find the forth, third, then second-layer and then use that to find the top guy.
- HashMap <String,Object> thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, forthLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex fifthLayerDepVert = getUniqueNode(transId, fromAppId, graph, forthLayerDepNodeType, thisNodeTypeParamHash, nullVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, thirdLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex forthLayerDepVert = getUniqueNode(transId, fromAppId, graph, thirdLayerDepNodeType, thisNodeTypeParamHash, fifthLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, secondLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex thirdLayerDepVert = getUniqueNode(transId, fromAppId, graph, secondLayerDepNodeType, thisNodeTypeParamHash, forthLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, depNodeType, nodePropsHash, apiVersion);
- TitanVertex secLayerDepVert = getUniqueNode(transId, fromAppId, graph, depNodeType, thisNodeTypeParamHash, thirdLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, nodeType, nodePropsHash, apiVersion);
- return( getUniqueNode(transId, fromAppId, graph, nodeType, thisNodeTypeParamHash, secLayerDepVert, apiVersion) );
- }
- else {
- // Will need to find the fifth-layer dependent node
- String sixthLayerDepNodeType = figureDepNodeTypeForRequest( transId, fromAppId, fifthLayerDepNodeType, nodePropsHash, apiVersion );
- if( sixthLayerDepNodeType == null || sixthLayerDepNodeType.equals("")){
- // This six-layer kind of node does not depend on another node for uniqueness.
- // So we can find it, and then use it to find the fifth, forth, third, then second-layer and then use that to find the top guy.
- HashMap <String,Object> thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, fifthLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex sixthLayerDepVert = getUniqueNode(transId, fromAppId, graph, fifthLayerDepNodeType, thisNodeTypeParamHash, nullVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, forthLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex fifthLayerDepVert = getUniqueNode(transId, fromAppId, graph, forthLayerDepNodeType, thisNodeTypeParamHash, sixthLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, thirdLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex forthLayerDepVert = getUniqueNode(transId, fromAppId, graph, thirdLayerDepNodeType, thisNodeTypeParamHash, fifthLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, secondLayerDepNodeType, nodePropsHash, apiVersion);
- TitanVertex thirdLayerDepVert = getUniqueNode(transId, fromAppId, graph, secondLayerDepNodeType, thisNodeTypeParamHash, forthLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, depNodeType, nodePropsHash, apiVersion);
- TitanVertex secLayerDepVert = getUniqueNode(transId, fromAppId, graph, depNodeType, thisNodeTypeParamHash, thirdLayerDepVert, apiVersion);
-
- thisNodeTypeParamHash = getThisNodeTypeParams(transId, fromAppId, nodeType, nodePropsHash, apiVersion);
- return( getUniqueNode(transId, fromAppId, graph, nodeType, thisNodeTypeParamHash, secLayerDepVert, apiVersion) );
- }
- else {
- // We don't currently support more layers. We can later if we need to.
- // Hopefully, we'll never need to go this deep -- there should be unique keys in there somewhere!
- throw new AAIException("AAI_6114", "CODE-LIMITATION - Can't resolve dependant node layers for nodeType = " + nodeType);
- }
- }
- }
- }
- }
- }
- } // End getUniqueNodeWithDepParams()
-
- /**
- * Gets the unique node with dep params.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param nodePropsHash the node props hash
- * @return the unique node with dep params
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanVertex getUniqueNodeWithDepParams( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> nodePropsHash ) throws AAIException {
- return getUniqueNodeWithDepParams(transId, fromAppId, graph, nodeType, nodePropsHash, null);
- }
-
-
- /**
- * Gets the this node type params.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param targetNodeType the target node type
- * @param passedHash the passed hash
- * @param apiVersion the api version
- * @return the this node type params
- * @throws AAIException the AAI exception
- */
- private static HashMap <String, Object> getThisNodeTypeParams(String transId, String fromAppId, String targetNodeType,
- HashMap<String,Object> passedHash, String apiVersion )throws AAIException{
- /*
- * For the passed-in hash, each key is assumed to look like, "nodeType.paramName". We want to
- * pick out the entries that match the targetNodeType and return those with the values they go with. The
- * returned keys will have the "nodeType." stripped off.
- *
- * NOTE - the nodeType passed to this method could actually be a nodeTypeCategory. Just keepin it ugly.
- */
-
- if( passedHash == null ){
- throw new AAIException("AAI_6120", "Bad param: null passedHash ");
- }
-
- String targetNodeTypeCat = "";
- if( DbEdgeRules.NodeTypeCatMap.containsKey(targetNodeType) ){
- targetNodeTypeCat = DbEdgeRules.NodeTypeCatMap.get(targetNodeType);
- }
-
- HashMap <String,Object> returnHash = new HashMap <String,Object> ();
- Iterator <Map.Entry<String,Object>>it = passedHash.entrySet().iterator();
- while( it.hasNext() ){
- Map.Entry <String,Object>pairs = (Map.Entry<String,Object>)it.next();
- String k = (pairs.getKey()).toString();
- int periodLoc = k.indexOf(".");
- if( periodLoc <= 0 ){
- throw new AAIException("AAI_6120", "Bad filter param key passed in: [" + k + "]. Expected format = [nodeName.paramName]\n");
- }
- else {
- String nty = k.substring(0,periodLoc);
- String paramName = k.substring(periodLoc + 1);
- if( nty.equals(targetNodeType) || (!targetNodeTypeCat.equals("") && nty.equals(targetNodeTypeCat)) ){
- String newK = paramName;
- returnHash.put( newK,pairs.getValue() );
- }
- }
- }
-
- //aaiLogger.debug(logline, " - end ");
- return returnHash;
-
- }// End of getThisNodeTypeParams()
-
- /**
- * Gets the this node type params.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param targetNodeType the target node type
- * @param passedHash the passed hash
- * @return the this node type params
- * @throws AAIException the AAI exception
- */
- @Deprecated
- private static HashMap <String, Object> getThisNodeTypeParams(String transId, String fromAppId, String targetNodeType,
- HashMap<String,Object> passedHash )throws AAIException{
- return getThisNodeTypeParams( transId, fromAppId, targetNodeType,
- passedHash, null);
-
- }
-
- /**
- * Gets the dep node types.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param apiVersion the api version
- * @return the dep node types
- * @throws AAIException the AAI exception
- */
- public static ArrayList <String> getDepNodeTypes(String transId, String fromAppId, String nodeType, String apiVersion)throws AAIException{
- /*
- * This returns any nodeTypes that this nodeType can be dependent on. A particular instance of a node will only
- * depend on one other node - we don't currently support dependence on multiple nodes.
- */
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- ArrayList <String> depNodeTypeL = new ArrayList <String> ();
- if( !DbEdgeRules.NodeTypeCategory.containsKey(nodeType) ){
- // This is a good-ole nodeType
- Collection <String> depNTColl = dbMaps.NodeDependencies.get(nodeType);
- Iterator <String> ntItr = depNTColl.iterator();
- while( ntItr.hasNext() ){
- depNodeTypeL.add(ntItr.next());
- }
- }
- else {
- // The passed-in nodeType must really be a nodeTypeCategory
- Collection <String> nTypeCatCol = DbEdgeRules.NodeTypeCategory.get(nodeType);
- Iterator <String> catItr = nTypeCatCol.iterator();
- String catInfo = "";
- if( catItr.hasNext() ){
- // For now, we only look for one.
- catInfo = catItr.next();
- }
- else {
- throw new AAIException("AAI_6121", "Error getting DbEdgeRules.NodeTypeCategory info for nodeTypeCat = " + nodeType);
- }
-
- String [] flds = catInfo.split(",");
- if( flds.length != 4 ){
- throw new AAIException("AAI_6121", "Bad EdgeRule.NodeTypeCategory data (itemCount=" + flds.length + ") for nodeType = [" + nodeType + "].");
- }
-
- String nodeTypesString = flds[0];
- String hasDepNodes = flds[3];
- if( hasDepNodes.equals("true") ){
- String [] ntNames = nodeTypesString.split("\\|");
- for( int i = 0; i < ntNames.length; i++ ){
- Collection <String> depNTColl = dbMaps.NodeDependencies.get(nodeType);
- Iterator <String> ntItr = depNTColl.iterator();
- while( ntItr.hasNext() ){
- String depNode = ntItr.next();
- if( !depNodeTypeL.contains(depNode) ){
- depNodeTypeL.add(depNode);
- }
- }
- }
- }
- }
-
-
- return depNodeTypeL;
-
- }// End getDepNodeTypes()
-
- /**
- * Gets the dep node types.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @return the dep node types
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static ArrayList <String> getDepNodeTypes(String transId, String fromAppId, String nodeType)throws AAIException{
- return getDepNodeTypes( transId, fromAppId, nodeType, null);
- }
-
- /**
- * Gets the default delete scope.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param apiVersion the api version
- * @return the default delete scope
- * @throws AAIException the AAI exception
- */
- private static String getDefaultDeleteScope(String transId, String fromAppId, String nodeType, String apiVersion)throws AAIException{
-
- // At some point we may have different delete rules for different services, so this is
- // a list for now even thought there's only one scope per nodeType.
- Collection <String> scopeList = DbEdgeRules.DefaultDeleteScope.get(nodeType);
- if( scopeList.isEmpty() ){
- throw new AAIException("AAI_6121", "No default deleteScope found for nodeType = [" + nodeType + "] ");
- }
- else {
- Iterator <String> ito = scopeList.iterator();
- return ito.next();
- }
-
- }// End getDefaultDeleteScope()
-
- /**
- * Gets the default delete scope.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @return the default delete scope
- * @throws AAIException the AAI exception
- */
- @Deprecated
- private static String getDefaultDeleteScope(String transId, String fromAppId, String nodeType)throws AAIException{
- return getDefaultDeleteScope( transId, fromAppId, nodeType, null);
- }
-
- /**
- * Needs A dep node 4 uniqueness.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param apiVersion the api version
- * @return the boolean
- * @throws AAIException the AAI exception
- */
- public static Boolean needsADepNode4Uniqueness(String transId, String fromAppId, String nodeType, String apiVersion)throws AAIException{
- // Note: the passed in nodeType could really be a nodeTypeCategory. That is handled by getDepNodeTypes()
-
- ArrayList <String> depList = getDepNodeTypes(transId, fromAppId, nodeType, apiVersion);
- if( depList.isEmpty() ){
- return false;
- }
- else {
- return true;
- }
-
- }// End needsADepNode4Uniqueness()
-
- /**
- * Needs A dep node 4 uniqueness.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @return the boolean
- * @throws AAIException the AAI exception
- */
- @Deprecated
- private static Boolean needsADepNode4Uniqueness(String transId, String fromAppId, String nodeType)throws AAIException{
- return needsADepNode4Uniqueness( transId, fromAppId, nodeType, null);
- }
-
- /**
- * Node type A can depend on B.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeTypeA the node type A
- * @param nodeTypeB the node type B
- * @param apiVersion the api version
- * @return the boolean
- * @throws AAIException the AAI exception
- */
- public static Boolean nodeTypeACanDependOnB(String transId, String fromAppId, String nodeTypeA, String nodeTypeB, String apiVersion)
- throws AAIException{
- // Note: the passed in nodeType could really be a nodeTypeCategory. That is handled by getDepNodeTypes()
-
- ArrayList <String> depList = getDepNodeTypes(transId, fromAppId, nodeTypeA, apiVersion);
- if( depList.isEmpty() ){
- return false;
- }
- else if( depList.contains(nodeTypeB) ){
- return true;
- }
- else {
- return false;
- }
-
- }// End nodeTypeACanDependOnB()
-
- /**
- * Node type A can depend on B.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeTypeA the node type A
- * @param nodeTypeB the node type B
- * @return the boolean
- * @throws AAIException the AAI exception
- */
- @Deprecated
- private static Boolean nodeTypeACanDependOnB(String transId, String fromAppId, String nodeTypeA, String nodeTypeB)
- throws AAIException{
- return nodeTypeACanDependOnB( transId, fromAppId, nodeTypeA, nodeTypeB, null);
- }
-
- /**
- * Figure dep node type for request.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param requestParamHash the request param hash
- * @param apiVersion the api version
- * @return the string
- * @throws AAIException the AAI exception
- */
- public static String figureDepNodeTypeForRequest(String transId, String fromAppId, String nodeType,
- HashMap<String,Object> requestParamHash, String apiVersion )throws AAIException{
- /*
- * This is ugly. But if the passed-in nodeType is dependent on another nodeType for
- * uniqueness, we need to return what that dependent node-type is. The ugly comes in
- * because a node can be dependent on more than one type of node. So, to tell which one
- * is going to apply, we root through the passed request parameters to see which of
- * the possible dependent node types is being used.
- * Note -- if there comes a day when there are so many dependencies that the request could
- * have more than one that match -- Then we need to think up something new. But for now,
- * we have to assume that if there are more than one legal dep-node-types, only one will
- * be represented in the requestHash data. >>> NOTE >>> That day has come. For
- * the upstreamers will send in a LinkedHashMap instead of just an unordered
- * HashMap so we can look in order for the dependent node.
- *
- */
-
- if( requestParamHash == null ){
- throw new AAIException("AAI_6120", "Bad param: null requestParamHash ");
- }
-
- ArrayList <String> depNodeTypes = getDepNodeTypes(transId, fromAppId, nodeType, apiVersion);
- if( depNodeTypes.isEmpty() ){
- // This kind of node is not dependent on any other
- //aaiLogger.debug(logline, " (not dependent) - end ");
- return "";
- }
- else if( depNodeTypes.size() == 1 ){
- // This kind of node can only depend on one other nodeType - so return that.
- //aaiLogger.debug(logline, " (depends on " + depNodeTypes.get(0) + " - end ");
- return depNodeTypes.get(0);
- }
- else {
- // We need to look to find the first of the dep-node types that is represented in the passed-in
- // request data. That will be the one we need to use.
-
- // first find out what node-types are represented in the requestHash
-
- Iterator <Map.Entry<String,Object>>it = requestParamHash.entrySet().iterator();
- while( it.hasNext() ){
- Map.Entry <String,Object>pairs = (Map.Entry<String,Object>)it.next();
- String k = (pairs.getKey()).toString();
- int periodLoc = k.indexOf(".");
- if( periodLoc <= 0 ){
- throw new AAIException("AAI_6120", "Bad filter param key passed in: [" + k + "]. Expected format = [nodeName.paramName]\n");
- }
- else {
- String nty = k.substring(0,periodLoc);
- if( depNodeTypes.contains(nty) ){
- // This is the first possible dep. node type we've found for the passed in data set
- return nty;
- }
- }
- }
-
- }
-
- // It's not an error if none is found - the caller needs to deal with cases where there
- // should be a dep. node identified but isn't.
- //aaiLogger.debug(logline, " no dep NT found - end ");
- return "";
-
- }// End of figureDepNodeTypeForRequest()
-
- /**
- * Figure dep node type for request.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param requestParamHash the request param hash
- * @return the string
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static String figureDepNodeTypeForRequest(String transId, String fromAppId, String nodeType,
- HashMap<String,Object> requestParamHash )throws AAIException{
- return figureDepNodeTypeForRequest( transId, fromAppId, nodeType, requestParamHash, null);
- }
-
- /**
- * Detach connected nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param startNodeVal the start node val
- * @param autoDeleteOrphans the auto delete orphans
- * @param apiVersion the api version
- * @return deletedNodeCount
- * @throws AAIException the AAI exception
- */
- public static int detachConnectedNodes( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, TitanVertex startNodeVal, boolean autoDeleteOrphans, String apiVersion ) throws AAIException{
-
- /* Find nodes that are attached to this node which meet the nodeType/filterParams criteria.
- * Remove the edges that go to those nodes.
- * If that turns any of the nodes into an orphan, then delete it if the autoDeleteOrphans flag is set.
- * Return a count of how many nodes were actually deleted (not just detached).
- */
-
- int deletedCount = 0;
-
- if( startNodeVal == null ){
- // They should have passed in the node that this query starts from
- throw new AAIException("AAI_6109", "null startNode object passed to detachConnectedNodes().");
- }
-
- // We want to loop through the connected Nodes that we found.
- // For each connected Node, we'll get the all edges that start from that node and look for the one
- // that connects back to our startNode.
- // Only delete the edge that connects back to our startNode.
- // then autoDeleteOrphans flag is set, then delete the connectedNode if it's now orphaned.
- //
-
- String startNodeVId = startNodeVal.id().toString();
- ArrayList<TitanVertex> conNodeList = getConnectedNodes( transId, fromAppId, graph, nodeType, propFilterHash, startNodeVal, apiVersion, false );
- Iterator<TitanVertex> conVIter = conNodeList.iterator();
- while( conVIter.hasNext() ){
- TitanVertex connectedVert = conVIter.next();
- boolean isFirstOne = true;
- Iterator<Edge> eI = connectedVert.edges(Direction.BOTH);
- while( eI.hasNext() ){
- TitanEdge ed = (TitanEdge) eI.next();
- TitanVertex otherVtx = (TitanVertex) ed.otherVertex(connectedVert);
- String otherSideLookingBackVId = otherVtx.id().toString();
- if( startNodeVId.equals(otherSideLookingBackVId) ){
- // This is an edge from the connected node back to our starting node
- if( isFirstOne && !eI.hasNext() && autoDeleteOrphans ){
- // This was the one and only edge for this connectedNode, so
- // delete the node and edge since flag was set
- String resVers = connectedVert.<String>property("resource-version").orElse(null);
- removeAaiNode( transId, fromAppId, graph, connectedVert, "USE_DEFAULT", apiVersion, resVers);
- deletedCount = deletedCount + 1;
- }
- else {
- removeAaiEdge( transId, fromAppId, graph, ed );
- }
- }
- isFirstOne = false;
- }
- }
- return deletedCount;
-
- } // end of detachConnectedNodes()
-
-
-
- /**
- * Detach connected nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param startNodeVal the start node val
- * @param autoDeleteOrphans the auto delete orphans
- * @return the int
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static int detachConnectedNodes( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, TitanVertex startNodeVal, boolean autoDeleteOrphans ) throws AAIException{
- return detachConnectedNodes( transId, fromAppId, graph, nodeType,
- propFilterHash, startNodeVal, autoDeleteOrphans, null);
- }
-
- /**
- * Gets the nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param noFilterOnPurpose the no filter on purpose
- * @param apiVersion the api version
- * @return ArrayList<TitanVertex>
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static ArrayList<TitanVertex> getNodes( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, Boolean noFilterOnPurpose, String apiVersion ) throws AAIException{
- boolean skipGroomingFlag = true;
- // we will only do real-time grooming if a system variable is set, telling us not to skip it.
- String skipGroomingStr = AAIConstants.AAI_SKIPREALTIME_GROOMING;
- if( skipGroomingStr.equals("false") ){
- skipGroomingFlag = false;
- }
- return( getNodes(transId, fromAppId, graph, nodeType, propFilterHash, noFilterOnPurpose, apiVersion, skipGroomingFlag) );
- }
-
- /**
- * Gets the nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param noFilterOnPurpose the no filter on purpose
- * @param apiVersion the api version
- * @param skipGroomCheck the skip groom check
- * @return ArrayList<TitanVertex>
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static ArrayList<TitanVertex> getNodes( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, Boolean noFilterOnPurpose, String apiVersion, boolean skipGroomCheck )
- throws AAIException{
- // Note - the skipGroomCheck flag is set to true when the DataGrooming tool is using this method to collect
- // node data. When the grooming tool is collecting data, we don't want any nodes skipped, because we
- // want details about what nodes/edges are bad - more detail than the check in this method does
- // as it checks if a node is ok to return to a caller.
-
- /* Use the nodeType + filterParams to find nodes.
- */
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- ArrayList<TitanVertex> returnVertList = new ArrayList<TitanVertex>();
- if( nodeType == null || nodeType.equals("") ){
- // They should have passed in a nodeType
- throw new AAIException("AAI_6118", "Required field: nodeType not passed to getNodes().");
- }
-
- if( !noFilterOnPurpose && (propFilterHash == null || propFilterHash.isEmpty()) ){
- // They should have passed at least one property to filter on
- throw new AAIException("AAI_6118", "Required field: propFilterHash not passed to getNodes().");
- }
-
- ArrayList<String> kName = new ArrayList<String>();
- ArrayList<Object> kVal = new ArrayList<Object>();
- int i = -1;
- Collection <String> indexedProps = dbMaps.NodeMapIndexedProps.get(nodeType);
- // First loop through to pick up the indexed-properties if there are any being used
-
- if( propFilterHash != null ){
- Iterator <?> it = propFilterHash.entrySet().iterator();
- while( it.hasNext() ){
- Map.Entry<?,?> propEntry = (Map.Entry<?,?>) it.next();
- String propName = (propEntry.getKey()).toString();
- // Don't allow search on properties that do not have SINGLE cardinality
- if( !checkPropCardinality(propName, "Set") && !checkPropCardinality(propName, "List") ){
- if( indexedProps.contains(propName) ){
- i++;
- kName.add(i, propName);
- kVal.add(i, (Object)propEntry.getValue());
- }
- }
- }
-
- // Now go through again and pick up the non-indexed properties
- it = propFilterHash.entrySet().iterator();
- while( it.hasNext() ){
- Map.Entry <?,?> propEntry = (Map.Entry<?,?>)it.next();
- String propName = (propEntry.getKey()).toString();
- // Don't allow search on properties that do not have SINGLE cardinality
- if( !checkPropCardinality(propName, "Set") && !checkPropCardinality(propName, "List") ){
- if( ! indexedProps.contains(propName) ){
- i++;
- kName.add(i, propName);
- kVal.add(i, (Object)propEntry.getValue());
- }
- }
- }
- }
-
- Iterable <?> verts = null;
- String propsAndValuesForMsg = "";
- int topPropIndex = i;
- if( topPropIndex == -1 ){
- // No Filtering -- just go get them all
- verts= graph.query().has("aai-node-type",nodeType).vertices();
- propsAndValuesForMsg = " ( no filter props ) ";
- }
- else if( topPropIndex == 0 ){
- verts= graph.query().has(kName.get(0),kVal.get(0)).has("aai-node-type",nodeType).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ") ";
- }
- else if( topPropIndex == 1 ){
- verts= graph.query().has(kName.get(0),kVal.get(0)).has(kName.get(1),kVal.get(1)).has("aai-node-type",nodeType).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ", "
- + kName.get(1) + " = " + kVal.get(1) + ") ";
- }
- else if( topPropIndex == 2 ){
- verts= graph.query().has(kName.get(0),kVal.get(0)).has(kName.get(1),kVal.get(1)).has(kName.get(2),kVal.get(2)).has("aai-node-type",nodeType).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ", "
- + kName.get(1) + " = " + kVal.get(1) + ", "
- + kName.get(2) + " = " + kVal.get(2) + ") ";
- }
- else if( topPropIndex == 3 ){
- verts= graph.query().has(kName.get(0),kVal.get(0)).has(kName.get(1),kVal.get(1)).has(kName.get(2),kVal.get(2)).has(kName.get(3),kVal.get(3)).has("aai-node-type",nodeType).vertices();
- propsAndValuesForMsg = " (" + kName.get(0) + " = " + kVal.get(0) + ", "
- + kName.get(1) + " = " + kVal.get(1) + ", "
- + kName.get(2) + " = " + kVal.get(2) + ", "
- + kName.get(3) + " = " + kVal.get(3) + ") ";
- }
- else {
- String emsg = " -- Sorry -- we only support 4 filter properties in getNodes() for now... \n";
- throw new AAIException("AAI_6114", emsg);
- }
- if( verts != null ){
- // We did find some matching vertices
- Iterator <?> it = verts.iterator();
- while( it.hasNext() ){
- TitanVertex v = (TitanVertex)it.next();
-
- if( skipGroomCheck ){
- // Good or bad, just return everything we find
- returnVertList.add( v );
- }
- else {
- // Weed out any bad vertices we find
- if( thisVertexNotReachable(transId, fromAppId, graph, v, apiVersion) ){
- LOGGER.info("IN-LINE GROOMING - Unreachable Node DETECTED > skipping it. ");
- }
- else if( thisVertexHasBadEdges(transId, fromAppId, graph, v, apiVersion) ){
- LOGGER.info("IN-LINE GROOMING - BAD EDGE DETECTED > skipping vtxId = [" + v.id() + "] ");
- }
- else if( thisVertexIsAPhantom(transId, fromAppId, graph, v, apiVersion) ){
- LOGGER.info("IN-LINE GROOMING - BAD NODE DETECTED > skipping vtxId = [" + v.id() + "] ");
- }
- else {
- returnVertList.add( v );
- }
- }
- }
- }
-
- return returnVertList;
- }
-
- /**
- * Gets the nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param noFilterOnPurpose the no filter on purpose
- * @return the nodes
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static ArrayList<TitanVertex> getNodes( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, Boolean noFilterOnPurpose ) throws AAIException{
- return getNodes(transId, fromAppId, graph, nodeType,
- propFilterHash, noFilterOnPurpose, null );
- }
- // End of getNodes()
-
-
- /**
- * Gets the connected children.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVtx the start vtx
- * @param limitToThisNodeType the limit to this node type
- * @return ArrayList <TitanVertex>
- * @throws AAIException the AAI exception
- */
- public static ArrayList<TitanVertex> getConnectedChildren( String transId, String fromAppId, TitanTransaction graph,
- TitanVertex startVtx, String limitToThisNodeType ) throws AAIException{
-
- // Just get child nodes (ie. other end of an OUT edge that is tagged as a parent/Child edge)
-
- ArrayList <TitanVertex> childList = new ArrayList <TitanVertex> ();
- Boolean doNodeTypeCheck = false;
- if( limitToThisNodeType != null && ! limitToThisNodeType.equals("") ){
- doNodeTypeCheck = true;
- }
-
-
- List<Vertex> verts = graph.traversal().V(startVtx).union(__.outE().has("isParent-REV", true).inV(), __.inE().has("isParent", true).outV()).toList();
- TitanVertex tmpVtx = null;
- int vertsSize = verts.size();
- for (int i = 0; i < vertsSize; i++){
- tmpVtx = (TitanVertex) verts.get(i);
- if( ! doNodeTypeCheck ){
- childList.add(tmpVtx);
- }
- else {
- String tmpNT = tmpVtx.<String>property("aai-node-type").orElse(null);
- if( tmpNT != null && tmpNT.equals(limitToThisNodeType) ){
- childList.add(tmpVtx);
- }
- }
- }
-
- return childList;
-
- }// End of getConnectedChildren()
-
-
-
- /**
- * Gets the connected nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param startNodeVal the start node val
- * @param apiVersion the api version
- * @param excludeRecurComingIn the exclude recur coming in
- * @return ArrayList <TitanVertex>
- * @throws AAIException the AAI exception
- */
- public static ArrayList<TitanVertex> getConnectedNodes( String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, TitanVertex startNodeVal, String apiVersion, Boolean excludeRecurComingIn ) throws AAIException{
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
- /* Get (almost) all the nodes that are connected to this vertex.
- * Narrow down what is returned using optional filter parameters nodeType and propFilterHash
- * NOTE - the default behavior has changed slightly. For start-Nodes that
- * can be recursivly connected, this method will only bring back the same kind of
- * connected node by following an OUT edge. Ie. if the start node is an "model-element",
- * then this method will only follow OUT edges to get to other "model-element" type nodes.
- */
-
- String startNodeNT = "";
- if( startNodeVal == null ){
- // They should have passed in the node that this query starts from
- throw new AAIException("AAI_6109", "null startNode object passed to getConnectedNodes().");
- }
- else {
- startNodeNT = startNodeVal.<String>property("aai-node-type").orElse(null);
- }
-
- boolean nodeTypeFilter = false;
- if( nodeType != null && !nodeType.equals("") ){
- // They want to filter using nodeType
- if( ! dbMaps.NodeProps.containsKey(nodeType) ){
- throw new AAIException("AAI_6115", "Unrecognized nodeType [" + nodeType + "] passed to getConnectedNodes().");
- }
- nodeTypeFilter = true;
- }
-
- ArrayList <String> excludeVidList = new ArrayList <String> ();
- if( DbEdgeRules.CanBeRecursiveNT.containsKey(startNodeNT) && excludeRecurComingIn ){
- // If we're starting on a nodeType that supports recursion, then find any connected
- // nodes that are coming from IN edges so we can exclude them later.
-
- Iterable <?> vertsR = startNodeVal.query().direction(Direction.IN).vertices();
- Iterator <?> vertIR = vertsR.iterator();
- while( vertIR != null && vertIR.hasNext() ){
- TitanVertex tmpVertIN = (TitanVertex) vertIR.next();
- String tmpNT = tmpVertIN.<String>property("aai-node-type").orElse(null);
- if( tmpNT != null && tmpNT.equals(startNodeNT) ){
- // We're on a nodetype that supports recursion (like model-element) and we've
- // found an connected Node of this same type on an IN edge - put this
- // on our excludeList.
- excludeVidList.add( tmpVertIN.id().toString() );
- }
- }
- }
-
- boolean propertyFilter = false;
- if( propFilterHash != null && !propFilterHash.isEmpty() ){
- // They want to filter using some properties
- Iterator <?> it = propFilterHash.entrySet().iterator();
- while( it.hasNext() ){
- Map.Entry<?,?> propEntry = (Map.Entry<?,?>)it.next();
- String propName = (propEntry.getKey()).toString();
- if( ! dbMaps.NodeProps.containsValue(propName) ){
- throw new AAIException("AAI_6116", "Unrecognized property name [" + propName + "] passed to getConnectedNodes().");
- }
- // Don't allow search on properties that do not have SINGLE cardinality
- if( !checkPropCardinality(propName, "Set") && !checkPropCardinality(propName, "List") ){
- propertyFilter = true;
- }
- }
- }
- // If filter-properties were passed in, then look for nodes that have those values.
- ArrayList<TitanVertex> returnVertList = new ArrayList<TitanVertex>();
- Iterable<TitanVertex> qResult = null;
- Iterator<TitanVertex> resultI = null;
- try {
- qResult = startNodeVal.query().vertices();
- resultI = qResult.iterator();
- }
- catch( NullPointerException npe ){
- throw new AAIException("AAI_6125", "Titan null pointer exception trying to get nodes connected to vertexId = " +
- startNodeVal.id() + ", aai-node-type = [" + startNodeVal.property("aai-node-type") + "].");
- }
-
- while( resultI != null && resultI.hasNext() ){
- boolean addThisOne = true;
- TitanVertex tmpV = (TitanVertex)resultI.next();
- if( tmpV == null ){
- LOGGER.info("Titan gave a null vertex when looking for nodes connected to vertexId = " +
- startNodeVal.id() + ", aai-node-type = [" + startNodeVal.property("aai-node-type") + "].");
- // Note - we will skip this one, but try to return any others that we find.
- addThisOne = false;
- }
-
- else {
- String tmpVid = tmpV.id().toString();
- if( nodeTypeFilter ){
- Object nto = tmpV.<Object>property("aai-node-type").orElse(null);
- if( nto == null || !nto.toString().equals(nodeType) ){
- //LOGGER.info("Found a connected vertex (vertexId = " +
- // tmpVid + "), but we will not collect it. It had aai-node-type [" +
- // nto + "], we are looking for [" + nodeType + "]. ");
- // Note - we will skip this one, but try to return any others that we find.
- addThisOne = false;
- }
- }
-
- if( excludeVidList.contains(tmpVid) ){
- LOGGER.info("Found a connected vertex (vertexId = " +
- tmpVid + "), but will exclude it since it is on an IN edge and this nodeType " +
- startNodeNT + " can be recursively attached.");
- // Note - we will skip this one, but try to return any others that we find.
- addThisOne = false;
- }
-
- if( propertyFilter ){
- Iterator <?> it = propFilterHash.entrySet().iterator();
- while( it.hasNext() ){
- Map.Entry <?,?>propEntry = (Map.Entry<?,?>)it.next();
- String propName = (propEntry.getKey()).toString();
- if( checkPropCardinality(propName, "Set") || checkPropCardinality(propName, "List") ){
- // Don't allow search on properties that do not have SINGLE cardinality
- continue;
- }
- Object propVal = propEntry.getValue();
- Object foundVal = tmpV.<Object>property(propName).orElse(null);
- if( foundVal != null && propVal != null && !foundVal.toString().equals(propVal.toString()) ){
- addThisOne = false;
- break;
- }
- else if( (foundVal == null && propVal != null) || (foundVal != null && propVal == null) ){
- addThisOne = false;
- break;
- }
- }
- }
- }
- if( addThisOne ){
- // This node passed the tests -- put it on the return List
- returnVertList.add( (TitanVertex)tmpV );
- }
- }
- //aaiLogger.debug(logline, " end ");
- return returnVertList;
-
- }// End of getConnectedNodes()
-
-
- /**
- * Gets the connected nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param startNodeVal the start node val
- * @param apiVersion the api version
- * @return the connected nodes
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static ArrayList<TitanVertex> getConnectedNodes(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, TitanVertex startNodeVal, String apiVersion ) throws AAIException {
- return getConnectedNodes( transId, fromAppId, graph, nodeType,
- propFilterHash, startNodeVal, apiVersion, true );
- }
-
- /**
- * Gets the connected nodes.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param nodeType the node type
- * @param propFilterHash the prop filter hash
- * @param startNodeVal the start node val
- * @return the connected nodes
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static ArrayList<TitanVertex> getConnectedNodes(String transId, String fromAppId, TitanTransaction graph, String nodeType,
- HashMap<String,Object> propFilterHash, TitanVertex startNodeVal ) throws AAIException {
- return getConnectedNodes( transId, fromAppId, graph, nodeType,
- propFilterHash, startNodeVal, null, true );
-
- }
-
- /**
- * Ip address format OK.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param addrVal the addr val
- * @param addrVer the addr ver
- * @param apiVersion the api version
- * @return Boolean
- * @throws AAIException the AAI exception
- */
- public static Boolean ipAddressFormatOK(String transId, String fromAppId, String addrVal, String addrVer, String apiVersion) throws AAIException{
-
- /* NOTE -- the google methods we use do not allow leading zeros in ipV4 addresses.
- * So it will reject, "22.33.44.001"
- */
-
- if( addrVal == null ){
- throw new AAIException("AAI_6120", "Bad data (addrVal = null) passed to ipAddressFormatOK()");
- }
- else if( addrVer == null ){
- throw new AAIException("AAI_6120", "Bad data (addrType = null) passed to ipAddressFormatOK()");
- }
-
- Boolean retVal = false;
- Boolean lookingForV4 = false;
- Boolean lookingForV6 = false;
- InetAddress inetAddr = null;
-
- if( addrVer.equalsIgnoreCase("v4") || addrVer.equals("ipv4") || addrVer.equals("4")){
- lookingForV4 = true;
- }
- else if( addrVer.equalsIgnoreCase("v6") || addrVer.equals("ipv6") || addrVer.equals("6")){
- lookingForV6 = true;
- }
- else {
- throw new AAIException("AAI_6120", " Bad data for addressVersion [" + addrVer + "] passed to ipAddressFormatOK()");
- }
-
- try {
- inetAddr = InetAddresses.forString(addrVal);
- if( inetAddr instanceof Inet4Address ){
- if( lookingForV4 ){
- retVal = true;
- }
- else {
- throw new AAIException("AAI_6120", "Bad data. Address is a V4, but addressType said it should be V6. ["
- + addrVal + "], [" + addrVer + "] passed to ipAddressFormatOK()");
- }
- }
- else if( inetAddr instanceof Inet6Address ){
- if( lookingForV6 ){
- retVal = true;
- }
- else {
- throw new AAIException("AAI_6120", "Bad data. Address is a V6, but addressType said it should be V4. ["
- + addrVal + "], [" + addrVer + "] passed to ipAddressFormatOK().");
- }
- }
- }
- catch (IllegalArgumentException e) {
- throw new AAIException("AAI_6120", "Badly formed ip-address: [" + addrVal + "] passed to ipAddressFormatOK()");
- }
-
- return retVal;
-
- }//end of ipAddressFormatOk()
-
- /**
- * Ip address format OK.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param addrVal the addr val
- * @param addrVer the addr ver
- * @return the boolean
- * @throws AAIException the AAI exception
- */
- public static Boolean ipAddressFormatOK(String transId, String fromAppId, String addrVal, String addrVer) throws AAIException{
- return ipAddressFormatOK( transId, fromAppId, addrVal, addrVer, null);
- }
-
- /**
- * Save aai edge to db.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param edgeLabel the edge label
- * @param outV the out V
- * @param inV the in V
- * @param propHash the prop hash
- * @param apiVersion the api version
- * @return TitanEdge
- * @throws AAIException the AAI exception
- */
- private static TitanEdge saveAaiEdgeToDb(String transId, String fromAppId, TitanTransaction graph, String edgeLabel,
- TitanVertex outV, TitanVertex inV, HashMap <String,Object> propHash, String apiVersion) throws AAIException{
-
- // If this edge doesn't exist yet, then create it.
-
- // NOTE - the Titan javaDoc says that there might not always be an id for a node.
- // This is the internal-titan-unique-id, not any of our data.
- // Not sure how to know when it might be there and when it might not?!
- // So far, it has worked for all my testing, but this might warrant some
- // further investigation.
-
- TitanEdge existingEdge = null;
- String inVId = inV.id().toString();
- Iterator <Edge> eI = outV.edges(Direction.BOTH, edgeLabel);
- while( eI.hasNext() ){
- TitanEdge ed = (TitanEdge) eI.next();
- TitanVertex otherVtx = (TitanVertex) ed.otherVertex(outV);
- if( (otherVtx.id().toString()).equals(inVId) ){
- // NOTE -?- Not sure -- at some point we might want to check the edgeLabels also since we might
- // want to allow two different-type edges between the same two vertexes? (or maybe not.)
- existingEdge = ed;
- break;
- }
- }
-
- if( existingEdge != null ){
- // This is just an UPDATE
- for( Map.Entry<String, Object> entry : propHash.entrySet() ){
- LOGGER.debug("update edge property/val = [" + entry.getKey() + "]/[" + entry.getValue() + "]");
- existingEdge.property( entry.getKey(), entry.getValue() );
- }
-
- return( existingEdge );
- }
- else {
- // This is an ADD
-
- // Uniqueness double-check. This is just to catch the possibility that at the transaction layer,
- // if data came in for two identical nodes that point to the same dependant node (for uniqueness),
- // we would only be able to catch the problem at the time the edge to the second node is added.
- // For example - if they had a VM and then got a request to add two ipAddress nodes, but some
- // bad data was passed and those two ipAddress nodes were identical -- we'd want to catch it.
- String outV_NType = outV.<String>property("aai-node-type").orElse(null);
- String inV_NType = inV.<String>property("aai-node-type").orElse(null);
- if( needsADepNode4Uniqueness(transId, fromAppId, outV_NType, apiVersion)
- && nodeTypeACanDependOnB(transId, fromAppId, outV_NType, inV_NType, apiVersion) ){
- // The out-Vertex has a uniqueness dependency on the in-vertex
- // Make sure we haven't already added an node/edge like this in this transaction
- HashMap <String, Object> nodeKeyPropsHash = getNodeKeyPropHash(transId, fromAppId, graph, outV);
- ArrayList<TitanVertex> resultList = new ArrayList<TitanVertex>();
- resultList = DbMeth.getConnectedNodes("transId", "fromAppId", graph, outV_NType, nodeKeyPropsHash, inV, apiVersion, false);
- if( resultList.size() > 0 ){
- String propInfo = "";
- if( nodeKeyPropsHash != null ){
- propInfo = nodeKeyPropsHash.toString();
- }
- throw new AAIException("AAI_6117", "Failed to add edge. This node (" + inV_NType + ") already has an edge to a " + outV_NType +
- " node with kepProps [" + propInfo + "]");
- }
- }
- else if( needsADepNode4Uniqueness(transId, fromAppId, inV_NType, apiVersion)
- && nodeTypeACanDependOnB(transId, fromAppId, inV_NType, outV_NType, apiVersion) ){
- // The in-Vertex has a uniqueness dependency on the out-vertex
- // Make sure we haven't already added an node/edge like this in this transaction
- HashMap <String, Object> nodeKeyPropsHash = getNodeKeyPropHash(transId, fromAppId, graph, inV);
- ArrayList<TitanVertex> resultList = new ArrayList<TitanVertex>();
- resultList = DbMeth.getConnectedNodes("transId", "fromAppId", graph, inV_NType, nodeKeyPropsHash, outV, apiVersion, false);
- if( resultList.size() > 0 ){
- String propInfo = "";
- if( nodeKeyPropsHash != null ){
- propInfo = nodeKeyPropsHash.toString();
- }
- throw new AAIException("AAI_6117", "Failed to add edge. This node (" + outV_NType + ") already has an edge to a " + inV_NType +
- " node with kepProps [" + propInfo + "]");
- }
- }
-
-
- // We're good to go to add this edge
-
- TitanEdge tEdge = outV.addEdge( edgeLabel, inV );
- // Add the properties to the new Edge
- for( Map.Entry<String, Object> entry : propHash.entrySet() ){
- tEdge.property( entry.getKey(), entry.getValue() );
- }
-
- // For (resource-id updates) we need to "touch" the vertices on each side of the edge so
- // anybody working on one of those vertices will know that something (ADDing this edge) has happened.
- touchVertex( transId, fromAppId, inV );
- touchVertex( transId, fromAppId, outV );
-
- return tEdge;
- }
-
- }// End saveAaiEdgeToDb()
-
-
-
- /**
- * Derive edge rule key for this edge.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param tEdge the t edge
- * @return String - key to look up edgeRule (fromNodeType|toNodeType)
- * @throws AAIException the AAI exception
- */
- public static String deriveEdgeRuleKeyForThisEdge( String transId, String fromAppId, TitanTransaction graph,
- TitanEdge tEdge ) throws AAIException{
-
- TitanVertex fromVtx = tEdge.outVertex();
- TitanVertex toVtx = tEdge.inVertex();
- String startNodeType = fromVtx.<String>property("aai-node-type").orElse(null);
- String targetNodeType = toVtx.<String>property("aai-node-type").orElse(null);
- String key = startNodeType + "|" + targetNodeType;
- if( EdgeRules.getInstance().hasEdgeRule(startNodeType, targetNodeType) ){
- // We can use the node info in the order they were given
- return( key );
- }
- else {
- key = targetNodeType + "|" + startNodeType;
- if( EdgeRules.getInstance().hasEdgeRule(targetNodeType, startNodeType) ){
- return( key );
- }
- else {
- // Couldn't find a rule for this edge
- throw new AAIException("AAI_6120", "No EdgeRule found for passed nodeTypes: " + startNodeType + ", "
- + targetNodeType);
- }
- }
- }// end of deriveEdgeRuleKeyForThisEdge()
-
-
-
- /**
- * Save aai edge to db.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param edgeLabel the edge label
- * @param outV the out V
- * @param inV the in V
- * @param propHash the prop hash
- * @return the titan edge
- * @throws AAIException the AAI exception
- */
- @Deprecated
- private static TitanEdge saveAaiEdgeToDb(String transId, String fromAppId, TitanTransaction graph, String edgeLabel,
- TitanVertex outV, TitanVertex inV, HashMap <String,Object> propHash) throws AAIException{
- return saveAaiEdgeToDb( transId, fromAppId, graph, edgeLabel,
- outV, inV, propHash, null);
- }
-
- /**
- * Persist aai edge.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param targetVert the target vert
- * @param apiVersion the api version
- * @return the titan edge
- * @throws AAIException the AAI exception
- */
- public static TitanEdge persistAaiEdge( String transId, String fromAppId, TitanTransaction graph,
- TitanVertex startVert, TitanVertex targetVert, String apiVersion ) throws AAIException{
- TitanEdge returnEdge = persistAaiEdge(transId, fromAppId, graph, startVert, targetVert, apiVersion, "");
- return returnEdge;
- }
-
- /**
- * Persist aai edge.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param targetVert the target vert
- * @param apiVersion the api version
- * @param edgeType the edge type
- * @return TitanEdge
- * @throws AAIException the AAI exception
- */
- public static TitanEdge persistAaiEdge( String transId, String fromAppId, TitanTransaction graph,
- TitanVertex startVert, TitanVertex targetVert, String apiVersion, String edgeType ) throws AAIException{
-
- TitanVertex fromVtx = null;
- TitanVertex toVtx = null;
- String startNodeType = startVert.<String>property("aai-node-type").orElse(null);
- String targetNodeType = targetVert.<String>property("aai-node-type").orElse(null);
- String fwdRuleKey = startNodeType + "|" + targetNodeType;
- int fwdRuleCount = 0;
- String fwdRule = "";
- String fwdLabel = "";
- String revRuleKey = targetNodeType + "|" + startNodeType;
- int revRuleCount = 0;
- String revRule = "";
- String revLabel = "";
- String edRule = "";
- String edLabel = "";
-
- Boolean checkType = false;
- if( (edgeType != null) && edgeType != "" ){
- checkType = true;
- }
-
- // As of 16-07, it is possible to have more than one kind of edge defined between a given
- // pair of nodeTypes. So we need to check to see if there is only one possibility, or if
- // we need to look at the edgeType to determine which to use.
- // NOTE -- we're only supporting having 2 edges between a given pair of nodeTypes and
- // one and only one of them would have to be a parent-child edge.
-
- if( DbEdgeRules.EdgeRules.containsKey(fwdRuleKey) ){
- Collection <String> edRuleColl = DbEdgeRules.EdgeRules.get(fwdRuleKey);
- Iterator <String> ruleItr = edRuleColl.iterator();
- while( ruleItr.hasNext() ){
- String tmpRule = ruleItr.next();
- String [] rules = tmpRule.split(",");
- String tmpLabel = rules[0];
- String tmpParChild = rules[3];
- if( !checkType
- || (checkType && tmpParChild.equals("true") && edgeType.equals("parentChild"))
- || (checkType && tmpParChild.equals("false") && edgeType.equals("cousin")) ){
- // Either they didn't want us to check the edgeType or it is a match
- fwdRuleCount++;
- if( fwdRuleCount > 1 ){
- // We found more than one with the given info
- throw new AAIException("AAI_6120", "Multiple EdgeRules found for nodeTypes: [" + startNodeType + "], ["
- + targetNodeType + "], edgeType = [" + edgeType + "].");
- }
- else {
- fwdRule = tmpRule;
- fwdLabel = tmpLabel;
- }
- }
- }
- }
-
- // Try it the other way also (unless this is the case of a nodeType recursively pointing to itself
- // Ie. the edge rule: "model-element|model-element"
- if( !revRuleKey.equals(fwdRuleKey) && DbEdgeRules.EdgeRules.containsKey(revRuleKey) ){
- Collection <String> edRuleColl = DbEdgeRules.EdgeRules.get(revRuleKey);
- Iterator <String> ruleItr = edRuleColl.iterator();
- while( ruleItr.hasNext() ){
- String tmpRule = ruleItr.next();
- String [] rules = tmpRule.split(",");
- String tmpLabel = rules[0];
- String tmpParChild = rules[3];
- if( !checkType
- || (checkType && tmpParChild.equals("true") && edgeType.equals("parentChild"))
- || (checkType && tmpParChild.equals("false") && edgeType.equals("cousin")) ){
- // Either they didn't want us to check the edgeType or it is a match
- revRuleCount++;
- if( revRuleCount > 1 ){
- // We found more than one with the given info
- throw new AAIException("AAI_6120", "Multiple EdgeRules found for nodeTypes: [" + targetNodeType + "], ["
- + startNodeType + "], edgeType = [" + edgeType + "].");
- }
- else {
- revRule = tmpRule;
- revLabel = tmpLabel;
- }
- }
- }
- }
-
- if( (fwdRuleCount == 1) && (revRuleCount == 0) ){
- // We can use the node info in the order they were given
- fromVtx = startVert;
- toVtx = targetVert;
- edRule = fwdRule;
- edLabel = fwdLabel;
- }
- else if( (fwdRuleCount == 0) && (revRuleCount == 1) ){
- // We need to switch the vertex order so the edge-direction is correct
- toVtx = startVert;
- fromVtx = targetVert;
- edRule = revRule;
- edLabel = revLabel;
- }
- else if( (fwdRuleCount == 0) && (revRuleCount == 0) ){
- // No edge rule found for this
- throw new AAIException("AAI_6120", "No EdgeRule found for passed nodeTypes: " + startNodeType + ", " + targetNodeType
- + "], checkLabelType = [" + edgeType + "].");
- }
- else if( (fwdRuleCount > 0) && (revRuleCount > 0) ){
- // We found more than one with the given info
- throw new AAIException("AAI_6120", "Multiple EdgeRules (fwd and rev) found for nodeTypes: [" + startNodeType + "], ["
- + targetNodeType + "], checkLabelType = [" + edgeType + "].");
- }
-
- // If we got to this point, we now have a single edge label and we know to and from Vtx.
-
- HashMap <String,Object> edgeParamHash = getEdgeTagPropPutHash4Rule(transId, fromAppId, edRule);
- // We do "source-of-truth" for all edges
- edgeParamHash.put("source-of-truth", fromAppId );
-
- TitanEdge returnEdge = saveAaiEdgeToDb(transId, fromAppId, graph, edLabel, fromVtx, toVtx, edgeParamHash, apiVersion);
-
- return returnEdge;
-
- }
-
- /**
- * Persist aai edge.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param targetVert the target vert
- * @return the titan edge
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanEdge persistAaiEdge( String transId, String fromAppId, TitanTransaction graph,
- TitanVertex startVert, TitanVertex targetVert ) throws AAIException{
- return persistAaiEdge( transId, fromAppId, graph,
- startVert, targetVert, null);
- }
- // End persistAaiEdge()
-
-
- /**
- * Persist aai edge.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param edgeLabel the edge label
- * @param startVert the start vert
- * @param targetVert the target vert
- * @param propHash the prop hash
- * @param addIfNotFound the add if not found
- * @return the titan edge
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanEdge persistAaiEdge( String transId, String fromAppId, TitanTransaction graph,
- String edgeLabel, TitanVertex startVert, TitanVertex targetVert,
- HashMap <String,Object> propHash, Boolean addIfNotFound ) throws AAIException{
-
- /*----- This method is depricated ------
- * We will ignore the parameters: edgeLabel, propHash and addIfNotFound
- * We will use the remaining params to call the newer version of this method
- */
- TitanEdge returnEdge = persistAaiEdge(transId, fromAppId, graph, startVert, targetVert, null);
-
- return returnEdge;
-
- }// End depricated version of persistAaiEdge()
-
-
- /**
- * Persist aai edge with dep params.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param targetNodeType the target node type
- * @param targetNodeParamHash the target node param hash
- * @param apiVersion the api version
- * @return TitanEdge
- * @throws AAIException the AAI exception
- */
- public static TitanEdge persistAaiEdgeWithDepParams( String transId, String fromAppId, TitanTransaction graph,
- TitanVertex startVert, String targetNodeType, HashMap <String,Object> targetNodeParamHash, String apiVersion) throws AAIException{
-
- TitanVertex targetVert = getUniqueNodeWithDepParams( transId, fromAppId, graph, targetNodeType, targetNodeParamHash, apiVersion );
- TitanEdge returnEdge = persistAaiEdge(transId, fromAppId, graph, startVert, targetVert, apiVersion);
-
- return returnEdge;
-
- }// End persistAaiEdgeWithDepParams()
-
- // Version that lets you pass in an edgeType ("parentChild" or "cousin" since it sometimes cannot be determined
- /**
- * Persist aai edge with dep params.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param targetNodeType the target node type
- * @param targetNodeParamHash the target node param hash
- * @param apiVersion the api version
- * @param edgeType the edge type
- * @return the titan edge
- * @throws AAIException the AAI exception
- */
- // from the two nodeTypes anymore (16-07)
- public static TitanEdge persistAaiEdgeWithDepParams( String transId, String fromAppId, TitanTransaction graph,
- TitanVertex startVert, String targetNodeType, HashMap <String,Object> targetNodeParamHash,
- String apiVersion, String edgeType) throws AAIException{
- TitanVertex targetVert = getUniqueNodeWithDepParams( transId, fromAppId, graph, targetNodeType, targetNodeParamHash, apiVersion );
- TitanEdge returnEdge = persistAaiEdge(transId, fromAppId, graph, startVert, targetVert, apiVersion, edgeType);
-
- return returnEdge;
-
- }// End persistAaiEdgeWithDepParams()
-
- /**
- * Persist aai edge with dep params.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param startVert the start vert
- * @param targetNodeType the target node type
- * @param targetNodeParamHash the target node param hash
- * @return the titan edge
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static TitanEdge persistAaiEdgeWithDepParams( String transId, String fromAppId, TitanTransaction graph,
- TitanVertex startVert, String targetNodeType, HashMap <String,Object> targetNodeParamHash) throws AAIException{
- return persistAaiEdgeWithDepParams( transId, fromAppId, graph,
- startVert, targetNodeType, targetNodeParamHash, null);
- }
-
- /**
- * Gets the node key prop hash.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param vtx the vtx
- * @return nodeKeyPropHash
- * @throws AAIException the AAI exception
- */
- public static HashMap <String, Object> getNodeKeyPropHash( String transId, String fromAppId, TitanTransaction graph, TitanVertex vtx) throws AAIException{
-
- if( vtx == null ){
- throw new AAIException("AAI_6109", "null node object passed to getNodeKeyPropHash().");
- }
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- String nType = vtx.<String>property("aai-node-type").orElse(null);
- if( ! dbMaps.NodeKeyProps.containsKey(nType) ){
- // Problem if no key Properties defined for this nodeType
- String defVer = AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP);
- throw new AAIException("AAI_6105", "No node-key-properties defined in dbMaps for nodeType = " + nType + " (ver=" + defVer + ")");
- }
-
- HashMap <String,Object>nodeKeyPropsHash = new HashMap<String,Object>();
- Collection <String> keyProps = dbMaps.NodeKeyProps.get(nType);
- Iterator <String> keyPropI = keyProps.iterator();
- while( keyPropI.hasNext() ){
- String propName = keyPropI.next();
- Object value = (Object) vtx.<Object>property(propName).orElse(null);
- nodeKeyPropsHash.put(propName, value);
- }
-
- return nodeKeyPropsHash;
-
- }// End of getNodeKeyPropHash()
-
- /**
- * Gets the node name prop hash.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param vtx the vtx
- * @param apiVersion the api version
- * @return nodeKeyPropHash
- * @throws AAIException the AAI exception
- */
- public static HashMap <String, Object> getNodeNamePropHash( String transId, String fromAppId, TitanTransaction graph, TitanVertex vtx, String apiVersion) throws AAIException{
-
- if( vtx == null ){
- throw new AAIException("AAI_6109", "null node object passed to getNodeNamePropHash()." );
- }
-
- String nType = vtx.<String>property("aai-node-type").orElse(null);
- HashMap <String,Object>nodeNamePropsHash = new HashMap<String,Object>();
- Collection <String> keyProps = DbMeth.getNodeNameProps(transId, fromAppId, nType, apiVersion);
- Iterator <String> keyPropI = keyProps.iterator();
- while( keyPropI.hasNext() ){
- String propName = keyPropI.next();
- Object value = (Object) vtx.<Object>property(propName).orElse(null);
- nodeNamePropsHash.put(propName, value);
- }
-
- return nodeNamePropsHash;
-
- }// End of getNodeNamePropHash()
-
-
- /**
- * Removes the aai edge.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param tEdge the t edge
- * @return void
- */
- public static void removeAaiEdge( String transId, String fromAppId, TitanTransaction graph, TitanEdge tEdge){
- // Before removing the edge, touch the vertices on each side so their resource-versions will get updated
- TitanVertex tmpVIn = tEdge.inVertex();
- touchVertex( transId, fromAppId, tmpVIn );
-
- TitanVertex tmpVOut = tEdge.outVertex();
- touchVertex( transId, fromAppId, tmpVOut );
-
- // Remove the passed in edge.
- tEdge.remove();
-
- }// end of removeAaiEdge()
-
-
- /**
- * Removes the aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param thisVtx the this vtx
- * @param scopeParam the scope param
- * @param apiVersion the api version
- * @param resourceVersion the resource version
- * @throws AAIException the AAI exception
- */
- public static void removeAaiNode( String transId, String fromAppId, TitanTransaction graph, TitanVertex thisVtx, String scopeParam,
- String apiVersion, String resourceVersion ) throws AAIException{
- // Note: the resource Version Override flag is only set to true when called by the Model Delete code which
- // has no way to know the resource-versions of nodes at lower-levels of it's model topology.
- Boolean resVersionOverrideFlag = false;
- removeAaiNode( transId, fromAppId, graph, thisVtx, scopeParam, apiVersion, resourceVersion, resVersionOverrideFlag );
- }
-
-
- /**
- * <pre>
- * Possible values for deleteScope can be:
- * USE_DEFAULT - Get the scope from ref data for this node
- * THIS_NODE_ONLY (but should fail if it there are nodes that depend on it for uniqueness)
- * CASCADE_TO_CHILDREN - will look for OUT-Edges that have parentOf/hasDelTarget = true and follow those down
- * ERROR_4_IN_EDGES_OR_CASCADE - combo of error-if-any-IN-edges + CascadeToChildren
- * ERROR_IF_ANY_IN_EDGES - Fail if this node has any existing IN edges
- * ERROR_IF_ANY_EDGES - Fail if this node has any existing edges at all!
- * </pre>.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param thisVtx the this vtx
- * @param scopeParam the scope param
- * @param apiVersion the api version
- * @param resourceVersion the resource version
- * @param resVerOverride the res ver override
- * @return void
- * @throws AAIException the AAI exception
- */
- public static void removeAaiNode( String transId, String fromAppId, TitanTransaction graph, TitanVertex thisVtx, String scopeParam,
- String apiVersion, String resourceVersion, Boolean resVerOverride ) throws AAIException{
- String nodeType2Del = thisVtx.<String>property("aai-node-type").orElse(null);
- String deleteScope = scopeParam;
- if( scopeParam.equals("USE_DEFAULT") ){
- deleteScope = getDefaultDeleteScope(transId, fromAppId, nodeType2Del, apiVersion);
- }
-
- if( !resVerOverride && needToDoResourceVerCheck(apiVersion, false) ){
- // Need to check that they knew what they were deleting
- String existingResVer = thisVtx.<String>property("resource-version").orElse(null);
- if( resourceVersion == null || resourceVersion.equals("") ){
- throw new AAIException("AAI_6130", "Resource-version not passed for delete of = " + nodeType2Del);
- }
- else if( (existingResVer != null) && !resourceVersion.equals(existingResVer) ){
- throw new AAIException("AAI_6131", "Resource-version MISMATCH for delete of = " + nodeType2Del);
- }
- }
-
- if( !deleteScope.equals("THIS_NODE_ONLY")
- && !deleteScope.equals("CASCADE_TO_CHILDREN")
- && !deleteScope.equals("ERROR_4_IN_EDGES_OR_CASCADE")
- && !deleteScope.equals("ERROR_IF_ANY_EDGES")
- && !deleteScope.equals("ERROR_IF_ANY_IN_EDGES") ){
- throw new AAIException("AAI_6120", "Unrecognized value in deleteScope: [" + deleteScope + "].");
- }
-
- if( deleteScope.equals("ERROR_IF_ANY_EDGES") ){
- if ( thisVtx.edges(Direction.BOTH).hasNext() ) {
- throw new AAIException("AAI_6110", "Node cannot be deleted because it still has Edges and the ERROR_IF_ANY_EDGES scope was used.");
- }
- }
- else if( deleteScope.equals("ERROR_IF_ANY_IN_EDGES") || deleteScope.equals("ERROR_4_IN_EDGES_OR_CASCADE") ){
- Iterator <Edge> eI = thisVtx.edges(Direction.IN);
- boolean onlyHasParent = false;
- Edge temp = null;
- if( eI != null && eI.hasNext() ){
- temp = eI.next();
- Boolean isParent = temp.<Boolean>property("isParent").orElse(null);
- if (isParent != null && isParent && !eI.hasNext()) {
- onlyHasParent = true;
- }
-
- if (!onlyHasParent) {
- throw new AAIException("AAI_6110", "Node cannot be deleted because it still has Edges and the " + deleteScope + " scope was used.");
- }
- }
- }
- else if( deleteScope.equals("THIS_NODE_ONLY")){
- // Make sure nobody depends on this node.
- Iterator<Edge> eI = thisVtx.edges(Direction.BOTH);
- while( eI.hasNext() ){
- TitanEdge ed = (TitanEdge) eI.next();
- TitanVertex otherVtx = (TitanVertex) ed.otherVertex(thisVtx);
- String nodeTypeA = otherVtx.<String>property("aai-node-type").orElse(null);
- if( nodeTypeACanDependOnB(transId, fromAppId, nodeTypeA, nodeType2Del, apiVersion)){
- // We're only supposed to delete this node - but another node is dependant on it,
- // so we shouldn't delete this one.
- throw new AAIException("AAI_6110", "Node cannot be deleted using scope = " + deleteScope +
- " another node (type = " + nodeTypeA + ") depends on it for uniqueness.");
- }
- }
- }
-
- // We've passed our checks - so do some deleting of edges and maybe pass
- // the delete request down to children or delete-targets.
-
- // First we deal with the "IN"-Edges which can't have children/delete-targets which
- // by definition (of "IN") on the other end
- Iterator <Edge> eI_In = thisVtx.edges(Direction.IN);
- while( eI_In.hasNext() ){
- TitanEdge ed = (TitanEdge) eI_In.next();
-
- //- "touch" vertex on other side of this edge so it gets a fresh resource-version
- TitanVertex tmpVOther = ed.otherVertex(thisVtx);
- touchVertex( transId, fromAppId, tmpVOther );
-
- ed.remove();
- }
-
- // Now look at the "OUT"-edges which might include children or delete-targets
- String cascadeMsg = "This nt = " + nodeType2Del + ", Cascading del to: ";
- Iterator <Edge> eI_Out = thisVtx.edges(Direction.OUT);
- if( !eI_Out.hasNext() ){
- cascadeMsg = cascadeMsg + "[no children for this node]";
- }
- while( eI_Out.hasNext() ){
- TitanEdge ed = (TitanEdge) eI_Out.next();
-
- // "touch" vertex on other side of this edge so it gets a fresh resource-version
- TitanVertex tmpVOther = ed.otherVertex(thisVtx);
- touchVertex( transId, fromAppId, tmpVOther );
-
- Boolean otherVtxAChild = ed.<Boolean>property("isParent").orElse(null);
- if( otherVtxAChild == null ){
- otherVtxAChild = false;
- }
-
- Boolean otherVtxADeleteTarget = ed.<Boolean>property("hasDelTarget").orElse(null);
- if( otherVtxADeleteTarget == null ){
- otherVtxADeleteTarget = false;
- }
-
- if( (otherVtxAChild || otherVtxADeleteTarget) &&
- (deleteScope.equals("CASCADE_TO_CHILDREN") || deleteScope.equals("ERROR_4_IN_EDGES_OR_CASCADE")) ){
- // Delete the edge to the child and Pass the delete down to it.
- ed.remove();
- TitanVertex otherVtx = (TitanVertex) ed.otherVertex(thisVtx);
- String vid = otherVtx.id().toString();
- String nty = otherVtx.<String>property("aai-node-type").orElse(null);
- String resVers = otherVtx.<String>property("resource-version").orElse(null);
- cascadeMsg = cascadeMsg + "[" + nty + ":" + vid + "]";
- removeAaiNode(transId, fromAppId, graph, otherVtx, "CASCADE_TO_CHILDREN", apiVersion, resVers);
- }
- else {
- // The other node is not a child or deleteTarget. Delete the edge to it if it is not
- // dependent (Should never be dependent since it's not a child/delTarget... but
- // someone could create a node that was dependent for Uniqueness without
- // being a child/target.
-
- // DEBUG -- eventually add the check for dependancy that isn't on a parent-type or delTarget-type edge
- ed.remove();
- }
- }
-
- LOGGER.info(cascadeMsg);
-
- Iterator<Edge> eI = thisVtx.edges(Direction.BOTH);
- if( ! eI.hasNext() ){
- // By this point, either there were no edges to deal with, or we have dealt with them.
- thisVtx.remove();
- }
- else {
- // Something went wrong and we couldn't delete all the edges for this guy.
- throw new AAIException("AAI_6110", "Node could be deleted because it unexpectedly still has Edges.\n");
- }
- }
-
-
- /**
- * Removes the aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param thisVtx the this vtx
- * @param scopeParam the scope param
- * @return void
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static void removeAaiNode( String transId, String fromAppId, TitanTransaction graph, TitanVertex thisVtx, String scopeParam) throws AAIException{
- removeAaiNode(transId, fromAppId, graph, thisVtx, scopeParam, null, null);
- }
-
- /**
- * Removes the aai node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param thisVtx the this vtx
- * @param scopeParam the scope param
- * @param apiVersion the api version
- * @throws AAIException the AAI exception
- */
- @Deprecated
- public static void removeAaiNode( String transId, String fromAppId, TitanTransaction graph, TitanVertex thisVtx, String scopeParam,
- String apiVersion ) throws AAIException{
- removeAaiNode(transId, fromAppId, graph, thisVtx, scopeParam, apiVersion, null);
- }
- // end of removeAaiNode()
-
-
- /**
- * Delete all graph data.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @return void
- */
- public static void deleteAllGraphData( String transId, String fromAppId, TitanGraph graph ){
- /** ======================================================================
- * WARNING -- this removes ALL the data that is currently in the graph.
- * ======================================================================
- **/
- LOGGER.warn("deleteAllGraphData called! Run for the hills!");
- Iterator<Edge> edges = graph.edges(Direction.BOTH);
- graph.tx().commit();
- Edge edge = null;
- while (edges.hasNext()) {
- edge = edges.next();
- edges.remove();
- }
- graph.tx().commit();
- Iterator<Vertex> vertices = graph.vertices();
- graph.tx().commit();
- Vertex vertex = null;
- while (vertices.hasNext()) {
- vertex = vertices.next();
- vertex.remove();
- }
- graph.tx().commit();
- }
-
-
- /**
- * Show all edges for node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param tVert the t vert
- * @return the array list
- */
- public static ArrayList <String> showAllEdgesForNode( String transId, String fromAppId, TitanVertex tVert ){
-
- ArrayList <String> retArr = new ArrayList <String> ();
- Iterator <Edge> eI = tVert.edges(Direction.IN);
- if( ! eI.hasNext() ){
- retArr.add("No IN edges were found for this vertex. ");
- }
- while( eI.hasNext() ){
- TitanEdge ed = (TitanEdge) eI.next();
- String lab = ed.label();
- TitanVertex vtx = (TitanVertex) ed.otherVertex(tVert);
- if( vtx == null ){
- retArr.add(" >>> COULD NOT FIND VERTEX on the other side of this edge edgeId = " + ed.id() + " <<< ");
- }
- else {
- String nType = vtx.<String>property("aai-node-type").orElse(null);
- String vid = vtx.id().toString();
- retArr.add("Found an IN edge (" + lab + ") to this vertex from a [" + nType + "] node with VtxId = " + vid );
- //DEBUG ---
- //showPropertiesForEdge( transId, fromAppId, ed );
- }
- }
-
- eI = tVert.edges(Direction.OUT);
- if( ! eI.hasNext() ){
- retArr.add("No OUT edges were found for this vertex. ");
- }
- while( eI.hasNext() ){
- TitanEdge ed = (TitanEdge) eI.next();
- String lab = ed.label();
- TitanVertex vtx = (TitanVertex) ed.otherVertex(tVert);
- if( vtx == null ){
- retArr.add(" >>> COULD NOT FIND VERTEX on the other side of this edge edgeId = " + ed.id() + " <<< ");
- }
- else {
- String nType = vtx.<String>property("aai-node-type").orElse(null);
- String vid = vtx.id().toString();
- retArr.add("Found an OUT edge (" + lab + ") from this vertex to a [" + nType + "] node with VtxId = " + vid );
- //DEBUG ---
- //showPropertiesForEdge( transId, fromAppId, ed );
- }
- }
- return retArr;
- }
-
-
- /**
- * Show properties for node.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param tVert the t vert
- * @return the array list
- */
- public static ArrayList <String> showPropertiesForNode( String transId, String fromAppId, TitanVertex tVert ){
-
- ArrayList <String> retArr = new ArrayList <String> ();
- if( tVert == null ){
- retArr.add("null Node object passed to showPropertiesForNode()\n");
- }
- else {
- String nodeType = "";
- //String datType = "";
- Object ob = tVert.<Object>property("aai-node-type").orElse(null);
- if( ob == null ){
- nodeType = "null";
- }
- else{
- nodeType = ob.toString();
- //datType = ob.getClass().getSimpleName();
- }
-
- retArr.add(" AAINodeType/VtxID for this Node = [" + nodeType + "/" + tVert.id() + "]");
- retArr.add(" Property Detail: ");
- Iterator<VertexProperty<Object>> pI = tVert.properties();
- while( pI.hasNext() ){
- VertexProperty<Object> tp = pI.next();
- Object val = tp.value();
- //retArr.add("Prop: [" + tp.getPropertyKey() + "], val = [" + val + "], dataType = " + val.getClass() );
- retArr.add("Prop: [" + tp.key() + "], val = [" + val + "] ");
- }
- }
- return retArr;
- }
-
-
- /**
- * Gets the node name props.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param nodeType the node type
- * @param apiVersion the api version
- * @return HashMap of keyProperties
- * @throws AAIException the AAI exception
- */
- public static Collection <String> getNodeNameProps( String transId, String fromAppId, String nodeType, String apiVersion ) throws AAIException{
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- Collection <String> nameProps = new ArrayList <String>();
- if( dbMaps.NodeNameProps.containsKey(nodeType) ){
- nameProps = dbMaps.NodeNameProps.get(nodeType);
- }
- else if( DbEdgeRules.NodeTypeCategory.containsKey(nodeType) ){
- // The passed-in nodeType was really a nodeCategory, theoretically, all the guys in the same
- // category should have the same name property -- so if they just give us the category, we will
- // just give the name info from the first nodeType we encounter of that category.
- Collection <String> nTypeCatCol = DbEdgeRules.NodeTypeCategory.get(nodeType);
- Iterator <String> catItr = nTypeCatCol.iterator();
- String catInfo = "";
- if( catItr.hasNext() ){
- // For now, we only look for one.
- catInfo = catItr.next();
- }
- else {
- throw new AAIException("AAI_6105", "Required Property name(s) not found for nodeType = " + nodeType);
- }
-
- String [] flds = catInfo.split(",");
- if( flds.length != 4 ){
- throw new AAIException("AAI_6121", "Bad EdgeRule.NodeTypeCategory data (itemCount=" + flds.length + ") for nodeType = [" + nodeType + "].");
- }
-
- String nodeTypesString = flds[0];
- String [] nodeTypeNames = nodeTypesString.split("\\|");
- if( nodeTypeNames != null && nodeTypeNames.length > 0 ){
- // We'll just use the first one
- String nt = nodeTypeNames[0];
- nameProps = dbMaps.NodeNameProps.get(nt);
- }
- }
-
-
- // Note - it's ok if there was no defined name property for this nodeType.
-
- return nameProps;
-
- }// end of getNodeKeyPropNames
-
-
- /**
- * Gets the edge tag prop put hash 4 rule.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param edRule the ed rule
- * @return the edge tag prop put hash 4 rule
- * @throws AAIException the AAI exception
- */
- public static HashMap <String,Object> getEdgeTagPropPutHash4Rule( String transId, String fromAppId, String edRule )
- throws AAIException{
- // For a given edgeRule - already pulled out of DbEdgeRules.EdgeRules -- parse out the "tags" that
- // need to be set for this kind of edge.
- // These are the Boolean properties like, "isParent", "usesResource" etc.
- HashMap <String,Object> retEdgePropPutMap = new HashMap <String,Object>();
-
- if( (edRule == null) || edRule.equals("") ){
- // No edge rule found for this
- throw new AAIException("AAI_6120", "blank edRule passed to getEdgeTagPropPutHash4Rule()");
- }
-
- int tagCount = DbEdgeRules.EdgeInfoMap.size();
- String [] rules = edRule.split(",");
- if( rules.length != tagCount ){
- throw new AAIException("AAI_6121", "Bad EdgeRule data (itemCount =" + rules.length + ") for rule = [" + edRule + "].");
- }
-
- // In DbEdgeRules.EdgeRules -- What we have as "edRule" is a comma-delimited set of strings.
- // The first item is the edgeLabel.
- // The second in the list is always "direction" which is always OUT for the way we've implemented it.
- // Items starting at "firstTagIndex" and up are all assumed to be booleans that map according to
- // tags as defined in EdgeInfoMap.
- // Note - if they are tagged as 'reverse', that means they get the tag name with "-REV" on it
- for( int i = DbEdgeRules.firstTagIndex; i < tagCount; i++ ){
- String booleanStr = rules[i];
- Integer mapKey = new Integer(i);
- String propName = DbEdgeRules.EdgeInfoMap.get(mapKey);
- String revPropName = propName + "-REV";
-
- if( booleanStr.equals("true") ){
- retEdgePropPutMap.put(propName, true);
- retEdgePropPutMap.put(revPropName,false);
- }
- else if( booleanStr.equals("false") ){
- retEdgePropPutMap.put(propName, false);
- retEdgePropPutMap.put(revPropName,false);
- }
- else if( booleanStr.equals("reverse") ){
- retEdgePropPutMap.put(propName, false);
- retEdgePropPutMap.put(revPropName,true);
- }
- else {
- throw new AAIException("AAI_6121", "Bad EdgeRule data for rule = [" + edRule + "], val = [" + booleanStr + "].");
- }
-
- }
-
- return retEdgePropPutMap;
-
- } // End of getEdgeTagPropPutHash()
-
-
-
- /**
- * Gets the edge tag prop put hash.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param edgeRuleKey the edge rule key
- * @return the edge tag prop put hash
- * @throws AAIException the AAI exception
- */
- public static Map<String, EdgeRule> getEdgeTagPropPutHash( String transId, String fromAppId, String edgeRuleKey )
- throws AAIException{
- // For a given edgeRuleKey (nodeTypeA|nodeTypeB), look up the rule that goes with it in
- // DbEdgeRules.EdgeRules and parse out the "tags" that need to be set on each edge.
- // These are the Boolean properties like, "isParent", "usesResource" etc.
- // Note - this code is also used by the updateEdgeTags.java code
-
- String[] edgeRuleKeys = edgeRuleKey.split("\\|");
-
- if (edgeRuleKeys.length < 2 || ! EdgeRules.getInstance().hasEdgeRule(edgeRuleKeys[0], edgeRuleKeys[1])) {
- throw new AAIException("AAI_6120", "Could not find an DbEdgeRule entry for passed edgeRuleKey (nodeTypeA|nodeTypeB): " + edgeRuleKey + ".");
- }
-
- Map<String, EdgeRule> edgeRules = EdgeRules.getInstance().getEdgeRules(edgeRuleKeys[0], edgeRuleKeys[1]);
-
- return edgeRules;
-
- } // End of getEdgeTagPropPutHash()
-
-
- /**
- * This property was put by newer version of code.
- *
- * @param apiVersionStr the api version str
- * @param nodeType the node type
- * @param propName the prop name
- * @return true, if successful
- * @throws AAIException the AAI exception
- */
- private static boolean thisPropertyWasPutByNewerVersionOfCode( String apiVersionStr,
- String nodeType, String propName) throws AAIException{
- // We want to return True if the nodeType + property-name combo was introduced AFTER the apiVersion passed.
-
- int apiVerInt = 0;
- int propIntroVerInt = 0;
-
- if( apiVersionStr == null || apiVersionStr.equals("") ){
- apiVersionStr = org.openecomp.aai.util.AAIApiVersion.get();
- }
- apiVerInt = getVerNumFromVerString(apiVersionStr);
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
- String propIntroKey = nodeType + "|" + propName;
- if( propName.equals("prov-status") ){
- // This is a special case -- The dbMaps from v2 has it in there, but it was introduced half way through. So
- // it needs to be catogorized as v3.
- propIntroVerInt = 3;
- }
- else if( ! dbMaps.PropertyVersionInfoMap.containsKey(propIntroKey) ){
- String detail = propIntroKey + " [" + propIntroKey + "] not found in dbMaps.PropertyVersionInfoMap.";
- throw new AAIException("AAI_6121", detail);
- }
- else {
- String propIntroVerString = dbMaps.PropertyVersionInfoMap.get(propIntroKey);
- propIntroVerInt = getVerNumFromVerString( propIntroVerString );
- }
-
- if( propIntroVerInt > apiVerInt ){
- return true;
- }
- else {
- return false;
- }
-
- } // End of thisPropertyWasPutByNewerVersionOfCode()
-
-
- /**
- * Touch vertex.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param v the v
- * @return void
- */
- public static void touchVertex( String transId, String fromAppId, TitanVertex v ){
- // We want to "touch" the vertex -- Ie. update it's last-mod-date, last-mod- resource-version to the current date/time
- if( v != null ){
- long unixTimeNow = System.currentTimeMillis() / 1000L;
- String timeNowInSec = "" + unixTimeNow;
- v.property( "aai-last-mod-ts", timeNowInSec );
- v.property( "resource-version", timeNowInSec );
- v.property( "last-mod-source-of-truth", fromAppId );
- }
- } // End of touchVertex()
-
-
- /**
- * Check prop cardinality.
- *
- * @param propName the prop name
- * @param cardinalityType the cardinality type
- * @return boolean
- * @throws AAIException the AAI exception
- */
- public static boolean checkPropCardinality( String propName, String cardinalityType ) throws AAIException {
-
- // Return true if the named property is tagged in our dbMaps PropetyDataTypeMap as
- // having the passed in cardinality type.
- // NOTE: supported cardinality types in dbMaps = "Set" or "List"
- // In Titan (and ex5.json), those go in as "SET" and "LIST"
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- if( dbMaps.PropertyDataTypeMap.containsKey(propName) ){
- String propDataType = dbMaps.PropertyDataTypeMap.get(propName);
- if( propDataType != null && propDataType.startsWith(cardinalityType) ){
- return true;
- }
- }
- return false;
-
- } // End of checkPropCardinality()
-
- /**
- * Convert type if needed.
- *
- * @param propName the prop name
- * @param val the val
- * @return convertedValue (if it was a String but needed to be a Boolean)
- * @throws AAIException the AAI exception
- */
- public static Object convertTypeIfNeeded( String propName, Object val )
- throws AAIException {
- // Make sure the dataType of the passed-in Object matches what the DB expects
-
- // NOTE: since this is a fix very late in our dev cycle, we'll just fix the scenarios that
- // we're having trouble with which is Strings getting into the db which should be going in as
- // Booleans or Integers.
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- if( dbMaps.PropertyDataTypeMap.containsKey(propName) ){
- String dbExpectedDataType = dbMaps.PropertyDataTypeMap.get(propName);
- if( dbExpectedDataType != null
- && dbExpectedDataType.equals("Boolean")
- && val != null
- && !(val instanceof Boolean) ){
- String valStr = val.toString().trim();
- if( valStr.equals("true") || valStr.equals("True") || valStr.equals("TRUE") ){
- return Boolean.valueOf("true");
- }
- else if( valStr.equals("false") || valStr.equals("False") || valStr.equals("FALSE") ){
- return Boolean.valueOf("false");
- }
- else {
- String emsg = "Error trying to convert value: [" + valStr + "] to a Boolean for property + " + propName + "\n";
- throw new AAIException("AAI_6120", emsg);
- }
- }
- else if( dbExpectedDataType != null
- && dbExpectedDataType.equals("Integer")
- && val != null
- && !(val.toString().trim().equals(""))
- && !(val instanceof Integer) ){
- String valStr = val.toString().trim();
- Integer newInt;
- try {
- newInt = Integer.valueOf(valStr);
- return newInt;
- }
- catch( Exception e ){
- String emsg = "Error trying to convert value: [" + valStr + "] to an Integer for property + " + propName + "\n";
- throw new AAIException("AAI_6120", emsg);
- }
- }
- }
-
- // If it didn't need to be converted, just return it.
- return val;
-
- } // End of convertTypeIfNeeded()
-
-
-
- /**
- * This vertex not reachable.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param v the v
- * @param version the version
- * @return boolean
- */
- public static boolean thisVertexNotReachable( String transId, String fromAppId, TitanTransaction graph, TitanVertex v, String version){
- if( v == null ){
- return true;
- }
- else {
- try {
- v.id().toString();
- }
- catch( Exception ex ){
- // Could not get this -- sometimes we're holding a vertex object that has gotten deleted, so
- // when we try to get stuff from it, we get an "Element Has Been Removed" error from Titan
- return true;
- }
- }
-
- return false;
-
- } // End of thisVertexNotReachable()
-
- /**
- * This vertex has bad edges.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param v the v
- * @param version the version
- * @return boolean
- */
- public static boolean thisVertexHasBadEdges( String transId, String fromAppId, TitanTransaction graph, TitanVertex v, String version){
-
- Iterator <Edge> eItor = v.edges(Direction.BOTH);
- while( eItor.hasNext() ){
- Edge e = null;
- e = eItor.next();
- if( e == null ){
- return true;
- }
- Vertex vIn = e.inVertex();
- if( (vIn == null) || (vIn.<String>property("aai-node-type").orElse(null) == null) ){
- // this is a bad edge because it points to a vertex that isn't there anymore
- return true;
- }
-
- Vertex vOut = e.outVertex();
- if( (vOut == null) || (vOut.<String>property("aai-node-type").orElse(null) == null) ){
- // this is a bad edge because it points to a vertex that isn't there anymore
- return true;
- }
- }
-
- // If we made it to here, the vertex's edges must be ok.
- return false;
-
- } // End of thisVertexHasBadEdges()
-
-
- /**
- * This vertex is A phantom.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param v the v
- * @param version the version
- * @return boolean
- * @throws AAIException the AAI exception
- */
- public static boolean thisVertexIsAPhantom( String transId, String fromAppId, TitanTransaction graph, TitanVertex v, String version )
- throws AAIException {
-
-
- // The kind of Phantom we're looking for is the kind that we sometimes get when we do a select without
- // using key properties. They can be in the database as a vertex, but the indexes that should point to
- // them are not working -- so they cannot be used by normal interfaces (like the REST API) which means
- // that if we return it, it can mess up a caller who tries to use it.
- if( v == null ){
- return true;
- }
- String thisVid = v.id().toString();
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- Object propOb = v.<Object>property("aai-node-type").orElse(null);
- if( propOb == null ){
- // This vertex does not have an aai-node-type ---> it is messed up
- return true;
- }
- String nType = propOb.toString();
- if( ! dbMaps.NodeKeyProps.containsKey(nType) ){
- // This node Type does not have keys defined
- // This could just be bad reference data, so we will not flag this guy, but we
- // can't really do our test...
- return false;
- }
-
- HashMap <String,Object> propHashWithKeys = new HashMap<String, Object>();
- Collection <String> keyProps = null;
- try {
- keyProps = getNodeKeyPropNames(transId, fromAppId, nType, version);
- }
- catch (AAIException ex) {
- // something wrong with getting this guy's key property names - we'll abandon this test...
- return false;
- }
-
- Iterator <String> keyPropI = keyProps.iterator();
- while( keyPropI.hasNext() ){
- String propName = keyPropI.next();
- String propVal = "";
- Object ob = v.<Object>property(propName).orElse(null);
- if( ob != null ){
- propVal = ob.toString();
- }
- propHashWithKeys.put(propName, propVal);
- }
- try {
- // Note - We can get more than one back since some nodes need a dep. node for uniqueness.
- // We don't care about that -- we just want to make sure we can get this vertex back when
- // we're searching with it's indexed fields.
- // NOTE - we're passing the skipGroomCheck to getNodes so we don't wind up in an infinite loop
- ArrayList <TitanVertex> vertList2 = getNodes( transId, fromAppId, graph, nType, propHashWithKeys, false, version, true );
- Iterator<TitanVertex> iter2 = vertList2.iterator();
- while( iter2.hasNext() ){
- TitanVertex tvx2 = iter2.next();
- String foundId = tvx2.id().toString();
- if( foundId.equals( thisVid ) ){
- // We could get back the vertex by looking it up using key properties... That's good.
- return false;
- }
- }
- }
- catch (Exception e2) {
- //String msg = " Error encountered for this vertex id: [" + thisVid +
- // "]. Caught this exception: " + e2.toString();
- // Something messed up - but that doesn't prove that this is a phantom.
- return false;
- }
-
- // If we dropped down to here, we have looked but could not pull the vertex out of the
- // db using it's key fields, so it gets flagged as a Phantom.
- return true;
-
- } // End of thisVertexIsAPhantom()
-
-
- /**
- * Gets the node by unique key.
- *
- * @param transId the trans id
- * @param fromAppId the from app id
- * @param graph the graph
- * @param aaiUniquekey the aai uniquekey
- * @return the node by unique key
- */
- public TitanVertex getNodeByUniqueKey(String transId, String fromAppId, TitanTransaction graph, String aaiUniquekey) {
-
- TitanVertex vert = null;
-
- Iterator<?> vertI = graph.query().has("aai-unique-key", aaiUniquekey).vertices().iterator();
-
- if( vertI != null && vertI.hasNext()) {
- // We found a vertex that meets the input criteria.
- vert = (TitanVertex) vertI.next();
- }
-
- return vert;
- }
-
-
-
-}
-
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/ModelBasedProcessing.java b/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/ModelBasedProcessing.java
index 6d9a277..da1fc1e 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/ModelBasedProcessing.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/dbgraphgen/ModelBasedProcessing.java
@@ -36,23 +36,21 @@ import java.util.concurrent.TimeUnit;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.VertexProperty;
-
import org.openecomp.aai.db.DbMethHelper;
import org.openecomp.aai.db.props.AAIProperties;
import org.openecomp.aai.dbgen.PropertyLimitDesc;
import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.ingestModel.DbMaps;
-import org.openecomp.aai.ingestModel.IngestModelMoxyOxm;
import org.openecomp.aai.introspection.Introspector;
import org.openecomp.aai.introspection.Loader;
import org.openecomp.aai.introspection.exceptions.AAIUnknownObjectException;
import org.openecomp.aai.query.builder.QueryBuilder;
+import org.openecomp.aai.schema.enums.PropertyMetadata;
import org.openecomp.aai.serialization.db.DBSerializer;
import org.openecomp.aai.serialization.db.EdgeRules;
import org.openecomp.aai.serialization.db.EdgeType;
import org.openecomp.aai.serialization.engines.TransactionalGraphEngine;
import org.openecomp.aai.util.AAIConfig;
-import org.openecomp.aai.util.AAIConstants;
+
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import com.google.common.collect.ArrayListMultimap;
@@ -137,12 +135,12 @@ public class ModelBasedProcessing{
String calcModId = modVtx.<String>property("model-invariant-id").orElse(null);
// Now we can look up instances that match this model's info
if( calcModId != null ){
- startVerts = this.engine.asAdmin().getReadOnlyTraversalSource().V().has("model-invariant-id-local",calcModId).has("model-version-id-local",passedModelVersionId);
+ startVerts = this.engine.asAdmin().getReadOnlyTraversalSource().V().has(addDBAliasedSuffix("model-invariant-id"),calcModId).has(addDBAliasedSuffix("model-version-id"),passedModelVersionId);
}
}
else if( passedModelInvId != null && !passedModelInvId.equals("") ){
// They gave us the model-invariant-id
- startVerts = this.engine.asAdmin().getReadOnlyTraversalSource().V().has("model-invariant-id-local",passedModelInvId);
+ startVerts = this.engine.asAdmin().getReadOnlyTraversalSource().V().has(addDBAliasedSuffix("model-invariant-id"),passedModelInvId);
}
else if( passedModelName != null && !passedModelName.equals("") ){
List<Vertex> modelVerVtxList = getModelVersUsingName(transId, fromAppId, passedModelName);
@@ -154,7 +152,7 @@ public class ModelBasedProcessing{
Vertex modVtx = getModelGivenModelVer(modelVerVtxList.get(i),"");
String calcModInvId = modVtx.<String>property("model-invariant-id").orElse(null);
// Now we can look up instances that match this model's info
- Iterator<Vertex> tmpStartIter = this.engine.asAdmin().getReadOnlyTraversalSource().V().has("model-invariant-id-local",calcModInvId).has("model-version-id-local",calcModVerId);
+ Iterator<Vertex> tmpStartIter = this.engine.asAdmin().getReadOnlyTraversalSource().V().has(addDBAliasedSuffix("model-invariant-id"),calcModInvId).has(addDBAliasedSuffix("model-version-id"),calcModVerId);
while( tmpStartIter.hasNext() ){
Vertex tmpStartVert = (Vertex) tmpStartIter.next();
startVtxList.add(tmpStartVert);
@@ -171,8 +169,8 @@ public class ModelBasedProcessing{
while( startVerts.hasNext() ){
Vertex tmpStartVert = (Vertex) startVerts.next();
String vid = tmpStartVert.id().toString();
- String tmpModId = tmpStartVert.<String>property("model-invariant-id-local").orElse(null);
- String tmpModVerId = tmpStartVert.<String>property("model-version-id-local").orElse(null);
+ String tmpModId = tmpStartVert.<String>property(addDBAliasedSuffix("model-invariant-id")).orElse(null);
+ String tmpModVerId = tmpStartVert.<String>property(addDBAliasedSuffix("model-version-id")).orElse(null);
startVertInfo.put(vid, tmpModVerId);
}
}
@@ -264,8 +262,8 @@ public class ModelBasedProcessing{
}
String vid = startVtx.id().toString();
- String personaModInvId = startVtx.<String>property("model-invariant-id-local").orElse(null);
- String personaModVerId = startVtx.<String>property("model-version-id-local").orElse(null);
+ String personaModInvId = startVtx.<String>property(addDBAliasedSuffix("model-invariant-id")).orElse(null);
+ String personaModVerId = startVtx.<String>property(addDBAliasedSuffix("model-version-id")).orElse(null);
// Either this start-node has persona info (which should not contradict any passed-in model info)
// or they should have passed in the model to use - so we'd just use that.
@@ -425,9 +423,7 @@ public class ModelBasedProcessing{
List<Map<String,Object>> startNodeFilterArrayOfHashesVal,
String apiVer )
throws AAIException{
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
+
List<ResultSet> resultArray = new ArrayList<>();
// NOTE: this method can be used for different styles of queries:
@@ -537,7 +533,7 @@ public class ModelBasedProcessing{
if( ! skipModelVerIdList.contains(modVerKey) ){
Vertex modelVerVtx = (Vertex)distinctModelVersHash.get(modVerKey);
Multimap<String, String> tmpTopoMap = genTopoMap4ModelVer( transId, fromAppId,
- modelVerVtx, modVerKey, dbMaps );
+ modelVerVtx, modVerKey);
validNextStepHash.put(modVerKey, tmpTopoMap);
}
}
@@ -550,7 +546,7 @@ public class ModelBasedProcessing{
Map<String, String> firstStepInfoHash = new HashMap<>();
// For firstStepInfoHash: key = startNodeVtxId, val=topNodeType plus personaData if applicable
// ie. the value is what we'd use as the "first-step" for this model.
- if( !nodeTypeSupportsPersona( startNodeType, dbMaps) ){
+ if( !nodeTypeSupportsPersona( startNodeType) ){
// This node type doesn't have persona info, so we just use startNodeType for the first-step-info
snKeySet = startNode2ModelVerHash.keySet();
startNodeIterator = snKeySet.iterator();
@@ -575,8 +571,8 @@ public class ModelBasedProcessing{
Vertex modelVerVtx = (Vertex)distinctModelVersHash.get(thisVtxModelVerId);
Vertex modelVtx = getModelGivenModelVer( modelVerVtx, "" );
String modInvId = modelVtx.<String>property("model-invariant-id").orElse(null);
- String personaModInvId = tmpVtx.<String>property("model-invariant-id-local").orElse(null);
- String personaModVerId = tmpVtx.<String>property("model-version-id-local").orElse(null);
+ String personaModInvId = tmpVtx.<String>property(addDBAliasedSuffix("model-invariant-id")).orElse(null);
+ String personaModVerId = tmpVtx.<String>property(addDBAliasedSuffix("model-version-id")).orElse(null);
if( modInvId.equals(personaModInvId) && thisVtxModelVerId.equals(personaModVerId) ){
String tmpPersonaInfoStr = startNodeType + "," + personaModInvId + "," + personaModVerId;
firstStepInfoHash.put(vtxKey, tmpPersonaInfoStr );
@@ -666,9 +662,7 @@ public class ModelBasedProcessing{
throws AAIException{
Map<String,String> retHash = new HashMap<>();
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
+
// Locate the Model-ver node to be used
Vertex modelVerVtx = null;
if( modelVersionId != null && !modelVersionId.equals("") ){
@@ -688,7 +682,7 @@ public class ModelBasedProcessing{
}
Vertex startVtx = result.get();
- String startVertModVerId = startVtx.<String>property("model-version-id-local").orElse(null);
+ String startVertModVerId = startVtx.<String>property(addDBAliasedSuffix("model-version-id")).orElse(null);
modelVerVtx = getNodeUsingUniqueId(transId, fromAppId, "model-ver",
"model-version-id", startVertModVerId);
}
@@ -733,7 +727,7 @@ public class ModelBasedProcessing{
String msg = "Could not determine the top-node nodeType for model-version-id: [" + modelVersionId + "]";
throw new AAIException("AAI_6132", msg);
}
- if( nodeTypeSupportsPersona(topNType, dbMaps) ){
+ if( nodeTypeSupportsPersona(topNType) ){
Vertex modelVtx = getModelGivenModelVer(modelVerVtx,"");
chkFirstNodePersonaModInvId = modelVtx.<String>property("model-invariant-id").orElse(null);
chkFirstNodePersonaModVerId = modelVerVtx.<String>property("model-version-id").orElse(null);
@@ -747,7 +741,7 @@ public class ModelBasedProcessing{
ArrayList <String> vidsTraversed = new ArrayList<>();
Map<String, String> delKeyHash = collectDeleteKeyHash( transId, fromAppId,
firstModElementVertex, incomingTrail, currentHash, vidsTraversed,
- 0, dbMaps, modConHash,
+ 0, modConHash,
chkFirstNodePersonaModInvId, chkFirstNodePersonaModVerId );
@@ -765,8 +759,8 @@ public class ModelBasedProcessing{
if( !chkFirstNodePersonaModInvId.equals("") ){
// NOTE: For Service or Resource models, if this is a nodeType that supports persona's, then
// we need to make sure that the start node matches the persona values.
- String startVertPersonaModInvId = startVtx.<String>property("model-invariant-id-local").orElse(null);
- String startVertPersonaModVerId = startVtx.<String>property("model-version-id-local").orElse(null);
+ String startVertPersonaModInvId = startVtx.<String>property(addDBAliasedSuffix("model-invariant-id")).orElse(null);
+ String startVertPersonaModVerId = startVtx.<String>property(addDBAliasedSuffix("model-version-id")).orElse(null);
if( !chkFirstNodePersonaModInvId.equals(startVertPersonaModInvId)
|| !chkFirstNodePersonaModVerId.equals(startVertPersonaModVerId) ){
String msg = "Persona-Model data mismatch for start node (" + topNType + "), " +
@@ -778,7 +772,7 @@ public class ModelBasedProcessing{
// Read the model-ver into a Map for processing
Multimap <String, String> validNextStepMap = genTopoMap4ModelVer(transId, fromAppId,
- modelVerVtx, modelVersionId, dbMaps );
+ modelVerVtx, modelVersionId);
// Collect the data
String elementLocationTrail = topNType + personaData;
@@ -1555,7 +1549,7 @@ public class ModelBasedProcessing{
modPipe = this.engine.asAdmin().getReadOnlyTraversalSource().V(thisLevelElemVtx).both().has(AAIProperties.NODE_TYPE, targetNodeType);
}
else {
- modPipe = this.engine.asAdmin().getReadOnlyTraversalSource().V(thisLevelElemVtx).both().has(AAIProperties.NODE_TYPE, targetNodeType).has("model-invariant-id-local",pmid).has("model-version-id-local",pmv);
+ modPipe = this.engine.asAdmin().getReadOnlyTraversalSource().V(thisLevelElemVtx).both().has(AAIProperties.NODE_TYPE, targetNodeType).has(addDBAliasedSuffix("model-invariant-id"),pmid).has(addDBAliasedSuffix("model-version-id"),pmv);
}
if( modPipe == null || !modPipe.hasNext() ){
@@ -1591,12 +1585,12 @@ public class ModelBasedProcessing{
* @param fromAppId the from app id
* @param modelVerVertex the model-ver vertex
* @param modelVerId the model-version-id
- * @param dbMaps the db maps
+ * @param loader the db maps
* @return MultiMap of valid next steps for each potential model-element
* @throws AAIException the AAI exception
*/
public Multimap<String, String> genTopoMap4ModelVer( String transId, String fromAppId,
- Vertex modelVerVertex, String modelVerId, DbMaps dbMaps )
+ Vertex modelVerVertex, String modelVerId)
throws AAIException {
if( modelVerVertex == null ){
@@ -1643,7 +1637,7 @@ public class ModelBasedProcessing{
}
Multimap <String, String> collectedMap = collectTopology4ModelVer( transId, fromAppId,
- firstElementVertex, "", initialEmptyMap, vidsTraversed, 0, dbMaps, null, firstModelInvId, firstModelVersion );
+ firstElementVertex, "", initialEmptyMap, vidsTraversed, 0, null, firstModelInvId, firstModelVersion );
return collectedMap;
@@ -1965,6 +1959,9 @@ public class ModelBasedProcessing{
Vertex relLookupVtx = (Vertex) lookPipe.next();
// We found a related-lookup record to try and use
String srcProp = relLookupVtx.<String>property("source-node-property").orElse(null);
+ String srcNodeType = relLookupVtx.<String>property("source-node-type").orElse(null);
+ srcProp = getPropNameWithAliasIfNeeded(srcNodeType, srcProp);
+
if( (srcProp == null) || srcProp.equals("")){
String msg = " Bad related-lookup (source-node-property) found in Named Query definition. ";
throw new AAIException("AAI_6133", msg);
@@ -1975,6 +1972,8 @@ public class ModelBasedProcessing{
throw new AAIException("AAI_6133", msg);
}
String targetProp = relLookupVtx.<String>property("target-node-property").orElse(null);
+ targetProp = getPropNameWithAliasIfNeeded(targetNodeType, targetProp);
+
if( (targetProp == null) || targetProp.equals("")){
String msg = " Bad related-lookup (target-node-property) found in Named Query definition. ";
throw new AAIException("AAI_6133", msg);
@@ -1986,10 +1985,16 @@ public class ModelBasedProcessing{
propCollectList.add((String)vpI.next().value());
}
- // Use the value from the source to see if we can find ONE target record using the value from the source
+ // Use the value from the source to see if we can find ONE target record using the
+ // value from the source
String valFromInstance = instanceVertex.<String>property(srcProp).orElse(null);
if( valFromInstance == null ){
- valFromInstance = "";
+ // if there is no key to use to go look up something, we should end it here and just
+ // note what happened - no need to try to look something up by an empty key
+ LOGGER.debug("WARNING - the instance data node of type [" + srcNodeType
+ + "] did not have a value for property [" + srcProp
+ + "], so related-lookup is being abandoned.");
+ return retHash;
}
Map<String,Object> propHash = new HashMap<String,Object>();
@@ -1997,18 +2002,26 @@ public class ModelBasedProcessing{
Optional<Vertex> result = dbMethHelper.locateUniqueVertex(targetNodeType, propHash);
if (!result.isPresent()) {
- throw new AAIException("AAI_6114", "No Node of type " + targetNodeType + " found for properties");
+ // If it can't find the lookup node, don't fail, just log that it couldn't be found ---
+ LOGGER.debug("WARNING - Could not find lookup node that corresponds to nodeType ["
+ + targetNodeType + "] propertyName = [" + srcProp
+ + "], propVal = [" + valFromInstance
+ + "] so related-lookup is being abandoned.");
+ return retHash;
}
+ else {
Vertex tmpVtx = result.get();
// Pick up the properties from the target vertex that they wanted us to get
for( int j = 0; j < propCollectList.size(); j++ ){
String tmpPropName = propCollectList.get(j);
+ tmpPropName = getPropNameWithAliasIfNeeded(targetNodeType, tmpPropName);
Object valObj = tmpVtx.<Object>property(tmpPropName).orElse(null);
String lookupKey = targetNodeType + "." + tmpPropName;
retHash.put(lookupKey, valObj);
}
}
+ }
return retHash;
@@ -2107,7 +2120,7 @@ public class ModelBasedProcessing{
* @param Map that got us to this point (that we will use as the base of the map we will return)
* @param vidsTraversed the vids traversed ---- ArrayList of vertexId's that we traversed to get to this point
* @param levelCounter the level counter
- * @param dbMaps the db maps
+ * @param loader the db maps
* @param modConstraintHash the mod constraint hash
* @param overRideModelId the over ride model id
* @param overRideModelVersionId the over ride model version id
@@ -2117,7 +2130,7 @@ public class ModelBasedProcessing{
public Map<String, String> collectDeleteKeyHash( String transId, String fromAppId,
Vertex thisLevelElemVtx, String incomingTrail,
Map<String,String> currentHash, ArrayList <String> vidsTraversed,
- int levelCounter, DbMaps dbMaps, Map<String, Vertex> modConstraintHash,
+ int levelCounter, Map<String, Vertex> modConstraintHash,
String overRideModelId, String overRideModelVersionId )
throws AAIException {
@@ -2207,7 +2220,7 @@ public class ModelBasedProcessing{
firstElementModelInfo = "," + overRideModelId + "," + overRideModelVersionId;
}
}
- else if( nodeTypeSupportsPersona(thisElementNodeType, dbMaps) ){
+ else if( nodeTypeSupportsPersona(thisElementNodeType) ){
firstElementModelInfo = "," + subModelFirstModInvId + "," + subModelFirstVerId;
}
@@ -2314,12 +2327,12 @@ public class ModelBasedProcessing{
Vertex elVert = (Vertex)(entry.getValue());
String tmpElVid = elVert.id().toString();
String tmpElNT = getModElementWidgetType( elVert, thisGuysTrail );
- check4EdgeRule(tmpElNT, thisElementNodeType, dbMaps);
+ check4EdgeRule(tmpElNT, thisElementNodeType);
if( !vidsTraversed.contains(tmpElVid) ){
// This is one we would like to use - so we'll recursively get it's result set to add to ours
Map<String, String> tmpHash = collectDeleteKeyHash( transId, fromAppId,
elVert, thisGuysTrail,
- currentHash, vidsTraversed, levelCounter, dbMaps, modConstraintHash2Use,
+ currentHash, vidsTraversed, levelCounter, modConstraintHash2Use,
"", "" );
thisHash.putAll(tmpHash);
}
@@ -2377,7 +2390,7 @@ public class ModelBasedProcessing{
* @param currentMap the current map -- map that got us to this point (that we will use as the base of the map we will return)
* @param vidsTraversed the vids traversed -- ArrayList of vertexId's that we traversed to get to this point
* @param levelCounter the level counter
- * @param dbMaps the db maps
+ * @param loader the db maps
* @param modConstraintHash the mod constraint hash
* @param overRideModelInvId the override model-invariant-id
* @param overRideModelVersionId the override model-version-id
@@ -2387,7 +2400,7 @@ public class ModelBasedProcessing{
public Multimap<String, String> collectTopology4ModelVer( String transId, String fromAppId,
Vertex thisLevelElemVtx, String incomingTrail,
Multimap <String,String> currentMap, List<String> vidsTraversed,
- int levelCounter, DbMaps dbMaps, Map<String, Vertex> modConstraintHash,
+ int levelCounter, Map<String, Vertex> modConstraintHash,
String overRideModelInvId, String overRideModelVersionId )
throws AAIException {
@@ -2414,7 +2427,7 @@ public class ModelBasedProcessing{
// first element which is a single widget-type model.
String firstElementModelInfo = "";
String thisElementNodeType = getModElementWidgetType( thisLevelElemVtx, incomingTrail );
- if( nodeTypeSupportsPersona(thisElementNodeType, dbMaps) && overRideModelInvId != null && !overRideModelInvId.equals("") ){
+ if( nodeTypeSupportsPersona(thisElementNodeType) && overRideModelInvId != null && !overRideModelInvId.equals("") ){
firstElementModelInfo = "," + overRideModelInvId + "," + overRideModelVersionId;
}
@@ -2434,7 +2447,7 @@ public class ModelBasedProcessing{
subModelFirstModInvId = thisElementsModelVtx.<String>property("model-invariant-id").orElse(null);
subModelFirstModVerId = thisElementsModelVerVtx.<String>property("model-version-id").orElse(null);
- if( nodeTypeSupportsPersona(thisElementNodeType, dbMaps) ){
+ if( nodeTypeSupportsPersona(thisElementNodeType) ){
modInfo4Trail = "," + subModelFirstModInvId + "," + subModelFirstModVerId;
}
String modelVerId = thisElementsModelVerVtx.<String>property("model-version-id").orElse(null);
@@ -2501,7 +2514,7 @@ public class ModelBasedProcessing{
Vertex elVert = (Vertex)(entry.getValue());
String tmpElVid = elVert.id().toString();
String tmpElNT = getModElementWidgetType( elVert, thisGuysTrail );
- String tmpElStepName = getModelElementStepName( elVert, thisGuysTrail, dbMaps );
+ String tmpElStepName = getModelElementStepName( elVert, thisGuysTrail);
List<String> linkagePtList = new ArrayList <String>();
Iterator <VertexProperty<Object>> vpI = elVert.properties("linkage-points");
@@ -2519,19 +2532,19 @@ public class ModelBasedProcessing{
// rest of this "trail"
for( int i = 0; i < linkagePtList.size(); i++ ){
Multimap<String, String> tmpMap = collectTopology4LinkagePoint( transId, fromAppId,
- linkagePtList.get(i), thisGuysTrail, currentMap, dbMaps);
+ linkagePtList.get(i), thisGuysTrail, currentMap);
thisMap.putAll(tmpMap);
}
}
else {
- check4EdgeRule(tmpElNT, thisElementNodeType, dbMaps);
+ check4EdgeRule(tmpElNT, thisElementNodeType);
thisMap.put(thisGuysTrail, tmpElStepName);
if( !thisTrailsVidsTraversed.contains(tmpElVid) ){
// This is one we would like to use - so we'll recursively get it's result set to add to ours
Multimap<String, String> tmpMap = collectTopology4ModelVer( transId, fromAppId,
elVert, thisGuysTrail,
currentMap, thisTrailsVidsTraversed, levelCounter,
- dbMaps, modConstraintHash2Use, subModelFirstModInvId, subModelFirstModVerId );
+ modConstraintHash2Use, subModelFirstModInvId, subModelFirstModVerId );
thisMap.putAll(tmpMap);
}
else {
@@ -2556,10 +2569,10 @@ public class ModelBasedProcessing{
*
* @param nodeTypeA the node type A
* @param nodeTypeB the node type B
- * @param dbMaps the db maps
+ * @param loader the db maps
* @throws AAIException the AAI exception
*/
- public void check4EdgeRule( String nodeTypeA, String nodeTypeB, DbMaps dbMaps ) throws AAIException {
+ public void check4EdgeRule( String nodeTypeA, String nodeTypeB) throws AAIException {
// Throw an exception if there is no defined edge rule for this combination of nodeTypes in DbEdgeRules.
final EdgeRules edgeRules = EdgeRules.getInstance();
@@ -2568,21 +2581,25 @@ public class ModelBasedProcessing{
&& !edgeRules.hasEdgeRule(nodeTypeB, nodeTypeA) ){
// There's no EdgeRule for this -- find out if one of the nodeTypes is invalid or if
// they are valid, but there's just no edgeRule for them.
- if( ! dbMaps.NodeProps.containsKey(nodeTypeA) ){
+ try {
+ loader.introspectorFromName(nodeTypeA);
+ } catch (AAIUnknownObjectException e) {
String emsg = " Unrecognized nodeType aa [" + nodeTypeA + "]\n";
throw new AAIException("AAI_6115", emsg);
}
- else if( ! dbMaps.NodeProps.containsKey(nodeTypeB) ){
+ try {
+ loader.introspectorFromName(nodeTypeB);
+ } catch (AAIUnknownObjectException e) {
String emsg = " Unrecognized nodeType bb [" + nodeTypeB + "]\n";
throw new AAIException("AAI_6115", emsg);
}
- else {
+ } else {
String msg = " No Edge Rule found for this pair of nodeTypes (order does not matter) ["
+ nodeTypeA + "], [" + nodeTypeB + "].";
throw new AAIException("AAI_6120", msg);
- }
}
+
}
@@ -2594,12 +2611,12 @@ public class ModelBasedProcessing{
* @param linkagePointStr -- Note it is in reverse order from where we connect to it.
* @param incomingTrail -- trail of nodeTypes that got us here (this vertex) from the top
* @param currentMap the current map -- that got us to this point (that we will use as the base of the map we will return)
- * @param dbMaps the db maps
+ * @param loader the db maps
* @return Map of the topology
* @throws AAIException the AAI exception
*/
public Multimap<String, String> collectTopology4LinkagePoint( String transId, String fromAppId,
- String linkagePointStrVal, String incomingTrail, Multimap <String,String> currentMap, DbMaps dbMaps )
+ String linkagePointStrVal, String incomingTrail, Multimap <String,String> currentMap)
throws AAIException {
Multimap <String, String> thisMap = ArrayListMultimap.create();
@@ -2641,7 +2658,7 @@ public class ModelBasedProcessing{
}
for( int i=(linkageSteps.length - 1); i >= 0; i-- ){
thisStepNT = linkageSteps[i];
- check4EdgeRule(lastStepNT, thisStepNT, dbMaps);
+ check4EdgeRule(lastStepNT, thisStepNT);
thisMap.put(thisGuysTrail, thisStepNT);
thisGuysTrail = thisGuysTrail + "|" + thisStepNT;
lastStepNT = thisStepNT;
@@ -3062,11 +3079,11 @@ public class ModelBasedProcessing{
*
* @param elementVtx the model-element vtx
* @param elementTrail the element trail
- * @param dbMaps the db maps
+ * @param loader the db maps
* @return the element step name
* @throws AAIException the AAI exception
*/
- public String getModelElementStepName( Vertex elementVtx, String elementTrail, DbMaps dbMaps)
+ public String getModelElementStepName( Vertex elementVtx, String elementTrail)
throws AAIException {
// Get the "step name" for a model-element
@@ -3106,7 +3123,7 @@ public class ModelBasedProcessing{
}
String stepName = "";
- if( nodeTypeSupportsPersona(thisElementNodeType, dbMaps) ){
+ if( nodeTypeSupportsPersona(thisElementNodeType) ){
// This nodeType that this resource or service model refers to does support persona-related fields, so
// we will use model-invariant-id and model-version-id as part of the step name.
stepName = thisElementNodeType + "," + modInvId + "," + modVerId;
@@ -3129,25 +3146,26 @@ public class ModelBasedProcessing{
* Node type supports persona.
*
* @param nodeType the node type
- * @param dbMaps the db maps
+ * @param loader the db maps
* @return the boolean
* @throws AAIException the AAI exception
*/
- public Boolean nodeTypeSupportsPersona(String nodeType, DbMaps dbMaps)
+ public Boolean nodeTypeSupportsPersona(String nodeType)
throws AAIException {
if( nodeType == null || nodeType.equals("") ){
return false;
}
-
- // Return true if this type of node supports the properties: "model-invariant-id-local" and "model-version-id-local"
- if( ! dbMaps.NodeProps.containsKey(nodeType) ){
+ Introspector obj = null;
+ try {
+ obj = loader.introspectorFromName(nodeType);
+ } catch (AAIUnknownObjectException e) {
String emsg = " Unrecognized nodeType [" + nodeType + "]\n";
- throw new AAIException("AAI_6115", emsg);
- }
+ throw new AAIException("AAI_6115", emsg);
+ }
- Collection <String> props4ThisNT = dbMaps.NodeProps.get(nodeType);
- if( !props4ThisNT.contains("model-invariant-id-local") || !props4ThisNT.contains("model-version-id-local") ){
+ Collection <String> props4ThisNT = loader.introspectorFromName(nodeType).getProperties();
+ if( !props4ThisNT.contains(addDBAliasedSuffix("model-invariant-id")) || !props4ThisNT.contains(addDBAliasedSuffix("model-version-id")) ){
return false;
}
else {
@@ -3582,7 +3600,6 @@ public class ModelBasedProcessing{
// Note - this will throw an exception if the model either can't be found, or if
// we can't figure out its topology map.
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
Vertex modelVerVtx = getNodeUsingUniqueId(transId, fromAppId, "model-ver",
"model-version-id", modelVersionIdVal);
if( modelVerVtx == null ){
@@ -3591,7 +3608,7 @@ public class ModelBasedProcessing{
}
else {
Multimap<String, String> topoMap = genTopoMap4ModelVer( transId, fromAppId,
- modelVerVtx, modelVersionIdVal, dbMaps );
+ modelVerVtx, modelVersionIdVal);
String msg = " modelVer [" + modelVersionIdVal + "] topo multiMap looks like: \n[" + topoMap + "]";
System.out.println("INFO -- " + msg );
}
@@ -3711,7 +3728,19 @@ public class ModelBasedProcessing{
}
QueryBuilder builder = this.engine.getQueryBuilder(startV).union(builders);
return builder;
+ }
+ private String addDBAliasedSuffix(String propName) {
+ return propName + AAIProperties.DB_ALIAS_SUFFIX;
+ }
+
+ protected String getPropNameWithAliasIfNeeded(String nodeType, String propName) throws AAIUnknownObjectException {
+
+ String retPropName = propName;
+ if( loader.introspectorFromName(nodeType).getPropertyMetadata(propName, PropertyMetadata.DB_ALIAS).isPresent() ){
+ return propName + AAIProperties.DB_ALIAS_SUFFIX;
+ }
+ return retPropName;
}
}
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/RelationshipGraph.java b/aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/RelationshipGraph.java
deleted file mode 100644
index 8277b2c..0000000
--- a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/RelationshipGraph.java
+++ /dev/null
@@ -1,299 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * Copyright (C) 2017 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.aai.dbgraphmap;
-
-import java.io.UnsupportedEncodingException;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.commons.collections.map.MultiValueMap;
-import org.eclipse.persistence.dynamic.DynamicEntity;
-import org.eclipse.persistence.dynamic.DynamicType;
-import org.eclipse.persistence.jaxb.dynamic.DynamicJAXBContext;
-
-import org.openecomp.aai.dbgen.DbMeth;
-import org.openecomp.aai.dbgraphgen.DbEdgeGroup;
-import org.openecomp.aai.domain.model.AAIResources;
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.extensions.AAIExtensionMap;
-import org.openecomp.aai.util.AAIConfig;
-import org.openecomp.aai.util.AAIConstants;
-import org.openecomp.aai.util.RestURL;
-import com.thinkaurelius.titan.core.TitanTransaction;
-import com.thinkaurelius.titan.core.TitanVertex;
-
-public class RelationshipGraph {
-
- /**
- * this method processes the one relationship for the startVertex that is
- * sent.
- *
- * @param g the g
- * @param startVertex the start vertex
- * @param jaxbContext the jaxb context
- * @param rel the rel
- * @param aaiExtMap the aai ext map
- * @throws AAIException the AAI exception
- */
- public static void updRelationship(TitanTransaction g, TitanVertex startVertex,
- DynamicJAXBContext jaxbContext,
- DynamicEntity rel,
- AAIExtensionMap aaiExtMap)
- throws AAIException {
- String apiVersion = aaiExtMap.getApiVersion();
- String transId = aaiExtMap.getTransId();
- String fromAppId = aaiExtMap.getFromAppId();
- MultiValueMap relatedNodesMap = new MultiValueMap();
-
- if( rel != null ){
- HashMap<String, Object> propFilterHash = new HashMap<String, Object>();
- poplatePropertyHashWithRelData(rel, apiVersion, propFilterHash);
- String relNodeType = (String)rel.get("relatedTo");
- relatedNodesMap.put(relNodeType, propFilterHash);
- }
- DbEdgeGroup.replaceEdgeGroup(transId, fromAppId, g, startVertex,
- "ONLY_PASSED_COUSINS_REL", relatedNodesMap, apiVersion);
-
- }
-
- /**
- * Poplate property hash with rel data.
- *
- * @param rel the rel
- * @param apiVersion the api version
- * @param propFilterHash the prop filter hash
- * @throws AAIException the AAI exception
- */
- private static void poplatePropertyHashWithRelData(DynamicEntity rel, String apiVersion,
- HashMap<String, Object> propFilterHash) throws AAIException {
-
- for( DynamicEntity relData: (List<DynamicEntity>)rel.get("relationshipData")) {
- String prop = ((String)relData.get("relationshipKey")).toLowerCase().trim();
- propFilterHash.put(prop, ((String)relData.get("relationshipValue")).trim());
- }
- }
-
- /**
- * this method gets any relationships for the startVertex being processed
- * and sets the related-link.
- *
- * @param g the g
- * @param startVertex the start vertex
- * @param apiVersion the api version
- * @param aaiExtMap the aai ext map
- * @return the relationships
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static DynamicEntity getRelationships(TitanTransaction g, TitanVertex startVertex,
- String apiVersion, AAIExtensionMap aaiExtMap)
- throws AAIException, UnsupportedEncodingException {
-
- DynamicType relationshipsType = null;
- DynamicType relationshipType = null;
- DynamicType relationshipDataType = null;
- DynamicType relatedToPropertyType = null;
-
- Boolean setRelatedToProperty = true;
-
- AAIResources aaiResources = org.openecomp.aai.ingestModel.IngestModelMoxyOxm.aaiResourceContainer
- .get(apiVersion);
-
- DynamicJAXBContext jaxbContext = aaiResources.getJaxbContext();
-
- //String apiVersion = aaiExtMap.getApiVersion();
- String transId = aaiExtMap.getTransId();
- String fromAppId = aaiExtMap.getFromAppId();
-
- HashMap <String, String> vidToNodeTypeHash = new HashMap <String, String>();
- HashMap <String, TitanVertex> vidToVertexHash = new HashMap <String, TitanVertex>();
-
- if ("v2".equals( apiVersion)) {
- relationshipsType = jaxbContext.getDynamicType("inventory.aai.openecomp.org.RelationshipList");
- relationshipType = jaxbContext.getDynamicType(".org.Relationship");
- relationshipDataType = jaxbContext.getDynamicType("inventory.aai.openecomp.org.RelationshipData");
- setRelatedToProperty = false;
- } else {
- relationshipsType = jaxbContext.getDynamicType("inventory.aai.openecomp.org." + apiVersion + ".RelationshipList");
- relationshipType = jaxbContext.getDynamicType("inventory.aai.openecomp.org." + apiVersion + ".Relationship");
- relationshipDataType = jaxbContext.getDynamicType("inventory.aai.openecomp.org." + apiVersion + ".RelationshipData");
- relatedToPropertyType = jaxbContext.getDynamicType("inventory.aai.openecomp.org." + apiVersion + ".RelatedToProperty");
- if (relatedToPropertyType == null) {
- setRelatedToProperty = false; // some versions do not support this
- }
- }
-
- DynamicEntity relationships = relationshipsType.newDynamicEntity();
- List<DynamicEntity> listOfRelationships = new ArrayList<DynamicEntity>();
-
- DbEdgeGroup.getEdgeGroup(transId,
- fromAppId,
- g,
- startVertex,
- vidToNodeTypeHash,
- vidToVertexHash,
- "ONLY_COUSIN_REL",
- AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
- // Convert the found relationships to a RelationshipList DynamicEntity
- for( Map.Entry<String, TitanVertex> entry : vidToVertexHash.entrySet() ){
-
- List<DynamicEntity> relationshipDataList = new ArrayList<DynamicEntity>();
- List<DynamicEntity> relatedToPropertyList = new ArrayList<DynamicEntity>();
-
- DynamicEntity relationship = relationshipType.newDynamicEntity();
-
- TitanVertex relNode = entry.getValue();
- String relNodeVid = entry.getKey();
- String relNodeType = vidToNodeTypeHash.get(relNodeVid);
- String relNodeURL = RestURL.get(g, relNode, apiVersion);
-
- HashMap <String, Object> nodeKeyPropsHash = RestURL.getKeyHashes(g, relNode, AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
- Iterator <Map.Entry<String,Object>>keyIterator = nodeKeyPropsHash.entrySet().iterator();
- while( keyIterator.hasNext() ){
- DynamicEntity relationshipData = relationshipDataType.newDynamicEntity();
- Map.Entry <String,Object>pair = (Map.Entry<String,Object>)keyIterator.next();
- String key = pair.getKey();
-
- if (!key.contains(".")) {
- key = relNodeType + "." + key;
- }
-
- String value = "";
- if( pair.getValue() != null ){
- value = pair.getValue().toString();
- }
-
- relationshipData.set("relationshipKey", key);
- relationshipData.set("relationshipValue", value);
-
- relationshipDataList.add(relationshipData);
- }
-
- if (setRelatedToProperty) {
- HashMap <String, Object> nodeNamePropsHash = DbMeth.getNodeNamePropHash(transId, fromAppId, g, relNode, AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
- Iterator <Map.Entry<String,Object>>nameIterator = nodeNamePropsHash.entrySet().iterator();
- while( nameIterator.hasNext() ){
- DynamicEntity relatedToProperty = relatedToPropertyType.newDynamicEntity();
- Map.Entry <String,Object>pair = (Map.Entry<String,Object>)nameIterator.next();
- String key = pair.getKey();
-
- if (!key.contains(".")) {
- key = relNodeType + "." + key;
- }
-
- String value = "";
- if( pair.getValue() != null ){
- value = pair.getValue().toString();
- }
- relatedToProperty.set("propertyKey", key);
- relatedToProperty.set("propertyValue", value);
-
- relatedToPropertyList.add(relatedToProperty);
-
- }
- relationship.set("relatedToProperty", relatedToPropertyList);
- }
- relationship.set("relatedTo", relNodeType);
- relationship.set("relatedLink", relNodeURL);
- relationship.set("relationshipData", relationshipDataList);
-
- listOfRelationships.add(relationship);
- }
- relationships.set("relationship", listOfRelationships);
- return relationships;
- }
-
- /**
- * this method processes any relationships for the startVertex being
- * processed.
- *
- * @param g the g
- * @param startVertex the start vertex
- * @param jaxbContext the jaxb context
- * @param relationshipList the relationship list
- * @param aaiExtMap the aai ext map
- * @throws AAIException the AAI exception
- */
- public static void updRelationships(TitanTransaction g, TitanVertex startVertex,
- DynamicJAXBContext jaxbContext,
- DynamicEntity relationshipList,
- AAIExtensionMap aaiExtMap)
- throws AAIException {
-
- String apiVersion = aaiExtMap.getApiVersion();
- String transId = aaiExtMap.getTransId();
- String fromAppId = aaiExtMap.getFromAppId();
- MultiValueMap relatedNodesMap = new MultiValueMap();
- if (relationshipList != null) {
- if( relationshipList.get("relationship") != null ){
- List <DynamicEntity> relListTmp = relationshipList.get("relationship");
- for( DynamicEntity rel: relListTmp) {
- HashMap<String, Object> propFilterHash = new HashMap<String, Object>();
- poplatePropertyHashWithRelData(rel, apiVersion, propFilterHash);
- String relNodeType = (String)rel.get("relatedTo");
- relatedNodesMap.put(relNodeType, propFilterHash);
-
-
- }
- }
- DbEdgeGroup.replaceEdgeGroup(transId, fromAppId, g, startVertex,
- "ALL_COUSIN_REL", relatedNodesMap, apiVersion);
- }
- }
-
- /**
- * this method deletes the relationship sent in for the startVertex being
- * processed.
- *
- * @param g the g
- * @param startVertex the start vertex
- * @param jaxbContext the jaxb context
- * @param rel the rel
- * @param aaiExtMap the aai ext map
- * @throws AAIException the AAI exception
- */
- public static void delRelationship(TitanTransaction g, TitanVertex startVertex,
- DynamicJAXBContext jaxbContext,
- DynamicEntity rel,
- AAIExtensionMap aaiExtMap)
- throws AAIException {
-
- String apiVersion = aaiExtMap.getApiVersion();
- String transId = aaiExtMap.getTransId();
- String fromAppId = aaiExtMap.getFromAppId();
- MultiValueMap relatedNodesMap = new MultiValueMap();
-
- if( rel != null ){
- HashMap<String, Object> propFilterHash = new HashMap<String, Object>();
- poplatePropertyHashWithRelData(rel, apiVersion, propFilterHash);
- String relNodeType = (String)rel.get("relatedTo");
- relatedNodesMap.put(relNodeType, propFilterHash);
- }
-
- DbEdgeGroup.deleteEdgeGroup(transId, fromAppId, g, startVertex,
- relatedNodesMap, apiVersion);
-
- }
-
-}
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/SearchGraph.java b/aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/SearchGraph.java
index 7ffc52e..d9e40c4 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/SearchGraph.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/dbgraphmap/SearchGraph.java
@@ -20,8 +20,6 @@
package org.openecomp.aai.dbgraphmap;
-import java.io.StringReader;
-import java.io.StringWriter;
import java.io.UnsupportedEncodingException;
import java.net.URI;
import java.util.ArrayList;
@@ -29,10 +27,8 @@ import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
-import java.util.ListIterator;
import java.util.Map;
import java.util.Optional;
-import java.util.Set;
import java.util.stream.Stream;
import javax.ws.rs.core.HttpHeaders;
@@ -40,7 +36,6 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.UriBuilderException;
import javax.xml.bind.JAXBException;
-import javax.xml.transform.stream.StreamSource;
import org.apache.tinkerpop.gremlin.process.traversal.P;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
@@ -50,25 +45,20 @@ import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.eclipse.persistence.dynamic.DynamicEntity;
import org.eclipse.persistence.dynamic.DynamicType;
import org.eclipse.persistence.exceptions.DynamicException;
-import org.eclipse.persistence.jaxb.JAXBMarshaller;
-import org.eclipse.persistence.jaxb.JAXBUnmarshaller;
-import org.eclipse.persistence.jaxb.MarshallerProperties;
import org.eclipse.persistence.jaxb.dynamic.DynamicJAXBContext;
-
import org.openecomp.aai.db.DbMethHelper;
import org.openecomp.aai.db.props.AAIProperties;
import org.openecomp.aai.dbgen.PropertyLimitDesc;
import org.openecomp.aai.dbgraphgen.ModelBasedProcessing;
import org.openecomp.aai.dbgraphgen.ResultSet;
import org.openecomp.aai.dbmap.DBConnectionType;
-import org.openecomp.aai.domain.model.AAIResources;
import org.openecomp.aai.exceptions.AAIException;
import org.openecomp.aai.extensions.AAIExtensionMap;
import org.openecomp.aai.introspection.Introspector;
import org.openecomp.aai.introspection.Loader;
import org.openecomp.aai.introspection.LoaderFactory;
import org.openecomp.aai.introspection.ModelType;
-import org.openecomp.aai.introspection.PropertyPredicates;
+import org.openecomp.aai.introspection.MoxyLoader;
import org.openecomp.aai.introspection.exceptions.AAIUnknownObjectException;
import org.openecomp.aai.parsers.relationship.RelationshipToURI;
import org.openecomp.aai.query.builder.QueryBuilder;
@@ -82,13 +72,8 @@ import org.openecomp.aai.serialization.engines.TitanDBEngine;
import org.openecomp.aai.serialization.engines.TransactionalGraphEngine;
import org.openecomp.aai.serialization.queryformats.exceptions.AAIFormatVertexException;
import org.openecomp.aai.serialization.queryformats.utils.UrlBuilder;
-import org.openecomp.aai.util.AAIApiServerURLBase;
-import org.openecomp.aai.util.AAIApiVersion;
-import org.openecomp.aai.util.AAIConfig;
-import org.openecomp.aai.util.AAIConstants;
-import org.openecomp.aai.util.PojoUtils;
-import org.openecomp.aai.util.RestURL;
import org.openecomp.aai.util.StoreNotificationEvent;
+
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import com.google.common.base.CaseFormat;
@@ -468,7 +453,7 @@ public class SearchGraph {
boolean isParallel = stream.isParallel();
stream.forEach(v -> {
String nodeType = v.<String>property(AAIProperties.NODE_TYPE).orElse(null);
-
+
String thisNodeURL;
try {
thisNodeURL = urlBuilder.pathed(v);
@@ -486,7 +471,7 @@ public class SearchGraph {
} catch (AAIException | AAIFormatVertexException e) {
throw new RuntimeException(e);
}
-
+
});
return searchResults;
}
@@ -531,13 +516,6 @@ public class SearchGraph {
public Response runNamedQuery(String fromAppId, String transId, String queryParameters,
DBConnectionType connectionType,
AAIExtensionMap aaiExtMap) throws JAXBException, AAIException {
- // TODO Auto-generated method stub
- AAIResources aaiResources = org.openecomp.aai.ingestModel.IngestModelMoxyOxm.aaiResourceContainer
- .get(aaiExtMap.getApiVersion());
- DynamicJAXBContext jaxbContext = aaiResources.getJaxbContext();
- JAXBUnmarshaller unmarshaller = jaxbContext.createUnmarshaller();
-
- //String dynamicClass = aaiRes.getResourceClassName();
Introspector inventoryItems;
boolean success = true;
@@ -545,7 +523,8 @@ public class SearchGraph {
TransactionalGraphEngine dbEngine = null;
try {
- Loader loader = LoaderFactory.createLoaderForVersion(ModelType.MOXY, AAIProperties.LATEST);
+ MoxyLoader loader = (MoxyLoader)LoaderFactory.createLoaderForVersion(ModelType.MOXY, AAIProperties.LATEST);
+ DynamicJAXBContext jaxbContext = loader.getJAXBContext();
dbEngine = new TitanDBEngine(
QueryStyle.TRAVERSAL,
connectionType,
@@ -554,28 +533,20 @@ public class SearchGraph {
ModelBasedProcessing processor = new ModelBasedProcessing(loader, dbEngine, serializer);
g = dbEngine.startTransaction();
- if (aaiExtMap.getHttpServletRequest().getContentType() == null || // default to json
- aaiExtMap.getHttpServletRequest().getContentType().contains("application/json")) {
- unmarshaller.setProperty("eclipselink.media-type", "application/json");
- unmarshaller.setProperty("eclipselink.json.include-root", false);
+ org.openecomp.aai.restcore.MediaType mediaType = org.openecomp.aai.restcore.MediaType.APPLICATION_JSON_TYPE;
+ String contentType = aaiExtMap.getHttpServletRequest().getContentType();
+ if (contentType != null && contentType.contains("application/xml")) {
+ mediaType = org.openecomp.aai.restcore.MediaType.APPLICATION_XML_TYPE;
}
if (queryParameters.length() == 0) {
queryParameters = "{}";
- unmarshaller.setProperty("eclipselink.media-type", "application/json");
- unmarshaller.setProperty("eclipselink.json.include-root", false);
}
- String dynamicClass = "inventory.aai.openecomp.org." + aaiExtMap.getApiVersion() + ".ModelAndNamedQuerySearch";
- Class<? extends DynamicEntity> resultClass = jaxbContext.newDynamicEntity(dynamicClass).getClass();
-
- StringReader reader = new StringReader(queryParameters);
-
- DynamicEntity modelAndNamedQuerySearch = (DynamicEntity) unmarshaller.unmarshal(new StreamSource(reader), resultClass).getValue();
+ DynamicEntity modelAndNamedQuerySearch = (DynamicEntity)loader.unmarshal("ModelAndNamedQuerySearch", queryParameters, mediaType).getUnderlyingObject();
if (modelAndNamedQuerySearch == null) {
throw new AAIException("AAI_5105");
}
-
HashMap<String,Object> namedQueryLookupHash = new HashMap<String,Object>();
DynamicEntity qp = modelAndNamedQuerySearch.get("queryParameters");
@@ -668,20 +639,14 @@ public class SearchGraph {
DBConnectionType connectionType,
boolean isDelete,
AAIExtensionMap aaiExtMap) throws JAXBException, AAIException, DynamicException, UnsupportedEncodingException {
- // TODO Auto-generated method stub
- AAIResources aaiResources = org.openecomp.aai.ingestModel.IngestModelMoxyOxm.aaiResourceContainer
- .get(aaiExtMap.getApiVersion());
- DynamicJAXBContext jaxbContext = aaiResources.getJaxbContext();
- JAXBUnmarshaller unmarshaller = jaxbContext.createUnmarshaller();
-
- //String dynamicClass = aaiRes.getResourceClassName();
Response response;
boolean success = true;
TitanTransaction g = null;
TransactionalGraphEngine dbEngine = null;
try {
- Loader loader = LoaderFactory.createLoaderForVersion(ModelType.MOXY, AAIProperties.LATEST);
+ MoxyLoader loader = (MoxyLoader) LoaderFactory.createLoaderForVersion(ModelType.MOXY, AAIProperties.LATEST);
+ DynamicJAXBContext jaxbContext = loader.getJAXBContext();
dbEngine = new TitanDBEngine(
QueryStyle.TRAVERSAL,
connectionType,
@@ -691,24 +656,20 @@ public class SearchGraph {
g = dbEngine.startTransaction();
- if (aaiExtMap.getHttpServletRequest().getContentType() == null || // default to json
- aaiExtMap.getHttpServletRequest().getContentType().contains("application/json")) {
- unmarshaller.setProperty("eclipselink.media-type", "application/json");
- unmarshaller.setProperty("eclipselink.json.include-root", false);
+ org.openecomp.aai.restcore.MediaType mediaType = org.openecomp.aai.restcore.MediaType.APPLICATION_JSON_TYPE;
+ String contentType = aaiExtMap.getHttpServletRequest().getContentType();
+ if (contentType != null && contentType.contains("application/xml")) {
+ mediaType = org.openecomp.aai.restcore.MediaType.APPLICATION_XML_TYPE;
}
if (queryParameters.length() == 0) {
queryParameters = "{}";
- unmarshaller.setProperty("eclipselink.media-type", "application/json");
- unmarshaller.setProperty("eclipselink.json.include-root", false);
}
- String dynamicClass = "inventory.aai.openecomp.org." + aaiExtMap.getApiVersion() + ".ModelAndNamedQuerySearch";
- Class<? extends DynamicEntity> resultClass = jaxbContext.newDynamicEntity(dynamicClass).getClass();
-
- StringReader reader = new StringReader(queryParameters);
-
- DynamicEntity modelAndNamedQuerySearch = (DynamicEntity) unmarshaller.unmarshal(new StreamSource(reader), resultClass).getValue();
+ DynamicEntity modelAndNamedQuerySearch = (DynamicEntity)loader.unmarshal("ModelAndNamedQuerySearch", queryParameters, mediaType).getUnderlyingObject();
+ if (modelAndNamedQuerySearch == null) {
+ throw new AAIException("AAI_5105");
+ }
if (modelAndNamedQuerySearch == null) {
throw new AAIException("AAI_5105");
}
@@ -797,7 +758,6 @@ public class SearchGraph {
ResultSet rs = resultSet.get(0);
TitanVertex firstVert = rs.getVert();
- String restURL = RestURL.get(g, firstVert);
Map<String,String> delResult = processor.runDeleteByModel( transId, fromAppId,
modelVersionId, topNodeType, startNodeFilterHash.get(0), aaiExtMap.getApiVersion(), resourceVersion );
@@ -814,20 +774,17 @@ public class SearchGraph {
List<DynamicEntity> newInvItemList = new ArrayList<DynamicEntity>();
newInvItemList.add(topInvItem);
inventoryItems.set("inventoryResponseItem", newInvItemList);
+ String notificationVersion = AAIProperties.LATEST.toString();
- // put the inventoryItems in a UEB notification object
- String notificationVersion = AAIConfig.get("aai.notification.current.version");
-
- AAIResources aaiNotificationResources = org.openecomp.aai.ingestModel.IngestModelMoxyOxm.aaiResourceContainer
- .get(notificationVersion);
-
- DynamicJAXBContext notificationJaxbContext = aaiNotificationResources.getJaxbContext();
+ String restURI = serializer.getURIForVertex(firstVert).toString();
- DynamicEntity notificationHeader = notificationJaxbContext
- .getDynamicType("inventory.aai.openecomp.org." + notificationVersion + ".NotificationEventHeader")
- .newDynamicEntity();
-
- notificationHeader.set("entityLink", restURL);
+ if (restURI.startsWith("/")) {
+ restURI = "/aai/" + notificationVersion + restURI;
+ } else {
+ restURI = "/aai/" + notificationVersion + "/" + restURI;
+ }
+ DynamicEntity notificationHeader = (DynamicEntity) loader.introspectorFromName("notification-event-header").getUnderlyingObject();
+ notificationHeader.set("entityLink", restURI);
notificationHeader.set("action", "DELETE");
notificationHeader.set("entityType", "inventory-response-items");
@@ -837,7 +794,7 @@ public class SearchGraph {
StoreNotificationEvent sne = new StoreNotificationEvent(transId, fromAppId);
- sne.storeDynamicEvent(notificationJaxbContext, notificationVersion, notificationHeader, inventoryItems);
+ sne.storeDynamicEvent(loader.getJAXBContext(), notificationVersion, notificationHeader, inventoryItems);
response = Response.ok(resultStr).build();
@@ -1059,8 +1016,7 @@ public class SearchGraph {
String aaiNodeType = vert.<String>property("aai-node-type").orElse(null);
-
- PojoUtils pu = new PojoUtils();
+
if (aaiNodeType != null) {
Introspector thisObj = loader.introspectorFromName(aaiNodeType);
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSInInterceptor.java b/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSInInterceptor.java
index 80127d0..7480c05 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSInInterceptor.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSInInterceptor.java
@@ -21,11 +21,8 @@
package org.openecomp.aai.interceptors;
import java.io.InputStream;
-import java.text.DateFormat;
-import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
-import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.UUID;
@@ -39,13 +36,14 @@ import org.apache.cxf.helpers.CastUtils;
import org.apache.cxf.interceptor.LoggingMessage;
import org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor;
import org.apache.cxf.message.Message;
-
import org.openecomp.aai.exceptions.AAIException;
import org.openecomp.aai.logging.ErrorLogHelper;
import org.openecomp.aai.rest.util.EchoResponse;
import org.openecomp.aai.util.AAIConfig;
import org.openecomp.aai.util.AAIConstants;
+import org.openecomp.aai.util.FormatDate;
import org.openecomp.aai.util.HbaseSaltPrefixer;
+
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
@@ -265,19 +263,8 @@ public class AAILogJAXRSInInterceptor extends JAXRSInInterceptor {
* @return the string
*/
protected String genDate() {
- Date date = new Date();
- DateFormat formatter = null;
- try {
- formatter = new SimpleDateFormat(AAIConfig.get(AAIConstants.HBASE_TABLE_TIMESTAMP_FORMAT));
- } catch (AAIException ex) {
- ErrorLogHelper.logException(ex);
- } finally {
- if (formatter == null) {
- formatter = new SimpleDateFormat("YYMMdd-HH:mm:ss:SSS");
- }
- }
-
- return formatter.format(date);
+ FormatDate fd = new FormatDate(AAIConfig.get(AAIConstants.HBASE_TABLE_TIMESTAMP_FORMAT, "YYMMdd-HH:mm:ss:SSS"));
+ return fd.getDateTime();
}
}
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSOutInterceptor.java b/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSOutInterceptor.java
index 0f5e457..563500e 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSOutInterceptor.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/interceptors/AAILogJAXRSOutInterceptor.java
@@ -21,10 +21,7 @@
package org.openecomp.aai.interceptors;
import java.io.OutputStream;
-import java.text.DateFormat;
-import java.text.SimpleDateFormat;
import java.util.Collections;
-import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -36,11 +33,12 @@ import org.apache.cxf.io.CachedOutputStream;
import org.apache.cxf.io.CachedOutputStreamCallback;
import org.apache.cxf.jaxrs.interceptor.JAXRSOutInterceptor;
import org.apache.cxf.message.Message;
-
import org.openecomp.aai.exceptions.AAIException;
import org.openecomp.aai.logging.ErrorLogHelper;
import org.openecomp.aai.util.AAIConfig;
import org.openecomp.aai.util.AAIConstants;
+import org.openecomp.aai.util.FormatDate;
+
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
@@ -269,34 +267,15 @@ public class AAILogJAXRSOutInterceptor extends JAXRSOutInterceptor {
}
protected String genDate() {
- Date date = new Date();
- DateFormat formatter = null;
- try {
- formatter = new SimpleDateFormat(AAIConfig.get(AAIConstants.HBASE_TABLE_TIMESTAMP_FORMAT));
- } catch (AAIException ex) {
- ErrorLogHelper.logException(ex);
- } finally {
- if (formatter == null) {
- formatter = new SimpleDateFormat("YYMMdd-HH:mm:ss:SSS");
- }
- }
- return formatter.format(date);
+ FormatDate fd = new FormatDate(AAIConfig.get(AAIConstants.HBASE_TABLE_TIMESTAMP_FORMAT, "YYMMdd-HH:mm:ss:SSS"));
+ return fd.getDateTime();
}
public String putTransaction(String tid, String status, String rqstTm, String respTm, String srcId, String rsrcId, String rsrcType, String rqstBuf, String respBuf, String actualResponse) {
String tm = null;
- String fromAppId = srcId.substring(0, srcId.indexOf(':'));
- String transId = srcId.substring(srcId.indexOf(':') + 1);
if (tid == null || "".equals(tid)) {
- Date date = new Date();
- DateFormat formatter = null;
- try {
- formatter = new SimpleDateFormat(AAIConfig.get(AAIConstants.HBASE_TABLE_TIMESTAMP_FORMAT));
- } catch (Exception e) {
- formatter = new SimpleDateFormat("YYYYMMdd-HH:mm:ss:SSS");
- }
- tm = formatter.format(date);
+ tm = this.genDate();
tid = tm + "-";
}
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/rest/search/SearchProvider.java b/aai-traversal/src/main/java/org/openecomp/aai/rest/search/SearchProvider.java
index d6712ce..844f375 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/rest/search/SearchProvider.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/rest/search/SearchProvider.java
@@ -24,9 +24,7 @@ import java.util.ArrayList;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
-import javax.ws.rs.Consumes;
import javax.ws.rs.GET;
-import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
@@ -36,19 +34,11 @@ import javax.ws.rs.core.HttpHeaders;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.Status;
-import javax.ws.rs.core.UriInfo;
-
-import org.eclipse.persistence.dynamic.DynamicEntity;
-import org.eclipse.persistence.jaxb.dynamic.DynamicJAXBContext;
import org.openecomp.aai.db.props.AAIProperties;
import org.openecomp.aai.dbgraphmap.SearchGraph;
import org.openecomp.aai.dbmap.DBConnectionType;
-import org.openecomp.aai.domain.model.AAIResource;
-import org.openecomp.aai.domain.model.AAIResources;
import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.extensions.AAIExtensionMap;
-import org.openecomp.aai.ingestModel.IngestModelMoxyOxm;
import org.openecomp.aai.introspection.Loader;
import org.openecomp.aai.introspection.LoaderFactory;
import org.openecomp.aai.introspection.ModelType;
@@ -60,7 +50,6 @@ import org.openecomp.aai.serialization.engines.QueryStyle;
import org.openecomp.aai.serialization.engines.TitanDBEngine;
import org.openecomp.aai.serialization.engines.TransactionalGraphEngine;
import org.openecomp.aai.serialization.queryformats.utils.UrlBuilder;
-import org.openecomp.aai.util.AAIApiVersion;
/**
* Implements the search subdomain in the REST API. All API calls must include
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/rest/ueb/UEBNotification.java b/aai-traversal/src/main/java/org/openecomp/aai/rest/ueb/UEBNotification.java
index 8cb16e1..c50dbab 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/rest/ueb/UEBNotification.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/rest/ueb/UEBNotification.java
@@ -51,7 +51,7 @@ public class UEBNotification {
private Loader currentVersionLoader = null;
protected List<NotificationEvent> events = null;
private Version notificationVersion = null;
-
+
/**
* Instantiates a new UEB notification.
*
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/util/RestURL.java b/aai-traversal/src/main/java/org/openecomp/aai/util/RestURL.java
deleted file mode 100644
index 7c70929..0000000
--- a/aai-traversal/src/main/java/org/openecomp/aai/util/RestURL.java
+++ /dev/null
@@ -1,704 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * Copyright (C) 2017 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.aai.util;
-
-import java.io.UnsupportedEncodingException;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.LinkedHashMap;
-
-import org.apache.tinkerpop.gremlin.structure.Direction;
-import org.apache.tinkerpop.gremlin.structure.Edge;
-import org.springframework.web.util.UriUtils;
-
-import org.openecomp.aai.domain.model.AAIResource;
-import org.openecomp.aai.domain.model.AAIResourceKey;
-import org.openecomp.aai.domain.model.AAIResourceKeys;
-import org.openecomp.aai.domain.model.AAIResources;
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.extensions.AAIExtensionMap;
-import org.openecomp.aai.ingestModel.DbMaps;
-import org.openecomp.aai.ingestModel.IngestModelMoxyOxm;
-import com.google.common.base.CaseFormat;
-import com.thinkaurelius.titan.core.TitanEdge;
-import com.thinkaurelius.titan.core.TitanTransaction;
-import com.thinkaurelius.titan.core.TitanVertex;
-
-public class RestURL {
-
-
- /*
- * method returns a REST URL for the given node based on its nodetype and key
- * information
- */
-
- /**
- * Gets the.
- *
- * @param graph the graph
- * @param node the node
- * @param apiVersion the api version
- * @param isLegacyVserverUEB the is legacy vserver UEB
- * @param isCallbackurl the is callbackurl
- * @return the string
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static String get(TitanTransaction graph, TitanVertex node, String apiVersion, Boolean isLegacyVserverUEB, Boolean isCallbackurl) throws AAIException, UnsupportedEncodingException
- {
- String nodeType = node.<String>property("aai-node-type").orElse(null);
- String url = "";
- String currentNodeType = nodeType;
- Boolean noMoreDependentNodes = true;
- TitanVertex currentNode = node;
-
- // if the caller supplies an apiVersion we'll use it, otherwise we'll just
- // reflect back from the called URI
- if (apiVersion == null) {
- apiVersion = AAIApiVersion.get();
- }
-
- String nodeURI = null;
- if (Boolean.parseBoolean(AAIConfig.get("aai.use.unique.key", "false")))
- nodeURI = node.<String>property("aai-unique-key").orElse(null);
-
- if (nodeURI != null && !nodeURI.equals("")) {
- if (isCallbackurl) {
- url = AAIConfig.get(AAIConstants.AAI_GLOBAL_CALLBACK_URL) + apiVersion + "/" + nodeURI;
- return url;
- } else {
- url = AAIApiServerURLBase.get() + apiVersion + "/" + nodeURI;
- return url;
- }
- }
-
- // TODO
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- // add the url component for the dependent on nodes for the node passed in
- while (noMoreDependentNodes) {
- Collection <String> depNodeTypeColl = dbMaps.NodeDependencies.get(currentNodeType);
- Iterator <String> depNodeTypeListIterator = (Iterator<String>) depNodeTypeColl.iterator();
- if (!depNodeTypeListIterator.hasNext()) {
- noMoreDependentNodes = false;
- break;
- }
-
- // Look for IN edges for the current Node and find its Parent - and make it the current Node
- boolean foundParent = false;
- Iterator <Edge> inEdges = currentNode.edges(Direction.IN);
- while( inEdges.hasNext() ){
- TitanEdge inEdge = (TitanEdge) inEdges.next();
- Boolean inEdgeIsParent = inEdge.<Boolean>property("isParent").orElse(null);
- if( inEdgeIsParent != null && inEdgeIsParent ){
- foundParent = true;
- currentNode = (TitanVertex) inEdge.otherVertex(currentNode);
- break;
- }
- }
-
- if (foundParent == false) {
- break;
- }
-
- // find the key(s) and add to the url
- // first see what type of node the parent is - note some nodes can have one of many kinds of parents
- String depNodeType = currentNode.<String>property("aai-node-type").orElse(null);
- Collection <String> keyProps = dbMaps.NodeKeyProps.get(depNodeType);
- Iterator <String> keyPropI = keyProps.iterator();
-
- String nodeUrl = null;
- String depNodeTypePlural = dbMaps.NodePlural.get(depNodeType);
-
- if (depNodeTypePlural != null)
- {
- nodeUrl = depNodeTypePlural + "/" + depNodeType + "/";
- }
-
- while (keyPropI.hasNext()) {
- Object nodeKey = currentNode.<Object>property(keyPropI.next()).orElse(null);
- nodeUrl += RestURLEncoder.encodeURL(nodeKey.toString()) + "/";
- }
-
- currentNodeType = depNodeType;
-
- url = nodeUrl + url;
- }
- // use the name space of the highest level of unique node since lots of children node types
- // are common ex. l-interface is in the path for pserver and vpe
- String urlNamespace = dbMaps.NodeNamespace.get(currentNodeType) + "/";
- urlNamespace = CaseFormat.UPPER_CAMEL.to(CaseFormat.LOWER_HYPHEN, urlNamespace);
-
- // add the url component for the node passed in
- Collection <String> keyProps = dbMaps.NodeKeyProps.get(nodeType);
- Iterator <String> keyPropI = keyProps.iterator();
-
- String nodeUrl = null;
- String nodeTypePlural = "";
- nodeTypePlural = dbMaps.NodePlural.get(nodeType);
-
-
- if (nodeTypePlural != null && !nodeTypePlural.equals("")){
- nodeUrl = nodeTypePlural + "/" + nodeType + "/";
- } else {
- nodeUrl = nodeType + "/";
- }
-
- if (nodeType.equals("ipaddress")) { // this has 2 keys but API only uses port-or -address in URL
- String nodeKey = node.<String>property("port-or-interface").orElse(null);
- nodeUrl += RestURLEncoder.encodeURL(nodeKey) + "/";
- } else {
- while (keyPropI.hasNext()) {
- Object nodeKey = node.<Object>property(keyPropI.next()).orElse(null);
- nodeUrl += RestURLEncoder.encodeURL(nodeKey.toString()) + "/";
- }
- }
- if (isCallbackurl) {
- url = AAIConfig.get(AAIConstants.AAI_GLOBAL_CALLBACK_URL) + apiVersion + "/" + urlNamespace + url + nodeUrl;
- } else {
- url = AAIApiServerURLBase.get() + apiVersion + "/" + urlNamespace + url + nodeUrl;
- }
- return url;
- }
-
- /**
- * Gets the search url.
- *
- * @param graph the graph
- * @param node the node
- * @param apiVersion the api version
- * @return the search url
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static String getSearchUrl(TitanTransaction graph, TitanVertex node, String apiVersion) throws AAIException, UnsupportedEncodingException
- {
- String nodeType = node.<String>property("aai-node-type").orElse(null);
- String url = "";
- String currentNodeType = nodeType;
- Boolean noMoreDependentNodes = true;
- TitanVertex currentNode = node;
- Boolean hasCloudRegion = false;
-
- // if the caller supplies an apiVersion we'll use it, otherwise we'll just
- // reflect back from the called URI
- if (apiVersion == null) {
- apiVersion = AAIApiVersion.get();
- }
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP));
-
- // add the url component for the dependent on nodes for the node passed in
- while (noMoreDependentNodes) {
- Collection <String> depNodeTypeColl = dbMaps.NodeDependencies.get(currentNodeType);
- Iterator <String> depNodeTypeListIterator = (Iterator<String>) depNodeTypeColl.iterator();
- if (!depNodeTypeListIterator.hasNext()) {
- noMoreDependentNodes = false;
- break;
- }
-
- // Look for IN edges for the current Node and find its Parent - and make it the current Node
- boolean foundParent = false;
- Iterator <Edge> inEdges = currentNode.edges(Direction.IN);
- while( inEdges.hasNext() ){
- TitanEdge inEdge = (TitanEdge) inEdges.next();
- Boolean inEdgeIsParent = inEdge.<Boolean>property("isParent").orElse(null);
- if( inEdgeIsParent != null && inEdgeIsParent ){
- foundParent = true;
- currentNode = inEdge.otherVertex(currentNode);
- break;
- }
- }
-
- if (foundParent == false) {
- break;
- }
-
- // find the key(s) and add to the url
- // first see what type of node the parent is - note some nodes can have one of many kinds of parents
- String depNodeType = currentNode.<String>property("aai-node-type").orElse(null);
- Collection <String> keyProps = dbMaps.NodeKeyProps.get(depNodeType);
- Iterator <String> keyPropI = keyProps.iterator();
-
- String nodeUrl = null;
- String depNodeTypePlural = dbMaps.NodePlural.get(depNodeType);
-
- if (depNodeTypePlural != null)
- nodeUrl = depNodeTypePlural + "/" + depNodeType + "/";
-
- while (keyPropI.hasNext()) {
- Object nodeKey = currentNode.<Object>property(keyPropI.next()).orElse(null);
- nodeUrl += RestURLEncoder.encodeURL(nodeKey.toString()) + "/";
- }
-
- currentNodeType = depNodeType;
-
- url = nodeUrl + url;
- }
- // use the name space of the highest level of unique node since lots of children node types
- // are common ex. l-interface is in the path for pserver and vpe
- String urlNamespace = dbMaps.NodeNamespace.get(currentNodeType) + "/";
- urlNamespace = CaseFormat.UPPER_CAMEL.to(CaseFormat.LOWER_HYPHEN, urlNamespace);
-
- // add the url component for the node passed in
- Collection <String> keyProps = dbMaps.NodeKeyProps.get(nodeType);
- Iterator <String> keyPropI = keyProps.iterator();
-
- String nodeUrl = null;
- String nodeTypePlural = "";
- nodeTypePlural = dbMaps.NodePlural.get(nodeType);
-
- if (nodeTypePlural != null && !nodeTypePlural.equals(""))
- nodeUrl = nodeTypePlural + "/" + nodeType + "/";
- else
- nodeUrl = nodeType + "/";
-
- if (nodeType.equals("ipaddress")) { // this has 2 keys but API only uses port-or -address in URL
- String nodeKey = node.<String>property("port-or-interface").orElse(null);
- nodeUrl += RestURLEncoder.encodeURL(nodeKey) + "/";
- } else {
- while (keyPropI.hasNext()) {
- Object nodeKey = node.<Object>property(keyPropI.next()).orElse(null);
- nodeUrl += RestURLEncoder.encodeURL(nodeKey.toString()) + "/";
- }
- }
-
- String nodeVersion = dbMaps.NodeVersionInfoMap.get(nodeType);
- String urlVersion = null;
- int nodeVerNum = Integer.parseInt(nodeVersion.substring(1));
- int apiVerNum = Integer.parseInt(apiVersion.substring(1));
-
- if (hasCloudRegion) {
- if (apiVerNum < 7)
- urlVersion = "v7"; // or set to the latest version?
- else
- urlVersion = apiVersion;
- } else {
- if (nodeVerNum == apiVerNum || nodeVerNum < apiVerNum)
- urlVersion = apiVersion;
- else
- urlVersion = nodeVersion;
- }
- url = AAIApiServerURLBase.get() + urlVersion + "/" + urlNamespace + url + nodeUrl;
- //remove the trailing "/"
- url = url.substring(0, url.length()-1);
- return url;
- }
-
- /**
- * Gets the.
- *
- * @param graph the graph
- * @param node the node
- * @return the string
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static String get(TitanTransaction graph, TitanVertex node) throws AAIException, UnsupportedEncodingException
- {
- return get(graph, node, null, false, false);
- }
-
- /**
- * Gets the.
- *
- * @param graph the graph
- * @param node the node
- * @param apiVersion the api version
- * @return the string
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static String get(TitanTransaction graph, TitanVertex node, String apiVersion) throws AAIException, UnsupportedEncodingException
- {
- return get(graph, node, apiVersion, false, false);
- }
-
- /**
- * Gets the.
- *
- * @param graph the graph
- * @param node the node
- * @param apiVersion the api version
- * @param isLegacyVserverUEB the is legacy vserver UEB
- * @return the string
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static String get(TitanTransaction graph, TitanVertex node, String apiVersion, Boolean isLegacyVserverUEB) throws AAIException, UnsupportedEncodingException
- {
- return get(graph, node, apiVersion, isLegacyVserverUEB, false);
- }
-
- /**
- * Gets the key hashes.
- *
- * @param graph the graph
- * @param node the node
- * @return the key hashes
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static LinkedHashMap<String, Object> getKeyHashes(TitanTransaction graph, TitanVertex node) throws AAIException, UnsupportedEncodingException
- {
- return getKeyHashes(graph, node, null);
- }
-
- /*
- * method returns a Hash of Hashes for each parents keys for the given node based on its nodetype
- * Special cases for REST URLs:
- * - old URLS for vserver, ipaddress and volume node types for v2/v3
- * - images, flavor, vnic and l-interface node types will return new url
- * - nodetypes with multiple keys such as service capability
- * - nodetypes with multiple keys such as ipaddress where we use one key in the URL
- * - cvlan-tags and *list nodetypes - have special or no plurals - they get handled via the hash Map
- */
-
- /**
- * Gets the key hashes.
- *
- * @param graph the graph
- * @param node the node
- * @param apiVersion the api version
- * @return the key hashes
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static LinkedHashMap <String,Object> getKeyHashes(TitanTransaction graph, TitanVertex node, String apiVersion) throws AAIException, UnsupportedEncodingException
- {
- String nodeType = node.<String>property("aai-node-type").orElse(null);
- Boolean noMoreDependentNodes = true;
- TitanVertex currentNode = node;
-
- if (apiVersion == null || apiVersion.equals("")) {
- apiVersion = AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP);
- }
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(apiVersion);
-
- // Hash of hashes of keys for each node and its ancestry
- LinkedHashMap <String,Object> returnHash = new LinkedHashMap <String,Object> ();
-
- // create the hash for the keys for the node passed in
- HashMap <String,Object> thisNodeHash = new HashMap <String,Object> ();
- Collection <String> keyProps = dbMaps.NodeKeyProps.get(nodeType);
- Iterator <String> keyPropI = keyProps.iterator();
-
- if (nodeType.equals("ipaddress")) { // this has 2 keys but API only uses port-or -address in URL
- String nodeKeyValue = node.<String>property("port-or-interface").orElse(null);
- thisNodeHash.put("port-or-interface", nodeKeyValue);
- } else {
- while (keyPropI.hasNext()) {
- String nodeKeyName = keyPropI.next();
- Object nodeKeyValue = node.<Object>property(nodeKeyName).orElse(null);
- thisNodeHash.put(nodeKeyName, nodeKeyValue);
- nodeKeyName = nodeType + "." + nodeKeyName;
- }
- }
- returnHash.putAll(thisNodeHash);
-
- // create and add the hashes for the dependent nodes for the node passed in
- while (noMoreDependentNodes) {
-// Collection <String> depNodeTypeColl = DbRules.NodeDependencies.get(currentNodeType);
-// Iterator <String> depNodeTypeListIterator = (Iterator<String>) depNodeTypeColl.iterator();
- HashMap <String,Object> depNodeHash = new HashMap <String,Object> ();
-//
-// if (!depNodeTypeListIterator.hasNext()) {
-// noMoreDependentNodes = false;
-// break;
-// }
-
- boolean foundParent = false;
-
- // Look for IN edges for the current Node and find its Parent - and make it the current Node
- Iterator <Edge> inEdges = currentNode.edges(Direction.IN);
- while( inEdges.hasNext() ){
- TitanEdge inEdge = (TitanEdge) inEdges.next();
- Boolean inEdgeIsParent = inEdge.<Boolean>property("isParent").orElse(null);
- if( inEdgeIsParent != null && inEdgeIsParent ){
- currentNode = inEdge.otherVertex(currentNode);
- foundParent = true;
- break;
- }
- }
- if (foundParent == false) {
- break;
- }
-
- // find the key(s) and add to the url
- // first see what type of node the parent is - note some nodes can have one of many kinds of parents
- String depNodeType = currentNode.<String>property("aai-node-type").orElse(null);
- keyProps = dbMaps.NodeKeyProps.get(depNodeType);
- keyPropI = keyProps.iterator();
-
- while (keyPropI.hasNext()) {
- String nodeKeyName = keyPropI.next();
- Object nodeKeyValue = currentNode.<Object>property(nodeKeyName).orElse(null);
- nodeKeyName = depNodeType + "." + nodeKeyName;
- // key name will be like tenant.tenant-id
-
- depNodeHash.put(nodeKeyName, nodeKeyValue);
- }
- returnHash.putAll(depNodeHash);
- }
-
- return returnHash;
- }
-
- /*
- * method returns a Hash of Hashes for each parents keys for the given node based on its nodeURI
- * Special cases for REST URLs:
- * - images, flavor, vnic and l-interface node types will return new url
- * - nodetypes with multiple keys such as service capability
- * - nodetypes with multiple keys such as ipaddress where we use one key in the URL
- * - cvlan-tags and *list nodetypes - have special or no plurals - they get handled via the hash Map
- */
-
- /**
- * Gets the key hashes.
- *
- * @param nodeURI the node URI
- * @return the key hashes
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static LinkedHashMap <String,Object> getKeyHashes(String nodeURI) throws AAIException, UnsupportedEncodingException
- {
- return getKeyHashes(nodeURI, null);
-
- }
-
- /**
- * Gets the key hashes.
- *
- * @param nodeURI the node URI
- * @param apiVersion the api version
- * @return the key hashes
- * @throws AAIException the AAI exception
- * @throws UnsupportedEncodingException the unsupported encoding exception
- */
- public static LinkedHashMap <String,Object> getKeyHashes(String nodeURI, String apiVersion) throws AAIException, UnsupportedEncodingException
- {
-
- if (apiVersion == null || apiVersion.equals(""))
- apiVersion = AAIConfig.get(AAIConstants.AAI_DEFAULT_API_VERSION_PROP);
-
- DbMaps dbMaps = IngestModelMoxyOxm.dbMapsContainer.get(apiVersion);
-
- // Hash of hashes of keys for each node and its ancestry
- LinkedHashMap <String,Object> returnHash = new LinkedHashMap <String,Object> ();
-
- String path = nodeURI.replaceFirst("^/", "");
- Path p = Paths.get(path);
- int index = p.getNameCount() - 2; // index of where we expect the node type to be
-
- // if the node type has one key
- String currentNodeType = p.getName(index).toString();
- // if the node type has two keys - this assumes max 2 keys
- if (!dbMaps.NodeKeyProps.containsKey(currentNodeType))
- currentNodeType = p.getName(--index).toString();
-
- // create the hash for the keys for the node passed in
- LinkedHashMap <String,Object> thisNodeHash = new LinkedHashMap <String,Object> ();
- Collection <String> keyProps = dbMaps.NodeKeyProps.get(currentNodeType);
- Iterator <String> keyPropI = keyProps.iterator();
-
- if (currentNodeType.equals("ipaddress")) { // this has 2 keys but API only uses port-or -address in URL
- String nodeKeyValue = p.getName(index + 1).toString();
- thisNodeHash.put("port-or-interface", nodeKeyValue);
- } else {
- int j = 1;
- while (keyPropI.hasNext()) {
- String nodeKeyName = currentNodeType + "." + keyPropI.next();
- String nodeKeyValue = p.getName(index + j++).toString();
- thisNodeHash.put(nodeKeyName, nodeKeyValue);
- }
- }
- returnHash.putAll(thisNodeHash);
- if (!currentNodeType.contains("-list"))
- index -= 3;
- else
- index -= 2; // no plural in this case
-
-
- // create and add the hashes for the dependent nodes for the node passed in
- LinkedHashMap <String,Object> depNodeHash = new LinkedHashMap <String,Object> ();
- String depNodeType = null;
- while (index >= 2) {
- if (depNodeType == null) depNodeType = p.getName(index).toString();
- //System.out.println("index=" + index);
- // if the node type has one key
- currentNodeType = p.getName(index).toString();
- // if the node type has two keys - this assumes max 2 keys
- if (!dbMaps.NodeKeyProps.containsKey(currentNodeType))
- currentNodeType = p.getName(--index).toString();
-
- keyProps = dbMaps.NodeKeyProps.get(currentNodeType);
- keyPropI = keyProps.iterator();
-
- if (currentNodeType.equals("ipaddress")) { // this has 2 keys but API only uses port-or -address in URL
- String nodeKeyValue = p.getName(index + 1).toString();
- depNodeHash.put("port-or-interface", nodeKeyValue);
- } else {
- int j = 1;
- while (keyPropI.hasNext()) {
- String nodeKeyName = currentNodeType + "." + keyPropI.next();
- String nodeKeyValue = p.getName(index + j++).toString();
- depNodeHash.put(nodeKeyName, nodeKeyValue);
- }
- }
-
- if (!currentNodeType.contains("-list"))
- index -= 3;
- else
- index -= 2; // no plural in this case
- }
- if (depNodeType != null)
- returnHash.putAll(depNodeHash);
-
- return returnHash;
- }
-
- /**
- * Parses the uri.
- *
- * @param allKeys the all keys
- * @param keyList the key list
- * @param uri the uri
- * @param aaiExtMap the aai ext map
- * @return the AAI resource
- * @throws UnsupportedEncodingException the unsupported encoding exception
- * @throws AAIException the AAI exception
- */
- public static AAIResource parseUri(HashMap<String, String> allKeys, LinkedHashMap<String,
- LinkedHashMap<String,Object>> keyList, String uri,
- AAIExtensionMap aaiExtMap) throws UnsupportedEncodingException, AAIException {
-
- String[] ps = uri.split("/");
-
- String apiVersion = ps[0];
- aaiExtMap.setApiVersion(apiVersion);
-
- AAIResources aaiResources = org.openecomp.aai.ingestModel.IngestModelMoxyOxm.aaiResourceContainer.get(apiVersion);
-
- String namespace = ps[1];
-
- aaiExtMap.setNamespace(namespace);
-
- // /vces/vce/{vnf-id}/port-groups/port-group/{port-group-id}/cvlan-tag-entry/cvlan-tag/{cvlan-tag}
-
- // FullName -> /Vces/Vce/PortGroups/PortGroup/CvlanTagEntry/CvlanTag <-
-
- String fullResourceName = "/" + CaseFormat.LOWER_HYPHEN.to(CaseFormat.UPPER_CAMEL, namespace);
- AAIResources theseResources = new AAIResources();
-
- StringBuffer thisUri = new StringBuffer();
-
- // the URI config option in the props file has a trailing slash
- thisUri.append("/" + namespace);
-
- boolean firstNode = true;
-
- AAIResource lastResource = null;
-
- for (int i = 2; i < ps.length; i++) {
-
- AAIResource aaiRes;
- StringBuffer tmpResourceName = new StringBuffer();
-
- String p = ps[i];
- String seg =ps[i];
-
- thisUri.append("/" + seg);
-
- tmpResourceName.append(fullResourceName);
-
- if (seg.equals("cvlan-tag")) {
- seg = "cvlan-tag-entry";
- }
- tmpResourceName.append("/" + CaseFormat.LOWER_HYPHEN.to(CaseFormat.UPPER_CAMEL, seg));
-
- String tmpResource = tmpResourceName.toString();
-
- if (aaiResources.getAaiResources().containsKey(tmpResource)) {
- aaiRes = aaiResources.getAaiResources().get(tmpResource);
- lastResource = aaiRes;
- theseResources.getAaiResources().put(tmpResource, aaiRes);
- fullResourceName = tmpResource;
- if ("node".equals(aaiRes.getResourceType())) {
-
- if (firstNode == true) {
- aaiExtMap.setTopObjectFullResourceName(fullResourceName);
- firstNode = false;
- }
-
- // get the keys, which will be in order and the next path segment(s)
- AAIResourceKeys keys = aaiRes.getAaiResourceKeys();
-
- LinkedHashMap<String,Object> subKeyList = new LinkedHashMap<String,Object>();
-
- // there might not be another path segment
- if ( (i + 1) < ps.length) {
-
- for (AAIResourceKey rk : keys.getAaiResourceKey()) {
- String p1 = ps[++i];
- String encodedKey = p1.toString();
- thisUri.append("/" + encodedKey);
- String decodedKey = UriUtils.decode(p1.toString(), "UTF-8");
- subKeyList.put(rk.getKeyName(), decodedKey);
- }
- keyList.put(tmpResource, subKeyList);
- // this is the key
- allKeys.put(tmpResource, thisUri.toString());
- }
- } else { // examples sit directly under the container level, should probably be query params!!!
- if ( (i + 1) < ps.length) {
- String p1 = ps[i+1];
- if (p1.toString().equals("example") || p1.toString().equals("singletonExample")) {
- LinkedHashMap<String,Object> subKeyList = new LinkedHashMap<String,Object>();
- subKeyList.put("container|example", p1.toString());
- keyList.put(tmpResource, subKeyList);
- }
- }
- }
- } else {
- if (p.equals("relationship-list")) {
- LinkedHashMap<String,Object> subKeyList = new LinkedHashMap<String,Object>();
- subKeyList.put("container|relationship", p.toString());
- keyList.put(tmpResource, subKeyList);
- } else if ( p.toString().length() > 0 && !p.toString().equals("example") && !p.toString().equals("singletonExample")
- && !p.toString().equals("relationship") ) {
- // this means the URL will break the model, so we bail
- throw new AAIException("AAI_3001", "bad path");
- }
- }
- }
- aaiExtMap.setUri(AAIConfig.get("aai.global.callback.url") + apiVersion + thisUri.toString());
- aaiExtMap.setNotificationUri(AAIConfig.get("aai.global.callback.url") + AAIConfig.get("aai.notification.current.version") + thisUri.toString());
- aaiExtMap.setFullResourceName(fullResourceName);
- return lastResource;
- }
-
-}
-
diff --git a/aai-traversal/src/main/java/org/openecomp/aai/util/StoreNotificationEvent.java b/aai-traversal/src/main/java/org/openecomp/aai/util/StoreNotificationEvent.java
index 181627b..e054e3d 100644
--- a/aai-traversal/src/main/java/org/openecomp/aai/util/StoreNotificationEvent.java
+++ b/aai-traversal/src/main/java/org/openecomp/aai/util/StoreNotificationEvent.java
@@ -21,9 +21,6 @@
package org.openecomp.aai.util;
import java.io.StringWriter;
-import java.text.DateFormat;
-import java.text.SimpleDateFormat;
-import java.util.Date;
import java.util.Iterator;
import java.util.UUID;
@@ -33,9 +30,9 @@ import org.eclipse.persistence.dynamic.DynamicEntity;
import org.eclipse.persistence.jaxb.dynamic.DynamicJAXBContext;
import org.json.JSONException;
import org.json.JSONObject;
-
import org.openecomp.aai.dmaap.AAIDmaapEventJMSProducer;
import org.openecomp.aai.domain.notificationEvent.NotificationEvent;
+import org.openecomp.aai.domain.notificationEvent.ObjectFactory;
import org.openecomp.aai.exceptions.AAIException;
import org.openecomp.aai.introspection.Introspector;
import org.openecomp.aai.introspection.Loader;
@@ -73,9 +70,9 @@ public class StoreNotificationEvent {
throw new AAIException("AAI_7350");
}
- org.openecomp.aai.domain.notificationEvent.ObjectFactory factory = new org.openecomp.aai.domain.notificationEvent.ObjectFactory();
+ ObjectFactory factory = new ObjectFactory();
- org.openecomp.aai.domain.notificationEvent.NotificationEvent ne = factory.createNotificationEvent();
+ NotificationEvent ne = factory.createNotificationEvent();
if (eh.getId() == null) {
eh.setId(genDate2() + "-" + UUID.randomUUID().toString());
@@ -297,6 +294,9 @@ public class StoreNotificationEvent {
entityJsonObjectUpdated.put("event-header", entityHeader);
entityJsonObjectUpdated.put("cambria.partition", cambriaPartition);
+ String transId = entityHeader.getString("id");
+ String fromAppId = entityHeader.getString("source-name");
+
Iterator<String> iter = entityJsonObject.keys();
JSONObject entity = new JSONObject();
if (iter.hasNext()) {
@@ -320,9 +320,8 @@ public class StoreNotificationEvent {
* @return the string
*/
public static String genDate() {
- Date date = new Date();
- DateFormat formatter = new SimpleDateFormat("YYYYMMdd-HH:mm:ss:SSS");
- return formatter.format(date);
+ FormatDate fd = new FormatDate("YYMMdd-HH:mm:ss:SSS");
+ return fd.getDateTime();
}
/**
@@ -331,9 +330,8 @@ public class StoreNotificationEvent {
* @return the string
*/
public static String genDate2() {
- Date date = new Date();
- DateFormat formatter = new SimpleDateFormat("YYYYMMddHHmmss");
- return formatter.format(date);
+ FormatDate fd = new FormatDate("YYYYMMddHHmmss");
+ return fd.getDateTime();
}
}