1 files changed, 25 insertions, 0 deletions
diff --git a/Biz/PodcastItLater/Core.py b/Biz/PodcastItLater/Core.py
index 2f05db3..3a88f22 100644
--- a/Biz/PodcastItLater/Core.py
+++ b/Biz/PodcastItLater/Core.py
@@ -879,6 +879,31 @@ class Database:  # noqa: PLR0904
             return dict(row) if row is not None else None
 
     @staticmethod
+    def get_queue_position(job_id: int) -> int | None:
+        """Get position of job in pending queue."""
+        with Database.get_connection() as conn:
+            cursor = conn.cursor()
+            # Get created_at of this job
+            cursor.execute(
+                "SELECT created_at FROM queue WHERE id = ?",
+                (job_id,),
+            )
+            row = cursor.fetchone()
+            if not row:
+                return None
+            created_at = row[0]
+
+            # Count pending items created before or at same time
+            cursor.execute(
+                """
+                SELECT COUNT(*) FROM queue
+                WHERE status = 'pending' AND created_at <= ?
+                """,
+                (created_at,),
+            )
+            return int(cursor.fetchone()[0])
+
+    @staticmethod
     def get_user_queue_status(
         user_id: int,
     ) -> list[dict[str, Any]]: