חjRddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZmZmZddlmZmZddlmZddlmZmZmZmZmZmZddlZddlZddlmZddlm Z ddl!Z"ddl!m#Z#dd l$m%Z%m&Z&m'Z'erd d l(m(Z(d d l)m)Z)d d l*m*Z*d dl+m+Z+edZ,eddZ-dZ.GddZ/GddZ0GddZ1GddZ2Gddee,Z3y)) annotationsN)deque)Callable ItemsViewIterator)datetimetimezone)IOBase) TYPE_CHECKINGAnyBinaryIODequeGenericTypeVar)Retry)Optas_rest_api_attributes is_undefined)AppAuthentication)Auth) GithubObject)InstallationAuthorizationTT_ghr)boundc6eZdZddZddZd dZd d dZd dZy) RequestsResponsecV|j|_|j|_||_yN) status_codestatusheadersresponse)selfrs UC:\Users\pivot\Documents\cueki\casual-preloader\Lib\site-packages\github/Requester.py__init__zRequestsResponse.__init__smm yy  c6|jjSr!)r$itemsr&s r( getheaderszRequestsResponse.getheaderss||!!##r*c6|jjxsdS)N)r%textr-s r(readzRequestsResponse.reads}}!!'R'r*c:|jj|S)N chunk_size)r% iter_content)r&r5s r(r6zRequestsResponse.iter_contents}}))Z)@@r*c8|jjyr!)r%raise_for_statusr-s r(r8z!RequestsResponse.raise_for_statuss &&(r*N)r'zrequests.Response)returnzItemsView[str, str]r9str)r)r5 int | Noner9rr9None)__name__ __module__ __qualname__r)r.r2r6r8r*r(rrs $(A)r*rc|eZdZUded< d d dZ d d dZd dZd dZy)HTTPSRequestsConnectionClassz int | RetryretryNc \|r|nd|_||_d|_||_|j dd|_t j|_tj|j_ | t jj|_n||_| t jj|_n||_t jj#|j|j |j |_|jj'd|j$y)NihttpsverifyT max_retriespool_connections pool_maxsizezhttps://porthostprotocoltimeoutgetrHrequestsSessionsession RequesternoopAuthauthadaptersDEFAULT_RETRIESrEDEFAULT_POOLSIZE pool_size HTTPAdapteradaptermountr&rOrNstrictrQrEr\kwargss r(r)z%HTTPSRequestsConnectionClass.__init__s!Dc    jj40 '') &..  =!**::DJDJ  %..??DN&DN((44 !^^5  :t||4r*cJ||_||_||_||_||_yr!verburlinputr$streamr&rerfrgr$rhs r(requestz$HTTPSRequestsConnectionClass.requests'    r*cHt|j|jj}|jd|j d|j |j}|||j|j|j|jd}t|SN://:F)r$datarQrHallow_redirects getattrrUrelowerrPrOrNrfr$rgrQrHrr&rerfr's r( getresponsez(HTTPSRequestsConnectionClass.getresponset||TYY__%67s499+Qtyyk$((D  LLLL;;!   ""r*c8|jjyr!rUcloser-s r(ryz"HTTPSRequestsConnectionClass.close r*NFNNN)rOr;rNr<raboolrQr<rEint | Retry | Noner\r<rbr r9r>F) rer;rfr;rgzstr | io.BufferedReader | Noner$dict[str, str]rhr|r9r>r9rr=)r?r@rA__annotations__r)rjruryrBr*r(rDrDs   "$( $$5$5$5 $5  $5 " $5$5$5 $5X   .        #r*rDcTeZdZ d ddZdd dZd dZd dZy) HTTPRequestsConnectionClassNc \|r|nd|_||_d|_||_|j dd|_t j|_tj|j_ | t jj|_n||_| t jj|_n||_t jj#|j|j |j |_|jj'd|j$y)NPhttprHTrIzhttp://rMr`s r(r)z$HTTPRequestsConnectionClass.__init__s!Db    jj40 '') &..  =!**::DJDJ  %..??DN&DN((44 !^^5  9dll3r*cJ||_||_||_||_||_yr!rdris r(rjz#HTTPRequestsConnectionClass.requests%    r*cHt|j|jj}|jd|j d|j |j}|||j|j|j|jd}t|Srlrqrts r(ruz'HTTPRequestsConnectionClass.getresponse rvr*c8|jjyr!rxr-s r(ryz!HTTPRequestsConnectionClass.closerzr*r{)rOr;rNr<rar|rQr<rEr}r\r<rbr r~) rer;rfr;rgr>r$rrhr|r9r>rr=)r?r@rAr)rjruryrBr*r(rrsl  "$( $$4$4$4 $4  $4 " $4$4$4L #r*rcjeZdZUded<ded<eZeZdZdZ ded<d ed <e d^d Z e d_d Z e d`d Ze dadZe d`dZe dbdZe dcdZdZdZdZdZded<dddZdedZdfdZd`dZded<ded<ded <d!ed"<d#ed$<d#ed%< dg dhd&Zdid'Zdjd(Ze dkd)Ze dld*Ze dmd+Z e dnd,Z!d`d-Z"e#did.Z$e#dod/Z%e#dod0Z&e#dod1Z'e#dod2Z(e#dod3Z)e#dpd4Z*dqd5Z+e#drd6Z,e#drd7Z-dsd8Z.e#dtd9Z/dud:Z0 dv dwd;Z1 dx dyd<Z2 dz d{d=Z3e d|d>Z4 d}d?Z5d~d@Z6 ddAZ7ddBZ8 d ddCZ9 ddDZ: ddEZ; ddFZ< ddGZ=e ddHZ>ddIZ?ddJZ@e ddKZAe ddLZBe ddMZCe ddNZDddOZE d ddPZF d ddQZG d ddRZH dz ddSZI dz ddTZJ d ddUZK d ddVZL d ddWZMddXZNddYZOddZZP d dd[ZQe#dd\ZR dd]ZSy)rVz InstallationAuthorization | None&_Requester__installation_authorizationzAppAuthentication | None_Requester__app_authTNzlogging.Logger | None_Requester__loggerz list[Any] _frameBufferc|Sr!rB)rjs r(rWzRequester.noopAuth(sr*c.d|_||_||_y)NF)_Requester__persist_Requester__httpConnectionClass _Requester__httpsConnectionClass)clshttpConnectionClasshttpsConnectionClasss r(injectConnectionClassesz!Requester.injectConnectionClasses,s  $7!%9"r*c>d|_t|_t|_y)NT)rrrrDrrs r(resetConnectionClassesz Requester.resetConnectionClasses6s $?!%A"r*c||_yr!r)rloggers r( injectLoggerzRequester.injectLogger<s  r*cd|_yr!rrs r( resetLoggerzRequester.resetLogger@s  r*c||_yr!) DEBUG_FLAG)rflags r( setDebugFlagzRequester.setDebugFlagFs r*c||_yr!) ON_CHECK_ME)r onCheckMes r( setOnCheckMezRequester.setOnCheckMeJs #r*Fi DEBUG_FRAMEzCallable | Nonerc|jrk|dddg}|j|jdz kr|jj |n||jd<t |jdz |_yy)z Initialize a debug frame with requestHeader Frame count is updated and will be attached to respond header The structure of a frame: [requestHeader, statusCode, responseHeader, raw_data] Some of them may be None Nrr)r _frameCountDEBUG_FRAME_BUFFER_SIZErappendlen)r& requestHeader new_frames r(NEW_DEBUG_FRAMEzRequester.NEW_DEBUG_FRAMEVss ??&dD9I$">">"BB!!((3'0!!!$"4#4#459D  r*intr;c|jr9|||g|j|jdd|j||j<yy)zl Update current frame with response Current frame index will be attached to responseHeader. rN)rrrDEBUG_HEADER_KEY)r& statusCoderesponseHeaderros r(DEBUG_ON_RESPONSEzRequester.DEBUG_ON_RESPONSEfsP ??8D  d.. /! 4 594D4DN400 1 r*c|jrb|jUd}|j|jvr(|j|j}|j|}|j||yyyr!)rrr_headersr)r&objframe frame_indexs r(check_mezRequester.check_mersf ??t//;E$$ 4!ll4+@+@A ))+6   S% ( %15 88w %)%@%@D " XX %)%?%?D " .. .5_c!*!1glgn!%'($$(!(C(X\C8C9   %  i %&  ',0) dkk= 1 KK % %d + 2r*cL|jj}|d=|d=|d=|S)Nrrr)__dict__copyr&states r( __getstate__zRequester.__getstate__s4 ""$ / 0 * + 2 3 r*c|jj|tj|_d|_t |_yr!)rupdaterrrrrrrs r( __setstate__zRequester.__setstate__s5 U#!*!1 $)G!r*cF|j|r|dt| S|Sr!)endswithr)stringsuffixs r( remove_suffixzRequester.remove_suffixs( ??6 ".S[L) ) r*c||dvrd}|jd}|jdrtj|d}|dzS)N)r0rr0rz/v3z/graphql)rr rVr rs r(rzRequester.get_graphql_prefixsJ <49,D{{3 == **47Dj  r*ctjj|d}tjj|S)Nr)rrrparse_qs)rfquerys r(get_parameters_of_urlzRequester.get_parameters_of_urls0 %%c*1-||$$U++r*c tjj|\}}}}}}tjj|}|jdi|j D cic]\}} |t | tr| n| gc} }|j D cgc]9\} } | D]/} | t | trt| jn| f1;} } } } tjj||||d|f}t| dk(r|S|dtjjt| Scc} }wcc} } } w)Nr0r?rB)rrrrrr,rrr|r;rsrr urlencodesorted)rf parametersrnetlocparamsrfragment url_paramskvkeyvaluesvalueparameter_lists r(add_parameters_to_urlzRequester.add_parameters_to_urls> 8>||7L7LS7Q4VUH\\**51  bjN^N^N`aN`daQZ4%8qcAN`ab *//1 1 V 5$(?#e*""$U K L1  ll%%vvsFB&QR ~ ! #JU!FLL226.3IJKL Lb s ' E!>E c$|j5|j!|jjd|_ddd|jr6|jj j|jr5yy#1swYLxYw)z5 Close the connection to the server. N)rrryrpopleftr-s r(ryzRequester.close sr # #  ,!!'')$(!$''  % % - - / 5 5 7'' $ #s .BBc t|j|j|j|j|j |j |j|j|j|j|j|j S)z Returns arguments required to recreate this Requester with Requester.__init__, as well as with MainClass.__init__ and GithubIntegration.__init__. ) rXrrQrrrHrEr\rrrr) rrrrrrrrrrrrrr-s r(rbzRequester.kwargsso __NN'']]==,,&&%)%D%D#'#@#@))  r*c|jSr!)rr-s r(rzRequester.base_url* r*c|jSr!)rr-s r( graphql_urlzRequester.graphql_url.s!!!r*c|jSr!)rr-s r(rzRequester.scheme2s }}r*c|jSr!)rr-s r(rzRequester.hostname6r&r*ch|j |jS|jd|jS)Nrn)rrr-s r(hostname_and_portzRequester.hostname_and_port:s/ ;; == --$++//r*c|jSr!)rr-s r(rXzRequester.auth@ {{r*cT|j}|j|tdi|S)z Create a new requester instance with identical configuration but the given authentication method. :param auth: authentication method :return: new Requester instance )rXrB)rbrrV)r&rXrbs r(withAuthzRequester.withAuthDs) 4  "6""r*c|jSr!rr-s r(is_lazyzRequester.is_lazyPr.r*c|j Sr!r2r-s r( is_not_lazyzRequester.is_not_lazyTs;;r*ct|s|j|k(r|S|j}|j|t di|S)a{ Create a new requester instance with identical configuration but the given lazy setting. :param lazy: if True, completable objects created from this instance are lazy, as well as completable objects created from those, and so on. :return: new Requester instance if is_defined(lazy) and lazy != self.is_lazy, this instance otherwise )rrB)rr3rbrrV)r&rrbs r(withLazyzRequester.withLazyXsA  !5K 4  "6""r*c|jSr!)rr-s r(rzRequester.api_versionhs   r*cv||jk(r|S|j}|j|tdi|S)a Create a new requester instance with identical configuration but the given API version setting. :param api_version: string, GitHub API version to use (see https://docs.github.com/en/rest/about-the-rest- api/api-versions). Note that some PyGithub methods might downgrade this version if it is not supported by the implementation. Set to None to not specify any version :return: new Requester instance if is_defined(lazy) and lazy != self.is_lazy, this instance otherwise )rrB)rrbrrV)r&rrbs r(withApiVersionzRequester.withApiVersionls< $** *K + ."6""r*c|j||g|j|j||||||j||S)z Send a request with JSON body. :param input: request body, serialized to JSON if specified :return: ``(headers: dict, JSON Response: Any)`` :raises: :class:`GithubException` for error status codes follow_302_redirect)_Requester__postProcess_Requester__check requestJson_Requester__customConnection)r&rerfrr$rgr=s r(requestJsonAndCheckzRequester.requestJsonAndCheck}sg$"t!!   T\\!!++C0(;"   r*c|j||g|j|j||||||j|S)a Send a request with multi-part-encoded body. :param input: request body, will be multi-part encoded if specified :return: ``(headers: dict, JSON Response: Any)`` :raises: :class:`GithubException` for error status codes )r>r?requestMultipartrA)r&rerfrr$rgs r(requestMultipartAndCheckz"Requester.requestMultipartAndChecksW""t!!   T\\400sJQVX\XoXopsXtu v  r*c|j||g|j|j||||||j|S)z Send a request with a file for the body. :param input: path to a file to use for the request body :return: ``(headers: dict, JSON Response: Any)`` :raises: :class:`GithubException` for error status codes )r>r? requestBlobrA)r&rerfrr$rgcnxs r(requestBlobAndCheckzRequester.requestBlobAndChecksV$"t!!   T\\4++D#z7ESWSjSjknSop q  r*c |jDcic])\}}|t|tr|j|nd+c}}Scc}}wr!)r,rr paths_of_dict)rdrvals r(rKzRequester.paths_of_dictsG_`_f_f_hi_hS[SVX[z#t/DS&&s+$N_hiiis.Ac |D]+}||vr td|d|j|||}-|jr t|}||||S)Nz GraphQL path z not found in data: ) RuntimeErrorrKis_restr)r&r$ro data_pathklassitems r( data_as_classzRequester.data_as_classsjD4"]9+=QRVRdRdeiRjQk#lmm:D ==?)$/DT7D))r*c,||d}|jd|j|\}}d|vrgt|ddk(rC|dd}|jddk(r't j d |||jd |j d ||||fS) z Queries the GraphQL API. :param query: GraphQL query :param variables: GraphQL variables :return: ``(headers: dict, JSON Response: dict)`` :raises: :class:`GithubException` for error status codes )r variablesPOSTrgerrorsrrtype NOT_FOUNDmessage)rBr(rrRgithubUnknownObjectExceptioncreateException)r&rrVinput_response_headersroerrors r( graphql_queryzRequester.graphql_querys!y9!%!9!9&$BRBRZ`!9!a$ t 4>"a'Xq)99V$ 3 77TCSUZU^U^_hUijj&&s, { } } } :param node_id: GraphQL node id :param output_schema: The schema of the retrieved properties of the node, without enclosing curly brackets :param node_type: The GraphQL node type :return: ``(headers: dict, JSON Response: dict)`` :raises: :class:`GithubException` for error status codes   zq query Q($id: ID!) { node(id: $id) { __typename ... on z {}z+ } } idronode __typenamer^z Retrieved z object is of different type: )r]) startswithrerRr_GithubException)r&node_id output_schema node_typerr$roactual_node_types r( graphql_nodezRequester.graphql_nodes,''- a0M   3}oR0  1   **54/B 88FB/33FB?CCLR[\ y ((($YK/MN^M_`  }r*cv| |j}|j|||\}}|j||ddg|S)ar Fetches a GraphQL node by id in the give schema, and returns a PyGithub instance of the given class populated with the retrieved properties. Uses :func:`graph_node` to retrieve the GraphQl node. :param node_id: GraphQL node id :param output_schema: The schema of the retrieved properties of the node, without enclosing curly brackets :param klass: PyGithub class :param node_type: Optional GraphQL node type, defaults to the name of the PyGithub class :return: PyGithub class instance :raises: :class:`GithubException` for error status codes rorm)r?rurT)r&rqrrrRrsr$ros r(graphql_node_classzRequester.graphql_node_class3sG"  I))'=)L !!'4&&1A5IIr*c|ddj|ddzdz}d|d|d|d}|j|d|i\}}||jd ij|ifS) a Send a GraphQL mutation to the GraphQL API. This sends the following GraphQL request:: mutation Mutation($input: MutationNameInput!) { mutationName(input: $input) { } } Uses :func:`graphql_query` to send the request to the GraphQL API. :param mutation_name: name of the mutation :param mutation_input: input data for the mutation :param output_schema: The schema of the retrieved properties of the mutation, without enclosing curly brackets :return: ``(headers: dict, JSON Response: dict)`` :raises: :class:`GithubException` for error status codes NrzInput!zmutation Mutation($input: z) { z(input: $input) { z } }rgro)upperrerR)r& mutation_namemutation_inputrrmutation_input_namerr$ros r(graphql_named_mutationz Requester.graphql_named_mutationJs.,BQ/557-:KKhV,-@,A}oUhivhww}~**57N2KL ,00CCCr*cX|j|||\}}|j|||g|S)au Send a GraphQL mutation to the GraphQL API, populates and returns a PyGithub class instance. Uses :func:`graphql_named_mutation` to send the mutation to the GraphQL API. :param mutation_name: name of the mutation :param mutation_input: input data for the mutation :param output_schema: The schema of the retrieved properties of the mutation, without enclosing curly brackets :param item: property in the response to extract the properties for the class to return :return: PyGithub class instance :raises: :class:`GithubException` for error status codes )r}rT)r&rzr{rrrSrRr$ros r(graphql_named_mutation_classz&Requester.graphql_named_mutation_classfs6 33M>S`a !!'4$??r*c\|j|}|dk\r|j|||||fS)Nr^)_Requester__structuredFromJsonra)r&r#responseHeadersoutputros r(__checkzRequester.__checkys; ((0 S=&&vE E$$r*cF|dk(rt|tr d|vr||d<||fS)NGETrf)rr)r&rerfrros r( __postProcesszRequester.__postProcesss/ 5=Zd3T8IDK$$r*ct|tr|k(ryd|}j|Stfd|DS)NT.c3BK|]}j|ywr!)_Requester__hostnameHasDomain).0rLrrs r( z0Requester.__hostnameHasDomain..s!SARA3**8Q7ARs)rr;r any)rrdomain_or_domains domain_suffixs`` r(__hostnameHasDomainzRequester.__hostnameHasDomainsK ' -,, 123M$$]3 3SARSSSr*ctjj|}|jJ|j|jk(rz|j |j ddg}|jjt|sJ|j|j|jk(sJ|jy|j|j|jsJ|jy)Nz/api/z /login/oauth)rrrrrrrrrotuplerNrrr)r&rfrprefixess r(__assertUrlAllowedzRequester.__assertUrlAlloweds LL ! !# &zz%%% :: ( t'<'$&{{7+ &zz$'' &??3'4??3+?~% &sA0A:9A:c|j|||||\}}}t|d5} |D]} | s| j|  dddy#1swYyxYw)zh GET a file from the server and save it to the given path, which includes the filename. r4wbN) getStreamopenwrite) r&rfrrr$rHr5_stream_chunk_iteratorfchunks r(getFilezRequester.getFilesU'+nnS*gs_in&j#1# $ .GGEN/  sA A  Ac  |i}d|d<d d}|j|d|||d|dd \}}} t| tst| dr1t| d r%| j ||| j | fSt d t| ) zo GET a stream from the server. :returns:``(status, headers, stream_chunk_iterator)`` Nzapplication/octet-streamAcceptcy)N)r0r0rB)rs r(encodez#Requester.getStream..encode%sr*rTrhr=r6r8r4z$Expected a RequestsResponse object: )rr r9tuple[str, str])_Requester__requestEncoderrhasattrr8r6 TypeErrorrZ) r&rfrr$rHr5rr#rrs r(rzRequester.getStreams ?G6 +/*>*> Z$tae+?+ ' f. / FN +@R0S  # # %?F,?,?:,?,VV V>tF|nMNNr*c dd}|j||||||||\} } } t| tr| | | fStd)z Send a request with JSON input. :param input: request body, will be serialized as JSON :returns:``(status, headers, body)`` c0dtj|fS)Nzapplication/json)rdumpsrXs r(rz%Requester.requestJson..encodeDs%tzz%'88 8r*r<z1requestJson() Expected a str, should never happen)rgr r9rrrr;r) r&rerfrr$rgrHr=rr#rrs r(r@zRequester.requestJson2s\$ 9+/*>*> sJTg+?+ ' fc "?F2 2LMMr*c dd}|j|||||||\}} } t| tr|| | fStd)z Send a request with multi-part encoding. :param input: request body, will be serialized as multipart form data :returns:``(status, headers, body)`` cd}d}d}|jD]'\}}|d||z }|d|d|z }||z }|||zz })|d|d|z }d||fS)Nz(----------------------------3c3ba8b523b2z r0z--z&Content-Disposition: form-data; name=""zmultipart/form-data; boundary=)r,)rgboundaryeol encoded_inputnamers r(rz*Requester.requestMultipart..encode_sAHCM${{} e2hZu!55 #I$qQTPU!VV $ , - r(2cU3 3M3H:> M Mr*z6requestMultipart() Expected a str, should never happen)rgdict[str, Any]r9rr r&rerfrr$rgrHrr#rrs r(rDzRequester.requestMultipartNsS" N+/*>*>sD#z[bdikq*r' fc "?F2 2QRRr*c idfd }|r+ttjj|d<|j ||||||\}} } t | tr|| | fSt d)z Send a request with a file as request body. :param input: path to a local file to use for request body :returns:``(status, headers, body)`` cdvrd}n/tj|}|d|dntj}t |d}||fS)N Content-Typerrb) mimetypes guess_typerdefaultMediaTyper) local_path mime_type guessed_typerr$s r(rz%Requester.requestBlob..encodesV(#N3 (33J? /;A/JLOPVPgPg Z&Aa< r*zContent-Lengthz1requestBlob() Expected a str, should never happen)rr;r9tuple[str, Any])r;osrgetsizerrrrs ` r(rGzRequester.requestBlobqs ?G  (+BGGOOE,B(CG$ %*.*>*>sD#z[bdikq*r' fc "?F2 2LMMr*c dfd }|s|j|}|j|||||\}} } t| tr%|j||g|j || | St d)a  Send a request with a binary file-like for the body. :param file_like: file-like object to use for the request body :return: ``(headers: dict, JSON Response: Any)`` :raises: :class:`GithubException` for error status codes cdfS)NrrB)r file_liker$s r(rz3Requester.requestMemoryBlobAndCheck..encodes>*I5 5r*z?requestMemoryBlobAndCheck() Expected a str, should never happen)rr r9r)rArrr;r>r?r) r&rerfrr$rrHrr#rrs `` r(requestMemoryBlobAndCheckz#Requester.requestMemoryBlobAndChecks& 6))#.C*.*>*>sD#z[bdmou*v' fc "%4%%dC`$,,vX^2_` `Z[[r*c |dvsJ|i}|i}|j|jj||j|d<|j|j|tj <|j |}tj||}d} |||\|d<} |j||j||||| || \} } } tj| vratj| vrOtt| tjtt| tjf|_tj | vr*tt| tj |_tj$| vr'| tj$j'd|_|j+| | t-| t.r| nd| | | fS)N)HEADrrWPATCHPUTDELETEz User-Agentrrz, rh)rauthenticationrrrheaderApiVersion_Requester__makeAbsoluteUrlrVr!r_Requester__requestRawheaderRateRemainingheaderRateLimitrfloatrheaderRateResetrheaderOAuthScopessplitrrrr;)r&rHrerfrrequestHeadersrgrrhr=rr#rrs r(__requestEncodezRequester.__requestEncodesHHHH  J  !N ;; " KK & &~ 6'+'7'7|$    (6:6G6GN622 3$$S)--c:>   *M ^,*.*;*; sNM&^q+<+ '  % % 8V=S=SWf=fE/&*D*DEFGE/&*@*@ABC"D   ! !_ 4+.u_VE[E[5\/]+^D (  # # 6 /0H0H I O OPT UD  v*VUXBY_gh..r*c (|j| |}||j}|j||||||j} |r| n| j } | j } | j D cic]\} } | j| }} } |r t|tr|j|j||||| || | dk(rU|dk(s|dk(rKtjtj|j!|||||||j#|S| dk(rd|vr|d}t$j&j)|}|j*|j,k7r&t/d|j,d|j*d |j0|j2k7r&t/d |j2d |j0d |j4|k(rW|j6d t9|j6znd }|j,d|j2||}t/d|d|d|j:j=t>j@r+|j:jCd|d |j4|j!|||j4||||j#|S| dk(r |r d|vr|d}t$j&j)|}|jE|}|jG|}|j:j=t>jHr+|j:jKd|d |j4|j0|j2k7r)|jMD cic]\} } | dk7s | | }} } |j!||||||d|j#|S| || f|j#|Scc} } wcc} } w#|j#|wxYw)Nrr)rhi-locationzGithub server redirected from z protocol to zJ, please correct your Github server URL via base_url: Github(base_url=...)z#Github server redirected from host z to rnr0rmz Requested z but server redirected to zS, you may need to correct your Github server URL via base_url: Github(base_url=...)z)Following Github server redirection from i.z/Following Github server redirection (302) from AuthorizationTr)'_Requester__deferRequest_Requester__createConnectionrjrur2r#r.rsrr ry_Requester__logtimesleeprPROCESSING_202_WAIT_TIMEr_Requester__recordRequestTimerrrrrrOrrrrr;_logger isEnabledForloggingINFOinforArDEBUGdebugr,)r&rHrerfrrgrhr= original_cnxr%rr#rrrrrrNrequested_locationrs r( __requestRawzRequester.__requestRaws D!? +L{--/ KKc5.& A(H!'XX]]_F__F8@8K8K8MN8M1qwwy!|8MONeV,KKM JJtS.%RX Y}  6::;((tS.RW`f(gV  $ $T *S}!>*:6LL))(388t}},&8}UVU]U]T^_cd::0&=doo=NdSTS]S]R^_cd66S=59[[5L3T[[!11RTD,0MM?#doo=NtfUXTY)Z&&$%7$88RS[R\]=> <<,,W\\:LL%%(QRUQVVZ[\[a[aZb&cd((tQVV^UZci(j$  $ $T *#}!49V*:6LL))(3--h7--h7<<,,W]];LL&&)XY\X]]abcbhbhai'jk::07E7K7K7M%f7Mtq!QRVeQead7MN%f((t^U6_c)  $ $T * ?F2  $ $T *oO^&g  $ $T *sEA,O>?O2BO>0FO> CO> O8+O80O>O>2 O>>Pc|jj}|jjDcgc] \}}|dk7s |}}}|r t|nd}|r t|nd}|jr||jznd}|j r||j znd} |dk(r|n t|| } t| t jtjjz d} | dkDr_|jtjt|_ |jjd| dt!j"| yycc}}w)Nrrz sleeping zs before next GitHub request)rrr,maxrrrnowr utc timestamprr getLoggerr?rrr) r&rerSrlwrites last_request last_write next_request next_writenextdefers r(__deferRequestzRequester.__deferRequest6s(''..0 $ 4 4 : : <K <1U ! <K(0s8}a $*S[ KOKjKj t'F'FFpq EIEbEbj4#@#@@hi #u}|#lJ2OD8<< 5??AA1E 19}}$ ' 1 1( ; MM  )E72N O P JJu  Ls EEctjtjj |j |<yr!)rr r r rr)r&res r(__recordRequestTimezRequester.__recordRequestTimeKs(%-\\(,,%?%I%I%KT"r*c|jdr|j|}|Stjj |}|j }|j dk7r|d|j z }|S)Nrr0r)rorrrrrr)r&rfrs r(__makeAbsoluteUrlzRequester.__makeAbsoluteUrlOsl >># ]]OC5)C   %%c*A&&Cww"}177)}$ r*c | |j}|jr1|j%||jjk(r |jS|j5|jr:|j.||jjk(r|jcdddS|j!|jj d|_|j ||j|j|j|j|j|_ddd|jS#1swY|jSxYw)N)rEr\rQrH) rrrrOrryrrrrrr)r&rs r(__createConnectionzRequester.__createConnection[s  H >>d//;DL]L]LbLb@b$$ $  # #~~$"3"3"?HPTPaPaPfPfDf(($ #  ,!!'')$(! $ 6 6 ll**}} !7!D  $   $   s=D.A;D..Ecn|jtjt|_|jSr!)rrrr?r-s r(rzRequester._loggerus( == #--h7DM}}r*cZ|jjtjr|j }|j r|j j ||jjd||j|j|||||t|tr|nd yy)Nz%s %s://%s%s %s %s ==> %i %s %srh) rrrrrrmask_authenticationrrrrr;) r&rerfrrgr#rrheadersForRequests r(__logzRequester.__log{s << $ $W]] 3 . 3 3 5 {{ //0AB LL  1 !$VS1x  4r*)rjrequests.models.PreparedRequestr9r$)rz!type[HTTPRequestsConnectionClass]rz"type[HTTPSRequestsConnectionClass]r9r>r=)rlogging.Loggerr9r>)rr|r9r>)rrr9r>)rrr9r>)rrrzdict[str, str | int]ror;r9r>)rrr9r>)NNFN)rX Auth | Nonerr;rQrrr;rrrHz bool | strrEr}r\r<rrrrrr|rr)r9r)rrr9r>)r r;r r;r9r;)rrr9r;)rfr;r9zdict[str, list])rfr;rrr9r;r:)r9r&)rXr&r9rV)r9r|)rz Opt[bool]r9rV)r9r)rrr9rV)NNNF)rer;rfr;rdict[str, Any] | Noner$dict[str, str] | Nonerg Any | Noner=r|r9tuple[dict[str, Any], Any])NNN) rer;rfr;rr'r$r'rgr(r9z,tuple[dict[str, Any], dict[str, Any] | None])NNNN)rer;rfr;rr(r$r(rgrrHAHTTPRequestsConnectionClass | HTTPSRequestsConnectionClass | Noner9%tuple[dict[str, Any], dict[str, Any]])rLrr9r) r$rrorrQ list[str]rR type[T_gh]r9r)rr;rVrr9r,) rr;rVrrQr-rRr.r9r)rqr;rrr;rsr;r9r,r!) rqr;rrr;rRr.rsrr9r)rzr;r{rrrr;r9r,) rzr;r{rrrr;rSr;rRr.r9r)r#rrrrr;r9r*) rer;rfr;rrror r9r*)rr;rzstr | list[str]r9r|)rfr;r9r>)rfr;r9r+)r#rr$rrrr9zGithubException.GithubException)r]r;r9r|)ror;r9r )NNNr)rfr;rr;rr'r$r(rHr+r5int | None | Noner9r>) rfr;rr'r$r(rHr+r5r/r9z$tuple[int, dict[str, Any], Iterator])NNNNF)rer;rfr;rr'r$r'rgr)rHr+r=r|r9tuple[int, dict[str, Any], str])rer;rfr;rr'r$r'rgr(rHr+r9r0)rer;rfr;rr(r$r(rgrrHr+r9r0)rer;rfr;rr r$rrr rHr+r9r*)FF)rHr+rer;rfr;rr(rr(rgzT | NonerzCallable[[T], tuple[str, Any]]rhr|r=r|r9(tuple[int, dict[str, Any], str | object])rHr+rer;rfr;rrrgr)rhr|r=r|r9r1)rer;r9r>)rfr;r9r;)rrr9z:HTTPRequestsConnectionClass | HTTPSRequestsConnectionClass)r9r%)rer;rfr;rrrgr)r#r<rrrzstr | object | Noner9r>)Tr?r@rArrrrDrrr staticmethodrW classmethodrrrrrrrrrrrrrrr)rrr rrr!rypropertyrbrr(rrr,rXr0r3r5r7rr:rBrErIrKrTrergrurwr}rr?r>rrrArarrrrrrr@rDrGrrrrrrrrrrBr*r(rVrVs "BB((79I&*H#*:>:A:  ::BB  $$J"$#'K': E) ]]O%% ,,**26/3"&C,C,C, C,  C,  C,C,"C,C,#/C,!-C,C, C,J,  !!,,M M"M MM. 8  (""00  ## !!#*-1)- $)      *  '    "   $  L-1)-'+    *  '  %   6 6-1)- QU   *  '    O  / 0jj *% *-; *HQ *Zd *  *&*NN%3N@INR\N N$-`\`JJ+.J7AJNXJ J.D D2@DQTD .D8@ @2@@QT@\_@hr@ @& % %( % % $ %%%!%4B%JM% #%TTT>11 1 1 ) 11:^^==     &"-1)-QU()# ##* # ' # O #&# #*-1)-QU() O O*O' O O O & O .OF-1)- QU$)NNN* N ' N  NON"N )N@-1)-'+QU!S!S!S* !S ' !S % !SO!S )!SN-1)- QU"N"N"N* "N ' "N  "NO"N )"NVRV\\\ \  \  \O\ $\N$)4/ N4/4/ 4/ * 4/ . 4/4//4/4/"4/ 24/z$)K+ NK+K+ K+ ' K+  K+K+"K+ 2K+Z*L &*!"! C!4 '     ($ r*rVc>eZdZUdZded<ddZed dZd dZy) rz5 Mixin class that allows to set a requester. rV_WithRequester__requestercd|_yr!r6r-s r(r)zWithRequester.__init__s -1r*c|jSr!r8r-s r( requesterzWithRequester.requestersr*cBt|tsJ|||_|Sr!)rrVr6)r&r:s r(rzWithRequester.withRequesters$)Y/::/$ r*Nr=)r9rV)r:rVr9zWithRequester[T]) r?r@rA__doc__rr)r4r:rrBr*r(rrs-2  r*r)4 __future__riorrrrrrr urllib.parse collectionsrcollections.abcrrrrr r typingr r r rrrrSrequests.adaptersurllib3r github.Constsrgithub.GithubExceptionr_rpgithub.GithubObjectrrrrrrrrr&ACCESS_TOKEN_REFRESH_THRESHOLD_SECONDSrrDrrVrrBr*r(rIsr#   99'HH0II4*D CLv^,*,&))(FFR==@wwt#GAJr*