Method evalBoxPlus

engine/temporal.go:377–417

evalBoxPlus implements the box-plus operator ([+). It returns true if the atom will be true CONTINUOUSLY throughout the future interval. Syntax: [+[d1, d2] p(X) means "p(X) will be true for the entire period from d1 to d2 from now"

(
	atom ast.Atom,
	opInterval ast.Interval,
	interval *ast.Interval,
	subst unionfind.UnionFind,
)

// It returns true if the atom will be true CONTINUOUSLY throughout the future interval.
// Syntax: [+[d1, d2] p(X) means "p(X) will be true for the entire period from d1 to d2 from now"
func (te *TemporalEvaluator) evalBoxPlus(
	atom ast.Atom,
	opInterval ast.Interval,
	interval *ast.Interval,
	subst unionfind.UnionFind,
) ([]unionfind.UnionFind, error) {
	// Calculate the query interval based on the operator's interval
	queryInterval, err := te.resolveFutureOperatorInterval(opInterval)
	if err != nil {
		return nil, err
	}

	var solutions []unionfind.UnionFind

	// Query all facts matching the atom
	err = te.temporalStore.GetAllFacts(atom, func(tf factstore.TemporalFact) error {
		// Unify first to check if this fact matches
		newSubst, err := unionfind.UnifyTermsExtend(atom.Args, tf.Atom.Args, subst)
		if err != nil {
			return nil // No match, continue
		}

		// For box-plus, the fact's interval must CONTAIN the query interval
		// (the fact must be true throughout the entire future query period)
		if te.intervalContains(tf.Interval, queryInterval) {
			// Bind interval variables if present
			if interval != nil {
				newSubst = te.bindIntervalVariables(*interval, tf.Interval, newSubst)
			}

			solutions = append(solutions, newSubst)
		}
		return nil
	})

	if err != nil {
		return nil, err
	}

	return solutions, nil
}

// resolveFutureOperatorInterval converts a future operator interval to absolute timestamps.
func (te *TemporalEvaluator) resolveFutureOperatorInterval(interval ast.Interval) (ast.Interval, error) {