feat: add image_daemon.py system-level preprocessor

Dockerfile

@@ -22,6 +22,7 @@ RUN cd /root/.openclaw/extensions/feishu-openclaw && npm install @sinclair/typeb
 COPY SOUL.md /root/.openclaw/workspace/SOUL.md
 COPY status_page.py /app/status_page.py
 COPY image_proxy.py /app/image_proxy.py
+COPY image_daemon.py /app/image_daemon.py
 COPY skills/ /root/.openclaw/skills/
 COPY entrypoint.sh /app/entrypoint.sh
 RUN chmod +x /app/entrypoint.sh

entrypoint.sh

@@ -264,6 +264,14 @@ echo "   Gateway PID: $GATEWAY_PID"
 # 等待网关启动
 sleep 5
 
+# ============================================
+# 启动图片预处理守护进程（后台）
+# ============================================
+echo "🖼️ 启动图片预处理守护进程..."
+python3 /app/image_daemon.py &
+IMAGE_DAEMON_PID=$!
+echo "   Image Daemon PID: $IMAGE_DAEMON_PID"
+
 # ============================================
 # 启动状态监控网页（前台，端口 7860）
 # ============================================

image_daemon.py

@@ -0,0 +1,218 @@
+#!/usr/bin/env python3
+"""
+飞书图片预处理守护进程 (image_daemon.py)
+后台运行，自动检测飞书聊天中的新图片消息，下载并上传到图床，
+然后以文本消息回复图片 URL，让 OpenClaw agent 直接看到可访问的 URL。
+"""
+import os, sys, json, time, requests, hashlib
+
+FEISHU_BASE = "https://open.feishu.cn/open-apis"
+POLL_INTERVAL = int(os.environ.get("IMAGE_POLL_INTERVAL", "3"))
+processed_file = "/tmp/image_daemon_processed.json"
+
+def log(msg):
+    print(f"[image_daemon] {msg}", flush=True)
+
+def load_processed():
+    try:
+        with open(processed_file) as f:
+            return set(json.load(f))
+    except:
+        return set()
+
+def save_processed(s):
+    with open(processed_file, "w") as f:
+        json.dump(list(s)[-500:], f)  # keep last 500
+
+def get_tenant_token():
+    app_id = os.environ.get("FEISHU_APP_ID")
+    app_secret = os.environ.get("FEISHU_APP_SECRET")
+    resp = requests.post(f"{FEISHU_BASE}/auth/v3/tenant_access_token/internal",
+        json={"app_id": app_id, "app_secret": app_secret}, timeout=10)
+    data = resp.json()
+    if data.get("code") != 0:
+        raise Exception(f"token error: {data}")
+    return data["tenant_access_token"]
+
+def get_bot_chats(token):
+    """获取 bot 参与的所有聊天"""
+    headers = {"Authorization": f"Bearer {token}"}
+    resp = requests.get(f"{FEISHU_BASE}/im/v1/chats",
+        headers=headers, params={"page_size": 20}, timeout=10)
+    data = resp.json()
+    if data.get("code") != 0:
+        return []
+    return [c["chat_id"] for c in data.get("data", {}).get("items", [])]
+
+def get_recent_messages(token, chat_id, limit=10):
+    """获取聊天中最近的消息"""
+    headers = {"Authorization": f"Bearer {token}"}
+    resp = requests.get(f"{FEISHU_BASE}/im/v1/messages",
+        headers=headers,
+        params={
+            "container_id_type": "chat",
+            "container_id": chat_id,
+            "sort_type": "ByCreateTimeDesc",
+            "page_size": limit
+        }, timeout=10)
+    data = resp.json()
+    if data.get("code") != 0:
+        return []
+    return data.get("data", {}).get("items", [])
+
+def extract_image_keys(msg):
+    """从消息中提取所有 image_key"""
+    msg_type = msg.get("msg_type", "")
+    body_str = msg.get("body", {}).get("content", "{}")
+    try:
+        content = json.loads(body_str)
+    except:
+        return []
+
+    keys = []
+    if msg_type == "image":
+        k = content.get("image_key", "")
+        if k:
+            keys.append(k)
+    elif msg_type == "post":
+        # rich text / forwarded messages
+        for lang in ["zh_cn", "en_us"]:
+            lang_content = content.get(lang, {})
+            if isinstance(lang_content, dict):
+                for row in lang_content.get("content", []):
+                    if isinstance(row, list):
+                        for elem in row:
+                            if isinstance(elem, dict) and elem.get("tag") == "img":
+                                k = elem.get("image_key", "")
+                                if k:
+                                    keys.append(k)
+    return keys
+
+def download_image(token, image_key):
+    """从飞书下载图片"""
+    headers = {"Authorization": f"Bearer {token}"}
+    resp = requests.get(f"{FEISHU_BASE}/im/v1/images/{image_key}",
+        headers=headers, timeout=30)
+    if resp.status_code == 200 and len(resp.content) > 100:
+        return resp.content
+    return None
+
+def upload_image(data):
+    """上传到免费图床"""
+    # catbox.moe
+    try:
+        resp = requests.post("https://catbox.moe/user/api.php",
+            data={"reqtype": "fileupload"},
+            files={"filedata": ("img.jpg", data, "image/jpeg")}, timeout=30)
+        if resp.status_code == 200 and resp.text.startswith("http"):
+            return resp.text.strip()
+    except:
+        pass
+    # 0x0.st
+    try:
+        resp = requests.post("https://0x0.st",
+            files={"file": ("img.jpg", data, "image/jpeg")}, timeout=30)
+        if resp.status_code == 200 and resp.text.startswith("http"):
+            return resp.text.strip()
+    except:
+        pass
+    # tmpfiles
+    try:
+        resp = requests.post("https://tmpfiles.org/api/v1/upload",
+            files={"file": ("img.jpg", data, "image/jpeg")}, timeout=30)
+        if resp.status_code == 200:
+            url = resp.json().get("data", {}).get("url", "")
+            if url:
+                return url.replace("tmpfiles.org/", "tmpfiles.org/dl/")
+    except:
+        pass
+    return None
+
+def reply_text(token, chat_id, msg_id, text):
+    """在飞书聊天中回复文本消息"""
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json; charset=utf-8"
+    }
+    # 作为回复发送
+    resp = requests.post(f"{FEISHU_BASE}/im/v1/messages/{msg_id}/reply",
+        headers=headers,
+        json={
+            "content": json.dumps({"text": text}),
+            "msg_type": "text"
+        }, timeout=10)
+    return resp.json()
+
+def process_message(token, chat_id, msg):
+    """处理单条消息"""
+    msg_id = msg.get("message_id", "")
+    sender_type = msg.get("sender", {}).get("sender_type", "")
+
+    # 跳过 bot 自己发的消息
+    if sender_type == "app":
+        return
+
+    image_keys = extract_image_keys(msg)
+    if not image_keys:
+        return
+
+    urls = []
+    for key in image_keys[:3]:  # 最多处理 3 张
+        log(f"📥 下载图片 {key}")
+        data = download_image(token, key)
+        if data:
+            log(f"📥 {len(data)} bytes, 上传中...")
+            url = upload_image(data)
+            if url:
+                urls.append(url)
+                log(f"✅ {url}")
+            else:
+                # 保存到本地
+                path = f"/tmp/{key}.jpg"
+                with open(path, "wb") as f:
+                    f.write(data)
+                log(f"⚠️ 图床失败，本地保存: {path}")
+
+    if urls:
+        url_text = "\n".join(urls)
+        reply = f"[系统] 图片已自动处理，可通过以下链接查看：\n{url_text}"
+        result = reply_text(token, chat_id, msg_id, reply)
+        log(f"📤 已回复图片链接到聊天 (code={result.get('code', '?')})")
+
+def main():
+    log("🚀 启动中...")
+    processed = load_processed()
+    token = None
+    token_time = 0
+
+    while True:
+        try:
+            # 每 30 分钟刷新一次 token
+            if not token or time.time() - token_time > 1800:
+                token = get_tenant_token()
+                token_time = time.time()
+                log("🔑 Token 已刷新")
+
+            chats = get_bot_chats(token)
+            for chat_id in chats:
+                messages = get_recent_messages(token, chat_id, limit=5)
+                for msg in messages:
+                    msg_id = msg.get("message_id", "")
+                    if msg_id in processed:
+                        continue
+                    processed.add(msg_id)
+
+                    # 检查是否包含图片
+                    msg_type = msg.get("msg_type", "")
+                    if msg_type in ("image", "post"):
+                        process_message(token, chat_id, msg)
+
+            save_processed(processed)
+
+        except Exception as e:
+            log(f"❌ 错误: {e}")
+
+        time.sleep(POLL_INTERVAL)
+
+if __name__ == "__main__":
+    main()