f42042ccb7
All checks were successful
Build and Deploy / build-and-deploy (push) Successful in 1m5s
Combines shared, blog, market, cart, events, federation, and account into a single repository. Eliminates submodule sync, sibling model copying at build time, and per-app CI orchestration. Changes: - Remove per-app .git, .gitmodules, .gitea, submodule shared/ dirs - Remove stale sibling model copies from each app - Update all 6 Dockerfiles for monorepo build context (root = .) - Add build directives to docker-compose.yml - Add single .gitea/workflows/ci.yml with change detection - Add .dockerignore for monorepo build context - Create __init__.py for federation and account (cross-app imports)
162 lines
4.8 KiB
Python
162 lines
4.8 KiB
Python
from __future__ import annotations
|
|
|
|
from sqlalchemy import select, func
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from shared.events import emit_activity
|
|
from shared.models.container_relation import ContainerRelation
|
|
|
|
|
|
async def attach_child(
|
|
session: AsyncSession,
|
|
parent_type: str,
|
|
parent_id: int,
|
|
child_type: str,
|
|
child_id: int,
|
|
label: str | None = None,
|
|
sort_order: int | None = None,
|
|
) -> ContainerRelation:
|
|
"""
|
|
Create a ContainerRelation and emit container.child_attached event.
|
|
|
|
Upsert behaviour: if a relation already exists (including soft-deleted),
|
|
revive it instead of inserting a duplicate.
|
|
"""
|
|
# Check for existing (including soft-deleted)
|
|
existing = await session.scalar(
|
|
select(ContainerRelation).where(
|
|
ContainerRelation.parent_type == parent_type,
|
|
ContainerRelation.parent_id == parent_id,
|
|
ContainerRelation.child_type == child_type,
|
|
ContainerRelation.child_id == child_id,
|
|
)
|
|
)
|
|
if existing:
|
|
if existing.deleted_at is not None:
|
|
# Revive soft-deleted relation
|
|
existing.deleted_at = None
|
|
if sort_order is not None:
|
|
existing.sort_order = sort_order
|
|
if label is not None:
|
|
existing.label = label
|
|
await session.flush()
|
|
await emit_activity(
|
|
session,
|
|
activity_type="Add",
|
|
actor_uri="internal:system",
|
|
object_type="rose:ContainerRelation",
|
|
object_data={
|
|
"parent_type": parent_type,
|
|
"parent_id": parent_id,
|
|
"child_type": child_type,
|
|
"child_id": child_id,
|
|
},
|
|
source_type="container_relation",
|
|
source_id=existing.id,
|
|
)
|
|
return existing
|
|
# Already attached and active — no-op
|
|
return existing
|
|
|
|
if sort_order is None:
|
|
max_order = await session.scalar(
|
|
select(func.max(ContainerRelation.sort_order)).where(
|
|
ContainerRelation.parent_type == parent_type,
|
|
ContainerRelation.parent_id == parent_id,
|
|
ContainerRelation.deleted_at.is_(None),
|
|
)
|
|
)
|
|
sort_order = (max_order or 0) + 1
|
|
|
|
rel = ContainerRelation(
|
|
parent_type=parent_type,
|
|
parent_id=parent_id,
|
|
child_type=child_type,
|
|
child_id=child_id,
|
|
label=label,
|
|
sort_order=sort_order,
|
|
)
|
|
session.add(rel)
|
|
await session.flush()
|
|
|
|
await emit_activity(
|
|
session,
|
|
activity_type="Add",
|
|
actor_uri="internal:system",
|
|
object_type="rose:ContainerRelation",
|
|
object_data={
|
|
"parent_type": parent_type,
|
|
"parent_id": parent_id,
|
|
"child_type": child_type,
|
|
"child_id": child_id,
|
|
},
|
|
source_type="container_relation",
|
|
source_id=rel.id,
|
|
)
|
|
|
|
return rel
|
|
|
|
|
|
async def get_children(
|
|
session: AsyncSession,
|
|
parent_type: str,
|
|
parent_id: int,
|
|
child_type: str | None = None,
|
|
) -> list[ContainerRelation]:
|
|
"""Query children of a container, optionally filtered by child_type."""
|
|
stmt = select(ContainerRelation).where(
|
|
ContainerRelation.parent_type == parent_type,
|
|
ContainerRelation.parent_id == parent_id,
|
|
ContainerRelation.deleted_at.is_(None),
|
|
)
|
|
if child_type is not None:
|
|
stmt = stmt.where(ContainerRelation.child_type == child_type)
|
|
|
|
stmt = stmt.order_by(
|
|
ContainerRelation.sort_order.asc(), ContainerRelation.id.asc()
|
|
)
|
|
result = await session.execute(stmt)
|
|
return list(result.scalars().all())
|
|
|
|
|
|
async def detach_child(
|
|
session: AsyncSession,
|
|
parent_type: str,
|
|
parent_id: int,
|
|
child_type: str,
|
|
child_id: int,
|
|
) -> bool:
|
|
"""Soft-delete a ContainerRelation and emit container.child_detached event."""
|
|
result = await session.execute(
|
|
select(ContainerRelation).where(
|
|
ContainerRelation.parent_type == parent_type,
|
|
ContainerRelation.parent_id == parent_id,
|
|
ContainerRelation.child_type == child_type,
|
|
ContainerRelation.child_id == child_id,
|
|
ContainerRelation.deleted_at.is_(None),
|
|
)
|
|
)
|
|
rel = result.scalar_one_or_none()
|
|
if not rel:
|
|
return False
|
|
|
|
rel.deleted_at = func.now()
|
|
await session.flush()
|
|
|
|
await emit_activity(
|
|
session,
|
|
activity_type="Remove",
|
|
actor_uri="internal:system",
|
|
object_type="rose:ContainerRelation",
|
|
object_data={
|
|
"parent_type": parent_type,
|
|
"parent_id": parent_id,
|
|
"child_type": child_type,
|
|
"child_id": child_id,
|
|
},
|
|
source_type="container_relation",
|
|
source_id=rel.id,
|
|
)
|
|
|
|
return True
|