Validate dynamic tool schemas

Author: SqlRush

docs/cc-100-roadmap.md

@@ -295,6 +295,8 @@ M5/M9 补充：通用 tool schema validator 现在支持 `required` 的 Go `[]st
 
 M5/M9 补充：通用 tool schema validator 现在支持 `const`、`pattern`、`maxLength`、`minItems`/`maxItems`、`minProperties`/`maxProperties`、`exclusiveMinimum`/`exclusiveMaximum` 以及 `allOf`/`anyOf`/`oneOf`，并兼容 Go 代码直接构造的 typed schema list，外部 MCP 工具 schema 的基础 JSON Schema 约束会在本地调用前执行。
 
+M4/M5/M10 补充：`FuncTool.Validate` 现在使用与模型 tool definition 同源的动态 `InputSchemaFunc`，本地执行前校验会应用 Task subagent enum 等 runtime metadata 驱动的 schema 约束，避免“模型看到的 schema”和“实际执行校验”分叉。
+
 M7 补充：scripted permission payload、dialog expectation、event、cancel-permission 和 dialog-result expectation 现在接受 `ID`/`ToolName`/`Actions`、`permissionID`、`requestID`、`toolUseID`、`operationID`、`operation`、`commandName`、`resourcePath`、`body`、`reasonText`、`allowedActions`、`buttons` 等相邻字段，并支持数字 request ID。
 
 M6 补充：microcompact disk cache loader 和 prune 现在接受 digest 缺失但文件名已 keyed 的 cache entry，会用 `<digest>.json` 文件名作为 digest fallback，同时保留显式 digest mismatch 的 invalid-cache guard。

docs/claude-code-go-rewrite-plan.md

@@ -188,6 +188,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：通用 tool schema validator 现在支持数字 `minimum`/`maximum`，可直接执行 LSPDiagnostics `limit` 等工具 schema 的数值范围契约。
 - 本轮补充：通用 tool schema validator 现在支持 `required` 的 Go `[]string` 形态和 object `additionalProperties` schema 校验，MCP `get_prompt.arguments` 会在 schema 层拒绝非字符串参数值。
 - 本轮补充：通用 tool schema validator 现在支持 `const`、`pattern`、`maxLength`、`minItems`/`maxItems`、`minProperties`/`maxProperties`、`exclusiveMinimum`/`exclusiveMaximum` 以及 `allOf`/`anyOf`/`oneOf`，并兼容 Go 代码直接构造的 typed schema list，外部 MCP 工具 schema 的基础 JSON Schema 约束会在本地调用前执行。
+- 本轮补充：`FuncTool.Validate` 现在使用与模型 tool definition 同源的动态 `InputSchemaFunc`，本地执行前校验会应用 Task subagent enum 等 runtime metadata 驱动的 schema 约束，避免“模型看到的 schema”和“实际执行校验”分叉。
 - 本轮补充：WebFetch/WebSearch 输入解码现在兼容 `timeout`、`max_bytes`/`maxBytes`、`max_results`/`maxResults` 的 quoted semantic string 数值；WebSearch 也会按官方校验拒绝同一请求同时设置 `allowed_domains` 和 `blocked_domains`。
 - 本轮补充：Grep 现在支持 whole-word 搜索参数 `word_regexp`/`wordRegexp`/`word-regexp`/`-w`，在 regex 和 fixed-string 模式下按词边界过滤匹配，并兼容 quoted boolean 输入。
 - 本轮补充：Grep 现在支持反向匹配参数 `invert_match`/`invertMatch`/`invert-match`/`-v`，`files_with_matches`、`content`、`count` 和 multiline 模式都会按非匹配行/未覆盖行输出，并兼容 quoted boolean 输入。

internal/tool/func_tool.go

@@ -73,7 +73,7 @@ func (t FuncTool) Validate(ctx Context, raw json.RawMessage) error {
 	if err != nil {
 		return err
 	}
-	if err := ValidateSchema(t.DefinitionValue.InputSchema, normalized); err != nil {
+	if err := ValidateSchema(t.validationSchema(ctx), normalized); err != nil {
 		return err
 	}
 	if t.ValidateFunc != nil {
@@ -82,6 +82,16 @@ func (t FuncTool) Validate(ctx Context, raw json.RawMessage) error {
 	return nil
 }
 
+func (t FuncTool) validationSchema(ctx Context) contracts.JSONSchema {
+	if t.InputSchemaFunc == nil {
+		return t.DefinitionValue.InputSchema
+	}
+	return t.InputSchema(PromptContext{
+		WorkingDirectory: ctx.WorkingDirectory,
+		Metadata:         ctx.Metadata,
+	})
+}
+
 func (t FuncTool) CheckPermissions(ctx Context, raw json.RawMessage) (contracts.PermissionDecision, error) {
 	normalized, err := t.normalizeInput(raw)
 	if err != nil {

internal/tool/tool_test.go

@@ -159,6 +159,39 @@ func TestValidateSchemaAdvancedConstraints(t *testing.T) {
 	}
 }
 
+func TestFuncToolValidateUsesDynamicInputSchema(t *testing.T) {
+	dynamic := FuncTool{
+		DefinitionValue: contracts.ToolDefinition{
+			Name: "Dynamic",
+			InputSchema: contracts.JSONSchema{
+				"type": "object",
+				"properties": map[string]any{
+					"mode": map[string]any{"type": "string", "enum": []any{"static"}},
+				},
+			},
+		},
+		InputSchemaFunc: func(ctx PromptContext) contracts.JSONSchema {
+			allowed, _ := ctx.Metadata["allowed_mode"].(string)
+			if allowed == "" {
+				allowed = "dynamic"
+			}
+			return contracts.JSONSchema{
+				"type": "object",
+				"properties": map[string]any{
+					"mode": map[string]any{"type": "string", "enum": []any{allowed}},
+				},
+			}
+		},
+	}
+	ctx := Context{Metadata: map[string]any{"allowed_mode": "dynamic"}}
+	if err := dynamic.Validate(ctx, json.RawMessage(`{"mode":"dynamic"}`)); err != nil {
+		t.Fatal(err)
+	}
+	if err := dynamic.Validate(ctx, json.RawMessage(`{"mode":"static"}`)); err == nil || !strings.Contains(err.Error(), "input.mode must be one of dynamic") {
+		t.Fatalf("err = %v", err)
+	}
+}
+
 func TestExecutorRunsAllowedTool(t *testing.T) {
 	engine := permissions.NewEngine(contracts.PermissionContext{Mode: contracts.PermissionDefault})
 	registry, err := NewRegistry(FuncTool{

internal/tools/task/tools_test.go

@@ -1497,7 +1497,7 @@ func TestTaskToolUsesAvailableAgentsInPromptSchemaAndValidation(t *testing.T) {
 		Name:  "Task",
 		Input: json.RawMessage(`{"description":"Review API","prompt":"Inspect API changes","subagent_type":"missing:agent"}`),
 	}, nil)
-	if err == nil || !strings.Contains(err.Error(), `subagent_type "missing:agent" is not available`) {
+	if err == nil || !strings.Contains(err.Error(), "input.subagent_type must be one of general-purpose, demo:reviewer") {
 		t.Fatalf("err = %v", err)
 	}
 }