⚙️ Optimizando sistema de actualización y gestión

Author: TechAtlasDev

.github/workflows/deploy.yml

@@ -0,0 +1,31 @@
+name: Deploy Bot
+on:
+  push:
+    branches: [ main ]
+
+jobs:
+  deploy:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+      
+      - name: Set up SSH
+        uses: webfactory/[email protected]
+        with:
+          ssh-private-key: ${{ secrets.SSH_PRIVATE_KEY }}
+          
+      - name: Add SSH key fingerprint
+        run: |
+          mkdir -p ~/.ssh
+          ssh-keyscan ${{ secrets.SSH_HOST }} >> ~/.ssh/known_hosts
+          
+      - name: Deploy to VPS
+        run: |
+          ssh ${{ secrets.SSH_USER }}@${{ secrets.SSH_HOST }} "
+            cd /ruta/a/tu/bot &&
+            git pull origin main &&
+            # Si usas requirements.txt:
+            pip install -r requirements.txt &&
+            # Reiniciar el bot (ajusta según tu configuración)
+            systemctl --user restart telegrambot.service
+          "

README.md

@@ -0,0 +1 @@
+# Blind

agenda.json

@@ -0,0 +1,56 @@
+import argparse
+from watchdog.observers import Observer
+from watchdog.events import FileSystemEventHandler
+import subprocess
+import time
+
+class BotHandler(FileSystemEventHandler):
+    def __init__(self, script_name):
+        self.script_name = script_name
+        self.process = None
+        self.start_bot()
+
+    def start_bot(self):
+        if self.process:
+            self.process.kill()
+        self.process = subprocess.Popen(["python3", "-m", self.script_name])
+
+    def on_modified(self, event):
+        if event.src_path.endswith(".py"):
+            print(f"Cambio detectado en {event.src_path}. Reiniciando bot...")
+            self.start_bot()
+
+    def stop_bot(self):
+        if self.process:
+            self.process.kill()
+
+def main():
+    parser = argparse.ArgumentParser()
+    parser.add_argument("--dev", action="store_true", help="Modo desarrollo (auto-reload)")
+    args = parser.parse_args()
+
+    script_name = "blind.src.main"
+    bot_handler = BotHandler(script_name)
+
+    if args.dev:
+        print("Modo desarrollo activado (con auto-reload)")
+        observer = Observer()
+        observer.schedule(bot_handler, path="./blind", recursive=True)
+        observer.start()
+
+        try:
+            while True:
+                time.sleep(1)
+        except KeyboardInterrupt:
+            print("Deteniendo el bot...")
+            bot_handler.stop_bot()
+            observer.stop()
+            observer.join()
+    else:
+        print("Modo producción activado")
+        try:
+            while True:
+                time.sleep(1)
+        except KeyboardInterrupt:
+            print("Deteniendo el bot...")
+            bot_handler.stop_bot()

blind/manager.py

@@ -1,4 +1,4 @@
-from src.utils.utilities import printTest
+from blind.src.utils.utilities import printTest
 
 from pyrogram import Client
 from pyrogram.types.messages_and_media.message import Message

src/__init__.py renamed to blind/src/__init__.py

@@ -1,4 +1,4 @@
-from src.utils.utilities import printTest
+from blind.src.utils.utilities import printTest
 import json
 from .objects import Rutina
 

src/apps/__init__.py renamed to blind/src/apps/__init__.py

@@ -1,7 +1,7 @@
 from pyrogram import Client
 from pyrogram.types import Message
 from .core import Agenda, Rutina
-from src.utils.utilities import printTest
+from blind.src.utils.utilities import printTest
 
 async def crear_rutina(nombre_horario:str, hora:str, dias_semana:list[str], zona_horaria:str, **kwargs) -> str:
     """

src/apps/basics/__init__.py renamed to blind/src/apps/basics/__init__.py

@@ -59,8 +59,8 @@ async def temporizador(time_value: float, postdata: str, time_unit: str = "hours
 
 
 async def enviar_mensaje_despues(client: Client, chat_id: int, postdata: str, delay: float, message):
-    from src.apps.llm.lib.objects import CHAT
-    from src.apps.llm.lib.handler import HandlerResponseJSON
+    from blind.src.apps.llm.lib.objects import CHAT
+    from blind.src.apps.llm.lib.handler import HandlerResponseJSON
 
     AICUVO = CHAT(message, client)
 

src/apps/basics/wellcome.py renamed to blind/src/apps/basics/wellcome.py

@@ -5,7 +5,7 @@
 import tempfile
 from pyrogram import Client
 from pyrogram.types.messages_and_media.message import Message
-from src.utils.utilities import upload_to_gemini
+from blind.src.utils.utilities import upload_to_gemini
 
 async def graficar(function_code_python_function: str, nombre_funcion:str="Función de CuVo", **kwargs):
     """

