(._stash&s3AGGAJ's<(1,-T22 c,d|jddS)N"r )r)rs rz%sanitize_fts5_query..-s1QWWQZL):rr r )rz re.Match[str]returnstr) _QUOTED_PHRASE_REsub _BOOL_OP_RE_SPECIAL_CHARS_RE_HYPHEN_WORD_RE enumeratereplace_MULTI_SPACE_REstrip)queryrsafeipartrs @rsanitize_fts5_queryr(s  L3   /D ??3 %D  d +D   :D AD\*34||eA3dOT23   sD ) / / 11rct}|} ||vrtjd||S|j||j |}||S|j d}|s|S|}Z)u_위임 체인을 역방향 추적하여 루트 세션 ID를 반환한다. 순환 방지 포함.z(Cycle detected in session lineage at: %sparent_session_id)setloggerwarningadd get_sessionget) session_iddbvisitedcurrentrowparents r_resolve_lineage_rootr75srGG  g  NNEw ON GnnW% ;N,-N rct||kr|S|s|d|Sd}|jjD]G}|jj |jjd}|dk7sE|}n|dk(r|d|S|dz}t d||z }t t|||z}t d||z }|||S)uT쿼리 매칭 위치를 중심으로 max_chars 이하 텍스트 창을 추출한다.Nrr)rr#splitlowerfindmaxmin) full_textr$ max_charspostokenidxhalfstartends r_truncate_around_matchesrHHs 9~" )$$ C$$&oo$$U[[]%8%8%=> "9C    by)$$ >D 3: E c)nei/ 0C 3? #E U3 rc2djd|DS)uI세션 메시지 목록을 '[role] content' 텍스트로 직렬화한다. c3rK|]/}d|jddd|jdxsd1yw)[roleunknownz] contentrN)r0).0rs r z'_format_conversation..bs9`RSqvy12"QUU95E5K4LM`s57)join)messagess r_format_conversationrT`s 99`W_` ``rc d}|g}|r2ddjdt|zd}|j|d|d|dzd }tj|j }tj |_ |j||j} |jt} g} | D]} | d } |r| |k(r| | vr| j| |j| }tt||d }| j!| t#| ||| d | ddt| |k\s| S| S#|jwxYw)u5FTS5 SQL 쿼리 실행 후 결과를 구조화한다.rz AND m.role IN (,?)z SELECT m.session_id, snippet(messages_fts, 0, '', '', '...', 32) AS snip, rank FROM messages_fts JOIN messages m ON messages_fts.rowid = m.id WHERE messages_fts MATCH ?z% ORDER BY rank LIMIT z r1i)rAsniprank)r1root_session_idsummarysnippetscore)rRrextendsqlite3connectdb_pathRow row_factoryexecutefetchallcloser+r. get_messagesrHrTr r7) clean_queryr2 role_filterlimitcurrent_session_id role_clauseparamssqlconnrowsseenresultsr5sidmsgsr]s r_execute_fts_searchrwesrK'=F(#K8H2H)I(J!L  k"#$/-0qyk  C ??2:: &D{{D||C(113 UDG|$ #);";  $;   s#*+?+E{^ab!#8b#A"v;V    w<5  N-, N7 s ; EEct|}|sdgiS t|||||}d|iS#t$r%}tj d||dgicYd}~Sd}~wwxYw)u@FTS5 검색을 수행하고 결과를 포맷하여 반환한다.rtz FTS5 search error (query=%r): %sN)r(rw Exceptionr,r-)r$r2rkrlrmrjrtexcs rsearch_sessionsr{sm&e,K 2%k2{EK]^ w  9;L2s& AA AA)r$rrr)r1rr2'SessionStore'rr)i)r@rr$rrAintrr)rS list[dict]rr) rjrr2r|rklist[str] | Nonerlr}rm str | Nonerr~)NN) r$rr2r|rkrrlr}rmrrdict)__doc__ __future__rreratypingr utils.loggerrutils.session_storer__name__r,compilerrrrr"r(r7rHrTrwr{rrrsM"  #0 H BJJz*bjj,- BJJ{+"**23"**X&28& 0a 888"8  8 # 8  8|%)%)    "    #    r