Method AppendEvent

pkg/session/sqlite/store.go:275–328

AppendEvent adds an event to a session.

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

// AppendEvent adds an event to a session.
func (s *Service) AppendEvent(ctx context.Context, sessionID string, event *session.Event) error {
	s.mu.Lock()
	defer s.mu.Unlock()

	// Check session exists
	var exists bool
	err := s.db.QueryRowContext(ctx, `SELECT 1 FROM sessions WHERE id = ?`, sessionID).Scan(&exists)
	if errors.Is(err, sql.ErrNoRows) {
		return session.ErrSessionNotFound
	}
	if err != nil {
		return fmt.Errorf("check session: %w", err)
	}

	// Serialize fields
	contentJSON, err := json.Marshal(event.Content)
	if err != nil {
		return fmt.Errorf("marshal content: %w", err)
	}

	actionsJSON, err := json.Marshal(event.Actions)
	if err != nil {
		return fmt.Errorf("marshal actions: %w", err)
	}

	toolIDsJSON, err := json.Marshal(event.LongRunningToolIDs)
	if err != nil {
		return fmt.Errorf("marshal tool ids: %w", err)
	}

	metadataJSON, err := json.Marshal(event.Metadata)
	if err != nil {
		return fmt.Errorf("marshal metadata: %w", err)
	}

	now := time.Now()
	if event.ID == "" {
		event.ID = uuid.New().String()
	}

	_, err = s.db.ExecContext(ctx,
		`INSERT INTO events (id, session_id, invocation_id, agent_id, branch, author, content, reasoning, actions, long_running_tool_ids, metadata, created_at)
		 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
		event.ID, sessionID, event.InvocationID, event.AgentID, event.Branch, event.Author,
		string(contentJSON), event.Reasoning, string(actionsJSON), string(toolIDsJSON), string(metadataJSON), now,
	)
	if err != nil {
		return fmt.Errorf("insert event: %w", err)
	}

	// Update session timestamp
	_, err = s.db.ExecContext(ctx, `UPDATE sessions SET updated_at = ? WHERE id = ?`, now, sessionID)
	return err
}

// GetEvents retrieves events for a session.
func (s *Service) GetEvents(ctx context.Context, sessionID string, filter *session.EventFilter) ([]session.Event, error) {