[feat][backend] code evaluator (#220)

Makefile

@@ -2,6 +2,10 @@ IMAGE_REGISTRY := docker.io
 IMAGE_REPOSITORY := cozedev
 IMAGE_NAME := coze-loop
 
+# Python FaaS image config
+PYFAAS_IMAGE_NAME := coze-loop-python-faas
+PYFAAS_DOCKERFILE := ./release/image/python-faas.Dockerfile
+
 DOCKER_COMPOSE_DIR := ./release/deployment/docker-compose
 
 HELM_CHART_DIR := ./release/deployment/helm-chart/umbrella
@@ -33,18 +37,37 @@ image%:
 		docker run --rm $(IMAGE_REPOSITORY)/$(IMAGE_NAME):latest du -sh /coze-loop/bin; \
 		docker run --rm $(IMAGE_REPOSITORY)/$(IMAGE_NAME):latest du -sh /coze-loop/resources; \
 		docker run --rm $(IMAGE_REPOSITORY)/$(IMAGE_NAME):latest du -sh /coze-loop ;; \
+	  -python-faas-bpush-*) \
+	    version="$*"; \
+	    version="$${version#-python-faas-bpush-}"; \
+	    docker buildx build \
+		  --platform linux/amd64,linux/arm64 \
+		  --progress=plain \
+		  --push \
+		  --build-context bootstrap=$(DOCKER_COMPOSE_DIR)/bootstrap/python-faas \
+		  -f $(PYFAAS_DOCKERFILE) \
+		  -t $(IMAGE_REGISTRY)/$(IMAGE_REPOSITORY)/$(PYFAAS_IMAGE_NAME):latest \
+		  -t $(IMAGE_REGISTRY)/$(IMAGE_REPOSITORY)/$(PYFAAS_IMAGE_NAME):"$$version" \
+		  .; \
+		docker pull $(IMAGE_REGISTRY)/$(IMAGE_REPOSITORY)/$(PYFAAS_IMAGE_NAME):latest; \
+		docker run --rm $(IMAGE_REPOSITORY)/$(PYFAAS_IMAGE_NAME):latest du -sh /app; \
+		docker run --rm $(IMAGE_REPOSITORY)/$(PYFAAS_IMAGE_NAME):latest du -sh /app/vendor; \
+		;; \
 	  -help|*) \
       	echo "Usage:"; \
-      	echo "  make image--login             # Login to the image registry ($(IMAGE_REGISTRY))"; \
-      	echo "  make image-<version>          # Build & push multi-arch image with tags <version> and latest"; \
+		echo "  make image--login                         # Login to the image registry ($(IMAGE_REGISTRY))"; \
+		echo "  make image-<version>                      # Build & push coze-loop image (<version>, latest)"; \
+		echo "  make image-python-faas-bpush-<version>    # Build & push python-faas image (<version>, latest)"; \
       	echo; \
       	echo "Examples:"; \
-      	echo "  make image--login             # Login before pushing images"; \
-      	echo "  make image-1.0.0              # Build & push images tagged '1.0.0' and 'latest'"; \
+	    echo "  make image--login"; \
+	    echo "  make image-1.0.0"; \
+	    echo "  make image-python-faas-bpush-1.0.0"; \
       	echo; \
       	echo "Notes:"; \
-      	echo "  - 'image--login' logs in using IMAGE_REPOSITORY as the username."; \
-      	echo "  - 'image-<version>' will push to $(IMAGE_REGISTRY)/$(IMAGE_REPOSITORY)/$(IMAGE_NAME)"; \
+	    echo "  - 'image--login' logs in using IMAGE_REPOSITORY as the username."; \
+	    echo "  - 'image-<version>' pushes to $(IMAGE_REGISTRY)/$(IMAGE_REPOSITORY)/$(IMAGE_NAME)"; \
+	    echo "  - 'image-python-faas-bpush-<version>' pushes to $(IMAGE_REGISTRY)/$(IMAGE_REPOSITORY)/$(PYFAAS_IMAGE_NAME)"; \
       	exit 1 ;; \
 	esac
 

backend/api/handler/coze/loop/apis/handler_test.go

@@ -120,3 +120,35 @@ func Test_invokeAndRender(t *testing.T) {
 		})
 	}
 }
+
+func TestValidateEvaluator(t *testing.T) {
+	tests := []struct {
+		name      string
+		wantPanic bool
+	}{
+		{
+			name:      "ValidateEvaluator function exists and can be called",
+			wantPanic: false,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			ctx := context.Background()
+			c := &app.RequestContext{}
+
+			// The function will panic due to nil localEvaluatorSvc, but we verify it exists and can be called
+			// This test mainly ensures the function compiles and follows the expected pattern
+			if tt.wantPanic {
+				assert.Panics(t, func() {
+					ValidateEvaluator(ctx, c)
+				})
+			} else {
+				// Even though it panics, we verify the function signature is correct
+				assert.Panics(t, func() {
+					ValidateEvaluator(ctx, c)
+				})
+			}
+		})
+	}
+}

backend/modules/evaluation/application/wire.go

@@ -64,6 +64,7 @@ import (
 	"github.com/coze-dev/coze-loop/backend/modules/evaluation/infra/rpc/llm"
 	"github.com/coze-dev/coze-loop/backend/modules/evaluation/infra/rpc/prompt"
 	"github.com/coze-dev/coze-loop/backend/modules/evaluation/infra/rpc/tag"
+	"github.com/coze-dev/coze-loop/backend/modules/evaluation/infra/runtime"
 	evalconf "github.com/coze-dev/coze-loop/backend/modules/evaluation/pkg/conf"
 	"github.com/coze-dev/coze-loop/backend/pkg/conf"
 )
@@ -137,8 +138,8 @@ var (
 		domainservice.NewEvaluatorRecordServiceImpl,
 		NewEvaluatorSourceServices,
 		llm.NewLLMRPCProvider,
-		NewStubRuntimeFactory,
-		NewStubRuntimeManagerFromFactory,
+		NewRuntimeFactory,
+		NewRuntimeManagerFromFactory,
 		NewSandboxConfig,
 		NewLogger,
 
@@ -306,14 +307,14 @@ func NewLogger() *logrus.Logger {
 	return logger
 }
 
-// NewStubRuntimeFactory 创建存根运行时工厂
-func NewStubRuntimeFactory(logger *logrus.Logger, sandboxConfig *entity.SandboxConfig) component.IRuntimeFactory {
-	return service.NewStubRuntimeFactory(logger, sandboxConfig)
+// NewRuntimeFactory 创建运行时工厂
+func NewRuntimeFactory(logger *logrus.Logger, sandboxConfig *entity.SandboxConfig) component.IRuntimeFactory {
+	return runtime.NewRuntimeFactory(logger, sandboxConfig)
 }
 
-// NewStubRuntimeManagerFromFactory 从工厂创建存根运行时管理器
-func NewStubRuntimeManagerFromFactory(factory component.IRuntimeFactory, logger *logrus.Logger) component.IRuntimeManager {
-	return service.NewStubRuntimeManager(factory, logger)
+// NewRuntimeManagerFromFactory 从工厂创建运行时管理器
+func NewRuntimeManagerFromFactory(factory component.IRuntimeFactory, logger *logrus.Logger) component.IRuntimeManager {
+	return runtime.NewRuntimeManager(factory, logger)
 }
 
 func NewEvaluatorSourceServices(
@@ -336,4 +337,4 @@ func NewEvaluatorSourceServices(
 		serviceMap[svc.EvaluatorType()] = svc
 	}
 	return serviceMap
-}
+}