majjo/stoatchat
1
0
Fork 0
mirror of https://github.com/stoatchat/stoatchat.git synced 2026-08-31 05:52:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: update channels for gateway

Browse Source
This commit is contained in:
RR
2026-07-22 13:46:23 +01:00
parent 4586e4738a
commit 12a8a2a5f8
1 changed files with 3 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
crates/core/database/src/events/client.rs
View File

@@ -366,14 +366,7 @@ pub enum EventV1 {
impl EventV1 {
/// Publish helper wrapper
pub async fn p(self, channel: String) {
#[cfg(not(debug_assertions))]
redis_kiss::p(channel, self).await;
#[cfg(debug_assertions)]
info!("Publishing event to {channel}: {self:?}");
// #[cfg(debug_assertions)]
// redis_kiss::publish(channel, self).await.unwrap();
//redis_kiss::p(channel.clone(), &self).await;
if let Err(e) = get_amqp().publish_event(channel, &self).await {
if cfg!(debug_assertions) {
@@ -387,23 +380,16 @@ impl EventV1 {
/// Publish user event
pub async fn p_user(self, id: String, db: &Database) {
self.clone().p(id.clone()).await;
// TODO: this should be captured by member list in the future and not immediately fanned out to users
if let Ok(members) = db.fetch_all_memberships(&id).await {
for member in members {
self.clone().server(member.id.server).await;
}
}
}
/// Publish private event
pub async fn private(self, id: String) {
self.p(format!("{id}!")).await;
self.p(format!("{id}")).await;
}
/// Publish server member event
pub async fn server(self, id: String) {
self.p(format!("{id}u")).await;
self.p(format!("{id}")).await;
}
/// Publish internal global event