36 lines
1.3 KiB
Python
36 lines
1.3 KiB
Python
 
|
"""add accounts.sync_window + backfill progress counters
|
||
|
|
|
||
|
|
Lets the user choose at account setup how much history to import (SPEC §12 M2):
|
||
|
|
``all`` (default; recent 30d first, then the rest), ``3months`` (windowed), or
|
||
|
|
``new`` (no backfill — only mail arriving after setup). ``backfill_total`` /
|
||
|
|
``backfill_done`` drive the initial-sync progress UX; total 0 means "nothing to
|
||
|
|
import" (the ``new`` window, or an empty account).
|
||
|
|
|
||
|
|
Revision ID: 0012
|
||
|
|
Revises: 0011
|
||
|
|
Create Date: 2026-07-23
|
||
|
|
"""
|
||
|
|
|
||
|
|
from __future__ import annotations
|
||
|
|
|
||
|
|
from collections.abc import Sequence
|
||
|
|
|
||
|
|
from alembic import op
|
||
|
|
|
||
|
|
revision: str = "0012"
|
||
|
|
down_revision: str | None = "0011"
|
||
|
|
branch_labels: str | Sequence[str] | None = None
|
||
|
|
depends_on: str | Sequence[str] | None = None
|
||
|
|
|
||
|
|
|
||
|
|
def upgrade() -> None:
|
||
|
|
op.execute("ALTER TABLE accounts ADD COLUMN sync_window text NOT NULL DEFAULT 'all'")
|
||
|
|
op.execute("ALTER TABLE accounts ADD COLUMN backfill_total integer NOT NULL DEFAULT 0")
|
||
|
|
op.execute("ALTER TABLE accounts ADD COLUMN backfill_done integer NOT NULL DEFAULT 0")
|
||
|
|
|
||
|
|
|
||
|
|
def downgrade() -> None:
|
||
|
|
op.execute("ALTER TABLE accounts DROP COLUMN IF EXISTS backfill_done")
|
||
|
|
op.execute("ALTER TABLE accounts DROP COLUMN IF EXISTS backfill_total")
|
||
|
|
op.execute("ALTER TABLE accounts DROP COLUMN IF EXISTS sync_window")
|