Function parseInternal

pkg/traceql/parse.go:37–80

(s string, skipTransformations []string, allowUnsafeHints bool)

}

func parseInternal(s string, skipTransformations []string, allowUnsafeHints bool) (expr *RootExpr, err error) {
	defer func() {
		if r := recover(); r != nil {
			var ok bool
			if err, ok = r.(error); ok {
				var parseErr *ParseError
				if errors.As(err, &parseErr) {
					return
				}
				err = newParseError(err.Error(), 0, 0)
			}
		}
	}()
	l := lexer{
		parser: yyNewParser().(*yyParserImpl),
	}
	l.Init(strings.NewReader(s))
	l.Scanner.Error = func(_ *scanner.Scanner, msg string) {
		l.Error(msg)
	}
	e := l.parser.Parse(&l)
	if len(l.errs) > 0 {
		return nil, l.errs[0]
	}
	if e != 0 {
		return nil, fmt.Errorf("unknown parse error: %d", e)
	}

	if transformations, ok := l.expr.Hints.GetStringSlice(HintSkipASTTransformations, allowUnsafeHints); ok {
		for _, name := range transformations {
			name = strings.TrimSpace(name)
			if name != "" && !slices.Contains(skipTransformations, name) {
				skipTransformations = append(skipTransformations, name)
			}
		}
	}

	l.expr = ApplyASTRewrites(l.expr, skipTransformations)
	if l.expr.OptimizationCount > 0 {
		level.Debug(log.Logger).Log("msg", "optimize AST for TraceQL query", "query", s, "optimizedQuery", l.expr.String(), "optimizationCount", l.expr.OptimizationCount)
	}

	return l.expr, nil
}

// warning: ParseIdentifier is used to parse filter policies in pkg/spanfilter/config/config.go
// if changed, it can break existing config.