Update app.py

app.py

@@ -17,9 +17,15 @@ async def fetch_url(url, session, max_retries=3, timeout=180):
         try:
             async with session.get(url, timeout=ClientTimeout(total=timeout)) as response:
                 response.raise_for_status()
-                return await response.text()
+                content = await response.read()
+                return content.decode('utf-8', errors='ignore')
         except asyncio.TimeoutError:
             print(f"Attempt {attempt + 1} timed out after {timeout} seconds", flush=True)
+        except aiohttp.ClientPayloadError as e:
+            print(f"Payload error on attempt {attempt + 1}: {str(e)}", flush=True)
+            if response.content_length and len(content) >= response.content_length:
+                print(f"Received data length: {len(content)}, expected: {response.content_length}", flush=True)
+                return content.decode('utf-8', errors='ignore')
         except aiohttp.ClientError as e:
             print(f"Attempt {attempt + 1} failed: {str(e)}", flush=True)
         
@@ -29,8 +35,8 @@ async def fetch_url(url, session, max_retries=3, timeout=180):
     raise Exception(f"Failed to fetch URL after {max_retries} attempts")
 
 async def extract_and_transform_proxies(input_text):
-    print("Original input data:")
-    print(input_text)
+    print("Original input data (first 1000 characters):")
+    print(input_text[:1000])
     print("------------------------")
 
     try:
@@ -47,15 +53,19 @@ async def extract_and_transform_proxies(input_text):
                 proxies_text = proxies_match.group(1)
                 proxies_list = yaml.safe_load(proxies_text)
             else:
-                return "未找到有效的代理配置"
+                # 如果仍然找不到，尝试提取所有看起来像代理配置的部分
+                proxy_pattern = r'{[^}]+}'
+                possible_proxies = re.findall(proxy_pattern, input_text)
+                proxies_list = [yaml.safe_load(proxy) for proxy in possible_proxies]
     except yaml.YAMLError as e:
         return f"YAML解析错误: {str(e)}"
 
     if not proxies_list:
         return "未找到有效的代理配置"
 
-    print("Parsed proxies list:")
-    print(proxies_list)
+    print(f"Found {len(proxies_list)} possible proxy configurations")
+    print("Sample of parsed proxies list:")
+    print(proxies_list[:5])  # 只打印前5个代理配置
     print("------------------------")
 
     transformed_proxies = []