From c1f2d7eed4be1d0ec24d389641bf4220f844a037 Mon Sep 17 00:00:00 2001
From: uncor3 <contactuncor3@gmail.com>
Date: Mon, 8 Jun 2026 20:43:10 +0000
Subject: [PATCH] refactor(query): derive QtThreading

---
 src/query_sqlite.rs | 28 ++++++----------------------
 1 file changed, 6 insertions(+), 22 deletions(-)

diff --git a/src/query_sqlite.rs b/src/query_sqlite.rs
index 8376e16..56e9b32 100644
--- a/src/query_sqlite.rs
+++ b/src/query_sqlite.rs
@@ -7,24 +7,17 @@ use crate::constants::{
     RECENTS_ALBUM_QUERY, RECENTS_QUERY,
 };
 use crate::device_ctx;
-use crate::qt_threading::{QtThread, QtThreading};
+use crate::qt_threading::{QtThreading};
 use crate::utils::create_album_info;
-use crate::{RUNTIME, run_sync};
-use idevice::afc::{AfcClient, opcode::AfcFopenMode};
-use rusqlite::{Connection, OptionalExtension, Rows};
-use serde_json::json;
-use std::default;
-use std::fmt::format;
-use std::path::PathBuf;
+use crate::{RUNTIME};
+use idevice::afc::{opcode::AfcFopenMode};
+use rusqlite::{Connection, OptionalExtension,};
 use std::sync::Arc;
-use std::{io::SeekFrom, pin::Pin};
-use tokio::io::{AsyncReadExt, AsyncSeekExt};
-use tokio::net::TcpListener;
 use tokio::sync::Mutex;
+use macros::QtThreading;
 
-use tokio::sync::oneshot;
 
-#[derive(QObject, Default)]
+#[derive(QObject, Default, QtThreading)]
 pub struct Query {
     base: qt_base_class!(trait QObject),
     udid: String,
@@ -43,15 +36,6 @@ pub struct Query {
     album_queried: qt_signal!(id: i32, items: QStringList),
 }
 
-impl QtThreading for Query {
-    fn qt_thread(&self) -> crate::qt_threading::QtThread<Self>
-    where
-        Self: Sized,
-    {
-        QtThread::new(self)
-    }
-}
-
 impl Query {
     pub fn with_device_attr(udid: QString, ios_version: u32) -> Self {
         let mut state = QVariantMap::default();