Update app/fetch.py

app/fetch.py

@@ -1,53 +1,20 @@
-import httpx
-from fastapi import HTTPException
-from urllib.parse import quote_plus
-
-
-SCRAPINGANT_KEY = "fdd15bd8d6f042f893d8bb93a8e47722"
-SCRAPINGANT_ENDPOINT = "https://api.scrapingant.com/v2/general"
+import aiohttp
 
 
 class Fetcher:
+    def __init__(self):
+        self.session = None
+
     async def start(self):
-        # không cần init gì
-        pass
+        if not self.session:
+            self.session = aiohttp.ClientSession()
 
     async def stop(self):
-        pass
+        if self.session:
+            await self.session.close()
+            self.session = None
 
     async def fetch(self, url: str):
-        params = {
-            "url": url,
-            "x-api-key": SCRAPINGANT_KEY,
-            "proxy_type": "residential",
-            "proxy_country": "VN",
-            "browser": "false",
-        }
-
-        try:
-            async with httpx.AsyncClient(timeout=20) as client:
-                resp = await client.get(
-                    SCRAPINGANT_ENDPOINT,
-                    params=params,
-                    headers={
-                        "Accept": "application/json, text/plain, */*",
-                        "User-Agent": "Mozilla/5.0",
-                    },
-                )
-
-            if resp.status_code != 200:
-                raise HTTPException(
-                    status_code=resp.status_code,
-                    detail="Upstream error",
-                )
-
-            text = resp.text.strip()
-
-            # ScrapingAnt trả JSON thẳng nếu API
-            try:
-                return resp.json()
-            except Exception:
-                return {"raw": text}
-
-        except httpx.RequestError as e:
-            raise HTTPException(502, f"Proxy error: {str(e)}")
+        async with self.session.get(url, timeout=30) as resp:
+            text = await resp.text()
+            return {"ok": True, "status": resp.status, "data": text}