Function stateManagementExample

examples/session-postgres/main.go:142–193

stateManagementExample 状态管理示例

(ctx context.Context, service *postgres.Service, sessionID string)

// stateManagementExample 状态管理示例
func stateManagementExample(ctx context.Context, service *postgres.Service, sessionID string) {
	// 1. 添加不同作用域的状态
	event := &session.Event{
		ID:           "evt-" + generateID(),
		Timestamp:    time.Now(),
		InvocationID: "inv-002",
		AgentID:      "agent-customer-support",
		Branch:       "root",
		Author:       "system",
		Content: types.Message{
			Role:    types.RoleSystem,
			Content: "State update",
		},
		Actions: session.EventActions{
			StateDelta: map[string]any{
				// App 级状态（所有用户共享）
				"app:version": "1.0.0",
				"app:feature_flags": map[string]bool{
					"enable_voice": true,
					"enable_video": false,
				},

				// User 级状态（该用户所有会话共享）
				"user:language": "zh-CN",
				"user:theme":    "dark",
				"user:timezone": "Asia/Shanghai",

				// Session 级状态（当前会话）
				"session:start_time":         time.Now().Unix(),
				"session:conversation_topic": "帮助咨询",

				// Temp 级状态（临时）
				"temp:cache_key": "temp-value",
			},
		},
	}

	if err := service.AppendEvent(ctx, sessionID, event); err != nil {
		log.Fatalf("Failed to update state: %v", err)
	}

	// 2. 查询状态
	state, err := service.GetState(ctx, sessionID, "")
	if err != nil {
		log.Fatalf("Failed to get state: %v", err)
	}

	fmt.Printf("✅ State updated (%d keys)\n", len(state))
	fmt.Println("   App state: version =", state["app:version"])
	fmt.Println("   User state: language =", state["user:language"])
	fmt.Println("   Session state: topic =", state["session:conversation_topic"])
}

// artifactVersioningExample 工件版本管理示例
func artifactVersioningExample(ctx context.Context, service *postgres.Service, sessionID string) {