i?1i) ddlmZddlmZmZddlmZmZmZm Z ddl m Z ddl m Z mZddlmZmZddlmZmZerddlmZd d d d d d d d d d d dd ZGd d eZGddeZy )) annotations) TYPE_CHECKINGAny)"filter_out_none_values_recursively ignore_docsmaybe_extract_enum_member_valueparse_date_fields) ApifyApiError)catch_not_found_or_throw pluck_data)ResourceClientResourceClientAsync)WebhookDispatchCollectionClient$WebhookDispatchCollectionClientAsync)WebhookEventTypeN) event_types request_urlpayload_templateactor_id actor_task_id actor_run_idignore_ssl_errors do_not_retryidempotency_key is_ad_hocc v|||||| |||dd} |d| d<||D cgc] } t| c} | d<| Scc} w)z6Prepare webhook dictionary representation for clients.) actorRunId actorTaskIdactorId) requestUrlpayloadTemplateignoreSslErrors doNotRetryidempotencyKeyisAdHoc conditionTr% eventTypes)r) rrrrrrrrrrwebhook event_types w/home/www/therecruiter.miabetepe.com/venv/lib/python3.12/site-packages/apify_client/clients/resource_clients/webhook.pyget_webhook_representationr+sj"+,")&(  G! _j kQ[!@!L k  N!ls6c eZdZdZed fd Zd dZdddddddddd d dZd dZd dZ dd Z xZ S) WebhookClientz-Sub-client for manipulating a single webhook.cL|jdd}t||d|i|y)zInitialize the WebhookClient. resource_pathwebhooksNpopsuper__init__selfargskwargsr/ __class__s r*r4zWebhookClient.__init__=, ?J?  $FmFvFc"|jS)Retrieve the webhook. https://docs.apify.com/api/v2#/reference/webhooks/webhook-object/get-webhook Returns: dict, optional: The retrieved webhook, or None if it does not exist _getr6s r*getzWebhookClient.getCsyy{r;N rrrrrrrrrc ^t|||||||||  } |jt| S)8Update the webhook. https://docs.apify.com/api/v2#/reference/webhooks/webhook-object/update-webhook Args: event_types (list of WebhookEventType, optional): List of event types that should trigger the webhook. At least one is required. request_url (str, optional): URL that will be invoked once the webhook is triggered. payload_template (str, optional): Specification of the payload that will be sent to request_url actor_id (str, optional): Id of the actor whose runs should trigger the webhook. actor_task_id (str, optional): Id of the actor task whose runs should trigger the webhook. actor_run_id (str, optional): Id of the actor run which should trigger the webhook. ignore_ssl_errors (bool, optional): Whether the webhook should ignore SSL errors returned by request_url do_not_retry (bool, optional): Whether the webhook should retry sending the payload to request_url upon failure. is_ad_hoc (bool, optional): Set to True if you want the webhook to be triggered only the first time the condition is fulfilled. Only applicable when actor_run_id is filled. Returns: dict: The updated webhook rBr+_updater r6rrrrrrrrrwebhook_representations r*updatezWebhookClient.updateMsCB"<##-'%/% " ||>?UVWWr;c"|jS)uDelete the webhook. https://docs.apify.com/api/v2#/reference/webhooks/webhook-object/delete-webhook _deleter@s r*deletezWebhookClient.delete|s ||~r;c |jj|jdd|j}t t |j S#t$r}t|Yd}~yd}~wwxYwzTest a webhook. Creates a webhook dispatch with a dummy payload. https://docs.apify.com/api/v2#/reference/webhooks/webhook-test/test-webhook Returns: dict, optional: The webhook dispatch created by the test testPOST)urlmethodparamsN http_clientcall_url_paramsr r jsonr r r6responseexcs r*rQzWebhookClient.testsp *'',,IIf%||~-H %Z %@A A * $S ) ) *sAA A=( A88A=c8tdi|jdS)aGet dispatches of the webhook. https://docs.apify.com/api/v2#/reference/webhooks/dispatches-collection/get-collection Returns: WebhookDispatchCollectionClient: A client allowing access to dispatches of this webhook using its list method dispatchesr/)r_sub_resource_init_optionsr@s r*r`zWebhookClient.dispatchess'/ --L-I  r;)r6r-r7rr8rreturnNone)r6r-rd dict | None)r6r-rlist[WebhookEventType] | Noner str | Nonerrhrrhrrhrrhr bool | Nonerrirrirddict)r6r-rdre)r6r-rdr __name__ __module__ __qualname____doc__rr4rArIrNrQr` __classcell__r9s@r*r-r-:s7GG 6:"&'+#$(#')-$(!%-X-X3-X -X % -X  -X"-X!-X'-X"-X-X -X^0  r;r-c eZdZdZed fd Zd dZdddddddddd d dZd dZd dZ dd Z xZ S)WebhookClientAsyncz3Async sub-client for manipulating a single webhook.cL|jdd}t||d|i|y)z"Initialize the WebhookClientAsync.r/r0Nr1r5s r*r4zWebhookClientAsync.__init__r:r;c>K|jd{S7w)r=Nr>r@s r*rAzWebhookClientAsync.getsYY[   NrBc zKt|||||||||  } |jt| d{S7w)rDrBNrErGs r*rIzWebhookClientAsync.updatesMB"<##-'%/% " \\"DE["\]]]]s 2;9;c>K|jd{S7w)rKNrLr@s r*rNzWebhookClientAsync.deletes \\^###rvcK |jj|jdd|jd{}t t |j S7&#t$r}t|Yd}~yd}~wwxYwwrPrVr\s r*rQzWebhookClientAsync.tests *!--22IIf%||~3H %Z %@A A  * $S ) ) *s@B >A+A)%A+(B )A++ B 4 B?B B  B c8tdi|jdS)aGet dispatches of the webhook. https://docs.apify.com/api/v2#/reference/webhooks/dispatches-collection/get-collection Returns: WebhookDispatchCollectionClientAsync: A client allowing access to dispatches of this webhook using its list method r`rarb)rrcr@s r*r`zWebhookClientAsync.dispatches s'4 --L-I  r;)r6rsr7rr8rrdre)r6rsrdrf)r6rsrrgrrhrrhrrhrrhrrhrrirrirrirdrj)r6rsrdre)r6rsrdrrkrqs@r*rsrss=GG !6:"&'+#$(#')-$(!%-^ -^3-^ -^ % -^  -^"-^!-^'-^"-^-^ -^^$0  r;rs)rrgrrhrrhrrhrrhrrhrrirrirrhrrirdrj) __future__rtypingrrapify_shared.utilsrrrr apify_client._errorsr apify_client._utilsr r apify_client.clients.baser rAapify_client.clients.resource_clients.webhook_dispatch_collectionrrapify_shared.constsrr+r-rsrbr;r*rs"%/DIT4 26"#' $#%) $"&!".""! "  "  ""#"" "" "Jk Nk \k ,k r;