R-jddlmZddlmZmZddlmZddlZddlm Z m Z m Z m Z m Z ddlmZmZmZmZmZmZmZddlmZmZdd lmZdd lmZmZdd lmZm Z m!Z!m"Z"dd l#m$Z$dd l%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddgZ/GddeZ0GddeZ1GddZ2GddZ3GddZ4GddZ5y)) annotations)ListUnion)LiteralN)webhook_list_paramswebhook_ping_paramswebhook_create_paramswebhook_update_params$webhook_rotate_signing_secret_params)BodyOmitQueryHeadersNotGivenomit not_given)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)make_request_options)Webhook)WebhookListResponse)WebhookPingResponse)WebhookDeleteResponse)"WebhookRotateSigningSecretResponseWebhooksResourceAsyncWebhooksResourcec eZdZeddZeddZdeddded ddZdeeeeeddded ddZ deeddded dd Z dddded  dd Z dddded  dd Z deddded  ddZ deddded ddZy)r#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/stainless-sdks/gemini-next-gen-api-python#accessing-raw-response-data-eg-headers )WebhooksResourceWithRawResponseselfs {/Users/jameslopez/projects/TradingBot25/.venv/lib/python3.12/site-packages/google/genai/_interactions/resources/webhooks.pywith_raw_responsez"WebhooksResource.with_raw_response5s/t44ct|Sz An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/stainless-sdks/gemini-next-gen-api-python#with_streaming_response )%WebhooksResourceWithStreamingResponser)s r+with_streaming_responsez(WebhooksResource.with_streaming_response?s5T::r-N api_versionname extra_headers extra_query extra_bodytimeoutc ||jj}|std||j|jj |dt |||dt jt||||tS);Creates a new Webhook. Args: subscribed_events: Required. The events that the webhook is subscribed to. Available events: - batch.succeeded - batch.expired - batch.failed - interaction.requires_action - interaction.completed - interaction.failed - video.generated uri: Required. The URI to which webhook events will be sent. name: Optional. The user-provided name of the webhook. 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 :Expected a non-empty value for `api_version` but received webhooksr3pathsubscribed_eventsurir4r5r6r7r8bodyoptionscast_to) _client_get_api_version_path_param ValueError_post_build_maybe_vertex_pathrr WebhookCreateParamsrr r*r3r@rAr4r5r6r7r8s r+createzWebhooksResource.createHsn  ,,BBDKYZeYhij jzz LL 1 1kPZ 1 [ ):  &99 )+Q[el  r- r3 update_maskr4stater@rAr5r6r7r8c r||jj}|std||std||j|jj |d|t ||||dt jt|| | | t d|it jtS) Updates an existing Webhook. Args: update_mask: Optional. The list of fields to update. name: Optional. The user-provided name of the webhook. state: Optional. The state of the webhook. subscribed_events: Optional. The events that the webhook is subscribed to. Available events: - batch.succeeded - batch.expired - batch.failed - interaction.requires_action - interaction.completed - interaction.failed - video.generated uri: Optional. The URI to which webhook events will be sent. 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 r;1Expected a non-empty value for `id` but received webhooks/r=r4rQr@rArPr5r6r7r8queryrC) rGrHrI_patchrKrr WebhookUpdateParamsrr r*idr3rPr4rQr@rAr5r6r7r8s r+updatezWebhooksResource.updates~  ,,BBDKYZeYhij jPQSPVWX X{{ LL 1 1kR[\^[_P` 1 a  "):  &99)+'%%}k&BDYDmDmn %  r-r3 page_size page_tokenr5r6r7r8c||jj}|std||j|jj |dt ||||t ||dtjtS)Lists all Webhooks. Args: page_size: Optional. The maximum number of webhooks to return. The service may return fewer than this value. If unspecified, at most 50 webhooks will be returned. The maximum value is 1000. page_token: Optional. A page token, received from a previous `ListWebhooks` call. Provide this to retrieve the subsequent page. 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 r;r<r=r_r`rWrErF) rGrHrI_getrKrrrWebhookListParamsrr*r3r_r`r5r6r7r8s r+listzWebhooksResource.listsB  ,,BBDKYZeYhij jyy LL 1 1kPZ 1 [(+'%%%.&0(99  (  r-r3r5r6r7r8c ||jj}|std||std||j|jj |d|t ||||t S)F Deletes a Webhook. Args: 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 r;rTrUr=rBrdrGrHrI_deleterKrr!r*r\r3r5r6r7r8s r+deletezWebhooksResource.delete$s0  ,,BBDKYZeYhij jPQSPVWX X|| LL 1 1kR[\^[_P` 1 a(+Q[el*   r-c ||jj}|std||std||j|jj |d|t ||||t S)L Gets a specific Webhook. Args: 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 r;rTrUr=rBrdrGrHrIrerKrrrns r+getzWebhooksResource.getJs0  ,,BBDKYZeYhij jPQSPVWX Xyy LL 1 1kR[\^[_P` 1 a(+Q[el   r-r3rDr5r6r7r8c 4||jj}|std||std||j|jj |d|dt |t jt||||tS) Sends a ping event to a Webhook. Args: body: Request message for WebhookService.PingWebhook. 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 r;rTrU:pingr=rBrC) rGrHrIrJrKrr WebhookPingParamsrr r*r\r3rDr5r6r7r8s r+pingzWebhooksResource.pingps6  ,,BBDKYZeYhij jPQSPVWX Xzz LL 1 1kR[\^[__dPe 1 f ':'L'LM(+Q[el(   r-r3revocation_behaviorr5r6r7r8c 8||jj}|std||std||j|jj |d|dt d|it jt||||tS)  Generates a new signing secret for a Webhook. Args: revocation_behavior: Optional. The revocation behavior for previous signing secrets. 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 r;rTrU:rotateSigningSecretr=r|rBrC) rGrHrIrJrKrr WebhookRotateSigningSecretParamsrr"r*r\r3r|r5r6r7r8s r+rotate_signing_secretz&WebhooksResource.rotate_signing_secrets8  ,,BBDKYZeYhij jPQSPVWX Xzz LL 1 1kR[\^[__sPt 1 u &(;<4UU)+Q[el7  r-)returnr()rr0r3 str | Noner@zList[Union[Literal['batch.succeeded', 'batch.expired', 'batch.failed', 'interaction.requires_action', 'interaction.completed', 'interaction.failed', 'video.generated'], str]]rAstrr4 str | Omitr5Headers | Noner6 Query | Noner7 Body | Noner8'float | httpx.Timeout | None | NotGivenrrr\rr3rrPrr4rrQzJLiteral['enabled', 'disabled', 'disabled_due_to_failed_deliveries'] | Omitr@zList[Union[Literal['batch.succeeded', 'batch.expired', 'batch.failed', 'interaction.requires_action', 'interaction.completed', 'interaction.failed', 'video.generated'], str]] | OmitrArr5rr6rr7rr8rrrr3rr_z int | Omitr`rr5rr6rr7rr8rrrr\rr3rr5rr6rr7rr8rrr!r\rr3rr5rr6rr7rr8rrrr\rr3rrDzwebhook_ping_params.Body | Omitr5rr6rr7rr8rrr r\rr3rr|zZLiteral['revoke_previous_secrets_after_h24', 'revoke_previous_secrets_immediately'] | Omitr5rr6rr7rr8rrr"__name__ __module__ __qualname__rr,r1rrrNr]rhrorsrzrr-r+r#r#4sT55;;#'  )-$("&;D3I  I   I $%I &'I ,&-I ."/I 0 1I 293I 4 5I ^#'"&\`)-$("&;D;X X  X  X  X ZX X ./X 4&5X 6"7X 8 9X :9;X < =X z#' $!%)-$("&;D5  5  5  5 &5 "5  5 95  5 v#')-$("&;D$ $  $ &$ "$  $ 9$  $ T#')-$("&;D$ $  $ &$ "$  $ 9$  $ T#'04)-$("&;D( (  ( . ( &( "(  ( 9(  ( \#')-$("&;D, ,  ,  , &, ",  , 9,  ,, r-c eZdZeddZeddZdeddded ddZdeeeeeddded ddZ deeddded dd Z dddded  dd Z dddded  dd Z deddded  ddZ deddded ddZy)r$ct|Sr')$AsyncWebhooksResourceWithRawResponser)s r+r,z'AsyncWebhooksResource.with_raw_responses4D99r-ct|Sr/)*AsyncWebhooksResourceWithStreamingResponser)s r+r1z-AsyncWebhooksResource.with_streaming_responses:$??r-Nr2c DK||jj}|std||j|jj |dt |||dt jd{t||||td{S7$7w)r:Nr;r<r=r?rBrC) rGrHrIrJrKrr rLrrrMs r+rNzAsyncWebhooksResource.createsn  ,,BBDKYZeYhij jZZ LL 1 1kPZ 1 [,):  &99 )+Q[el     s$A5B 7B 8B BB B rOc K||jj}|std||std||j|jj |d|t ||||dt jd{t|| | | t d|it jd{t d{S7G77w) rSNr;rTrUr=rVrPrWrC) rGrHrIrYrKrr rZrrr[s r+r]zAsyncWebhooksResource.update(s~  ,,BBDKYZeYhij jPQSPVWX X[[ LL 1 1kR[\^[_P` 1 a, "):  &99)+'%1"K02G2[2[ )!   ! s6B C C +C7C8CCCCCr^cBK||jj}|std||j|jj |dt ||||t ||dtjd{td{S77w)rbNr;r<r=rcrWrd) rGrHrIrerKrrrrfrrgs r+rhzAsyncWebhooksResource.listsB  ,,BBDKYZeYhij jYY LL 1 1kPZ 1 [(+'%1%.&0(99  (    s$A=B?BBBBBric K||jj}|std||std||j|jj |d|t ||||t d{S7w)rkNr;rTrUr=rBrdrlrns r+rozAsyncWebhooksResource.deletes0  ,,BBDKYZeYhij jPQSPVWX X\\ LL 1 1kR[\^[_P` 1 a(+Q[el* "    BB B B c K||jj}|std||std||j|jj |d|t ||||t d{S7w)rqNr;rTrUr=rBrdrrrns r+rszAsyncWebhooksResource.gets0  ,,BBDKYZeYhij jPQSPVWX XYY LL 1 1kR[\^[_P` 1 a(+Q[el     rrtc dK||jj}|std||std||j|jj |d|dt |t jd{t||||td{S7$7w) rvNr;rTrUrwr=rBrC) rGrHrIrJrKrr rxrr rys r+rzzAsyncWebhooksResource.pings6  ,,BBDKYZeYhij jPQSPVWX XZZ LL 1 1kR[\^[__dPe 1 f,T3F3X3XYY(+Q[el(     Y s$BB0B, B0'B.(B0.B0r{c hK||jj}|std||std||j|jj |d|dt d|it jd{t||||t d{S7$7w) r~Nr;rTrUrr=r|rBrC) rGrHrIrJrKrr rrr"rs r+rz+AsyncWebhooksResource.rotate_signing_secret1s8  ,,BBDKYZeYhij jPQSPVWX XZZ LL 1 1kR[\^[__sPt 1 u,&(;<4UU)+Q[el7     s$BB2 B. B2)B0*B20B2)rr)rrrrrrrrrrrr-r+r$r$sV::@@#'  )-$("&;D3I  I   I $%I &'I ,&-I ."/I 0 1I 293I 4 5I ^#'"&\`)-$("&;D;Z Z  Z  Z  Z ZZ Z ./Z 4&5Z 6"7Z 8 9Z :9;Z < =Z ~#' $!%)-$("&;D5  5  5  5 &5 "5  5 95  5 v#')-$("&;D$ $  $ &$ "$  $ 9$  $ T#')-$("&;D$ $  $ &$ "$  $ 9$  $ T#'04)-$("&;D( (  ( . ( &( "(  ( 9(  ( \#')-$("&;D, ,  ,  , &, ",  , 9,  ,, r-ceZdZddZy)r(c~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yN) _webhooksrrNr]rhrorsrzrr*r<s r+__init__z(WebhooksResourceWithRawResponse.__init__as!- OO  . OO  , MM  . OO  + LL , MM  &=  * *& "r-Nr<r#rNonerrrrrr-r+r(r(` r-r(ceZdZddZy)rc~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yr) rrrNr]rhrorsrzrrs r+rz-AsyncWebhooksResourceWithRawResponse.__init__|s!3 OO  4 OO  2 MM  4 OO  1 LL 2 MM  &C  * *& "r-Nr<r$rrrrr-r+rr{rr-rceZdZddZy)r0c~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yr) rrrNr]rhrorsrzrrs r+rz.WebhooksResourceWithStreamingResponse.__init__s!2 OO  3 OO  1 MM  3 OO  0 LL 1 MM  &B  * *& "r-Nrrrr-r+r0r0rr-r0ceZdZddZy)rc~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yr) rrrNr]rhrorsrzrrs r+rz3AsyncWebhooksResourceWithStreamingResponse.__init__s!8 OO  9 OO  7 MM  9 OO  6 LL 7 MM  &H  * *& "r-Nrrrr-r+rrrr-r)6 __future__rtypingrrtyping_extensionsrhttpxtypesrr r r r _typesr rrrrrr_utilsrr_compatr _resourcerr _responserrrr _base_clientr types.webhookrtypes.webhook_list_responsertypes.webhook_ping_responser types.webhook_delete_responser!,types.webhook_rotate_signing_secret_responser"__all__r#r$r(rr0rrr-r+rs$#% KJJ;%9 0#==A] 6 7R R j T ,T n   6  6  6  r-