i7#pddlZddlmZddlmZddlZddlmZddlm Z m Z m Z ddl m Z ddlZddlZddlmZddlmZddlmZmZdd lmZdd lmZdd lmZdd lmZeejAjBZ"ee"d z dejFdZ$ejFdZ%ejFdZ&e$se'dejPdZ)ejTe)Z+e+jYdZ-e+jYdZ.ej^ej`ddejbe2Z3ejbdjiejjejbdjiejje dddZ6e Z7ejpe&dZ9ee$d d!"Z:iZ;iZ<Gd#d$e Z=d%e>fd&Z?d'e>d(e@fd)ZAd'e>d*e@fd+ZBd%e>fd,ZCe7jd-d.e=fd/ZEe6je7e6jd0d1ZHy)2N)Path)datetime)FastAPI HTTPException APIRouter) BaseModel) load_dotenv) ChatOpenAI) AgentExecutorcreate_openai_functions_agent)ConversationBufferMemory)MultiServerMCPClient)get_padel_prompt)get_restaurante_promptz.envT)override OPENAI_KEYMCP_URL REDIS_URLu*⚠️ Falta OPENAI_KEY en el archivo .envzAmerica/Guayaquilz%Y-%m-%dz%H:%Mz'%(asctime)s [%(levelname)s] %(message)s)levelformatforcehttpxlangchain_mcp_adapterszCliente MULTIAGENTE MCPzQEndpoint para recibir mensajes de WhatsApp e interactuar con el Agente LangChain.z/multiagente-mcp)title description root_path)decode_responseszgpt-4og?)openai_api_keymodel temperaturec"eZdZUeed<eed<y) UserMessage whatsapp_idmensajeN)__name__ __module__ __qualname__str__annotations__3/opt/tws/multiagentes-mcp/cliente-mcp/client_mcp.pyr"r"Ms  Lr+r"user_idcL|tvrtddt|<t|S)u8Crea o recupera la memoria de conversación del usuario.historyT) memory_keyreturn_messages)CONVERSATION_MEMORIESr )r-s r,get_or_create_memoryr3Ts.++)A  * g& ! ))r+r#estadocKtjd|d|id{tjd|d|y7 w)u7Guarda el estado del usuario (1=pádel, 2=restaurante). whatsapp:r4)mappingNu💾 Estado de z guardado como ) redis_clienthsetloggerinfor#r4s r,set_user_stater=]sJ   i }5&?Q  RRR KK/+ofXFGSs AA!AreturncnKtjd|dd{}|r t|SdS7w)z%Obtiene el estado actual del usuario.r6r4Nr)r8hgetintr<s r,get_user_staterBbs9$$y %>I IF 3v;'a'Js 535c  Kt|d{}|dk(rd}tttd}n|dk(rd}t ttd}nyt |t dd i}|jd{}tjd |d |Dcgc]}|jc}ttt|| |dd }|jD]}|j |d fd } | |_|S77cc}ww)uGDevuelve el agente (pádel o restaurante) según el estado del usuario.Npadel[RESERVA_CREADA_EXITOSAMENTE] restaurante[RESTAURANTE_RESERVA]streamable_httpurl transportu%🔧 Herramientas detectadas en MCP (): llmtoolspromptTagentrQmemoryverbose_toolc Ktjd|jd|d||i|d{}tjd|jdtj|d|S7@wNu🛠️ Ejecutando tool: z | args: z kwargs: u ✅ Tool z ejecutada. Resultado: F) ensure_asciir:r;namejsondumpsrXargskwargsresult original_funcs r,wrapperz#get_agent_by_state..wrappersu KK3EJJA&D9D:DD(ADDDz/messagemsgc>Ktjd|jd|jt |j}t |jd{}|jj jdk(r#t|jdd{dddS|dk(rd }|jj d k(rDt|jd d{d }tjd |jd n|jj dk(rDt|jdd{d}tjd |jdn'tjd|jd|dSt|jd{}|sdddS||_ d|jd|j} tjd|d||jd|id{}tjd|d|dd|ddS777]7777#t$r<}tjd|jd|dtdd |!d}~wwxYww)"zARecibe mensajes de WhatsApp y redirige al agente correspondiente.u👤 CLIENTE [z]: NsalirrokzKHas salido del sistema. Para iniciar nuevamente, escribe cualquier mensaje.)status respuestau¡Hola! 👋 Bienvenido al sistema MultiAgente. Por favor elige una opción: 1️⃣ Reservar una cancha de pádel 2️⃣ Reservar una mesa en el restaurante1rDu 🟢 Usuario u seleccionó agente PÁDEL2rGu seleccionó agente RESTAURANTEu📋 Mostrando menú inicial a z-No hay agente asignado para tu estado actual.[z] u!➡️ Enviando input al agente (rNinputu 🤖 AGENTE [u] respondió: outputu ❌ Error procesando mensaje de z: T)exc_infoizError procesando mensaje: ) status_codedetail)r:r;r#r$r3rBstriplowerr=rqrUainvoke Exceptionerrorr)rrrUr4menu_msgagent_executor user_inputrces r,receive_messagerss KK. 1S[[MBC !#// 2F!#//2 2F {{  "g-S__a000-z{{{ :  ;;   # % !4 4 4F KK-'88RS T [[   C ' !4 4 4F KK-'88WX Y KK9#//9JK L": :.coo>>N -\]]"NS__%R }5JV 7xs:,OP%--w .CDD mF8>&:J9KLMVH-=>>Q3 1 5 5?E V 77H1#NY] ^6PQRPS4TUUVsAJI AJ(I )AJ/I 0A JIA)J:I;.J*1II)IJ J JJJI J7JJJstartupcd Ktjdtttdt ttdd}i}|j D]\}}t|tddi}|jd{}ttt|||dd }|jD]}|j |d  fd }||_|t|<|D cgc]} | j c} ||<tjd |tjdy7cc} ww)zBInicializa los agentes y sus herramientas al arrancar el servidor.u🚀 Servidor arrancando...rFrI)rErHrJrKNrOTrSrWc Ktjd|jd|d||i|d{}tjd|jdtj|d|S7@wrZr\r`s r,rezstartup_event..wrappersv 7 |9TFR[\b[cde,d=f== i |3J4::V\kpKqJrst >rfu3🔍 Herramientas cargadas para todos los agentes: u9✅ Agentes inicializados y listos para recibir mensajes.)r:r;rrgrhritemsrrrir r rPrQrjAGENT_EXECUTORSr]) agentes_configall_tools_info agente_namerRrlrQrorprernrds @r, startup_eventrs$ KK-."/?Dcd-oPghN N-335> V);Vg8h*ij  **,, /CuVT  NN D IIM+/   DI (0 $7<&=!qvv&={#/>2 KKEnEUVW KKKL1-*'>s%BD0D)AD0 D+37D0+D0)Iospathlibrrpytz redis.asyncioasyncioredisfastapirrrpydanticrloggingr^dotenvr langchain_openair langchain.agentsr r langchain.memoryr langchain_mcp_adapters.clientragents.padel_agentragents.restaurante_agentr__file__resolveparentBASE_DIRgetenvrrr ValueErrortimezoneEC_TZnowCURRENT_DATETIME_ECstrftimergrh basicConfigINFO getLoggerr%r:setLevelWARNINGapprouterfrom_urlr8rPr2rr"r(r3rAr=rBrqpostrinclude_routeron_eventrr*r+r,rsM  55 'I5>0; > ! ! # * * Hv - RYY| $ "))I  BIIk "  A BB  )*"hll5)%..z:%..w7  ,, 4    8 $'##GOO4*+44W__E  #c  u~~i$?   )*#*HcH3H (c(c(&c&VZ0V{0V0Vd6 i%M%Mr+