antigravity global bot changes

app/main.py

@@ -48,38 +48,95 @@ class LoanManager:
 
 loan_mgr = LoanManager()
 
+# --- CONFIGURACIÓN DE VARIABLES GLOBALES ---
+TG_TOKEN = os.getenv("TELEGRAM_TOKEN")
+TG_CHAT_ID = os.getenv("TELEGRAM_CHAT_ID")
+GOOGLE_PROXY_URL = "https://script.google.com/macros/s/AKfycbz7z1Jb0vsur42GmmqrL3PVXeRkN2WxSojFDIleEDoLOg6MnrmJjb_uuPcQ15CTwyzD/exec"
+
+# --- CONFIGURACIÓN DE PROXY PARA TODO EL BOT ---
+if TG_TOKEN and GOOGLE_PROXY_URL:
+    base_url = GOOGLE_PROXY_URL.split('?')[0]
+    telebot.apihelper.API_URL = base_url + "?path={1}&token={0}"
+    telebot.apihelper.CONNECT_TIMEOUT = 60
+    telebot.apihelper.READ_TIMEOUT = 60
+
+# Inicializar bot (GLOBAL)
+bot = telebot.TeleBot(TG_TOKEN) if TG_TOKEN else None
+
+# --- AYUDANTE PARA ESCAPAR MARKDOWN (GLOBAL) ---
+def escape_md(text):
+    if not text: return ""
+    for char in ['_', '*', '[', '`']:
+        text = text.replace(char, f"\\{char}")
+    return text
+
+# --- BOT HANDLERS (GLOBALS) ---
+if bot:
+    @bot.callback_query_handler(func=lambda call: True)
+    def handle_query(call):
+        try:
+            if call.data.startswith("accept_"):
+                loan_id = call.data.replace("accept_", "")
+                if loan_mgr.update_status(loan_id, "ACCEPTED"):
+                    bot.answer_callback_query(call.id, "Préstamo Aceptado")
+                    nuevo_texto = f"✅ *ACEPTADO*\n{escape_md(call.message.text)}"
+                    bot.edit_message_text(nuevo_texto, TG_CHAT_ID, call.message.message_id, parse_mode="Markdown")
+                    # Notificar a todas las sesiones activas vía PubSub
+                    bot_broadcast({"text": f"Préstamo {loan_id[:8]} ACEPTADO", "color": ft.Colors.GREEN})
+            elif call.data.startswith("decline_"):
+                loan_id = call.data.replace("decline_", "")
+                if loan_mgr.update_status(loan_id, "DECLINED"):
+                    bot.answer_callback_query(call.id, "Préstamo Declinado")
+                    nuevo_texto = f"❌ *DECLINADO*\n{escape_md(call.message.text)}"
+                    bot.edit_message_text(nuevo_texto, TG_CHAT_ID, call.message.message_id, parse_mode="Markdown")
+                    bot_broadcast({"text": f"Préstamo {loan_id[:8]} DECLINADO", "color": "red"})
+        except Exception as e:
+            print(f"Callback Error: {e}")
+
+    @bot.message_handler(commands=['aceptar', 'declinar', 'status'])
+    def handle_text_commands(message):
+        try:
+            text = message.text.split()
+            if len(text) < 2:
+                bot.reply_to(message, "Uso: /aceptar <id> o /declinar <id>")
+                return
+            cmd = text[0][1:]; loan_id = text[1]
+            status = "ACCEPTED" if cmd == "aceptar" else "DECLINED"
+            if loan_mgr.update_status(loan_id, status):
+                emoji = "✅" if status == "ACCEPTED" else "❌"
+                bot.reply_to(message, f"{emoji} Préstamo {loan_id} actualizado a {status}")
+                bot_broadcast({"text": f"Préstamo {loan_id[:8]} {status}", "color": "green" if status == "ACCEPTED" else "red"})
+            else:
+                bot.reply_to(message, "ID de préstamo no encontrado.")
+        except Exception as e:
+            print(f"Command Error: {e}")
+
+# --- BROADCAST PARA NOTIFICACIONES (GLOBAL) ---
+registered_pages = []
+def bot_broadcast(msg):
+    for p in registered_pages:
+        try:
+            p.pubsub.send_all(msg)
+        except: pass
+
+def start_bot_thread():
+    if bot:
+        try: bot.delete_webhook()
+        except: pass
+        while True:
+            try:
+                bot.infinity_polling(timeout=20, long_polling_timeout=10)
+            except Exception as e:
+                print(f"Error DNS/Red: {e}. Reintento en 60s...")
+                time.sleep(60)
+
+if bot:
+    threading.Thread(target=start_bot_thread, daemon=True).start()
+
 def main(page: ft.Page):
     page.title = "MAKERSPACE DATABASE"
     page.theme_mode = ft.ThemeMode.DARK
     page.padding = 10
