Function appendEventsExample

examples/session-postgres/main.go:95–139

appendEventsExample 追加事件示例

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

// appendEventsExample 追加事件示例
func appendEventsExample(ctx context.Context, service *postgres.Service, sessionID string) {
	// 1. 用户消息事件
	userEvent := &session.Event{
		ID:           "evt-" + generateID(),
		Timestamp:    time.Now(),
		InvocationID: "inv-001",
		AgentID:      "agent-customer-support",
		Branch:       "root",
		Author:       "user",
		Content: types.Message{
			Role:    types.RoleUser,
			Content: "我需要帮助",
		},
	}

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

	// 2. Agent 响应事件（带状态变更）
	agentEvent := &session.Event{
		ID:           "evt-" + generateID(),
		Timestamp:    time.Now(),
		InvocationID: "inv-001",
		AgentID:      "agent-customer-support",
		Branch:       "root",
		Author:       "assistant",
		Content: types.Message{
			Role:    types.RoleAssistant,
			Content: "我很乐意帮助您！请问有什么问题吗？",
		},
		Actions: session.EventActions{
			StateDelta: map[string]any{
				"session:last_response_time": time.Now().Unix(),
				"session:message_count":      1,
			},
		},
	}

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

	fmt.Println("✅ Appended 2 events")
}

// stateManagementExample 状态管理示例
func stateManagementExample(ctx context.Context, service *postgres.Service, sessionID string) {