Method AddSession

pkg/session/store.go:594–633

AddSession adds a new session to the store, including any messages

(ctx context.Context, session *Session)

// AddSession adds a new session to the store, including any messages
func (s *SQLiteSessionStore) AddSession(ctx context.Context, session *Session) error {
	if session.ID == "" {
		return ErrEmptyID
	}

	fields, err := sessionPersistedFieldsOf(session)
	if err != nil {
		return err
	}

	// Use a transaction to insert session and its items
	tx, err := s.db.BeginTx(ctx, nil)
	if err != nil {
		return err
	}
	defer func() { _ = tx.Rollback() }()

	_, err = tx.ExecContext(ctx,
		`INSERT INTO sessions (
			id, tools_approved, input_tokens, output_tokens, title, cost, send_user_message,
			max_iterations, working_dir, created_at, permissions, agent_model_overrides,
			custom_models_used, thinking, parent_id
		) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
		session.ID, session.ToolsApproved, session.InputTokens, session.OutputTokens, session.Title,
		session.Cost, session.SendUserMessage, session.MaxIterations, session.WorkingDir,
		session.CreatedAt.Format(time.RFC3339), fields.PermissionsJSON, fields.AgentModelOverridesJSON,
		fields.CustomModelsUsedJSON, false, fields.ParentID)
	if err != nil {
		return err
	}

	// Insert all messages into session_items
	for position, item := range session.Messages {
		if err := s.addItemTx(ctx, tx, session.ID, position, item); err != nil {
			return fmt.Errorf("adding item at position %d: %w", position, err)
		}
	}

	return tx.Commit()
}

// scanSession scans a single row into a Session struct.
// Note: Messages are loaded separately from session_items table.