Jiaqing Liang
38f8cfc037
Rename tracked email.py/lark.py to _email_example.py/_lark_example.py so the poller (which skips _-prefixed files) no longer polls them on a fresh clone. Activate by copying to email.py/lark.py (now gitignored). Also nudge manager to reuse existing subagents on IM signals.
28 lines
1.5 KiB
Python
28 lines
1.5 KiB
Python
"""飞书：lark-cli 轮询 config.local.json {"lark_chat_ids": [...]} 中的会话，INTERVAL 内有新消息 → 触发。"""
|
|
import glob, json, os, subprocess, time
|
|
|
|
INTERVAL = 300
|
|
|
|
PROMPT = """\
|
|
你是飞书采集subagent。先读记忆中用户画像，再用 lark-cli 查看最近消息（详见 lark_cli_sop；会话ID取本插件目录 config.local.json 的 lark_chat_ids，逐个 `lark-cli im +chat-messages-list --as user --chat-id <id> --sort desc --page-size 10`），挑出刚出现的新消息，过滤后汇报值得关注项并补全上下文。
|
|
不执行外部动作；无值得关注的就一句话说明。"""
|
|
|
|
_CFG = os.path.join(os.path.dirname(os.path.abspath(__file__)), "config.local.json")
|
|
_NODE = glob.glob(os.path.expandvars(r"%APPDATA%\fnm\node-versions\*\installation")) # lark-cli在fnm node下
|
|
|
|
|
|
def check() -> bool:
|
|
cfg = json.load(open(_CFG, encoding="utf-8")) if os.path.exists(_CFG) else {}
|
|
env = {**os.environ, "PATH": os.pathsep.join(_NODE + [os.environ.get("PATH", "")])}
|
|
start = int(time.time()) - INTERVAL - 5
|
|
for cid in cfg.get("lark_chat_ids", []):
|
|
r = subprocess.run(
|
|
f"lark-cli im +chat-messages-list --as user --chat-id {cid} --start {start} --page-size 1",
|
|
shell=True, capture_output=True, text=True, encoding="utf-8", errors="replace", env=env)
|
|
try:
|
|
if json.loads(r.stdout)["data"]["total"]:
|
|
return True
|
|
except Exception:
|
|
pass
|
|
return False
|