From 85957f1c8c2e34bee63eea8a1a8294a649b2f6d6 Mon Sep 17 00:00:00 2001
From: ArabCoders <admin@arabcoders.org>
Date: Fri, 12 Jan 2024 18:07:11 +0300
Subject: [PATCH] Fixed checking already in queue item message.

---
 app/DownloadQueue.py | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git a/app/DownloadQueue.py b/app/DownloadQueue.py
index 9d0b795c..525ca06f 100644
--- a/app/DownloadQueue.py
+++ b/app/DownloadQueue.py
@@ -113,10 +113,15 @@ class DownloadQueue:
 
                 await self.clear([item.info._id])
 
-            if self.queue.exists(key=entry.get('id'), url=entry.get('webpage_url') or entry.get('url')):
-                log.info(
-                    f'Item [{item.info.title}] already in download queue')
-                return {'status': 'error', 'msg': 'Link already queued for downloading.'}
+            try:
+                item = self.queue.get(key=entry.get('id'), url=entry.get(
+                    'webpage_url') or entry.get('url'))
+                if item is not None:
+                    log.info(
+                        f'Item [{item.info.title}] already in download queue.')
+                    return {'status': 'error', 'msg': 'Link already queued for downloading.'}
+            except KeyError:
+                pass
 
             dl = ItemDTO(
                 id=entry.get('id'),