Function splitReqConditions

pkg/traceql/lenient_extract.go:133–188

splitReqConditions converts a field expression into condition groups by expanding OR clauses into separate groups. Each group represents one AND-connected set of conditions that must all be satisfied together. Example: { (.a="1" || .b="2") && .c="3" } produces two groups: - [.a="1", .c="3"] - [.b="

(expr FieldExpression, maxGroups int)

//   - [.a="1", .c="3"]
//   - [.b="2", .c="3"]
func splitReqConditions(expr FieldExpression, maxGroups int) ([][]Condition, bool) {
	var reachedMaxGroups bool
	ops := flattenExprToOperations(expr, OpNone)

	totalGroups := 1
	for _, op := range ops {
		if op.opType == OpOr {
			totalGroups *= len(op.conditions)
			if totalGroups > maxGroups {
				totalGroups = maxGroups
				break
			}
		}
	}

	conditionGroups := make([][]Condition, totalGroups)
	repeats := 1
	for _, op := range ops {
		opCondIdx := 0
		repeated := 0
		for i := 0; i < totalGroups; i++ {
			if op.opType == OpOr {
				conditionGroups[i] = append(conditionGroups[i], op.conditions[opCondIdx]...)
				repeated++
				if repeated == repeats {
					repeated = 0
					opCondIdx++
				}
				if opCondIdx >= len(op.conditions) {
					opCondIdx = 0
				}
			} else {
				for _, conds := range op.conditions {
					conditionGroups[i] = append(conditionGroups[i], conds...)
				}
			}
		}
		if op.opType == OpOr {
			repeats *= len(op.conditions)
			if repeats > maxGroups {
				repeats = maxGroups
				reachedMaxGroups = true
			}
		}
	}

	// Drop empty groups (e.g. from an empty filter `{}`).
	result := conditionGroups[:0]
	for _, g := range conditionGroups {
		if len(g) > 0 {
			result = append(result, g)
		}
	}

	return result, reachedMaxGroups
}

// deduplicateConditionBranches removes duplicate branches from an OR group.