cyb50-quant/market-regime-identifier-30/smtp_relay_server.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
本地SMTP中继服务器 - 将邮件转发到外部邮箱
支持两种方式:
1. 直接投递(会被拒收): python smtp_relay_server.py --direct
2. 通过QQ邮箱中继(推荐): python smtp_relay_server.py --relay
"""

import asyncio
import smtplib
import sys
from datetime import datetime
from aiosmtpd.controller import Controller
from aiosmtpd.handlers import Proxy
from email import message_from_bytes

# ========== 配置你的QQ邮箱中继 ==========
RELAY_HOST = "smtp.qq.com"
RELAY_PORT = 587
RELAY_USER = "380880504@qq.com"     # QQ邮箱
RELAY_PASS = "your_auth_code"        # QQ邮箱授权码
# =======================================


class SmartRelayHandler:
    """
    智能中继处理器
    - 将收到的邮件通过真实SMTP服务器转发
    """

    def __init__(self, relay_host=None, relay_port=None, relay_user=None, relay_pass=None):
        self.relay_host = relay_host
        self.relay_port = relay_port
        self.relay_user = relay_user
        self.relay_pass = relay_pass
        self.use_relay = all([relay_host, relay_port, relay_user, relay_pass])
        self.email_count = 0

    async def handle_DATA(self, server, session, envelope):
        """处理收到的邮件并转发"""
        self.email_count += 1

        mail_from = envelope.mail_from
        rcpt_tos = envelope.rcpt_tos
        data = envelope.content

        print(f"\n{'='*70}")
        print(f"[RECEIVE] 收到邮件 #{self.email_count}")
        print(f"{'='*70}")
        print(f"时间: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
        print(f"发件人: {mail_from}")
        print(f"收件人: {', '.join(rcpt_tos)}")
        print(f"大小: {len(data)} bytes")

        # 解析邮件主题
        try:
            msg = message_from_bytes(data)
            subject = msg.get('Subject', 'No Subject')
            print(f"主题: {subject}")
        except:
            pass

        # 转发邮件
        if self.use_relay:
            success = self._relay_email(mail_from, rcpt_tos, data)
            if success:
                print(f"[RELAY] 邮件已通过 {self.relay_host} 转发成功")
            else:
                print(f"[FAIL] 转发失败，邮件已保存到本地")
                self._save_local(mail_from, rcpt_tos, data)
        else:
            print(f"[MODE] 本地模式 - 未配置中继，仅保存到文件")
            self._save_local(mail_from, rcpt_tos, data)

        return '250 OK'

    def _relay_email(self, mail_from, rcpt_tos, data):
        """通过真实SMTP服务器转发邮件"""
        try:
            print(f"[RELAY] 正在连接 {self.relay_host}:{self.relay_port}...")
            with smtplib.SMTP(self.relay_host, self.relay_port, timeout=30) as server:
                server.starttls()
                print(f"[RELAY] 正在登录 {self.relay_user}...")
                server.login(self.relay_user, self.relay_pass)
                print(f"[RELAY] 正在发送给 {', '.join(rcpt_tos)}...")
                server.sendmail(self.relay_user, rcpt_tos, data)
            return True
        except Exception as e:
            print(f"[RELAY ERROR] {e}")
            return False

    def _save_local(self, mail_from, rcpt_tos, data):
        """保存到本地文件"""
        try:
            with open("received_emails.log", 'a', encoding='utf-8') as f:
                f.write(f"\n{'='*70}\n")
                f.write(f"Email #{self.email_count} - {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n")
                f.write(f"From: {mail_from}\n")
                f.write(f"To: {', '.join(rcpt_tos)}\n")
                f.write(f"{'-'*70}\n")
                f.write(data.decode('utf-8', errors='replace'))
                f.write(f"\n{'='*70}\n")
            print(f"[SAVE] 已保存到 received_emails.log")
        except Exception as e:
            print(f"[SAVE ERROR] {e}")


class DirectDeliveryHandler:
    """
    直接投递处理器
    - 尝试直接连接到收件人域名的MX记录投递
    - 大概率会被拒收（因为没有SPF/DKIM）
    """

    def __init__(self):
        self.email_count = 0

    async def handle_DATA(self, server, session, envelope):
        self.email_count += 1
        mail_from = envelope.mail_from
        rcpt_tos = envelope.rcpt_tos
        data = envelope.content

        print(f"\n{'='*70}")
        print(f"[DIRECT] 收到邮件 #{self.email_count}")
        print(f"{'='*70}")
        print(f"警告: 直接投递模式，大概率会被拒收！")
        print(f"发件人: {mail_from}")
        print(f"收件人: {', '.join(rcpt_tos)}")

        # 尝试直接投递
        for rcpt in rcpt_tos:
            domain = rcpt.split('@')[1]
            print(f"[DIRECT] 尝试投递到 {domain}...")
            try:
                # 这里简化处理，实际需要查询MX记录
                self._try_deliver(domain, mail_from, rcpt, data)
            except Exception as e:
                print(f"[DIRECT FAIL] {e}")

        # 保存备份
        with open("received_emails.log", 'a', encoding='utf-8') as f:
            f.write(f"\n[Direct Attempt] {datetime.now()}\n")
            f.write(data.decode('utf-8', errors='replace'))

        return '250 OK'

    def _try_deliver(self, domain, mail_from, rcpt_to, data):
        """尝试直接连接到目标域的邮件服务器"""
        import dns.resolver
        try:
            # 查询MX记录
            answers = dns.resolver.resolve(domain, 'MX')
            mx_host = str(answers[0].exchange)
            print(f"[DIRECT] MX记录: {mx_host}")

            # 连接并投递
            with smtplib.SMTP(mx_host, 25, timeout=10) as server:
                server.sendmail(mail_from, [rcpt_to], data)
            print(f"[DIRECT] 投递成功！")
        except Exception as e:
            print(f"[DIRECT] 投递失败: {e}")


def main():
    import argparse

    parser = argparse.ArgumentParser(description='本地SMTP中继服务器')
    parser.add_argument('--port', type=int, default=25,
                        help='本地监听端口 (默认: 25)')
    parser.add_argument('--host', type=str, default='localhost',
                        help='监听地址 (默认: localhost)')
    parser.add_argument('--relay', action='store_true',
                        help='使用中继模式 (通过QQ邮箱转发)')
    parser.add_argument('--direct', action='store_true',
                        help='使用直接投递模式 (会被拒收)')

    args = parser.parse_args()

    # 选择处理器
    if args.direct:
        handler = DirectDeliveryHandler()
        mode = "直接投递 (大概率被拒收)"
    elif args.relay:
        if RELAY_PASS == "your_auth_code":
            print("[ERROR] 请先配置QQ邮箱授权码!")
            print(f"编辑 {__file__}，修改 RELAY_PASS = '你的授权码'")
            sys.exit(1)
        handler = SmartRelayHandler(RELAY_HOST, RELAY_PORT, RELAY_USER, RELAY_PASS)
        mode = f"中继模式 (via {RELAY_HOST})"
    else:
        handler = SmartRelayHandler()  # 本地模式
        mode = "本地保存 (未配置中继)"

    # 启动服务器
    controller = Controller(handler, hostname=args.host, port=args.port)

    print("="*70)
    print(f"[SMTP Relay Server] 启动成功")
    print("="*70)
    print(f"模式: {mode}")
    print(f"监听: {args.host}:{args.port}")
    print(f"测试: python send_simple_test_email.py")
    print("-"*70)

    if args.relay:
        print(f"中继账号: {RELAY_USER}")
        print("邮件将转发到收件人邮箱")
    else:
        print("邮件仅保存到本地: received_emails.log")
        print("要启用转发，请运行: python smtp_relay_server.py --relay")

    print(f"\n按 Ctrl+C 停止服务器")
    print("="*70)

    controller.start()

    try:
        while True:
            import time
            time.sleep(1)
    except KeyboardInterrupt:
        print("\n\n正在停止服务器...")
        controller.stop()
        print("[OK] 服务器已停止")


if __name__ == '__main__':
    main()