Method AppendEvent

pkg/session/postgres/service.go:207–304

AppendEvent 实现 session.Service 接口

(ctx context.Context, sessionID string, event *session.Event)

// AppendEvent 实现 session.Service 接口
func (s *Service) AppendEvent(ctx context.Context, sessionID string, event *session.Event) error {
	return s.db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
		// 1. 序列化事件内容
		contentJSON, err := json.Marshal(event.Content)
		if err != nil {
			return fmt.Errorf("marshal content: %w", err)
		}

		// 2. 序列化事件动作
		var actionsJSON []byte
		if event.Actions.StateDelta != nil || event.Actions.ArtifactDelta != nil {
			actionsJSON, err = json.Marshal(event.Actions)
			if err != nil {
				return fmt.Errorf("marshal actions: %w", err)
			}
		}

		// 3. 序列化元数据
		var metadataJSON []byte
		if len(event.Metadata) > 0 {
			metadataJSON, err = json.Marshal(event.Metadata)
			if err != nil {
				return fmt.Errorf("marshal metadata: %w", err)
			}
		}

		// 4. 创建事件记录
		eventModel := &EventModel{
			ID:                 event.ID,
			SessionID:          sessionID,
			InvocationID:       event.InvocationID,
			Branch:             event.Branch,
			Author:             event.Author,
			AgentID:            event.AgentID,
			Timestamp:          event.Timestamp,
			Content:            contentJSON,
			Actions:            actionsJSON,
			LongRunningToolIDs: event.LongRunningToolIDs,
			Metadata:           metadataJSON,
		}

		if err := tx.Create(eventModel).Error; err != nil {
			return fmt.Errorf("create event: %w", err)
		}

		// 5. 应用状态变更（StateDelta）
		if len(event.Actions.StateDelta) > 0 {
			for key, value := range event.Actions.StateDelta {
				scope, actualKey := parseStateKey(key)

				// 序列化值
				valueJSON, err := json.Marshal(value)
				if err != nil {
					return fmt.Errorf("marshal state value: %w", err)
				}

				now := time.Now()