Function lR

cli.bundle.mjs:591–591

(t)

`)}if(o==="timeline"){try{if(a){let h=a.searchEvents(e,n,c||"",s);p.push(...h.map(g=>({title:`[${g.category}] ${g.type}`,content:g.data,source:"prior-session",origin:"prior-session",timestamp:g.created_at})))}}catch(h){Yl&&process.stderr.write(`[ctx] SessionDB search failed: ${h}
`)}try{let h=iR([e],n,c,u,l);p.push(...h)}catch(h){Yl&&process.stderr.write(`[ctx] auto-memory search failed: ${h}
`)}}for(let h of p)h.timestamp&&!h.timestamp.includes("T")&&(h.timestamp=h.timestamp.replace(" ","T")+"Z");return o==="timeline"&&p.sort((h,g)=>(h.timestamp||"").localeCompare(g.timestamp||"")),p.slice(0,n)}var Yl,uR=x(()=>{"use strict";aR();Yl=process.env.DEBUG?.includes("context-mode")});function uq(t){if(typeof t=="string"){if(t.trim().length===0)return t;try{let n=JSON.parse(t);if(Array.isArray(n))return n}catch{}return[t]}return t}function lR(t){let e=t?{project:j.string().optional().describe("Project scope. Default (omit): this session's project \u2014 auto-resolved from the host adapter. 'global': span every project in the shared store (cross-project recall). <absolute-path>: scope to that specific project directory.")}:{};return j.object({queries:j.preprocess(uq,j.array(j.string()).optional().describe("Array of search queries. Batch ALL questions in one call.")),limit:j.coerce.number().optional().default(3).describe("Results per query (default: 3)"),source:j.string().optional().describe("Filter to a specific indexed source (partial match)."),contentType:j.enum(["code","prose"]).optional().describe("Filter results by content type: 'code' or 'prose'."),sort:j.enum(["relevance","timeline"]).optional().default("relevance").describe("Sort mode. 'relevance' (default): BM25 ranked, current session only. 'timeline': chronological across current session, prior sessions, and auto-memory."),...e})}function dR(t,e,n){if(e)return t===void 0?n():t==="global"?null:t}var ob,pR=x(()=>{"use strict";ql();ob=!!process.env.CONTEXT_MODE_PROJECT_DIR});var Ql,mR=x(()=>{"use strict";Ql=class{#e;#t=new Map;#n;constructor(e,n=4096){this.#e=e,this.#n=Math.max(1,n)}record(e,n=Date.now()){let r=this.#t.get(e);return(!r||n-r.windowStart>this.#e.windowMs)&&(r={count:0,windowStart:n},this.#t.set(e,r),this.#o()),r.count++,{count:r.count,windowStart:r.windowStart,blocked:r.count>this.#e.blockAfter,softCapped:r.count>this.#e.softCapAfter}}size(){return this.#t.size}#o(){if(this.#t.size<=this.#n)return;let e,n=1/0;for(let[r,o]of this.#t)o.windowStart<n&&(n=o.windowStart,e=r);e!==void 0&&this.#t.delete(e)}}});import*as Xe from"node:fs";import*as fR from"node:os";import*as li from"node:path";function ed(t){return t?/[/\\]\.(claude|codex)[/\\]plugins[/\\](cache|marketplaces)[/\\]/.test(t):!1}function pq(t){if(!Xe.existsSync(t.projectsRoot))return;let e,n=0;try{for(let r of Xe.readdirSync(t.projectsRoot)){let o=li.join(t.projectsRoot,r),s;try{s=Xe.statSync(o)}catch{continue}if(!s.isDirectory())continue;let i;try{i=Xe.readdirSync(o)}catch{continue}for(let a of i){if(!a.endsWith(".jsonl"))continue;let c=li.join(o,a);try{let u=Xe.statSync(c).mtimeMs;u>n&&(n=u,e=c)}catch{}}}}catch{return}if(e&&!(typeof t.maxAgeMs=="number"&&(t.nowMs??Date.now())-n>t.maxAgeMs))try{let r=Xe.openSync(e,"r");try{let o=Buffer.alloc(8192),s=Xe.readSync(r,o,0,o.length,0),i=o.subarray(0,s).toString("utf-8");for(let a of i.split(`
`).slice(0,10))if(a.trim())try{let c=JSON.parse(a);if(typeof c.cwd=="string"&&c.cwd.length>0)return c.cwd}catch{}}finally{Xe.closeSync(r)}}catch{}}function mq(t){let e=t?.codexHome??process.env.CODEX_HOME??li.join(fR.homedir(),".codex"),n=li.join(e,"sessions");if(!Xe.existsSync(n))return null;let r=4,o=1e4,s=0,i,a=0,c=(u,l)=>{if(s>=o)return;let d;try{d=Xe.readdirSync(u)}catch{return}d.sort().reverse();for(let p of d){if(s>=o)return;s++;let f=li.join(u,p),m;try{m=Xe.statSync(f)}catch{continue}if(m.isDirectory()){l<r&&c(f,l+1);continue}if(!m.isFile()||!p.endsWith(".jsonl"))continue;let h=m.mtimeMs;h>a&&(a=h,i=f)}};try{c(n,0)}catch{return null}if(!i||typeof t?.transcriptMaxAgeMs=="number"&&(t.now??Date.now())-a>t.transcriptMaxAgeMs)return null;try{let u=Xe.openSync(i,"r");try{let l=Buffer.alloc(1048576),d=Xe.readSync(u,l,0,l.length,0),p=l.subarray(0,d).toString("utf-8");for(let f of p.split(`
`).slice(0,10))if(f.trim())try{let m=JSON.parse(f),h=m?.meta?.cwd??(m?.type==="session_meta"?m?.payload?.cwd:void 0);if(typeof h!="string"||h.length===0)continue;return ed(h)?null:h}catch{return null}}finally{Xe.closeSync(u)}}catch{return null}return null}function hR(t){let{env:e,cwd:n,pwd:r,transcriptsRoot:o,transcriptMaxAgeMs:s,nowMs:i,strictPlatform:a,codexHome:c}=t,u=a?[...lm(a),...lq]:dq;for(let l of u){let d=e[l];if(d&&!ed(d))return d}if(o){let l=pq({projectsRoot:o,maxAgeMs:s,nowMs:i});if(l&&!ed(l))return l}if(a==="codex"){let l=mq({codexHome:c,transcriptMaxAgeMs:s,now:i});if(l)return l}return r&&!ed(r)?r:n}var lq,dq,gR=x(()=>{"use strict";uo();lq=["CONTEXT_MODE_PROJECT_DIR"],dq=["CLAUDE_PROJECT_DIR","GEMINI_PROJECT_DIR","VSCODE_CWD","OPENCODE_PROJECT_DIR","PI_PROJECT_DIR","IDEA_INITIAL_DIRECTORY","CURSOR_CWD","CONTEXT_MODE_PROJECT_DIR"]});import{execFileSync as fq}from"node:child_process";import{existsSync as ar,readdirSync as di,statSync as hq}from"node:fs";import{homedir as sd}from"node:os";import{join as qt,sep as gq}from"node:path";function wR(t,e){let n=t.split(".").map(Number),r=e.split(".").map(Number);for(let o=0;o<3;o++){if((n[o]??0)>(r[o]??0))return!0;if((n[o]??0)<(r[o]??0))return!1}return!1}function _q(t){let e=t?.home??sd();return[["claude-code",[".claude"]],["gemini-cli",[".gemini"]],["antigravity",[".gemini"]],["antigravity-cli",[".gemini"]],["openclaw",[".openclaw"]],["codex",[".codex"]],["cursor",[".cursor"]],["vscode-copilot",[".vscode"]],["copilot-cli",[".copilot"]],["kiro",[".kiro"]],["pi",[".pi"]],["omp",[".omp"]],["qwen-code",[".qwen"]],["kilo",[".config","kilo"]],["opencode",[".config","opencode"]],["zed",[".config","zed"]],["jetbrains-copilot",[".config","JetBrains"]]].map(([r,o])=>{let s=qt(e,...o,"context-mode");return{name:r,sessionsDir:qt(s,"sessions"),contentDir:qt(s,"content")}})}function bq(t){let n=t.replace(/\.md$/i,"").match(/^([a-z]+)/i);return n?n[1].toLowerCase():"other"}function ec(t){let e=Ze(),n=t?.sessionsDir??qt(e,"context-mode","sessions"),r=t?.memoryRoot??qt(e,"projects"),o=0,s=0,i=0,a=Number.POSITIVE_INFINITY,c=new Set,u={};if(ar(n)){let f=[];try{f=di(n).filter(m=>m.endsWith(".db"))}catch{}if(f.length>0){let m=null;try{m=t?.loadDatabase?t.loadDatabase():nt()}catch{}if(m)for(let h of f){let g=qt(n,h);try{let y=new m(g,{readonly:!0});try{let _=y.prepare("SELECT COUNT(*) AS cnt FROM session_events").get(),b=y.prepare("SELECT COUNT(*) AS cnt FROM session_meta").get();o+=_?.cnt??0,s+=b?.cnt??0;try{let S=y.prepare("SELECT category, COUNT(*) AS cnt FROM session_events GROUP BY category").all();for(let T of S)T.category&&(u[T.category]=(u[T.category]??0)+(T.cnt??0))}catch{}try{let S=y.prepare("SELECT COALESCE(SUM(length(snapshot)), 0) AS bytes FROM session_resume WHERE consumed = 1").get();S?.bytes&&(i+=S.bytes)}catch{}try{let S=y.prepare("SELECT MIN(created_at) AS t FROM session_events").get();if(S?.t){let T=S.t.endsWith("Z")?S.t:S.t+"Z",M=Date.parse(T);Number.isFinite(M)&&M<a&&(a=M)}}catch{}try{let S=y.prepare("SELECT DISTINCT project_dir AS p FROM session_events WHERE project_dir != ''").all();for(let T of S)T.p&&c.add(T.p)}catch{}}finally{y.close()}}catch{}}}}let l=0,d=0,p={};if(ar(r)){let f=[];try{f=di(r).filter(m=>{try{return hq(qt(r,m)).isDirectory()}catch{return!1}})}catch{}for(let m of f){let h=qt(r,m,"memory");if(!ar(h))continue;let g=[];try{g=di(h).filter(y=>y.endsWith(".md"))}catch{continue}if(g.length!==0){d++,l+=g.length;for(let y of g){let _=bq(y);p[_]=(p[_]??0)+1}}}}return{totalEvents:o,totalSessions:s,autoMemoryCount:l,autoMemoryProjects:d,autoMemoryByPrefix:p,categoryCounts:u,rescueBytes:i,firstEventMs:Number.isFinite(a)?a:0,distinctProjects:c.size}}function ER(t){let e=t.sessionsDir??qt(sd(),".claude","context-mode","sessions"),n=t.sessionId,r={sessionId:n,events:0,dbCount:0,daysAlive:0,snapshotBytes:0,snapshotsConsumed:0,byCategory:[]};if(!n||!ar(e))return r;let o=[];try{o=di(e).filter(b=>!(!b.endsWith(".db")||t.worktreeHash&&!b.startsWith(t.worktreeHash)))}catch{return r}if(o.length===0)return r;let s=null;try{s=t.loadDatabase?t.loadDatabase():nt()}catch{return r}if(!s)return r;let i={},a=0,c=0,u=0,l=0,d=Number.POSITIVE_INFINITY,p=0,f=0,m=new Map,h=b=>Math.floor(b/864e5)*864e5;for(let b of o){let S=qt(e,b),T=!1;try{let M=new s(S,{readonly:!0});try{let v=M.prepare("SELECT category, COUNT(*) AS cnt FROM session_events WHERE session_id = ? GROUP BY category").all(n);for(let P of v)P.category&&(i[P.category]=(i[P.category]??0)+(P.cnt??0),a+=P.cnt??0,T=!0);let $=M.prepare("SELECT MIN(created_at) AS mn, MAX(created_at) AS mx FROM session_events WHERE session_id = ?").get(n);if($?.mn){let P=Date.parse($.mn+($.mn.endsWith("Z")?"":"Z"));Number.isFinite(P)&&P<d&&(d=P)}if($?.mx){let P=Date.parse($.mx+($.mx.endsWith("Z")?"":"Z"));Number.isFinite(P)&&P>p&&(p=P)}try{let P=M.prepare("SELECT strftime('%s', created_at) AS sec, COUNT(*) AS cnt FROM session_events WHERE session_id = ? GROUP BY date(created_at)").all(n);for(let A of P){if(!A.sec)continue;let R=parseInt(A.sec,10)*1e3;if(!Number.isFinite(R))continue;let C=h(R),H=m.get(C)??{count:0,rescueBytes:0};H.count+=A.cnt??0,m.set(C,H)}}catch{}try{let P=M.prepare("SELECT COALESCE(SUM(length(snapshot)), 0) AS bytes, COUNT(*) AS n, MAX(strftime('%s', created_at)) AS lastSec FROM session_resume WHERE session_id = ? AND consumed = 1").get(n);if(P?.bytes&&(u+=P.bytes),P?.n&&(l+=P.n),P?.lastSec){let A=parseInt(P.lastSec,10)*1e3;if(Number.isFinite(A)&&A>f&&(f=A),Number.isFinite(A)&&(P?.bytes??0)>0){let R=h(A),C=m.get(R)??{count:0,rescueBytes:0};C.rescueBytes=Math.max(C.rescueBytes,P.bytes),m.set(R,C)}}}catch{}}finally{M.close()}}catch{}T&&c++}let g=d<p?(p-d)/864e5:0,y=Object.entries(i).filter(([,b])=>b>0).map(([b,S])=>({category:b,count:S,label:nd[b]||b})).sort((b,S)=>S.count-b.count),_=[...m.entries()].sort((b,S)=>b[0]-S[0]).map(([b,S])=>({ms:b,count:S.count,...S.rescueBytes>0?{rescueBytes:S.rescueBytes}:{}}));return{sessionId:n,events:a,dbCount:c,daysAlive:g,snapshotBytes:u,snapshotsConsumed:l,byCategory:y,firstEventMs:Number.isFinite(d)?d:0,lastEventMs:p>0?p:0,lastRescueMs:f>0?f:void 0,byDay:_}}function xq(t,e,n){if(!t||!e||!ar(e))return 0;let r=null;try{r=n?.loadDatabase?n.loadDatabase():nt()}catch{return 0}if(!r)return 0;try{let o=new r(e,{readonly:!0});try{let s=o.prepare(`SELECT COALESCE(SUM(LENGTH(content) + LENGTH(title)), 0) AS bytes
         FROM chunks WHERE session_id = ?`).get(t);return Number(s?.bytes??0)}finally{o.close()}}catch{return 0}}function TR(t,e){if(!t||!ar(t))return 0;let n=null;try{n=e?.loadDatabase?e.loadDatabase():nt()}catch{return 0}if(!n)return 0;try{let r=new n(t,{readonly:!0});try{let o=r.prepare(`SELECT COALESCE(SUM(LENGTH(content) + LENGTH(title)), 0) AS bytes