o pjr% @sVddlmZddlZddlZddlZddlZddlmZmZm Z m Z ddl Z ddl m Z ddlmZddlmZmZddlmZmZdd lmZdd lmZdd lmZmZdd lmZe ej e!d ej"ej#dde$dZ%dWddZ&e 'e j(dddddXddZ)e)*de j(ddd d!e j(d"e +gd#d$d%e j(d&d'd(e j(d)d*dd+d,e j(d-de ,dd.d/e j(d0d1e ,dd2d/dYd;d<Z-e)*d=dZd>d?Z.e)*dZd@dAZ/d[dCdDZ0e)*dZdEdFZ1e)*dGe j(dHddIdd\dKdLZ2e)*dMe j(dNdddOdPd]dRdSZ3dZdTdUZ4e4e5dVkr)e)dSdS)^) annotationsN)DictAnyListTuple) load_dotenv) urlencode) AroFloClient AroFloError)AroFloConfigErrorAroFloSettings)build_capabilities_manifest)build_registry)UsersContractError query_users)SecretsManagerz.envz"%(levelname)s:%(name)s:%(message)s)levelformat aroflo_clireturnr cCstS)zN Helper central para crear el cliente AroFlo para comandos generales. )r rr apps/aroflo_connector_app/cli.py make_client srz--debugTzActiva logs en modo DEBUG.)is_flaghelpdebugboolNonecCs&|rttjtddSdS)z!CLI para la AroFlo Connector App.zModo DEBUG activado.N)logging getLoggersetLevelDEBUGlogr)rrrrcli'sr$zcontract-usersz --tenant-idzTrusted platform tenant ID.)requiredrz --operation)listsearchgetr')typedefaultz --record-id)r*z--filter filter_specsz&Canonical field:operator:value filter.)multiplerz--pagei')r*r)z --page-sized tenant_idstr operation record_idtuple[str, ...]pageint page_sizec sg}|D]0}|dd}t|dkrtd|ddvr'dk||d|dd qtd } fd d | D} zttt | d |||||ddd} Wnt t t fyr} ztt| | d} ~ wwttj| ddddS)zCRun the normalized users contract through tenant vault credentials.:z,Each --filter must use field:operator:value.>truefalser;rr )fieldoperatorvalue)aroflo_base_urlaroflo_u_encodedaroflo_p_encodedaroflo_api_secretaroflo_org_encodedaroflo_host_ipcs*i|]}jd|ddur|qS)aroflo_connector_app)r0app_id secret_nameN) get_secret).0namemanagerr0r?rr Fs z"contract_users..)settings)r5r7auto)r2r3filters pagination transportNFindent ensure_ascii)splitlenclickClickExceptionlowerappendrrr r from_credentialsr r rr1echojsondumps) r0r2r3r,r5r7rQspecpartsnames credentialsresultexcrrLrcontract_users0s,        rgzonesc Csnzt}Wnty!}ztdtt|tdd}~wwt|}ttjt | ddddS)u,Lista las zonas registradas (debug rápido).❌ Error de configuración:r Nr9FrT) rr rYr^r1 SystemExitrr_r`r&keys)clientrfregrrr zones_cmdUs  "rnc Cszt}Wnty"}ztdtt|tdd}~wwtd|j|jddd|j ddd|j ddd|j ddd|j |j |jd}ttj|dd d dS) uBVerifica que las variables de entorno necesarias estén presentes.u❌ Configuración incompleta:r Nu'✅ Configuración OK. Valores leídos:z...)base_url u_encoded p_encoded api_secret org_encodedaccepthost_iptimeoutr9FrT)r from_envr rYr^r1rjrprqrrrsrtrurvrwr_r`)rOrfmaskedrrrenvcheckfs&    rzTuple[Dict[str, Any], str]cCs gd}t|}t|}||fS)zH Replica el urlVarString del script de Postman para zone=users. ))zoneusers)wherezand|createdutc|>|2001-01-01)r51)rdict) params_list var_stringparamsrrrbuild_users_querysrc Cszt}Wnty!}ztdtt|tdd}~wwt\}}z |jdd||d}WntyN}ztdtt|tdd}~wwtdtt j |d d d dS) z? Ping simple a AroFlo usando base_url + ?zone=users... rir Nr+GETmethodrru!❌ Error al conectar con AroFlo:u2✅ Conexión OK a zone=users. Respuesta resumida:r9FrT) rr rYr^r1rjrrequestr r_r`)rlrfrrdatarrrpings0      rz users-rawz --include-rawz&Imprime la respuesta completa en JSON. include_rawc Cszt}Wnty!}ztdtt|tdd}~wwt\}}z |jdd||d}WntyN}ztdtt|tdd}~ww|r^tt j |dd d dS| d i}| d pt| d pt| dptg}tdt ||D]<}| dp| dp| d} | dp| dp| dp| ddd| dd } td| d| qdS)uW Lista usuarios desde AroFlo usando zone=users en base_url (versión antigua). rir Nr+rru❌ Error al obtener usuarios:r9FrT zoneresponser}itemsrecordszUsuarios recibidos: useridUserIDidrKUserNameusername givennames surnamez- z: )rr rYr^r1rjrrr r_r`r(rXstrip) rrlrfrrrr|ruuidrKrrr users_rawsN      "  rz caps-dumpz--pretty/--no-prettyu>Imprime el JSON con indentación legible o en una sola línea.)r* show_defaultrprettyc Cszt}Wnty!}ztdtt|tdd}~wwt|}|r5ttj|ddddSttj|ddddS) zH Muestra el manifest de capacidades de la AroFlo Connector App. rir Nr9FrT),r8) separatorsrV) rr rYr^r1rjrr_r`)rrlrfmanifestrrr caps_dumps  rc Cszt}Wnty}z td|WYd}~dSd}~wwt|}|D]?\}}td|d}zt|}Wnt yItd|Yq'wt |dd}t |r`|t |td|q'td|q'dS) u Registra dinámicamente las CLIs de todas las zonas registradas. Estándar: - cada zona puede tener zones//cli.py con register_cli(root, zone) - el CLI general no debe duplicar lógica por zona z:No se pudo construir AroFloClient para registrar zonas: %sNz.zones.z.cliz%Zona '%s' no tiene cli.py (saltando). register_clizRegistrada CLI para zona '%s'.z8Zona '%s' tiene cli.py pero sin register_cli (saltando).) rr r#rrr __package__ importlib import_moduleModuleNotFoundErrorgetattrcallabler$)rlrfregistrycoder| module_pathmod register_fnrrrregister_zone_cliss,      r__main__)rr )rrrr)r0r1r2r1r3r1r,r4r5r6r7r6rr)rr)rr{)rrrr)rrrr)6 __future__rrr_rostypingrrrrrYdotenvr urllib.parserrlr r configr r services.capabilitiesrzones.registryrservices.users_v1rr'bridge_platform.secrets.secrets_managerrpathjoingetcwd basicConfigINFOr r#rgroupoptionr$commandChoiceIntRangergrnrzrrrrr__name__rrrrsp             , "