Update arbitrage_launcher.py

arbitrage_launcher.py

@@ -1,7 +1,7 @@
 # arbitrage_launcher.py
 # Wrapper that automatically disables the arbitrage bot when the CLOB API
 # is unreachable and re‑enables it once the API recovers.
-# Sends a Telegram notification on each state change.
+# Sends a Telegram notification on each state change (with log confirmation).
 # No manual intervention needed – just replace the line in startup.sh.
 # All comments in English.
 
@@ -19,13 +19,15 @@ TELEGRAM_CHAT_ID = os.getenv("TELEGRAM_CHAT_ID")
 def send_telegram(text: str):
     """Send a message via Telegram Bot API.  Fails silently if not configured."""
     if not TELEGRAM_TOKEN or not TELEGRAM_CHAT_ID:
-        return
+        print("[Arbitrage] Telegram not configured – cannot send alert.", flush=True)
+        return False
     url = f"https://api.telegram.org/bot{TELEGRAM_TOKEN}/sendMessage"
     data = urllib.parse.urlencode({"chat_id": TELEGRAM_CHAT_ID, "text": text}).encode()
     try:
         urllib.request.urlopen(urllib.request.Request(url, data=data, method="POST"), timeout=10)
+        return True
     except:
-        pass
+        return False
 
 # ── State file to avoid duplicate alerts ─────────────
 STATE_FILE = "/app/arbitrage_clob_state.txt"
@@ -55,13 +57,20 @@ while True:
         # API is reachable
         if get_last_state() != "up":
             print("[Arbitrage] CLOB API is reachable. Enabling arbitrage bot...", flush=True)
-            send_telegram("✅ CLOB API is now reachable. Arbitrage bot re‑enabled.")
+            if send_telegram("✅ CLOB API is now reachable. Arbitrage bot re‑enabled."):
+                print("[Arbitrage] Telegram alert sent (re‑enabled).", flush=True)
+            else:
+                print("[Arbitrage] Telegram alert failed to send.", flush=True)
             set_state("up")
         break
     except Exception as e:
         if get_last_state() != "down":
-            print(f"[Arbitrage] CLOB API unreachable. Bot disabled. ({e})", flush=True)
-            send_telegram(f"⚠️ Arbitrage bot disabled – CLOB API unreachable.\nError: {e}")
+            msg = f"⚠️ Arbitrage bot disabled – CLOB API unreachable.\nError: {e}"
+            print(f"[Arbitrage] {msg}", flush=True)
+            if send_telegram(msg):
+                print("[Arbitrage] Telegram alert sent (disabled).", flush=True)
+            else:
+                print("[Arbitrage] Telegram alert failed to send.", flush=True)
             set_state("down")
         time.sleep(300)
 
@@ -72,6 +81,5 @@ try:
 except Exception as e:
     print(f"[Arbitrage] Bot crashed: {e}", flush=True)
     traceback.print_exc()
-    # Reset state to "down" so the next restart will re‑notify if needed
     set_state("down")
     sys.exit(1)