Always create the sentinel nodes

Author: GearsAD

src/CloudGraphsDFG/entities/CloudGraphsDFG.jl

@@ -32,10 +32,14 @@ function CloudGraphsDFG{T}(neo4jConnection::Neo4j.Connection,
                             getPackedTypeFunc,
                             decodePackedTypeFunc,
                             rebuildFactorMetadata!;
-                            solverParams::T=NoSolverParams()) where T <: AbstractParams
+                            solverParams::T=NoSolverParams(),
+                            createSessionNodes::Bool=true) where T <: AbstractParams
     graph = Neo4j.getgraph(neo4jConnection)
     neo4jInstance = Neo4jInstance(neo4jConnection, graph)
-    return CloudGraphsDFG{T}(neo4jInstance, userId, robotId, sessionId, description, encodePackedTypeFunc, getPackedTypeFunc, decodePackedTypeFunc, rebuildFactorMetadata!, Symbol[], solverParams)
+    dfg = CloudGraphsDFG{T}(neo4jInstance, userId, robotId, sessionId, description, encodePackedTypeFunc, getPackedTypeFunc, decodePackedTypeFunc, rebuildFactorMetadata!, Symbol[], solverParams)
+    # Create the session if it doesn't already exist
+    createSessionNodes && createDfgSessionIfNotExist(dfg)
+    return dfg
 end
 """
     $(SIGNATURES)
@@ -53,9 +57,10 @@ function CloudGraphsDFG{T}(host::String,
                            getPackedTypeFunc,
                            decodePackedTypeFunc,
                            rebuildFactorMetadata!;
-                           solverParams::T=NoSolverParams()) where T <: AbstractParams
+                           solverParams::T=NoSolverParams(),
+                           createSessionNodes::Bool=true) where T <: AbstractParams
     neo4jConnection = Neo4j.Connection(host, port=port, user=dbUser, password=dbPassword);
-    return CloudGraphsDFG{T}(neo4jConnection, userId, robotId, sessionId, description, encodePackedTypeFunc, getPackedTypeFunc, decodePackedTypeFunc, rebuildFactorMetadata!, solverParams=solverParams)
+    return CloudGraphsDFG{T}(neo4jConnection, userId, robotId, sessionId, description, encodePackedTypeFunc, getPackedTypeFunc, decodePackedTypeFunc, rebuildFactorMetadata!, solverParams=solverParams, createSessionNodes=createSessionNodes)
 end
 
 

src/CloudGraphsDFG/services/CGStructure.jl

@@ -114,7 +114,7 @@ function createDfgSessionIfNotExist(dfg::CloudGraphsDFG)::Session
     strip(dfg.sessionId) == "" && error("Session ID is not populated in DFG.")
     user = User(Symbol(dfg.userId), dfg.userId, "Description for $(dfg.userId)", Dict{Symbol, String}())
     robot = Robot(Symbol(dfg.robotId), Symbol(dfg.userId), dfg.robotId, "Description for $(dfg.userId):$(dfg.robotId)", Dict{Symbol, String}())
-    session = Session(Symbol(dfg.sessionId), Symbol(dfg.robotId), Symbol(dfg.userId), dfg.sessionId, "Description for $(dfg.userId):$(dfg.robotId):$(dfg.sessionId)", Dict{Symbol, String}())
+    session = Session(Symbol(dfg.sessionId), Symbol(dfg.robotId), Symbol(dfg.userId), dfg.sessionId, dfg.description, Dict{Symbol, String}())
 
     _getNodeCount(dfg.neo4jInstance, [dfg.userId, "USER"]) == 0 && createUser(dfg, user)
     _getNodeCount(dfg.neo4jInstance, [dfg.userId, dfg.robotId, "ROBOT"]) == 0 && createRobot(dfg, robot)

src/CloudGraphsDFG/services/CloudGraphsDFG.jl

@@ -9,7 +9,7 @@ function _getDuplicatedEmptyDFG(dfg::CloudGraphsDFG)::CloudGraphsDFG
     while true #do..while loop
         count += 1
         sessionId = dfg.sessionId*"_$count"
-        length(_getLabelsFromCyphonQuery(dfg.neo4jInstance, "(node:$(dfg.userId):$(dfg.robotId):$(sessionId))")) == 0 && break
+        _getNodeCount(dfg.neo4jInstance, [dfg.userId, dfg.robotId, sessionId]) == 0 && break
     end
     @debug "Unique+empty copy session name: $sessionId"
     return CloudGraphsDFG{typeof(dfg.solverParams)}(