diff --git a/bp/api/routes.py b/bp/api/routes.py index 14a6ab3..e83824d 100644 --- a/bp/api/routes.py +++ b/bp/api/routes.py @@ -292,17 +292,19 @@ async def _create_product_from_payload(session: AsyncSession, payload: Dict[str, _replace_children(p, payload) await session.flush() - # Emit federation event for new products - from shared.events import emit_event - await emit_event( + # Publish to federation inline + from shared.services.federation_publish import try_publish + await try_publish( session, - event_type="product.listed", - aggregate_type="Product", - aggregate_id=p.id, - payload={ - "title": p.title or "", - "description": getattr(p, "description", "") or "", + user_id=getattr(p, "user_id", None), + activity_type="Create", + object_type="Object", + object_data={ + "name": p.title or "", + "summary": getattr(p, "description", "") or "", }, + source_type="Product", + source_id=p.id, ) return p diff --git a/shared b/shared index 18410c4..3bde451 160000 --- a/shared +++ b/shared @@ -1 +1 @@ -Subproject commit 18410c4b16bee0ded450d5db00df2766c711e18d +Subproject commit 3bde451ce9a2e5126187489cc37ab0305d908e0d