FjddlmZddlZddlmZmZmZddlmZddl Z ddl m Z ddl m Z mZmZmZmZmZmZmZddlmZmZmZdd lmZdd lmZdd lmZmZdd l m!Z!m"Z"d dl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.ddl/m0Z0m1Z1ddl2m3Z4ddl5m6Z6m7Z7m8Z8m9Z9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBddlCmDZDddgZEGddeZFGddeZGGddZHGdd ZIGd!d"ZJGd#d$ZKy)%) annotationsN)ListOptionalcast)Literal)_legacy_response)BodyOmitQueryHeadersNotGiven HeadersLikeomit not_given) path_templatemaybe_transformasync_maybe_transform)cached_property)construct_type)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper) EventTypesAsyncEventTypesEventTypesWithRawResponseAsyncEventTypesWithRawResponseEventTypesWithStreamingResponse$AsyncEventTypesWithStreamingResponse)SyncCursorPageAsyncCursorPage)InvalidWebhookSignatureError)AsyncPaginatormake_request_options)webhook_signature_matches)webhook_list_paramswebhook_test_paramswebhook_create_paramswebhook_update_paramswebhook_rotate_secret_params)WebhookEndpoint)UnwrapWebhookEvent)DeletedWebhookEndpoint)WebhookEndpointTestResult)WebhookEndpointWithSecretWebhooks AsyncWebhooksceZdZeddZeddZeddZddded ddZddded ddZ e e e ddded dd Z e e ddded  dd Z ddded dd Z e ddded  ddZddded ddZdd ddZddd d dZy)!r2c,t|jSN)r_clientselfs `/root/workspace/ytshorts/venv/lib/python3.12/site-packages/openai/resources/webhooks/webhooks.py event_typeszWebhooks.event_types/s$,,''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/openai/openai-python#accessing-raw-response-data-eg-headers )WebhooksWithRawResponser8s r:with_raw_responsezWebhooks.with_raw_response3s't,,r<ct|Sz An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/openai/openai-python#with_streaming_response )WebhooksWithStreamingResponser8s r:with_streaming_responsez Webhooks.with_streaming_response=s-T22r<N extra_headers extra_query extra_bodytimeoutc |jdt|||dtjt ||||ddit S)@ Creates a webhook endpoint for the authenticated project. Args: event_types: The event types that trigger deliveries to this endpoint. name: A human-readable name for the webhook endpoint. url: The HTTPS URL that receives webhook deliveries. 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 /webhook_endpointsr;nameurl bearer_authTrFrGrHrIsecuritybodyoptionscast_to)_postrr*WebhookCreateParamsr&r1r9r;rNrOrFrGrHrIs r:createzWebhooks.createFsbhzz  #.  &99 )+'%'. .#  r<c |std||jtd|t||||dditS)o Retrieves a webhook endpoint for the authenticated project. 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 BExpected a non-empty value for `webhook_endpoint_id` but received (/webhook_endpoints/{webhook_endpoint_id}webhook_endpoint_idrPTrQrUrV ValueError_getrr&r-r9r`rFrGrHrIs r:retrievezWebhooks.retrievese.#TUhTkl yy DZm n(+'%'. $  r<r;rNrOrFrGrHrIc |std||jtd|t|||dtj t ||||dditS) L Updates a webhook endpoint for the authenticated project. Args: event_types: The complete set of event types that should trigger deliveries. name: A new human-readable name for the webhook endpoint. url: A new HTTPS URL that receives webhook deliveries. 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_rMrPTrQrS)rcrWrrr+WebhookUpdateParamsr&r- r9r`r;rNrOrFrGrHrIs r:updatezWebhooks.updatesl#TUhTkl zz DZm n #.  &99 )+'%'. $#  r<afterlimitrFrGrHrIc|jdttt||||t ||dt j dditSa Returns webhook endpoints for the authenticated project in newest-first order. Args: after: ID of the last webhook endpoint from the previous page. limit: Maximum number of webhook endpoints to return. Defaults to 20. 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 rL)rnrorPT)rFrGrHrIqueryrR)pagerUmodel) _get_api_listr"r-r&rr(WebhookListParamsr9rnrorFrGrHrIs r:listz Webhooks.listsh8!! 0(+'%%!&!&(99 (. "#"  r<c |std||jtd|t||||dditS)m Deletes a webhook endpoint for the authenticated project. 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]r^r_rPTrQrarc_deleterr&r/res r:deletezWebhooks.delete3se.#TUhTkl || DZm n(+'%'. +  r<#keep_old_secret_active_for_24_hoursrFrGrHrIc |std||jtd|td|itj t ||||dditS) V Rotates the signing secret for a webhook endpoint in the authenticated project. Args: keep_old_secret_active_for_24_hours: Whether to keep the previous signing secret valid for 24 hours after rotation. Defaults to false, which invalidates the previous secret immediately. 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]6/webhook_endpoints/{webhook_endpoint_id}/rotate_secretr_rrPTrQrS)rcrWrrr,WebhookRotateSecretParamsr&r1r9r`rrFrGrHrIs r: rotate_secretzWebhooks.rotate_secretZs6#TUhTkl zz H^q !68[\,FF)+'%'. .  r<c |std||jtd|td|itj t ||||dditS)  Sends a sample event to a webhook endpoint for the authenticated project. Args: event_type: The event type to send as a sample delivery. 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]-/webhook_endpoints/{webhook_endpoint_id}/testr_ event_typerPTrQrS)rcrWrrr)WebhookTestParamsr&r0r9r`rrFrGrHrIs r:testz Webhooks.tests|Z#TUhTkl zz I_r s , !;=P=b=bc(+'%'. .  r<secretc ||jj}|j|||ttt tt j|S)KValidates that the given payload was sent by OpenAI and parses the payload.payloadheadersrtype_value)r7webhook_secretverify_signaturerr.rjsonloads)r9rrrs r:unwrapzWebhooks.unwrapsT >\\00F gwvN  (jj)   r<,r tolerancec||jj}| tdt||||s t ddya\Validates whether or not the webhook payload was sent by OpenAI. Args: payload: The webhook payload headers: The webhook headers secret: The webhook secret (optional, will use client secret if not provided) tolerance: Maximum age of the webhook in seconds (default: 300 = 5 minutes) NzThe webhook secret must either be set using the env var, OPENAI_WEBHOOK_SECRET, on the client class, OpenAI(webhook_secret='123'), or passed to this functionrzAThe given webhook signature does not match the expected signaturer7rrc_webhook_signature_matchesr$r9rrrrs r:rzWebhooks.verify_signaturesZ >\\00F >`  *'76U^_.S `r<)returnr)rr?)rrCr;aList[Literal['batch.completed', 'batch.failed', 'batch.expired', 'batch.cancelled', 'response.completed', 'response.failed', 'response.cancelled', 'response.incomplete', 'eval.run.succeeded', 'eval.run.failed', 'eval.run.canceled', 'fine_tuning.job.succeeded', 'fine_tuning.job.failed', 'fine_tuning.job.cancelled', 'realtime.call.incoming', 'video.completed', 'video.failed', 'safety.alert.created']]rNstrrOrrFHeaders | NonerG Query | NonerH Body | NonerI(float | httpx2.Timeout | None | NotGivenrr1 r`rrFrrGrrHrrIrrr-r`rr;aList[Literal['batch.completed', 'batch.failed', 'batch.expired', 'batch.cancelled', 'response.completed', 'response.failed', 'response.cancelled', 'response.incomplete', 'eval.run.succeeded', 'eval.run.failed', 'eval.run.canceled', 'fine_tuning.job.succeeded', 'fine_tuning.job.failed', 'fine_tuning.job.cancelled', 'realtime.call.incoming', 'video.completed', 'video.failed', 'safety.alert.created']] | OmitrN str | OmitrOrrFrrGrrHrrIrrr-)rnOptional[str] | Omitro int | OmitrFrrGrrHrrIrrzSyncCursorPage[WebhookEndpoint] r`rrFrrGrrHrrIrrr/r`rrz bool | OmitrFrrGrrHrrIrrr1r`rraLiteral['batch.completed', 'batch.failed', 'batch.expired', 'batch.cancelled', 'response.completed', 'response.failed', 'response.cancelled', 'response.incomplete', 'eval.run.succeeded', 'eval.run.failed', 'eval.run.canceled', 'fine_tuning.job.succeeded', 'fine_tuning.job.failed', 'fine_tuning.job.cancelled', 'realtime.call.incoming', 'video.completed', 'video.failed', 'safety.alert.created']rFrrGrrHrrIrrr0r str | bytesrrr str | Nonerr. rrrrrrrintrNone__name__ __module__ __qualname__rr;r@rDrrZrfrrlrxr}rrrrr<r:r2r2.sZ((--33J)-$("& ?F @:AF B #CF \)-$("&&?L @"AL B CL D:EL F GL b'+ )-$("&)AsyncWebhooksWithRawResponser8s r:r@zAsyncWebhooks.with_raw_responses,D11r<ct|SrB)"AsyncWebhooksWithStreamingResponser8s r:rDz%AsyncWebhooks.with_streaming_response s2$77r<NrEc K|jdt|||dtjd{t ||||ddit d{S7'7w)rKrLrMNrPTrQrS)rWrr*rXr&r1rYs r:rZzAsyncWebhooks.creates{hZZ ,#.  &99 )+'%'. .#     s!.AA "AAAAc K|std||jtd|t||||dditd{S7w) r\r]r^r_rPTrQraNrbres r:rfzAsyncWebhooks.retrieve]ss.#TUhTkl YY DZm n(+'%'. $    AA A Argc K|std||jtd|t|||dtj d{t ||||ddit d{S7'7w) rir]r^r_rMNrPTrQrS)rcrWrrr+rjr&r-rks r:rlzAsyncWebhooks.updatesl#TUhTkl ZZ DZm n,#.  &99 )+'%'. $#     s$A A7 A3 "A7.A5/A75A7rmc|jdttt||||t ||dt j dditSrq)rur#r-r&rr(rvrws r:rxzAsyncWebhooks.listsh8!!  1(+'%%!&!&(99 (. "#"  r<c K|std||jtd|t||||dditd{S7w) rzr]r^r_rPTrQraNr{res r:r}zAsyncWebhooks.deletess.#TUhTkl \\ DZm n(+'%'. +"    rr~c K|std||jtd|td|itj d{t ||||ddit d{S7'7w) rr]rr_rNrPTrQrS)rcrWrrr,rr&r1rs r:rzAsyncWebhooks.rotate_secret)s6#TUhTkl ZZ H^q -68[\,FF)+'%'. .      $AA5 A1 "A5,A3-A53A5c K|std||jtd|td|itj d{t ||||ddit d{S7'7w) rr]rr_rNrPTrQrS)rcrWrrr)rr&r0rs r:rzAsyncWebhooks.testZsZ#TUhTkl ZZ I_r s,lJ-GI\InInoo(+'%'. .   o  rrc ||jj}|j|||t|tr|j dn|}t ttttj|S)rrzutf-8r) r7rr isinstancebytesdecoderr.rrr)r9rrrrTs r:rzAsyncWebhooks.unwrapsm >\\00F gwvN*4We*Dw~~g&'  (jj&   r<rrc||jj}| tddt||||s t dyrrrs r:rzAsyncWebhooks.verify_signaturesX >\\00F >`  *'76U^_./rs s`r<)rr)rr)rrrrr)rnrrorrFrrGrrHrrIrrzAAsyncPaginator[WebhookEndpoint, AsyncCursorPage[WebhookEndpoint]]rrrrrrrr<r:r3r3sa--2288J)-$("& ?F @:AF B #CF \)-$("&&?L @"AL B CL D:EL F GL b'+ )-$("&> OO  )@@     '>> OO  %<< MM  '>> OO  .EE  " " %<< MM  r<c@t|jjSr6)rrr;r8s r:r;z#WebhooksWithRawResponse.event_typess()C)CDDr<Nrr2rr)rrrrrrrr;rr<r:r?r?s 2EEr<r?c&eZdZddZeddZy)rc ||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_tj|j|_ yr6) rr async_to_raw_response_wrapperrZrfrlrxr}rrrs r:rz%AsyncWebhooksWithRawResponse.__init__s!&DD OO  )FF     'DD OO  %BB MM  'DD OO  .KK  " " %BB MM  r<c@t|jjSr6)rrr;r8s r:r;z(AsyncWebhooksWithRawResponse.event_typess-dnn.H.HIIr<Nrr3rr)rrrrr<r:rrs 2JJr<rc&eZdZddZeddZy)rCc~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yr6) rrrZrfrlrxr}rrrs r:rz&WebhooksWithStreamingResponse.__init__ s!2 OO  5     3 OO  1 MM  3 OO  :  " " 1 MM  r<c@t|jjSr6)r rr;r8s r:r;z)WebhooksWithStreamingResponse.event_types#s.t~~/I/IJJr<Nr)rr rrr<r:rCrC s 2KKr<rCc&eZdZddZeddZy)rc~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yr6) rrrZrfrlrxr}rrrs r:rz+AsyncWebhooksWithStreamingResponse.__init__)s!8 OO  ;     9 OO  7 MM  9 OO  @  " " 7 MM  r<c@t|jjSr6)r!rr;r8s r:r;z.AsyncWebhooksWithStreamingResponse.event_typesBs3DNN4N4NOOr<Nr)rr!rrr<r:rr(s 2PPr<r)L __future__rrtypingrrrtyping_extensionsrhttpx2r _typesr r r r rrrr_utilsrrr_compatr_modelsr _resourcerr _responserrr;rrrrr r! paginationr"r# _exceptionsr$ _base_clientr%r& lib._webhooksr'rtypes.webhooksr(r)r*r+r,types.webhooks.webhook_endpointr-#types.webhooks.unwrap_webhook_eventr.'types.webhooks.deleted_webhook_endpointr/+types.webhooks.webhook_endpoint_test_resultr0+types.webhooks.webhook_endpoint_with_secretr1__all__r2r3r?rrCrrr<r:rs# ''% XXXKK&%:Y:7@T?EMTT  'LL^Kt$Kt\EE>JJ>KK>PPr<