修雨
5ce7cb61b0
新增 `dws skill setup` 交互式安装命令，支持单产品（mono）和多产品（multi，标记为试验版）两种 skill 布局，并与开源 dws v1.0.30 命令对齐。 主要变更： - 骨架：skills/ 拆为 skills/mono/ 和 skills/multi/（29 个产品 skill），git rename 保留历史 - 命令：新增 `skill setup` cobra 子命令，支持 --mode、--target、--source、--yes，huh 交互 - multi 模式支持 -s/--skill、-x/--exclude 按产品选择 - 覆盖全部 14 个 agent home 目录（与 install.sh 一致） - 发布：install.sh / install.ps1 / post-goreleaser.sh 改读 skills/mono；dws-skills.zip 同时包含 mono 和 multi 内容；~/.dws 本地缓存 - 内容对齐：删除 8 个仅内部使用的产品 skill、dingtalk-a2a；修正 mono/multi 共 15+ 处命令引用以匹配 OSS dws v1.0.30；chat skill 从 dws-wukong 回移更新 - 漂移清理：物理删除 skill 文档中 OSS 未暴露的命令，true-fail 命令转为 caveat；--help diff 100% 覆盖审计 - 测试：新增 Layer A 静态命令调度验证 + Layer B 端到端 mock 调度验证 - 同步 main：drive 9 个命令同步到 mono/multi skill
115 lines
3.1 KiB
Python
115 lines
3.1 KiB
Python
#!/usr/bin/env python3
|
|
"""
|
|
查询今天未读邮件并汇总（自动获取邮箱地址）
|
|
|
|
用法:
|
|
python mail_unread_summary.py
|
|
python mail_unread_summary.py --size 30
|
|
python mail_unread_summary.py --dry-run
|
|
"""
|
|
|
|
import sys
|
|
import json
|
|
import subprocess
|
|
import argparse
|
|
from datetime import datetime, timezone, timedelta
|
|
from typing import List, Any, Optional
|
|
|
|
TZ = timezone(timedelta(hours=8))
|
|
|
|
|
|
def run_dws(
|
|
args: List[str], dry_run: bool = False,
|
|
) -> Optional[Any]:
|
|
cmd = ['dws'] + args
|
|
if dry_run:
|
|
print(f"[dry-run] {' '.join(cmd)}")
|
|
return None
|
|
try:
|
|
result = subprocess.run(
|
|
cmd, capture_output=True, text=True, timeout=60
|
|
)
|
|
if result.returncode != 0:
|
|
print(f"错误：{result.stderr.strip()}", file=sys.stderr)
|
|
return None
|
|
return json.loads(result.stdout)
|
|
except (subprocess.TimeoutExpired, json.JSONDecodeError,
|
|
FileNotFoundError) as e:
|
|
print(f"错误：{e}", file=sys.stderr)
|
|
return None
|
|
|
|
|
|
def get_my_email(dry_run: bool = False) -> Optional[str]:
|
|
data = run_dws([
|
|
'mail', 'mailbox', 'list', '--format', 'json',
|
|
], dry_run=dry_run)
|
|
if dry_run:
|
|
return '<MY_EMAIL>'
|
|
if not data:
|
|
return None
|
|
if isinstance(data, list) and data:
|
|
item = data[0]
|
|
return (item.get('email') or item.get('address')
|
|
if isinstance(item, dict) else str(item))
|
|
if isinstance(data, dict):
|
|
return data.get('email') or data.get('address')
|
|
return None
|
|
|
|
|
|
def main():
|
|
parser = argparse.ArgumentParser(
|
|
description='查询今天未读邮件'
|
|
)
|
|
parser.add_argument(
|
|
'--size', type=int, default=20, help='返回数量'
|
|
)
|
|
parser.add_argument('--dry-run', action='store_true')
|
|
args = parser.parse_args()
|
|
|
|
print('📬 获取邮箱地址...')
|
|
email = get_my_email(dry_run=args.dry_run)
|
|
if not email and not args.dry_run:
|
|
print('错误：无法获取邮箱地址')
|
|
sys.exit(1)
|
|
|
|
today = datetime.now(TZ).strftime('%Y-%m-%dT00:00:00Z')
|
|
kql = f'isRead:false AND date>{today}'
|
|
|
|
print(f'🔍 搜索未读邮件...\n')
|
|
data = run_dws([
|
|
'mail', 'message', 'search',
|
|
'--email', email or '<MY_EMAIL>',
|
|
'--query', kql,
|
|
'--size', str(args.size),
|
|
'--format', 'json',
|
|
], dry_run=args.dry_run)
|
|
|
|
if args.dry_run:
|
|
return
|
|
if not data:
|
|
print('未查到邮件')
|
|
return
|
|
|
|
messages = (data if isinstance(data, list)
|
|
else data.get('items', data.get('messages', [])))
|
|
|
|
print(f"📧 今日未读邮件")
|
|
print('=' * 50)
|
|
if not messages:
|
|
print(' ✅ 收件箱清空，没有未读邮件！')
|
|
return
|
|
|
|
for m in messages:
|
|
subj = m.get('subject', '(无主题)')
|
|
sender = m.get('from', {})
|
|
sender_name = (sender.get('name') or sender.get('email', '未知')
|
|
if isinstance(sender, dict) else str(sender))
|
|
print(f" 📩 {subj}")
|
|
print(f" 发件人: {sender_name}")
|
|
|
|
print(f"\n合计: {len(messages)} 封未读邮件")
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main()
|