fix: image_daemon v2 with detailed logging

image_daemon.py

@@ -1,17 +1,18 @@
 #!/usr/bin/env python3
 """
-飞书图片预处理守护进程 (image_daemon.py)
+飞书图片预处理守护进程 (image_daemon.py) v2
 后台运行，自动检测飞书聊天中的新图片消息，下载并上传到图床，
 然后以文本消息回复图片 URL，让 OpenClaw agent 直接看到可访问的 URL。
 """
-import os, sys, json, time, requests, hashlib
+import os, sys, json, time, requests
 
 FEISHU_BASE = "https://open.feishu.cn/open-apis"
-POLL_INTERVAL = int(os.environ.get("IMAGE_POLL_INTERVAL", "3"))
+POLL_INTERVAL = int(os.environ.get("IMAGE_POLL_INTERVAL", "5"))
 processed_file = "/tmp/image_daemon_processed.json"
 
 def log(msg):
-    print(f"[image_daemon] {msg}", flush=True)
+    ts = time.strftime("%H:%M:%S")
+    print(f"[image_daemon {ts}] {msg}", flush=True)
 
 def load_processed():
     try:
@@ -22,16 +23,20 @@ def load_processed():
 
 def save_processed(s):
     with open(processed_file, "w") as f:
-        json.dump(list(s)[-500:], f)  # keep last 500
+        json.dump(list(s)[-500:], f)
 
 def get_tenant_token():
     app_id = os.environ.get("FEISHU_APP_ID")
     app_secret = os.environ.get("FEISHU_APP_SECRET")
+    if not app_id or not app_secret:
+        log(f"❌ 环境变量缺失: FEISHU_APP_ID={'set' if app_id else 'MISSING'}, FEISHU_APP_SECRET={'set' if app_secret else 'MISSING'}")
+        return None
     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}")
+        log(f"❌ Token 获取失败: {data}")
+        return None
     return data["tenant_access_token"]
 
 def get_bot_chats(token):
@@ -40,9 +45,14 @@ def get_bot_chats(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:
+    code = data.get("code", -1)
+    if code != 0:
+        msg = data.get("msg", "unknown")
+        log(f"❌ 获取聊天列表失败 (code={code}): {msg}")
+        log(f"   需要权限: im:chat / im:chat:readonly")
         return []
-    return [c["chat_id"] for c in data.get("data", {}).get("items", [])]
+    items = data.get("data", {}).get("items", [])
+    return [c["chat_id"] for c in items]
 
 def get_recent_messages(token, chat_id, limit=10):
     """获取聊天中最近的消息"""
@@ -56,7 +66,11 @@ def get_recent_messages(token, chat_id, limit=10):
             "page_size": limit
         }, timeout=10)
     data = resp.json()
-    if data.get("code") != 0:
+    code = data.get("code", -1)
+    if code != 0:
+        msg = data.get("msg", "unknown")
+        log(f"❌ 获取消息失败 chat={chat_id} (code={code}): {msg}")
+        log(f"   需要权限: im:message / im:message:readonly")
         return []
     return data.get("data", {}).get("items", [])
 
@@ -75,7 +89,6 @@ def extract_image_keys(msg):
         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):
@@ -89,16 +102,16 @@ def extract_image_keys(msg):
     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
+    log(f"❌ 下载图片失败 {image_key}: HTTP {resp.status_code}, {resp.text[:200]}")
+    log(f"   需要权限: im:resource")
     return None
 
 def upload_image(data):
