o d`6@sDdZddlZddlZddlZddlZddlZddlmZddlm Z Gddde Z Gddde Z Gd d d e Z Gd d d e ZGd dde ZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddejjZdd ZGd!d"d"eZGd#d$d$eZdS)%4A connection object to interface with REST services.N)urllib)formatsc@eZdZdZdddZdS)Errorz'A general error derived from Exception.NcCst||||_||_dSN) Exception__init__urlcode)selfmsgr r rr/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/pyactiveresource/connection.pyr s  zError.__init__)NNN__name__ __module__ __qualname____doc__r rrrrrrc@r) ServerErrorz,An error caused by an ActiveResource server.NcCs0|durt||j|j|jdSt|dSr)rr r r r )r responserrrr szServerError.__init__rrrrrrrrc@r)ConnectionErrorz&An error caused by network connection.NcCsN|s tdd|_d}n t||_|j}|st|j}t||||jjdS)N)Responserfrom_httpresponser strrr r )r rmessager rrrr %s   zConnectionError.__init__NNrrrrrr"rrc@eZdZdZdS) RedirectionzHTTP 3xx redirection.Nrrrrrrrrr!2sr!c@r ) ClientErrorz,An error caused by an ActiveResource client.Nr"rrrrr#7r#c@r )ResourceConflictz2An error raised when there is a resource conflict.Nr"rrrrr%=r$r%c@r )ResourceInvalidz+An error raised when a resource is invalid.Nr"rrrrr&Cr$r&c@r)ResourceNotFoundz-An error raised when a resource is not found.NcCs4|dur|durd|j|jf}tj|||ddS)Nz%s: %s)rr)r r r#r )r rrrrrr MszResourceNotFound.__init__rrrrrrr'Irr'c@r ) BadRequestz0An error raised when client sends a bad request.Nr"rrrrr(Tr$r(c@r )UnauthorizedAccessz/An error raised when an access is unauthorized.Nr"rrrrr)Zr$r)c@r )ForbiddenAccessz+An error raised when access is not allowed.Nr"rrrrr*`r$r*c@r )MethodNotAllowedz-An error raised when a method is not allowed.Nr"rrrrr+fr$r+c@s(eZdZdZddZddZddZdS) Requestz1A request object which allows additional methods.cOs&d|_tjjj|g|Ri|dSr)_methodrrequestr,r )r argskwargsrrrr os zRequest.__init__cCs|js tjj|S|jS)zReturn the HTTP method.)r-rr.r, get_methodr rrrr1sszRequest.get_methodcCs ||_dS)zSet the HTTP method.N)r-)r methodrrr set_methodys zRequest.set_methodN)rrrrr r1r4rrrrr,ls  r,cCstj}|ddko|ddkS)zKDetermines if our version of urllib.request.urlopen has a timeout argument.r)sys version_info)versionrrr_urllib_has_timeout~sr;c@sHeZdZdZdddZddZdd Zd d Zdd d Ze ddZ dS)rz+Represents a response from the http server.NrcCs.||_||_||_|duri}||_||_dS)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 r bodyheadersr)r r r<r=r rrrrr s zResponse.__init__cCs.t|tr|j|j|jf|j|j|jfkSdS)NF) isinstancerr r<r=)r otherrrr__eq__s zResponse.__eq__cCsd|j|j|j|jfS)Nz2Response(code=%s, body="%s", headers=%s, msg="%s"))r r<r=r r2rrr__repr__szResponse.__repr__cCs |j|Srr=)r keyrrr __getitem__s zResponse.__getitem__cCs|j||Sr)r=get)r rCvaluerrrrEsz Response.getcCs||j|t|j|j|S)zCreate a Response object based on an httplib.HTTPResponse object. Args: response: An httplib.HTTPResponse object. Returns: A Response object. )r readdictr=r )clsrrrrrs zResponse.from_httpresponse)NrNr) rrrrr r@rArDrE classmethodrrrrrrs  rc@seZdZdZdddejfddZddZddZdd d Z d d Z dd dZ dddZ dddZ dddZdddZdddZddZdS) ConnectionrNcCs|durtd||\|_|_|_|p|jpd|_|p!|jp!d|_|js)|jr sz$Connection._open..zrequest-headers:%sz Content-Typezrequest-body:%s)POSTPUTzContent-Length0Nz'Response(code=%d, headers=%s, msg="%s")z --> %d %s %db)$rr\urljoinrNrYinforfr4six iteritems add_headerrUr=ridebugrZ mime_typedatarVr;socketgetdefaulttimeoutsetdefaulttimeout _handle_error_urlopenerror HTTPErrorURLErrorrrrr r closelenr<)r r3pathr=rxr r.rCrF header_string old_timeout http_responseerrrrrr_opensj               zConnection._opencCs$tr tjj||jdStj|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. )rV)r;rr.urlopenrV)r r.rrrr}0s  zConnection._urlopencC|jd||dS)zPerform an HTTP get request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. Returns: A Response object. GETrBrr rr=rrrrE@ zConnection.getcCs|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. )rZrTrEr<rrrr get_formattedKs zConnection.get_formattedcCr)zPerform an HTTP delete request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. Returns: A Response object. DELETErBrrrrrdeleteVrzConnection.deletecC|jd|||dS)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. ror=rxrr rr=rxrrrputa zConnection.putcCr)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. rnrrrrrrpostmrzConnection.postcCr)zPerform an HTTP put request. Args: path: The HTTP path to retrieve. headers: A dictionary of HTTP headers to add. Returns: A Response object. HEADrBrrrrrheadyrzConnection.headcCs|jdvr t|d|jkrdkr|S|jdkrt||jdkr(t||jdkr1t||jdkr:t||jdkrCt||jdkrLt||jd krUt|d|jkrcd krdt |d |jkrrd krwt |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!r(r)r*r'r+r%r&r#rr)r rrrrr|s4        zConnection._handle_errorrr)rrrrr JSONFormatr rMrfrr}rErrrrrr|rrrrrKs   ;  rK)rrQrWryr8rs six.movesrpyactiveresourcerrrrrr!r#r%r&r'r(r)r*r+r.r,r;objectrrKrrrrs0     6