Update watcher.py

watcher.py

@@ -160,17 +160,14 @@ def poll_progress_url(progress_url, max_attempts=30, interval=10):
     return False, last_json
 
 def process_savenow_flow(youtube_url, quality_opt):
-    """
-    SaveNow の初回 GET -> progress_url をポーリング -> 見つかったリンクを channel に送信
-    """
     initial_url = build_savenow_initial_url(youtube_url, quality_opt)
-    send_to_channel(f"SaveNow にリクエストを送信しています: {initial_url}")
+    send_to_channel(f"リクエストを送信しています")
     try:
         r = requests.get(initial_url, timeout=30)
         r.raise_for_status()
         init_json = r.json()
     except Exception as e:
-        send_to_channel(f"SaveNow へのリクエストに失敗しました: {e}")
+        send_to_channel(f"リクエストに失敗しました: {e}")
         return None
 
     # 初回レスポンスに progress_url がある想定
@@ -188,17 +185,17 @@ def process_savenow_flow(youtube_url, quality_opt):
                     urls.append(alt["url"])
             # channel に送る
             for i, u in enumerate(urls, start=1):
-                send_to_channel(f"ダウンロードリンク #{i}: <link type=\"url\" value=\"{u}\">{u}</link>")
+                send_to_channel(f"<link type=\"url\" value=\"{u}\">ダウンロードリンク{i}</link>")
             return urls
-        send_to_channel("progress_url が見つかりませんでした。レスポンスをログに出します。")
-        send_to_channel(f"初回レスポンス: {json.dumps(init_json, ensure_ascii=False)[:1000]}")
+        send_to_channel("progress_url が見つかりませんでした。")
+        #send_to_channel(f"初回レスポンス: {json.dumps(init_json, ensure_ascii=False)[:1000]}")
         return None
 
     # progress_url があればポーリング
-    send_to_channel(f"進捗監視を開始します: {progress_url} （最大30回、10秒間隔）")
+    send_to_channel(f"変換処理を開始します")
     ok, poll_json = poll_progress_url(progress_url, max_attempts=30, interval=10)
     if not ok:
-        send_to_channel("進捗監視がタイムアウトしました。最後のレスポンスをログに出します。")
+        send_to_channel("進捗監視がタイムアウトしました。")
         send_to_channel(f"最後のレスポンス: {json.dumps(poll_json, ensure_ascii=False)[:1000]}")
         return None
 
@@ -219,11 +216,11 @@ def process_savenow_flow(youtube_url, quality_opt):
             unique_urls.append(u)
 
     if not unique_urls:
-        send_to_channel("ダウンロードリンクが見つかりませんでした（成功レスポンスでしたが link が空）。")
+        send_to_channel("ダウンロードリンクが見つかりませんでした（成功レスポンスでしたがlinkが空）。")
         return None
 
     for i, u in enumerate(unique_urls, start=1):
-        send_to_channel(f"ダウンロードリンク #{i}: <link type=\"url\" value=\"{u}\">{u}</link>")
+        send_to_channel(f"<link type=\"url\" value=\"{u}\">ダウンロードリンク{i}</link>")
 
     return unique_urls
 
@@ -296,14 +293,12 @@ def main():
 
             quality_opt = normalize_quality(option)
             youtube_url = f"https://www.youtube.com/watch?v={video_id}"
-            send_to_channel(f"{video_id} のダウンロード（SaveNow）を開始します。")
+            send_to_channel(f"{video_id} のダウンロードを開始します。")
 
             # SaveNow フローを使う（要求にあった処理）
             urls = process_savenow_flow(youtube_url, quality_opt)
 
-            if urls:
-                send_to_channel("リンクを取得しました。必要ならファイルをアップロードする処理を追加してください。")
-            else:
+            if  not urls:
                 send_to_channel("リンクが取得できませんでした。別の方法を試すか、ログを確認してください。")
 
             processed_messages.add(latest_msg["id"])