+ jHja0t$Rt^RIHt^RIt^RIt^RIHt^RIH t ^RI H t H t H t ]P!]4tRtRt]!R04t]!4tR ]R &R R ltR RltRRltRRltRRltR#)a7One-shot import of the pre-isolation ``hosted_room*`` rows into ``shared-state.db``. ``0e422e0ece`` repointed the room store from the root ``state.db`` to ``shared-state.db`` without moving the rows it already held, so an install that had rooms started with an empty coordination set and every pre-existing room resolved to "hosted room not found" (#109775). The first open after the upgrade copies the rows across once; the marker row keeps that a one-shot step, because a purge in THIS store must never be undone by re-importing rows the legacy store still holds. ) annotationsN)closing)Path)clock table_columns table_existszstate.dbhosted_room_legacy_importshosted_room_driver_leasesz set[Path]_failed_sourcesc V^8dQhRRRR/#)db_pathrreturnz Path | None)formats"G/home/ubuntu/.hermes/hermes-agent/gateway/hosted_rooms_legacy_import.py __annotate__r sYYY+YcRVPR8XdVP\4#R#)zThe pre-isolation store for ``db_path``, or ``None`` when this database has no predecessor. Only the shared coordination database has one: callers that pass any other path (older layouts, tests) own that file directly. zshared-state.dbN)name with_name SOURCE_NAME)r s&r source_pathr s' .5\\=N-N7  [ )XTXXrc$V^8dQhRRRRRR/#)r connsqlite3.Connectionr rrboolr)rs"rrr)s'__$_t__rc\V4pVe V\9dR#\V\4;'d0VP R\ R2\ 34P 4RJ#)ziTrue once the import for this database has been recorded, given up on for this process, or never applies.NTzSELECT 1 FROM z WHERE source=?)rr r MARKER_TABLEexecuterfetchone)rr sources&& rsettledr")sc  !F ~?2 l + _ _ o61HHP Z^1__rc(V^8dQhRRRRRRRR/#)r legacyrtargetrstrrzlist[tuple[str, str]]r)rs"rrr2s, 2&_select_expressions..@sGaCS'?TM#&,&>#CIQ_C_#&"CSs333 3)gateway.hosted_roomsr(rr&rextenditems) r$r%rr(r-r._r/defaultsrowpairsr0r1s &&f @@r_select_expressionsr;2s5JYq/-FUA]d((/Hq-3^^>PQUPVVWV f NE W LLa8>>CSaa L rZ Ws B4 B4 B<1C>Cc$V^8dQhRRRRRR/#)r r%rr!rrintr)rs"rrrEs"++)+4+C+rcaa^RIHp.pVPR4Uu0uFp\V^,4kK upo\ \ P !RV R2R^ R74;_uu_4pVPR4Uu.uFp\V^,4NK pp\VRR 7EFpV\9g#V\8XgVPR4'dK3\W4'gAVP\VPR V34P4^,44\WPV4pV'gKVU U u.uFwrV NK p p p VPR R PR V44 RV 24p RV 9d"V PR4oVV3RlV 4p Rp MRp VR8Xd-\!V 4p V Uu.uFp\VS,4NK ppVP#V RV RR PV 4 RR PR\%V 4,4 R2V 4EK V'dWR\'VR49dFVPVP)RR PR\%V4,4 R2R7V4RRR4\%V4#uupiuupiuup p iuupi +'giL0;i)uoCopy every room ``target`` does not have yet, with all of its child rows; returns rooms copied. A room id present in both stores is skipped as a unit: grafting the legacy events under this store's room would leave ``next_seq`` behind ``MAX(seq)`` and every later append colliding. Room-scoped tables therefore use a plain INSERT — a row the target refuses raises and aborts the whole import rather than being dropped in silence. A table this store has not created yet (the driver, policy and replica schemas are initialized by their own modules) is created from the source's own DDL so its rows survive the upgrade too. )_EVENT_BYTES_BACKFILLz SELECT room_id FROM hosted_roomszfile:z?mode=roT)uritimeoutzNSELECT name FROM sqlite_master WHERE type='table' AND name GLOB 'hosted_room*'cVR8gV3#) hosted_roomsr)rs&r_copy_rows..WsDN4JD3Qr)keyz;SELECT sql FROM sqlite_master WHERE type='table' AND name=?zSELECT z, c3*"TF wrVxK R#5ir+r)r,r7exprs& rr2_copy_rows..as5P%wqd%sz FROM room_idc3Z<"TF p\VS,4S9gKVxK" R#5ir+)r&)r,r9existing room_indexs& rr2rIds#Tts3z?/C8/Sts+ +INSERTzINSERT OR IGNORErCz INTO z (z ) VALUES (?r) event_bytesz room_id IN ()whereN)_next _migrating)r4r?rr&rsqlite3connectsorted _SKIP_TABLESrendswithrr r;joinindexlist executemanylenrr)r%r!r? copied_roomsr9r$namesrr:r.r7columnsrowsverbrLrMs&& @@r _copy_rowsrcEs; L'-~~6X'YZ'YCF 'YZH 5!9tRP Q QU[(. \)^_)^SV)^_5&QRRD|#t|';t}}Md?e?e--s6>>QTXSZ$\\d\d\fgh$j kl'=E/45u)&vuG5>>GDII5P%5P,P+QQWX\W]"^_DG#$]]95 TtT)~%Dz@DEC O 4 E   &tfBtyy'9&:*TYYsUXY`UaOaEbDccdegk m)S, Mv~1VV NN%,,\$))CRUVbRcLcBdAeef3g,hjv x7 R: | =[_6 F/ R QsEJ$*J9>J)B/J9 J. A0J9J4 AJ9;AJ9)J99 K c$V^8dQhRRRRRR/#)r rrr rrNoner)rs"rrrss'ee0e4eDerc\V4pVe\W4'dR#VPR4VP4'd \ W4M^pTPR\ R24TPR\ R 2\\R4T34TPR4T'd\PR Y24R#R# \ \ P3dYpTPR4TPR4\PT4\PRY$4Rp?R#Rp?ii;i) zCopy the pre-isolation rows in once, then record the marker; never fails the open. The copy runs inside the caller's schema transaction under its own savepoint, so a crash or a refused row leaves either both the copied rows and the marker or neither. NzSAVEPOINT legacy_importzROLLBACK TO legacy_importzRELEASE legacy_importzVhosted rooms: could not import the pre-isolation %s (%s); will retry on the next startzCREATE TABLE IF NOT EXISTS zM (source TEXT PRIMARY KEY, imported_at REAL NOT NULL, rooms INTEGER NOT NULL)zINSERT OR IGNORE INTO z. (source, imported_at, rooms) VALUES (?, ?, ?)z=hosted rooms: imported %d pre-isolation Group Chat(s) from %s)rr"ris_filercOSErrorrTErrorr addloggerwarningrrrinfo)rr r!copiedexcs&& rimport_legacy_roomsrpss  !F ~//LL*+ -3^^-=-=D)1 LL %l^4A BCLL .\] eDk6*, LL()  SU[d W]] # 01 ,-F#o $sC CE)A D<<E)__conditional_annotations____doc__ __future__rloggingrT contextlibrpathlibrgateway.hosted_rooms_commonrrr getLogger__name__rkrr frozensetrWsetr __annotations__rr"r;rcrp)rqs@rr}sw#JJ   8 $ + 567 !U"Y_&+\er