diff --git a/bp/api/routes.py b/bp/api/routes.py index 70740d2..14a6ab3 100644 --- a/bp/api/routes.py +++ b/bp/api/routes.py @@ -291,6 +291,20 @@ async def _create_product_from_payload(session: AsyncSession, payload: Dict[str, #await session.flush() # get p.id _replace_children(p, payload) await session.flush() + + # Emit federation event for new products + from shared.events import emit_event + await emit_event( + session, + event_type="product.listed", + aggregate_type="Product", + aggregate_id=p.id, + payload={ + "title": p.title or "", + "description": getattr(p, "description", "") or "", + }, + ) + return p # ---- API -------------------------------------------------------------------- diff --git a/shared b/shared index 8850a01..dd7a99e 160000 --- a/shared +++ b/shared @@ -1 +1 @@ -Subproject commit 8850a0106a51acb55d5c7b84dd45b0b012b6333e +Subproject commit dd7a99e8b73264120912bf5800eea38ce064868d