diff --git a/backend/src/endpoint/user.rs b/backend/src/endpoint/user.rs index a044cf9e..191db86b 100644 --- a/backend/src/endpoint/user.rs +++ b/backend/src/endpoint/user.rs @@ -7,7 +7,7 @@ use crate::endpoint::util::hash; use crate::grpc::backend::user_set_server::*; use crate::grpc::backend::*; -use entity::token; + use entity::user; use entity::user::*; @@ -247,7 +247,7 @@ impl UserSet for Arc { ) -> Result, Status> { let db = DB.get().unwrap(); let (auth, req) = self.parse_request(req).await?; - let (user_id, perm) = auth.ok_or_default()?; + let (user_id, _) = auth.ok_or_default()?; let model = user::Entity::find() .filter(user::Column::Username.eq(req.username)) diff --git a/backend/src/endpoint/util/error.rs b/backend/src/endpoint/util/error.rs index 7e7d69dd..c8750373 100644 --- a/backend/src/endpoint/util/error.rs +++ b/backend/src/endpoint/util/error.rs @@ -1,5 +1,5 @@ use thiserror::Error; -use tokio::sync::broadcast::error; + #[derive(Debug, Error)] pub enum Error { diff --git a/backend/src/endpoint/util/filter.rs b/backend/src/endpoint/util/filter.rs index ed61443c..bc561e80 100644 --- a/backend/src/endpoint/util/filter.rs +++ b/backend/src/endpoint/util/filter.rs @@ -6,19 +6,19 @@ pub trait Filter where Self: EntityTrait, { - fn read_filter(query: S, auth: &Auth) -> Result { + fn read_filter(_: S, _: &Auth) -> Result { Err(Error::Unauthenticated) } - fn write_filter(query: S, auth: &Auth) -> Result { + fn write_filter(_: S, _: &Auth) -> Result { Err(Error::Unauthenticated) } } pub trait ParentalFilter { - fn publish_filter(query: S, auth: &Auth) -> Result { + fn publish_filter(_: S, _: &Auth) -> Result { Err(Error::Unauthenticated) } - fn link_filter(query: S, auth: &Auth) -> Result { + fn link_filter(_: S, _: &Auth) -> Result { Err(Error::Unauthenticated) } } diff --git a/backend/src/endpoint/util/stream.rs b/backend/src/endpoint/util/stream.rs index f8436683..f31132e6 100644 --- a/backend/src/endpoint/util/stream.rs +++ b/backend/src/endpoint/util/stream.rs @@ -9,7 +9,7 @@ pub fn into_tokiostream( let (tx, rx) = channel(128); tokio::spawn(async move { - while let Some(item) = iter.next() { + for item in iter.by_ref() { if tx.send(Result::<_, tonic::Status>::Ok(item)).await.is_err() { break; }