je3Z4Gd?d@e4Z5edABGdCdDZ6dbdEZ7dcdFZ8dddGZ9dedHZ:dedIZ;dfdJZdidMZ?djdNZ@dAdOdkdPZAdldQZBdmdRZCdndSZDdodTZEdpdUZFGdVdWZGdqdXZHdrdYZIdsdZZJdtd[ZKdud\ZLdvd]ZMdwd^ZNdxd_ZOdydzd`ZPeQdak(r eRePy){zCEvent-first observer for the exact Task26 replacement consent card.) annotationsN) dataclass)Path)Finalcast@2e0894eac92bc396cc4723bf1f18ebc653b95018dd41574df435941c235da925r CANDIDATE@af4a9d0a1ffffb6eb7551c1d6dc2b32853ca6d024332a4f8f5702bbf992f141bWHEEL@d816dbbd6a27d5826b251d279a9831de096ef7cd79b5fd131ceff7253b7369bePLAN@8416cd7c83cab5540af2e1e01dbcc5b1bdfd49a59d8ef21ea49512c28d749218 GOLDEN_V6@a2e15845764e7041957ae4518096fe73f87ec35b57021980cdd4df3ea18ac00d RECOVERY_V6cb_PCczfFXoI4GjvCxLBs1oRA SESSION_ID@53b4f95b5b4db9a611128976a7b951bbe22d9619e05b2ff07fadf5b02f9a5380SID_HASH%task26_live_2e_r2_20260815_8527916639 CUSTOMER_KEY 8527916639ACTOR_IDCHAT_ID0TOPIC_ID158CLAIM_MESSAGE_ID159CARD_MESSAGE_ID 8693203710OWNER_ID@5e3067fe3c865224fc73ff5a9a65058c87960f05d9af53bddccaf6f32dc83939CONSENT_RECEIPT_SHA256z:data/onboarding/telegram-customer-bootstrap-v1/ledger.jsonLEDGER_RELATIVEzcustomers/registry.jsonREGISTRY_RELATIVEz(task26-consent-stage-observer-receipt-v1SCHEMA@b41060dea28eb3bbb83217068f5218d5df2c879dba00e73c9ca4e577a6049dad@145515d5e110dcebb94fcaa554bcee29544b3a75dcfe058fae944ea3b70042b2@07f868adf9fe0565e6eac89fd76b09601adea315e2a122a09ee748614d912c2f)zgateway/platforms/telegram.pyz0gateway/platforms/telegram_customer_bootstrap.pyz'gateway/platforms/nutrition_coaching.pyRUNTIME_HASHESzK/home/cube/projects/richard/hermes-agent/.venv/lib/python3.12/site-packages VENV_SITE@fe4a8725be379e47b1b2fab3029147705d7def887d94af747e5057c93322c40f@d1f848d1fa8bc71e018f45c83e8e19e93671dfa83157d3feff15b8f7ec0f1d8a)z3workspace/checkin_cli/checkin_cli/customer_admin.pyz9workspace/checkin_cli/checkin_cli/nutrition_onboarding.pyPROFILE_MODULE_HASHESi@iiIIIii O_NOFOLLOWceZdZdZy) ObserverErrorz'Fail-closed consent observer violation.N__name__ __module__ __qualname____doc__L.omo/evidence/task26/task26-consent-observer-st_01a007da/consent_observer.pyr4r4:s1r;r4ceZdZdZy)ObserverTimeoutzBounded event wait expired.Nr5r:r;r<r>r>>s%r;r>T)frozencJeZdZUded<ded<ded<ded<ded<ded<y ) Baselinedict[str, object]registryledgersessionstrregistry_sha256 ledger_sha256expected_consent_receipt_sha256N)r6r7r8__annotations__r:r;r<rArABs&  %((r;rAcRtj|ddddjS)NFT),:) ensure_ascii sort_keys separators allow_nan)jsondumpsencodevalues r<canonical_bytesrWLs# ::e%4Jbg h o o qqr;cZtjt|jSN)hashlibsha256rW hexdigestrUs r< digest_jsonr]Ps >>/%0 1 ; ; ==r;cdtj|jjSrY)rZr[ read_bytesr\)paths r< sha256_fileraTs! >>$//+ , 6 6 88r;c|jrt|d|j}tj|jr0|j t jk7s|jdk7rt|dtj|jtk7rt|dy)N is a symlinkz# is not one owner-held regular filez is not private 0600) is_symlinkr4statS_ISREGst_modest_uidosgetuidst_nlinkS_IMODE PRIVATE_FILEr`labelinfos r<_private_regularrrXs ug]344 99;D << % )Ct}}XYGYug%HIJJ ||DLL!\1ug%9:;;2r;cd|jrt|d|j}tj|jr!|j t jk7rt|dtj|jtk7rt|dy)Nrcz is not an owner-held directoryz is not private 0700) rer4rfS_ISDIRrhrirjrkrm PRIVATE_DIRros r< _private_dirrvbs ug]344 99;D << % )Cug%DEFF ||DLL![0ug%9:;;1r;ct||tj|tjtjzt z} tj |}tj||jdz}t||jk7s|jdkDrt|d tj| tj|}t!|t"st|d|t%j&|j)fS#tj|wxYw#ttjf$r}t|d|d}~wwxYw)Nrdiz changed during stable readz is invalid JSONz is not a JSON object)rrrjopenO_RDONLY O_CLOEXECr2fstatreadst_sizelenr4closerRloadsUnicodeDecodeErrorJSONDecodeError isinstancedictrZr[r\)r`rpfdrqrawrVexcs r< _load_jsonrls,T5! r{{R\\1J> ?Bxx|ggb$,,*+ s8t|| #t||6F'F5')D EF F(G  A 3 eT "ug%:;<< '..%//1 11    4 4 5Aug%567S@As% A-D&E&D=E-E((E-ct|hdk7s|jddk7r td|jd}t|tr#|jdt |d|dk7r td|Dcgc].}t|t s|jd tk(s-|0}}t|d k7r td |d Scc}w) N>digestschemasessionsrztelegram-customer-bootstrap-v1zbootstrap ledger schema driftrrrrzbootstrap ledger digest drift session_idrdz&exact bootstrap session is unavailabler) setgetr4rlistr]rrr~)rDrowsrowmatchess r<_sessionrs 6{66&**X:NRr:r;<< ::j !D dD !VZZ%9[TZ[cTdrvIw=x%x;<<"ddsjd&; @UYc@csdGd 7|qDEE 1:esCC2Cc|jd}t|ts td|Dcgc].}t|ts|jdt k(s-|0}}t |dk7r td|dScc}w)N customerszregistry schema drift customer_keyrdz&exact registry customer is unavailabler)rrrr4rrr~)rCrrrs r< _customerrs| [)I i &344'mis:c4+@SWW^E\`lElsiGm 7|qDEE 1:nsBB Bc ZtddttttdddS)N privacy-v1)chat_idtopic_idcustomer_user_idconsent_card_message_idbootstrap_generationnotice_version)r]intrr r:r;r<_expected_receipt_digestrs/ M#&#7 !&  r;ctjD](\}}tt|z |k7st d|t jD]$\}}t||z |k7st d|y)Nzloaded runtime hash drift: zprofile authority hash drift: )r+itemsrar,r4r/)profilerelativeexpecteds r<validate_runtimers~,224( y8+ , 8"=hZ HI I5499;( w) *h 6"@ KL L@RSFK 6 C GG$ %E eT "DEE X'"2BD EE  x' 99^ $ 4 99' (H 4 777 1 1 77< A % 77: ( * 77= !U * 770 1Q 6 77, - @ 77& '2 - 77> " .PQQ"H WX(X[!\\ << "% / << #8]e'f f <</ 0VZnr4s sUVV')H))HII Hfc=+x PPr;ct|t|}}ttttft j t j|}|jd}t|ts tdd|jddd|d<t|tr|jdnd}t|trt|dk7r tdt j t j|}td t|d D}||d |<||k7r td |S) Nrz"registry consent commit is invalidTrrr z'registry consent commit date is invalidc3XK|]"\}}|jdtk(s|$yw)rN)rr.0irs r< z/validate_registry_transition..s)v!Jvq#cggVdNeiuNu!J **rz6registry changed beyond exact privacy-v1 consent grant)rrrrFobjectrRrrSrrr4r~next enumerate) beforeafter old_customer new_customerrconsentrecordedexpected_registryindexs r<validate_registry_transitionrs!*6!2Ie4D,LDf%tzz$**\2J'KLH67G gt $@AA M(B&)H $%.8-Fw{{=)DH h $H (;EFF 4::f#56 v+<[+I!Jv vE,4k"5) !!TUU Or;c,t|t|}}tjtj|}|j ddd|j ddt |j dtr||k(r td||k7r tdtjtj|}|d}tdt|D}|||<t|d |d |d <||k7r td |S) NAWAITING_ACTIVATIONr updated_at)rrrrz-bootstrap consent commit timestamp is invalidzBbootstrap transition is not exact generation 4 to 5 consent commitrc3XK|]"\}}|jdtk(s|$yw)rN)rrrs r<rz-validate_ledger_transition..s%Xvq#CGGL4IZ4Wrrrrz5bootstrap ledger changed beyond exact consent session) rrRrrSupdaterrrFr4rrr])rroldnewrexpected_ledgerrrs r<validate_ledger_transitionrs%Czz$**S/*H OO&a#'sww|7L cggl+S 1SCZKLL h`aajjF!34O : &D X4X XEDK +x7P^b,c dOH STT Jr;ctjdd}|jtjtj z}|dkr t dtjt|S)NT use_errnorzinotify_init1 failed: errno ) ctypesCDLL inotify_init1rjrz O_NONBLOCKr4 get_errnor)libcrs r< _inotify_initrs\ ;;tt ,D  BLL2==8 9B Av:6;K;K;M:NOPP r7Nr;ctjdd}|j|tj|t }|dkr t dtjt|S)NTrrz inotify_add_watch failed: errno ) rrinotify_add_watchrjfsencode IN_MOVED_TOr4rr)rr`rwatchs r< _add_watchrs] ;;tt ,D  " "2r{{4'8+ FE qy>v?O?O?Q>RSTT u:r;cg}d}|tjzt|krtj||\}}}}|tjz }||||zj dddj dd}||z }|t zr td|tzr td|j|||f|tjzt|kr|S)Nrrdzutf-8strictzinotify queue overflowzauthority watch invalidated) EVENTsizer~ unpack_fromsplitdecode IN_Q_OVERFLOWr4 IN_IGNOREDappend)rresultoffsetrmask_cookielengthnames r<_eventsr s F F 5:: S )','8'8f'E$tWf%**6&6/*00:1=DDWhW& -  89 9 *  => > udD)* 5:: S ) Mr;c,eZdZddZddZddZd dZy) ConsentWatcherct|j|_||_d|_d|_d|_d|_y)N)rrrrregistry_watch ledger_watchbaseline)selfrrs r<__init__zConsentWatcher.__init__ s6( . )- r;cvt|_t|j|jtz j |_t|j|jtz j |_t|j|j|_ tj|jd}t|D]M\}}}||f|j tj f|jtj fhvsDt#d|jS#t$rd}YtwxYw)Nrr;z.authority changed across subscription baseline)rrrrr&rrr%rrrrrjr|BlockingIOErrorr r r4)rqueuedr_maskr s r<armzConsentWatcher.arm(s/(4<selectr rjr|rr&r rrrCrrr%rrDr)rtimeoutdeadline registry_seenrregistry_after_hashselector remainingreadyrrr rledger_after_hashrs r<waitzConsentWatcher.wait7s ==  78 8>>#g-   ,,.$''9#7#78 $t~~'77 >)*NOO  2)*NOO*1"''$''52I*J&E5$ 3 33@Q@V@V8V5? O`@`bu5v22 DMM$:$::}$&B4==CYCY[`&a (, $"3"33@T@T8T,"/0k"ll3=dll_>\^p3q0089M9MuU*C1DFWWW NN +K* NN s 4DG8<G8AG85G88H cp|jdk\r'tj|jd|_yy)Nrr)rrjr)rs r<rzConsentWatcher.closeXs) 77a< HHTWW DG r;N)rrrboolreturnNone)r0rA)r%floatr0z'tuple[str, dict[str, object], str, str])r0r1)r6r7r8rrr-rr:r;r<rrs. Br;rc>tttttddS)N) golden_v6 recovery_v6) candidate wheel_sha256 plan_sha256runbook_sha256)r r r rrr:r;r<bindingsr:^s"E$,5kR TTr;c \tttttt t tddd S)N!canonical_customer_consent_acceptr) actor_idrrrclaim_message_idrrractionr)rrrr rrrrr:r;r<callback_authorityr@cs' W()?O$(L9\ [[r;cv|j}t|jdtjtj ztj ztjztz}tj||t} t|dz}tj||tj|tjtj |j"tk7r t%d tj&|y#tj&|wxYw)Nzreceipt parent zreceipt mode drift)rrvrrjO_WRONLYO_CREATO_EXCLrzr2rxrnrWwritefsyncrfrmr{rhr4r)r`rVflagsrrs r< _secure_writerIjs <<>D./ KK"** $ryy 02<< ?* LE ul +Be$u, S  << ,, - = 45 5 >   s A=D!!D8cr|5tj|t|tj|yyrY)rjrFrWr)rrVs r< _ready_wirerKys* ~ _U+,  r;c tdddtt|j|j|j ddddd S) NREADY_BEFORE_CONSENTz)inotify-established-before-human-callbackrr)rGbootstrap_ledger_sha256bootstrap_staterz!no-raw-update-no-token-no-network) rstatusevent_subscriptionsafe_window_secondsr:r@rIrprivacy)r'r:r@rIrGrH)rs r< ready_receiptrUsN(>"M#'XZ"4"6/7/W/W,4,D,D4<4J4J,>XY[; <.sJ4<<>ts*)sortedrglobrrF relative_torar])rootvaluesr`s r< tree_digestr`sV FJ 3JJ s4++D12K4EFGK v r;c t|j|j } |j}t |}|j dk(r(t |j|||jSt |j|t|j|tt|jd|j|j \}}}}t"ddt%t'd|d|j)d du|||j*d d d }t |j|||jS#|jwxYw) Nrarm-onlyT)flushPASS_CONSENT_COMMITTEDzinotify-before-human-callbackzgranted/privacy-v1z+AWAITING_CONSENT:g4->AWAITING_ACTIVATION:g5r)registry_consentrbootstrap_transitionconsent_card_retiredregistry_sha256_afterbootstrap_ledger_sha256_afterconsent_receipt_sha256z*redacted-no-raw-update-no-token-no-network)rrQrRr:r@commitrT)rrskip_runtime_hashesrrUmoderIreceiptrr+rKready_fdprintrWrr-r%r'r:r@rrI) argswatcherrr+rrregistry_after ledger_afterrns r<runrus'T\\t?W?W;WXG;;=h' 99 " $,, .&  % djj%(DMM5) oe$++-T:9@dll9S6 S.,06BZ)H'zASAU2F-86c69gg>W6X\`6`7E?K8@8`8` bK &L dllG,  sAE6CEE!cztjt}|jdd}|j d}|j dt d|j dt d|j d d tj |j d }|j dt d|j d t d|j dt d|j dtd|j dt|j d d tj |S)N) descriptionrmT)destrequiredrbz --profile)typeryz --receiptz--skip-runtime-hashes store_true)r?helpobservez--readyz --timeoutz --ready-fd)rz) argparseArgumentParserr9add_subparsers add_parser add_argumentrSUPPRESSr2r)rsubrr}s r<parserrs  $ $ 9F   Vd  ;C .. $C[td;[td;,\HYHYZnnY'G 4$? = 4$? 54@ C0 0HL]L]^ Mr;ctj|} |jdk(r)|jdks|jdkDr t dt |}tt|jy#t $r(}td|tjYd}~yd}~wttttf$r(}td|tjYd}~yd}~wwxYw) Nr}rrNztimeout must be in (0, 1800]zFAIL: )file)r parse_argsrmr%r4rur>rpsysstderrOSError ValueErrorKeyErrorrWr)argvrqrnrs r<mainrs 8  t $D  99 !t||q'8DLL4? ?d) /' " ) ) +,   sen3::. 7J 9 sen3::.s$AB C1 B--C1 C,,C1__main__)rVrr0bytes)rVrr0rF)r`rr0rF)r`rrprFr0r1)r`rrprFr0ztuple[dict[str, object], str])rDrBr0rB)rCrBr0rB)r0rF)rrr0r1)rrrr/r0rA)rrBrrBr0rF)rrBrrBr0rB)r0r)rrr`rr0r)rrr0zlist[tuple[int, int, str]])r0rB)r0zdict[str, str])r`rrVrBr0r1)rz int | NonerVrBr0r1)rrAr0rB)r^rr0rF)rqzargparse.Namespacer0rB)r0zargparse.ArgumentParserrY)rzlist[str] | Noner0r)Sr9 __future__rr~rrZrRrjr rfstructrr dataclassesrpathlibrtypingrrr rJr r rrrrrrrrrr r"r$r%r&r'r+r,r/rrrStructrrnrugetattrr2 RuntimeErrorr4r>rArWr]rarrrvrrrrrrrrrrr rr:r@rIrKrUr`rurrr6 SystemExitr:r;r<rsVI"   !U 5UQuQPePU 5UW UW/ E/T%T= e=%%%% bbZ[[ 9:5:::%g8z/q ef 5f;}BD u     f  Rq ) 2L2&m& $)))r>9<<2& M<@)QX**  <<~T [  <:"   z TV r;