style: 🚚 cargo clippy

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<Server> {
     ) -> Result<Response<()>, 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))

backend/src/endpoint/util/error.rs

@@ -1,5 +1,5 @@
 use thiserror::Error;
-use tokio::sync::broadcast::error;
+
 
 #[derive(Debug, Error)]
 pub enum Error {

backend/src/endpoint/util/filter.rs

@@ -6,19 +6,19 @@ pub trait Filter
 where
     Self: EntityTrait,
 {
-    fn read_filter<S: QueryFilter + Send>(query: S, auth: &Auth) -> Result<S, Error> {
+    fn read_filter<S: QueryFilter + Send>(_: S, _: &Auth) -> Result<S, Error> {
         Err(Error::Unauthenticated)
     }
-    fn write_filter<S: QueryFilter + Send>(query: S, auth: &Auth) -> Result<S, Error> {
+    fn write_filter<S: QueryFilter + Send>(_: S, _: &Auth) -> Result<S, Error> {
         Err(Error::Unauthenticated)
     }
 }
 
 pub trait ParentalFilter {
-    fn publish_filter<S: QueryFilter + Send>(query: S, auth: &Auth) -> Result<S, Error> {
+    fn publish_filter<S: QueryFilter + Send>(_: S, _: &Auth) -> Result<S, Error> {
         Err(Error::Unauthenticated)
     }
-    fn link_filter<S: QueryFilter + Send>(query: S, auth: &Auth) -> Result<S, Error> {
+    fn link_filter<S: QueryFilter + Send>(_: S, _: &Auth) -> Result<S, Error> {
         Err(Error::Unauthenticated)
     }
 }

backend/src/endpoint/util/stream.rs

@@ -9,7 +9,7 @@ pub fn into_tokiostream<O: Send + 'static>(
     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;
             }