o Cci @srddlmZddlmZmZmZmZmZddlm Z d#d d Z d$ddZ d%ddZ d%ddZ dddd&d!d"ZdS)') annotations)AnyDictListTupleOptional urlencodeclientrmethodstr params_listList[Tuple[str, str]]returncCsHt|}|pd}|dkr|jddd||ddidS|jd|||dS) a) Ejecuta request al client AroFlo usando lista de params para permitir repetidos. GET -> AroFlo lee querystring (params=lista de tuplas). POST -> AroFlo espera application/x-www-form-urlencoded en el BODY (data=string). (En trackingcenter por ahora solo usamos GET.) GETPOSTNz Content-Typez!application/x-www-form-urlencoded)r paramsdata var_stringheaders)r rr)r upperrequest)r r r rmethod_urY/var/www/html/flask_server/apps/aroflo_connector_app/zones/trackingcentres/_join_utils.pyrs  rrespDict[str, Any]cCs||t|ddS)N)rr)rmetar)rr rrrraw_wrap s rr str | NonecCsp|dd}|dur|dd}|dus|dkrdSzt|}Wn ty+tdw|dkr4tdt|S)NpageSizepagesizerzpageSize debe ser un entero.rzpageSize debe ser > 0.)getint Exception ValueErrorr )rvivrrrcoerce_page_size*s    r)cCs|d}|dur dSt|}|sdSd|vrtd|dd\}}|}|}|s5td|dvr=td|d|S)Norder|z4order debe tener formato 'campo|asc' o 'campo|desc'.u&order: el campo no puede estar vacío.)ascdescu-order: la dirección debe ser 'asc' o 'desc'.)r#r stripr&splitlower)rr'field directionrrr coerce_order=s   r4N)joinr*zonewhere Optional[str]r5pager$r!r*cCshd|fg}|r|d|f|r|d|f|r |d|f|r)|d|f|dt|f|S)ul Builder estándar para listados con WHERE opcional + JOIN opcional + ORDER opcional + paginación. r6r7r5r*r!r9)appendr )r6r7r5r9r!r*r rrrbuild_list_paramsUs r;)r rr r r rrr)rrr rrr)rrrr )r6r r7r8r5r8r9r$r!r8r*r8rr) __future__rtypingrrrrr urllib.parser rrr)r4r;rrrrs