forked from jmug/stoatchat
Run cargo fmt.
This commit is contained in:
@@ -1,8 +1,6 @@
|
|||||||
|
use crate::database::*;
|
||||||
|
use crate::notifications::events::ClientboundNotification;
|
||||||
use crate::util::result::{Error, Result};
|
use crate::util::result::{Error, Result};
|
||||||
use crate::{
|
|
||||||
database::*,
|
|
||||||
notifications::{events::ClientboundNotification, hive},
|
|
||||||
};
|
|
||||||
use mongodb::bson::to_document;
|
use mongodb::bson::to_document;
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
use serde::{Deserialize, Serialize};
|
|
||||||
use rauth::auth::Session;
|
|
||||||
use hive_pubsub::PubSub;
|
use hive_pubsub::PubSub;
|
||||||
|
use rauth::auth::Session;
|
||||||
|
use serde::{Deserialize, Serialize};
|
||||||
use snafu::Snafu;
|
use snafu::Snafu;
|
||||||
|
|
||||||
use super::hive::{get_hive, subscribe_if_exists};
|
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())
|
.unsubscribe(&user.to_string(), &id.to_string())
|
||||||
.ok();
|
.ok();
|
||||||
}
|
}
|
||||||
ClientboundNotification::UserRelationship { id, user, status } => {
|
ClientboundNotification::UserRelationship { id, user, status } => match status {
|
||||||
match status {
|
RelationshipStatus::None => {
|
||||||
RelationshipStatus::None => {
|
get_hive()
|
||||||
get_hive()
|
.hive
|
||||||
.hive
|
.unsubscribe(&id.to_string(), &user.to_string())
|
||||||
.unsubscribe(&id.to_string(), &user.to_string())
|
.ok();
|
||||||
.ok();
|
|
||||||
},
|
|
||||||
_ => {
|
|
||||||
subscribe_if_exists(id.clone(), user.clone()).ok();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
_ => {
|
||||||
|
subscribe_if_exists(id.clone(), user.clone()).ok();
|
||||||
|
}
|
||||||
|
},
|
||||||
_ => {}
|
_ => {}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
use crate::database::*;
|
use crate::database::*;
|
||||||
use crate::notifications::{events::ClientboundNotification, hive};
|
use crate::notifications::events::ClientboundNotification;
|
||||||
use crate::util::result::{Error, Result};
|
use crate::util::result::{Error, Result};
|
||||||
|
|
||||||
use futures::try_join;
|
use futures::try_join;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
use crate::database::*;
|
use crate::database::*;
|
||||||
use crate::notifications::{events::ClientboundNotification, hive};
|
use crate::notifications::events::ClientboundNotification;
|
||||||
use crate::util::result::{Error, Result};
|
use crate::util::result::{Error, Result};
|
||||||
|
|
||||||
use futures::try_join;
|
use futures::try_join;
|
||||||
|
|||||||
@@ -1,9 +1,8 @@
|
|||||||
use crate::database::*;
|
use crate::database::*;
|
||||||
use crate::notifications::{events::ClientboundNotification, hive};
|
use crate::notifications::events::ClientboundNotification;
|
||||||
use crate::util::result::{Error, Result};
|
use crate::util::result::{Error, Result};
|
||||||
|
|
||||||
use futures::try_join;
|
use futures::try_join;
|
||||||
use hive_pubsub::PubSub;
|
|
||||||
use mongodb::bson::doc;
|
use mongodb::bson::doc;
|
||||||
use rocket_contrib::json::JsonValue;
|
use rocket_contrib::json::JsonValue;
|
||||||
|
|
||||||
|
|||||||
@@ -1,9 +1,8 @@
|
|||||||
use crate::database::*;
|
use crate::database::*;
|
||||||
use crate::notifications::{events::ClientboundNotification, hive};
|
use crate::notifications::events::ClientboundNotification;
|
||||||
use crate::util::result::{Error, Result};
|
use crate::util::result::{Error, Result};
|
||||||
|
|
||||||
use futures::try_join;
|
use futures::try_join;
|
||||||
use hive_pubsub::PubSub;
|
|
||||||
use mongodb::bson::doc;
|
use mongodb::bson::doc;
|
||||||
use rocket_contrib::json::JsonValue;
|
use rocket_contrib::json::JsonValue;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user