feat(backend): auto task pipeline

Author: Ev4nFeng

.github/.licenserc.yaml

@@ -42,6 +42,34 @@ dependency:
   licenses:
     - name: github.com/cloudwego/eino-ext/*/*/*
       license: Apache-2.0
+    - name: github.com/cloudwego/eino
+      license: Apache-2.0
+    - name: github.com/cloudwego/gopkg
+      license: Apache-2.0
+    - name: github.com/cloudwego/configmanager
+      license: Apache-2.0
+    - name: github.com/cloudwego/localsession
+      license: Apache-2.0
+    - name: github.com/cloudwego/runtimex
+      license: Apache-2.0
+    - name: github.com/hertz-contrib/sse
+      license: Apache-2.0
+    - name: github.com/xeipuuv/gojsonschema
+      license: Apache-2.0
+    - name: github.com/xeipuuv/gojsonpointer
+      license: Apache-2.0
+    - name: github.com/xeipuuv/gojsonreference
+      license: Apache-2.0
+    - name: github.com/google/s2a-go
+      license: Apache-2.0
+    - name: github.com/josharian/intern
+      license: MIT
+    - name: github.com/lib/pq
+      license: MIT
+    - name: github.com/olekukonko/tablewriter
+      license: MIT
+    - name: github.com/paulmach/orb
+      license: MIT
   excludes:
     - name: github.com/alicebob/gopher-json
       license: Unlicense

.gitignore

@@ -24,6 +24,7 @@ output/
 # Files generated by IDEs
 .idea/
 *.iml
+.trae/
 
 # MacOS files
 **/.DS_Store
@@ -59,4 +60,6 @@ backend/script/errorx/.env
 .cursor/
 .specify/
 specs/
-.puml
+.puml
+.trae
+openspec/

README.cn.md

@@ -115,6 +115,9 @@ Coze Loop 通过提供全生命周期的管理能力，帮助开发者更高效
 6. 开始定制你的 Coze Loop 项目。
    参考 `examples/` 目录示例，修改 `values.yaml` 即可覆盖默认设置，修改后重新执行 `make helm-up` 生效。
 