src/apps/group/new_member.py renamed to blind/src/apps/group/new_member.py

@@ -1,6 +1,6 @@
 from pyrogram import Client
 from pyrogram.types.messages_and_media.message import Message
-from src.utils.vars import GOOGLE_KEY_CX, GOOGLE_KEY_SEARCH_ENGINE_CUSTOM
+from blind.src.utils.vars import GOOGLE_KEY_CX, GOOGLE_KEY_SEARCH_ENGINE_CUSTOM
 from googleapiclient.discovery import build
 
 class objectSearch:

src/apps/llm/lib/functions/audio.py renamed to blind/src/apps/llm/lib/functions/audio.py

@@ -4,7 +4,7 @@
 from pyrogram import Client
 from pyrogram.types.messages_and_media.message import Message
 
-from src.utils.utilities import printTest
+from blind.src.utils.utilities import printTest
 
 async def visitarURL(url:str, **kwargs):
     """

src/apps/llm/lib/functions/calculadora.py renamed to blind/src/apps/llm/lib/functions/calculadora.py

@@ -1,4 +1,4 @@
-from youtube_transcript_api import YouTubeTranscriptApi
+#from youtube_transcript_api import YouTubeTranscriptApi
 from urllib.parse import urlparse, parse_qs
 
 from pyrogram import Client
@@ -31,10 +31,10 @@ async def youtube_obtener_video_transcripcion(url:str, **kwargs):
 
     # Obtiene la transcripción del video
     try:
-        transcript = YouTubeTranscriptApi.get_transcript(video_id, languages=['es', 'en'])
+#        transcript = YouTubeTranscriptApi.get_transcript(video_id, languages=['es', 'en'])
         # Convierte la transcripción en un texto simple
-        texto = "\n".join([item['text'] for item in transcript])
-        return {"results":texto}
+#        texto = "\n".join([item['text'] for item in transcript])
+        return {"results":"Funcionalidad en mantenimiento"}
     except Exception as e:
         print (f"Ocurrió un error en la transcripción -> {e}")
         return {"results": f"Error al obtener la transcripción, error: {e}"}

src/apps/llm/lib/functions/chat.py renamed to blind/src/apps/llm/lib/functions/chat.py

@@ -7,15 +7,15 @@
 
 from .path import functions
 from .functions.chat import main
-from src.utils.utilities import printTest, printError
+from blind.src.utils.utilities import printTest, printError
 
 class HandlerResponseJSON:
   def __init__(self, data:GenerateContentResponse, messsage:Message, client:Client):
     self.message = messsage
     self.client = client
     self.data = data    
 
-  async def execute(self) -> dict:
+  async def execute(self, functions:dict=functions) -> dict:
     for part in self.data.parts:
       printTest(part) # -- Debug
       if part.text:

src/apps/llm/lib/functions/cronjobs/core.py renamed to blind/src/apps/llm/lib/functions/cronjobs/core.py

@@ -1,5 +1,5 @@
-from src.utils.vars import AI_TOKEN
-from src.utils.utilities import printError
+from blind.src.utils.vars import AI_TOKEN
+from blind.src.utils.utilities import printError
 import google.generativeai as genai
 from google.generativeai.types import HarmCategory, HarmBlockThreshold
 from google.api_core.exceptions import InternalServerError
@@ -96,31 +96,33 @@ def partModel(prompt:str) -> genai.protos.Part:
   )
 
 class CHAT:
-  def __init__(self, user:Message, client:Client):
+  def __init__(self, user:Message, client:Client, PROMPT:str=AI_ACTITUDE, name_model="", tools:dict=functions):
+    self.tools = tools
     self.client = client
     self.user = user
-    self.model = self.createModel()
-    self.CHAT_OPERATIONS = CHAT_USER_ACTIONS(self.user)
+    self.model = self.createModel(PROMPT=PROMPT, tools=tools)
+    self.CHAT_OPERATIONS = CHAT_USER_ACTIONS(self.user, ai_model=name_model)
     self.CHAT_USER = self.CHAT_OPERATIONS.loadChat()
 
     self.chat = self.model.start_chat(history=self.CHAT_USER.get("history", []))
     self.TOKENS_CONSUMIDOS = self.count_tokens()
 
-  def createModel(self, data:dict={}, cache=None) -> genai.GenerativeModel:
+  def createModel(self, data:dict={}, cache=None, PROMPT:str=AI_ACTITUDE, tools=functions) -> genai.GenerativeModel:
     MODEL = data.get("model", "gemini-1.5-flash-001")
-    NAME_MODEL = data.get("name", "CuVo")
     CONFIG_TEMPERATURE = data.get("temperature", 1)
 
+    tools = [tools.values()] if type(tools) is dict else tools
+
     model = genai.GenerativeModel(
       model_name=MODEL,
-      tools=[functions.values()],
+      tools=tools,
       generation_config={
         "temperature": CONFIG_TEMPERATURE,
         "top_p": 0.95,
         "top_k": 40,
         "max_output_tokens": 8192,
       },
-      system_instruction=AI_ACTITUDE.format(NAME_MODEL)
+      system_instruction=PROMPT
     ) if not cache else genai.GenerativeModel.from_cached_content(
       cached_content=cache
     )
@@ -191,8 +193,8 @@ def count_tokens(self):
     return self.model.count_tokens(history).total_tokens
 
 class CHAT_USER_ACTIONS:
-  def __init__(self, user:Message):
-    self.fileChat = f"{str(user.chat.title)+'_' if user.chat.title else ''}{user.chat.id}.pkl"
+  def __init__(self, user:Message, ai_model:str=""):
+    self.fileChat = f"{ai_model+str(user.chat.title)+'_' if user.chat.title else ''}{user.chat.id}.pkl"
     self.user = user
     self.chatName = user.chat.title if user.chat.title else user.from_user.username or user.from_user.first_name
     self.isGroup = True if user.chat.type in ["group", "supergroup"] else False

src/apps/llm/lib/functions/cronjobs/objects.py renamed to blind/src/apps/llm/lib/functions/cronjobs/objects.py

@@ -3,16 +3,15 @@
 from pyrogram import Client, filters
 from pyrogram.types.bots_and_keyboards.callback_query import CallbackQuery
 from pyrogram.types.messages_and_media.message import Message
-#from src.apps.llm.lib.objects import AICUVO
+#from blind.src.apps.llm.lib.objects import AICUVO
 
-from src.utils.vars import ADMIN_ID
-from src.apps.llm.lib.objects import CHAT_USER_ACTIONS
+from blind.src.utils.vars import ADMIN_ID
+from blind.src.apps.llm.lib.objects import CHAT_USER_ACTIONS
 
 async def main(client:Client, CallbackQuery:CallbackQuery, postdata=0):
   if postdata == "clear":
     if CallbackQuery.from_user.id:
       CHAT_USER_ACTIONS(CallbackQuery.message).deleteChat(CallbackQuery.from_user.id)
-#      AICUVO.chat = AICUVO.model.start_chat(history=[])
       await CallbackQuery.answer("Memoria limpia con exito")
       await CallbackQuery.message.reply_text("[⚠️] LA MEMORIA DE CUVO ESTÁ LIMPIA.")
     else:

src/apps/llm/lib/functions/cronjobs/rutine.py renamed to blind/src/apps/llm/lib/functions/cronjobs/rutine.py

@@ -5,8 +5,8 @@
 from google.generativeai.types.generation_types import GenerateContentResponse
 from pyrogram import enums
 
-from src.utils.utilities import clearComand
-from src.utils.buttons import keymakers
+from blind.src.utils.utilities import clearComand
+from blind.src.utils.buttons import keymakers
 
 @Client.on_message((filters.command("cuvo") & filters.text) | (filters.private & filters.text))
 async def CUVO(client: Client, message: Message):

src/apps/llm/lib/functions/cronjobs/temporizador.py renamed to blind/src/apps/llm/lib/functions/cronjobs/temporizador.py

@@ -4,7 +4,7 @@
 from .lib.objects import CHAT
 from pyrogram import enums
 
-from src.utils.utilities import upload_to_gemini, clearComand, downloadMedia, printTest
+from blind.src.utils.utilities import upload_to_gemini, clearComand, downloadMedia, printTest
 import os
 
 @Client.on_message(filters.audio & (filters.command("cuvo") | filters.private))

src/apps/llm/lib/functions/get_info_user.py renamed to blind/src/apps/llm/lib/functions/get_info_user.py

@@ -4,7 +4,7 @@
 from .lib.objects import CHAT
 from pyrogram import enums
 
-from src.utils.utilities import upload_to_gemini, clearComand, downloadMedia, printTest
+from blind.src.utils.utilities import upload_to_gemini, clearComand, downloadMedia, printTest
 import os
 
 @Client.on_message(filters.document & (filters.command("cuvo") | filters.private))

src/apps/llm/lib/functions/graficarfuncion.py renamed to blind/src/apps/llm/lib/functions/graficarfuncion.py

@@ -5,8 +5,8 @@
 from google.generativeai.types.generation_types import GenerateContentResponse
 from pyrogram import enums
 
-from src.utils.utilities import upload_to_gemini, clearComand, downloadMedia, printTest
-from src.utils.buttons import keymakers
+from blind.src.utils.utilities import upload_to_gemini, clearComand, downloadMedia, printTest
+from blind.src.utils.buttons import keymakers
 import os
 
 @Client.on_message(filters.photo & (filters.command("cuvo") | filters.private))

src/apps/llm/lib/functions/ip.py renamed to blind/src/apps/llm/lib/functions/ip.py

@@ -1,8 +1,8 @@
 from pyrogram import Client
 from pyrogram.types.bots_and_keyboards.callback_query import CallbackQuery
 
-from src.apps.llm import llmactions
-from src.utils.utilities import printTest
+from blind.src.apps.llm import llmactions
+from blind.src.utils.utilities import printTest
 
 @Client.on_callback_query()
 async def controler(client:Client, CallbackQuery:CallbackQuery):    

src/apps/llm/lib/functions/pdf.py renamed to blind/src/apps/llm/lib/functions/pdf.py

@@ -0,0 +1,27 @@
+from pyrogram import Client
+from pyrogram.types.messages_and_media.message import Message
+
+async def ejecutar(file_name:str, **kwargs):
+  """
+  Ejecuta esta función para poder ejecutar el script de python, está diseñado para probar el output para que el asistente pueda comprender si el script está listo o necesita mejorar algo.
+
+  Args:
+    file_name (str): El nombre del archivo de desarrollo (ejemplo: script.py)
+
+  Returns:
+  El output del archivo de desarrollo.
+  """
+  message:Message = kwargs.get("message", None)
+  client:Client = kwargs.get("client", None)
+
+  await message.reply_text(f"[⚡️] <b>Conda</b> está ejecutando el script.")
+
+  try:
+    with open(file_name, "r") as f:
+      code = f.read()
+    output = exec(code)
+    return {"results": output}
+  except FileNotFoundError:
+    return {"results":"Archivo script.py no encontrado."}
+  except Exception as e:
+    return {"results":f"Error al ejecutar el código: {e}"}

src/apps/llm/lib/functions/search.py renamed to blind/src/apps/llm/lib/functions/search.py

@@ -0,0 +1,39 @@
+from pyrogram import Client
+from pyrogram.types.messages_and_media.message import Message
+import re
+
+async def ide(code: str, file_name: str, **kwargs):
+    """
+    Permite escribir en el archivo de desarrollo código en python, para poder ser ejecutado luego con la función "ejecutar".
+
+    IMPORTANTE: No se tiene que usar funciones como "input" ni cualquier otra cosa que requiera interacción con la terminal, ya que esto causará que el sistema espere respuesta del usuario, en su lugar establece variables.
+
+    Args:
+        code (str): El código a escribir en el archivo de desarrollo, ejemplo: 'import random\\n# Genera un número aleatorio entre 1 y 10\\nnumero_aleatorio = random.randint(1, 10)\\n\\nprint("Número aleatorio generado: ", numero_aleatorio)'
+
+        file_name (str): El nombre del archivo de desarrollo (ejemplo: script.py)
+    Returns:
+        True o False dependiendo del éxito al guardar el código en el archivo de desarrollo.
+    """
+    message = kwargs.get("message", None)
+    client = kwargs.get("client", None)
+
+    await message.reply_text(f"[⚡️] <b>Conda</b> está verificando el script.")
+
+    # Validar que el código no contenga funciones problemáticas
+    prohibited_patterns = [r'\binput\b', r'\bgetpass\b']  # Palabras clave prohibidas
+    for pattern in prohibited_patterns:
+        if re.search(pattern, code):
+            return {"results": "[⚠️] El script contiene funciones problemáticas como 'input'. Por favor, elimínalas y vuelve a intentarlo. (consejo: reemplaza el valor de los input por constantes)"}
+
+    try:
+        with open(file_name, "w") as f:
+            code = code.replace("\\n", "\n")
+            code = code.replace("\\", '')
+            f.write(str(code))
+        await message.reply_text(f"[✅] Script guardado correctamente en {file_name}.")
+        return {"results": True}
+    except FileNotFoundError:
+        return {"results": "Archivo no encontrado."}
+    except Exception as e:
+        return {"results": f"Error al guardar el código: {e}"}