ÁjddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z m Z mZmZmZmZddlmZmZmZmZmZdd lmZdd lmZmZdd lmZmZd d l m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&ddl'm(Z(m)Z)ddl*m+Z+m,Z,m-Z-ddl.m/Z/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6ddgZ7GddeZ8GddeZ9GddZ:GddZ;GddZ<GddZ=y) ) annotations)ListOptional)chainN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)is_given path_templatemaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper) CertificatesAsyncCertificatesCertificatesWithRawResponse AsyncCertificatesWithRawResponse!CertificatesWithStreamingResponse&AsyncCertificatesWithStreamingResponse)SyncPageCursorAsyncPageCursor)tunnel_list_paramstunnel_create_paramstunnel_rotate_token_params)AsyncPaginatormake_request_options) BetaTunnel)AnthropicBetaParam)BetaTunnelTokenTunnels AsyncTunnelsc xeZdZeddZeddZeddZeeddded ddZ eddded ddZ eeeeddded  dd Z eddded dd Z eddded dd Z eeddded  ddZy)r+c,t|jSN)r_clientselfs O/tmp/pip-target-k_scjv0h/lib/python/anthropic/resources/beta/tunnels/tunnels.py certificateszTunnels.certificates#sDLL))ct|Sa This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers )TunnelsWithRawResponser1s r3with_raw_responsezTunnels.with_raw_response's&d++r5ct|Sz An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response )TunnelsWithStreamingResponser1s r3with_streaming_responsezTunnels.with_streaming_response1s,D11r5N display_namebetas extra_headers extra_query extra_bodytimeoutc $itdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt d|itjt||||tS) The Tunnels API is in research preview. It requires the `anthropic-beta: mcp-tunnels-2026-06-22` header and may change without a deprecation period. It supersedes the Admin API endpoints at `/v1/organizations/tunnels`, which remain available during a migration window. Creates a tunnel. Creation allocates a fresh hostname and provisions the tunnel; it is not idempotent. The new tunnel rejects MCP traffic until at least one CA certificate is added. Args: display_name: Optional human-readable name for the tunnel (1-255 characters). betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds anthropic-beta,c32K|]}t|ywr/str.0es r3 z!Tunnels.create..a5Lc!f5Lmcp-tunnels-2026-06-22/v1/tunnels?beta=truer?rArBrCrDbodyoptionscast_to) rrjoinrr_postrr$TunnelCreateParamsr'r(r2r?r@rArBrCrDs r3createzTunnels.create:sH  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] zz # .,!?AUAhAhi(+Q[el   r5r@rArBrCrDc $|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t S) The Tunnels API is in research preview. It requires the `anthropic-beta: mcp-tunnels-2026-06-22` header and may change without a deprecation period. It supersedes the Admin API endpoints at `/v1/organizations/tunnels`, which remain available during a migration window. Fetches a tunnel by ID. Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds 8Expected a non-empty value for `tunnel_id` but received rGrHc32K|]}t|ywr/rJrLs r3rOz#Tunnels.retrieve..rPrQrR!/v1/tunnels/{tunnel_id}?beta=true tunnel_idrTrWrX ValueErrorrrrYrr_getrr'r(r2rer@rArBrCrDs r3retrievezTunnels.retrievers@WXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] yy = S(+Q[el   r5include_archivedlimitpager@rArBrCrDc@itdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt tt||||t|||dtjtS) QThe Tunnels API is in research preview. It requires the `anthropic-beta: mcp-tunnels-2026-06-22` header and may change without a deprecation period. It supersedes the Admin API endpoints at `/v1/organizations/tunnels`, which remain available during a migration window. Lists tunnels. Results are ordered by creation time, newest first; archived tunnels are excluded unless include_archived is set. Args: include_archived: Whether to include archived tunnels in the results. Defaults to false. limit: Maximum number of tunnels to return per page. Defaults to 20, maximum 1000. page: Opaque pagination cursor from a previous `list_tunnels` response. betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rGrHc32K|]}t|ywr/rJrLs r3rOzTunnels.list..rPrQrRrSrmrnrorArBrCrDqueryrorWmodel) rrrYrr _get_api_listr!r(r'rr#TunnelListParams r2rmrnror@rArBrCrDs r3listz Tunnels.listsR  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] !! # +(+'%%,.rPrQrR)/v1/tunnels/{tunnel_id}/archive?beta=truerdrTrf rhrrrYrrrZrr'r(rjs r3archivezTunnels.archivesFWXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] zz EQZ [(+Q[el   r5c $|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t S) The Tunnels API is in research preview. It requires the `anthropic-beta: mcp-tunnels-2026-06-22` header and may change without a deprecation period. It supersedes the Admin API endpoints at `/v1/organizations/tunnels`, which remain available during a migration window. Reveals a tunnel's connector token. The value is fetched live on each call; Anthropic does not store it. Repeated calls return the same value until the token is rotated. Exposed as POST so the token does not appear in intermediary access logs. Args: betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rarGrHc32K|]}t|ywr/rJrLs r3rOz'Tunnels.reveal_token..OrPrQrR./v1/tunnels/{tunnel_id}/reveal_token?beta=truerdrTrf rhrrrYrrrZrr'r*rjs r3 reveal_tokenzTunnels.reveal_token'sFWXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] zz JV_ `(+Q[el$   r5reasonr@rArBrCrDc Z|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|td|itjt|||| t S) The Tunnels API is in research preview. It requires the `anthropic-beta: mcp-tunnels-2026-06-22` header and may change without a deprecation period. It supersedes the Admin API endpoints at `/v1/organizations/tunnels`, which remain available during a migration window. Rotates a tunnel's connector token. Rotation invalidates the current token for new connections and returns a fresh value; established connections are not severed. A connector restarted after rotation must use the new value. Args: reason: Optional free-text reason for the rotation, recorded for audit. betas: Optional header to specify the beta version(s) you want to use. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rarGrHc32K|]}t|ywr/rJrLs r3rOz'Tunnels.rotate_token..rPrQrR./v1/tunnels/{tunnel_id}/rotate_token?beta=truerdrrTrU) rhrrrYrrrZrrr%TunnelRotateTokenParamsr'r*r2rerr@rArBrCrDs r3 rotate_tokenzTunnels.rotate_token_sJWXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] zz JV_ ` (F!35O5g5gh(+Q[el$   r5)returnr)rr8)rr<r?Optional[str] | Omitr@List[AnthropicBetaParam] | OmitrAHeaders | NonerB Query | NonerC Body | NonerD'float | httpx.Timeout | None | NotGivenrr(rerKr@rrArrBrrCrrDrrr()rm bool | Omitrn int | Omitro str | Omitr@rrArrBrrCrrDrrzSyncPageCursor[BetaTunnel]rerKr@rrArrBrrCrrDrrr*rerKrrr@rrArrBrrCrrDrrr*__name__ __module__ __qualname__rr4r9r=rrr]rkr{rrrr5r3r+r+"s**,,22.215)-$("&;D6 +6 / 6 &6 "6  6 96  6 x26)-$("&;D3 3 / 3 &3 "3  3 93  3 p)- 15)-$("&;DF &F  F  F / F &F "F  F 9F  $F X26)-$("&;D6 6 / 6 &6 "6  6 96  6 x26)-$("&;D6 6 / 6 &6 "6  6 96  6 x(,15)-$("&;D9 9 % 9 / 9 &9 "9  9 99  9 r5c xeZdZeddZeddZeddZeeddded ddZ eddded ddZ eeeeddded  dd Z eddded dd Z eddded dd Z eeddded  ddZy)r,c,t|jSr/)rr0r1s r3r4zAsyncTunnels.certificatess ..r5ct|Sr7)AsyncTunnelsWithRawResponser1s r3r9zAsyncTunnels.with_raw_responses+400r5ct|Sr;)!AsyncTunnelsWithStreamingResponser1s r3r=z$AsyncTunnels.with_streaming_responses166r5Nr>c TKitdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt d|itjd{t||||t d{S7$7w) rFrGrHc32K|]}t|ywr/rJrLs r3rOz&AsyncTunnels.create..rPrQrRrSr?NrTrU) rrrYrrrZrr$r[r'r(r\s r3r]zAsyncTunnels.createsH  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] ZZ #,nl-KMaMtMtuu(+Q[el     u s$A=B(?B$ B(B& B(&B(r^c @K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t d {S7w) r`rarGrHc32K|]}t|ywr/rJrLs r3rOz(AsyncTunnels.retrieve..rPrQrRrcrdrTrfNrgrjs r3rkzAsyncTunnels.retrieves@WXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] YY = S(+Q[el     BBBBrlc@itdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt tt||||t|||dtjtS) rqrGrHc32K|]}t|ywr/rJrLs r3rOz$AsyncTunnels.list..LrPrQrRrSrsrtrv) rrrYrrrxr"r(r'rr#ryrzs r3r{zAsyncTunnels.list sR  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] !! # ,(+'%%,.rPrQrRrrdrTrfNrrjs r3rzAsyncTunnels.archivehsFWXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] ZZ EQZ [(+Q[el      rc @K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t d {S7w) rrarGrHc32K|]}t|ywr/rJrLs r3rOz,AsyncTunnels.reveal_token..rPrQrRrrdrTrfNrrjs r3rzAsyncTunnels.reveal_tokensFWXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] ZZ JV_ `(+Q[el$      rrc K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|td|itjd {t|||| t d {S7$7w) rrarGrHc32K|]}t|ywr/rJrLs r3rOz,AsyncTunnels.rotate_token..rPrQrRrrdrNrTrU) rhrrrYrrrZrrr%rr'r*rs r3rzAsyncTunnels.rotate_tokensJWXaWdef f  $'*hhu5Le5LOgNh/i&j"  "  *+C] H[Y[] ZZ JV_ `,h-?A[AsAstt(+Q[el$     t s$BCB? C:C;CC)rr)rr)rrrr)rmrrnrrorr@rrArrBrrCrrDrrz7AsyncPaginator[BetaTunnel, AsyncPageCursor[BetaTunnel]]rrrrr5r3r,r,s//1177.215)-$("&;D6 +6 / 6 &6 "6  6 96  6 x26)-$("&;D3 3 / 3 &3 "3  3 93  3 p)- 15)-$("&;DF &F  F  F / F &F "F  F 9F  AF X26)-$("&;D6 6 / 6 &6 "6  6 96  6 x26)-$("&;D6 6 / 6 &6 "6  6 96  6 x(,15)-$("&;D9 9 % 9 / 9 &9 "9  9 99  9 r5c&eZdZddZeddZy)r8c||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yr/) _tunnelsrto_raw_response_wrapperr]rkr{rrrr2tunnelss r3__init__zTunnelsWithRawResponse.__init__s &>> NN  )@@     %<< LL  (?? OO  -DD   -DD   r5c@t|jjSr/)rrr4r1s r3r4z#TunnelsWithRawResponse.certificates+s*4==+E+EFFr5Nrr+rNone)rrrrrrrr4rr5r3r8r8s ,GGr5r8c&eZdZddZeddZy)rc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yr/) rrasync_to_raw_response_wrapperr]rkr{rrrrs r3rz$AsyncTunnelsWithRawResponse.__init__1s &DD NN  )FF     %BB LL  (EE OO  -JJ   -JJ   r5c@t|jjSr/)rrr4r1s r3r4z(AsyncTunnelsWithRawResponse.certificatesGs/ 0J0JKKr5Nrr,rr)rrrrr5r3rr0s ,LLr5rc&eZdZddZeddZy)r<cJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yr/)rrr]rkr{rrrrs r3rz%TunnelsWithStreamingResponse.__init__Ms 2 NN  5     1 LL  4 OO  9   9   r5c@t|jjSr/)rrr4r1s r3r4z)TunnelsWithStreamingResponse.certificatescs01K1KLLr5Nr)rrrrr5r3r<r<Ls ,MMr5r<c&eZdZddZeddZy)rcJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yr/)rrr]rkr{rrrrs r3rz*AsyncTunnelsWithStreamingResponse.__init__is 8 NN  ;     7 LL  : OO  ?   ?   r5c@t|jjSr/)r rr4r1s r3r4z.AsyncTunnelsWithStreamingResponse.certificatess5dmm6P6PQQr5Nr)rr rrr5r3rrhs ,RRr5r)> __future__rtypingrr itertoolsrhttpxr_typesr r r r r rr_utilsrrrrr_compatr _resourcerr _responserrr4rrrrrr paginationr!r" types.betar#r$r% _base_clientr&r'types.beta.beta_tunnelr(types.anthropic_beta_paramr)types.beta.beta_tunnel_tokenr*__all__r+r,r8rr<rrr5r3rs#! !LLLgg';Z;__A1=< n %v ov r v #v r GG8LL8MM8RRr5