AQL steering and node data ingest improvement

Author: lkarlslund

modules/aql/aqlquery.go

@@ -157,26 +157,28 @@ func (aqlq AQLquery) resolveEdgesFrom(
 				}
 
 				switch aqlq.Mode {
+				case Walk:
+					// no-op
 				case Trail:
 					if direction == engine.Out {
-						if committedGraph.HasEdge(currentState.node, nextNode) ||
-							currentState.workingGraph.HasEdge(currentState.node.ID(), nextNode.ID()) {
+						if /*committedGraph.HasEdge(currentState.node, nextNode) ||*/
+						currentState.workingGraph.HasEdge(currentState.node.ID(), nextNode.ID()) {
 							return true
 						}
 					} else {
-						if committedGraph.HasEdge(nextNode, currentState.node) ||
-							currentState.workingGraph.HasEdge(nextNode.ID(), currentState.node.ID()) {
+						if /*committedGraph.HasEdge(nextNode, currentState.node) ||*/
+						currentState.workingGraph.HasEdge(nextNode.ID(), currentState.node.ID()) {
 							return true
 						}
 					}
 				case Acyclic:
 					if currentState.workingGraph.HasNode(nextNode.ID()) || committedGraph.HasNode(nextNode) {
 						return true
 					}
-				case Simple:
-					if currentState.workingGraph.HasNode(nextNode.ID()) {
-						return true
-					}
+					// case Path:
+					// 	if currentState.workingGraph.HasNode(nextNode.ID()) {
+					// 		return true
+					// 	}
 				}
 
 				if thisEdgeSearcher.FilterEdges.NegativeComparator != query.CompareInvalid {

modules/engine/node.go

@@ -4,6 +4,7 @@ import (
 	"encoding/xml"
 	"errors"
 	"fmt"
+	"reflect"
 	"runtime"
 	"slices"
 	"strconv"
@@ -470,6 +471,14 @@ func (o *Node) setFlex(flexinit ...any) {
 			data = data[:0]
 			attribute = v
 		default:
+			if i == nil && ignoreblanks {
+				continue
+			}
+			// deref pointers
+			if reflect.ValueOf(i).Kind() == reflect.Ptr {
+				i = reflect.ValueOf(i).Elem().Interface()
+			}
+
 			newvalue := NV(i)
 			if newvalue == nil || (ignoreblanks && newvalue.IsZero()) {
 				continue