fix: 全面代码审查修复

- 修复 send_message 返回类型注解 (Union[str, AsyncGenerator])
- 修复 PoW 计算逻辑，使用 hash <= target 比较
- 修复 acquire() 跳过禁言账号
- 修复 delete_chat 中 .first 后 .count() 误用
- 修复 stream_message 结束后缺少 delete_chat 清理
- 修复 readyz 返回格式，避免嵌套 accounts 列表
- 移除 start.py 中硬编码凭据，改用 .env 配置
- proxy.py 密钥改为从环境变量读取
- 添加 httpx 到 requirements.txt
- 全局替换 print 为结构化 logging
- 动态生成邮箱脱敏，替代硬编码 skip_phrases
- bare except 改为 except Exception
- README 对齐实际代码（模型列表、管理界面 URL、文件结构）
- 添加 .env.example 模板
- 添加 config 格式注释

.env.example

@@ -0,0 +1,18 @@
+# DS2API Browser 环境配置
+# 复制此文件为 .env 并填入实际值
+
+# 多账号配置，用分号分隔
+# 格式: email:password[:name[:proxy]]
+DS2API_ACCOUNTS=user1@gmail.com:password1:账号1;user2@gmail.com:password2:账号2
+
+# API 密钥（逗号分隔）
+DS2API_KEYS=sk-test123456
+
+# 管理员密钥
+DS2API_ADMIN_KEY=admin
+
+# 服务端口
+DS2API_PORT=5001
+
+# 无头浏览器模式
+DS2API_HEADLESS=true

README.md

@@ -62,7 +62,7 @@ nohup python main.py > /tmp/ds2api-browser.log 2>&1 &
 
 ## Web 管理界面
 
-访问 `http://localhost:5001/test.html` 可以：
+访问 `http://localhost:5001/` 可以：
 
 - 测试 API 请求
 - 导入账号（支持批量）
@@ -77,7 +77,7 @@ curl http://localhost:5001/v1/chat/completions \
   -H "Authorization: Bearer sk-test123456" \
   -H "Content-Type: application/json" \
   -d '{
-    "model": "deepseek-v4-flash",
+    "model": "deepseek-flash",
     "messages": [{"role": "user", "content": "Hello!"}]
   }'
 ```
@@ -89,7 +89,7 @@ curl http://localhost:5001/v1/chat/completions \
   -H "Authorization: Bearer sk-test123456" \
   -H "Content-Type: application/json" \
   -d '{
-    "model": "deepseek-v4-flash",
+    "model": "deepseek-flash",
     "messages": [{"role": "user", "content": "Hello!"}],
     "stream": true
   }'
@@ -106,7 +106,7 @@ client = OpenAI(
 )
 
 response = client.chat.completions.create(
-    model="deepseek-v4-flash",
+    model="deepseek-flash",
     messages=[{"role": "user", "content": "Hello!"}]
 )
 print(response.choices[0].message.content)
@@ -116,12 +116,8 @@ print(response.choices[0].message.content)
 
 | 模型 ID | 说明 |
 |---------|------|
-| deepseek-v4-flash | 快速模式（默认） |
-| deepseek-v4-pro | 专家模式 |
-| deepseek-v4-flash-search | 快速 + 搜索 |
-| deepseek-v4-pro-search | 专家 + 搜索 |
-| deepseek-chat | 兼容原版 DS2API |
-| deepseek-reasoner | 推理模式 |
+| deepseek-flash | 快速模式（默认） |
+| deepseek-pro | 专家模式（深度思考） |
 
 ## 健康检查
 
@@ -147,13 +143,15 @@ curl http://localhost:5001/admin/stats -H "admin-key: admin"
 
 ```
 ds2api-browser/
-├── main.py              # FastAPI 服务器
+├── main.py              # FastAPI 服务器（含管理界面）
 ├── deepseek_browser.py  # CloakBrowser 自动化核心
+├── deepseek_api.py      # DeepSeek HTTP API 客户端
 ├── account_manager.py   # 账号池管理
 ├── config.py            # 配置管理
+├── proxy.py             # 多协议代理（Claude/Gemini/Ollama）
 ├── start.py             # 快速启动脚本
 ├── run.py               # 运行入口
