Update watcher.py

watcher.py

@@ -351,6 +351,47 @@ def send_to_channel(text):
     )
     res.raise_for_status()
 
+    
+def upload_file_to_channel(file_url):
+    # mp4バイナリ取得
+    file_res = requests.get(file_url, timeout=60)
+    file_res.raise_for_status()
+
+    upload_url = "https://media.channel.io/cht/v1/pri-file/200605/groups/519217/message/send_yt_video_file.mp4"
+
+    files = {
+        "file": ("video.mp4", file_res.content, "video/mp4")
+    }
+
+    headers = {
+        "x-account": X_ACCOUNT,
+    }
+
+    res = requests.post(upload_url, headers=headers, files=files, timeout=60)
+    res.raise_for_status()
+
+    return res.json()  # ←これを messages POST の body.files に入れる
+
+
+def send_video_message(file_json):
+    request_id = f"desk-web-{int(time.time() * 1000)}"
+    
+    payload = {
+        "requestId": request_id,
+        "blocks": [
+            {"type": "text", "value": "プレビュー："}
+        ],
+        "files": [file_json],  # ←ここが重要！
+    }
+
+    res = requests.post(
+        POST_URL,
+        headers=HEADERS_POST,
+        data=json.dumps(payload),
+        timeout=30
+    )
+    res.raise_for_status()
+
 # ===== Main =====
 def main():
     processed_messages = set()  # 処理済みメッセージを追跡
@@ -475,9 +516,10 @@ def main():
                             nonce
                         )
                         send_to_channel(f"<link type=\"url\" value=\"{merged_url}\">{q}p 結合済み動画</link>")
+                        file_json = upload_file_to_channel(merged_url)
+                        send_video_message(file_json)
                     except Exception as e:
                         send_to_channel(f"結合失敗: {e}")
-
             send_to_channel("完了しました！")
             processed_messages.add(latest_msg["id"])