Delete scanner.py

scanner.py

@@ -1,108 +0,0 @@
-# ════════════════════════════════════════
-# FILE: scanner.py
-# ════════════════════════════════════════
-
-import asyncio
-import random
-import re
-from datetime import datetime, timezone
-from curl_cffi.requests import AsyncSession
-import config
-
-async def check_fragment_status(session: AsyncSession, word: str, semaphore: asyncio.Semaphore, job_id: str) -> dict:
-    async with semaphore:
-        retries = 0
-        status = "Unknown"
-        while retries <= config.MAX_RETRIES:
-            proxy_dict = None
-            if config.PROXY_POOL:
-                proxy_str = random.choice(config.PROXY_POOL)
-                proxy_dict = {"http": proxy_str, "https": proxy_str}
-            
-            try:
-                url = f"https://fragment.com/username/{word}"
-                response = await session.get(url, timeout=10, proxies=proxy_dict)
-                text = response.text
-                
-                if response.status_code in [429, 403, 503] or "Just a moment..." in text or 'id="challenge-running"' in text:
-                    await asyncio.sleep(2 ** retries)
-                    retries += 1
-                    continue
-                
-                if response.status_code in [200, 404]:
-                    final_url = str(response.url)
-                    if "/?query=" in final_url:
-                        pattern = rf'<div class="table-cell-value tm-value">@{re.escape(word)}</div>(.*?)</tr>'
-                        match = re.search(pattern, text, re.DOTALL)
-                        if match:
-                            status_html = match.group(1)
-                            if "tm-status-available" in status_html:
-                                status = "Available"
-                            elif "tm-status-taken" in status_html:
-                                status = "Taken"
-                            elif "tm-status-unavail" in status_html:
-                                status = "Unavailable"
-                            else:
-                                status = "Unknown Status Fragment"
-                        else:
-                            status = "Not Found in Search Results"
-                    else:
-                        match = re.search(r'<span class="tm-section-header-status[^>]*">(.*?)</span>', text)
-                        if match:
-                            status = re.sub(r'<[^>]+>', '', match.group(1)).strip()
-                        elif "Someone already claimed this username" in text:
-                            status = "Taken"
-                        elif "is currently not for sale" in text:
-                            status = "Unavailable"
-                        else:
-                            status = f"Unknown: {final_url.replace('https://fragment.com', '')}"
-                    break
-                else:
-                    status = f"Failed: HTTP {response.status_code}"
-                    retries += 1
-                    await asyncio.sleep(1)
-
-            except Exception as e:
-                retries += 1
-                await asyncio.sleep(1)
-                status = f"Error: {type(e).__name__}"
-        
-        if retries > config.MAX_RETRIES and status.startswith("Unknown"):
-            status = "BLOCKED: Max Retries Hit"
-        
-        await asyncio.sleep(config.DELAY_BETWEEN_REQUESTS)
-        
-        return {
-            "Username": word,
-            "Status": status,
-            "Timestamp": datetime.now(timezone.utc).isoformat(),
-            "JobID": job_id
-        }
-
-async def run_scan(words: list[str], job_id: str, stop_event: asyncio.Event, progress_callback):
-    semaphore = asyncio.Semaphore(config.WORKERS)
-    
-    async with AsyncSession(impersonate="chrome110") as session:
-        completed_so_far = 0
-        total = len(words)
-        
-        for i in range(0, total, config.BATCH_SIZE):
-            if stop_event.is_set():
-                return
-            
-            batch_words = words[i:i + config.BATCH_SIZE]
-            tasks = [
-                asyncio.create_task(check_fragment_status(session, word, semaphore, job_id))
-                for word in batch_words
-            ]
-            
-            batch_results = []
-            for coro in asyncio.as_completed(tasks):
-                res = await coro
-                batch_results.append(res)
-                completed_so_far += 1
-            
-            if stop_event.is_set():
-                return
-            
-            await progress_callback(completed_so_far, total, batch_results)