Method WorkflowDemoRunEvalHandler

pkg/server/workflow_demo.go:277–418

WorkflowDemoRunEvalHandler 返回一个 HTTP handler, 用于运行内置 demo 工作流并对最终回答进行评估。 路径示例: POST /v1/workflows/demo/run-eval 请求体: { "workflow_id": "sequential_demo", "input": "处理用户数据", "reference": "期望的总结结果...", "keywords": ["收集", "分析", "报告"], "scorers": ["keyword_coverage", "lexical_similar

()

//	  ]
//	}
func (s *Server) WorkflowDemoRunEvalHandler() 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 WorkflowRunEvalRequest
		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
		}

		// 验证 scorers 列表
		scorerNames := req.Scorers
		if len(scorerNames) == 0 {
			scorerNames = []string{"keyword_coverage", "lexical_similarity"}
		}
		for _, name := range scorerNames {
			if name != "keyword_coverage" && name != "lexical_similarity" {
				http.Error(w, "unsupported scorer: "+name, 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
			rawEvents []session.Event
		)

		reader := wf.Execute(ctx, req.Input)
		for {
			ev, err := reader.Recv()
			if err != nil {
				if errors.Is(err, io.EOF) {
					break
				}
				resp := &WorkflowRunEvalResponse{
					WorkflowRunResponse: WorkflowRunResponse{