-    
-    # --- CONFIGURACIÓN DE VARIABLES ---
-    TG_TOKEN = os.getenv("TELEGRAM_TOKEN")
-    TG_CHAT_ID = os.getenv("TELEGRAM_CHAT_ID")
-    GOOGLE_PROXY_URL = "https://script.google.com/macros/s/AKfycbz7z1Jb0vsur42GmmqrL3PVXeRkN2WxSojFDIleEDoLOg6MnrmJjb_uuPcQ15CTwyzD/exec"
-    GITLAB_URL = "https://gitlab.com"
-    GIT_TOKEN = os.getenv("GITLAB_TOKEN")
-    GIT_GROUP = os.getenv("GITLAB_GROUP_ID")
-
-    # --- CONFIGURACIÓN DE PROXY PARA TODO EL BOT ---
-    if TG_TOKEN and GOOGLE_PROXY_URL:
-        # Asegurarnos de que el formato sea correcto
-        base_url = GOOGLE_PROXY_URL.split('?')[0] # Limpiar parámetros previos
-        telebot.apihelper.API_URL = base_url + "?path={1}&token={0}"
-        # Google es lento; subimos el timeout del socket interno
-        telebot.apihelper.CONNECT_TIMEOUT = 60
-        telebot.apihelper.READ_TIMEOUT = 60
-        
-    # Inicializar bot
-    bot = telebot.TeleBot(TG_TOKEN) if TG_TOKEN else None
-
-    # --- AYUDANTE PARA ESCAPAR MARKDOWN (V1) ---
-    def escape_md(text):
-        if not text: return ""
-        # En Markdown V1 solo necesitamos escapar estos caracteres si no son formato
-        for char in ['_', '*', '[', '`']:
-            text = text.replace(char, f"\\{char}")
-        return text
 
     def mostrar_notificacion(texto, color="blue"):
         snack = ft.SnackBar(ft.Text(texto), bgcolor=color)
@@ -108,67 +165,18 @@ def main(page: ft.Page):
                 return f"ERR_DNS: {error_msg[:40]}"
             return f"ERR_CONN: {error_msg[:100]}"
 
-    # --- BOT CALLBACK HANDLER ---
-    if bot:
-        @bot.callback_query_handler(func=lambda call: True)
-        def handle_query(call):
-            try:
-                if call.data.startswith("accept_"):
-                    loan_id = call.data.replace("accept_", "")
-                    if loan_mgr.update_status(loan_id, "ACCEPTED"):
-                        bot.answer_callback_query(call.id, "Préstamo Aceptado")
-                        # Escapar el texto anterior para evitar que caracteres especiales rompan el nuevo mensaje
-                        nuevo_texto = f"✅ *ACEPTADO*\n{escape_md(call.message.text)}"
-                        bot.edit_message_text(nuevo_texto, TG_CHAT_ID, call.message.message_id, parse_mode="Markdown")
-                        mostrar_notificacion(f"Préstamo {loan_id[:8]} ACEPTADO", ft.Colors.GREEN)
-                elif call.data.startswith("decline_"):
-                    loan_id = call.data.replace("decline_", "")
-                    if loan_mgr.update_status(loan_id, "DECLINED"):
-                        bot.answer_callback_query(call.id, "Préstamo Declinado")
-                        nuevo_texto = f"❌ *DECLINADO*\n{escape_md(call.message.text)}"
-                        bot.edit_message_text(nuevo_texto, TG_CHAT_ID, call.message.message_id, parse_mode="Markdown")
-                        mostrar_notificacion(f"Préstamo {loan_id[:8]} DECLINADO", ft.Colors.RED)
-                page.update()
-            except Exception as e:
-                print(f"Callback Error: {e}")
-
-        # --- BOT COMMAND HANDLER ---
-        @bot.message_handler(commands=['aceptar', 'declinar', 'status'])
-        def handle_text_commands(message):
-            try:
-                text = message.text.split()
-                if len(text) < 2:
-                    bot.reply_to(message, "Uso: /aceptar <id> o /declinar <id>")
-                    return
-                
-                cmd = text[0][1:] 
-                loan_id = text[1]
-                
-                status = "ACCEPTED" if cmd == "aceptar" else "DECLINED"
-                if loan_mgr.update_status(loan_id, status):
-                    emoji = "✅" if status == "ACCEPTED" else "❌"
-                    bot.reply_to(message, f"{emoji} Préstamo {loan_id} actualizado a {status}")
-                    mostrar_notificacion(f"Préstamo {loan_id[:8]} {status}", ft.Colors.GREEN if status == "ACCEPTED" else ft.Colors.RED)
-                else:
-                    bot.reply_to(message, "ID de préstamo no encontrado.")
-                page.update()
-            except Exception as e:
-                print(f"Command Error: {e}")
-
-    def start_bot():
-        if bot:
-            while True:
-                try:
-                    # Bajamos el timeout del 'getUpdates' para que Google no corte la conexión
-                    # pero mantenemos el 'interval' para darle respiro
-                    bot.infinity_polling(timeout=20, long_polling_timeout=10)
-                except Exception as e:
-                    print(f"Error de red en el bot (DNS/Bloqueo?): {e}. Reintentando en 60s...")
-                    time.sleep(60)
-
-    # Iniciar polling en hilo separado
-    if bot:
-        threading.Thread(target=start_bot, daemon=True).start()
+    # Registrar esta página para recibir notificaciones del bot
+    registered_pages.append(page)
+    def on_broadcast(msg):
+        mostrar_notificacion(msg["text"], msg["color"])
+        # Si estamos en /prestamos, forzar refresco (esto es un poco complejo sin una ref global)
+        # Por ahora solo la notificación
+    page.pubsub.subscribe(on_broadcast)
+    
+    # --- CONFIGURACIÓN DE VARIABLES LOCALES ---
+    GITLAB_URL = "https://gitlab.com"
+    GIT_TOKEN = os.getenv("GITLAB_TOKEN")
+    GIT_GROUP = os.getenv("GITLAB_GROUP_ID")
 
     def mostrar_factura(i):
         status_color = {