daiddlZddlZddlZddlmZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlZddlZddlZddlmZej*dk\rddlmZnddlmZdd lmZ dd lmZdd lmZm Z m!Z!dd l"m#Z#m$Z$ddlm%Z%ddl&m'Z'ddl(m)Z)e e efZ*e e ee+e,fZ-e)e.Z/Gdde0Z1y#e$r dd lmZYUwxYw)N) CookieJar)dumps)ListMutableMappingOptionalTupleUnionoverload) urlencode) HTTPAdapter))Literal) T_resp_json)SIGNATURE_RSA_SHA512) SIGNATURE_RSA) HTTPErrorResponseSession)OAuth1OAuth2)Self)Retry)get_default_loggerc+ eZdZdddZddddZdddZddiZdd d Zddd Zd Z d d d dddd d d d d d dd d d dgddddddd fde de e de e de de de e e fdede ej de ede ed e ed!e ed"ed#ed$e ee e fd%e e d&e e ee e fd fd'ed(ee d)e d*e f*d+Zd,efd-Zd.efd/Zde de d,d fd0Zd%e d,d fd1Zd2ed,d fd3Zd4Zd5ed,d fd6Zd5ed,d fd7Z d8e d9e fd:Z!e"d;e#d,e$fd<Z%d=Z&d>Z'd d e(jRfd?e de d@e ee d fdAe edBe d,d f dCZ* dpdDe de e de e e d fd,e fdEZ+e"dqde e dFe dGe ed,e fdHZ,drdIZ- dsd?e dFe d@e ee d fdJe ee d fdKe e.dLe edAe edMe edGe edNed!ed,e#fdOZ/e0 dtdPdPdQdFe d@e ee d fdKe e.dLe edAe edRe1ddGe edNed!e1dd,e2fdSZ3e0 dtdPdPdPdTdFe d@e ee d fdKe e.dLe edAe edRe1ddGe edNed!ed,e2fdUZ3e0 dudFe d@e ee d fdKe e.dLe edAe edRe e1ddGe edNed!e1dd,e#fdVZ3e0 dvdFe d@e ee d fdKe e.dLe edAe edRe e1ddGe edNed!e1dd,e$fdWZ3e0 dvdFe d@e ee d fdKe e.dLe edAe edRe edGe edNed!ed,e4fdXZ3 dwdFe d@e ee d fdKe e.dLe edAe edRe edGe edNed!ed,e4fdYZ3dZZ5e0dPdPdPdPdPdPdPd[dFe d@e ee fdJe ee d fdAe edMe edLe edGe edNed!e1dd,e$fd\Z6e0 dudPd]dFe d@e ee d fdJe ee d fdAe edMe edLe edGe edNed!e1dd,e$fd^Z6e0 dvdFe d@e ee d fdJe ee d fdAe edMe edLe edGe edNed!e1dd,e$fd_Z6e0 dudFe d@e ee d fdJe ee d fdAe edMe edLe edGe edNed!e1dd,e#fd`Z6e0 dvdFe d@e ee d fdJe ee d fdAe edMe edLe edGe edNed!ed,e e#ed ffdaZ6 dwdFe d@e ee d fdJe ee d fdAe edMe edLe edGe edNed!ed,e e#ed ffdbZ6e0 dxdFe d@e ee d fdAe edMe edGe edLe edNed!e1dd,e$fdcZ7e0 dudFe d@e ee d fdAe edMe edGe edLe edNed!e1dd,e$fddZ7e0 dxdFe d@e ee d fdAe edMe edGe edLe edNed!e1dd,e#fdeZ7e0 dudFe d@e ee d fdAe edMe edGe edLe edNed!ed,e e#ed ffdfZ7 dydFe d@e ee d fdAe edMe edGe edLe edNed!ed,e e#ed ffdgZ7 dydFe d@e ee d fdAe edMe edGe edLe edNed!ed,e8fdhZ9e0 dzdFe d@e ee d fdAe edLe edGe edNed!e1dd,e$fdiZ:e0 dxdFe d@e ee d fdAe edLe edGe edNed!e1dd,e$fdjZ:e0 dzdFe d@e ee d fdAe edLe edGe edNed!e1dd,e#fdkZ:e0 dxdFe d@e ee d fdAe edLe edGe edNed!ed,e8fdlZ: d{dFe d@e ee d fdAe edLe edGe edNed!ed,e8fdmZ:d;e#d,d fdnZ;e%>s%CA%F!G1!L,,!2 ?$,,.DM#DM << #$(LLDMM !  ! !d&<&<// $!%!8!8#22#22 44+/+A+A G MM  +'*J K   & &x :    & &u -    & &u -    ' ' /  !  ) )( 3  MM ! ! ( ( 1    ' ' / returnc|SNrUs rX __enter__zAtlassianRestAPI.__enter__s rZ_c$|jyr])close)rUras rX__exit__zAtlassianRestAPI.__exit__s  rZc*||f|j_yr])rLauth)rUr%r&s rXrNz&AtlassianRestAPI._create_basic_sessions&1 rZcJ|jdd|jy)N AuthorizationzBearer )_update_headerstrip)rUr3s rXrOz&AtlassianRestAPI._create_token_sessions Owu{{}o-FGrZrVcN|jjj|yr]rLheadersrS)rUrVs rXrTz'AtlassianRestAPI._create_header_sessions $$V,rZcDddlm}m}|||j_y)Nr)OPTIONALHTTPKerberosAuth)mutual_authentication)requests_kerberosrorprLrf)rUrarorps rXrRz)AtlassianRestAPI._create_kerberos_sessions@-HM rZ oauth_dictct|d|d|jdt|d|d}||j_y)N consumer_keykey_certsignature_method access_tokenaccess_token_secret)rsa_keyrwresource_owner_keyresource_owner_secret)rgetrrLrfrUrsr,s rXrPz&AtlassianRestAPI._create_oauth_sessionsJ ~ &z*'^^,> N).9",-B"C  # rZcdd|vrd|d<t|d|d|d}||j_y)a Use OAuth 2.0 Authentication :param oauth_dict: Dictionary containing access information. Must at least contain "client_id" and "token". "token" is a dictionary and must at least contain "access_token" and "token_type". :return: clientN client_idr3)rrLrfr~s rXrQz'AtlassianRestAPI._create_oauth2_sessions@ : %#'Jx z+. 80DjQXFYZ" rZkeyvaluecR|jjj||iy)zl Update header for exist session :param key: :param value: :return: Nrl)rUrrs rXrizAtlassianRestAPI._update_headers  $$c5\2rZresponsec |jS#t$rtjdYyt$r}tj |Yd}~yd}~wwxYw)Nz!Received response with no content)json ValueErrorlogdebug Exceptionerror)res rX_response_handlerz"AtlassianRestAPI._response_handlersI ==? "  II9 :  IIaL sAAAAc |jd|dz zz}|jdk7r#|tjd|jz }t t dt |j|S)a# Calculate the backoff delay for a given retry attempt. This method computes an exponential backoff delay based on the retry count and a configurable backoff factor. It optionally adds a random jitter to introduce variability in the delay, which can help prevent synchronized retries in distributed systems. The calculated backoff delay is clamped between 0 and a maximum allowable delay (`self.max_backoff_seconds`) to avoid excessively long wait times. :param retry_count: int, REQUIRED: The current retry attempt number (1-based). Determines the exponential backoff delay. :return: float: The calculated backoff delay in seconds, adjusted for jitter and clamped to the maximum allowable value. r;gr)r@rArandomuniformfloatmaxminr7)rU retry_count backoff_values rX_calculate_backoff_valuez)AtlassianRestAPI._calculate_backoff_valuese ++q[1_/EF   # % V^^At/B/BC CMSC 8 8-HIJJrZcdfd}|S)a Creates and returns a retry handler function for managing HTTP request retries. The returned handler function determines whether a request should be retried based on the response and retry settings. :return: Callable[[Response], bool]: A function that takes an HTTP response object as input and returns `True` if the request should be retried, or `False` otherwise. rcjrId|jvr;|jdk(r,tjt |jdyj r jryjkrD|jjvr,dz j}tj|yy)Nz Retry-Afterr#TFr) rJrm status_codetimesleeprEr5rIr8r6r)rrrWrUs rX_handlez0AtlassianRestAPI._retry_handler.._handle1s%%-8;K;K*KPXPdPdhkPk 3x// >?@))T-C-C111h6J6JdNeNe6e1  $ = =g F  =)rZr^)rUrrWs` @rX_retry_handlerzAtlassianRestAPI._retry_handler%s $rZmethoddatarmlevelc*|xs |j}dj|djt|j Dcgc]\}}d|d|dc}}|sdndt |d|}t j ||y cc}}w) z :param method: :param url: :param data: :param headers: :param level: :return: z5curl --silent -X {method} -H {headers} {data} '{url}'z -H ': z--data ')rrmrr$)rmsgN)default_headersformatjoinlistitemsrr) rUrr$rrmrrrmessages rXlog_curl_debugzAtlassianRestAPI.log_curl_debugEs"1T11IPPKKtGMMOG\ ]e1SEE7!!4 ]^xd }A%> Q  e) !^sBresourcecp| |j}| |j}djd|||fDS)N/c3VK|]!}|t|jd#ywNrstrrj.0ss rX z0AtlassianRestAPI.resource_url..fs#faXYXeA S)f)))r(r)r)rUrr(r)s rX resource_urlzAtlassianRestAPI.resource_url_s@  }}H  **KxxfHk83TfffrZpathtrailingcHdjd||fD}|r|dz }|S)Nrc3VK|]!}|t|jd#ywrrrs rXrz.AtlassianRestAPI.url_joiner..js!T!amCFLL-Tr)r)r$rrurl_links rX url_joinerzAtlassianRestAPI.url_joinerhs+88TT{TT  OHrZc6|jjSr])rLrcr_s rXrczAtlassianRestAPI.closeos}}""$$rZrflagsparamsfilesabsolutec @|j| rdn |j|| } d| vrdnd} |s|r | r| dz } n| dz } |r| t|xsidz } |r!| |s| rdnddj|xsgzz } d}||sdn t |}|sdn t |}|xs |j }|j } |j|| ||xs| |jj|| ||||j|j||j|j }||}|rr d |_tj!d |||j"|j$tj!d |j&|j(s| r|S|j+||S)a :param method: :param path: :param data: :param json: :param flags: :param params: :param headers: :param files: :param trailing: bool - OPTIONAL: Add trailing slash to url :param absolute: bool, OPTIONAL: Do not prefix url, url is absolute :param advanced_mode: bool, OPTIONAL: Return the raw response :return: N?TF&,)safer)rr$rmr) rr$rmrrr'verifyrr2r4zutf-8zHTTP: %s %s -> %s %szHTTP: Response text -> %s)rr$r rrrrrrLrequestr'r*r2r4encodingrrrreasontextr/raise_for_status)rUrrrrrrrmrrrr/r$params_already_in_url json_dump retry_handlerrcontinue_retriess rXrzAtlassianRestAPI.requestrs:oohdDHHdHM(+s  U$s s   9fl#6 6C  6%:Cchhu{XZF[[ [C =#4tD$(eDkI1T11++-    &Y   }},,  YY- H -X6  # (&$8L8Lhoo^ -x}}=   O h'rZ.)rrnot_json_responsecyr]r^ rUrrrrrmrrrr/s rXr}zAtlassianRestAPI.get rZ)rrr/cyr]r^rs rXr}zAtlassianRestAPI.getrrZc yr]r^rs rXr}zAtlassianRestAPI.getrrZc yr]r^rs rXr}zAtlassianRestAPI.get rZc yr]r^rs rXr}zAtlassianRestAPI.get rrZc |jd||||||||  } |js| r| S|r | jS| jsy | j S#t $r+} t j| | jcYd} ~ Sd} ~ wwxYw)a2 Get request based on the python-requests module. You can override headers, and also, get not json response :param path: :param data: :param flags: :param params: :param headers: :param not_json_response: OPTIONAL: For get content from raw request's packet :param trailing: OPTIONAL: for wrap slash symbol in the end of string :param absolute: bool, OPTIONAL: Do not prefix url, url is absolute :param advanced_mode: bool, OPTIONAL: Return the raw response :return: GET)rrrrrmrrr/N)rr/contentrrrrr) rUrrrrrmrrrr/rrs rXr}zAtlassianRestAPI.gets2<< '     O ## #== %}}& % ! }}$ %sA B  BB B c|j|i|}d|vr|d}n |j}|s|D]}|j|}|S|d}|jj|}|ddD]}|j|}|S)z :param fields: list of tuples in the form (field_name, default value (optional)). Used for chaining dictionary value accession. E.g. [("field1", "default1"), ("field2", "default2"), ("field3", )] r/rrN)r}r/r)rUfieldsargskwargsrr/field first_fields rX_get_response_contentz&AtlassianRestAPI._get_response_contentIs488T,V, f $"?3M ..M 0'8<</ 0 !)K*x}}**K8H 0'8<</ 0rZ)rrmrrrrr/cyr]r^ rUrrrrmrrrrr/s rXpostzAtlassianRestAPI.postfrrZ)r/c yr]r^rs rXrzAtlassianRestAPI.postvrrZc yr]r^rs rXrzAtlassianRestAPI.postrrZc yr]r^rs rXrzAtlassianRestAPI.postrrZc yr]r^rs rXrzAtlassianRestAPI.postrrZc z|jd|||||||||  } |js| r| S|j| S)am :param path: :param data: :param json: :param headers: :param files: :param params: :param trailing: :param absolute: :param advanced_mode: bool, OPTIONAL: Return the raw response :return: if advanced_mode is not set - returns dictionary. If it is set - returns raw response. POST) rrrrmrrrrr/rr/r) rUrrrrmrrrrr/rs rXrzAtlassianRestAPI.postsX0<< '     O%%h//rZcyr]r^ rUrrrmrrrrr/s rXputzAtlassianRestAPI.putrrZc yr]r^rs rXrzAtlassianRestAPI.put rZcyr]r^rs rXrzAtlassianRestAPI.putrrZc yr]r^rs rXrzAtlassianRestAPI.put rrZc x|jd|||||||| } |js|r| S|j| S) :param path: Path of request :param data: :param headers: adjusted headers, usually it's default :param files: :param trailing: :param params: :param absolute: :param advanced_mode: bool, OPTIONAL: Return the raw response :return: if advanced_mode is not set - returns dictionary. If it is set - returns raw response. PUTrrrmrrrrr/r rUrrrmrrrrr/rs rXrzAtlassianRestAPI.putsU,<< '     O%%h//rZc x|jd|||||||| } |js|r| S|j| S)rPATCHrrrs rXpatchzAtlassianRestAPI.patchEsU,<< '     O%%h//rZcyr]r^rUrrrmrrrr/s rXdeletezAtlassianRestAPI.deletekrrZcyr]r^rs rXrzAtlassianRestAPI.deletey rZcyr]r^rs rXrzAtlassianRestAPI.deleterrZcyr]r^rs rXrzAtlassianRestAPI.deleterrZc v|jd|||||||}|js|r|S|j|S)a Deletes resources at given paths. :param path: :param data: :param headers: :param params: :param trailing: :param absolute: :param advanced_mode: bool, OPTIONAL: Return the raw response :rtype: dict :return: Empty dictionary to have consistent interface. Some of Atlassian REST resources don't return any content. If advanced_mode is set - returns raw response. DELETE)rrrmrrrr/r) rUrrrmrrrr/rs rXrzAtlassianRestAPI.deletesR0<< '     O%%h//rZc H|jdk(r+|jjddk7r td|d|jcxkrdkr|nnx |j }|j dk(rBd j t|jDcgc] \}}|d |c}}}n |jd t}|jd t}t|tr-d |vr)|jt|jnt|tr&d |vr"|j|jd dnQt|trA|j|Dcgc]&}t|tr|jd dn|(c}d j |}t|||j#ycc}}wcc}w#t$r/}tj!||j#Yd}~yd}~wwxYw)a; Checks the response for errors and throws an exception if return code >= 400 Since different tools (Atlassian, Jira, ...) have different formats of returned json, this method is intended to be overwritten by a tool specific implementation. :param response: :return: irzapplication/json;charset=UTF-8zUnauthorized (401))riiXzhttps://api.atlassian.com r errorMessageserrorsrrN)rrmr}rrr$rrrdict isinstanceextendvaluesappendrrrr) rUrjkv error_msgerror_msg_listrrs rXrz!AtlassianRestAPI.raise_for_statuss   3 &8+;+;+?+?+OSs+s08D D (&& , , >MMO88:: $ 4 ?*S41aaS1#;*S TI%&UU?DF%CNUU8TV4F!&$/IV4K&--d6==?.CD#FD1i66I&--fjjB.GH#FD1&--kq.rfgzRSUYGZquuY/C`a/a.rs $ . 9I  H==  % % '#+T/s , ! ))++ ,s8AG)G -CG)=+G$(G) G)) H!2%HH!c|jS)z(Providing access to the restricted field)rLr_s rXr+zAtlassianRestAPI.sessions}}rZ)NNr])r[N) rrNNNNNNNFF)....).......)........)NNNNNNFF)......)NNNNNFF).....)NNNNFF)>__name__ __module__ __qualname__rexperimental_headersform_token_headersno_check_headerssafe_mode_headersexperimental_headers_generalrrrrEr boolrKrrrobjectrrrrYrr`rdrNrOrTrRrPrQri staticmethodrrrrrloggingDEBUGrrrrcrrr rbytesr} T_resp_getrrrT_resprrrpropertyr+r^rZrXrr0s*$O +$%K' ,Z8(I (%$ H #'"&"'/.2 $!%'+(,6:#26"'(7#'#'5B0 B03-B03- B0  B0  B038_B0B0(**+B0~B0B0)$B0 ~B0B0B0 .c23!B0"}#B0$CsCx$./%B0& 'B0(!I)B0*!+B0,!-B0H462c2S2T2H3H4H-T-d-N ### # #$ #3#3c3HK*H(,"&]] ***D#tO$ * $ *  * *6cggg'/}gJOPSUXZ^P^J_g g SHTNVY % '+'+ $!%"& $#'#QQQD#tO$ Q D#tO$ Q ~ QQ$Q~Q4.QQQ Qh(+ #!$"%  $'    D#tO$  ~    $  #4=  4.    t}       (+ #!$"%  $'!    D#tO$  ~    $  #4=  4.           (+ #!$"%69#&    D#tO$  ~    $  $GEN3  4.    t}       (+ #!$"%69#&(+    D#tO$  ~    $  $GEN3  4.    u~       (+ #!$"%,/#&!    D#tO$  ~    $  $D>  4.           "(, $!%"&,0#'#/%/%D#tO$/%~ /%  /% $ /%$D>/%4./%/%/% /%b: (+"% #!$#&(+    D#I  D#tO$  $  ~    4.    u~       (+'*"% #!$#&  ),    D#tO$  D#tO$  $  ~    4.    u~       (+'*"% #!$#&(+    D#tO$  D#tO$  $  ~    4.    u~       (+'*"% #!$#&    D#tO$  D#tO$  $  ~    4.    t}       (+'*"% #!$#&!    D#tO$  D#tO$  $  ~    4.       xt# $    "(,'+"& $!%#'#&0&0D#tO$&0D#tO$ &0 $ &0 ~ &0&04.&0&0&0 xt# $&0R(+"% ##&!$    D#tO$  $  ~  4.      u~       (+"% ##&!$(+    D#tO$  $  ~  4.      u~       (+"% ##&!$    D#tO$  $  ~  4.      t}       (+"% ##&!$!    D#tO$  $  ~  4.         xt# $    (,"& $#'!%##0#0D#tO$#0$ #0 ~ #0 4. #0#0#0#0 xt# $#0J(,"& $#'!%##0#0D#tO$#0$ #0 ~ #0 4. #0#0#0#0 #0L(+"%!$#&    D#tO$  $    4.    u~       (+"%!$#&(+    D#tO$  $    4.    u~       (+"%!$#&    D#tO$  $    4.    t}       (+"%!$#&!    D#tO$  $    4.           (,"&!%#'#$0$0D#tO$$0$ $0  $0 4. $0$0$0 $0L ( (d (DrZr)2r%rrhttp.cookiejarrrrtypingrrrrr r urllib.parser sysrKrFrequests.adaptersr version_infortyping_extensionsatlassian.typehintsroauthlib.oauth1.rfc5849rr ImportErroroauthlib.oauth1rrrrequests_oauthlibrrr urllib3.utilratlassian.request_utilsrr)rr'r(rrr#rr^rZrXr9s $# )v)+.M21,"6 x$ % 8[#u4 5 "~v~#.-.s$B22 C?C