Method WorkflowDemoRunHandler

pkg/server/workflow_demo.go:174–250

WorkflowDemoRunHandler 返回一个 HTTP handler, 用于运行内置的演示工作流。 路径示例: POST /v1/workflows/demo/run 请求体: { "workflow_id": "sequential_demo", "input": "处理用户数据" } 响应体: { "events": [ {"id":"...","agent_id":"DataCollector","text":"...","metadata":{...}}, ... ] }

()

//	  ]
//	}
func (s *Server) WorkflowDemoRunHandler() http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if r.Method != http.MethodPost {
			http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
			return
		}

		var req WorkflowRunRequest
		if err := jsonNewDecoder(r.Body).Decode(&req); err != nil {
			http.Error(w, "invalid JSON body", http.StatusBadRequest)
			return
		}

		if req.WorkflowID == "" {
			http.Error(w, "workflow_id is required", http.StatusBadRequest)
			return
		}
		if req.Input == "" {
			http.Error(w, "input is required", http.StatusBadRequest)
			return
		}

		ctx := r.Context()
		ctx, cancel := context.WithTimeout(ctx, 2*time.Minute)
		defer cancel()

		wf, err := s.buildDemoWorkflow(req.WorkflowID)
		if err != nil {
			http.Error(w, err.Error(), http.StatusBadRequest)
			return
		}

		var events []WorkflowEvent

		reader := wf.Execute(ctx, req.Input)
		for {
			ev, err := reader.Recv()
			if err != nil {
				if errors.Is(err, io.EOF) {
					break
				}
				resp := &WorkflowRunResponse{
					ErrorMessage: err.Error(),
				}
				writeJSON(w, http.StatusInternalServerError, resp)
				return
			}
			if ev == nil {
				continue
			}
			events = append(events, WorkflowEvent{
				ID:        ev.ID,
				Timestamp: ev.Timestamp,
				AgentID:   ev.AgentID,
				Branch:    ev.Branch,
				Author:    ev.Author,
				Text:      ev.Content.Content,
				Metadata:  ev.Metadata,