8j+ddlmZddlmZmZddlmZddlmZddl m Z m Z m Z m Z mZmZddlmZmZddlmZerddlmZdd lmZmZdd lmZed Gd d eZed GddeZy)) annotations) TYPE_CHECKINGAny)AnyUrl) docs_group)TestWebhookResponseWebhookWebhookConditionWebhookDispatchWebhookResponse WebhookUpdate)ResourceClientResourceClientAsync)response_to_dict)WebhookEventType)WebhookDispatchCollectionClient$WebhookDispatchCollectionClientAsync)TimeoutzResource clientsc eZdZdZdd dfdZddddZdddddddddddd dd Zdddd Zd ddd ZddZ xZ S) WebhookClientzSub-client for managing a specific webhook. Provides methods to manage a specific webhook, e.g. get, update, or delete it. Obtain an instance via an appropriate method on the `ApifyClient` class. webhooks resource_pathc *t|d||d|yN) resource_idrsuper__init__selfrrkwargs __class__s ]/var/www/html/GAP/venv/lib/python3.12/site-packages/apify_client/_resource_clients/webhook.pyr zWebhookClient.__init__!'  #'  shorttimeoutcj|j|}|ytj|jSa Retrieve the webhook. https://docs.apify.com/api/v2#/reference/webhooks/webhook-object/get-webhook Args: timeout: Timeout for the API HTTP request. Returns: The retrieved webhook, or None if it does not exist. r)N_getr model_validatedatar"r*results r%getzWebhookClient.get.s37+ >--f5:::r'N event_types request_urlpayload_templateheaders_templateactor_id actor_task_id actor_run_idignore_ssl_errors do_not_retry is_ad_hocr*c t| t|nd| t|nd|||| |r| ndt|||} |jdd| i| j dd} t j| jSaUpdate the webhook. https://docs.apify.com/api/v2#/reference/webhooks/webhook-object/update-webhook Args: event_types: List of event types that should trigger the webhook. At least one is required. request_url: URL that will be invoked once the webhook is triggered. payload_template: Specification of the payload that will be sent to request_url. headers_template: Headers that will be sent to the request_url. actor_id: Id of the Actor whose runs should trigger the webhook. actor_task_id: Id of the Actor task whose runs should trigger the webhook. actor_run_id: Id of the Actor run which should trigger the webhook. ignore_ssl_errors: Whether the webhook should ignore SSL errors returned by request_url. do_not_retry: Whether the webhook should retry sending the payload to request_url upon failure. is_ad_hoc: 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. timeout: Timeout for the API HTTP request. Returns: The updated webhook. N)r;r:r9)r5r6r7r8r<r=r> conditionr*T)by_alias exclude_noner r listrr _update model_dumpr r/r0r"r5r6r7r8r9r:r;r<r=r>r*webhook_updater2s r%updatezWebhookClient.update>sH'-8-D[)$/:/F{+D--/%#/iT&)+!  mgm1J1JTXgk1J1lm--f5:::r'c(|j|yzDelete the webhook. https://docs.apify.com/api/v2#/reference/webhooks/webhook-object/delete-webhook Args: timeout: Timeout for the API HTTP request. r)N_deleter"r*s r%deletezWebhookClient.deletess W %r'mediumc|jj|jdd|j|}t |}t j |jS)Test a webhook. Creates a webhook dispatch with a dummy payload. https://docs.apify.com/api/v2#/reference/webhooks/webhook-test/test-webhook Args: timeout: Timeout for the API HTTP request. Returns: The webhook dispatch created by the test. Raises: NotFoundError: If the webhook does not exist. testPOSTurlmethodparamsr* _http_clientcall _build_url _build_paramsrrr/r0r"r*responser2s r%rTzWebhookClient.test}s` $$))'%%' * "(+"11&9>>>r'cR|jjdddi|jSzGet dispatches of the webhook. https://docs.apify.com/api/v2#/reference/webhooks/dispatches-collection/get-collection Returns: A client allowing access to dispatches of this webhook using its list method. r dispatchesr_client_registry"webhook_dispatch_collection_client_base_client_kwargsr"s r%rczWebhookClient.dispatches6Ht$$GG & &&  r'rstrrrkr#rreturnNoner*rrlzWebhook | Noner5zlist[WebhookEventType] | Noner6 str | Noner7rpr8rpr9rpr:rpr;rpr< bool | Noner=rqr>rqr*rrlr r*rrlrmr*rrlr )rlr __name__ __module__ __qualname____doc__r r3rJrPrTrc __classcell__r$s@r%rrs(          )0;&6:"&'+'+#$(#')-$(!%"3;33; 3; % 3; % 3;3;"3;!3;'3;"3;3;3; 3;j,3&*2?4  r'rc eZdZdZdd dfdZddddZdddddddddddd dd Zdddd Zd ddd ZddZ xZ S)WebhookClientAsynczSub-client for managing a specific webhook. Provides methods to manage a specific webhook, e.g. get, update, or delete it. Obtain an instance via an appropriate method on the `ApifyClientAsync` class. rrc *t|d||d|yrrr!s r%r zWebhookClientAsync.__init__r&r'r(r)cK|j|d{}|ytj|jS7&wr,r-r1s r%r3zWebhookClientAsync.gets?yyy11 >--f5:::2sA?'ANr4c  Kt| t|nd| t|nd|||| |r| ndt|||} |jdd| i| j ddd{} t j| jS7#wr@rDrHs r%rJzWebhookClientAsync.updatesH'-8-D[)$/:/F{+D--/%#/iT&)+!  $t||sGs~7P7PZ^mq7P7rss--f5:::tsA&B(B )$BcDK|j|d{y7wrLrMrOs r%rPzWebhookClientAsync.deletesll7l+++s   rQcK|jj|jdd|j|d{}t |}t j |jS7.w)rSrTrUrVNrZr_s r%rTzWebhookClientAsync.test sn **//'%%' 0  "(+"11&9>>> sAA3A1/A3cR|jjdddi|jSrbrdrhs r%rczWebhookClientAsync.dispatches#rir'rjrnrorrrs)rlrrtrzs@r%r|r|s(          /6;&6:"&'+'+#$(#')-$(!%"3;33; 3; % 3; % 3;3;"3;!3;'3;"3;3;3; 3;j29,08?4  r'r|N) __future__rtypingrrpydanticrapify_client._docsrapify_client._modelsrr r r r r /apify_client._resource_clients._resource_clientrrapify_client._utils.httprapify_client._literalsrapify_client._resource_clientsrrapify_client.typesrrr|rr'r%rsz"%)`57t* H NH  H V H ,H  H r'