+ jHjsaR*t!0tRt^RIt^RIt^RIt^RIHt^RIt^RIH t ]P!] 4t RRRRRRRRR R R R R R R RRRRRRR RR RR RR/t R]!4R0R+mRRR0R0R,mR 0R-mR 0R.mR RR0R 0R/mR0R0mR0R1mRRR0R0R2mR0R2mR0R3mRR0/tRtRR/RltRtR t]P(!4tR!tR"tR#tR$tR4R%lt/t]^k/t]^kR&tR'tR(tR)t R#)5z>Profile-owned room controls over the canonical hosted service.N)Path)RuntimeStoreErrorgroups.capabilities session:read groups.list groups.state groups.log groups.createzsession:control groups.renamegroups.disband groups.sendzsession:submitgroups.attachment.uploadgroups.attachment.download groups.stop groups.retrygroups.discardgroups.approvezsession:approveinclude_disbandedroom_id cancel_id profiles.listinclude_sessionscaaa a a a a"SPSPuo o \PSR4pVS P9d \ R4hS P S P 8wd \ R4hS\9gB\V\4'd,\V4\S,R0,, 'd \ R4h\S P 4o \P!\S PP4P 4GRjxL pVP"\P!S P 4GRjxL 8wd \ R4h^RIHpVPR4pVe"\V\(4'g \ R4hV'dV!VS 4'g \ R4hVP+4UUu/uFwrxVR8wgKWxbK uppoSR8Xd \-SS4MR o V V VV VV V3Rlp \P!V 4GRjxL #ELLuuppiL5i) rpermission_deniedprofile_mismatchprofileinvalid_paramsN)profile_matches_homerc <^RIHp^RIHpV!S4;_uu_4SR8Xd\ SSSS S4uuRRR4#\ SSSS SP R7uuRRR4# \dhTd'p\\TRR4;'gR4ThRp?i\\3dp\R4ThRp?ii;i +'giR#;i))_profile_runtime_scope)HostedRoomErrorrN) host_scopereasonr) gateway.runr gateway.hosted_roomsr! _profiles_group host_scopedrgetattr ValueError TypeError) r r!excactor authority connectionhomemethodsiblingssupplieds C/home/ubuntu/.hermes/hermes-agent/gateway/session_group_controls.pyinvoke&dispatch_group_control..invokeGs68 #D ) )( E48L* ) CiZMcMcd * ) % " c'Xt(D(X(XHXY_bb * C'(89sB C* ) )sAB?A$$B<5B<6!BB<*B<+ B77B<<B?? C )r.r- GROUP_METHODSget capabilitiesr profile_id_FIELDS isinstancedictsetrasyncio to_threaddbdb_pathresolveparenthermes_cli.profilesrstritems_roster_siblings)r/r1params capabilityrCrrkeyvaluer5r-r.r0r2r3sff& @@@@@r4dispatch_group_controlrN1s!++Z-=-=Iu""6>:J+++ 344 9/// 233 WJvt$<$<F wW]bkalOl@m@m 011  $$ %D%%d9<<+?+?&@&H&HIIG~~w00>>> 2338jj#G:gs#;#; 011+GT:: 233-3\\^P^zssi?O  ^PH9??9R H5XZH C C""6* **5J>Q" +sUDI'H8(2IH;AI2II H=/H=5>I3I4I;I=Ir"Fc&aaaaaaaaaa^RIHoSPPoSP 4o\ SRR4o\ SRR4oSe\ SP4P4\ S4P48wd \R4hSPP4pVPR4'dVPR4'dRo0RmpRo\ SRR4eARS9d:Sf \R 4hVR 8Xd VVV3R loMS!SPSR,4VR9d-Sf \R 4h^RI HpHpVR 8XdTMTp V !SSS4#W&9d?Sf \R 4hSPR4'g \R4h\!SVS4#VVVVV3Rlp VVVVVV3Rlp VVVVVVVV3Rlp VVVVV3Rlp VVVV3RlpRV RV R V RVRVVV3RlRVVV3RlRV /pW,!4#)r) hosted_roomshosted_room_serviceNauthorize_roomrrunningstoppingrrr cB<S!SPSR,RVR7R#)rT)createconnN)subject)rWr-rJroom_authorizers&r4admit_group..admitms vi/@TXYr runtime_coordination_required)uploaddownloadrc<a^RIHpV!SSR7wpoRSPRSRJRRRSR R R R R /R.ROR\\4RSP R\ V3RlV44/ #)r) member_rosterr2protocol_versiondriverNpersistent_processTauthority_gateway_id room_linkenabledFr#canonical_driver_requiredfeaturesmethods max_log_limitseatable_profilesc38<"TFqS9gK VxK R#5iNr7).0namerefuseds& r4 /_group..capabilities..s+ZUTRYFYDDUs ) room_identity monotonic_logreplayable_disband)gateway.session_hosted_membersraPROTOCOL_VERSIONlistr8 MAX_LOG_LIMITsorted)rahomesrrr. gateway_idr"roomsservices @r4r:_group..capabilities~s|@'y:Fw"E$:$:HgUYFY$d,BJi:UVT4 .ATAT#V+ZU+Z%Z \ \r\c<a S PRSP4S PR^4r\S RR4f3SP!S 3/S BpRTR\ V4V8Xd W,/#R/#So S f \ R4hV V 3Rlp.TRrepVfrSP!S 3//S CRV/CBpVF?pV!V4'd&\ V4V8XdTpMVP V4V^, pKA \ V4V8gKtRVRV/#)limitoffsetrQNr next_offsetrc<S!SPVR,4R# \dpTPR8wdhRp?R#Rp?ii;i)rrNFT)rXrr#)roomr,r- authorizes& r4visible(_group..listing..visiblesD %--i9  % ::!44 s AAA)r9MAX_ROOM_LIST_LIMITr) list_roomslenrappend)rrresultrfoundcursorrbatchrrr-r.rCrJrYrs @r4listing_group..listings  7E,E,EF S[]^H_v 93T : B%%g88FV]c&kUZFZFNe e`de e#  #$78 8 &({!$$WM0L60L8V0LME4==5zU*&, LL&!  5zE! {;;r\c<^RIHpHp^RIHpHpV!S SR7wrEV!SP R4V4V!SP R4VR7pSeRSP!R/SBRS /B/#TUu.uFjpR TPR TPR TPR\TP;'g/4/TP'dRTP/M/CNKl p pRSPS SP R4SP R4T S S R7/# Tdp\R R\T4R 7ThRp?ii;iuupi)r)DiscussionValidationErrorvalidate_roster)rarefuse_unseatablerbmembers)local_profilesNrrZr)fielddetail member_idrhandletarget display_namerrq)rrqrrfrZr7)gateway.hosted_room_discussionrrrxrarr9 create_roomrrGrrrr>rr)rrrarr}rrrr,m normalizedrZr.rCr~r"rJrrs r4rV_group..createsZ]S 'y:F&**Y/9 a%fjj&;ERG" 3 3 Jf JE JKK#ahi`g[\#AKKAIIxQRQYQYahhnn"!5W>?nnn>1>>:RTW`g i))'6::i;PZZ'R\*  ) a#$4IcRUhW]` ` ais*4D1AE3E ED>!D99D>c<a^RIHoSPSSPR4RR7pSepVPR4f]SP SPR4SPR4;'gRRR7SP SPR44SfP\ ;QJd!VVV3R lR4F 'gK RM R M!VVV3R lR44'd \R 4hSPSSPR4RR7pR SPSSPR4SVR ,R7/#)r) list_tasksrT)rr disbanded_atrzroom-disbanded)rrequire_acknowledgedc3X<"TFpS!SSPR4VR7xK! R#5i)r)rstatusN)r9)rprrCrrJs& r4rs*_group..disband..s/#][6$.gvzz)?T]c#d#d[s'*Fr] tombstoneauthority_epoch)rexpected_gateway_idexpected_epoch)queuedrSrT indeterminatedeferred) gateway.hosted_room_driverr room_stater9 stop_roomrevoke_room_routesanyr disband_room)staterrCr~rJrrs @r4disband_group..disbands*9  &**Y2G[_ `  599^#<#D   fjj3(. ;(?(S(SCS37  9  & &vzz)'< = ?ss#][#]sss#][#] ] ]#$CD D  &**Y2G[_ `U//IAV$.uEV?W0YZ Zr\c<SP!S3/SBpRV/pSe/VPR4fSPVR,4VR&V#)rrr driver_status)rr9r)rrrCrJrrs r4r_group..statesQ262$  488N#;#C&-nnT)_&EF? # r\rrrrc*<SP!S3/SB#ro) read_eventsrCrJrsr4_group..se//B6Br\r c.<RSP!S3/SB/#)r) rename_roomrsr4rrs&%*;*;G*Nv*N!Or\r >r rrrr>r r)gatewayrPrBrClocal_authority_gateway_idr)rrDrruntimerr9rX"gateway.session_hosted_attachmentsr^r__execution_control)r.r-r1rJr"rexecution_methodsr^r_handlerr:rrVrrhandlersrZrCr~rYrrsff&fd @@@@@@r4r'r'Xs-ll""G113Ji!6=Gg'7>O  ( ( *d7m.C.C.E E#$67 7'')zz)$$ :(>(>Gj Ey/6ByTZGZ  "#$78 8 _ $ Z Z EMM6)+< = KK ?#$CD DG"&@@&hwv.. " ?#$CD Dzz)$$#$45 5!'66:: \ \!<!.sendsj6 VZZ %:&3FJJz4J&K%+ZZ %:< 16::j3ID"2D: :r\c<\SPR44\Jg=SR,^8g/SPR4'dSPR4'g \R4hSR8Xd SPM SP pV!R /SBpVR,pR Uu/uFq3\ W#4bK ppTPR Uu/uF q3W,bK up4SR8XdRMRRR V/#uupiuupi) execution_generationrtask_idrridentity discardedretriedTtaskr7)rr thread_idturn_id)rrcancel_generation)typer9intrdiscard_room_taskretry_room_taskr)update) operationrrrreceiptr1rJrs r4attempt_control+_execution_control..attempt_controls 23 4C ?01A5zz+..fjj6K6K#$45 517;K1KG--QXQhQh "6" #ACA8='(22A COQO05t{*OQ R%)99 y$PVX_`` CQs C+C0c:<\SPR44\JgYSR,^8gKSPR4R9g5\SPR4\4'dSR,'g \ R4hRRRSP !R/SB/#) rchoice request_idrapprovedTr>denyoncer7)rr9rr=rGrapprove_room_taskrJrsr4approve#_execution_control..approves 23 4C ?01A5::h'/??!&**\":C@@|H\H\#$45 5D(G,E,E,O,OPPr\r rc~<RSPSPR4SPR4;'gRR7/#) cancelledrrz desktop-stop)r)rr9rsr4r$_execution_control..s= W->-> JJy !VZZ -D-V-V.?.X Yr\rrrr7)rr1rJrrrrsfff r4rrsJ: aQ tY/' H F  r\z_(chat_id LIKE 'local-%' OR EXISTS (SELECT 1 FROM state_meta WHERE key = ? || sessions.chat_id))c ^RIHp^RIHpVPVP rT\ \ VRR4RR4f.#VP;'dVPRR4RJpV!VP4Uu.uFkqwPVJgKTV'dLVPf>V!VPVPPVPVP4MR3NKm up#uupi)aThe other local bots this process serves (``session_authorities.local_bots``, the set group seating uses too), as ``[(bot, reader)]``, snapshotted on the owner loop, where serve and unserve mutate the registry; an unbuilt slot is skipped. ``reader`` is the principal that row's session fields are read as, or None for a metadata-only row: only a host-scoped socket routes session verbs to a sibling (``AuthorityConnection._sibling_for``), and only a bot addressable by its own name (no ``problem``) is the one a click on its row opens. It carries this socket's subject and capabilities, which is what the routed connection would carry; none is built, so no poll (routed or not) adds connections.) local_bots) PrincipalrunnerNsession_authoritiesrT)gateway.session_authoritiesrgateway.session_contractrr.r-r)r(r9rproblemrXr;r: transport_id)r/rJrrr.r-readablebots&& r4rIrIs72!++Z-=-=uwy(D13H$OW %%VV&**5G*NRV*VH")"2"23 W3}}I7U .:s0B9<.summaryEs+((tDz:C\\"EvNWWYaa]aFll+-0F45=HJ ?F388C 0 0b1779:2D$t*mS'6'?CXCXVX $w-"5"52CINtCy50 &"6";";!!6*<#=#Z#Z AU#Z#ZYZ#VO%<%A%A C Cr\ last_sessionNworker_sessioncanonical_sessionz)SELECT * FROM sessions WHERE title=? AND zBot Chatuser_idarchivedzSELECT * FROM sessions WHERE z= AND archived=0 AND hidden=0 AND COALESCE(source,'') NOT IN (z=) ORDER BY COALESCE(last_activity_at,started_at) DESC LIMIT 1rz|SELECT id, source, title, COALESCE(last_activity_at, started_at) AS last_active FROM sessions WHERE COALESCE(source,'') IN (z?) AND archived=0 AND hidden=0 ORDER BY last_active DESC LIMIT 1sourcerr)rr7) hermes_state_local_migrationrhermes_state_sessionsrr#r _read_ctxr! _LOCAL_CHATr"r>striplower)rBrXr rrhidden_sources owner_filter owner_paramsr)fields canonicallatestworkerrWsf&& @r4rr=s:>XXcC(@$AABN-5FY[_`LL#L[M!Z",m!<>>Fhj  )I.'9XyYcOdOd*1)*+G//=.>?J J Fl EM E,D E GHPxz  f011fTliPTo6U%)&1D*E%FF> " %,V_F> " --;,<=0 01IKLT8:  (,fTlHvhGWG]G][]FdFdFfFlFlFn(/1F1FB W]^kWlWqWqpq(sF# $W $Z M[ $ #Z MsDAG.2G.AG.G.2G. 6G.G..G. G.G.. G? cpVP'gVP'd/#\W4p\PT4T# \dapT\9d\ P M\ Pp\PT4T!RTPT4/uRp?#Rp?ii;i)aYA sibling row's session fields. A retiring sibling is not read: unserve marks it before it closes the store, and this runs right before the read (a close that still lands mid-read is refused by ``reopen=False``). Any failure leaves only that row metadata-only, as the pre-unified roster degraded per profile, instead of failing the whole roster.zGBots roster: %s is metadata-only, its session store did not answer (%s)N) retiringretiredr  Exception _DEGRADEDloggerdebugwarningaddr;discard)r.readerr:r,logs&& r4_sibling_sessionsrJts Y... y1 i M '94fll&.. i  UW`WkWkmpq s A B5AB0*B50B5caaaa^RIHp^RIpVPRR4o\ S4\ Jd \ R4h^RIHpV!S4pV!VSVR8HR7p R TR \S4R V PR V PR V PRV P;'gRRV P;'gRRV P;'g^/p SR, p V P!4'd"VP#V P%RR74M/p \'V \(4'dT M/p V PR4p \'V \(4'dNV P+4UUu/uF0wr\ V4\,JgK\V4\/^V4bK2 uppM/V R&\'V PR4\(4'd V R,V R&\0;QJdV3RlR"4F 'gK RM RM!V3RlR"44V R&S'dV P3\5W44V .oSP740oR#VVV3RllpVF<wppT!V!VP84VP8VeVP:V3MR4K> \=VRR4pVe2VP?4P+4FwppV!VV4K ^RIH pV!4pVPC4'd V!RV4\E4FpV!VPFV4K ^RI$H%pRSR RR!V!4;'gR/#uuppi)$zThe Bots roster: this profile's row, then every profile it can name. ``siblings`` is ``_roster_siblings``' snapshot; a sibling with a reader carries the same session fields.) _profile_infoNrTr)served_profile_namedefault) is_defaultrqpathrOmodelprovider descriptionrr skill_count profile.yaml utf-8-sig)encoding_ui_meta_revisionsui_meta_revisionsui_metac3f<"TF&pSR, RV 2, P4xK( R#5i)assetszavatar.N)is_file)rpextr0s& r4rs_profiles..s.lUkcTH_>GGIIUks.1F has_avatarc<VP4S9dR#SPVP44RVR\V4RVR8HRRRRRRR VR ^/pS'dVeVP\ V!4\ WR , 4p\ V\4'dY\VPR 4;'gT4VR &\ VPR 4\4'd VR ,VR &SPV4R#) NrqrPrOrNrQrrRrSrrTrUrZ) rDrFrGrrJ_discovered_profile_metar=r>r9r) configuredrreachentrymetarprofilesseens&&& r4 discovered_profiles..discovereds >> t #  !"VS[, V_H_"j"mRQ[#  1 LL*E2 3' ^4KL dD ! !$'(@(N(NJ$OE. !$((9-t44#' ?i r\rQ)_get_default_hermes_home)get_install_idrgbot_mode_protocol install_id)pngjpgwebpro)&rFrL hermes_yamlr9rboolrrrMrGrOrQrRrSrrTr] safe_load read_textr=r>rHrmaxrrr rDr0r.r) profile_homesrkis_dir_named_profile_dirsrqhermes_cli.install_identityrl)r.r-r0rJr2rLyamlrMrqrrowrPrf revisionskvrirrHrrcrrkr%rlrrgrhs&&f&& @@@r4r&r&s2zz"4d; T) 011? t $DD$493DEG 4TL':L:L GMM:w/?/? '--33^WEYEYE_E_]_ '--22 4C . DCG<<>>4>>$..+.> ?WYDdD))4rD-.I4>y$4O4O?Hoo>O 1>Oda!%aC!2AAq 1>O 1UW$((9%t,,iIlUkllUkllC  =23uH LLN D( V &sxx0#((.4.@CMM6*d L  i!6=G")"7"7"9"?"?"A J z6 *#B = # %D {{}}9d#%'6;;'( ; "5t\>K[KaKa_a bbm 1s &MMc^VPVPVPVP3#ro) st_mtime_ns st_ctime_nsst_sizest_ino)stats&r4 _stat_keyrs%   d.. dkk JJr\c\P!V4pTP.\ T4O5# \dR#i;iro)oslstatOSErrorst_moder)rPrs& r4 _lstat_keyrs@xx~ LL +9T? ++ s1 AAc a ^RIHpHp^RIHpHpV!4p\ P!V4;_uu_4p.pVFo \;QJd.V 3RlV4FNK 5M!V 3RlV44p\ PPV!\S P444pVPS P\S P44Wx34K \\ P!V44\\!V443p RRR4\$P'\)T44p X e T 'dT ^,T 8Xd T ^,#T!4p T eY3\$\)T4&T # +'giLr;i \"dRp Li;i \"d#p \*P-RYL4.uRp ? #Rp ? ii;i)r)_get_profiles_root_iter_named_profile_dirs)_PROFILE_IDENTITY_MARKERSprofile_tombstone_pathc3<"TF8p\\PPSPV44xK: R#5iro)rrrPr#)rpmarkerres& r4rs&_named_profile_dirs..s4 I.GF!+277<< F+K L L.GsAANz!profiles.list: cannot list %s: %s)rFrrhermes_constantsrrrscandirtuplerPexistsrrrqrrr|r_NAMED_DIRS_CACHEr9rGrCrE)rrrr profiles_rootentriesrowsmarkersr signaturecachedtargetsr,res @r4ryrysvPR&(M  ZZ & &'D  % I.G I%% I.G IIGGNN+A$uzzBR+ST  UZZ5::<)@'UV !#277=#9:E&,rGrrzbytesobject)formats"r4 __annotate__rsXDDt654U5$;//05uEv:9T#uUF]3349wEr\>rrr>rr since_seqr>rqrr>rqrr>rrr>kindmimerqr upload_id data_base64>rr attachment_id>rrrr>rrrrrr)r7)"r__doc__r@loggingrpathlibrweakrefhermes_state_runtimer getLogger__name__rCr8r?r<rNr'rr4WeakSetrBrIr rrJr&rrrrryrbr)rs@r4rsrD 2   8 $>>N.&&'# 0 .$%'' "35;Y 34H34y+.5 _ "JI{+OQ/()! ($+NL5L^'^p  OO  W( k4n$Icj465799K,>r\