diff --git a/abandoned/email_scan/dev/codepen.py b/abandoned/email_scan/dev/codepen.py
deleted file mode 100644
index b061d98b3..000000000
--- a/abandoned/email_scan/dev/codepen.py
+++ /dev/null
@@ -1,55 +0,0 @@
-import httpx
-import re
-from user_scanner.core.result import Result
-
-
-async def _check(email: str) -> Result:
-    show_url = "https://codepen.io"
-    headers = {
-        'User-Agent': "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/144.0.0.0 Safari/537.36",
-        'Accept': '*/*',
-        'Accept-Language': 'en-US,en;q=0.9',
-        'Referer': 'https://codepen.io/accounts/signup/user/free',
-        'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
-        'X-Requested-With': 'XMLHttpRequest',
-        'Origin': 'https://codepen.io',
-    }
-
-    try:
-        async with httpx.AsyncClient(timeout=10.0, follow_redirects=True) as client:
-            init_res = await client.get("https://codepen.io/accounts/signup/user/free", headers=headers)
-
-            csrf_match = re.search(
-                r'name="csrf-token" content="([^"]+)"', init_res.text)
-            if not csrf_match:
-                return Result.error("Could not find CSRF token")
-
-            headers["X-CSRF-Token"] = csrf_match.group(1)
-
-            payload = {
-                'attribute': 'email',
-                'value': email,
-                'context': 'user'
-            }
-
-            response = await client.post(
-                'https://codepen.io/accounts/duplicate_check',
-                headers=headers,
-                data=payload
-            )
-
-            if "That Email is already taken." in response.text:
-                return Result.taken(url=show_url)
-            elif response.status_code == 200:
-                return Result.available(url=show_url)
-
-            return Result.error(f"Unexpected response: {response.status_code}")
-
-    except httpx.TimeoutException:
-        return Result.error("Connection timed out")
-    except Exception as e:
-        return Result.error(str(e))
-
-
-async def validate_codepen(email: str) -> Result:
-    return await _check(email)
diff --git a/user_scanner/email_scan/dev/codepen.py b/user_scanner/email_scan/dev/codepen.py
new file mode 100644
index 000000000..585167ca6
--- /dev/null
+++ b/user_scanner/email_scan/dev/codepen.py
@@ -0,0 +1,43 @@
+import re
+
+from user_scanner.core.impersonate import impersonate_request_async
+from user_scanner.core.result import Result
+
+SIGNUP_URL = "https://codepen.io/accounts/signup/user/free"
+
+
+async def validate_codepen(email: str) -> Result:
+    show_url = "https://codepen.io"
+
+    try:
+        page = await impersonate_request_async(SIGNUP_URL)
+        token = re.search(r'<meta name="csrf-token" content="([^"]+)"', page.text)
+        if page.status_code != 200 or not token:
+            return Result.error(
+                f"Could not read CodePen signup form ({page.status_code})",
+                url=show_url,
+            )
+
+        response = await impersonate_request_async(
+            "https://codepen.io/accounts/duplicate_check",
+            "POST",
+            headers={"x-csrf-token": token.group(1)},
+            data={"attribute": "email", "value": email, "context": "user"},
+        )
+        if response.status_code != 200:
+            return Result.error(
+                f"Unexpected CodePen response: {response.status_code}", url=show_url
+            )
+
+        data = response.json()
+        if data.get("success") is not True:
+            return Result.error("Unexpected CodePen response", url=show_url)
+
+        errors = data.get("payload", {}).get("errors", {}).get("email")
+        if errors == ["That Email is already taken. Please choose another!"]:
+            return Result.taken(url=show_url)
+        if errors == []:
+            return Result.available(url=show_url)
+        return Result.error("Unexpected CodePen email result", url=show_url)
+    except Exception as exc:  # noqa: BLE001 - scanner modules must return errors
+        return Result.error(exc, url=show_url)