bvandeusenandClaude Opus 4.8
04e3ab20cf
Foundation & Identity backend for ThoughtSync: - Quart app factory (create_app) with /api/health + SPA history-fallback - async SQLAlchemy 2.0 + asyncpg engine/session (lazy; boots without a DB) - native email+password auth via signed-cookie session (register/login/logout/me + login_required guard); bcrypt password hashing (72-byte safe) - multi-user sharing-ACL spine (rule 47): users, groups, group_members, and a polymorphic shares table + visible_to_user() SQL predicate (owner OR direct share OR group share) that M1's notes will scope through - Alembic async env (adapted from family pattern) + 0001 foundation migration - DB-free unit tests (app/health/auth-guard, password roundtrip, ACL compile) Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01FRgehjoz7Yv8LkUfADxACm
42 lines
1.2 KiB
Python
42 lines
1.2 KiB
Python
from __future__ import annotations
|
|
|
|
from sqlalchemy.ext.asyncio import AsyncEngine, AsyncSession, async_sessionmaker, create_async_engine
|
|
|
|
from .config import Config
|
|
|
|
_engine: AsyncEngine | None = None
|
|
_sessionmaker: async_sessionmaker[AsyncSession] | None = None
|
|
|
|
|
|
def get_engine() -> AsyncEngine:
|
|
"""Lazily create the process-wide async engine.
|
|
|
|
Lazy so the app (and unit tests) can import/boot without a live database —
|
|
only routes that actually touch data open a connection.
|
|
"""
|
|
global _engine, _sessionmaker
|
|
if _engine is None:
|
|
_engine = create_async_engine(Config.DATABASE_URL, pool_pre_ping=True)
|
|
_sessionmaker = async_sessionmaker(_engine, expire_on_commit=False)
|
|
return _engine
|
|
|
|
|
|
def get_sessionmaker() -> async_sessionmaker[AsyncSession]:
|
|
if _sessionmaker is None:
|
|
get_engine()
|
|
assert _sessionmaker is not None
|
|
return _sessionmaker
|
|
|
|
|
|
def session_scope() -> AsyncSession:
|
|
"""Open a new AsyncSession. Use as `async with session_scope() as db: ...`."""
|
|
return get_sessionmaker()()
|
|
|
|
|
|
async def dispose_engine() -> None:
|
|
global _engine, _sessionmaker
|
|
if _engine is not None:
|
|
await _engine.dispose()
|
|
_engine = None
|
|
_sessionmaker = None
|