if db_row := await self.database.get_row("settings", {"key": "schema_version"}):
prev_version = int(db_row["value"])
else:
- prev_version = 0
+ prev_version = DB_SCHEMA_VERSION
except (KeyError, ValueError, Exception):
# settings table doesn't exist yet or other error
prev_version = 0
)
"""
)
-
- # Users table (decoupled from auth providers)
+ # Users table
await self.database.execute(
"""
CREATE TABLE IF NOT EXISTS users (
)
"""
)
-
# User auth provider links (many-to-many)
await self.database.execute(
"""
)
"""
)
-
# Auth tokens table
await self.database.execute(
"""
)
"""
)
-
await self.database.commit()
async def _create_database_indexes(self) -> None: