GMAIL / app.py
TrainHeartX's picture
Update app.py
11c7767 verified
raw
history blame
3.91 kB
import gradio as gr
import comunicacion_gmail
import json
from urllib.parse import urlparse, parse_qs
def gmail_interface(accion, parametros):
"""Función que llama a gmail_tool y formatea la respuesta."""
try:
if parametros: # Si hay parámetros, verifica si contiene el auth_code
try:
parametros = json.loads(parametros) # Convierte la cadena JSON a un diccionario
except json.JSONDecodeError:
return "Error: Parámetros JSON inválidos."
auth_code = parametros.get("auth_code")
if auth_code:
# Completar el flujo OAuth con el auth_code
flow = InstalledAppFlow.from_client_secrets_file(
'credentials.json', comunicacion_gmail.SCOPES) # Accede a SCOPES desde comunicacion_gmail
flow.fetch_token(code=auth_code)
creds = flow.credentials
with open('token.pickle', 'wb') as token:
pickle.dump(creds, token)
# Vuelve a llamar a gmail_tool para ejecutar la acción original (sin el auth_code)
del parametros["auth_code"] # Eliminar auth_code antes de la siguiente llamada
resultado = comunicacion_gmail.gmail_tool(accion, parametros)
else:
resultado = comunicacion_gmail.gmail_tool(accion, parametros)
else: # Si no hay parámetros, llama a gmail_tool
resultado = comunicacion_gmail.gmail_tool(accion, parametros)
if "requires_auth" in resultado and resultado["requires_auth"]:
auth_url = resultado["auth_url"]
return gr.update(visible=True, value=f"Por favor, visita esta URL para autorizar la aplicación:\n{auth_url}\n\nLuego, copia el código de autorización y pégalo aquí como parámetro JSON: {{\"auth_code\": \"TU_CODIGO\"}}."), gr.update(visible=True) # Deja el campo para pegar el código visible
# Formatear la respuesta de gmail_tool
if accion == "leer_correos":
messages = resultado.get("messages", [])
formatted_messages = ""
for message in messages:
formatted_messages += f"ID: {message['id']}\nCuerpo: {message['body']}\n---\n" # Formateo básico. Adaptar según sea necesario.
return formatted_messages
elif accion == "enviar_correo":
message_id = resultado.get("message_id")
return f"Correo enviado con ID: {message_id}"
elif accion == "verificar_almacenamiento":
# Formatear la información de almacenamiento
storage = resultado.get("storageQuota", {}) # Manejar el caso donde no hay storageQuota
formatted_storage = f"Límite: {storage.get('limit', 'N/A')}\nUso: {storage.get('usage', 'N/A')}\nEn Drive: {storage.get('usageInDrive', 'N/A')}"
return formatted_storage
elif "error" in resultado: # Manejar errores de gmail_tool
return f"Error: {resultado['error']}"
return str(resultado) # Respuesta por defecto si no hay formato específico
except Exception as e:
return f"Error en gmail_interface: {e}"
iface = gr.Interface(
fn=gmail_interface,
inputs=[
gr.Dropdown(["leer_correos", "enviar_correo", "verificar_almacenamiento"], label="Acción", info="Selecciona la acción que quieres realizar con Gmail."),
gr.Textbox(label="Parámetros (JSON)", lines=3, info="Introduce los parámetros en formato JSON (ej. {\"maxResults\": 5})."),
],
outputs=[gr.Textbox(label="Resultado"), gr.HTML(visible=False)], # Añade gr.HTML aunque no se use en este ejemplo
title="Herramienta de Gmail",
description="Herramienta para interactuar con Gmail.",
allow_flagging="never",
)
iface.queue().launch(share=True) # Agrega .queue().launch(share=True), importante para el flujo de OAuth.