1 files changed, 42 insertions, 2 deletions
diff --git a/Biz/PodcastItLater/Core.py b/Biz/PodcastItLater/Core.py
index 2a9f85a..cc94659 100644
--- a/Biz/PodcastItLater/Core.py
+++ b/Biz/PodcastItLater/Core.py
@@ -373,7 +373,10 @@ class Database:  # noqa: PLR0904
                 SELECT id, url, email, status, created_at, error_message,
                        title, author
                 FROM queue
-                WHERE status IN ('pending', 'processing', 'error')
+                WHERE status IN (
+                    'pending', 'processing', 'extracting',
+                    'synthesizing', 'uploading', 'error'
+                )
                 ORDER BY created_at DESC
                 LIMIT 20
             """)
@@ -888,7 +891,10 @@ class Database:  # noqa: PLR0904
                        title, author
                 FROM queue
                 WHERE user_id = ? AND
-                      status IN ('pending', 'processing', 'error')
+                      status IN (
+                          'pending', 'processing', 'extracting',
+                          'synthesizing', 'uploading', 'error'
+                      )
                 ORDER BY created_at DESC
                 LIMIT 20
             """,
@@ -1866,6 +1872,40 @@ class TestQueueOperations(Test.TestCase):
         self.assertEqual(counts.get("processing", 0), 1)
         self.assertEqual(counts.get("error", 0), 1)
 
+    def test_queue_position(self) -> None:
+        """Verify queue position calculation."""
+        # Add multiple pending jobs
+        job1 = Database.add_to_queue(
+            "https://example.com/1",
+            "test@example.com",
+            self.user_id,
+        )
+        time.sleep(0.01)
+        job2 = Database.add_to_queue(
+            "https://example.com/2",
+            "test@example.com",
+            self.user_id,
+        )
+        time.sleep(0.01)
+        job3 = Database.add_to_queue(
+            "https://example.com/3",
+            "test@example.com",
+            self.user_id,
+        )
+
+        # Check positions
+        self.assertEqual(Database.get_queue_position(job1), 1)
+        self.assertEqual(Database.get_queue_position(job2), 2)
+        self.assertEqual(Database.get_queue_position(job3), 3)
+
+        # Move job 2 to processing
+        Database.update_job_status(job2, "processing")
+
+        # Check positions (job 3 should now be 2nd pending job)
+        self.assertEqual(Database.get_queue_position(job1), 1)
+        self.assertIsNone(Database.get_queue_position(job2))
+        self.assertEqual(Database.get_queue_position(job3), 2)
+
 
 class TestEpisodeManagement(Test.TestCase):
     """Test episode management functionality."""