| FROM python:3.9-slim |
|
|
| WORKDIR /app |
|
|
| RUN echo "telethon" > requirements.txt && pip install --no-cache-dir -r requirements.txt |
|
|
| RUN echo 'import asyncio\n\ |
| import os\n\ |
| import sys\n\ |
| import re\n\ |
| from telethon import TelegramClient, events\n\ |
| from telethon.sessions import StringSession\n\ |
| \n\ |
| sys.stdout.reconfigure(line_buffering=True)\n\ |
| \n\ |
| API_ID = int(os.environ.get("API_ID", "0"))\n\ |
| API_HASH = os.environ.get("API_HASH")\n\ |
| SESSION_STRING = os.environ.get("TG_SESSION_STRING")\n\ |
| \n\ |
| if not all([API_ID, API_HASH, SESSION_STRING]):\n\ |
| print("缺少必要的环境变量")\n\ |
| sys.exit(1)\n\ |
| \n\ |
| async def get_recent_verification_messages(client, count=5):\n\ |
| """获取来自官方通知用户(777000)的最近 count 条消息，并打印完整内容和验证码"""\n\ |
| print(f"正在获取来自官方通知用户的最近 {count} 条消息...")\n\ |
| messages = []\n\ |
| async for msg in client.iter_messages(777000, limit=count, reverse=False):\n\ |
| messages.append(msg)\n\ |
| # 按时间顺序从旧到新打印\n\ |
| for i, msg in enumerate(reversed(messages), 1):\n\ |
| text = msg.text\n\ |
| print(f"--- 第 {i} 条（{msg.date}）---")\n\ |
| print(f"消息内容: {text}")\n\ |
| match = re.search(r"\\b(\\d{5,6})\\b", text)\n\ |
| if match:\n\ |
| print(f"验证码: {match.group(1)}")\n\ |
| else:\n\ |
| print("未找到验证码")\n\ |
| if not messages:\n\ |
| print("未找到来自官方通知用户的消息")\n\ |
| \n\ |
| async def main():\n\ |
| # 延迟 60 秒启动，让旧容器完全退出，避免 session 冲突\n\ |
| print("等待 60 秒，确保旧容器已退出...")\n\ |
| await asyncio.sleep(60)\n\ |
| \n\ |
| client = TelegramClient(StringSession(SESSION_STRING), API_ID, API_HASH)\n\ |
| await client.start()\n\ |
| print("连接成功")\n\ |
| \n\ |
| # 启动时获取最近 5 条验证码消息\n\ |
| await get_recent_verification_messages(client, count=5)\n\ |
| \n\ |
| # 添加实时监听验证码（官方通知用户 777000）\n\ |
| @client.on(events.NewMessage(from_users=777000))\n\ |
| async def verification_handler(event):\n\ |
| text = event.message.text\n\ |
| print(f"收到新官方通知（实时）")\n\ |
| print(f"消息内容: {text}")\n\ |
| match = re.search(r"\\b(\\d{5,6})\\b", text)\n\ |
| if match:\n\ |
| print(f"验证码: {match.group(1)}")\n\ |
| else:\n\ |
| print("未找到验证码")\n\ |
| \n\ |
| print("验证码监听已启动，等待新消息...")\n\ |
| await client.run_until_disconnected()\n\ |
| \n\ |
| if __name__ == "__main__":\n\ |
| try:\n\ |
| asyncio.run(main())\n\ |
| except KeyboardInterrupt:\n\ |
| print("停止")\n\ |
| except Exception as e:\n\ |
| print(f"主程序异常: {e}")\n\ |
| import traceback\n\ |
| traceback.print_exc()\n' > verif_monitor.py |
|
|
| EXPOSE 7860 |
| CMD python -u verif_monitor.py 2>&1 & python -m http.server 7860 |
