FZj)dZddlZddlZddlmZddlZddlmZm Z m Z m Z m Z ddl mZmZmZddlmZmZddlmZmZGd d eZe d fd Ze d dfd Zy)zs mygeotab.api_async ~~~~~~~~~~~~~~~~~~~~~~ Async/Await-able public objects and methods wrapping the MyGeotab API. N) TimeoutError)APIDEFAULT_TIMEOUT_process get_api_url get_headers)AuthenticationExceptionMyGeotabExceptionTimeoutException)camelcaseify_parametersconvert_get_parameters)json_deserializejson_serializecfeZdZdZddddeddffd ZdZdZdZdZ d Z d Z e d Z xZS) rzBA simple, asynchronous, and Pythonic wrapper for the MyGeotab API.Nz my.geotab.comc 4t |||||||||y)a Initialize the asynchronous MyGeotab API object with credentials. :param username: The username used for MyGeotab servers. Usually an email address. :param password: The password associated with the username. Optional if `session_id` is provided. :param database: The database or company name. Optional as this usually gets resolved upon authentication. :param session_id: A session ID, assigned by the server. :param server: The server ie. my23.geotab.com. Optional as this usually gets resolved upon authentication. :param timeout: The timeout to make the call, in seconds. By default, this is 300 seconds (or 5 minutes). :param proxies: The proxies dictionary to apply to the request. :param cert: The path to client certificate. A single path to .pem file or a Tuple (.cer file, .pem file) :raise Exception: Raises an Exception if a username, or one of the session_id or password is not provided. )proxiescertN)super__init__) selfusernamepassworddatabase session_idservertimeoutrr __class__s TC:\Users\Rodrigo\frota-trucks-cliente\python\Lib\site-packages\mygeotab/api_async.pyrz API.__init__s%0 8Xz67\cjnoczK| tdt|}|jr&|jjs|j d|vr3|jjr|jj |d< t |j|||j|jd{}|d|_ |S7#t$r}|jdk(s|jdk(rd|jvr|jdk(r\|jjrF|xjd z c_ |j |j|fi|d{7cYd}~St!|jj"|jj$|jj&|d}~wwxYww) aMakes an async call to the API. :param method: The method name. :param params: Additional parameters to send (for example, search=dict(id='b123') ) :return: The JSON result (decoded into a dict) from the server.abs :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server. :raise TimeoutException: Raises when the request does not respond after some time. NA method name must be specified credentials) verify_sslrrInvalidUserExceptionDbUnavailableException Initializingr) Exceptionr r#r authenticate get_param_query_server_is_verify_ssl_cert_API__reauthorize_countr namemessager call_asyncr rrr)rmethod parametersparamsresult exceptions rr2zAPI.call_async3s >=> >(4   D$4$4$?$?      &4+;+;+F+F$($4$4$>$>$@F= ! !$,,4K^K^eieoeoppF!+,(Mq! ~~!77"::~QZQbQb?b++q0T5E5E5N5N,,1,%%'!0!F:!FFFF1((1143C3C3L3LdN^N^NeNe$%  s\BF;1C6C7CF;C F8B F3E F3"F8#F;(A F33F88F;c K|Dcgc]%}t|dt|dkDr|dni'}}|jd|d{Scc}w7 w)aPerforms an async multi-call to the API :param calls: A list of call 2-tuples with method name and params (for example, ('Get', dict(typeName='Trip')) ) :return: The JSON result (decoded into a dict) from the server :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server :raise TimeoutException: Raises when the request does not respond after some time. rr)r3r5ExecuteMultiCall)callsN)dictlenr2)rr:callformatted_callss rmulti_call_asynczAPI.multi_call_asyncWs]fkkej]a4tAw#d)a-tAwUWXejk__%7_OOOlOsA*AA A AcXK|jdd|it|d{S7w)aGets entities asynchronously using the API. Shortcut for using async_call() with the 'Get' method. :param type_name: The type of entity. :param parameters: Additional parameters to send. :return: The JSON result (decoded into a dict) from the server. :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server. :raise TimeoutException: Raises when the request does not respond after some time. type_nameN)Get)r2r)rrAr4s r get_asyncz API.get_asyncbs.%T__fifCYZdCeffffs !*(*cFK|jd||d{S7w)a Adds an entity asynchronously using the API. Shortcut for using async_call() with the 'Add' method. :param type_name: The type of entity. :param entity: The entity to add. :return: The id of the object added. :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server. :raise TimeoutException: Raises when the request does not respond after some time. AddrAentityNr2rrArGs r add_asyncz API.add_asyncms#__Ui_OOOO !!cFK|jd||d{S7w)aSets an entity asynchronously using the API. Shortcut for using async_call() with the 'Set' method. :param type_name: The type of entity :param entity: The entity to set :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server SetrFNrHrIs r set_asyncz API.set_asyncys#__Ui_OOOOrKcFK|jd||d{S7w)aRemoves an entity asynchronously using the API. Shortcut for using async_call() with the 'Remove' method. :param type_name: The type of entity. :param entity: The entity to remove. :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server. :raise TimeoutException: Raises when the request does not respond after some time. RemoverFNrHrIs r remove_asynczAPI.remove_asyncs#__X6_RRRRrKct|j|j|j|j|j S)zReturns a new async API object from an existing Credentials object. :param credentials: The existing saved credentials. :return: A new API object populated with MyGeotab credentials. )rrrrr)rrrrrr)r#s rfrom_credentialszAPI.from_credentialss> )) )) ))"--%%   r )__name__ __module__ __qualname____doc__rrr2r?rCrJrNrQ staticmethodrS __classcell__)rs@rrrs[L  p4"H P g PPS    r rTcK| td| tdt|}t|||||d{S7w)aMakes an asynchronous call to an un-authenticated method on a server. :param method: The method name. :param server: The MyGeotab server. :param timeout: The timeout to make the call, in seconds. By default, this is 300 seconds (or 5 minutes). :param verify_ssl: If True, verify the SSL certificate. It's recommended not to modify this. :param parameters: Additional parameters to send (for example, search=dict(id='b123') ). :return: The JSON result (decoded into a dict) from the server. :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server. :raise TimeoutException: Raises when the request does not respond after some time. Nr"z/A server (eg. my3.geotab.com) must be specified)rr$)r(r r+)r3rrr$r4s rserver_call_asyncr[sN~9:: ~IJJ(4J GPZ[ [[ [s9AAAcKt|}td||}t}d} |s|rftjtj } | j ttdr#| xjtjzc_|rIt|tr| j|n't|tr|\} } | j| | tj| } tj | 4d{} | j#|t%|||d d{}|j'|j(j+d }|j-d{}dddd{rd |j5vrSt7t9S777B74#1d{7swYDxYw#t.t0j.f$r}t3||d}~wwxYww) a'Formats and performs the asynchronous query against the API :param server: The server to query. :param method: The method name. :param parameters: A dict of parameters to send :param timeout: The timeout to make the call, in seconds. By default, this is 300 seconds (or 5 minutes). :param verify_ssl: Whether or not to verify SSL connections :param cert: The path to client certificate. A single path to .pem file or a Tuple (.cer file, .pem file) :return: The JSON-decoded result from the server :raise MyGeotabException: Raises when an exception occurs on the MyGeotab server :raise TimeoutException: Raises when the request does not respond after some time. :raise aiohttp.ClientResponseError: Raises when there is an HTTP status code that indicates failure. )idr3r5FOP_ENABLE_MIDDLEBOX_COMPAT)ssl) connectorNT)dataheadersrallow_redirectsz Content-Typezapplication/json)rr;r r` SSLContextPROTOCOL_TLS_CLIENTload_default_certshasattroptionsr_ isinstancestrload_cert_chaintupleaiohttp TCPConnector ClientSessionpostrraise_for_statusrcgettextrasyncior lowerrr)rr3r4rr$r api_endpointr5rc ssl_contextcerkeyconnsessionresponse content_typebodyexcs rr+r+sv&L Rz :FmGKTnnS%<%<= &&( 34 5   3#A#A A  dC  ' ' - e $HC  ' 'S 1   K 0D 0((488G$\\>aT[mq*H  % % '#++//?L!(D 98*,2D2D2FF $T* ++9 ) 9888 '.. /0v&C/0sC1H4GF7G#F?5F96AF?8F;9F?= GF= G *H7G9F?;F?=G?GG G GG>- G99G>>H)rWrur`concurrent.futuresrrnapirSyncAPIrrrr exceptionsr r r r4r r serializersrrr[r+r rrsY +TTTTG9C 'C L5DPT\(6EQU\`,,r