diff --git a/src/database/entities/channel.rs b/src/database/entities/channel.rs index 7f5c277183f174dedd62ae768753dbd8c4baa4c5..04267b580fc3bf889c5b7e0b02e87eec573ccd21 100644 --- a/src/database/entities/channel.rs +++ b/src/database/entities/channel.rs @@ -1,8 +1,6 @@ +use crate::database::*; +use crate::notifications::events::ClientboundNotification; use crate::util::result::{Error, Result}; -use crate::{ - database::*, - notifications::{events::ClientboundNotification, hive}, -}; use mongodb::bson::to_document; use serde::{Deserialize, Serialize}; diff --git a/src/notifications/events.rs b/src/notifications/events.rs index 4031d4e7063ea619bbb915b51e16f16239003d39..9056ce04da1d1a0d05cea36a569a96a64601cc63 100644 --- a/src/notifications/events.rs +++ b/src/notifications/events.rs @@ -1,6 +1,6 @@ -use serde::{Deserialize, Serialize}; -use rauth::auth::Session; use hive_pubsub::PubSub; +use rauth::auth::Session; +use serde::{Deserialize, Serialize}; use snafu::Snafu; use super::hive::{get_hive, subscribe_if_exists}; @@ -95,19 +95,17 @@ pub fn prehandle_hook(notification: &ClientboundNotification) { .unsubscribe(&user.to_string(), &id.to_string()) .ok(); } - ClientboundNotification::UserRelationship { id, user, status } => { - match status { - RelationshipStatus::None => { - get_hive() - .hive - .unsubscribe(&id.to_string(), &user.to_string()) - .ok(); - }, - _ => { - subscribe_if_exists(id.clone(), user.clone()).ok(); - } + ClientboundNotification::UserRelationship { id, user, status } => match status { + RelationshipStatus::None => { + get_hive() + .hive + .unsubscribe(&id.to_string(), &user.to_string()) + .ok(); } - } + _ => { + subscribe_if_exists(id.clone(), user.clone()).ok(); + } + }, _ => {} } } diff --git a/src/routes/users/add_friend.rs b/src/routes/users/add_friend.rs index 298dc9228ce87e69263dcbf5620a93e1bbf54538..f918fc8e340038d9e5cdae3132ec03dc4c808ebc 100644 --- a/src/routes/users/add_friend.rs +++ b/src/routes/users/add_friend.rs @@ -1,5 +1,5 @@ use crate::database::*; -use crate::notifications::{events::ClientboundNotification, hive}; +use crate::notifications::events::ClientboundNotification; use crate::util::result::{Error, Result}; use futures::try_join; diff --git a/src/routes/users/block_user.rs b/src/routes/users/block_user.rs index 9c069e5e90fbe8beb3d4b1d2960017a13009b91f..1fb51831da77965a9e0e7f254ba15d5e67dbf3c8 100644 --- a/src/routes/users/block_user.rs +++ b/src/routes/users/block_user.rs @@ -1,5 +1,5 @@ use crate::database::*; -use crate::notifications::{events::ClientboundNotification, hive}; +use crate::notifications::events::ClientboundNotification; use crate::util::result::{Error, Result}; use futures::try_join; diff --git a/src/routes/users/remove_friend.rs b/src/routes/users/remove_friend.rs index e68f20a44f1dda3ee83a3bbc2abbff398599d15a..37e831a174ff6ff57e47f0d62e9eedab04bd45d5 100644 --- a/src/routes/users/remove_friend.rs +++ b/src/routes/users/remove_friend.rs @@ -1,9 +1,8 @@ use crate::database::*; -use crate::notifications::{events::ClientboundNotification, hive}; +use crate::notifications::events::ClientboundNotification; use crate::util::result::{Error, Result}; use futures::try_join; -use hive_pubsub::PubSub; use mongodb::bson::doc; use rocket_contrib::json::JsonValue; diff --git a/src/routes/users/unblock_user.rs b/src/routes/users/unblock_user.rs index 0d23852130e0ea6b2aca24c52fea1cdfaf0dd861..ec575c4bda7c404eca4597497186849a6de4a2ec 100644 --- a/src/routes/users/unblock_user.rs +++ b/src/routes/users/unblock_user.rs @@ -1,9 +1,8 @@ use crate::database::*; -use crate::notifications::{events::ClientboundNotification, hive}; +use crate::notifications::events::ClientboundNotification; use crate::util::result::{Error, Result}; use futures::try_join; -use hive_pubsub::PubSub; use mongodb::bson::doc; use rocket_contrib::json::JsonValue;