fix: partial port of e0919ce - validation types + cache id stripping

Author: ImogeneOctaviap794

api/validation.go

@@ -622,6 +622,13 @@ func ValidateInput() ValidationRule {
 			"message":                true,
 			"function_call":          true,
 			"function_call_output":   true,
+			"input_text":             true,
+			"input_image":            true,
+			"output_text":            true,
+			"refusal":                true,
+			"input_file":             true,
+			"computer_screenshot":    true,
+			"summary_text":           true,
 			"file":                   true,
 			"image":                  true,
 		}

proxy/response_cache.go

@@ -223,22 +223,49 @@ func cacheCompletedResponse(expandedInputRaw []byte, completedData []byte) {
 
 	var items []json.RawMessage
 
-	// 添加展开后的请求 input items
+	// 添加展开后的请求 input items（剥离 id）
 	inputItems := gjson.ParseBytes(expandedInputRaw)
 	if inputItems.IsArray() {
 		inputItems.ForEach(func(_, v gjson.Result) bool {
-			items = append(items, json.RawMessage(v.Raw))
+			if item, ok := stripResponseItemID(json.RawMessage(v.Raw)); ok {
+				items = append(items, item)
+			}
 			return true
 		})
 	}
 
-	// 添加响应 output items
+	// 添加响应 output 中真正需要续链的工具上下文；reasoning/message 等
+	// 服务端输出 item 带有 rs_/msg_ id，store=false 时回灌会触发 item not found。
 	output.ForEach(func(_, v gjson.Result) bool {
-		items = append(items, json.RawMessage(v.Raw))
+		if v.Get("type").String() != "function_call" {
+			return true
+		}
+		if item, ok := stripResponseItemID(json.RawMessage(v.Raw)); ok {
+			items = append(items, item)
+		}
 		return true
 	})
 
 	if len(items) > 0 {
 		setResponseCache(respID, items)
 	}
 }
+
+// stripResponseItemID 去掉缓存 item 的 id 字段（保留 call_id）。
+// 服务端返回的 rs_/msg_/fc_ 前缀 id 在 store=false 的 replay 场景下
+// 会触发上游 "item not found"，而 call_id 是请求方自定义的工具调用链 id，必须保留。
+func stripResponseItemID(raw json.RawMessage) (json.RawMessage, bool) {
+	var item map[string]any
+	if err := json.Unmarshal(raw, &item); err != nil || item == nil {
+		return raw, true
+	}
+	if _, exists := item["id"]; !exists {
+		return raw, true
+	}
+	delete(item, "id")
+	stripped, err := json.Marshal(item)
+	if err != nil {
+		return nil, false
+	}
+	return stripped, true
+}

proxy/response_cache_test.go

@@ -60,3 +60,37 @@ func TestExpandPreviousResponseLeavesBodyUntouchedOnCacheMiss(t *testing.T) {
 		t.Fatalf("body mutated on cache miss; got=%s want=%s", got, body)
 	}
 }
+
+func TestCacheCompletedResponseStripsItemIDsAndSkipsReasoning(t *testing.T) {
+	resetResponseCacheForTest()
+
+	cacheCompletedResponse(
+		[]byte(`[{"type":"message","id":"msg_input","role":"user","content":"call a tool"}]`),
+		[]byte(`{"type":"response.completed","response":{"id":"resp_strip","output":[`+
+			`{"type":"reasoning","id":"rs_0609","encrypted_content":"opaque"},`+
+			`{"type":"message","id":"msg_output","role":"assistant","content":[{"type":"output_text","text":"thinking"}]},`+
+			`{"type":"function_call","id":"fc_123","call_id":"call_abc","name":"lookup","arguments":"{}"}`+
+			`]}}`),
+	)
+
+	cached := getResponseCache("resp_strip")
+	if len(cached) != 2 {
+		t.Fatalf("cached items = %d, want input message + function_call only (reasoning/message output should be skipped)", len(cached))
+	}
+	if typ := gjson.GetBytes(cached[0], "type").String(); typ != "message" {
+		t.Fatalf("cached[0].type = %q, want message", typ)
+	}
+	if id := gjson.GetBytes(cached[0], "id"); id.Exists() {
+		t.Fatalf("cached input id should be stripped, got %s", id.Raw)
+	}
+	if typ := gjson.GetBytes(cached[1], "type").String(); typ != "function_call" {
+		t.Fatalf("cached[1].type = %q, want function_call", typ)
+	}
+	if id := gjson.GetBytes(cached[1], "id"); id.Exists() {
+		t.Fatalf("cached function_call id should be stripped, got %s", id.Raw)
+	}
+	// call_id 必须保留——它是续链所依赖的关键字段
+	if callID := gjson.GetBytes(cached[1], "call_id").String(); callID != "call_abc" {
+		t.Fatalf("cached function_call call_id = %q, want call_abc (must be preserved)", callID)
+	}
+}