1 files changed, 81 insertions, 0 deletions
diff --git a/Biz/PodcastItLater/Core.py b/Biz/PodcastItLater/Core.py
index 4a017cc..cc94659 100644
--- a/Biz/PodcastItLater/Core.py
+++ b/Biz/PodcastItLater/Core.py
@@ -954,6 +954,52 @@ class Database:  # noqa: PLR0904
             logger.info("Updated user %s status to %s", user_id, status)
 
     @staticmethod
+    def delete_user(user_id: int) -> None:
+        """Delete user and all associated data."""
+        with Database.get_connection() as conn:
+            cursor = conn.cursor()
+
+            # 1. Get owned episode IDs
+            cursor.execute(
+                "SELECT id FROM episodes WHERE user_id = ?",
+                (user_id,),
+            )
+            owned_episode_ids = [row[0] for row in cursor.fetchall()]
+
+            # 2. Delete references to owned episodes
+            if owned_episode_ids:
+                # Construct placeholders for IN clause
+                placeholders = ",".join("?" * len(owned_episode_ids))
+
+                # Delete from user_episodes where these episodes are referenced
+                query = f"DELETE FROM user_episodes WHERE episode_id IN ({placeholders})"  # noqa: S608, E501
+                cursor.execute(query, tuple(owned_episode_ids))
+
+                # Delete metrics for these episodes
+                query = f"DELETE FROM episode_metrics WHERE episode_id IN ({placeholders})"  # noqa: S608, E501
+                cursor.execute(query, tuple(owned_episode_ids))
+
+            # 3. Delete owned episodes
+            cursor.execute("DELETE FROM episodes WHERE user_id = ?", (user_id,))
+
+            # 4. Delete user's data referencing others or themselves
+            cursor.execute(
+                "DELETE FROM user_episodes WHERE user_id = ?",
+                (user_id,),
+            )
+            cursor.execute(
+                "DELETE FROM episode_metrics WHERE user_id = ?",
+                (user_id,),
+            )
+            cursor.execute("DELETE FROM queue WHERE user_id = ?", (user_id,))
+
+            # 5. Delete user
+            cursor.execute("DELETE FROM users WHERE id = ?", (user_id,))
+
+            conn.commit()
+            logger.info("Deleted user %s and all associated data", user_id)
+
+    @staticmethod
     def mark_episode_public(episode_id: int) -> None:
         """Mark an episode as public."""
         with Database.get_connection() as conn:
@@ -1579,6 +1625,41 @@ class TestUserManagement(Test.TestCase):
         # All tokens should be unique
         self.assertEqual(len(tokens), 10)
 
+    def test_delete_user(self) -> None:
+        """Test user deletion and cleanup."""
+        # Create user
+        user_id, _ = Database.create_user("delete_me@example.com")
+
+        # Create some data for the user
+        Database.add_to_queue(
+            "https://example.com/article",
+            "delete_me@example.com",
+            user_id,
+        )
+
+        ep_id = Database.create_episode(
+            title="Test Episode",
+            audio_url="url",
+            duration=100,
+            content_length=1000,
+            user_id=user_id,
+        )
+        Database.add_episode_to_user(user_id, ep_id)
+        Database.track_episode_metric(ep_id, "played", user_id)
+
+        # Delete user
+        Database.delete_user(user_id)
+
+        # Verify user is gone
+        self.assertIsNone(Database.get_user_by_id(user_id))
+
+        # Verify queue items are gone
+        queue = Database.get_user_queue_status(user_id)
+        self.assertEqual(len(queue), 0)
+
+        # Verify episodes are gone (direct lookup)
+        self.assertIsNone(Database.get_episode_by_id(ep_id))
+
 
 class TestQueueOperations(Test.TestCase):
     """Test queue operations."""