-├── test.html            # Web 管理界面
+├── .env.example         # 环境变量模板
 ├── requirements.txt     # 依赖列表
 └── README.md            # 本文档
 ```

account_manager.py

@@ -1,10 +1,13 @@
 import asyncio
+import logging
 from collections import deque
 from dataclasses import dataclass, field
 from typing import Dict, Optional
 
 from deepseek_browser import DeepSeekBrowser
 
+logger = logging.getLogger(__name__)
+
 
 @dataclass
 class Account:
@@ -38,7 +41,7 @@ class AccountManager:
     async def acquire(self) -> Account:
         async with self._lock:
             for account in self.accounts.values():
-                if not account.in_use and account.error_count < 3:
+                if not account.in_use and account.error_count < 3 and not account.is_muted:
                     account.in_use = True
                     return account
 
@@ -53,7 +56,7 @@ class AccountManager:
 
         async with self._lock:
             for account in self.accounts.values():
-                if not account.in_use and account.error_count < 3:
+                if not account.in_use and account.error_count < 3 and not account.is_muted:
                     account.in_use = True
                     return account
 
@@ -92,7 +95,7 @@ class AccountManager:
                 account.muted_until = account.browser.muted_until()
             return account.browser
         except Exception as e:
-            print(f"Error creating browser: {e}")
+            logger.error("Error creating browser for %s: %s", account.email, e)
             await self.close_browser(account)
             raise
 
@@ -107,15 +110,15 @@ class AccountManager:
         if account.browser:
             try:
                 await account.browser.close()
-            except:
-                pass
+            except Exception as e:
+                logger.debug("Error closing browser for %s: %s", account.email, e)
             account.browser = None
             account.logged_in = False
 
     def get_stats(self) -> Dict:
         total = len(self.accounts)
         in_use = sum(1 for a in self.accounts.values() if a.in_use)
-        available = sum(1 for a in self.accounts.values() if not a.in_use and a.error_count < 3)
+        available = sum(1 for a in self.accounts.values() if not a.in_use and a.error_count < 3 and not a.is_muted)
         logged_in = sum(1 for a in self.accounts.values() if a.logged_in)
         muted = sum(1 for a in self.accounts.values() if a.is_muted)
         accounts_list = [

config.py

@@ -40,9 +40,11 @@ class Config:
     def from_env(cls) -> "Config":
         accounts = []
         
+        # Format: email:password[:name[:proxy]] separated by semicolons
         account_str = os.getenv("DS2API_ACCOUNTS", "")
         if account_str:
             for acc in account_str.split(";"):
+                # maxsplit=3 yields at most 4 parts: email, password, name, proxy
                 parts = acc.split(":", 3)
                 if len(parts) >= 2:
                     accounts.append(AccountConfig(

deepseek_api.py

@@ -1,13 +1,16 @@
 import asyncio
 import hashlib
 import json
+import logging
 import random
 import time
 import uuid
-from typing import AsyncGenerator, Optional
+from typing import AsyncGenerator, Optional, Union
 
 import httpx
 
+logger = logging.getLogger(__name__)
+
 
 class DeepSeekAPI:
     LOGIN_URL = "https://chat.deepseek.com/api/v0/users/login"
@@ -121,7 +124,9 @@ class DeepSeekAPI:
         while nonce < 10000000:
             test = f"{prefix}{nonce}"
             hash_val = hashlib.sha256(test.encode()).hexdigest()
-            if hash_val.startswith("0" * len(target)):
+            # Compare hash against target lexicographically — this handles
+            # both all-zero targets and mixed targets like "000abc".
+            if hash_val <= target:
                 break
             nonce += 1
         
@@ -138,7 +143,12 @@ class DeepSeekAPI:
         model: str = "deepseek-chat",
         stream: bool = False,
         timeout: int = 120,
-    ) -> str:
+    ) -> Union[str, AsyncGenerator[str, None]]:
+        """Send a message and return a response.
+
+        Returns:
+            str when stream=False, AsyncGenerator[str, None] when stream=True.
+        """
         if not self._token:
             await self.login()
         

deepseek_browser.py

@@ -1,4 +1,5 @@
 import asyncio
+import logging
 import random
 import time
 from pathlib import Path
@@ -6,6 +7,8 @@ from typing import AsyncGenerator, Optional
 
 from cloakbrowser import launch_persistent_context_async
 
+logger = logging.getLogger(__name__)
+
 
 class DeepSeekBrowser:
     DEEPSEEK_URL = "https://chat.deepseek.com"
@@ -30,6 +33,19 @@ class DeepSeekBrowser:
         self._logged_in = False
         self._ready = False
 
+    def _mask_email(self) -> str:
+        """Generate a masked version of the email for skip_phrases filtering."""
+        parts = self.email.split("@")
+        if len(parts) == 2:
+            local = parts[0]
+            domain = parts[1]
+            if len(local) > 4:
+                masked = local[:4] + "*" * (len(local) - 4)
+            else:
+                masked = local[0] + "*" * (len(local) - 1)
+            return f"{masked}@{domain}"
+        return self.email
+
     async def start(self):
         self.profile_dir.mkdir(parents=True, exist_ok=True)
 
@@ -79,7 +95,7 @@ class DeepSeekBrowser:
             self._is_muted = muted
             self._muted_until = until
             if muted:
-                print(f"[mute] {self.email} is muted until {until}")
+                logger.warning("[mute] %s is muted until %s", self.email, until)
         except Exception:
             self._is_muted = False
             self._muted_until = ""
@@ -91,7 +107,7 @@ class DeepSeekBrowser:
         return getattr(self, '_muted_until', "")
 
     async def _auto_login(self):
-        print(f"Logging in as {self.email}...")
+        logger.info("Logging in as %s...", self.email)
 
         try:
             email_input = self.page.locator('input[placeholder*="邮箱"], input[placeholder*="手机"], input[placeholder*="Email"], input[placeholder*="email"], input[type="text"]').first
@@ -102,10 +118,10 @@ class DeepSeekBrowser:
             # Take screenshot to debug
             try:
                 await self.page.screenshot(path=f"/tmp/login_fail_{self.email.replace('@','_at_')}.png")
-                print(f"Screenshot saved to /tmp/login_fail_{self.email.replace('@','_at_')}.png")
+                logger.error("Screenshot saved to /tmp/login_fail_%s.png", self.email.replace('@', '_at_'))
             except Exception:
                 pass
-            print(f"Email input error: {e}")
+            logger.error("Email input error: %s", e)
             raise
 
         try:
@@ -114,7 +130,7 @@ class DeepSeekBrowser:
             await password_input.fill(self.password)
             await asyncio.sleep(0.5)
         except Exception as e:
-            print(f"Password input error: {e}")
+            logger.error("Password input error: %s", e)
             raise
 
         try:
@@ -122,14 +138,14 @@ class DeepSeekBrowser:
             await login_button.click()
             await asyncio.sleep(3)
         except Exception as e:
-            print(f"Login button error: {e}")
+            logger.error("Login button error: %s", e)
             raise
 
         try:
             await self.page.wait_for_selector('textarea', timeout=30000)
             self._logged_in = True
             self._ready = True
-            print("Login successful!")
+            logger.info("Login successful!")
         except Exception:
             raise Exception("Login failed")
 
@@ -137,13 +153,23 @@ class DeepSeekBrowser:
         delay = random.uniform(min_ms, max_ms) / 1000
         await asyncio.sleep(delay)
 
+    def _get_skip_phrases(self) -> list:
+        """Build skip phrases list, dynamically including masked email."""
+        phrases = [
+            '深度思考', '智能搜索', '快速模式', '专家模式',
+            '内容由 AI 生成', '开启新对话', '暂无历史对话', '今天',
+        ]
+        masked = self._mask_email()
+        phrases.append(masked)
+        return phrases
+
     async def new_chat(self):
         try:
             await self.page.goto(self.DEEPSEEK_URL, timeout=30000)
             await asyncio.sleep(2)
             await self.page.wait_for_selector('textarea', timeout=15000)
         except Exception as e:
-            print(f"New chat error: {e}")
+            logger.error("New chat error: %s", e)
             raise
 
     async def delete_chat(self):
@@ -151,25 +177,25 @@ class DeepSeekBrowser:
             # Find the sidebar and active conversation
             chat_list = self.page.locator(
                 'nav, aside, [class*="sidebar"], [class*="Sidebar"], div:has-text("开启新对话")'
-            ).first
+            )
             chat_list_count = await chat_list.count()
             if chat_list_count == 0:
-                print(f"[delete_chat] no sidebar")
+                logger.debug("[delete_chat] no sidebar")
                 return
 
-            active_item = chat_list.locator(
+            active_item = chat_list.first.locator(
                 '[class*="active"], [class*="selected"], [class*="current"]'
             ).first
             active_count = await active_item.count()
             if active_count == 0:
                 # No active item yet (first chat), skip deletion
-                print(f"[delete_chat] no active item, skipping")
+                logger.debug("[delete_chat] no active item, skipping")
                 return
 
             # Get bounding box and click near right edge where "..." should be
             box = await active_item.bounding_box()
             if not box:
-                print(f"[delete_chat] no bbox")
+                logger.debug("[delete_chat] no bbox")
                 return
 
             # Instead of position-based click, find the "..." element in DOM
@@ -210,7 +236,7 @@ class DeepSeekBrowser:
                 }
                 return 'no-icon';
             }""")
-            print(f"[delete_chat] icon click: {click_result}")
+            logger.debug("[delete_chat] icon click: %s", click_result)
             await asyncio.sleep(0.5)
 
             # Search for "删除" or "Delete" anywhere on page
@@ -220,7 +246,7 @@ class DeepSeekBrowser:
             delete_count = await delete_btn.count()
             
             if delete_count == 0:
-                print(f"[delete_chat] no delete option found")
+                logger.debug("[delete_chat] no delete option found")
                 return
 
             await delete_btn.click()
@@ -234,12 +260,12 @@ class DeepSeekBrowser:
             if await confirm_btn.count() > 0:
                 await confirm_btn.click()
                 await asyncio.sleep(1)
-                print(f"[delete_chat] done!")
+                logger.debug("[delete_chat] done!")
             else:
-                print(f"[delete_chat] no confirm btn")
+                logger.debug("[delete_chat] no confirm btn")
                 
         except Exception as e:
-            print(f"[delete_chat] error: {e}")
+            logger.warning("[delete_chat] error: %s", e)
 
     async def switch_model(self, model: str):
         try:
@@ -280,7 +306,7 @@ class DeepSeekBrowser:
 
             return response
         except Exception as e:
-            print(f"Send message error: {e}")
+            logger.error("Send message error: %s", e)
             raise
 
     async def _wait_for_response(self, timeout: int, prompt: str = "") -> str:
@@ -291,7 +317,7 @@ class DeepSeekBrowser:
         last_text = ""
         stable_count = 0
 
-        skip_phrases = ['深度思考', '智能搜索', '快速模式', '专家模式', '内容由 AI 生成', '开启新对话', '暂无历史对话', '今天', 'huan********dja@gmail.com']
+        skip_phrases = self._get_skip_phrases()
 
         while time.time() < deadline:
             try:
@@ -361,7 +387,7 @@ class DeepSeekBrowser:
             last_text = ""
             stable_count = 0
 
-            skip_phrases = ['深度思考', '智能搜索', '快速模式', '专家模式', '内容由 AI 生成', '开启新对话', '暂无历史对话', '今天', 'huan********dja@gmail.com']
+            skip_phrases = self._get_skip_phrases()
 
             await asyncio.sleep(3)
 
@@ -403,14 +429,21 @@ class DeepSeekBrowser:
                             stable_count += 1
 
                         if stable_count >= 3:
-                            return
+                            break
 
                 except Exception:
                     pass
 
                 await asyncio.sleep(0.3)
+
+            # Clean up: delete the chat after streaming is done (#17)
+            try:
+                await self.delete_chat()
+            except Exception as e:
+                logger.warning("[stream_message] delete_chat cleanup error: %s", e)
+
         except Exception as e:
-            print(f"Stream message error: {e}")
+            logger.error("Stream message error: %s", e)
             raise
 
     async def close(self):

main.py

@@ -1,11 +1,18 @@
 import asyncio
 import json
+import logging
 import os
 import time
 import uuid
 from pathlib import Path
 from typing import Optional
 
+logging.basicConfig(
+    level=logging.INFO,
+    format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+)
+logger = logging.getLogger(__name__)
+
 from dotenv import load_dotenv
 
 # 自动加载项目目录下的 .env
@@ -153,6 +160,10 @@ async def chat_completions(
 
         await manager.release(account)
 
+        # Token counts are estimated by word splitting; not exact tokenization
+        prompt_tokens = len(prompt.split())
+        completion_tokens = len(response_text.split())
+
         return {
             "id": f"chatcmpl-{uuid.uuid4().hex[:8]}",
             "object": "chat.completion",
@@ -166,14 +177,15 @@ async def chat_completions(
                 }
             ],
             "usage": {
-                "prompt_tokens": len(prompt.split()),
-                "completion_tokens": len(response_text.split()),
-                "total_tokens": len(prompt.split()) + len(response_text.split()),
+                "prompt_tokens": prompt_tokens,
+                "completion_tokens": completion_tokens,
+                "total_tokens": prompt_tokens + completion_tokens,
             },
         }
 
     except Exception as e:
         await manager.mark_error(account)
+        logger.error("Chat completion error for model=%s: %s", request.model, e)
         raise HTTPException(status_code=503, detail=str(e))
 
 
@@ -186,7 +198,17 @@ async def healthz():
 @app.get("/readyz")
 async def readyz():
     stats = manager.get_stats()
-    return {"status": "ok", "accounts": stats}
+    return {
+        "status": "ok",
+        "accounts": {
+            "total": stats["total"],
+            "in_use": stats["in_use"],
+            "available": stats["available"],
+            "logged_in": stats["logged_in"],
+            "muted": stats["muted"],
+            "queue_size": stats["queue_size"],
+        },
+    }
 
 
 @app.get("/admin/stats")
@@ -234,6 +256,8 @@ async def list_accounts(admin_key: str = Header(...)):
             "name": acc.name,
             "in_use": acc.in_use,
             "logged_in": acc.logged_in,
+            "is_muted": acc.is_muted,
+            "muted_until": acc.muted_until,
             "error_count": acc.error_count,
         })
 
@@ -256,7 +280,7 @@ async def startup():
             proxy=acc.proxy,
         )
 
-    print(f"Loaded {len(config.accounts)} accounts")
+    logger.info("Loaded %d accounts", len(config.accounts))
 
 
 ADMIN_HTML = """<!DOCTYPE html>

proxy.py

@@ -1,4 +1,6 @@
 import json
+import logging
+import os
 import time
 import uuid
 from typing import Optional
@@ -9,6 +11,12 @@ from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import StreamingResponse
 from pydantic import BaseModel
 
+logging.basicConfig(
+    level=logging.INFO,
+    format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+)
+logger = logging.getLogger(__name__)
+
 app = FastAPI(title="DS2API Browser Proxy")
 
 app.add_middleware(
@@ -19,9 +27,11 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
-DS2API_URL = "http://127.0.0.1:5001"
-API_KEYS = ["sk-default", "sk-test123456"]
-ADMIN_KEY = "admin"
+DS2API_URL = os.getenv("DS2API_UPSTREAM_URL", "http://127.0.0.1:5001")
+API_KEYS = os.getenv("DS2API_PROXY_KEYS", os.getenv("DS2API_KEYS", "sk-default")).split(",")
+ADMIN_KEY = os.getenv("DS2API_ADMIN_KEY", "admin")
+# Internal key used to talk to the upstream DS2API instance
+_UPSTREAM_KEY = os.getenv("DS2API_UPSTREAM_KEY", API_KEYS[0] if API_KEYS else "sk-default")
 
 
 class Message(BaseModel):
@@ -48,12 +58,16 @@ def verify_api_key(authorization: Optional[str] = Header(None)) -> str:
     return token
 
 
+def _upstream_headers() -> dict:
+    return {"Authorization": f"Bearer {_UPSTREAM_KEY}"}
+
+
 @app.get("/v1/models")
 async def list_models(authorization: str = Header(...)):
     verify_api_key(authorization)
     
     async with httpx.AsyncClient() as client:
-        resp = await client.get(f"{DS2API_URL}/v1/models", headers={"Authorization": f"Bearer sk-test123456"})
+        resp = await client.get(f"{DS2API_URL}/v1/models", headers=_upstream_headers())
         return resp.json()
 
 
@@ -62,7 +76,7 @@ async def get_model(model_id: str, authorization: str = Header(...)):
     verify_api_key(authorization)
     
     async with httpx.AsyncClient() as client:
-        resp = await client.get(f"{DS2API_URL}/v1/models/{model_id}", headers={"Authorization": f"Bearer sk-test123456"})
+        resp = await client.get(f"{DS2API_URL}/v1/models/{model_id}", headers=_upstream_headers())
         return resp.json()
 
 
@@ -84,7 +98,7 @@ async def chat_completions(
                         "POST",
                         f"{DS2API_URL}/v1/chat/completions",
                         json=request.model_dump(),
-                        headers={"Authorization": "Bearer sk-test123456"},
+                        headers=_upstream_headers(),
                         timeout=120,
                     ) as resp:
                         async for line in resp.aiter_lines():
@@ -98,7 +112,7 @@ async def chat_completions(
         resp = await client.post(
             f"{DS2API_URL}/v1/chat/completions",
             json=request.model_dump(),
-            headers={"Authorization": "Bearer sk-test123456"},
+            headers=_upstream_headers(),
             timeout=120,
         )
         return resp.json()
@@ -139,8 +153,8 @@ async def anthropic_messages(request: Request, authorization: str = Header(...))
                     async with stream_client.stream(
                         "POST",
                         f"{DS2API_URL}/v1/chat/completions",
-                        json={"model": "deepseek-v4-flash", "messages": [{"role": "user", "content": prompt}], "stream": True},
-                        headers={"Authorization": "Bearer sk-test123456"},
+                        json={"model": "deepseek-flash", "messages": [{"role": "user", "content": prompt}], "stream": True},
+                        headers=_upstream_headers(),
                         timeout=120,
                     ) as resp:
                         async for line in resp.aiter_lines():
@@ -165,8 +179,8 @@ async def anthropic_messages(request: Request, authorization: str = Header(...))
 
         resp = await client.post(
             f"{DS2API_URL}/v1/chat/completions",
-            json={"model": "deepseek-v4-flash", "messages": [{"role": "user", "content": prompt}], "stream": False},
-            headers={"Authorization": "Bearer sk-test123456"},
+            json={"model": "deepseek-flash", "messages": [{"role": "user", "content": prompt}], "stream": False},
+            headers=_upstream_headers(),
             timeout=120,
         )
         data = resp.json()
@@ -201,8 +215,8 @@ async def gemini_generate(model: str, request: Request, authorization: str = Hea
     async with httpx.AsyncClient() as client:
         resp = await client.post(
             f"{DS2API_URL}/v1/chat/completions",
-            json={"model": "deepseek-v4-flash", "messages": [{"role": "user", "content": prompt}], "stream": False},
-            headers={"Authorization": "Bearer sk-test123456"},
+            json={"model": "deepseek-flash", "messages": [{"role": "user", "content": prompt}], "stream": False},
+            headers=_upstream_headers(),
             timeout=120,
         )
         data = resp.json()
@@ -243,8 +257,8 @@ async def gemini_stream_generate(model: str, request: Request, authorization: st
             async with stream_client.stream(
                 "POST",
                 f"{DS2API_URL}/v1/chat/completions",
-                json={"model": "deepseek-v4-flash", "messages": [{"role": "user", "content": prompt}], "stream": True},
-                headers={"Authorization": "Bearer sk-test123456"},
+                json={"model": "deepseek-flash", "messages": [{"role": "user", "content": prompt}], "stream": True},
+                headers=_upstream_headers(),
                 timeout=120,
             ) as resp:
                 async for line in resp.aiter_lines():
@@ -331,7 +345,7 @@ def main():
     uvicorn.run(
         app,
         host="0.0.0.0",
-        port=5002,
+        port=int(os.getenv("DS2API_PROXY_PORT", "5002")),
     )
 
 

requirements.txt

@@ -3,3 +3,4 @@ fastapi>=0.100.0
 uvicorn>=0.23.0
 pydantic>=2.0.0
 python-dotenv>=1.0.0
+httpx>=0.24.0

start.py

@@ -1,18 +1,14 @@
 #!/usr/bin/env python3
-"""Quick test script for DS2API Browser with multiple accounts."""
+"""Quick start script for DS2API Browser.
+
+Accounts and keys are loaded from .env file automatically by main.py.
+See .env.example for the expected format.
+"""
 import os
 import sys
 
 sys.path.insert(0, os.path.dirname(__file__))
 
-# 多账号配置，用分号分隔
-# 格式: email:password:name:proxy
-os.environ["DS2API_ACCOUNTS"] = "huanxiangnb+dja@gmail.com:m1234567:账号1;huanxiangnb+321fffww@gmail.com:m1234567:账号2"
-os.environ["DS2API_KEYS"] = "sk-test123456"
-os.environ["DS2API_ADMIN_KEY"] = "admin"
-os.environ["DS2API_PORT"] = "5002"
-os.environ["DS2API_HEADLESS"] = "true"
-
 from main import main
 
 if __name__ == "__main__":