Switch to unified AP activity bus
All checks were successful
Build and Deploy / build-and-deploy (push) Successful in 1m0s
All checks were successful
Build and Deploy / build-and-deploy (push) Successful in 1m0s
emit_event → emit_activity for order.created and order.paid events. Update shared submodule. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
@@ -1,5 +1,5 @@
|
|||||||
from shared.browser.app.payments.sumup import get_checkout as sumup_get_checkout
|
from shared.browser.app.payments.sumup import get_checkout as sumup_get_checkout
|
||||||
from shared.events import emit_event
|
from shared.events import emit_activity
|
||||||
from shared.services.registry import services
|
from shared.services.registry import services
|
||||||
|
|
||||||
|
|
||||||
@@ -17,10 +17,18 @@ async def check_sumup_status(session, order):
|
|||||||
session, order.id, order.user_id, order.session_id
|
session, order.id, order.user_id, order.session_id
|
||||||
)
|
)
|
||||||
await services.calendar.confirm_tickets_for_order(session, order.id)
|
await services.calendar.confirm_tickets_for_order(session, order.id)
|
||||||
await emit_event(session, "order.paid", "order", order.id, {
|
await emit_activity(
|
||||||
"order_id": order.id,
|
session,
|
||||||
"user_id": order.user_id,
|
activity_type="rose:OrderPaid",
|
||||||
})
|
actor_uri="internal:cart",
|
||||||
|
object_type="rose:Order",
|
||||||
|
object_data={
|
||||||
|
"order_id": order.id,
|
||||||
|
"user_id": order.user_id,
|
||||||
|
},
|
||||||
|
source_type="order",
|
||||||
|
source_id=order.id,
|
||||||
|
)
|
||||||
elif sumup_status == "FAILED":
|
elif sumup_status == "FAILED":
|
||||||
order.status = "failed"
|
order.status = "failed"
|
||||||
else:
|
else:
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ from shared.models.page_config import PageConfig
|
|||||||
from shared.models.market_place import MarketPlace
|
from shared.models.market_place import MarketPlace
|
||||||
from shared.config import config
|
from shared.config import config
|
||||||
from shared.contracts.dtos import CalendarEntryDTO
|
from shared.contracts.dtos import CalendarEntryDTO
|
||||||
from shared.events import emit_event
|
from shared.events import emit_activity
|
||||||
from shared.services.registry import services
|
from shared.services.registry import services
|
||||||
|
|
||||||
|
|
||||||
@@ -166,11 +166,19 @@ async def create_order_from_cart(
|
|||||||
session, order.id, user_id, session_id, page_post_id
|
session, order.id, user_id, session_id, page_post_id
|
||||||
)
|
)
|
||||||
|
|
||||||
await emit_event(session, "order.created", "order", order.id, {
|
await emit_activity(
|
||||||
"order_id": order.id,
|
session,
|
||||||
"user_id": user_id,
|
activity_type="Create",
|
||||||
"session_id": session_id,
|
actor_uri="internal:cart",
|
||||||
})
|
object_type="rose:Order",
|
||||||
|
object_data={
|
||||||
|
"order_id": order.id,
|
||||||
|
"user_id": user_id,
|
||||||
|
"session_id": session_id,
|
||||||
|
},
|
||||||
|
source_type="order",
|
||||||
|
source_id=order.id,
|
||||||
|
)
|
||||||
|
|
||||||
return order
|
return order
|
||||||
|
|
||||||
|
|||||||
2
shared
2
shared
Submodule shared updated: d697709f60...2e9db11925
Reference in New Issue
Block a user