Function demonstrateWithSchema

examples/memory-working/main.go:168–231

(ctx context.Context, backend backends.BackendProtocol)

}

func demonstrateWithSchema(ctx context.Context, backend backends.BackendProtocol) {
	// 定义 JSON Schema
	schema := &memory.JSONSchema{
		Type: "object",
		Properties: map[string]*memory.JSONSchema{
			"user_name": {Type: "string"},
			"role":      {Type: "string"},
			"task_status": {
				Type: "string",
				Enum: []any{"not_started", "in_progress", "completed"},
			},
			"preferences": {
				Type:  "array",
				Items: &memory.JSONSchema{Type: "string"},
			},
		},
		Required: []string{"user_name", "task_status"},
	}

	manager, err := memory.NewWorkingMemoryManager(&memory.WorkingMemoryConfig{
		Backend:  backend,
		BasePath: "/working_memory_schema/",
		Scope:    memory.ScopeThread,
		Schema:   schema,
	})
	if err != nil {
		log.Fatalf("create manager with schema: %v", err)
	}

	threadID := "structured-session"
	resourceID := "demo"

	// 有效的 JSON（符合 schema）
	validJSON := `{
  "user_name": "Alice",
  "role": "Engineer",
  "task_status": "in_progress",
  "preferences": ["TypeScript", "Functional Programming"]
}`

	err = manager.Update(ctx, threadID, resourceID, validJSON)
	if err != nil {
		log.Fatalf("unexpected error with valid JSON: %v", err)
	}
	fmt.Println("✓ 有效的 JSON 更新成功")

	// 无效的 JSON（缺少必需字段）
	invalidJSON := `{
  "user_name": "Bob"
}`

	err = manager.Update(ctx, threadID, resourceID, invalidJSON)
	if err != nil {
		fmt.Printf("✓ 无效的 JSON 被拒绝（预期行为）: %v\n", err)
	} else {
		fmt.Println("❌ 无效的 JSON 应该被拒绝")
	}