实战：个人事务处理中心LCP

# 建议保存路径：/root/.hermes/skills/scripts/process_gmail.py
import os
from google_auth_oauthlib.flow import InstalledAppFlow
from googleapiclient.discovery import build
# 假设 Agent 环境内置了 LLM 调用能力
# from hermes_tools import llm_call

# --- 配置 ---
SCOPES = ['https://www.googleapis.com/auth/gmail.modify']
CREDENTIALS_DIR = os.environ.get("GMAIL_CREDS_PATH", "/root/.hermes/secrets")
TOKEN_PATH = os.path.join(CREDENTIALS_DIR, 'token.json')
CREDS_PATH = os.path.join(CREDENTIALS_DIR, 'credentials.json')

def get_gmail_service():
    """获取并返回已授权的 Gmail 服务对象。"""
    # ... 此处省略了完整的 Google API 认证代码 ...
    # 真实场景下，你可以直接复用 google-auth-library-python 的标准实现
    # 这里仅为演示结构
    flow = InstalledAppFlow.from_client_secrets_file(CREDS_PATH, SCOPES)
    creds = flow.run_local_server(port=0)
    return build('gmail', 'v1', credentials=creds)

def summarize_email(content):
    """调用 LLM 生成邮件摘要。"""
    # 伪代码：实际应使用 Agent 内置的 LLM 调用方式
    # prompt = f"请将以下邮件内容提炼成不超过 50 字的摘要，并提取关键待办事项：\n\n{content}"
    # summary = llm_call(prompt)
    # return summary
    return f"摘要（伪代码）：{content[:100]}..."

def main():
    """主函数：拉取、处理、报告。"""
    service = get_gmain_service()
    
    # 1. 获取未读邮件
    results = service.users().messages().list(userId='me', q='is:unread in:inbox').execute()
    messages = results.get('messages', [])
    
    if not messages:
        print("🎉 收件箱无新邮件，一切尽在掌握。")
        return

    report_parts = []
    
    for message_info in messages[:5]: # 每次最多处理5封，防止超时
        msg = service.users().messages().get(userId='me', id=message_info['id']).execute()
        
        # 简单规则：忽略包含 "no-reply" 的邮件
        sender = next(h['value'] for h in msg['payload']['headers'] if h['name'] == 'From')
        if "no-reply" in sender:
            continue

        # 2. 获取内容并生成摘要
        snippet = msg['snippet']
        summary = summarize_email(snippet)
        subject = next(h['value'] for h in msg['payload']['headers'] if h['name'] == 'Subject')

        report_parts.append(f"### {subject}\n**发件人**: {sender}\n**摘要**: {summary}\n")

        # 3. 标记已读并归档
        service.users().messages().modify(
            userId='me',
            id=message_info['id'],
            body={'removeLabelIds': ['UNREAD', 'INBOX'], 'addLabelIds': ['processed-by-hermes']}
        ).execute()

    if report_parts:
        print("## 📬 每日邮件摘要\n\n" + "\n".join(report_parts))
    else:
        print("✅ 已过滤所有新邮件，无重要事项。")

if __name__ == '__main__':
    main()

cronjob(
  action='create',
  name='daily-gmail-processor',
  schedule='every 30m',
  # 注意：这里我们使用 script 参数直接指定脚本路径
  # 这是一种更现代、更直接的 no_agent 模式用法
  script='/root/.hermes/skills/scripts/process_gmail.py',
  no_agent=True, # 直接运行脚本，输出即为结果，高效稳定
  prompt="Gmail 邮件定时处理任务",
  deliver='origin' # 将结果发回你配置的 Telegram
)