bvandeusen
db01106714
- Rewrite get_all_tags() with SQL unnest instead of loading all notes - Consolidate convert_note_to_task/convert_task_to_note to single-session ops - Add search_notes_for_context() with single OR-keyword query for build_context() - Drop selectinload from list_conversations(), use correlated subquery for message_count - Add set_settings_batch() for single-transaction multi-setting upserts - Extract get_installed_models() shared helper into services/llm.py - Delete services/tasks.py pass-through wrapper; routes/tasks.py imports from services.notes - Add B-tree indexes on notes.title and conversations.updated_at (migration 0007) - Add logging to services/notes.py, services/chat.py, services/settings.py - Safe Conversation.to_dict() when messages relationship is not loaded Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
47 lines
1.6 KiB
Python
47 lines
1.6 KiB
Python
import logging
|
|
|
|
from sqlalchemy import select
|
|
|
|
from fabledassistant.models import async_session
|
|
from fabledassistant.models.setting import Setting
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
async def get_setting(key: str, default: str = "") -> str:
|
|
async with async_session() as session:
|
|
result = await session.execute(select(Setting).where(Setting.key == key))
|
|
setting = result.scalar_one_or_none()
|
|
return setting.value if setting else default
|
|
|
|
|
|
async def set_setting(key: str, value: str) -> None:
|
|
async with async_session() as session:
|
|
result = await session.execute(select(Setting).where(Setting.key == key))
|
|
setting = result.scalar_one_or_none()
|
|
if setting:
|
|
setting.value = value
|
|
else:
|
|
session.add(Setting(key=key, value=value))
|
|
await session.commit()
|
|
|
|
|
|
async def set_settings_batch(settings: dict[str, str]) -> None:
|
|
"""Update multiple settings in a single transaction."""
|
|
async with async_session() as session:
|
|
for key, value in settings.items():
|
|
result = await session.execute(select(Setting).where(Setting.key == key))
|
|
setting = result.scalar_one_or_none()
|
|
if setting:
|
|
setting.value = value
|
|
else:
|
|
session.add(Setting(key=key, value=value))
|
|
await session.commit()
|
|
logger.info("Batch-updated %d settings", len(settings))
|
|
|
|
|
|
async def get_all_settings() -> dict[str, str]:
|
|
async with async_session() as session:
|
|
result = await session.execute(select(Setting))
|
|
return {s.key: s.value for s in result.scalars().all()}
|