rPj(dZddlZddlmZmZmZddlZddlmZddl m Z ddl m Z m Z mZmZmZmZddlmZmZdd lmZeee d Zej0d eDcic]}||c}e ZeeZej0d eDcic]}||c}e Zdeedee fdZdeedzdedzdedzdeeefdzfdZ edZ!e!jEdgd dJdeddfdZ#e!jEddg dJdeeedfdeddfd Z$e!jEd!gd" dKd#eeeed$d%fd&eedzed'fdeedzed(d)fd*eeedzed+d,fd-eedzed.fde de deddfd/Z%e!jEd0gd1 dLdeeed2fd&eedzed3fdeedzed(d4fd#eeedzed$d5fd*eeedzed+d6fd-eedzed7fde de deddfd8Z&e!jEd9d:g dJdeeed;fdeddfd<Z'e!jEd=d>g dJdeeed?fdeddfd@Z(e!jEdAdBdCg dMdeeedDfdEee)edFdGdHfdeddfdIZ*ycc}wcc}w)Nz=Contains commands to manage webhooks on the Hugging Face Hub.N) Annotatedget_argsget_type_hints)WEBHOOK_DOMAIN_T)WebhookWatchedItem)SecretsFileOpt SecretsOptTokenOpt get_hf_api parse_env_map typer_factory)ArgumentOption)outtypeWatchedItemType)r WebhookDomainvaluesreturnc Tg}tt}|D]}d|vr+tjd|ddj |d|j dd\}}||vr+tjd|ddj |d|j t|||S) aYParse 'type:name' strings into WebhookWatchedItem objects. Args: values: List of strings in the format 'type:name' (e.g., 'model:bert-base-uncased', 'org:HuggingFace'). Returns: List of WebhookWatchedItem objects. Raises: click.BadParameter: If any value doesn't match the expected format. :zCExpected format 'type:name' (e.g. 'model:bert-base-uncased'), got 'z'. Valid types: z, .rzInvalid type ')rname)tuple_WATCHED_TYPESclick BadParameterjoinsplitappendr)ritems valid_typesvkindrs a/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/huggingface_hub/cli/webhooks.py _parse_watchr',s E'K  ? a<$$UVWUXY!!%;!7 8; WWS!_ d { "$$~dV;KDIIVaLbKccd%ef f 'T=> ? Lsecrets secrets_filejob_idct||}|sy|tjd|jDcic] \}}||xsdc}}Scc}}w)z^Parse `--secrets` / `--secrets-file` for the Job triggered by a webhook (requires `--job-id`).Nz.--secrets and --secrets-file require --job-id.)r rrr")r)r*r+ secrets_mapkeyvalues r&_parse_job_secretsr1HsW 6K  ~  !QRR/:/@/@/B CeC"  CC CsAzManage webhooks on the Hub.)helpz list | ls)zhf webhooks lszhf webhooks ls --format jsonzhf webhooks ls --format quiet)examplestokencpt|}|jDcgc]o}|j|jxsd|j|j xsg|j xsgDcgc]}|jd|jc}dq}}}tj|ycc}wcc}}w)z'List all webhooks for the current user.r4z(job)r)idurldisableddomainswatchedN) r list_webhooksr7r8r9r:r;rrrtable)r4apiwwiresultss r& webhooks_lsrBWs 5 !C""$   $$55#G yyB:;))/rK2277)1RWWI.K   G IIg L sA B2+"B- B2-B2infozhf webhooks info abc123 webhook_idzThe ID of the webhook.cht|}|j|}tj|y)z'Show full details for a single webhook.r6N)r get_webhookrdictrDr4r>webhooks r& webhooks_inforJqs( 5 !Cooj)GHHWr(create)zQhf webhooks create --url https://example.com/hook --watch model:bert-base-uncasedzjhf webhooks create --url https://example.com/hook --watch org:HuggingFace --watch model:gpt2 --domain repozJhf webhooks create --job-id 687f911eaea852de79c4a50a --watch user:julien-czghf webhooks create --job-id 687f911eaea852de79c4a50a --watch bucket:my-org/my-bucket --secrets HF_TOKENwatchz--watchzRItem to watch, in 'type:name' format (e.g. 'model:bert-base-uncased'). Repeatable.r8zBURL to send webhook payloads to. Mutually exclusive with --job-id.z--job-idz]ID of a Job to trigger (from job.id) instead of pinging a URL. Mutually exclusive with --url.domainz--domainzMDomain to watch: 'repo' or 'discussion'. Repeatable. Defaults to all domains.secretz.Optional secret used to sign webhook payloads.cf||tjd||tjdt|||}t|} t |} |r|D cgc]} | j c} nd} | j ||| | ||} tjd| jycc} w)zCreate a new webhook. Provide either --url (to ping a remote server) or --job-id (to trigger a Job), but not both. The source Job's secrets are not copied to the webhook: pass them again with --secrets / --secrets-file. N+Provide either --url or --job-id, not both.z!Provide either --url or --job-id.r6r8r+r;r:rNr)zWebhook createdr7) rrr1r r'r0create_webhookrresultr7)rLr8r+rMrNr)r*r4 job_secretsr> watched_itemsdr:rIs r&webhooks_createrXs` 6-  !NOO {v~  !DEE$WlFCK 5 !C 'M+1'1qww'tG   !GJJ WZZ0(sB.update)z8hf webhooks update abc123 --url https://new-url.com/hookz:hf webhooks update abc123 --watch model:gpt2 --domain repoz,hf webhooks update abc123 --secret newsecretzNhf webhooks update abc123 --job-id 687f911eaea852de79c4a50a --secrets HF_TOKENz The ID of the webhook to update.z$New URL to send webhook payloads to.zcID of the source Job to trigger (can be the current one). Required with --secrets / --secrets-file.ziNew list of items to watch, in 'type:name' format. Repeatable. Replaces the entire existing watched list.zANew list of domains to watch: 'repo' or 'discussion'. Repeatable.z)New secret used to sign webhook payloads.c >||tjdt|||} t|} |r t |nd} |r|D cgc]} | j c} nd} | j |||| | || }tjd|jycc} w)zUpdate an existing webhook. Only provided options are changed. Job secrets passed with --secrets replace stored values with the same name; others are kept. NrPr6rQzWebhook updatedrR) rrr1r r'r0update_webhookrrTr7)rDr8r+rLrMrNr)r*r4rUr>rVrWr:rIs r&webhooks_updater\sf 6-  !NOO$WlFCK 5 !C+0L'dM+1'1qww'tG   !GJJ WZZ0(sBenablezhf webhooks enable abc123z The ID of the webhook to enable.ct|}|j|}tjd|jy)zEnable a disabled webhook.r6zWebhook enabledrRN)r enable_webhookrrTr7rHs r&webhooks_enabler` s1 5 !C  ,GJJ WZZ0r(disablezhf webhooks disable abc123z!The ID of the webhook to disable.ct|}|j|}tjd|jy)zDisable an active webhook.r6zWebhook disabledrRN)r disable_webhookrrTr7rHs r&webhooks_disablerds1 5 !C!!*-GJJ!gjj1r(deletezhf webhooks delete abc123zhf webhooks delete abc123 --yesz The ID of the webhook to delete.yesz--yesz-yzSkip confirmation prompt.ctjd|d|t|}|j|tjd|y)zDelete a webhook permanently.z)Are you sure you want to delete webhook 'z'?)rfr6zWebhook deletedrRN)rconfirmr delete_webhookrT)rDrfr4r>s r&webhooks_deleterj)sD(KK;Jr{sD 66 65).);'?8 D #Y  D-04Z DADt D #s(^d D"?@   $ !#x-EFFG     (    #'A71  S  e   71  d XY [ 71  d  p   71&  ]d" `   '714  d DE G 571<=71>!?71@ A71B C7171t      #'I91#x-OPPQ91  d :; = 91  d  v    91  S D I   91.  ]d" T   /91<  d ?@ B =91DE91F!G91H I91J K9191x #1#x-OPPQ1 1 1  1 $2#x-PQQR2 2 2  2 #) 1#x-OPPQ1    ,   1 1 11U0N,Is ! K( K-