!xjAi<dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlmZddlmZmZdZdZd Zd Zd Zd Zd ZdZdZdZ dZ!dZ"dZ#dZ$e%hdZ&dZ'dZ(dZ)e jTe+e ddzZ,ee-j]j^Z0e0jbdZ2e2dz Z3e3dezz dz Z4e2dz Z5e3dz Z6e6d z Z7e6d!z Z8e6d"z Z9e0d#z Z:e0d$z Z;d%Zed(Z?Gd)d*e@ZAdJd+ZBdKd,ZCdLd-ZDd.d/dMd0ZEdNd1ZFd.d/dOd2ZGdPdQd3ZHdRd4ZIdSd5ZJdTd6ZKdUd7ZLdVd8ZMdWd9ZNdXd:ZOd;ZPdVd<ZQdYdZd=ZRdYdZd>ZSGd?d@ZTd[dAZUd\dBZVd]dCZWd^dDZXd^dEZYd^dFZZd_dGZ[d`dHZ\e]dIk(r e^e\y)azSTask26 invite harness v2: reset-bound absent-ledger initialization and observation.) annotationsN)Path)Any)parse_qsurlparse@2e0894eac92bc396cc4723bf1f18ebc653b95018dd41574df435941c235da925@af4a9d0a1ffffb6eb7551c1d6dc2b32853ca6d024332a4f8f5702bbf992f141b@7ace03c6dad33d2fc3ef223621cbca68a150fde8429932138e252fb8498ac582@3c6a0f24124142fc1b03c350a357d5530aa1a561c4b332e2e6c29a0de74c87e2@e2fbff811e5b0caf4551010c1a47d640bba17febffb951f0525b6ff4dccd71d3@2fb0019a8d9e46cc197f72685a89fc54ca5fb98a52840f41ade5d51f76d86736@7ef0eb8f4b27ab311a11909c25167df9493348d996319d009eec36a0ebf6f146@d2879b128573a9d75a55958d2fa3e1a24be1636f0a7a20affe8f2ef9b94dfd33 8527916639 8693203710dual_coach_pilot_test_bot@23845bda574c085e16b6d316e5e84e54b3bc6db3a8803c6b3b93ed7c4b86b049z0gateway/platforms/telegram_customer_bootstrap.py@145515d5e110dcebb94fcaa554bcee29544b3a75dcfe058fae944ea3b70042b2>ACTIVEFAILEDEXPIRED CANCELLED O_NOFOLLOWz.omo/evidence/task26z"task26-repaired-archive-successor-z.artifacts/hermes_agent-0.17.0-py3-none-any.whlz,.omo/plans/dualcoach-production-readiness.mdz*task26-runbook-rebind-2e0894ea-st_01a0054ez!task26-golden-path-2e0894ea-v5.mdz&task26-recovery-runbook-2e0894ea-v5.mdzrunbook-binding-receipt-v5.jsonzapproval-receipt.jsonzschema-v2.json@6a4249d263db04bea1432ad2393150ed77d3243a1365ed8dbe1eed5c0261df9ezOPERATIONS-v2.md@82099d8a3658a494c3cf13558e43fe7846e7e826cfcdec6c10515f05a697752dz6data/profile-reset-archives/task26-live-reset-2e0894eac eZdZy) HarnessErrorN)__name__ __module__ __qualname__N.omo/evidence/task26/task26-invite-harness-st_01a0056a-v2/invite_harness_v2.pyr!r!:sr&r!cHtj|jSN)hashlibsha256 hexdigest)raws r' sha_bytesr.>s >>#  ( ( **r&cVtj|ddddzjS)NT,:) sort_keys separators ensure_ascii )jsondumpsencode)values r' canonicalr;Bs' JJuRV WZ^ ^ f f hhr&c|j|j|j|j|j|j |j |jfSr))st_devst_inost_modest_nlinkst_uidst_size st_mtime_ns st_ctime_ns)infos r'stablerFFsB KKdllDMM4;; LL$**D,<,< >>r&Tprivatectj|tjtz} tj|}t j |jr0|jdk7s!|jtjk7rtd||r/t j|jdvrtd|g}tj|dx}r*|j|tj|dx}r*t|ttj|k7rtd|dj!|tj"|S#tj"|wxYw)Nzunsafe regular file: >@rzfile is not private: izfile changed during read: r&)osopenO_RDONLYO_FLAGSfstatstatS_ISREGr?r@rAgetuidr!S_IMODEreadappendrFjoinclose)pathrHfdbeforechunkschunks r' read_regularr`Ks) r{{W, -B "||FNN+v!/Cv}}XZXaXaXcGc!6tf=> > t||FNN3;WW!6tf=> > wwr;//e/ MM% wwr;//e/ &>VBHHRL1 1!;D6BC Cxx   sC&E2AE22F c.tt|dS)NFrG)r.r`)r[s r'sha_filerb]s \$6 77r&c tjt||}t |tst d||S#ttjf$r}t d||d}~wwxYw)NrGzinvalid JSON: zJSON root is not an object: )r7loadsr`UnicodeDecodeErrorJSONDecodeErrorr! isinstancedict)r[rHr:excs r' read_jsonrjasq= <g>? eT "9$@AA L  4 4 5=^D623<=s AA/A**A/c^|j}tj|jr@tj|js!|j t jk7rtd|tj|j|k7rtd|y)Nzunsafe directory: zwrong directory mode: ) lstatrSS_ISDIRr?S_ISLNKrArNrUr!rV)r[moderEs r'require_directoryrpks :: {{?@@ r{{RZZ/"));gEu MB "es3x bhhr3vw<0 0Fs3x     sAD/DD1ctttk7r tdt j t5}|j t}dddttk7r td|S#1swY(xYw)Nzwheel hash mismatchz$wheel bootstrap member hash mismatch) rbWHEEL WHEEL_SHA256r!zipfileZipFilerW MODULE_MEMBERr. MODULE_SHA256)archiver-s r'wheel_module_bytesrsa,&011  7ll=) ~&ABB J s A88Bcttfttftt ft tff}|D]+\}}t||k7std|jt}|jdd}tfd|Dr tdtjj!d}|1|j"%tt%|j"t&k7r tddt&ddd S) Nzbound evidence hash mismatch: zutf-8)zself._prepare_paths()z=self.state_dir.mkdir(mode=0o700, parents=True, exist_ok=True)zself._write_unlocked(())z,os.replace(temporary_name, self.ledger_path)zos.fsync(directory)c3&K|]}|v ywr)r%).0fragmentsources r' z$loaded_byte_proof..s H2Gh86 !2Gsz2candidate absent-ledger initializer proof mismatch-gateway.platforms.telegram_customer_bootstrapz2loaded bootstrap bytes differ from candidate wheelPASS)#candidate_absent_ledger_initializerinitializer_source_sha256"atomic_replace_and_directory_fsyncloaded_byte_match)PLAN PLAN_SHA256 GOLDEN_V5GOLDEN_V5_SHA256 RECOVERY_V5RECOVERY_V5_SHA256RUNBOOK_V5_RECEIPTRUNBOOK_V5_RECEIPT_SHA256rbr!namerdecodeany importlibutil find_specoriginrr)pinsr[wantedr-initializer_fragmentsspecrs @r'loaded_byte_proofrs {i)9: (),>@Y+Z D f D>V #!? {KL L  C ZZ F H2G HHOPP >> # #$S TD |t{{*htDKK7H.I].ZOPP/5%2.4#  r&ct|}tttk7r t dtt t k7r t didddtdtdtdtd td td td td tdt dt"dtt$dtdt dtt't(j+}|j-D]'\}}|j/||k7st d|||j/dgvrt d||S)Nzharness schema hash mismatchzoperations hash mismatchschemaz(task26-invite-harness-permission-seal-v2candidate_digest wheel_sha256 plan_sha256golden_runbook_v5_sha256recovery_runbook_v5_sha256runbook_binding_v5_sha256reset_manifest_sha256reset_evidence_digestactor_idowner_idapproval_event_sha256approval_receipt_sha256 schema_sha256operations_sha256harness_sha256zpermission seal mismatch: allowed_modeszmode is not permission sealed: )rjrbSCHEMA SCHEMA_SHA256r! OPERATIONSOPERATIONS_SHA256 CANDIDATErrrrrRESET_MANIFEST_SHA256RESET_EVIDENCE_DIGESTACTOR_IDOWNER_IDAPPROVAL_EVENT_SHA256APPROVAL_RECEIPTr__file__resolveitemsget)r[rosealexpectedkeyrs r' verify_sealrs T?D=(9:: 00566<I   {  #$4  %&8  $%> !6 !6 H H !6 "8,<#=  . (4>#9#9#;.s& I8H*#u8<<  %8Hs!$zreset manifest binding mismatchstatusrmanifest_sha256rpost_reset_empty_baselineTz(reset execution receipt binding mismatch)rrreset_receipt_sha256) RESET_RELATIVErbrr!rjrrrrrrr)profileroot manifest_path receipt_pathreceiptrrs @r' reset_bindingrs ^ #D?*M.(L "779::'H %G%$"0"' H I8H II<== H' ;;( )-B B ;;( )-B B ;;2 34 ?EFF%:%:$,\$: <digestrsessionsrtelegram-customer-bootstrap-v1z$unexpected customer-bootstrap schemarz'customer-bootstrap sessions are invalid)rrFTr0)r5r3r4 allow_nanrz)customer-bootstrap ledger digest mismatch session_idsid_hashz2duplicate or malformed customer-bootstrap identity) rjsetrr!rglistr7r8r9r.rhr{)r[r:rpayloaditemidshashess r'validate_ledgerrsK dOE 5z5589LPp9pABByy$H h %DEEjjE(OJY^#'J%QQWQWQY  yyi00FGG.6 Qhd*T4:P488L !hC Q/7 Rxt:dD;Qdhhz"xF R 3x3x= CCMSX$=S[AQUXY_U`A`OPP L R RsE?E?0FF) customersz gateway.lockzgateway_state.jsonrzstate.dbz.clean_shutdownzdata/customerszdata/owner-actionsz(data/activation-completion-notices.jsonlz$data/customer-activation-audit.jsonlz%data/customer-activation-journal.jsonz%data/customer-activation-receipt.jsonz2data/nutrition-onboarding-projection-journal.jsonlzdata/scheduled-deliveries.jsonlz$data/scheduled-deliveries-fence.jsonzdata/customer-schedule-claimszdata/recovery-auditszdata/activation-readinessc t|t|dz t|}|dz }|js|jr t dt Dcgc]+}||z js||z js*|-}}|rt d|dzt }ddddd d dttk7|d |Scc}w) Ndatadata/onboardingz8absent-ledger baseline requires onboarding parent absentz)unexpected post-reset sibling authority: rrRESET_BOUND_LEDGER_ABSENTFT) rbaselineledger_presentprior_session_countall_prior_sessions_terminalsibling_authorities_cleannearest_stable_parentactor_not_owner_staffr) rprexistsrvr!CLEARED_SIBLINGSrrr)rbinding onboardingrelativepresentproofs r'absent_baselinersgg&'G$G,,Jj335UVV(8(8HWx=O.(s B488G H ,s!#z#nonterminal prior bootstrap sessionc3dK|](}|jdxs|jd*yw) role_claimsrecovery_attemptsNrr s r'rz$existing_baseline..*s. YPX488M " Cdhh/B&C CPXs.0z#open prior claim/recovery authorityc3K|]<}t|jdtxr|djdk(>yw)customer_draft customer_keyN)rgrrh)rrrs r'rz$existing_baseline..,sJ(D 488,-t4s>N9O9S9STb9cgs9sssAAzcustomer key is not newrAUTHENTICATED_LEDGER_PRESENTT)rrrrrr)rprrrtiterdirrr!rvis_filerSrArNrUr?rr{r)rrr[ledgerrrrs ` r'existing_baselinersngg&' ' "D T "F KKEe#mmo.od o.=-2PPIJJ  ?? DLLNdiik6H6HBIIK6W[_[d[d[f[n[nqv[vz[NO O j!H B BB@AA YPX YY@AAC((%455 f2P&*3x=37N_Nac cc/sF ct|}|js|jr t||St |}dgdd|fS)Nr)rrr)rrrvrr)rrr[results r' preflightr6sI ' "D {{}) ,77 W %F6BRV WY_ __r&c$eZdZddZddZddZy)Inotifyctjdd}|jtj|_|j dkrt tjd|j|j tj|ttztz}|dkrBtj}tj|j t |d|y)NT) use_errnor inotify_init1zinotify_add_watch:)ctypesCDLLrrN O_CLOEXECr\OSError get_errnoinotify_add_watchfsencode IN_CREATE IN_MOVED_TOIN_CLOSE_WRITErZ)self directorylibcwatcherrors r'__init__zInotify.__init__?s{{440$$R\\2 77Q;&**,o> >&&tww I0F T_H_bpHpq 19$$&E HHTWW %#5i[!AB B r&cBtj|jyr))rNrZr\)r(s r'rZz Inotify.closeJs r&c Ltj|z}d} |tjz }|dkr|dk(r tdtj|jggg|dk(r t d|nd\}}}|s|r|Stdt j|jd}d} | dzt|kratjd|| \} } } } || dz| dz| zjddd}| d| zz } ||k(r|dz }| dzt|kra ) Nrz bounded filesystem event timeoutgiiIIIrJ) time monotonicr!selectr\maxrNrWr{struct unpack_fromsplit)r(rtimeoutdeadlinecount remainingreadable_rr~_watch_mask_cookielengthobserveds r'await_name_countzInotify.await_name_countMs9>>#g- 4>>#33IA~%1*"#EFF#]]DGG9b"UZ^_U_c#y>QehiNHa L"#EFFggdggu-GF2+W-171C1CFGU[1\.w"6B;v{V/CDJJ5RSTUVW"v+%t#QJE 2+W-r&N)r)rreturnNone)rFrG)rbytesr:floatrFint)r"r#r$r-rZrEr%r&r'rr>s Cr&rcrtjd}|j|j|jfS)Nr)r import_moduleRoomBootstrapStoreload_customer_draftroom_bootstrap_state_dir)modules r' import_apirQcs2  $ $%T UF  $ $f&@&@&BaBa aar&c \d|d|tttttt t dd S)Nztask26-invite-harness-v2-z -receipt-v1z1redacted; no raw invite token or customer content) rrorrrrrrrprivacy)rrrrrrrros r' base_receiptrUhs1-dV;?%|T_$4&8!6QfF  r&cf t|j\}}it||dddt|dd}|dr!t t |j|d<t|j||S#t tf$r'}it|dt|dd d }Yd}~Id}~wwxYw) NrrTr)r mutationsready_for_one_inviteledger_session_countr ledger_sha256FAILF)rblockerrWrX) rrrUr{rbrr!r!strrr)argsrorrrris r' read_moder_ssB"4<<0b\$'b6bVRS+/VT^M_I`b " #'/t||0L'MGO $DLL'* N ' "BB\$'B6c#h !5BBsA A::B0 B++B0c |jjs|jjr tdt \}}}||j }t |j|j\}}|d }|r|jdz nt|jj}|rdnd} t|} |rE|jdz js|jdz jr td|||j} | j|tt} | j!| d } | j#| d k7r td t|j}t%|}|j}t'|jdz d t'||j)Dchc]}|j*c}ddhk7r td|j)D]M}|js1|j-r!|j/j0dzdk7sDtdt3|dt3|dd zk7r td|dDcgc]-}|j5d| j6j8k(s,|/}}t3|d k7s.|dj5ddk7s|dj5dd k7r tdt;t=| j>j@dj5d}tC|tDr"t3|d k7s|djGds td |d}| j6jHtK|d!djMd"k7r td#d$| j6j8|| j>| jNjQtRd%}tU|j|itWd&id'd(d)|d*d+|rdnd,d-dd.|r| ndd/|s| ndd0d d1d d2|rd3nd d4dd| j6j8d5tK| j6j8jMd6| j6jHd7tK|jMdddd d8tY|tY|jd9t[|jgd:}tU|j||j\rg}t_d;|j\jad<DD]=} |jMtc|vr|je|jg?||jjggk7r td=|S#| j#wxYwcc}wcc}w#tthf$rYwxYw)>Nzone-use output already existsrrs onboarding ledger.jsonrz5onboarding authority race appeared after subscription) bot_usernamerg@rJz;expected exactly one watched authority creation/write eventirTrrz'unexpected candidate initializer outputrrLz/candidate initializer output mode/type mismatchrz1prepare did not establish exactly one new sessionrrrPREPARED generationz>new session is not exactly one generation-1 PREPARED authorityT)strict_parsingstartrc1_z$candidate private handoff is invalidasciizcandidate SID hash mismatchz task26-private-invite-handoff-v2)rr start_token customer_link expires_atrpreparer PASS_PREPAREDbaseline_beforer watch_rootr%event_subscription_before_initializeronboarding_create_event_countledger_write_event_count!candidate_initializer_invocationsprepare_invocations1final_ledger_publications_expected_from_candidate/atomic_replace_and_directory_fsync_source_proofsession_id_sha256rstart_token_sha256rZ0600)handoff_sha256 handoff_moderaw_token_locationsc3dK|](}|js|jr%|*ywr))rrvr s r'rzprepare..s'v,IDT\\^dhdsdsdu4,Is 000*z)raw token escaped the one private handoff)5handoffrrr!rQdraftrrrrrtrrv!prepare_rehearsal_customer_invite BOT_USERNAMErrErZrrprrrrSr?r{rsessionrrrrkqueryrgr startswithrr.r9rl isoformatrrrUrbr] evidence_rootsortedrglobr`rXrPermissionError)r^Store load_draft state_dir_forrr]rabsentrp event_namer+storeprepared event_count ledger_pathafterrrnewtokenstokenrr locationsr[s r'rmrms || 3 3 5:;;'1|$E:} tzz "Et||U-?-?@NFF() )F*0&nT\\6R6Y6YJ"(nJ J E  '88@@Bt||VgGgFsFsFuVW WmDLL12::5|fn:o,,Z=  aXYY .K K (E   Edll%66UCe#mmo.od o.=-2PPDEE  ?? DLLNdiik6I6IE6QUZ6ZPQ Q  5 VJ%7!81!<<NOO!*- g-D,1G8K[K[KfKf1f4-C g 3x1}A 7+z9SVZZ =UYZ=Z[\\ hx556<.>w.G$HH899;8K[K[KfKf#h6L6L%00::<(TGDLL'* y !#+_>OQWXbQcf,L 0 (A  #vK1  ,Q  1Fq  <&Qa :4 h&&11 Yx'7'7'B'B'I'I'KL H$$--0DYu||~E^ *1/>x ?T#4<<0& #DLL 12G DLL'*  vD,>,>,D,DS,IvvD <<>\$%77$$T\\^4w --/0 0JK K Nu  / hH!/2  s1 B WW%-W*W*):W/W"/XXc tttj}|dDcgc]#}|j dj k(s"|%}}t |dk7s8|dj djk7s|dj ddk7r tdttjj}itd d d tj jjd }tj|j ?t#j$j d t#j&j  |j)dj*}|j'|dk7r tdttj}t-fd|dD}|j d}t/|t0rt |dk7r td|d} | j dt2k7s,| j dt2k7s| j ddk7r tditdddt2d j j|j dt5tjdddd } tj6| | Scc}w#|j'wxYw)NrrrJrrrrcz-observe requires exact clean PREPARED bindingz observe-readyREADYT)revent_subscription_before_claimryr1raz2duplicate claim ledger writes observed at boundaryc3`K|]%}|jdjk(s"|'yw)rN)rrroner^s r'rzobserve..s(]0CGGL4IT__4\0s#..r z%accepted claim cardinality is not oneuser_idchat_idtopic_id0z,accepted claim is not exact actor private DMobservePASS_CLAIM_OBSERVEDF) raccepted_start_claim_countr private_dmrrrrZraw_getUpdatesdrop_pending_updates cursor_edits)rrrrrrr{rr!rrtrUr.r9rreadyready_fdrNr|rZrEtimeout_secondsnextrgrrrbr) r^rrmatchesr+rr<rclaimsclaimrs ` r'rrs ^DLL9 :F &z 2` 2dhh|6LPTP_P_6_t 2G` 7|qGAJNN:6$--G7ST:>>ZaKbfpKpJKK N4<<077 8E b|O, bdh"+DOO,B,B,D"ESWS`S` bEDJJ& }}  % &&~t7K7KL  zOPP N4<<8 9E ]uZ0] ]D XXm $F fd #s6{a'7BCC 1IE yyx'599Y+?8+KuyyYcOdhkOkIJJ^i(^4Iij#4t==488G3DW_`noso{o{`|W}!&W\^GDLL'* N;a  s#K*K*5K//Lc t\}}}ttj}|dDcgc]#}|j dj k(s"|%}}t |dk7s8|dj djk7s|dj ddk7r tdtjtd jj|dd jkr td ||jj}tfd |D}|j j"d k7r tdit%ddddj jd t'tjd}t)j*||Scc}w)NrrrJrrrrczexpiry binding mismatchdatetimerlz.canonical expiry unavailable before expires_atc3VK|] }|jjk(s|"ywr))rrs r'rzexpire..s!Mx3>>T__+Lxs))rzcanonical expiry failedexpire PASS_EXPIREDz!RoomBootstrapStore.expire_unbound)r canonical_apiexpire_invocationsrrrrZ)rQrrrrrr{rr!r3 __import__r fromisoformat timestampexpire_unboundrrr:rUrbrr) r^r_loadrrrrrrs ` r'rrs",,E5- ^DLL9 :F &z 2` 2dhh|6LPTP_P_6_t 2G` 7|qGAJNN:6$--G7ST:>>ZaKbfpKp455 yy{Z +44BB71:lC[\ffhhKLL]4<<01@@BH MxM MD zz9$455\h'\>Tw%&dooSWS`S`!H^DLL=Y4Z\GDLL'* Nas #GGctjt}|jdd}dD]}|j |}|j dt d|j dt d|j d t d|d k(rG|j d t d|j d t d|j d t |dvr&|j dd|j dd|dk(s|j dt d|j dtd|j dt"|S)N) descriptionroT)destrequired)dry-runverifyrmrrz --profile)typerz --permissionz --receiptrmz--draftz --handoffz--evidence-root)r>rrz --session-id)rz --sid-hashrz--readyz--timeout-secondsg^@)rdefaultz --ready-fd) argparseArgumentParser__doc__add_subparsers add_parser add_argumentrrIrJ)rsubrcommands r'parserrsA  $ $ 9F   Vd  ;CE..&[tdC^$F[tdC 9    E  4$ G  !2 > ( (  $ ?   = 9    E  !45% P  C 8F Mr&c tj} t|j|j|jdvrt ||j}n$t ttd|j|}tjjjt|j|dt|jd|ddk(rdSdS#t t"t$t&t(t*j,f$r-}tj.jd|d Yd}~yd}~wwxYw) N>rr)rmrrr)rorrr[rwrzFAIL: r6)r parse_argsr permissionror_rmrrsysstdoutbufferr|r;r]rr!r! ValueErrorKeyError StopIterationr BadZipFilestderr)r^rris r'mainrs 8   D DOOTYY/ 99- -tTYY/F!(WOPTPYPYZ[_`F  499xHXehimiuiuev*w xy8$.q5A5 ':xHZHZ [ 6#b)*sCC%#C%%-D?#D::D?__main__)r-rHrFr])r:rrFrH)rEzos.stat_resultrFztuple[int, ...])r[rrHboolrFrH)r[rrFr])r[rrHrrFdict[str, Any])rM)r[rrorJrFrG)r[rr:rrFrG)rFrH)rFzdict[str, str])r[rror]rFr)rrrFr)rrrFr)r[rrFrr))rrrz str | NonerFz%tuple[dict[str, Any], dict[str, Any]])rFztuple[Any, Any, Any])ror]rFr)r^argparse.Namespaceror]rFr)r^rrFr)rFzargparse.ArgumentParser)rFrJ)_r __future__rrrr*rimportlib.utilr7rNr5rSr7rr3rpathlibrtypingr urllib.parserrrrrrrrrrrrrrrr frozensetr r'r&r%r getattrrQrrrtHERErrROOTEVIDENCErr RUNBOOK_ROOTrrrrrrrrr RuntimeErrorr!r.r;rFr`rbrjrprrrrrrrrrrrrrQrUr_rmrrrrr" SystemExitr%r&r'rs9Y"  + N Q P UW^ZZ  * ZB R A B  ,,\15 5 H~&& ||A ( (89DEHxx <<FF > > EE !$EE11  R & & VNO < +i> 15$8.2<  <@<:R$&c6`""Jb  K\ F&,  z TV r&