diff --git a/app/assets/database/queries.py b/app/assets/database/queries.py index fb4e0a10c..ef21e4eb4 100644 --- a/app/assets/database/queries.py +++ b/app/assets/database/queries.py @@ -208,27 +208,6 @@ def fetch_asset_info_asset_and_tags( tags.append(tag_name) return first_info, first_asset, tags -def set_asset_info_preview( - session: Session, - asset_info_id: str, - preview_asset_id: str | None, -) -> None: - """Set or clear preview_id and bump updated_at. Raises on unknown IDs.""" - info = session.get(AssetInfo, asset_info_id) - if not info: - raise ValueError(f"AssetInfo {asset_info_id} not found") - - if preview_asset_id is None: - info.preview_id = None - else: - # validate preview asset exists - if not session.get(Asset, preview_asset_id): - raise ValueError(f"Preview Asset {preview_asset_id} not found") - info.preview_id = preview_asset_id - - info.updated_at = utcnow() - session.flush() - def list_tags_with_usage( session: Session, prefix: str | None = None, diff --git a/app/assets/manager.py b/app/assets/manager.py index 77df436aa..6425e7aa2 100644 --- a/app/assets/manager.py +++ b/app/assets/manager.py @@ -5,10 +5,8 @@ from app.assets.api import schemas_out from app.assets.database.queries import ( asset_exists_by_hash, fetch_asset_info_asset_and_tags, - get_asset_info_by_id, list_asset_infos_page, list_tags_with_usage, - set_asset_info_preview, ) @@ -99,43 +97,6 @@ def get_asset(asset_info_id: str, owner_id: str = "") -> schemas_out.AssetDetail last_access_time=info.last_access_time, ) -def set_asset_preview( - asset_info_id: str, - preview_asset_id: str | None, - owner_id: str = "", -) -> schemas_out.AssetDetail: - with create_session() as session: - info_row = get_asset_info_by_id(session, asset_info_id=asset_info_id) - if not info_row: - raise ValueError(f"AssetInfo {asset_info_id} not found") - if info_row.owner_id and info_row.owner_id != owner_id: - raise PermissionError("not owner") - - set_asset_info_preview( - session, - asset_info_id=asset_info_id, - preview_asset_id=preview_asset_id, - ) - - res = fetch_asset_info_asset_and_tags(session, asset_info_id=asset_info_id, owner_id=owner_id) - if not res: - raise RuntimeError("State changed during preview update") - info, asset, tags = res - session.commit() - - return schemas_out.AssetDetail( - id=info.id, - name=info.name, - asset_hash=asset.hash if asset else None, - size=int(asset.size_bytes) if asset and asset.size_bytes is not None else None, - mime_type=asset.mime_type if asset else None, - tags=tags, - user_metadata=info.user_metadata or {}, - preview_id=info.preview_id, - created_at=info.created_at, - last_access_time=info.last_access_time, - ) - def list_tags( prefix: str | None = None, limit: int = 100,