Function runWebUI

examples/plan-explore-ui/main.go:206–357

runWebUI 启动一个带简单前端的 HTTP 服务。 默认访问地址: http://localhost:8080

(_ context.Context, deps *agent.Dependencies, templateID, providerName, modelName, apiKey, addr string)

// runWebUI 启动一个带简单前端的 HTTP 服务。
// 默认访问地址: http://localhost:8080
func runWebUI(_ context.Context, deps *agent.Dependencies, templateID, providerName, modelName, apiKey, addr string) error {
	mux := http.NewServeMux()

	// 静态前端资源
	fs := http.FileServer(http.Dir("examples/plan-explore-ui/static"))
	mux.Handle("/", fs)

	// SSE 接口: /api/chat/stream
	mux.HandleFunc("/api/chat/stream", func(w http.ResponseWriter, r *http.Request) {
		if r.Method != http.MethodPost {
			http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
			return
		}

		_, ok := w.(http.Flusher)
		if !ok {
			http.Error(w, "streaming unsupported", http.StatusInternalServerError)
			return
		}

		var req struct {
			Input string `json:"input"`
		}
		if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
			http.Error(w, "invalid JSON body", http.StatusBadRequest)
			return
		}

		input := req.Input
		if input == "" {
			input = defaultPrompt()
		}

		reqCtx := r.Context()
		reqCtx, cancel := context.WithTimeout(reqCtx, 5*time.Minute)
		defer cancel()

		ag, err := agent.Create(reqCtx, &types.AgentConfig{
			TemplateID: templateID,
			ModelConfig: &types.ModelConfig{
				Provider: providerName,
				Model:    modelName,
				APIKey:   apiKey,
			},
			Sandbox: &types.SandboxConfig{
				Kind:    types.SandboxKindLocal,
				WorkDir: ".",
			},
			Middlewares: []string{"filesystem", "todolist"},
		}, deps)
		if err != nil {
			http.Error(w, "create agent failed: "+err.Error(), http.StatusInternalServerError)
			return
		}
		defer func() { _ = ag.Close() }()

		eventCh := ag.Subscribe([]types.AgentChannel{
			types.ChannelProgress,