կi6dZddlZddlZddlZddlZddlZddlmZddlm Z Gdde Z Gdde Z Gd d e Z Gd d e ZGd de ZGddeZGddeZGddeZGddeZGddeZGddeZGddeZGddej.j0ZdZGd d!eZGd"d#eZy)$4A connection object to interface with REST services.N)urllib)formatsceZdZdZddZy)Errorz'A general error derived from Exception.NcLtj||||_||_yN) Exception__init__urlcode)selfmsgr r s N/var/www/html/venv/lib/python3.12/site-packages/pyactiveresource/connection.pyr zError.__init__s 4% )NNN__name__ __module__ __qualname____doc__r rrrrs 1rrceZdZdZddZy) ServerErrorz,An error caused by an ActiveResource server.Nc|7tj||j|j|jytj|yr )rr rr r )rresponses rr zServerError.__init__s2   NN4x||X]] K NN4 rr rrrrrrs 6!rrceZdZdZddZy)ConnectionErrorz&An error caused by network connection.Nc|stdd|_d}n&tj||_|j}|st |j}t j ||||jjy)N)Responserfrom_httpresponser strrr r )rrmessager s rr zConnectionError.__init__%s`$T2.DMC$66x@DM,,C$--(G tWc4==+=+=>rNNrrrrrr"s 0 ?rrceZdZdZy) RedirectionzHTTP 3xx redirection.Nrrrrrrrr&r&2srr&ceZdZdZy) ClientErrorz,An error caused by an ActiveResource client.Nr'rrrr)r)7s6rr)ceZdZdZy)ResourceConflictz2An error raised when there is a resource conflict.Nr'rrrr+r+=s<rr+ceZdZdZy)ResourceInvalidz+An error raised when a resource is invalid.Nr'rrrr-r-C5rr-ceZdZdZddZy)ResourceNotFoundz-An error raised when a resource is not found.Ncr|||jd|j}tj|||y)Nz: )rr#)rr r)r )rrr#s rr zResourceNotFound.__init__Ms3  GO"*,, =GTHgFrr$rrrrr0r0Is 7Grr0ceZdZdZy) BadRequestz0An error raised when client sends a bad request.Nr'rrrr3r3Ts:rr3ceZdZdZy)UnauthorizedAccessz/An error raised when an access is unauthorized.Nr'rrrr5r5Zs9rr5ceZdZdZy)ForbiddenAccessz+An error raised when access is not allowed.Nr'rrrr7r7`r.rr7ceZdZdZy)MethodNotAllowedz-An error raised when a method is not allowed.Nr'rrrr9r9fs7rr9c"eZdZdZdZdZdZy)Requestz1A request object which allows additional methods.cld|_tjjj|g|i|yr )_methodrrequestr;r )rargskwargss rr zRequest.__init__os+ ''>t>v>rc|js)tjjj |S|jS)zReturn the HTTP method.)r=rr>r; get_methodrs rrBzRequest.get_methodss.||>>))44T: :||rc||_y)zSet the HTTP method.N)r=)rmethods r set_methodzRequest.set_methodys  rN)rrrrr rBrFrrrr;r;ls;? rr;cFtj}|ddk\xr|ddk\S)zKDetermines if our version of urllib.request.urlopen has a timeout argument.r)sys version_info)versions r_urllib_has_timeoutrN~s*   ' q ,WQZ1_,rcBeZdZdZd dZdZdZdZd dZe dZ y) r z+Represents a response from the http server.NcR||_||_||_|i}||_||_y)a Initialize a new Response object. code, body, headers, msg are retrievable as instance attributes. Individual headers can be retrieved using dictionary syntax (i.e. response['header'] => value. Args: code: The HTTP response code returned by the server. body: The body of the response. headers: A dictionary of HTTP headers. msg: The HTTP message (e.g. 200 OK => 'OK'). response: The original httplib.HTTPResponse (if any). N)r rbodyheadersr)rr rQrRrrs rr zResponse.__init__s1  ?G   rct|trG|j|j|jf|j|j|jfk(Sy)NF) isinstancer r rQrR)rothers r__eq__zResponse.__eq__sE eX &YY 4<<8ZZU]];< =rc pd|jd|jd|jd|jd S)NzResponse(code=z, body="z ", headers=z, msg="z"))r rQrRrrCs r__repr__zResponse.__repr__s% IItyy$,,: :rc |j|Sr rR)rkeys r __getitem__zResponse.__getitem__s||C  rc:|jj||Sr )rRget)rr[values rr^z Response.gets||U++rc||j|jt|j|j|S)zCreate a Response object based on an httplib.HTTPResponse object. Args: response: An httplib.HTTPResponse object. Returns: A Response object. )r readdictrRr)clsrs rr!zResponse.from_httpresponses78==(--/(()8<<C Cr)NrNr ) rrrrr rVrXr\r^ classmethodr!rrrr r s45!, :!, C Crr ceZdZdZdddej fdZdZdZddZ dZ ddZ dd Z dd Z dd Zdd Zdd ZdZy) ConnectionrNc| td|j|\|_|_|_|xs|jxsd|_|xs|jxsd|_|js |jrRt j |jd|jjdjd|_ nd|_ ||_ tjd|_ ||_y)aRInitialize a new Connection object. Args: site: The base url for connections (e.g. 'http://foo') user: username for basic authentication. password: password for basic authentication. timeout: socket timeout. format: format object for en/decoding resource data. Nz&Connection site argument requires siter:zutf-8zpyactiveresource.connection) ValueError _parse_sitesiteuserpasswordbase64 b64encodeencodedecodeauthtimeoutlogging getLoggerlogformat)rrkrlrmrsrws rr zConnection.__init__s <EF F.2.>.>t.D+ 49dm+DII+  7DMM7R 99 ((TYY *N)V)VW^)_`gghopDIDI $$%BC rc6tjj|}|j}|jr|dt |jzz }tjj |j|ddddf}||j|jfS)zRetrieve the auth information and base url for a site. Args: site: The URL to parse. Returns: A tuple containing (site, username, password). rhr) rparseurlparsehostnameportr" urlunparseschemeusernamerm)rrkpartshostnew_sites rrjzConnection._parse_sitesy %%d+~~ :: C#ejj/) )D<<**ELL$BB+OP%..%..99rct|S)zReturn a new request object. Args: url: The url to connect to. Returns: A Request object. )r;)rr s r_requestzConnection._requestss|rc tjj|j|}|jj d|||j |}|j||r/tj|D]\}}|j|||jr|jdd|jz|jrndjtj|jD cgc]\} } dj| | fc} } } |jjd| |rT|jd|jj ||_|jjd|j"n<|d vr8|jd|jj |jd d |j$r=t's3t)j*} t)j,|j$ d } |j/|j1|} t:j=| }|jjd |j>|j|j@| r| jC|j$r t'st)j,  |jj d|j>|j@tE|jF|Scc} } w#tj2j4$r}|j/|} Yd }~d }~wtj2j6$r}t9||d }~wwxYw# r| jC|j$r!t'st)j, wwwxYw)aEPerform an HTTP request. Args: method: The HTTP method (GET, PUT, POST, DELETE). path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. data: The data to send as the body of the request. Returns: A Response object. z%s %s AuthorizationzBasic  rhzrequest-headers:%sz Content-Typezrequest-body:%s)POSTPUTzContent-Length0Nz'Response(code=%d, headers=%s, msg="%s")z --> %d %s %db)$rryurljoinrkrvinforrFsix iteritems add_headerrrrRjoindebugrw mime_typedatarsrNsocketgetdefaulttimeoutsetdefaulttimeout _handle_error_urlopenerror HTTPErrorURLErrorrr r!r rcloselenrQ)rrEpathrRrr r>r[r_kv header_string old_timeout http_responseerrrs r_openzConnection._opensll""499d3  gvs+--$6" !mmG4 U""3.5 99   4990D E ?? II'*}}W__'E'G'E=AAqsxxA'7'E'GHM HHNN/ ?    ~t{{/D/D EGL HHNN,gll ;  &   ^T[[-B-B C   -s 3 << 3 5 224K  $ $T\\ 2 6 M & $ 2 24==3I J  11-@H HHNND#==(*:*:HLL J##%||$7$9((5  ox}}hll(--( *G'G(<<)) 8 $ 2 23 7 <<(( &Co% & ##%||$7$9((5%:|sJ?L N L?ANN8M N N/ M;;NNAOctr+tjj||jStjj|S)aWrap calls to urllib so they can be overriden. Args: request: A Request object. Returns: An httplib.HTTPResponse object. Raises: urllib.error.HTTPError on server errors. urllib.error.URLError on IO errors. )rs)rNrr>urlopenrs)rr>s rrzConnection._urlopen0s=  '''F F''0 0rc*|jd||S)zPerform an HTTP get request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. Returns: A Response object. GETrZrrrrRs rr^zConnection.get@szz%wz77rcl|jj|j||jS)zPerform an HTTP get request and return the formatted response. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. Returns: The resource as a dict. )rwrqr^rQrs r get_formattedzConnection.get_formattedKs*{{!!$((4"9">">??rc*|jd||S)zPerform an HTTP delete request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. Returns: A Response object. DELETErZrrs rdeletezConnection.deleteVszz(D'z::rc,|jd|||S)a Perform an HTTP put request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. data: The data to send as the body of the request. Returns: A Response object. rrRrrrrrRrs rputzConnection.putaszz%wTzBBrc,|jd|||S)a Perform an HTTP post request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. data: The data to send as the body of the request. Returns: A Response object. rrrrs rpostzConnection.postmszz&$dzCCrc*|jd||S)zPerform an HTTP put request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. Returns: A Response object. HEADrZrrs rheadzConnection.headyszz&$z88rc|jdvr t|d|jcxkrdkr|S|jdk(r t||jdk(r t||jdk(r t ||jdk(r t ||jdk(r t ||jdk(r t||jd k(r t|d|jcxkrd kr t|d |jcxkrd krt|t|t|) aHandle an HTTP error. Args: err: A urllib.error.HTTPError object. Returns: An HTTP response object if the error is recoverable. Raises: Redirection: if HTTP error code 301,302 returned. BadRequest: if HTTP error code 400 returned. UnauthorizedAccess: if HTTP error code 401 returned. ForbiddenAccess: if HTTP error code 403 returned. ResourceNotFound: if HTTP error code 404 is returned. MethodNotAllowed: if HTTP error code 405 is returned. ResourceConflict: if HTTP error code 409 is returned. ResourceInvalid: if HTTP error code 422 is returned. ClientError: if HTTP error code falls in 401 - 499. ServerError: if HTTP error code falls in 500 - 599. ConnectionError: if unknown HTTP error code returned. )i-i.iiiiiiiiiX) r r&r3r5r7r0r9r+r-r)rr)rrs rrzConnection._handle_errors(( 88z !c" " CHH "s "J# XX_S/ ! XX_$S) ) XX_!#& & XX_"3' ' XX_"3' ' XX_"3' ' XX_!#& & CHH "s "c" "# CHH "s "c" "#"#& &/#& &rr$r )rrrrr JSONFormatr rjrrrr^rrrrrrrrrrfrfsU>"&t**6:"9v1 8 @ ; C D 9+'rrf)rrnrtrrKr six.movesrpyactiveresourcerr rrrr&r)r+r-r0r3r5r7r9r>r;rNobjectr rfrrrrs;  $I!%! ?e ?  /  /  {  k G{G     k  { fnn$$$-3Cv3Cls's'r