Method ExecuteWithStream

cli/plugins/builtin_search.go:93–132

ExecuteWithStream parses the flat JSON args, converts to engine argv form, and runs engine.handleSearch via a fresh Engine instance. Output streams line-by-line through onOutput.

(ctx context.Context, args []string, onOutput func(string))

// argv form, and runs engine.handleSearch via a fresh Engine instance.
// Output streams line-by-line through onOutput.
func (p *BuiltinSearchPlugin) ExecuteWithStream(ctx context.Context, args []string, onOutput func(string)) (string, error) {
	parsed, err := parseSearchArgs(args)
	if err != nil {
		return "", err
	}
	if parsed.Term == "" {
		return "", fmt.Errorf("term required (usage: @search {\"term\":\"regex\"})")
	}

	argv := buildSearchArgv(parsed)

	var fullOutput strings.Builder
	var mu sync.Mutex
	emit := func(line string, isErr bool) {
		mu.Lock()
		defer mu.Unlock()
		if onOutput != nil {
			prefix := ""
			if isErr {
				prefix = "ERR: "
			}
			onOutput(prefix + line)
		}
		fullOutput.WriteString(line)
		fullOutput.WriteString("\n")
	}
	outWriter := engine.NewStreamWriter(func(line string) { emit(line, false) })
	errWriter := engine.NewStreamWriter(func(line string) { emit(line, true) })

	eng := engine.NewEngine(outWriter, errWriter, "")
	execErr := eng.Execute(ctx, "search", argv)

	outWriter.Flush()
	errWriter.Flush()

	if execErr != nil {
		return fullOutput.String(), fmt.Errorf("@search failed: %w", execErr)
	}
	return fullOutput.String(), nil
}

// searchArgs is the typed view of @search's JSON input.
type searchArgs struct {