Update watcher.py

watcher.py

@@ -61,7 +61,47 @@ def extract_youtube_id(text):
         if m:
             return m.group(1)
     return None
+ 
+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()
+    
 def extract_youtube_and_option(text):
     parts = re.split(r"[ \u3000]+", text.strip())
     video_id = extract_youtube_id(parts[0])
@@ -303,7 +343,16 @@ def main():
 
             if  not urls:
                 send_to_channel("リンクが取得できませんでした。別の方法を試すか、ログを確認してください。")
+            merged_url = urls[0]
+
+            send_to_channel("ファイルをダウンロードして送信します。少々お待ちください。")
 
+            try:
+                file_json = upload_file_to_channel(merged_url)
+                send_video_message(file_json)
+            except Exception as e:
+                send_to_channel(f"ファイル送信中にエラーが発生しました: {e}")
+                
             processed_messages.add(latest_msg["id"])
             print(f"処理完了: {video_id}")