fix(space): forward request ids into organization events
ZhenYi committed
Modified lib/space/src/services/invite.rs lib/space/src/services/invite.rs +2 −2 View lib/space/src/services/invite.rs
@@ -430,7 +430,7 @@
430430 organization_id: Uuid,
431431 actor_user_id: i64,
432432 payload: serde_json::Value,
433 _request_id: Option<&str>,
433 request_id: Option<&str>,
434434 ) -> SpaceResult<()> {
435435 let labels = events::Labels::new()
436436 .with(label::ORGANIZATION_ID, organization_id)
@@ -440,7 +440,7 @@
440440 label::ORGANIZATION_INVITE_CREATE,
441441 labels,
442442 payload,
443 None,
443 request_id,
444444 )
445445 .await
446446 }
Modified lib/space/src/services/member.rs lib/space/src/services/member.rs +2 −2 View lib/space/src/services/member.rs
@@ -897,7 +897,7 @@
897897 organization_id: Uuid,
898898 actor_user_id: i64,
899899 payload: serde_json::Value,
900 _request_id: Option<&str>,
900 request_id: Option<&str>,
901901 ) -> SpaceResult<()> {
902902 let labels = events::Labels::new()
903903 .with(label::ORGANIZATION_ID, organization_id)
@@ -907,7 +907,7 @@
907907 label::ORGANIZATION_MEMBER_UPDATE,
908908 labels,
909909 payload,
910 None,
910 request_id,
911911 )
912912 .await
913913 }
Modified lib/space/src/services/role.rs lib/space/src/services/role.rs +9 −3 View lib/space/src/services/role.rs
@@ -740,13 +740,19 @@
740740 organization_id: Uuid,
741741 actor_user_id: i64,
742742 payload: serde_json::Value,
743 _request_id: Option<&str>,
743 request_id: Option<&str>,
744744 ) -> SpaceResult<()> {
745745 let labels = events::Labels::new()
746746 .with(label::ORGANIZATION_ID, organization_id)
747747 .with(label::ACTOR_USER_ID, actor_user_id);
748 self.emit_tx(txn, label::ORGANIZATION_ROLE_UPDATE, labels, payload, None)
749 .await
748 self.emit_tx(
749 txn,
750 label::ORGANIZATION_ROLE_UPDATE,
751 labels,
752 payload,
753 request_id,
754 )
755 .await
750756 }
751757
752758 /// 单个角色详情。