o Tj@sddlmZddlZddlmZmZmZddlmZddl 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@ddlAmBZBddlCmDZDddgZEGdddeZFGdddeZGGdddZHGdd d ZIGd!d"d"ZJGd#d$d$ZKdS)%) 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 AsyncWebhooksc@eZdZedLddZedMddZedNd d Zd d d ed dOddZd d d ed dPdd Z e e e d d d ed!dQd$d%Z e e d d d ed&dRd,d-Z d d d ed dSd/d0Z e d d d ed1dTd4d5Zd d d ed dUd9d:Zd d;dVdCdDZd dEdFdWdJdKZd S)Xr1returnrcC t|jSN)r_clientselfr:e/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/openai/resources/webhooks/webhooks.py event_types/ zWebhooks.event_typesWebhooksWithRawResponsecCt|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 )r>r8r:r:r;with_raw_response3zWebhooks.with_raw_responseWebhooksWithStreamingResponsecCr?z 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 )rCr8r:r:r;with_streaming_response=z Webhooks.with_streaming_responseN extra_headers extra_query extra_bodytimeoutr<List[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']]namestrurlrHHeaders | NonerI Query | NonerJ Body | NonerK(float | httpx2.Timeout | None | NotGivenr0c Cs4|jdt|||dtjt||||ddidtdS)@ 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<rMrO bearer_authTrHrIrJrKsecuritybodyoptionscast_to)_postrr)WebhookCreateParamsr%r0r9r<rMrOrHrIrJrKr:r:r;createFs$4zWebhooks.createwebhook_endpoint_idr,c C<|s td||jtd|dt||||ddidtdS)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}rbrWTrXr\r] ValueError_getrr%r,r9rbrHrIrJrKr:r:r;retrieve zWebhooks.retriever<rMrOrHrIrJrKList[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']] | Omit str | Omitc CsN|s td||jtd|dt|||dtjt||||ddidtdS) 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 rerfrgrVrWTrXrZ)rjr^rrr*WebhookUpdateParamsr%r, r9rbr<rMrOrHrIrJrKr:r:r;updates,6 zWebhooks.updateafterlimitrHrIrJrKrwOptional[str] | Omitrx int | OmitSyncCursorPage[WebhookEndpoint]c C8|jdttt||||t||dtjddidtdSa 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 rU)rwrxrWT)rHrIrJrKqueryrY)pager\model) _get_api_listr!r,r%rr'WebhookListParamsr9rwrxrHrIrJrKr:r:r;list$z Webhooks.listr.c Crc)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 rerfrgrWTrXrhrj_deleterr%r.rlr:r:r;delete3rnzWebhooks.delete#keep_old_secret_active_for_24_hoursrHrIrJrKr bool | Omitc CJ|s td||jtd|dtd|itjt||||ddidtdS) 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 re6/webhook_endpoints/{webhook_endpoint_id}/rotate_secretrgrrWTrXrZ)rjr^rrr+WebhookRotateSecretParamsr%r0r9rbrrHrIrJrKr:r:r; rotate_secretZs*zWebhooks.rotate_secret event_typeLiteral['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']r/c Cr)  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 re-/webhook_endpoints/{webhook_endpoint_id}/testrgrrWTrXrZ)rjr^rrr(WebhookTestParamsr%r/r9rbrrHrIrJrKr:r:r;tests - z Webhooks.testsecretpayload str | bytesheadersrr str | Noner-cCs8|dur|jj}|j|||dttttt|dS)KValidates that the given payload was sent by OpenAI and parses the payload.Nrrrtype_value)r7webhook_secretverify_signaturerr-rjsonloads)r9rrrr:r:r;unwrapszWebhooks.unwrap,r tolerancerintNonecCs>|dur|jj}|durtdt||||dstdddSa\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 signaturer7rrj_webhook_signature_matchesr#r9rrrrr:r:r;rszWebhooks.verify_signature)r4r)r4r>)r4rCr<rLrMrNrOrNrHrPrIrQrJrRrKrSr4r0 rbrNrHrPrIrQrJrRrKrSr4r,rbrNr<rprMrqrOrqrHrPrIrQrJrRrKrSr4r,)rwryrxrzrHrPrIrQrJrRrKrSr4r{ rbrNrHrPrIrQrJrRrKrSr4r.rbrNrrrHrPrIrQrJrRrKrSr4r0rbrNrrrHrPrIrQrJrRrKrSr4r/rrrrrrr4r- rrrrrrrrr4r__name__ __module__ __qualname__rr<rArErrarmrrurrrrrrr:r:r:r;r1.sj   %NAQ6+KCc@r3)Xr2r4rcCr5r6)rr7r8r:r:r;r<r=zAsyncWebhooks.event_typesAsyncWebhooksWithRawResponsecCr?r@)rr8r:r:r;rArBzAsyncWebhooks.with_raw_response"AsyncWebhooksWithStreamingResponsecCr?rD)rr8r:r:r;rE rFz%AsyncWebhooks.with_streaming_responseNrGr<rLrMrNrOrHrPrIrQrJrRrKrSr0c sB|jdt|||dtjIdHt||||ddidtdIdHS)rTrUrVNrWTrXrZ)r^rr)r_r%r0r`r:r:r;ras&4 zAsyncWebhooks.createrbr,c D|s td||jtd|dt||||ddidtdIdHS) rdrerfrgrWTrXrhNrirlr:r:r;rm]   zAsyncWebhooks.retrieverorprqc s\|s td||jtd|dt|||dtjIdHt||||ddidtd IdHS) rrrerfrgrVNrWTrXrZ)rjr^rrr*rsr%r,rtr:r:r;rus.6  zAsyncWebhooks.updatervrwryrxrzAAsyncPaginator[WebhookEndpoint, AsyncCursorPage[WebhookEndpoint]]c Cr|r})rr"r,r%rr'rrr:r:r;rrzAsyncWebhooks.listr.c r) rrerfrgrWTrXrhNrrlr:r:r;rrzAsyncWebhooks.deleterrrc X|s td||jtd|dtd|itjIdHt||||ddidtd IdHS) rrerrgrNrWTrXrZ)rjr^rrr+rr%r0rr:r:r;r)s, zAsyncWebhooks.rotate_secretrrr/c r) rrerrgrNrWTrXrZ)rjr^rrr(rr%r/rr:r:r;rZs"-  zAsyncWebhooks.testrrrrrrrr-cCsP|dur|jj}|j|||dt|tr|dn|}ttttt |dS)rNrzutf-8r) r7rr isinstancebytesdecoderr-rrr)r9rrrr[r:r:r;rszAsyncWebhooks.unwraprrrrrcCs>|dur|jj}|durtddt||||dstddSrrrr:r:r;rszAsyncWebhooks.verify_signature)r4r)r4r)r4rrrr)rwryrxrzrHrPrIrQrJrRrKrSr4rrrrrrrr:r:r:r;r2sj   %NAQ6+KCc@$eZdZd ddZed dd Zd S) r>webhooksr1r4rcCl||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_t|j |_ dSr6) _webhooksrto_raw_response_wrapperrarmrurrrrr9rr:r:r;__init__, z WebhooksWithRawResponse.__init__rcC t|jjSr6)rrr<r8r:r:r;r< z#WebhooksWithRawResponse.event_typesNrr1r4r)r4rrrrrrr<r:r:r:r;r> r>c@r) rrr2r4rcCrr6) rrasync_to_raw_response_wrapperrarmrurrrrrr:r:r;rrz%AsyncWebhooksWithRawResponse.__init__rcCrr6)rrr<r8r:r:r;r<rz(AsyncWebhooksWithRawResponse.event_typesNrr2r4r)r4rrr:r:r:r;rrrc@r) rCrr1r4rcC^||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSr6) rrrarmrurrrrrr:r:r;r , z&WebhooksWithStreamingResponse.__init__rcCrr6)rrr<r8r:r:r;r<#rz)WebhooksWithStreamingResponse.event_typesNr)r4rrr:r:r:r;rC rrCc@r) rrr2r4rcCrr6) rrrarmrurrrrrr:r:r;r)rz+AsyncWebhooksWithStreamingResponse.__init__r cCrr6)r rr<r8r:r:r;r<Brz.AsyncWebhooksWithStreamingResponse.event_typesNr)r4r rr:r:r:r;r(rr)L __future__rrtypingrrrtyping_extensionsrhttpx2r_typesr r r r r rrr_utilsrrr_compatr_modelsr _resourcerr _responserrr<rrrrrr 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_resultr/+types.webhooks.webhook_endpoint_with_secretr0__all__r1r2r>rrCrr:r:r:r;sH   (          RQ