fix(cypher): frontend should always emit exclusive kind matchers

Author: seanjSO

cypher/frontend/expression.go

@@ -378,6 +378,8 @@ type NonArithmeticOperatorExpressionVisitor struct {
 func (s *NonArithmeticOperatorExpressionVisitor) EnterOC_NodeLabels(ctx *parser.OC_NodeLabelsContext) {
 	s.Expression = &cypher.KindMatcher{
 		Reference: s.Expression,
+		// Cypher-generated `KindMatcher`s should _always_ be exclusive to jive with the spec
+		IsExclusive: true,
 	}
 }
 

cypher/models/cypher/model.go

@@ -25,8 +25,10 @@ func (s AssignmentOperator) String() string {
 	return string(s)
 }
 
-type SyntaxNode any
-type Expression SyntaxNode
+type (
+	SyntaxNode any
+	Expression SyntaxNode
+)
 
 type ExpressionList interface {
 	Add(expression Expression)
@@ -744,12 +746,15 @@ func NewRangeQuantifier(value string) *RangeQuantifier {
 type KindMatcher struct {
 	Reference Expression
 	Kinds     graph.Kinds
+	// IsExclusive changes the kind matching operator from overlap (PG &&) to a stricter "left contains right" (PG @>)
+	IsExclusive bool
 }
 
-func NewKindMatcher(reference Expression, kinds graph.Kinds) *KindMatcher {
+func NewKindMatcher(reference Expression, kinds graph.Kinds, isExclusive bool) *KindMatcher {
 	return &KindMatcher{
-		Reference: reference,
-		Kinds:     kinds,
+		Reference:   reference,
+		Kinds:       kinds,
+		IsExclusive: isExclusive,
 	}
 }
 
@@ -759,8 +764,9 @@ func (s *KindMatcher) copy() *KindMatcher {
 	}
 
 	return &KindMatcher{
-		Reference: Copy(s.Reference),
-		Kinds:     Copy(s.Kinds),
+		Reference:   Copy(s.Reference),
+		Kinds:       Copy(s.Kinds),
+		IsExclusive: s.IsExclusive,
 	}
 }
 

cypher/models/pgsql/translate/kind.go

@@ -9,17 +9,22 @@ import (
 	"github.com/specterops/dawgs/cypher/models/pgsql/pgd"
 )
 
-func newPGKindIDMatcher(scope *Scope, treeTranslator *ExpressionTreeTranslator, binding *BoundIdentifier, kindIDs []int16) error {
+func newPGKindIDMatcher(scope *Scope, treeTranslator *ExpressionTreeTranslator, binding *BoundIdentifier, kindIDs []int16, isExclusive bool) error {
 	kindIDsLiteral := pgsql.NewLiteral(kindIDs, pgsql.Int2Array)
 
 	switch binding.DataType {
 	case pgsql.NodeComposite, pgsql.ExpansionRootNode, pgsql.ExpansionTerminalNode:
 		treeTranslator.PushOperand(pgd.Column(binding.Identifier, pgsql.ColumnKindIDs))
 		treeTranslator.PushOperand(kindIDsLiteral)
 
-		return treeTranslator.CompleteBinaryExpression(scope, pgsql.OperatorPGArrayLHSContainsRHS)
+		if isExclusive {
+			return treeTranslator.CompleteBinaryExpression(scope, pgsql.OperatorPGArrayLHSContainsRHS)
+		} else {
+			return treeTranslator.CompleteBinaryExpression(scope, pgsql.OperatorPGArrayOverlap)
+		}
 
 	case pgsql.EdgeComposite, pgsql.ExpansionEdge:
+		// An edge will only have a single kind_id, so the IsExclusive does not apply here.
 		treeTranslator.PushOperand(pgsql.CompoundIdentifier{binding.Identifier, pgsql.ColumnKindID})
 		treeTranslator.PushOperand(pgsql.NewAnyExpressionHinted(kindIDsLiteral))
 
@@ -39,6 +44,6 @@ func (s *Translator) translateKindMatcher(kindMatcher *cypher.KindMatcher) error
 	} else if kindIDs, err := s.kindMapper.MapKinds(kindMatcher.Kinds); err != nil {
 		return fmt.Errorf("failed to translate kinds: %w", err)
 	} else {
-		return newPGKindIDMatcher(s.scope, s.treeTranslator, binding, kindIDs)
+		return newPGKindIDMatcher(s.scope, s.treeTranslator, binding, kindIDs, kindMatcher.IsExclusive)
 	}
 }

query/model.go

@@ -10,9 +10,7 @@ import (
 )
 
 func convertCriteria[T any](criteria ...graph.Criteria) []T {
-	var (
-		converted = make([]T, len(criteria))
-	)
+	converted := make([]T, len(criteria))
 
 	for idx, nextCriteria := range criteria {
 		converted[idx] = nextCriteria.(T)
@@ -67,8 +65,9 @@ func DeleteKind(reference graph.Criteria, kind graph.Kind) *cypherModel.Updating
 	return cypherModel.NewUpdatingClause(&cypherModel.Remove{
 		Items: []*cypherModel.RemoveItem{{
 			KindMatcher: &cypherModel.KindMatcher{
-				Reference: reference,
-				Kinds:     graph.Kinds{kind},
+				Reference:   reference,
+				Kinds:       graph.Kinds{kind},
+				IsExclusive: false,
 			},
 		}},
 	})
@@ -78,8 +77,9 @@ func DeleteKinds(reference graph.Criteria, kinds graph.Kinds) *cypherModel.Updat
 	return cypherModel.NewUpdatingClause(&cypherModel.Remove{
 		Items: []*cypherModel.RemoveItem{{
 			KindMatcher: &cypherModel.KindMatcher{
-				Reference: reference,
-				Kinds:     kinds,
+				Reference:   reference,
+				Kinds:       kinds,
+				IsExclusive: false,
 			},
 		}},
 	})
@@ -131,13 +131,14 @@ func DeleteProperties(reference graph.Criteria, propertyNames ...string) *cypher
 
 func Kind(reference graph.Criteria, kinds ...graph.Kind) *cypherModel.KindMatcher {
 	return &cypherModel.KindMatcher{
-		Reference: reference,
-		Kinds:     kinds,
+		Reference:   reference,
+		Kinds:       kinds,
+		IsExclusive: false,
 	}
 }
 
 func KindIn(reference graph.Criteria, kinds ...graph.Kind) *cypherModel.KindMatcher {
-	return cypherModel.NewKindMatcher(reference, kinds)
+	return cypherModel.NewKindMatcher(reference, kinds, false)
 }
 
 func NodeProperty(name string) *cypherModel.PropertyLookup {