+> [!WARNING]
+> 如果要将 Coze Loop 部署到公网环境，建议在部署前评估整体评估安全风险，例如账号注册功能、Coze Server 监听地址配置、SSRF 和部分 API 水平越权的风险，并采取相应防护措施。详细信息可参考[快速开始](https://github.com/coze-dev/coze-loop/wiki/2.-%E5%BF%AB%E9%80%9F%E5%BC%80%E5%A7%8B#%E5%85%AC%E7%BD%91%E5%AE%89%E5%85%A8%E9%A3%8E%E9%99%A9)。
+
 ## 使用 Coze Loop 开源版
 
 * [Prompt 开发与调试](https://loop.coze.cn/open/docs/cozeloop/create-prompt)：Coze Loop 提供了完整的提示词开发流程。

README.md

@@ -115,6 +115,9 @@ Procedure:
 6. Start customizing your Coze Loop project.
    Refer to the examples in the `examples/` directory. Modify `values.yaml` to override the default settings. After making changes, rerun `make helm-up` for the changes to take effect.
 
+> [!WARNING]
+> If you want to deploy Coze Loop in a public network environment, it is recommended to assess security risks before you begin, and take corresponding protection measures. Possible security risks include account registration functions, Coze Server listening address configurations, SSRF (Server - Side Request Forgery), and some horizontal privilege escalations in APIs.  For more details, refer to [Quickstart](https://github.com/coze-dev/coze-loop/wiki/2.-Quickstart#security-risks-in-public-networks).
+
 ## Use the Coze Loop open source version
 
 * [Prompt development and debugging](https://loop.coze.cn/open/docs/cozeloop/create-prompt): Coze Loop provides a complete prompt development workflow.

backend/api/api.go

@@ -19,6 +19,14 @@ import (
 // mockEvaluatorClient 实现 evaluatorservice.Client 的必要方法，返回空响应以通过渲染
 type mockEvaluatorClient struct{}
 
+func (m *mockEvaluatorClient) AsyncRunEvaluator(ctx context.Context, req *evaluator.AsyncRunEvaluatorRequest, callOptions ...callopt.Option) (r *evaluator.AsyncRunEvaluatorResponse, err error) {
+	return nil, nil
+}
+
+func (m *mockEvaluatorClient) AsyncDebugEvaluator(ctx context.Context, req *evaluator.AsyncDebugEvaluatorRequest, callOptions ...callopt.Option) (r *evaluator.AsyncDebugEvaluatorResponse, err error) {
+	return nil, nil
+}
+
 func (m *mockEvaluatorClient) ListEvaluators(ctx context.Context, req *evaluator.ListEvaluatorsRequest, callOptions ...callopt.Option) (r *evaluator.ListEvaluatorsResponse, err error) {
 	return &evaluator.ListEvaluatorsResponse{}, nil
 }
@@ -63,6 +71,10 @@ func (m *mockEvaluatorClient) BatchGetEvaluatorVersions(ctx context.Context, req
 	return &evaluator.BatchGetEvaluatorVersionsResponse{}, nil
 }
 
+func (m *mockEvaluatorClient) BatchGetEvaluatorVersionIDs(ctx context.Context, req *evaluator.BatchGetEvaluatorVersionIDsRequest, callOptions ...callopt.Option) (r *evaluator.BatchGetEvaluatorVersionIDsResponse, err error) {
+	return &evaluator.BatchGetEvaluatorVersionIDsResponse{}, nil
+}
+
 func (m *mockEvaluatorClient) SubmitEvaluatorVersion(ctx context.Context, req *evaluator.SubmitEvaluatorVersionRequest, callOptions ...callopt.Option) (r *evaluator.SubmitEvaluatorVersionResponse, err error) {
 	return &evaluator.SubmitEvaluatorVersionResponse{}, nil
 }
@@ -239,3 +251,63 @@ func TestEvaluatorService_Handlers(t *testing.T) {
 		})
 	}
 }
+
+func TestEvaluatorService_AsyncHandlers(t *testing.T) {
+	t.Parallel()
+
+	ctx := context.Background()
+
+	tests := []struct {
+		name       string
+		body       string
+		handler    func(context.Context, *app.RequestContext)
+		wantStatus int
+	}{
+		{
+			name:       "AsyncRunEvaluator bad json",
+			body:       "{invalid",
+			handler:    AsyncRunEvaluator,
+			wantStatus: http.StatusBadRequest,
+		},
+		{
+			name:       "AsyncRunEvaluator ok",
+			body:       `{"workspace_id":1,"evaluator_version_id":2,"input_data":{"input_fields":{}}}`,
+			handler:    AsyncRunEvaluator,
+			wantStatus: http.StatusOK,
+		},
+		{
+			name:       "AsyncDebugEvaluator bad json",
+			body:       "{invalid",
+			handler:    AsyncDebugEvaluator,
+			wantStatus: http.StatusBadRequest,
+		},
+		{
+			name:       "AsyncDebugEvaluator ok",
+			body:       `{"workspace_id":1,"evaluator_type":2,"evaluator_content":{"code_evaluator":{"code_content":"print(1)","language_type":"Python"}},"input_data":{"input_fields":{}}}`,
+			handler:    AsyncDebugEvaluator,
+			wantStatus: http.StatusOK,
+		},
+		{
+			name:       "UpdateBuiltinEvaluatorTags tolerant body",
+			body:       `{"workspace_id":"x"}`,
+			handler:    UpdateBuiltinEvaluatorTags,
+			wantStatus: http.StatusOK,
+		},
+		{
+			name:       "UpdateBuiltinEvaluatorTags ok",
+			body:       `{}`,
+			handler:    UpdateBuiltinEvaluatorTags,
+			wantStatus: http.StatusOK,
+		},
+	}
+
+	for _, tt := range tests {
+		tc := tt
+		t.Run(tc.name, func(t *testing.T) {
+			t.Parallel()
+			c := newJSONCtxWithBody(tc.body)
+			tc.handler(ctx, c)
+			assert.Equal(t, tc.wantStatus, c.Response.StatusCode())
+		})
+	}
+}