feat: implement t-1fbElKv

1 files changed, 49 insertions, 0 deletions

diff --git a/Biz/PodcastItLater/Core.py b/Biz/PodcastItLater/Core.py
index 8d31956..ffcdfdb 100644
--- a/Biz/PodcastItLater/Core.py
+++ b/Biz/PodcastItLater/Core.py
@@ -948,6 +948,30 @@ class Database:  # noqa: PLR0904
             logger.info("Updated user %s status to %s", user_id, status)
 
     @staticmethod
+    def update_user_email(user_id: int, new_email: str) -> None:
+        """Update user's email address.
+
+        Args:
+            user_id: ID of the user to update
+            new_email: New email address
+
+        Raises:
+            ValueError: If email is already taken by another user
+        """
+        with Database.get_connection() as conn:
+            cursor = conn.cursor()
+            try:
+                cursor.execute(
+                    "UPDATE users SET email = ? WHERE id = ?",
+                    (new_email, user_id),
+                )
+                conn.commit()
+                logger.info("Updated user %s email to %s", user_id, new_email)
+            except sqlite3.IntegrityError:
+                msg = f"Email {new_email} is already taken"
+                raise ValueError(msg) from None
+
+    @staticmethod
     def mark_episode_public(episode_id: int) -> None:
         """Mark an episode as public."""
         with Database.get_connection() as conn:
@@ -1573,6 +1597,31 @@ class TestUserManagement(Test.TestCase):
         # All tokens should be unique
         self.assertEqual(len(tokens), 10)
 
+    def test_update_user_email(self) -> None:
+        """Update user email address."""
+        user_id, _ = Database.create_user("old@example.com")
+
+        # Update email
+        Database.update_user_email(user_id, "new@example.com")
+
+        # Verify update
+        user = Database.get_user_by_id(user_id)
+        self.assertIsNotNone(user)
+        if user:
+            self.assertEqual(user["email"], "new@example.com")
+
+        # Old email should not exist
+        self.assertIsNone(Database.get_user_by_email("old@example.com"))
+
+    def test_update_user_email_duplicate(self) -> None:
+        """Cannot update to an existing email."""
+        user_id1, _ = Database.create_user("user1@example.com")
+        Database.create_user("user2@example.com")
+
+        # Try to update user1 to user2's email
+        with self.assertRaises(ValueError):
+            Database.update_user_email(user_id1, "user2@example.com")
+
 
 class TestQueueOperations(Test.TestCase):
     """Test queue operations."""