chore: Simplify database service.

2025-12-29 13:19:07 +00:00 · 2025-09-30 22:15:01 +01:00
26 changed files with 1474 additions and 1179 deletions
--- a/.pre-commit-config.yaml
+++ b/.pre-commit-config.yaml
@@ -10,6 +10,7 @@ repos:
      - id: trailing-whitespace
        exclude: ".*\\.md$"
      - id: end-of-file-fixer
+      - id: check-added-large-files
  - repo: local
    hooks:
      - id: mypy
--- a/AGENTS.md
+++ b/AGENTS.md
@@ -41,7 +41,7 @@ The command outputs instructions for setting the required environment variable t
   uv run leggen server
   ```
   - For development mode with auto-reload: `uv run leggen server --reload`
-   - API will be available at `http://localhost:8000` with docs at `http://localhost:8000/api/v1/docs`
+   - API will be available at `http://localhost:8000` with docs at `http://localhost:8000/docs`

 ### Start the Frontend
 1. Navigate to the frontend directory: `cd frontend`
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,39 +1,4 @@

-## 2025.10.2 (2025/10/06)
-
-### Bug Fixes
-
- **frontend:** Improve nginx config. ([d78f4811](https://github.com/elisiariocouto/leggen/commit/d78f4811922df7e637abe65b1d0b1157dd331c3c))
- **frontend:** Include default mime types. ([7c06a1d8](https://github.com/elisiariocouto/leggen/commit/7c06a1d8b9bca3da2c481d9e89e7564cfffe32a3))
-
-
-
-## 2025.10.1 (2025/10/05)
-
-### Bug Fixes
-
- **frontend:** Fix PWA caching system, remove prompts. ([1cd63731](https://github.com/elisiariocouto/leggen/commit/1cd63731a35a1c77a59d7ae1a898ad8f22e362e4))
-
-
-### Documentation
-
-  Improve documentation, add gif showing web app. ([0750c41b](https://github.com/elisiariocouto/leggen/commit/0750c41b7b6634900ec19b1701d58b06346028e3))
-
-
-### Refactor
-
- **frontend:** Standardize button styling using shadcn Button component. ([38fddeb2](https://github.com/elisiariocouto/leggen/commit/38fddeb281588de41d8ff6292c1dd48443a059a4))
-
-
-
-## 2025.10.0 (2025/10/01)
-
-### Bug Fixes
-
- **gocardless:** Increase timeout to 30 seconds, some requests take some time. ([ca7968cc](https://github.com/elisiariocouto/leggen/commit/ca7968cc3c625e243fe2d75590a9e56f3100072b))
-
-
-
 ## 2025.9.26 (2025/09/30)

 ### Debug
--- a/README.md
+++ b/README.md
@@ -1,21 +1,13 @@
 # 💲 leggen

+An Open Banking CLI and API service for managing bank connections and transactions.

-A self hosted Open Banking Dashboard, API and CLI for managing bank connections and transactions.
+This tool provides a **unified command-line interface** (`leggen`) with both CLI commands and an integrated **FastAPI backend service**, plus a **React Web Interface** to connect to banks using the GoCardless Open Banking API.

 Having your bank data accessible through both CLI and REST API gives you the power to backup, analyze, create reports, and integrate with other applications.

-![Leggen demo](docs/leggen_demo.gif)
-
 ## 🛠️ Technologies

-  ### Frontend
-  - [React](https://reactjs.org/): Modern web interface with TypeScript
-  - [Vite](https://vitejs.dev/): Fast build tool and development server
-  - [Tailwind CSS](https://tailwindcss.com/): Utility-first CSS framework
-  - [shadcn/ui](https://ui.shadcn.com/): Modern component system built on Radix UI
-  - [TanStack Query](https://tanstack.com/query): Powerful data synchronization for React
-
  ### 🔌 API & Backend
  - [FastAPI](https://fastapi.tiangolo.com/): High-performance async API backend (integrated into `leggen server`)
  - [GoCardless Open Banking API](https://developer.gocardless.com/bank-account-data/overview): for connecting to banks
@@ -24,6 +16,12 @@ Having your bank data accessible through both CLI and REST API gives you the pow
  ### 📦 Storage
  - [SQLite](https://www.sqlite.org): for storing transactions, simple and easy to use

+  ### Frontend
+  - [React](https://reactjs.org/): Modern web interface with TypeScript
+  - [Vite](https://vitejs.dev/): Fast build tool and development server
+  - [Tailwind CSS](https://tailwindcss.com/): Utility-first CSS framework
+  - [shadcn/ui](https://ui.shadcn.com/): Modern component system built on Radix UI
+  - [TanStack Query](https://tanstack.com/query): Powerful data synchronization for React

 ## ✨ Features

@@ -56,9 +54,10 @@ Having your bank data accessible through both CLI and REST API gives you the pow
 1. Create a GoCardless account at [https://gocardless.com/bank-account-data/](https://gocardless.com/bank-account-data/)
 2. Get your API credentials (key and secret)

-### Installation
+### Installation Options

-#### Docker Compose (Recommended)
+#### Option 1: Docker Compose (Recommended)
+The easiest way to get started is with Docker Compose, which includes both the React frontend and FastAPI backend:

 ```bash
 # Clone the repository
@@ -69,11 +68,50 @@ cd leggen
 mkdir -p data && cp config.example.toml data/config.toml
 # Edit data/config.toml with your GoCardless credentials

-# Start all services
+# Start all services (frontend + backend)
 docker compose up -d

 # Access the web interface at http://localhost:3000
-# API documentation at http://localhost:3000/api/v1/docs
+# API is available at http://localhost:8000
+```
+
+#### Production Deployment
+
+For production deployment using published Docker images:
+
+```bash
+# Clone the repository
+git clone https://github.com/elisiariocouto/leggen.git
+cd leggen
+
+# Create your configuration
+mkdir -p data && cp config.example.toml data/config.toml
+# Edit data/config.toml with your GoCardless credentials
+
+# Start production services
+docker compose up -d
+
+# Access the web interface at http://localhost:3000
+# API is available at http://localhost:8000
+```
+
+### Development vs Production
+
+- **Development**: Use `docker compose -f compose.dev.yml up -d` (builds from source)
+- **Production**: Use `docker compose up -d` (uses published images)
+
+#### Option 2: Local Development
+For development or local installation:
+
+```bash
+# Install with uv (recommended) or pip
+uv sync  # or pip install -e .
+
+# Start the API service
+uv run leggen server --reload  # Development mode with auto-reload
+
+# Use the CLI (in another terminal)
+uv run leggen --help
 ```

 ### Configuration
@@ -115,22 +153,214 @@ case_sensitive = ["SpecificStore"]

 ## 📖 Usage

-### Web Interface
-Access the React web interface at `http://localhost:3000` after starting the services.
+### API Service (`leggen server`)

-### API Service
-Visit `http://localhost:3000/api/v1/docs` for interactive API documentation.
+Start the FastAPI backend service:

-### CLI Commands
 ```bash
-leggen status              # Check connection status
-leggen bank add            # Connect to a new bank
-leggen balances            # View account balances
-leggen transactions        # List transactions
-leggen sync                # Trigger background sync
+# Production mode
+leggen server
+
+# Development mode with auto-reload
+leggen server --reload
+
+# Custom host and port
+leggen server --host 127.0.0.1 --port 8080
 ```

-For more options, run `leggen --help` or `leggen <command> --help`.
+**API Documentation**: Visit `http://localhost:8000/docs` for interactive API documentation.
+
+### CLI Commands (`leggen`)
+
+#### Basic Commands
+```bash
+# Check connection status
+leggen status
+
+# Connect to a new bank
+leggen bank add
+
+# View account balances
+leggen balances
+
+# List recent transactions
+leggen transactions --limit 20
+
+# View detailed transactions
+leggen transactions --full
+```
+
+#### Sync Operations
+```bash
+# Start background sync
+leggen sync
+
+# Synchronous sync (wait for completion)
+leggen sync --wait
+
+# Force sync (override running sync)
+leggen sync --force --wait
+```
+
+#### API Integration
+```bash
+# Use custom API URL
+leggen --api-url http://localhost:8080 status
+
+# Set via environment variable
+export LEGGEN_API_URL=http://localhost:8080
+leggen status
+```
+
+### Docker Usage
+
+#### Development (build from source)
+```bash
+# Start development services
+docker compose -f compose.dev.yml up -d
+
+# View service status
+docker compose -f compose.dev.yml ps
+
+# Check logs
+docker compose -f compose.dev.yml logs frontend
+docker compose -f compose.dev.yml logs leggen-server
+
+# Stop development services
+docker compose -f compose.dev.yml down
+```
+
+#### Production (use published images)
+```bash
+# Start production services
+docker compose up -d
+
+# View service status
+docker compose ps
+
+# Check logs
+docker compose logs frontend
+docker compose logs leggen-server
+
+# Access the web interface at http://localhost:3000
+# API documentation at http://localhost:8000/docs
+
+# Stop production services
+docker compose down
+```
+
+## 🔌 API Endpoints
+
+The FastAPI backend provides comprehensive REST endpoints:
+
+### Banks & Connections
+- `GET /api/v1/banks/institutions?country=PT` - List available banks
+- `POST /api/v1/banks/connect` - Create bank connection
+- `GET /api/v1/banks/status` - Connection status
+- `GET /api/v1/banks/countries` - Supported countries
+
+### Accounts & Balances
+- `GET /api/v1/accounts` - List all accounts
+- `GET /api/v1/accounts/{id}` - Account details
+- `GET /api/v1/accounts/{id}/balances` - Account balances
+- `GET /api/v1/accounts/{id}/transactions` - Account transactions
+
+### Transactions
+- `GET /api/v1/transactions` - All transactions with filtering
+- `GET /api/v1/transactions/stats` - Transaction statistics
+
+### Sync & Scheduling
+- `POST /api/v1/sync` - Trigger background sync
+- `POST /api/v1/sync/now` - Synchronous sync
+- `GET /api/v1/sync/status` - Sync status
+- `GET/PUT /api/v1/sync/scheduler` - Scheduler configuration
+
+### Notifications
+- `GET/PUT /api/v1/notifications/settings` - Manage notifications
+- `POST /api/v1/notifications/test` - Test notifications
+
+## 🛠️ Development
+
+### Local Development Setup
+```bash
+# Clone and setup
+git clone https://github.com/elisiariocouto/leggen.git
+cd leggen
+
+# Install dependencies
+uv sync
+
+# Start API service with auto-reload
+uv run leggen server --reload
+
+# Use CLI commands
+uv run leggen status
+```
+
+### Testing
+
+Run the comprehensive test suite with:
+
+```bash
+# Run all tests
+uv run pytest
+
+# Run unit tests only
+uv run pytest tests/unit/
+
+# Run with verbose output
+uv run pytest tests/unit/ -v
+
+# Run specific test files
+uv run pytest tests/unit/test_config.py -v
+uv run pytest tests/unit/test_scheduler.py -v
+uv run pytest tests/unit/test_api_banks.py -v
+
+# Run tests by markers
+uv run pytest -m unit      # Unit tests
+uv run pytest -m api       # API endpoint tests
+uv run pytest -m cli       # CLI tests
+```
+
+The test suite includes:
+- **Configuration management tests** - TOML config loading/saving
+- **API endpoint tests** - FastAPI route testing with mocked dependencies
+- **CLI API client tests** - HTTP client integration testing
+- **Background scheduler tests** - APScheduler job management
+- **Mock data and fixtures** - Realistic test data for banks, accounts, transactions
+
+### Code Structure
+```
+leggen/              # CLI application
+├── commands/        # CLI command implementations
+├── utils/           # Shared utilities
+├── api/             # FastAPI API routes and models
+├── services/        # Business logic
+├── background/      # Background job scheduler
+└── api_client.py    # API client for server communication
+
+tests/               # Test suite
+├── conftest.py      # Shared test fixtures
+└── unit/            # Unit tests
+    ├── test_config.py      # Configuration tests
+    ├── test_scheduler.py   # Background scheduler tests
+    ├── test_api_banks.py   # Banks API tests
+    ├── test_api_accounts.py # Accounts API tests
+    └── test_api_client.py  # CLI API client tests
+```
+
+### Contributing
+1. Fork the repository
+2. Create a feature branch
+3. Make your changes with tests
+4. Submit a pull request
+
+The repository uses GitHub Actions for CI/CD:
+- **CI**: Runs Python tests (`uv run pytest`) and frontend linting/build on every push
+- **Release**: Creates GitHub releases with changelog when tags are pushed

 ## ⚠️ Notes
 - This project is in active development
+- GoCardless API rate limits apply
+- Some banks may require additional authorization steps
+- Docker images are automatically built and published on releases
--- a/docs/leggen_demo.gif
+++ b/docs/leggen_demo.gif
--- a/frontend/default.conf.template
+++ b/frontend/default.conf.template
@@ -1,102 +1,33 @@
 server {
-
-    # MIME types for PWA
-    include mime.types;
-    types {
-       application/manifest+json  webmanifest;
-    }
-
    listen 80;
    server_name localhost;
    root /usr/share/nginx/html;
    index index.html;

-    # Trust proxy headers from Caddy/upstream proxy
-    set_real_ip_from 0.0.0.0/0;
-    real_ip_header X-Forwarded-For;
-    real_ip_recursive on;
-
-    # Security headers
-    add_header X-Content-Type-Options "nosniff" always;
-    add_header X-Frame-Options "SAMEORIGIN" always;
-    add_header X-XSS-Protection "1; mode=block" always;
-    add_header Referrer-Policy "strict-origin-when-cross-origin" always;
-
    # Enable gzip compression
    gzip on;
    gzip_vary on;
    gzip_min_length 1024;
    gzip_proxied expired no-cache no-store private auth;
-    gzip_types text/plain text/css text/xml text/javascript application/javascript application/xml+rss application/json application/manifest+json image/svg+xml;
+    gzip_types text/plain text/css text/xml text/javascript application/javascript application/xml+rss application/json;

-    # Service worker - no cache, must revalidate
-    location ~ ^/(sw\.js|workbox-.*\.js)$ {
-        add_header Cache-Control "no-cache, no-store, must-revalidate" always;
-        add_header Pragma "no-cache" always;
-        add_header Expires "0" always;
-        add_header Service-Worker-Allowed "/" always;
-        types {
-            application/javascript js;
-        }
-    }
-
-    # PWA manifest - short cache with revalidation
-    location ~ ^/manifest\.webmanifest$ {
-        add_header Cache-Control "public, max-age=3600, must-revalidate" always;
-        types {
-            application/manifest+json webmanifest;
-        }
-    }
-
-    # Handle client-side routing (SPA)
+    # Handle client-side routing
    location / {
-        autoindex off;
-        expires off;
-        add_header Cache-Control "public, max-age=0, s-maxage=0, must-revalidate" always;
-        try_files $uri $uri/ /index.html =404;
+        try_files $uri $uri/ /index.html;
    }

    # API proxy to backend (configurable via API_BACKEND_URL env var)
    location /api/ {
        proxy_pass ${API_BACKEND_URL};
-        proxy_set_header Host $http_host;
+        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-        proxy_set_header X-Forwarded-Proto $http_x_forwarded_proto;
-        proxy_set_header X-Forwarded-Host $http_x_forwarded_host;
-        proxy_redirect off;
-
-        # Timeouts
-        proxy_connect_timeout 60s;
-        proxy_send_timeout 60s;
-        proxy_read_timeout 60s;
+        proxy_set_header X-Forwarded-Proto $scheme;
    }

-    # Cache static assets with immutable flag
-    location ~* \.(css|js)$ {
+    # Cache static assets
+    location ~* \.(js|css|png|jpg|jpeg|gif|ico|svg)$ {
        expires 1y;
-        add_header Cache-Control "public, immutable" always;
-        access_log off;
-    }
-
-    # Cache images and icons
-    location ~* \.(png|jpg|jpeg|gif|ico|svg|webp)$ {
-        expires 1y;
-        add_header Cache-Control "public, immutable" always;
-        access_log off;
-    }
-
-    # Cache fonts (if any are added later)
-    location ~* \.(woff|woff2|ttf|eot|otf)$ {
-        expires 1y;
-        add_header Cache-Control "public, immutable" always;
-        add_header Access-Control-Allow-Origin "*" always;
-        access_log off;
-    }
-
-    # Other static files
-    location ~* \.(xml|txt)$ {
-        expires 1d;
-        add_header Cache-Control "public, must-revalidate" always;
+        add_header Cache-Control "public, immutable";
    }
 }
--- a/frontend/src/components/AccountSettings.tsx
+++ b/frontend/src/components/AccountSettings.tsx
@@ -234,28 +234,24 @@ export default function AccountSettings() {
                                  }}
                                  autoFocus
                                />
-                                <Button
+                                <button
                                  onClick={handleEditSave}
                                  disabled={
                                    !editingName.trim() ||
                                    updateAccountMutation.isPending
                                  }
-                                  size="icon"
-                                  variant="ghost"
-                                  className="h-8 w-8 text-green-600 hover:text-green-700 hover:bg-green-100"
+                                  className="p-1 text-green-600 hover:text-green-700 disabled:opacity-50 disabled:cursor-not-allowed"
                                  title="Save changes"
                                >
                                  <Check className="h-4 w-4" />
-                                </Button>
-                                <Button
+                                </button>
+                                <button
                                  onClick={handleEditCancel}
-                                  size="icon"
-                                  variant="ghost"
-                                  className="h-8 w-8"
+                                  className="p-1 text-gray-600 hover:text-gray-700"
                                  title="Cancel editing"
                                >
                                  <X className="h-4 w-4" />
-                                </Button>
+                                </button>
                              </div>
                              <p className="text-sm text-muted-foreground truncate">
                                {account.institution_id}
@@ -269,15 +265,13 @@ export default function AccountSettings() {
                                    account.name ||
                                    "Unnamed Account"}
                                </h4>
-                                <Button
+                                <button
                                  onClick={() => handleEditStart(account)}
-                                  size="icon"
-                                  variant="ghost"
-                                  className="h-7 w-7 flex-shrink-0"
+                                  className="flex-shrink-0 p-1 text-muted-foreground hover:text-foreground transition-colors"
                                  title="Edit account name"
                                >
                                  <Edit2 className="h-4 w-4" />
-                                </Button>
+                                </button>
                              </div>
                              <p className="text-sm text-muted-foreground truncate">
                                {account.institution_id}
--- a/frontend/src/components/AccountsOverview.tsx
+++ b/frontend/src/components/AccountsOverview.tsx
@@ -273,28 +273,24 @@ export default function AccountsOverview() {
                                  }}
                                  autoFocus
                                />
-                                <Button
+                                <button
                                  onClick={handleEditSave}
                                  disabled={
                                    !editingName.trim() ||
                                    updateAccountMutation.isPending
                                  }
-                                  size="icon"
-                                  variant="ghost"
-                                  className="h-8 w-8 text-green-600 hover:text-green-700 hover:bg-green-100"
+                                  className="p-1 text-green-600 hover:text-green-700 disabled:opacity-50 disabled:cursor-not-allowed"
                                  title="Save changes"
                                >
                                  <Check className="h-4 w-4" />
-                                </Button>
-                                <Button
+                                </button>
+                                <button
                                  onClick={handleEditCancel}
-                                  size="icon"
-                                  variant="ghost"
-                                  className="h-8 w-8"
+                                  className="p-1 text-gray-600 hover:text-gray-700"
                                  title="Cancel editing"
                                >
                                  <X className="h-4 w-4" />
-                                </Button>
+                                </button>
                              </div>
                              <p className="text-sm text-muted-foreground truncate">
                                {account.institution_id}
@@ -308,15 +304,13 @@ export default function AccountsOverview() {
                                    account.name ||
                                    "Unnamed Account"}
                                </h4>
-                                <Button
+                                <button
                                  onClick={() => handleEditStart(account)}
-                                  size="icon"
-                                  variant="ghost"
-                                  className="h-7 w-7 flex-shrink-0"
+                                  className="flex-shrink-0 p-1 text-muted-foreground hover:text-foreground transition-colors"
                                  title="Edit account name"
                                >
                                  <Edit2 className="h-4 w-4" />
-                                </Button>
+                                </button>
                              </div>
                              <p className="text-sm text-muted-foreground truncate">
                                {account.institution_id}
--- a/frontend/src/components/NotificationFiltersDrawer.tsx
+++ b/frontend/src/components/NotificationFiltersDrawer.tsx
@@ -166,15 +166,13 @@ export default function NotificationFiltersDrawer({
                      className="flex items-center space-x-1 bg-secondary text-secondary-foreground px-2 py-1 rounded-md text-sm"
                    >
                      <span>{filter}</span>
-                      <Button
+                      <button
                        type="button"
                        onClick={() => removeCaseInsensitiveFilter(index)}
-                        variant="ghost"
-                        size="icon"
-                        className="h-5 w-5 hover:bg-secondary-foreground/10"
+                        className="text-secondary-foreground hover:text-foreground"
                      >
                        <X className="h-3 w-3" />
-                      </Button>
+                      </button>
                    </div>
                  ))
                ) : (
@@ -224,15 +222,13 @@ export default function NotificationFiltersDrawer({
                      className="flex items-center space-x-1 bg-secondary text-secondary-foreground px-2 py-1 rounded-md text-sm"
                    >
                      <span>{filter}</span>
-                      <Button
+                      <button
                        type="button"
                        onClick={() => removeCaseSensitiveFilter(index)}
-                        variant="ghost"
-                        size="icon"
-                        className="h-5 w-5 hover:bg-secondary-foreground/10"
+                        className="text-secondary-foreground hover:text-foreground"
                      >
                        <X className="h-3 w-3" />
-                      </Button>
+                      </button>
                    </div>
                  ))
                ) : (
--- a/frontend/src/components/PWAPrompts.tsx
+++ b/frontend/src/components/PWAPrompts.tsx
@@ -0,0 +1,160 @@
+import { useEffect, useState } from "react";
+import { X, Download, RotateCcw } from "lucide-react";
+
+interface BeforeInstallPromptEvent extends Event {
+  prompt(): Promise<void>;
+  userChoice: Promise<{ outcome: "accepted" | "dismissed" }>;
+}
+
+interface PWAPromptProps {
+  onInstall?: () => void;
+}
+
+export function PWAInstallPrompt({ onInstall }: PWAPromptProps) {
+  const [deferredPrompt, setDeferredPrompt] =
+    useState<BeforeInstallPromptEvent | null>(null);
+  const [showPrompt, setShowPrompt] = useState(false);
+
+  useEffect(() => {
+    const handler = (e: Event) => {
+      // Prevent the mini-infobar from appearing on mobile
+      e.preventDefault();
+      setDeferredPrompt(e as BeforeInstallPromptEvent);
+      setShowPrompt(true);
+    };
+
+    window.addEventListener("beforeinstallprompt", handler);
+
+    return () => window.removeEventListener("beforeinstallprompt", handler);
+  }, []);
+
+  const handleInstall = async () => {
+    if (!deferredPrompt) return;
+
+    try {
+      await deferredPrompt.prompt();
+      const { outcome } = await deferredPrompt.userChoice;
+
+      if (outcome === "accepted") {
+        onInstall?.();
+      }
+
+      setDeferredPrompt(null);
+      setShowPrompt(false);
+    } catch (error) {
+      console.error("Error installing PWA:", error);
+    }
+  };
+
+  const handleDismiss = () => {
+    setShowPrompt(false);
+    setDeferredPrompt(null);
+  };
+
+  if (!showPrompt || !deferredPrompt) return null;
+
+  return (
+    <div className="fixed bottom-4 left-4 right-4 md:left-auto md:right-4 md:max-w-sm bg-white dark:bg-gray-800 border border-gray-200 dark:border-gray-700 rounded-lg shadow-lg p-4 z-50">
+      <div className="flex items-start gap-3">
+        <div className="flex-shrink-0">
+          <Download className="h-5 w-5 text-blue-600 dark:text-blue-400" />
+        </div>
+        <div className="flex-1 min-w-0">
+          <p className="text-sm font-medium text-gray-900 dark:text-gray-100">
+            Install Leggen
+          </p>
+          <p className="text-sm text-gray-500 dark:text-gray-400">
+            Add to your home screen for quick access
+          </p>
+        </div>
+        <button
+          onClick={handleDismiss}
+          className="flex-shrink-0 text-gray-400 hover:text-gray-500 dark:hover:text-gray-300"
+        >
+          <X className="h-4 w-4" />
+        </button>
+      </div>
+      <div className="mt-3 flex gap-2">
+        <button
+          onClick={handleInstall}
+          className="flex-1 bg-blue-600 text-white text-sm font-medium px-3 py-2 rounded-md hover:bg-blue-700 focus:outline-none focus:ring-2 focus:ring-blue-500"
+        >
+          Install
+        </button>
+        <button
+          onClick={handleDismiss}
+          className="px-3 py-2 text-sm font-medium text-gray-700 dark:text-gray-300 hover:text-gray-900 dark:hover:text-gray-100"
+        >
+          Not now
+        </button>
+      </div>
+    </div>
+  );
+}
+
+interface PWAUpdatePromptProps {
+  updateAvailable: boolean;
+  onUpdate: () => void;
+}
+
+export function PWAUpdatePrompt({
+  updateAvailable,
+  onUpdate,
+}: PWAUpdatePromptProps) {
+  const [showPrompt, setShowPrompt] = useState(false);
+
+  useEffect(() => {
+    if (updateAvailable) {
+      setShowPrompt(true);
+    }
+  }, [updateAvailable]);
+
+  const handleUpdate = () => {
+    onUpdate();
+    setShowPrompt(false);
+  };
+
+  const handleDismiss = () => {
+    setShowPrompt(false);
+  };
+
+  if (!showPrompt || !updateAvailable) return null;
+
+  return (
+    <div className="fixed top-4 left-4 right-4 md:left-auto md:right-4 md:max-w-sm bg-white dark:bg-gray-800 border border-gray-200 dark:border-gray-700 rounded-lg shadow-lg p-4 z-50">
+      <div className="flex items-start gap-3">
+        <div className="flex-shrink-0">
+          <RotateCcw className="h-5 w-5 text-green-600 dark:text-green-400" />
+        </div>
+        <div className="flex-1 min-w-0">
+          <p className="text-sm font-medium text-gray-900 dark:text-gray-100">
+            Update Available
+          </p>
+          <p className="text-sm text-gray-500 dark:text-gray-400">
+            A new version of Leggen is ready to install
+          </p>
+        </div>
+        <button
+          onClick={handleDismiss}
+          className="flex-shrink-0 text-gray-400 hover:text-gray-500 dark:hover:text-gray-300"
+        >
+          <X className="h-4 w-4" />
+        </button>
+      </div>
+      <div className="mt-3 flex gap-2">
+        <button
+          onClick={handleUpdate}
+          className="flex-1 bg-green-600 text-white text-sm font-medium px-3 py-2 rounded-md hover:bg-green-700 focus:outline-none focus:ring-2 focus:ring-green-500"
+        >
+          Update Now
+        </button>
+        <button
+          onClick={handleDismiss}
+          className="px-3 py-2 text-sm font-medium text-gray-700 dark:text-gray-300 hover:text-gray-900 dark:hover:text-gray-100"
+        >
+          Later
+        </button>
+      </div>
+    </div>
+  );
+}
--- a/frontend/src/components/Settings.tsx
+++ b/frontend/src/components/Settings.tsx
@@ -403,28 +403,24 @@ export default function Settings() {
                                      }}
                                      autoFocus
                                    />
-                                    <Button
+                                    <button
                                      onClick={handleEditSave}
                                      disabled={
                                        !editingName.trim() ||
                                        updateAccountMutation.isPending
                                      }
-                                      size="icon"
-                                      variant="ghost"
-                                      className="h-8 w-8 text-green-600 hover:text-green-700 hover:bg-green-100"
+                                      className="p-1 text-green-600 hover:text-green-700 disabled:opacity-50 disabled:cursor-not-allowed"
                                      title="Save changes"
                                    >
                                      <Check className="h-4 w-4" />
-                                    </Button>
-                                    <Button
+                                    </button>
+                                    <button
                                      onClick={handleEditCancel}
-                                      size="icon"
-                                      variant="ghost"
-                                      className="h-8 w-8"
+                                      className="p-1 text-gray-600 hover:text-gray-700"
                                      title="Cancel editing"
                                    >
                                      <X className="h-4 w-4" />
-                                    </Button>
+                                    </button>
                                  </div>
                                  <p className="text-sm text-muted-foreground truncate">
                                    {account.institution_id}
@@ -438,15 +434,13 @@ export default function Settings() {
                                        account.name ||
                                        "Unnamed Account"}
                                    </h4>
-                                    <Button
+                                    <button
                                      onClick={() => handleEditStart(account)}
-                                      size="icon"
-                                      variant="ghost"
-                                      className="h-7 w-7 flex-shrink-0"
+                                      className="flex-shrink-0 p-1 text-muted-foreground hover:text-foreground transition-colors"
                                      title="Edit account name"
                                    >
                                      <Edit2 className="h-4 w-4" />
-                                    </Button>
+                                    </button>
                                  </div>
                                  <p className="text-sm text-muted-foreground truncate">
                                    {account.institution_id}
@@ -585,7 +579,7 @@ export default function Settings() {
                                Created {formatDate(connection.created_at)}
                              </p>
                            </div>
-                            <Button
+                            <button
                              onClick={() => {
                                const isWorking =
                                  connection.status.toLowerCase() === "ln";
@@ -600,13 +594,11 @@ export default function Settings() {
                                }
                              }}
                              disabled={deleteBankConnectionMutation.isPending}
-                              size="icon"
-                              variant="ghost"
-                              className="h-8 w-8 text-muted-foreground hover:text-destructive"
+                              className="p-1 text-muted-foreground hover:text-destructive transition-colors disabled:opacity-50 disabled:cursor-not-allowed"
                              title="Delete connection"
                            >
                              <Trash2 className="h-4 w-4" />
-                            </Button>
+                            </button>
                          </div>
                        </div>
                      </div>
--- a/frontend/src/components/TransactionsTable.tsx
+++ b/frontend/src/components/TransactionsTable.tsx
@@ -259,15 +259,14 @@ export default function TransactionsTable() {
      cell: ({ row }) => {
        const transaction = row.original;
        return (
-          <Button
+          <button
            onClick={() => handleViewRaw(transaction)}
-            variant="ghost"
-            size="sm"
+            className="inline-flex items-center px-2 py-1 text-xs bg-muted text-muted-foreground rounded hover:bg-accent transition-colors"
            title="View raw transaction data"
          >
            <Eye className="h-3 w-3 mr-1" />
            Raw
-          </Button>
+          </button>
        );
      },
    },
@@ -531,15 +530,14 @@ export default function TransactionsTable() {
                            transaction.transaction_currency,
                          )}
                        </p>
-                        <Button
+                        <button
                          onClick={() => handleViewRaw(transaction)}
-                          variant="ghost"
-                          size="sm"
+                          className="inline-flex items-center px-2 py-1 text-xs bg-muted text-muted-foreground rounded hover:bg-accent transition-colors"
                          title="View raw transaction data"
                        >
                          <Eye className="h-3 w-3 mr-1" />
                          Raw
-                        </Button>
+                        </button>
                      </div>
                    </div>
                  </div>
--- a/frontend/src/hooks/usePWA.ts
+++ b/frontend/src/hooks/usePWA.ts
@@ -0,0 +1,72 @@
+import { useEffect, useState } from "react";
+
+interface PWAUpdate {
+  updateAvailable: boolean;
+  updateSW: () => Promise<void>;
+  forceReload: () => Promise<void>;
+}
+
+export function usePWA(): PWAUpdate {
+  const [updateAvailable, setUpdateAvailable] = useState(false);
+  const [updateSW, setUpdateSW] = useState<() => Promise<void>>(
+    () => async () => {},
+  );
+
+  const forceReload = async (): Promise<void> => {
+    try {
+      // Clear all caches
+      if ("caches" in window) {
+        const cacheNames = await caches.keys();
+        await Promise.all(
+          cacheNames.map((cacheName) => caches.delete(cacheName)),
+        );
+        console.log("All caches cleared");
+      }
+
+      // Unregister service worker
+      if ("serviceWorker" in navigator) {
+        const registrations = await navigator.serviceWorker.getRegistrations();
+        await Promise.all(
+          registrations.map((registration) => registration.unregister()),
+        );
+        console.log("All service workers unregistered");
+      }
+
+      // Force reload
+      window.location.reload();
+    } catch (error) {
+      console.error("Error during force reload:", error);
+      // Fallback: just reload the page
+      window.location.reload();
+    }
+  };
+
+  useEffect(() => {
+    // Check if SW registration is available
+    if ("serviceWorker" in navigator) {
+      // Import the registerSW function
+      import("virtual:pwa-register")
+        .then(({ registerSW }) => {
+          const updateSWFunction = registerSW({
+            onNeedRefresh() {
+              setUpdateAvailable(true);
+              setUpdateSW(() => updateSWFunction);
+            },
+            onOfflineReady() {
+              console.log("App ready to work offline");
+            },
+          });
+        })
+        .catch(() => {
+          // PWA not available in development mode or when disabled
+          console.log("PWA registration not available");
+        });
+    }
+  }, []);
+
+  return {
+    updateAvailable,
+    updateSW,
+    forceReload,
+  };
+}
--- a/frontend/src/hooks/useVersionCheck.ts
+++ b/frontend/src/hooks/useVersionCheck.ts
@@ -0,0 +1,39 @@
+import { useEffect } from "react";
+import { useQuery } from "@tanstack/react-query";
+import { apiClient } from "../lib/api";
+
+const VERSION_STORAGE_KEY = "leggen_app_version";
+
+export function useVersionCheck(forceReload: () => Promise<void>) {
+  const { data: healthStatus, isSuccess: healthSuccess } = useQuery({
+    queryKey: ["health"],
+    queryFn: apiClient.getHealth,
+    refetchInterval: 30000,
+    retry: false,
+    staleTime: 0, // Always consider data stale to ensure fresh version checks
+  });
+
+  useEffect(() => {
+    if (healthSuccess && healthStatus?.version) {
+      const currentVersion = healthStatus.version;
+      const storedVersion = localStorage.getItem(VERSION_STORAGE_KEY);
+
+      if (storedVersion && storedVersion !== currentVersion) {
+        console.log(
+          `Version mismatch detected: stored=${storedVersion}, current=${currentVersion}`,
+        );
+        console.log("Clearing cache and reloading...");
+
+        // Update stored version first
+        localStorage.setItem(VERSION_STORAGE_KEY, currentVersion);
+
+        // Force reload to clear cache
+        forceReload();
+      } else if (!storedVersion) {
+        // First time loading, store the version
+        localStorage.setItem(VERSION_STORAGE_KEY, currentVersion);
+        console.log(`Version stored: ${currentVersion}`);
+      }
+    }
+  }, [healthSuccess, healthStatus?.version, forceReload]);
+}
--- a/frontend/src/main.tsx
+++ b/frontend/src/main.tsx
@@ -5,7 +5,6 @@ import { QueryClient, QueryClientProvider } from "@tanstack/react-query";
 import { ThemeProvider } from "./contexts/ThemeContext";
 import "./index.css";
 import { routeTree } from "./routeTree.gen";
-import { registerSW } from "virtual:pwa-register";

 const router = createRouter({ routeTree });

@@ -18,57 +17,6 @@ const queryClient = new QueryClient({
  },
 });

-const intervalMS = 60 * 60 * 1000;
-
-registerSW({
-  onRegisteredSW(swUrl, r) {
-    console.log("[PWA] Service worker registered successfully");
-
-    if (r) {
-      setInterval(async () => {
-        console.log("[PWA] Checking for updates...");
-
-        if (r.installing) {
-          console.log("[PWA] Update already installing, skipping check");
-          return;
-        }
-
-        if (!navigator) {
-          console.log("[PWA] Navigator not available, skipping check");
-          return;
-        }
-
-        if ("connection" in navigator && !navigator.onLine) {
-          console.log("[PWA] Device is offline, skipping check");
-          return;
-        }
-
-        try {
-          const resp = await fetch(swUrl, {
-            cache: "no-store",
-            headers: {
-              cache: "no-store",
-              "cache-control": "no-cache",
-            },
-          });
-
-          if (resp?.status === 200) {
-            console.log("[PWA] Update check successful, triggering update");
-            await r.update();
-          } else {
-            console.log(`[PWA] Update check returned status: ${resp?.status}`);
-          }
-        } catch (error) {
-          console.error("[PWA] Error checking for updates:", error);
-        }
-      }, intervalMS);
-    }
-  },
-  onOfflineReady() {
-    console.log("[PWA] App ready to work offline");
-  },
-});
-
 createRoot(document.getElementById("root")!).render(
  <StrictMode>
    <QueryClientProvider client={queryClient}>
--- a/frontend/src/routes/__root.tsx
+++ b/frontend/src/routes/__root.tsx
@@ -1,10 +1,31 @@
 import { createRootRoute, Outlet } from "@tanstack/react-router";
 import { AppSidebar } from "../components/AppSidebar";
 import { SiteHeader } from "../components/SiteHeader";
+import { PWAInstallPrompt, PWAUpdatePrompt } from "../components/PWAPrompts";
+import { usePWA } from "../hooks/usePWA";
+import { useVersionCheck } from "../hooks/useVersionCheck";
 import { SidebarInset, SidebarProvider } from "../components/ui/sidebar";
 import { Toaster } from "../components/ui/sonner";

 function RootLayout() {
+  const { updateAvailable, updateSW, forceReload } = usePWA();
+
+  // Check for version mismatches and force reload if needed
+  useVersionCheck(forceReload);
+
+  const handlePWAInstall = () => {
+    console.log("PWA installed successfully");
+  };
+
+  const handlePWAUpdate = async () => {
+    try {
+      await updateSW();
+      console.log("PWA updated successfully");
+    } catch (error) {
+      console.error("Error updating PWA:", error);
+    }
+  };
+
  return (
    <SidebarProvider
      style={
@@ -22,6 +43,13 @@ function RootLayout() {
        </main>
      </SidebarInset>

+      {/* PWA Prompts */}
+      <PWAInstallPrompt onInstall={handlePWAInstall} />
+      <PWAUpdatePrompt
+        updateAvailable={updateAvailable}
+        onUpdate={handlePWAUpdate}
+      />
+
      {/* Toast Notifications */}
      <Toaster />
    </SidebarProvider>
--- a/frontend/vite.config.ts
+++ b/frontend/vite.config.ts
@@ -11,7 +11,10 @@ export default defineConfig({
    VitePWA({
      registerType: "autoUpdate",
      includeAssets: [
-        "robots.txt"
+        "favicon.ico",
+        "apple-touch-icon-180x180.png",
+        "maskable-icon-512x512.png",
+        "robots.txt",
      ],
      manifest: {
        name: "Leggen",
--- a/leggen/commands/bank/add.py
+++ b/leggen/commands/bank/add.py
@@ -2,7 +2,6 @@ import click

 from leggen.api_client import LeggenAPIClient
 from leggen.main import cli
-from leggen.utils.disk import save_file
 from leggen.utils.text import info, print_table, success, warning


@@ -63,9 +62,6 @@ def add(ctx):
        # Connect to bank via API
        result = api_client.connect_to_bank(bank_id, "http://localhost:8000/")

-        # Save requisition details
-        save_file(f"req_{result['id']}.json", result)
-
        success("Bank connection request created successfully!")
        warning(
            "Please open the following URL in your browser to complete the authorization:"
--- a/leggen/commands/server.py
+++ b/leggen/commands/server.py
@@ -60,8 +60,6 @@ def create_app() -> FastAPI:
        description="Open Banking API for Leggen",
        version=version,
        lifespan=lifespan,
-        docs_url="/api/v1/docs",
-        openapi_url="/api/v1/openapi.json",
    )

    # Add CORS middleware
--- a/leggen/services/database_helpers.py
+++ b/leggen/services/database_helpers.py
@@ -0,0 +1,64 @@
+"""Database helper utilities for Leggen."""
+
+import sqlite3
+from contextlib import contextmanager
+from pathlib import Path
+from typing import Any, Generator
+
+from loguru import logger
+
+
+@contextmanager
+def get_db_connection(db_path: Path) -> Generator[sqlite3.Connection, None, None]:
+    """Context manager for database connections.
+
+    Usage:
+        with get_db_connection(db_path) as conn:
+            cursor = conn.cursor()
+            cursor.execute(...)
+            conn.commit()
+    """
+    conn = None
+    try:
+        conn = sqlite3.connect(str(db_path))
+        conn.row_factory = sqlite3.Row  # Enable dict-like access
+        yield conn
+    except Exception as e:
+        if conn:
+            conn.rollback()
+        logger.error(f"Database error: {e}")
+        raise
+    finally:
+        if conn:
+            conn.close()
+
+
+def execute_query(
+    db_path: Path, query: str, params: tuple = ()
+) -> list[dict[str, Any]]:
+    """Execute a SELECT query and return results as list of dicts."""
+    with get_db_connection(db_path) as conn:
+        cursor = conn.cursor()
+        cursor.execute(query, params)
+        rows = cursor.fetchall()
+        return [dict(row) for row in rows]
+
+
+def execute_single(
+    db_path: Path, query: str, params: tuple = ()
+) -> dict[str, Any] | None:
+    """Execute a SELECT query and return a single result as dict or None."""
+    with get_db_connection(db_path) as conn:
+        cursor = conn.cursor()
+        cursor.execute(query, params)
+        row = cursor.fetchone()
+        return dict(row) if row else None
+
+
+def execute_count(db_path: Path, query: str, params: tuple = ()) -> int:
+    """Execute a COUNT query and return the integer result."""
+    with get_db_connection(db_path) as conn:
+        cursor = conn.cursor()
+        cursor.execute(query, params)
+        result = cursor.fetchone()
+        return result[0] if result else 0
--- a/leggen/services/database_migrations.py
+++ b/leggen/services/database_migrations.py
@@ -0,0 +1,657 @@
+"""Database migration functions for Leggen."""
+
+import sqlite3
+import uuid
+from datetime import datetime
+from pathlib import Path
+
+from loguru import logger
+
+
+def run_all_migrations(db_path: Path) -> None:
+    """Run all necessary database migrations."""
+    if not db_path.exists():
+        logger.info("Database file not found, skipping migrations")
+        return
+
+    migrate_balance_timestamps_if_needed(db_path)
+    migrate_null_transaction_ids_if_needed(db_path)
+    migrate_to_composite_key_if_needed(db_path)
+    migrate_add_display_name_if_needed(db_path)
+    migrate_add_sync_operations_if_needed(db_path)
+    migrate_add_logo_if_needed(db_path)
+
+
+def migrate_balance_timestamps_if_needed(db_path: Path) -> None:
+    """Check and migrate balance timestamps if needed."""
+    try:
+        if _check_balance_timestamp_migration_needed(db_path):
+            logger.info("Balance timestamp migration needed, starting...")
+            _migrate_balance_timestamps(db_path)
+            logger.info("Balance timestamp migration completed")
+        else:
+            logger.info("Balance timestamps are already consistent")
+    except Exception as e:
+        logger.error(f"Balance timestamp migration failed: {e}")
+        raise
+
+
+def _check_balance_timestamp_migration_needed(db_path: Path) -> bool:
+    """Check if balance timestamps need migration."""
+    if not db_path.exists():
+        return False
+
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Check for mixed timestamp types
+        cursor.execute("""
+            SELECT typeof(timestamp) as type, COUNT(*) as count
+            FROM balances
+            GROUP BY typeof(timestamp)
+        """)
+
+        types = cursor.fetchall()
+        conn.close()
+
+        # If we have both 'real' and 'text' types, migration is needed
+        type_names = [row[0] for row in types]
+        return "real" in type_names and "text" in type_names
+
+    except Exception as e:
+        logger.error(f"Failed to check migration status: {e}")
+        return False
+
+
+def _migrate_balance_timestamps(db_path: Path) -> None:
+    """Convert all Unix timestamps to datetime strings."""
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Get all balances with REAL timestamps
+        cursor.execute("""
+            SELECT id, timestamp
+            FROM balances
+            WHERE typeof(timestamp) = 'real'
+            ORDER BY id
+        """)
+
+        unix_records = cursor.fetchall()
+        total_records = len(unix_records)
+
+        if total_records == 0:
+            logger.info("No Unix timestamps found to migrate")
+            conn.close()
+            return
+
+        logger.info(
+            f"Migrating {total_records} balance records from Unix to datetime format"
+        )
+
+        # Convert and update in batches
+        batch_size = 100
+        migrated_count = 0
+
+        for i in range(0, total_records, batch_size):
+            batch = unix_records[i : i + batch_size]
+
+            for record_id, unix_timestamp in batch:
+                try:
+                    # Convert Unix timestamp to datetime string
+                    dt_string = _unix_to_datetime_string(float(unix_timestamp))
+
+                    # Update the record
+                    cursor.execute(
+                        """
+                        UPDATE balances
+                        SET timestamp = ?
+                        WHERE id = ?
+                    """,
+                        (dt_string, record_id),
+                    )
+
+                    migrated_count += 1
+
+                    if migrated_count % 100 == 0:
+                        logger.info(
+                            f"Migrated {migrated_count}/{total_records} balance records"
+                        )
+
+                except Exception as e:
+                    logger.error(f"Failed to migrate record {record_id}: {e}")
+                    continue
+
+            # Commit batch
+            conn.commit()
+
+        conn.close()
+        logger.info(f"Successfully migrated {migrated_count} balance records")
+
+    except Exception as e:
+        logger.error(f"Balance timestamp migration failed: {e}")
+        raise
+
+
+def migrate_null_transaction_ids_if_needed(db_path: Path) -> None:
+    """Check and migrate null transaction IDs if needed."""
+    try:
+        if _check_null_transaction_ids_migration_needed(db_path):
+            logger.info("Null transaction IDs migration needed, starting...")
+            _migrate_null_transaction_ids(db_path)
+            logger.info("Null transaction IDs migration completed")
+        else:
+            logger.info("No null transaction IDs found to migrate")
+    except Exception as e:
+        logger.error(f"Null transaction IDs migration failed: {e}")
+        raise
+
+
+def _check_null_transaction_ids_migration_needed(db_path: Path) -> bool:
+    """Check if null transaction IDs need migration."""
+    if not db_path.exists():
+        return False
+
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Check for transactions with null or empty internalTransactionId
+        cursor.execute("""
+            SELECT COUNT(*)
+            FROM transactions
+            WHERE (internalTransactionId IS NULL OR internalTransactionId = '')
+            AND json_extract(rawTransaction, '$.transactionId') IS NOT NULL
+        """)
+
+        count = cursor.fetchone()[0]
+        conn.close()
+
+        return count > 0
+
+    except Exception as e:
+        logger.error(f"Failed to check null transaction IDs migration status: {e}")
+        return False
+
+
+def _migrate_null_transaction_ids(db_path: Path) -> None:
+    """Populate null internalTransactionId fields using transactionId from raw data."""
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Get all transactions with null/empty internalTransactionId but valid transactionId in raw data
+        cursor.execute("""
+            SELECT rowid, json_extract(rawTransaction, '$.transactionId') as transactionId
+            FROM transactions
+            WHERE (internalTransactionId IS NULL OR internalTransactionId = '')
+            AND json_extract(rawTransaction, '$.transactionId') IS NOT NULL
+            ORDER BY rowid
+        """)
+
+        null_records = cursor.fetchall()
+        total_records = len(null_records)
+
+        if total_records == 0:
+            logger.info("No null transaction IDs found to migrate")
+            conn.close()
+            return
+
+        logger.info(
+            f"Migrating {total_records} transaction records with null internalTransactionId"
+        )
+
+        # Update in batches
+        batch_size = 100
+        migrated_count = 0
+        skipped_duplicates = 0
+
+        for i in range(0, total_records, batch_size):
+            batch = null_records[i : i + batch_size]
+
+            for rowid, transaction_id in batch:
+                try:
+                    # Check if this transactionId is already used by another record
+                    cursor.execute(
+                        "SELECT COUNT(*) FROM transactions WHERE internalTransactionId = ?",
+                        (str(transaction_id),),
+                    )
+                    existing_count = cursor.fetchone()[0]
+
+                    if existing_count > 0:
+                        # Generate a unique ID to avoid constraint violation
+                        unique_id = f"{str(transaction_id)}_{uuid.uuid4().hex[:8]}"
+                        logger.debug(
+                            f"Generated unique ID for duplicate transactionId: {unique_id}"
+                        )
+                    else:
+                        # Use the original transactionId
+                        unique_id = str(transaction_id)
+
+                    # Update the record
+                    cursor.execute(
+                        """
+                        UPDATE transactions
+                        SET internalTransactionId = ?
+                        WHERE rowid = ?
+                        """,
+                        (unique_id, rowid),
+                    )
+
+                    migrated_count += 1
+
+                    if migrated_count % 100 == 0:
+                        logger.info(
+                            f"Migrated {migrated_count}/{total_records} transaction records"
+                        )
+
+                except Exception as e:
+                    logger.error(f"Failed to migrate record {rowid}: {e}")
+                    continue
+
+            # Commit batch
+            conn.commit()
+
+        conn.close()
+        logger.info(f"Successfully migrated {migrated_count} transaction records")
+        if skipped_duplicates > 0:
+            logger.info(
+                f"Generated unique IDs for {skipped_duplicates} duplicate transactionIds"
+            )
+
+    except Exception as e:
+        logger.error(f"Null transaction IDs migration failed: {e}")
+        raise
+
+
+def migrate_to_composite_key_if_needed(db_path: Path) -> None:
+    """Check and migrate to composite primary key if needed."""
+    try:
+        if _check_composite_key_migration_needed(db_path):
+            logger.info("Composite key migration needed, starting...")
+            _migrate_to_composite_key(db_path)
+            logger.info("Composite key migration completed")
+        else:
+            logger.info("Composite key migration not needed")
+    except Exception as e:
+        logger.error(f"Composite key migration failed: {e}")
+        raise
+
+
+def _check_composite_key_migration_needed(db_path: Path) -> bool:
+    """Check if composite key migration is needed."""
+    if not db_path.exists():
+        return False
+
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Check if transactions table exists
+        cursor.execute(
+            "SELECT name FROM sqlite_master WHERE type='table' AND name='transactions'"
+        )
+        if not cursor.fetchone():
+            conn.close()
+            return False
+
+        # Check if transactions table has the old primary key structure
+        cursor.execute("PRAGMA table_info(transactions)")
+        columns = cursor.fetchall()
+
+        # Check if internalTransactionId is the primary key (old structure)
+        internal_transaction_id_is_pk = any(
+            col[1] == "internalTransactionId" and col[5] == 1  # col[5] is pk flag
+            for col in columns
+        )
+
+        # Check if we have the new composite primary key structure
+        has_composite_key = any(
+            col[1] in ["accountId", "transactionId"]
+            and col[5] == 1  # col[5] is pk flag
+            for col in columns
+        )
+
+        conn.close()
+
+        # Migration is needed if:
+        # 1. internalTransactionId is still the primary key (old structure), OR
+        # 2. We don't have the new composite key structure yet
+        return internal_transaction_id_is_pk or not has_composite_key
+
+    except Exception as e:
+        logger.error(f"Failed to check composite key migration status: {e}")
+        return False
+
+
+def _migrate_to_composite_key(db_path: Path) -> None:
+    """Migrate transactions table to use composite primary key (accountId, transactionId)."""
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        logger.info("Starting composite key migration...")
+
+        # Step 1: Create temporary table with new schema
+        logger.info("Creating temporary table with composite primary key...")
+        cursor.execute("DROP TABLE IF EXISTS transactions_temp")
+        cursor.execute("""
+            CREATE TABLE transactions_temp (
+                accountId TEXT NOT NULL,
+                transactionId TEXT NOT NULL,
+                internalTransactionId TEXT,
+                institutionId TEXT,
+                iban TEXT,
+                transactionDate DATETIME,
+                description TEXT,
+                transactionValue REAL,
+                transactionCurrency TEXT,
+                transactionStatus TEXT,
+                rawTransaction JSON,
+                PRIMARY KEY (accountId, transactionId)
+            )
+        """)
+
+        # Step 2: Insert deduplicated data (keep most recent duplicate)
+        logger.info("Inserting deduplicated data...")
+        cursor.execute("""
+            INSERT INTO transactions_temp
+            SELECT
+                accountId,
+                json_extract(rawTransaction, '$.transactionId') as transactionId,
+                internalTransactionId,
+                institutionId,
+                iban,
+                transactionDate,
+                description,
+                transactionValue,
+                transactionCurrency,
+                transactionStatus,
+                rawTransaction
+            FROM (
+                SELECT *,
+                       ROW_NUMBER() OVER (
+                           PARTITION BY accountId, json_extract(rawTransaction, '$.transactionId')
+                           ORDER BY transactionDate DESC, rowid DESC
+                       ) as rn
+                FROM transactions
+                WHERE json_extract(rawTransaction, '$.transactionId') IS NOT NULL
+                AND accountId IS NOT NULL
+            ) WHERE rn = 1
+        """)
+
+        # Get counts for reporting
+        cursor.execute("SELECT COUNT(*) FROM transactions")
+        old_count = cursor.fetchone()[0]
+
+        cursor.execute("SELECT COUNT(*) FROM transactions_temp")
+        new_count = cursor.fetchone()[0]
+
+        duplicates_removed = old_count - new_count
+        logger.info(
+            f"Migration stats: {old_count} → {new_count} records ({duplicates_removed} duplicates removed)"
+        )
+
+        # Step 3: Replace tables
+        logger.info("Replacing tables...")
+        cursor.execute("ALTER TABLE transactions RENAME TO transactions_old")
+        cursor.execute("ALTER TABLE transactions_temp RENAME TO transactions")
+
+        # Step 4: Recreate indexes
+        logger.info("Recreating indexes...")
+        cursor.execute(
+            "CREATE INDEX IF NOT EXISTS idx_transactions_internal_id ON transactions(internalTransactionId)"
+        )
+        cursor.execute(
+            "CREATE INDEX IF NOT EXISTS idx_transactions_date ON transactions(transactionDate)"
+        )
+        cursor.execute(
+            "CREATE INDEX IF NOT EXISTS idx_transactions_account_date ON transactions(accountId, transactionDate)"
+        )
+        cursor.execute(
+            "CREATE INDEX IF NOT EXISTS idx_transactions_amount ON transactions(transactionValue)"
+        )
+
+        # Step 5: Cleanup
+        logger.info("Cleaning up...")
+        cursor.execute("DROP TABLE transactions_old")
+
+        conn.commit()
+        conn.close()
+
+        logger.info("Composite key migration completed successfully")
+
+    except Exception as e:
+        logger.error(f"Composite key migration failed: {e}")
+        raise
+
+
+def migrate_add_display_name_if_needed(db_path: Path) -> None:
+    """Check and add display_name column to accounts table if needed."""
+    try:
+        if _check_display_name_migration_needed(db_path):
+            logger.info("Display name column migration needed, starting...")
+            _migrate_add_display_name(db_path)
+            logger.info("Display name column migration completed")
+        else:
+            logger.info("Display name column already exists")
+    except Exception as e:
+        logger.error(f"Display name column migration failed: {e}")
+        raise
+
+
+def _check_display_name_migration_needed(db_path: Path) -> bool:
+    """Check if display_name column needs to be added to accounts table."""
+    if not db_path.exists():
+        return False
+
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Check if accounts table exists
+        cursor.execute(
+            "SELECT name FROM sqlite_master WHERE type='table' AND name='accounts'"
+        )
+        if not cursor.fetchone():
+            conn.close()
+            return False
+
+        # Check if display_name column exists
+        cursor.execute("PRAGMA table_info(accounts)")
+        columns = cursor.fetchall()
+
+        # Check if display_name column exists
+        has_display_name = any(col[1] == "display_name" for col in columns)
+
+        conn.close()
+        return not has_display_name
+
+    except Exception as e:
+        logger.error(f"Failed to check display_name migration status: {e}")
+        return False
+
+
+def _migrate_add_display_name(db_path: Path) -> None:
+    """Add display_name column to accounts table."""
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        logger.info("Adding display_name column to accounts table...")
+
+        # Add the display_name column
+        cursor.execute("""
+            ALTER TABLE accounts
+            ADD COLUMN display_name TEXT
+        """)
+
+        conn.commit()
+        conn.close()
+
+        logger.info("Display name column migration completed successfully")
+
+    except Exception as e:
+        logger.error(f"Display name column migration failed: {e}")
+        raise
+
+
+def migrate_add_sync_operations_if_needed(db_path: Path) -> None:
+    """Check and add sync_operations table if needed."""
+    try:
+        if _check_sync_operations_migration_needed(db_path):
+            logger.info("Sync operations table migration needed, starting...")
+            _migrate_add_sync_operations(db_path)
+            logger.info("Sync operations table migration completed")
+        else:
+            logger.info("Sync operations table already exists")
+    except Exception as e:
+        logger.error(f"Sync operations table migration failed: {e}")
+        raise
+
+
+def _check_sync_operations_migration_needed(db_path: Path) -> bool:
+    """Check if sync_operations table needs to be created."""
+    if not db_path.exists():
+        return False
+
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Check if sync_operations table exists
+        cursor.execute(
+            "SELECT name FROM sqlite_master WHERE type='table' AND name='sync_operations'"
+        )
+        table_exists = cursor.fetchone() is not None
+
+        conn.close()
+        return not table_exists
+
+    except Exception as e:
+        logger.error(f"Failed to check sync_operations migration status: {e}")
+        return False
+
+
+def _migrate_add_sync_operations(db_path: Path) -> None:
+    """Add sync_operations table."""
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        logger.info("Creating sync_operations table...")
+
+        # Create the sync_operations table
+        cursor.execute("""
+            CREATE TABLE sync_operations (
+                id INTEGER PRIMARY KEY AUTOINCREMENT,
+                started_at DATETIME NOT NULL,
+                completed_at DATETIME,
+                success BOOLEAN,
+                accounts_processed INTEGER DEFAULT 0,
+                transactions_added INTEGER DEFAULT 0,
+                transactions_updated INTEGER DEFAULT 0,
+                balances_updated INTEGER DEFAULT 0,
+                duration_seconds REAL,
+                errors TEXT,
+                logs TEXT,
+                trigger_type TEXT DEFAULT 'manual'
+            )
+        """)
+
+        # Create indexes for better performance
+        cursor.execute(
+            "CREATE INDEX IF NOT EXISTS idx_sync_operations_started_at ON sync_operations(started_at)"
+        )
+        cursor.execute(
+            "CREATE INDEX IF NOT EXISTS idx_sync_operations_success ON sync_operations(success)"
+        )
+        cursor.execute(
+            "CREATE INDEX IF NOT EXISTS idx_sync_operations_trigger_type ON sync_operations(trigger_type)"
+        )
+
+        conn.commit()
+        conn.close()
+
+        logger.info("Sync operations table migration completed successfully")
+
+    except Exception as e:
+        logger.error(f"Sync operations table migration failed: {e}")
+        raise
+
+
+def migrate_add_logo_if_needed(db_path: Path) -> None:
+    """Check and add logo column to accounts table if needed."""
+    try:
+        if _check_logo_migration_needed(db_path):
+            logger.info("Logo column migration needed, starting...")
+            _migrate_add_logo(db_path)
+            logger.info("Logo column migration completed")
+        else:
+            logger.info("Logo column already exists")
+    except Exception as e:
+        logger.error(f"Logo column migration failed: {e}")
+        raise
+
+
+def _check_logo_migration_needed(db_path: Path) -> bool:
+    """Check if logo column needs to be added to accounts table."""
+    if not db_path.exists():
+        return False
+
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        # Check if accounts table exists
+        cursor.execute(
+            "SELECT name FROM sqlite_master WHERE type='table' AND name='accounts'"
+        )
+        if not cursor.fetchone():
+            conn.close()
+            return False
+
+        # Check if logo column exists
+        cursor.execute("PRAGMA table_info(accounts)")
+        columns = cursor.fetchall()
+
+        # Check if logo column exists
+        has_logo = any(col[1] == "logo" for col in columns)
+
+        conn.close()
+        return not has_logo
+
+    except Exception as e:
+        logger.error(f"Failed to check logo migration status: {e}")
+        return False
+
+
+def _migrate_add_logo(db_path: Path) -> None:
+    """Add logo column to accounts table."""
+    try:
+        conn = sqlite3.connect(str(db_path))
+        cursor = conn.cursor()
+
+        logger.info("Adding logo column to accounts table...")
+
+        # Add the logo column
+        cursor.execute("""
+            ALTER TABLE accounts
+            ADD COLUMN logo TEXT
+        """)
+
+        conn.commit()
+        conn.close()
+
+        logger.info("Logo column migration completed successfully")
+
+    except Exception as e:
+        logger.error(f"Logo column migration failed: {e}")
+        raise
+
+
+def _unix_to_datetime_string(unix_timestamp: float) -> str:
+    """Convert Unix timestamp to datetime string."""
+    dt = datetime.fromtimestamp(unix_timestamp)
+    return dt.isoformat()
--- a/leggen/services/database_service.py
+++ b/leggen/services/database_service.py
--- a/leggen/services/gocardless_service.py
+++ b/leggen/services/gocardless_service.py
@@ -41,9 +41,7 @@ class GoCardlessService:
        headers = await self._get_auth_headers()

        async with httpx.AsyncClient() as client:
-            response = await client.request(
-                method, url, headers=headers, timeout=30, **kwargs
-            )
+            response = await client.request(method, url, headers=headers, **kwargs)
            _log_rate_limits(response, method, url)

            # If we get 401, clear token cache and retry once
@@ -51,9 +49,7 @@ class GoCardlessService:
                logger.warning("Got 401, clearing token cache and retrying")
                self._token = None
                headers = await self._get_auth_headers()
-                response = await client.request(
-                    method, url, headers=headers, timeout=30, **kwargs
-                )
+                response = await client.request(method, url, headers=headers, **kwargs)
                _log_rate_limits(response, method, url)

            response.raise_for_status()
--- a/leggen/utils/disk.py
+++ b/leggen/utils/disk.py
@@ -1,35 +0,0 @@
-import json
-import sys
-from pathlib import Path
-
-import click
-
-from leggen.utils.text import error, info
-
-
-def save_file(name: str, d: dict):
-    Path.mkdir(Path(click.get_app_dir("leggen")), exist_ok=True)
-    config_file = click.get_app_dir("leggen") / Path(name)
-
-    with click.open_file(str(config_file), "w") as f:
-        json.dump(d, f)
-        info(f"Wrote configuration file at '{config_file}'")
-
-
-def load_file(name: str) -> dict:
-    config_file = click.get_app_dir("leggen") / Path(name)
-    try:
-        with click.open_file(str(config_file), "r") as f:
-            config = json.load(f)
-            return config
-    except FileNotFoundError:
-        error(f"Configuration file '{config_file}' not found")
-        sys.exit(1)
-
-
-def get_prefixed_files(prefix: str) -> list:
-    return [
-        f.name
-        for f in Path(click.get_app_dir("leggen")).iterdir()
-        if f.name.startswith(prefix)
-    ]
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "leggen"
-version = "2025.10.2"
+version = "2025.9.26"
 description = "An Open Banking CLI"
 authors = [{ name = "Elisiário Couto", email = "elisiario@couto.io" }]
 requires-python = "~=3.13.0"
--- a/uv.lock
+++ b/uv.lock
@@ -257,7 +257,7 @@ wheels = [

 [[package]]
 name = "leggen"
-version = "2025.10.2"
+version = "2025.9.26"
 source = { editable = "." }
 dependencies = [
    { name = "apscheduler" },