Function runOnce

examples/openrouter/main.go:90–127

runOnce 非交互模式：执行单次对话并退出

(ctx context.Context, ag *agent.Agent, prompt string)

// runOnce 非交互模式：执行单次对话并退出
func runOnce(ctx context.Context, ag *agent.Agent, prompt string) error {
	// 订阅事件以捕获文本输出
	var textOutput strings.Builder
	eventCh := ag.Subscribe([]types.AgentChannel{types.ChannelProgress}, nil)

	done := make(chan struct{})
	go func() {
		for envelope := range eventCh {
			switch e := envelope.Event.(type) {
			case *types.ProgressTextChunkEvent:
				textOutput.WriteString(e.Delta)
			}
		}
		close(done)
	}()

	result, err := ag.Chat(ctx, prompt)
	ag.Unsubscribe(eventCh)
	<-done

	if err != nil {
		return fmt.Errorf("对话失败: %w", err)
	}

	// 优先使用事件流收集的文本，其次使用 result.Text
	output := textOutput.String()
	if output == "" {
		output = result.Text
	}

	if output != "" {
		fmt.Println(output)
	} else {
		fmt.Println("[完成]")
	}

	return nil
}

// runInteractive 交互模式：REPL 循环
func runInteractive(ctx context.Context, ag *agent.Agent) error {