From aa397137f2c20b65234727dcc0234033106333bb Mon Sep 17 00:00:00 2001 From: dusk Date: Wed, 13 Aug 2025 19:42:58 +0300 Subject: [PATCH] chore(crates): remove some warnings --- crates/avatars/src/main.rs | 2 +- crates/dispatch/src/main.rs | 3 +-- crates/gdpr_worker/src/main.rs | 2 -- crates/libpk/src/db/repository/avatars.rs | 4 ++-- 4 files changed, 4 insertions(+), 7 deletions(-) diff --git a/crates/avatars/src/main.rs b/crates/avatars/src/main.rs index c8399086..fb3d23b5 100644 --- a/crates/avatars/src/main.rs +++ b/crates/avatars/src/main.rs @@ -153,7 +153,7 @@ async fn verify( ) .await?; - let encoded = process::process_async(result.data, req.kind).await?; + let _ = process::process_async(result.data, req.kind).await?; Ok(()) } diff --git a/crates/dispatch/src/main.rs b/crates/dispatch/src/main.rs index 6570cf19..040884f2 100644 --- a/crates/dispatch/src/main.rs +++ b/crates/dispatch/src/main.rs @@ -12,8 +12,7 @@ use std::{ time::Duration, }; use tokio::{net::UdpSocket, sync::RwLock}; -use tracing::{debug, error, info}; -use tracing_subscriber::EnvFilter; +use tracing::{debug, error}; use axum::{extract::State, http::Uri, routing::post, Json, Router}; diff --git a/crates/gdpr_worker/src/main.rs b/crates/gdpr_worker/src/main.rs index b40557c0..8fefb153 100644 --- a/crates/gdpr_worker/src/main.rs +++ b/crates/gdpr_worker/src/main.rs @@ -1,5 +1,3 @@ -#![feature(let_chains)] - use sqlx::prelude::FromRow; use std::{sync::Arc, time::Duration}; use tracing::{error, info, warn}; diff --git a/crates/libpk/src/db/repository/avatars.rs b/crates/libpk/src/db/repository/avatars.rs index 1ff10cc7..66f48768 100644 --- a/crates/libpk/src/db/repository/avatars.rs +++ b/crates/libpk/src/db/repository/avatars.rs @@ -51,8 +51,8 @@ pub async fn remove_deletion_queue(pool: &PgPool, attachment_id: u64) -> anyhow: } pub async fn pop_queue( - pool: &PgPool, -) -> anyhow::Result, ImageQueueEntry)>> { + pool: &'_ PgPool, +) -> anyhow::Result, ImageQueueEntry)>> { let mut tx = pool.begin().await?; let res: Option = sqlx::query_as("delete from image_queue where itemid = (select itemid from image_queue order by itemid for update skip locked limit 1) returning *") .fetch_optional(&mut *tx).await?;