Update watcher.py

watcher.py

@@ -229,6 +229,50 @@ def send_to_channel(text):
     )
     res.raise_for_status()
 
+# ===== ダウンロードリンクを整理して表示 =====
+def format_download_links(items):
+    """
+    ダウンロードリンクを整理してフォーマットする
+    """
+    # 画質順にソート
+    video_items = []
+    audio_items = []
+    
+    for item in items:
+        if item["quality"] == "audio":
+            audio_items.append(item)
+        else:
+            m = re.match(r"(\d+)p", item["quality"])
+            if m:
+                video_items.append((int(m.group(1)), item))
+    
+    # 画質の高い順にソート
+    video_items.sort(key=lambda x: x[0], reverse=True)
+    
+    # メッセージ作成
+    lines = ["📥 利用可能なダウンロードリンク:"]
+    
+    # 映像リンク（音声付き）
+    video_with_audio = [item for item in items if item.get("has_audio") == "true" and item["quality"] != "audio"]
+    if video_with_audio:
+        lines.append("\n🎬 映像+音声（単一ファイル）:")
+        for item in video_with_audio:
+            lines.append(f"  • {item['quality']}: {item['url']}")
+    
+    # 映像のみリンク
+    if video_items:
+        lines.append("\n📹 映像のみ（高画質）:")
+        for quality, item in video_items:
+            lines.append(f"  • {item['quality']}: {item['url']}")
+    
+    # 音声のみリンク
+    if audio_items:
+        lines.append("\n🎵 音声のみ:")
+        for item in audio_items:
+            lines.append(f"  • {item['quality']}: {item['url']}")
+    
+    return "\n".join(lines)
+
 # ===== Main =====
 def main():
     processed_messages = set()  # 処理済みメッセージを追跡
@@ -279,48 +323,58 @@ def main():
             youtube_url = f"https://www.youtube.com/watch?v={youtube_id}"
             items, nonce = fetch_download_links(youtube_url)
             
-            if not nonce:
-                print("nonceの取得に失敗しました")
+            if not items:
+                print("ダウンロードリンクが見つかりません")
                 time.sleep(10)
                 continue
 
-            video_item, audio_item = select_best_video_and_audio(items)
-            if not video_item or not audio_item:
-                print("適切な動画または音声が見つかりません")
-                time.sleep(10)
-                continue
-
-            # 画質情報を取得
-            quality_match = re.match(r"(\d+)p", video_item["quality"])
-            if not quality_match:
-                print("画質情報の取得に失敗しました")
-                time.sleep(10)
-                continue
-                
-            quality = quality_match.group(1)
-            
-            # 動画タイトル（簡易版 - 実際にはYouTubeから取得する方が良い）
-            video_title = f"youtube_video_{youtube_id}"
+            # 1. すべてのダウンロードリンクを送信
+            download_links_message = format_download_links(items)
+            send_to_channel(download_links_message)
             
-            # サーバー側で結合
-            print(f"サーバー側での結合を開始します: {youtube_id} {quality}p")
-            merged_url = merge_video_on_server(
-                video_item["url"],
-                audio_item["url"],
-                youtube_id,
-                quality,
-                video_title,
-                nonce
-            )
-            
-            # 結果を送信
-            message = f"🎬 結合済み動画（{quality}p）\n{merged_url}"
-            send_to_channel(message)
+            # 2. 最高画質の映像と音声を結合（オプション）
+            if nonce:
+                video_item, audio_item = select_best_video_and_audio(items)
+                
+                if video_item and audio_item:
+                    # 画質情報を取得
+                    quality_match = re.match(r"(\d+)p", video_item["quality"])
+                    if quality_match:
+                        quality = quality_match.group(1)
+                        
+                        # 動画タイトル（簡易版）
+                        video_title = f"youtube_video_{youtube_id}"
+                        
+                        # 結合処理開始メッセージを送信
+                        send_to_channel(f"🔄 最高画質({quality}p)の動画と音声を結合中... しばらくお待ちください。")
+                        
+                        try:
+                            # サーバー側で結合
+                            print(f"サーバー側での結合を開始します: {youtube_id} {quality}p")
+                            merged_url = merge_video_on_server(
+                                video_item["url"],
+                                audio_item["url"],
+                                youtube_id,
+                                quality,
+                                video_title,
+                                nonce
+                            )
+                            
+                            # 結合済み動画のリンクを送信
+                            merged_message = f"✅ 結合完了！最高画質({quality}p)の動画:\n{merged_url}"
+                            send_to_channel(merged_message)
+                            
+                            print("結合完了:", merged_url)
+                            
+                        except Exception as merge_error:
+                            error_message = f"⚠️ 結合処理中にエラーが発生しました: {str(merge_error)}"
+                            send_to_channel(error_message)
+                            print("結合エラー:", merge_error)
             
             # 処理済みとしてマーク
             processed_messages.add(latest_msg.get("id"))
             
-            print("送信完了:", merged_url)
+            print(f"処理完了: {youtube_id}")
 
         except Exception as e:
             print("エラー:", e)