j0fUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZddlmZddlmZdZded <d Zded <d Zded <dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZ ded<d Z!ded!<d"d#d$d%d&Z"ded'<ed(Z#d)Z$e jJd*Z&d+Z'd,Z(d-Z)hd.Z*Gd/d0e+Z,Gd1d2e,Z-ed34Gd5d6Z.dMd7Z/dNdOd8Z0dPd9Z1dQd:Z2dRd;Z3 dSd<Z4dTd=Z5dUd>Z6dVd?Z7dWd@Z8dXdAZ9dYdBZ:dZdCZ;d[dDZGdGdHZ?d^dIZ@d_dJZAd]dKZBeCdLk(r eDeBy)`zNContinuous, event-first Task26 lifecycle observer and role-handoff controller.) annotationsN) dataclass)Path)Final@e788f5d56aef04da3097007e2ab79614f2060607d4331162169733b1208d9377r SUCCESSOR@a113a57564a11710dffd238688dd73f8037eabaed0b48532b4bc90b2996e69fcCORE@2fbd6c9ad9d4b5ee979e7671d44e32fd4769e8737e26d7459fe73c81a525c656WHEEL@d816dbbd6a27d5826b251d279a9831de096ef7cd79b5fd131ceff7253b7369bePLAN@8416cd7c83cab5540af2e1e01dbcc5b1bdfd49a59d8ef21ea49512c28d749218GOLDEN@a2e15845764e7041957ae4518096fe73f87ec35b57021980cdd4df3ea18ac00dRECOVERY@5e3067fe3c865224fc73ff5a9a65058c87960f05d9af53bddccaf6f32dc83939CONSENTcb_PCczfFXoI4GjvCxLBs1oRASESSION@53b4f95b5b4db9a611128976a7b951bbe22d9619e05b2ff07fadf5b02f9a5380SID%task26_live_2e_r2_20260815_8527916639KEY 8527916639CUSTOMER 8693203710OWNER) date_of_birthequation_sex_basis height_cm weight_kgactivity_categoryactivity_rationale goal_typetarget_weight_kg target_date allergies intolerancesreligious_ethical_exclusionsdisliked_foodsdietary_preferences conditions medicationspregnancy_breastfeedingeating_disorder_riskcooking_access budget_band meal_countschedule_constraintsFIELDS@95637abce4742d583534cf406b038f7c862ad0a72d10a6bab24d2452dcb0f776@8c7065277d5d96ce1012ac0c098d53288bba66c44c0674704be4072fe0a63951@8ce2fe8770c2b480083e9d44237d80892ccddcaec06acca14db18576a2ee0088@b41060dea28eb3bbb83217068f5218d5df2c879dba00e73c9ca4e577a6049dad)z1gateway/platforms/dualcoach_activation_cutover.pyz$gateway/platforms/dualcoach_admin.pyz0gateway/platforms/telegram_customer_bootstrap.pyzgateway/platforms/telegram.pyRUNTIMEzK/home/cube/projects/richard/hermes-agent/.venv/lib/python3.12/site-packagesztask26-continuous-lifecycle-v1iIIIii@i>recovery-auditsprofile-reset-archivesdualcoach-provider-authrehearsal-reset-archivespost-lifecycle-cleanup-archivesglobalc eZdZy)LifecycleErrorN__name__ __module__ __qualname__i.omo/evidence/task26/task26-continuous-lifecycle-observer-st_01a007da-v2-e788f5d5/continuous_lifecycle.pyrCrCPrIrCc eZdZy)LifecycleTimeoutNrDrHrIrJrMrMTrKrIrMT)frozencneZdZUded<ded<ded<ded<ded<ded <d Zded <d Zded <dd Zy)Promptstrstatusroleactorztuple[str, str]routez str | None message_idactioncommanddetailc |j|j|jt|j|j |j |j|jdS)N)rRrSrTrUrVrWrYrZ) rRrSrTlistrUrVrWrYrZselfs rJdocz Prompt.doccsIkkIIZZ$**%//kk||kk  rIN)returndict[str, object])rErFrG__annotations__rYrZr_rHrIrJrPrPXs; K I J  KGSFC  rIrPcdtj|jjSN)hashlibsha256 read_bytes hexdigest)ps rJsharjps >>!,,. ) 3 3 55rIc|js|S|jrtd||j}tj|j rC|j tjk7s"tj|j dzrtd| tj|jS#tj$r}td||d}~wwxYw)Nzsymlink authority: ?zunsafe authority: zinvalid JSON: )exists is_symlinkrCstatS_ISREGst_modest_uidosgetuidS_IMODEjsonloadsrgJSONDecodeError)ridefaultses rJloadr|ts 88:||~21#677 A LL # 88ryy{ " << "U *1!566:zz!,,.))   :~aS129:s2"CC<(C77C<c4t|tr!|Dcgc]}t|ts|c}St|trLdD]G}t|j|ts#||Dcgc]}t|ts|c}cSgScc}wcc}w)N)records generationsitems) isinstancer\dictget)vxks rJrowsrs!T41a 1d 3144!T4A!%%(D)#$Q4?4a:a+>4??5 I 5@sBB.BBctjtjtj j d}d|d|d|S)N=znon2::)base64urlsafe_b64encodebytesfromhexrdecoderstrip)rW generationhs rJcallbackrsH  s!34;;=DDSIA 6(!J' --bootstrap-session zg --expected-generation 5 --package-root /home/cube/.hermes/profiles/dualcoachtest/workspace/checkin_cli)rrrHrIrJ exact_cutoverrs4 b   M N   t  trIc |Dcgc]#}t|j|d|k(s"|%}}t|dk(r|dSdScc}w)NrXr)rQrlen)seqfieldvaluerrs rJ_onersM:Cq3quuUB/0E9CA:q6Q;1Q4(D( ;s #AAct|dz i}ttt|tr|j dgngdt }t|dz i}ttt|tr|j dgngdt}|dz tz dz }t|d z dxst|d z d}t|d z i}ttt|tr|j dinidt }|[t|trKt|j dtr,|dj t } t| tr| nd}t|d z i} t|d z i} |dz tz dz } t| dz d} d}t| tr| j d}t| j dg}|rt|dt|nd}|rt| dz |dz dnd}t|tr||j d|j d|j dt|j dt|j dgt|tr|j dndd}t|dz g}t|dz i}t|dz i}t|dz i}g}|dz }|jrO|jjD cgc](} | jstj| *}} ||||t| t| |t|t|trt|j!n t|t|tr|nit|tr||d Si|d Scc} w)!Nz:data/onboarding/telegram-customer-bootstrap-v1/ledger.jsonsessions session_idzcustomers/registry.json customers customer_keyzdata/customersznutrition-onboardingz ready.jsonztransient/workflow.jsonz session.jsonz:data/onboarding/telegram-publication-outbox-v1/ledger.jsonzCdata/onboarding/telegram-publication-outbox-v1/owner-callbacks.jsonwizardztelegram-bindings.jsonactive_session_idbindingsdraftsz.jsonversionsteprVchat_idtopic_idfinalized_event_id)rrrrVrUrz)data/owner-actions/draft-generations.jsonz.data/owner-actions/draft-generation-cards.jsonzdata/owner-actions/drafts.jsonz(data/owner-actions/draft-deliveries.jsonz$data/customer-activation-audit.jsonl) bootstrapcustomerworkflow publicationoutboxowner_callbacksrrcardsr deliveries activation)r|rrrrrrrrQrm read_text splitlinesstriprvrwr\values)rootbootbrregcrnrwfpubsprroutocwrbindractivebsbdraftgensrrrauditaps rJcapturers SSUW XD  D$)?TXXj" %RH B t// 4C  C)>SWW[" %BG  B  3 &)? ?B b< & T$r4M/Mt*TB ^#R (D  D$)?TXXj" %RH B  zjt,DHHZFdGGLJ E 6 6B yy{(* (A(A(CQ(C1qwwyA(CQs)8Dz)3E4)@elln%d5k&vt4&"$.z4$@j  GI  Rs 'O=Oc |jd}|jd}t|trV|jdtk7s>|jdtk7s&|jddvs|jddvr t d t|tr]|jd t t k7s@|jd ttd d dfvr*|jdttd gk7r t dt}|jdg}t|ts t d|D]}t|ts t d|jd|jdf}||vr t d|j||jd}|jd}|dk(r |td gk7s|dk(s|td gk7st d|jdi} t| trs| jDcgc]@}t|tr.|jd t k(r|jddk(r|B} }t| dkDr t dyycc}w)Nrrrsid_hashstate>ACTIVEAWAITING_ACTIVATIONr>zbootstrap authority driftrtelegram0user_idrrrUzcustomer route driftrzoutbox schema driftz duplicate publication generationrSownerzpublication role route driftrrR sent_auditedrzduplicate sent_audited delivery)rrrrrrCrrsetr\addrrr) rzrcseenrrrrSrUdterminals rJvalidate_snapshotrsH kA jA q$  55 ' ) 55  # 55>!B B 55 f ,899 q$  55 % , EE*  (X3OQUV Wg8Xs";;344 5D UU8R F fd #233 !T" !67 7 UU< !%% "5 6 9 !CD D  uuV}g J (C(w%% !?@ @ lBA!TXXZ !T"n%,h>1    x=1  !BC C  s)AJ ct||jd}|jd}t|trzt|trj|jddk(rV|jddk(rBt |jddt |jddkr t d|jd}|jd}t|trRt|trBt |jddt |jddkr t d |jd }|jd }t|trxt|trg|jd |jd k(rCt |jd dt |jd dkr t d yyyy)Nrr collectingcursorrzonboarding cursor regressedrrz publication generation regressedrrrzcheckin version regressed)rrrrintrC)arawbwrbpavbvs rJvalidate_transitionr$sa z B z B2t r4 FF7O| + FF7O| + x# $s266(A+>'? ?:;; } B } B2t r4 |Q' (3rvvlA/F+G G?@@ xB xB2t r4 FF< BFF<$8 8 y!$ %BFF9a,@(A A899 B 9 ! rIc |t||d}|d}|jd}|jd}t|trt|tsJt |jd}|jddk(rt|ts t dt |jd}|d k(rt|jd d }d |cxkrttkrn t d t|ts t d td dttdft |jddt|d|dzdSt|ts t dt|jdd }t |jd} |dk(r&tddttdf| td|ddS|dk(r&tddttdf| td|dd S|d!k(rtd"dttdf| d#S|d$vr/|d%k(rtd&d'd'd(dd)Std*d+d+d(dd,td-St d.|jdd/k7s|jdd0k7r t d1|jd2i} g} t| trY| jD cgc]@} t| tr.| jd3t k(r| jd4d5k(r| B} } | r&|rtd6d+d+d(dd7d8Std9d+d+d(dd:d;S|s t d<|jd=} t| tstd>dttdfdd?d@S| jdAtdgk7r t dB| jdCdDk7rFtdEdttdft | jddF| jdCdGS| jdHs4tdIdttdft | jddJdKS|jdLi}g}t|tro|j#Dcgc]T\}}t|tr?|jd3t k(r'|jdM| jdMk(r||fV}}}|jdNg}t|t$s t dO|Dcgc]O}t|tr=|jd3t k(r%|jdM| jdMk(r|Q}}|s|r t dPtdQd'd'd(ddRdSS|Dcgc]}|djd4dTvr|}}t|dk7r t dU|d \}}|Dchc]3}t|jdVt s#|jdV5}}|jdWg}t|t$s t dX|Dcgc]s}t|tra|jdY|k(s7|jdV||jdZhvs|jdV|vr|jdd[k(r|u}}t|dk7r t d\|d }|jd]}|ttdd^k7r t d_t |jd4}|d`vr8tdadttdft |jddb|dcddS|dek(r8tdfdttdft |jddb|dgdhSt dicc} wcc}}wcc}wcc}wcc}wcc}w)jNrrrrenabledrrzonboarding workflow unavailablerrrzcollection authority driftREADY_CUSTOMER_ONBOARDINGrrVzsubmit_answer:zanswer onboarding question rz'/22 by replying to the committed prompt)rZz"onboarding publication unavailablercustomer_attestationREADY_CUSTOMER_ATTESTattestrXz!press the attestation button once owner_reviewREADY_OWNER_ONBOARDING_APPROVErowner_okz7press Approve once; readiness finalization is automatic safety_holdSTOP_SAFETY_HOLDzclinical-review-required>ready finalizingrWAIT_AUTOMATIC_READINESSsystem)localrzautomatic-finalization!READY_OPERATOR_ACTIVATION_CUTOVERoperatorz!dualcoach_admin:customer:activatezbrun only after checklist evidence exists; commits registry activation then bootstrap g5->g6 ACTIVEzunknown onboarding outcomerrz.activation cutover is not atomically committedrrrRrREADY_OPERATOR_DISABLEzcustomer_admin:disablezCdisable exact customer, then stop service and await cleanup handoffREADY_CLEANUP_HANDOFFzsealed-cleanup:dry-runzIservice must be inactive; use sealed cleanup dry-run -> execute -> verifyz/active lifecycle customer unexpectedly disabledrREADY_CUSTOMER_START_CHECKINz send:checkinz'send checkin, then press Begin check-inrUzcheckin route driftrsummaryREADY_CUSTOMER_CHECKIN_ANSWERzcheckin:z"answer the visible check-in promptrREADY_CUSTOMER_CHECKIN_SUMMARYzcheckin:finalizezconfirm the visible summaryrrrzgeneration authority driftz&generated result lacks draft authorityWAIT_AUTOMATIC_GENERATIONzgeneration:autoz.no human action; wait for generated owner card>heldsentrejected supersededz&draft identity is duplicate or unknowntokenrzowner card authority driftdraft_idgeneration_token publishedz'exact owner generation card unavailable destinationrzowner card route drift>editedcreatedREADY_OWNER_DRAFT_REVIEWzdraft:z:reviewz;choose regenerate or edit if needed; otherwise approve onceapprovedREADY_OWNER_EXPLICIT_SENDz:sendz9approval never sends; press Send to customer exactly oncezunknown draft outcome)rrrrboolrCrQrrr5rPrrrrrrrr\)rzrrrrirrcurgenmidrrrwrmatchedrrrgrelevant_generationsrrdiddrgeneration_tokens cards_valuercarddestrRs rJclassifyr"Csa +A * A z B mA a :a#66 6155#$GuuW~.."d# !BC CBFF7O$ L bffXq)*C)c&k)$%ABB21    ((\  #     $^   NOO hA a  *   sO  <   uuW~(C(233uuV} ! +   sO l# $quuV}o &7   55% & ,   sO l# $ 0  UU8R FG&$  &1!T"n%,l#quu\':: F&  %% r*K k4 (9::A a  EE. !S ( EE, 155#6 6    !IJ J '     C  A Q488H %O O    6{aEFFQiGC 4 41 155>SV8Wg 4%%$K k4 (9:: A a  EE*  $uuW~#rvv.@'A!BBuuW~!22 EE'Nk )   5zQFGG 8D 88M "D 5UDD566 ! "F && &   CL & 'SE !P   '   CL & 'SE N   0 11g B ( s.A^A^$A^* ^/$^46^4> 1<CCE ikrIc$|jjdd|jjdd}|jr=|j j }|rt j|ddn|}t|jr td|jDnd|d |}t||d<tj|tjtjztjztj zd }tj"|t j$|dd d zj'tj(|tj*|y)NTparentsexist_ok@0000000000000000000000000000000000000000000000000000000000000000 event_sha256c3 K|]}dyw)rNrH).0_s rJ zappend_event..>s/;a;s r)schemasequenceprevious_event_sha256r$r& )parentmkdirchmodrmrrrvrwSCHEMAsumopenr+rsO_WRONLYO_CREATO_APPEND O_CLOEXECwriter)r*fsyncclose)patheventpreviouslinesrowfds rJ append_eventrP5s#KKdT2KKeH {{} ++-r?rsrBrCrDO_EXCLrGrvr)r*rHrI)rJrrOs rJsecurerSKsKKdT2KKe r{{RZZ/"));U CBHHR$**Q$:FMUUWXHHRLHHRLrIcNtttttt t dS)N) successorcorewheelplan golden_v6 recovery_v6consent_receipt)rr r rrrrrHrIrJrrTs!" rIctjD](\}}tt|z |k7st d|y)Nzinstalled runtime drift: )r:rrjSITErC)rirs rJ runtime_checkr^`s9 1 tax=A  #ycc}wrd)rswalkrSKIPrr)r^rdirsr6rs rJadd_treezWatcher.add_treetsP''$)),JAtQ"&8$Q!4-q$8DG HHT!W -8s A A c2|js|jsytjdd}|j |j t j|t}|dkrtd|||jt|<y)NTr`rzwatch failed: ) rnis_dirrbrcinotify_add_watchrOrsfsencodeMASKrCrlr)r^rirfrs rJrz Watcher.addysq <<> {{440  " "477BKKND A q5 >!!56 6  SVrIcXtj}|j|jtj |j |}|s t dtj|jd}d}|tjzt|krtj||\}}}} |tjz }|||| zjdddj} || z }|tzr t!d|t"zr|j$j'|t)| z } |dzr!| j+r|j-| |tjzt|kr|j/y#|j/wxYw)Nz stage monotonic deadline expiredirrzinotify overflowi@) selectorsDefaultSelectorregisterrO EVENT_READselectrMrsreadEVsizer unpack_fromsplitrOVERrCIGNOREDrlrrrtrrI) r^secondsselrrawoffrmaskr6nnamechilds rJwaitz Watcher.waitsP'') TWWi223 JJw'E&'IJJ''$''5)CC-3s8+ "sC 8 4Arww3q)//q9!<CCEq$;();<<'> ((DF3d:*$HHUO-3s8+ IIKCIIKs EFF)cBtj|jyrd)rsrIrOr]s rJrIz Watcher.closes rIN)rrr`None)rirr`r)rfloatr`r)rErFrGrmrrrrrIrHrIrJririns+  !0rIric `tdt|jt|ddddd S)NREADY_CONTINUOUS_LIFECYCLEz recursive-inotify-before-actions`Tz=no raw updates, tokens, customer answers, or provider content) r8rRrinitial_handoffauthority_sha256event_subscriptionper_stage_timeout_maxtotal_timeout_maxprivacy)r@rr_r+)rzprompts rJ ready_docrs3.J!::<&qM@!%"R  rIc tt|j}|jt |j}t |t |}t||}t|j||jdk(r|j|St|jd|jt|dt!t#j$|ddt'j(}|}|j*} t-|j.t'j(|z z |j0t'j(|z z }|dkr t3d|j5|t |j} t| t|k(rt7|| t | } t|jd |j*| j*| jt| d | j*|k7rPt!t#j$| jddt'j(}| j*}| | }}| j*d k(r1t8d t;| jd |jS#|jwxYw)Narm-onlyREADY)kindhandoffrTr')flushrz"bounded lifecycle deadline expired TRANSITION)rfromtorrr"PASS_CONTINUOUS_TO_CLEANUP_HANDOFF)r8rRr final_handoff)r^riprofilerrrrr"rrSrmoderIrPeventsr_r+printrvr)time monotonicrRmin stage_timeout total_timeoutrMrrr@r) rrrzrirstartstagelast remainingrqs rJrunrsO AJJL Aa A!QA 177Avv   QUUW*Q-P $**Q$ 't4 NN E E 88D%4>>#3e#;<4>>#3e#;<IA~&'KLL FF9  "A!} 1 - 1 % A (HH(( uuw(21  xx4djjD9F(xxaqAxx22$B ( %&UUW   IH  sFJ64J66Kctj}|jdd}dD]}|j|}|j dt d|j dt d|dk(sJ|j d t d|j d t d |j d t d |j} |jdk(rNd|jcxkrd kr.n tdd|jcxkrdkstdtdttjt|dy#t $r(}td|t"j$Yd}~yd}~wtt&t(t*f$r(}td|t"j$Yd}~yd}~wwxYw)NrT)r!required)robservez --profile)typerz--readyrz--eventsz--stage-timeoutr)rryz--total-timeoutrrztimeout bound invalidrzFAIL: )file)argparseArgumentParseradd_subparsers add_parser add_argumentrr parse_argsrrrrCrrvr)rrMsysstderrOSError ValueErrorKeyError)rsprrrr{s rJmainrsw  "B    6B' MM$  {= ytd; 9  NN:D4N @ NN,5$N G NN,5%N H( A  66Y AOO+t+ !89 945q3O%3O !89 94P !89 9 djjQ401  qcl, GZ : qcl,s%BE GFGGG__main__)rirr`rQrd)rirryobjectr`r)rrr`list[dict[str, object]])rWrQrrr`rQ)r`rQ)rrrrQrrQr`zdict[str, object] | None)rrr`ra)rzrar`r)rrarrar`r)rzrar`rP)rrar`rQ)rJrrKrar`r)rJrrrar`r)r`zdict[str, str]r)r`r)rzrarrPr`ra)rzargparse.Namespacer`ra)E__doc__ __future__rrrrbrervrsrzrostructrr dataclassesrpathlibrtypingrrrbr r rrrrrrrrrr5r:r]r@Structrrwrrrp RuntimeErrorrCrMrPrjr|rrrrrrrr"r+rPrSrr^rgrirrrrE SystemExitrHrIrJrsT"   !U 5UPePQuQPePRRT%TSS,, OUO 4U4%u2:|,n8z%g   Q *V]]6   \  ~  $   .6:$- ) )),)58))EP3Dl:>i2X , B --` 9x6 z TV rI