o Mi@sddlZddlmZmZmZmZmZmZmZddl m Z ddl Z ddl m Z ddlmZmZmZeeZGdddeZeeeefeeeeffZeeeefZGd d d Zdd d ZdS)N)AnyDictOptionalUnionListTupleSequence) urlencode)AroFloSettings)build_authorization_valuebuild_timestampbuild_hmac_signaturec@seZdZdZdS) AroFloErroru/Error genérico al hablar con la API de AroFlo.N)__name__ __module__ __qualname____doc__rr>/var/www/html/flask_server/apps/aroflo_connector_app/client.pyrsrc@seZdZdZ  ddeedeejddfddZ ddddd dddd d e d e d ee de de de dee dee dee de de fddZ d ee de de de fddZd dd e d e de fddZdS) AroFloClientu Cliente para la API de AroFlo. - Carga settings desde .env - Construye headers HMAC (igual Postman) - Hace request genérico y parsea JSON NsettingssessionreturncCs2|pt|_|p t|_|jjddidS)Nz User-Agentzaroflo-connector-app/0.0.1)r from_envrrequestsSessionrheadersupdate)selfrrrrr__init__&szAroFloClient.__init__GET)paramsdatajson var_stringorderorder_byorderbypathmethodr#r$r%r&r'r(r)kwargsc KsV|pd} |dur|p | }d| vr|dur| d}n| ddd| vr0|dur0| d}n| dd|durA||d|}|jjd} |rS| d|d7} |se|r\t|}n t|t ret|}t |j} t }t | |prd| ||jd\}}| dipi}i||}t|t rd |vrd |d <|durd |vrd |d <| d |jj }td | | ||durt|jnd|durdnd|z|jj| | f|||||d| }Wntjy}ztd||d}~wwz|}Wnty }z td|jd|j|d}~ww|d}|jdks|dvr)td|jd||S)Nr!r(r)r'/r") request_typer& authorization iso_timestamprrz Content-Typez!application/x-www-form-urlencodedzapplication/jsontimeoutz)r#r$r%rr1z%Error de red al conectar con AroFlo: z'Respuesta no JSON desde AroFlo (status=z): statusi)N0rOKz#Error en respuesta de AroFlo. HTTP=z , payload=)upperpop_inject_multi_paramrbase_urlrstriplstripr isinstancedictr r rr1logdebugtyperrrequestrRequestExceptionrr% ValueError status_codetextget)rr*r+r#r$r%r&r'r(r)r,method_uurlr/iso_ts_ hmac_headers extra_headersrr1respexc data_respr2rrrr@/s               zAroFloClient.requestkeyvaluec Cst|ttfrdd|D}n t|rt|gng}|s"|p!iS|dur6g}|D] }|||fq*|St|trMt|}|D] }|||fqA|St|dkr[|d||<|Sdd|D}|D] }|||fqf|S)uE Inserta un parámetro que puede repetirse (where/join/order) de forma segura. - Si params es None: crea lista de tuplas. - Si params es dict: si value es str -> set simple; si value es lista -> convierte a lista de tuplas. - Si params es lista de tuplas: agrega una o varias tuplas. cSs(g|]}|durt|rt|qSN)strstrip).0vrrr s(z4AroFloClient._inject_multi_param..Nr rcSsg|] \}}|t|fqSr)rR)rTkrUrrrrVs)r;listtuplerRrSappendlenitems) rr#rOrPvaluesoutrUout2out3rrrr7s,   z AroFloClient._inject_multi_param)r*cCs|j|d|dS)Nr!)r+r#)r@)rr#r*rrrrEszAroFloClient.get)NN)r!)rrrrrr rrr rR ParamsTyperMultiStrr@r7rErrrrrsj       p 1rrcCstSrQ)rrrrr get_clientsrc)rr)loggingtypingrrrrrrr urllib.parser rconfigr authr r r getLoggerrr= RuntimeErrorrrRrarbrrcrrrrs$    8