-    """上传到免费图床"""
     # catbox.moe
     try:
         resp = requests.post("https://catbox.moe/user/api.php",
@@ -106,16 +119,18 @@ def upload_image(data):
             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
+        log(f"⚠️ catbox 失败: HTTP {resp.status_code}")
+    except Exception as e:
+        log(f"⚠️ catbox 异常: {e}")
     # 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
+        log(f"⚠️ 0x0 失败: HTTP {resp.status_code}")
+    except Exception as e:
+        log(f"⚠️ 0x0 异常: {e}")
     # tmpfiles
     try:
         resp = requests.post("https://tmpfiles.org/api/v1/upload",
@@ -124,31 +139,32 @@ def upload_image(data):
             url = resp.json().get("data", {}).get("url", "")
             if url:
                 return url.replace("tmpfiles.org/", "tmpfiles.org/dl/")
-    except:
-        pass
+        log(f"⚠️ tmpfiles 失败: HTTP {resp.status_code}")
+    except Exception as e:
+        log(f"⚠️ tmpfiles 异常: {e}")
     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()
+    data = resp.json()
+    code = data.get("code", -1)
+    if code != 0:
+        log(f"❌ 回复消息失败 (code={code}): {data.get('msg', '')}")
+        log(f"   需要权限: im:message / im:message:create_as_bot")
+    return data
 
 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
 
@@ -156,8 +172,9 @@ def process_message(token, chat_id, msg):
     if not image_keys:
         return
 
+    log(f"🖼️ 发现 {len(image_keys)} 张图片 (msg_id={msg_id[:16]}...)")
     urls = []
-    for key in image_keys[:3]:  # 最多处理 3 张
+    for key in image_keys[:3]:
         log(f"📥 下载图片 {key}")
         data = download_image(token, key)
         if data:
@@ -167,33 +184,56 @@ def process_message(token, chat_id, msg):
                 urls.append(url)
                 log(f"✅ {url}")
             else:
-                # 保存到本地
                 path = f"/tmp/{key}.jpg"
                 with open(path, "wb") as f:
                     f.write(data)
-                log(f"⚠️ 图床失败，本地保存: {path}")
+                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', '?')})")
+        log(f"📤 已回复 (code={result.get('code', '?')})")
 
 def main():
     log("🚀 启动中...")
+
+    # 环境诊断
+    app_id = os.environ.get("FEISHU_APP_ID", "")
+    log(f"📋 飞书 App ID: {app_id[:10]}..." if app_id else "❌ FEISHU_APP_ID 未设置!")
+
     processed = load_processed()
     token = None
     token_time = 0
+    cycle = 0
 
     while True:
         try:
+            cycle += 1
             # 每 30 分钟刷新一次 token
             if not token or time.time() - token_time > 1800:
                 token = get_tenant_token()
+                if not token:
+                    log("⏳ Token 获取失败，60 秒后重试...")
+                    time.sleep(60)
+                    continue
                 token_time = time.time()
                 log("🔑 Token 已刷新")
 
             chats = get_bot_chats(token)
+
+            # 首次和每 100 轮打印状态
+            if cycle == 1 or cycle % 100 == 0:
+                log(f"📊 轮询中... 找到 {len(chats)} 个聊天 (第 {cycle} 轮)")
+
+            if not chats and cycle == 1:
+                log("⚠️ 未找到任何聊天！可能原因:")
+                log("   1. 飞书 App 缺少 im:chat 或 im:chat:readonly 权限")
+                log("   2. 还没有用户跟 bot 发过消息")
+                log("   3. App 未正确发布")
+                log("   请在飞书开发者后台开启权限后重新发布")
+
+            new_imgs = 0
             for chat_id in chats:
                 messages = get_recent_messages(token, chat_id, limit=5)
                 for msg in messages:
@@ -202,15 +242,18 @@ def main():
                         continue
                     processed.add(msg_id)
 
-                    # 检查是否包含图片
                     msg_type = msg.get("msg_type", "")
                     if msg_type in ("image", "post"):
                         process_message(token, chat_id, msg)
+                        new_imgs += 1
 
-            save_processed(processed)
+            if new_imgs > 0:
+                save_processed(processed)
 
         except Exception as e:
-            log(f"❌ 错误: {e}")
+            log(f"❌ 错误: {type(e).__name__}: {e}")
+            import traceback
+            traceback.print_exc()
 
         time.sleep(POLL_INTERVAL)