diff --git a/.claude-plugin/marketplace.json b/.claude-plugin/marketplace.json index db6baca0..b28402d2 100644 --- a/.claude-plugin/marketplace.json +++ b/.claude-plugin/marketplace.json @@ -10,7 +10,7 @@ "plugins": [ { "name": "claude-mem", - "version": "10.5.2", + "version": "10.5.3", "source": "./plugin", "description": "Persistent memory system for Claude Code - context compression across sessions" } diff --git a/package.json b/package.json index fc64334f..8f27ea66 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "claude-mem", - "version": "10.5.2", + "version": "10.5.3", "description": "Memory compression system for Claude Code - persist context across sessions", "keywords": [ "claude", diff --git a/plugin/.claude-plugin/plugin.json b/plugin/.claude-plugin/plugin.json index ec2e7707..a8ae05f3 100644 --- a/plugin/.claude-plugin/plugin.json +++ b/plugin/.claude-plugin/plugin.json @@ -1,6 +1,6 @@ { "name": "claude-mem", - "version": "10.5.2", + "version": "10.5.3", "description": "Persistent memory system for Claude Code - seamlessly preserve context across sessions", "author": { "name": "Alex Newman" diff --git a/plugin/modes/code--ar.json b/plugin/hooks/modes/code--ar.json similarity index 100% rename from plugin/modes/code--ar.json rename to plugin/hooks/modes/code--ar.json diff --git a/plugin/modes/code--bn.json b/plugin/hooks/modes/code--bn.json similarity index 100% rename from plugin/modes/code--bn.json rename to plugin/hooks/modes/code--bn.json diff --git a/plugin/modes/code--chill.json b/plugin/hooks/modes/code--chill.json similarity index 100% rename from plugin/modes/code--chill.json rename to plugin/hooks/modes/code--chill.json diff --git a/plugin/modes/code--cs.json b/plugin/hooks/modes/code--cs.json similarity index 100% rename from plugin/modes/code--cs.json rename to plugin/hooks/modes/code--cs.json diff --git a/plugin/modes/code--da.json b/plugin/hooks/modes/code--da.json similarity index 100% rename from plugin/modes/code--da.json rename to plugin/hooks/modes/code--da.json diff --git a/plugin/modes/code--de.json b/plugin/hooks/modes/code--de.json similarity index 100% rename from plugin/modes/code--de.json rename to plugin/hooks/modes/code--de.json diff --git a/plugin/modes/code--el.json b/plugin/hooks/modes/code--el.json similarity index 100% rename from plugin/modes/code--el.json rename to plugin/hooks/modes/code--el.json diff --git a/plugin/modes/code--es.json b/plugin/hooks/modes/code--es.json similarity index 100% rename from plugin/modes/code--es.json rename to plugin/hooks/modes/code--es.json diff --git a/plugin/modes/code--fi.json b/plugin/hooks/modes/code--fi.json similarity index 100% rename from plugin/modes/code--fi.json rename to plugin/hooks/modes/code--fi.json diff --git a/plugin/modes/code--fr.json b/plugin/hooks/modes/code--fr.json similarity index 100% rename from plugin/modes/code--fr.json rename to plugin/hooks/modes/code--fr.json diff --git a/plugin/modes/code--he.json b/plugin/hooks/modes/code--he.json similarity index 100% rename from plugin/modes/code--he.json rename to plugin/hooks/modes/code--he.json diff --git a/plugin/modes/code--hi.json b/plugin/hooks/modes/code--hi.json similarity index 100% rename from plugin/modes/code--hi.json rename to plugin/hooks/modes/code--hi.json diff --git a/plugin/modes/code--hu.json b/plugin/hooks/modes/code--hu.json similarity index 100% rename from plugin/modes/code--hu.json rename to plugin/hooks/modes/code--hu.json diff --git a/plugin/modes/code--id.json b/plugin/hooks/modes/code--id.json similarity index 100% rename from plugin/modes/code--id.json rename to plugin/hooks/modes/code--id.json diff --git a/plugin/modes/code--it.json b/plugin/hooks/modes/code--it.json similarity index 100% rename from plugin/modes/code--it.json rename to plugin/hooks/modes/code--it.json diff --git a/plugin/modes/code--ja.json b/plugin/hooks/modes/code--ja.json similarity index 100% rename from plugin/modes/code--ja.json rename to plugin/hooks/modes/code--ja.json diff --git a/plugin/modes/code--ko.json b/plugin/hooks/modes/code--ko.json similarity index 100% rename from plugin/modes/code--ko.json rename to plugin/hooks/modes/code--ko.json diff --git a/plugin/modes/code--nl.json b/plugin/hooks/modes/code--nl.json similarity index 100% rename from plugin/modes/code--nl.json rename to plugin/hooks/modes/code--nl.json diff --git a/plugin/modes/code--no.json b/plugin/hooks/modes/code--no.json similarity index 100% rename from plugin/modes/code--no.json rename to plugin/hooks/modes/code--no.json diff --git a/plugin/modes/code--pl.json b/plugin/hooks/modes/code--pl.json similarity index 100% rename from plugin/modes/code--pl.json rename to plugin/hooks/modes/code--pl.json diff --git a/plugin/modes/code--pt-br.json b/plugin/hooks/modes/code--pt-br.json similarity index 100% rename from plugin/modes/code--pt-br.json rename to plugin/hooks/modes/code--pt-br.json diff --git a/plugin/modes/code--ro.json b/plugin/hooks/modes/code--ro.json similarity index 100% rename from plugin/modes/code--ro.json rename to plugin/hooks/modes/code--ro.json diff --git a/plugin/modes/code--ru.json b/plugin/hooks/modes/code--ru.json similarity index 100% rename from plugin/modes/code--ru.json rename to plugin/hooks/modes/code--ru.json diff --git a/plugin/modes/code--sv.json b/plugin/hooks/modes/code--sv.json similarity index 100% rename from plugin/modes/code--sv.json rename to plugin/hooks/modes/code--sv.json diff --git a/plugin/modes/code--th.json b/plugin/hooks/modes/code--th.json similarity index 100% rename from plugin/modes/code--th.json rename to plugin/hooks/modes/code--th.json diff --git a/plugin/modes/code--tr.json b/plugin/hooks/modes/code--tr.json similarity index 100% rename from plugin/modes/code--tr.json rename to plugin/hooks/modes/code--tr.json diff --git a/plugin/modes/code--uk.json b/plugin/hooks/modes/code--uk.json similarity index 100% rename from plugin/modes/code--uk.json rename to plugin/hooks/modes/code--uk.json diff --git a/plugin/modes/code--ur.json b/plugin/hooks/modes/code--ur.json similarity index 100% rename from plugin/modes/code--ur.json rename to plugin/hooks/modes/code--ur.json diff --git a/plugin/modes/code--vi.json b/plugin/hooks/modes/code--vi.json similarity index 100% rename from plugin/modes/code--vi.json rename to plugin/hooks/modes/code--vi.json diff --git a/plugin/modes/code--zh.json b/plugin/hooks/modes/code--zh.json similarity index 100% rename from plugin/modes/code--zh.json rename to plugin/hooks/modes/code--zh.json diff --git a/plugin/modes/code.json b/plugin/hooks/modes/code.json similarity index 100% rename from plugin/modes/code.json rename to plugin/hooks/modes/code.json diff --git a/plugin/modes/email-investigation.json b/plugin/hooks/modes/email-investigation.json similarity index 100% rename from plugin/modes/email-investigation.json rename to plugin/hooks/modes/email-investigation.json diff --git a/plugin/package.json b/plugin/package.json index 9f635681..91566664 100644 --- a/plugin/package.json +++ b/plugin/package.json @@ -1,6 +1,6 @@ { "name": "claude-mem-plugin", - "version": "10.5.2", + "version": "10.5.3", "private": true, "description": "Runtime dependencies for claude-mem bundled hooks", "type": "module", diff --git a/plugin/scripts/mcp-server.cjs b/plugin/scripts/mcp-server.cjs index 129cba56..f9d8c37a 100755 --- a/plugin/scripts/mcp-server.cjs +++ b/plugin/scripts/mcp-server.cjs @@ -114,7 +114,7 @@ Set the \`cycles\` parameter to \`"ref"\` to resolve cyclical schemas with defs. ${c}`}var _P=new Set([".js",".jsx",".ts",".tsx",".mjs",".cjs",".py",".pyw",".go",".rs",".rb",".java",".cs",".cpp",".c",".h",".hpp",".swift",".kt",".php",".vue",".svelte"]),yP=new Set(["node_modules",".git","dist","build",".next","__pycache__",".venv","venv","env",".env","target","vendor",".cache",".turbo","coverage",".nyc_output",".claude",".smart-file-read"]),$P=512*1024;async function*a$(e,t,r=20){if(r<=0)return;let n;try{n=await(0,Sn.readdir)(e,{withFileTypes:!0})}catch{return}for(let o of n){if(o.name.startsWith(".")&&o.name!=="."||yP.has(o.name))continue;let i=(0,pi.join)(e,o.name);if(o.isDirectory())yield*a$(i,t,r-1);else if(o.isFile()){let a=o.name.slice(o.name.lastIndexOf("."));_P.has(a)&&(yield i)}}}async function bP(e){try{let t=await(0,Sn.stat)(e);if(t.size>$P||t.size===0)return null;let r=await(0,Sn.readFile)(e,"utf-8");return r.slice(0,1e3).includes("\0")?null:r}catch{return null}}async function s$(e,t,r={}){let n=r.maxResults||20,o=t.toLowerCase(),i=o.split(/[\s_\-./]+/).filter(h=>h.length>0),a=[];for await(let h of a$(e,e)){if(r.filePattern&&!(0,pi.relative)(e,h).toLowerCase().includes(r.filePattern.toLowerCase()))continue;let _=await bP(h);_&&a.push({absolutePath:h,relativePath:(0,pi.relative)(e,h),content:_})}let s=n$(a),c=[],u=[],l=0;for(let[h,_]of s){l+=xP(_);let E=Os(h.toLowerCase(),i)>0,I=[],A=(j,Le)=>{for(let de of j){let Kt=0,Qe="",Ht=Os(de.name.toLowerCase(),i);Ht>0&&(Kt+=Ht*3,Qe="name match"),de.signature.toLowerCase().includes(o)&&(Kt+=2,Qe=Qe?`${Qe} + signature`:"signature match"),de.jsdoc&&de.jsdoc.toLowerCase().includes(o)&&(Kt+=1,Qe=Qe?`${Qe} + jsdoc`:"jsdoc match"),Kt>0&&(E=!0,I.push({filePath:h,symbolName:Le?`${Le}.${de.name}`:de.name,kind:de.kind,signature:de.signature,jsdoc:de.jsdoc,lineStart:de.lineStart,lineEnd:de.lineEnd,matchReason:Qe})),de.children&&A(de.children,de.name)}};A(_.symbols),E&&(c.push(_),u.push(...I))}u.sort((h,_)=>{let b=Os(h.symbolName.toLowerCase(),i);return Os(_.symbolName.toLowerCase(),i)-b});let d=u.slice(0,n),m=new Set(d.map(h=>h.filePath)),p=c.filter(h=>m.has(h.filePath)).slice(0,n),g=p.reduce((h,_)=>h+_.foldedTokenEstimate,0);return{foldedFiles:p,matchingSymbols:d,totalFilesScanned:a.length,totalSymbolsFound:l,tokenEstimate:g}}function Os(e,t){let r=0;for(let n of t)if(e===n)r+=10;else if(e.includes(n))r+=5;else{let o=0,i=0;for(let a of n){let s=e.indexOf(a,o);s!==-1&&(i++,o=s+1)}i===n.length&&(r+=1)}return r}function xP(e){let t=e.symbols.length;for(let r of e.symbols)r.children&&(t+=r.children.length);return t}function c$(e,t){let r=[];if(r.push(`\u{1F50D} Smart Search: "${t}"`),r.push(` Scanned ${e.totalFilesScanned} files, found ${e.totalSymbolsFound} symbols`),r.push(` ${e.matchingSymbols.length} matches across ${e.foldedFiles.length} files (~${e.tokenEstimate} tokens for folded view)`),r.push(""),e.matchingSymbols.length===0)return r.push(" No matching symbols found."),r.join(` `);r.push("\u2500\u2500 Matching Symbols \u2500\u2500"),r.push("");for(let n of e.matchingSymbols){if(r.push(` ${n.kind} ${n.symbolName} (${n.filePath}:${n.lineStart+1})`),r.push(` ${n.signature}`),n.jsdoc){let o=n.jsdoc.split(` `).find(i=>i.replace(/^[\s*/]+/,"").trim().length>0);o&&r.push(` \u{1F4AC} ${o.replace(/^[\s*/]+/,"").trim()}`)}r.push("")}r.push("\u2500\u2500 Folded File Views \u2500\u2500"),r.push("");for(let n of e.foldedFiles)r.push(kn(n)),r.push("");return r.push("\u2500\u2500 Actions \u2500\u2500"),r.push(" To see full implementation: use smart_unfold with file path and symbol name"),r.join(` -`)}var Tf=require("node:fs/promises"),js=require("node:path"),kP="10.5.2";console.log=(...e)=>{ve.error("CONSOLE","Intercepted console output (MCP protocol protection)",void 0,{args:e})};var SP=Wy(),wP=Ky(),mi=`http://${wP}:${SP}`,u$={search:"/api/search",timeline:"/api/timeline"};async function l$(e,t){ve.debug("SYSTEM","\u2192 Worker API",void 0,{endpoint:e,params:t});try{let r=new URLSearchParams;for(let[a,s]of Object.entries(t))s!=null&&r.append(a,String(s));let n=`${mi}${e}?${r}`,o=await fetch(n);if(!o.ok){let a=await o.text();throw new Error(`Worker API error (${o.status}): ${a}`)}let i=await o.json();return ve.debug("SYSTEM","\u2190 Worker API success",void 0,{endpoint:e}),i}catch(r){return ve.error("SYSTEM","\u2190 Worker API error",{endpoint:e},r),{content:[{type:"text",text:`Error calling Worker API: ${r instanceof Error?r.message:String(r)}`}],isError:!0}}}async function zP(e,t){ve.debug("HTTP","Worker API request (POST)",void 0,{endpoint:e});try{let r=`${mi}${e}`,n=await fetch(r,{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify(t)});if(!n.ok){let i=await n.text();throw new Error(`Worker API error (${n.status}): ${i}`)}let o=await n.json();return ve.debug("HTTP","Worker API success (POST)",void 0,{endpoint:e}),{content:[{type:"text",text:JSON.stringify(o,null,2)}]}}catch(r){return ve.error("HTTP","Worker API error (POST)",{endpoint:e},r),{content:[{type:"text",text:`Error calling Worker API: ${r instanceof Error?r.message:String(r)}`}],isError:!0}}}async function IP(){try{return(await fetch(`${mi}/api/health`)).ok}catch(e){return ve.debug("SYSTEM","Worker health check failed",{},e),!1}}var d$=[{name:"__IMPORTANT",description:`3-LAYER WORKFLOW (ALWAYS FOLLOW): +`)}var Tf=require("node:fs/promises"),js=require("node:path"),kP="10.5.3";console.log=(...e)=>{ve.error("CONSOLE","Intercepted console output (MCP protocol protection)",void 0,{args:e})};var SP=Wy(),wP=Ky(),mi=`http://${wP}:${SP}`,u$={search:"/api/search",timeline:"/api/timeline"};async function l$(e,t){ve.debug("SYSTEM","\u2192 Worker API",void 0,{endpoint:e,params:t});try{let r=new URLSearchParams;for(let[a,s]of Object.entries(t))s!=null&&r.append(a,String(s));let n=`${mi}${e}?${r}`,o=await fetch(n);if(!o.ok){let a=await o.text();throw new Error(`Worker API error (${o.status}): ${a}`)}let i=await o.json();return ve.debug("SYSTEM","\u2190 Worker API success",void 0,{endpoint:e}),i}catch(r){return ve.error("SYSTEM","\u2190 Worker API error",{endpoint:e},r),{content:[{type:"text",text:`Error calling Worker API: ${r instanceof Error?r.message:String(r)}`}],isError:!0}}}async function zP(e,t){ve.debug("HTTP","Worker API request (POST)",void 0,{endpoint:e});try{let r=`${mi}${e}`,n=await fetch(r,{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify(t)});if(!n.ok){let i=await n.text();throw new Error(`Worker API error (${n.status}): ${i}`)}let o=await n.json();return ve.debug("HTTP","Worker API success (POST)",void 0,{endpoint:e}),{content:[{type:"text",text:JSON.stringify(o,null,2)}]}}catch(r){return ve.error("HTTP","Worker API error (POST)",{endpoint:e},r),{content:[{type:"text",text:`Error calling Worker API: ${r instanceof Error?r.message:String(r)}`}],isError:!0}}}async function IP(){try{return(await fetch(`${mi}/api/health`)).ok}catch(e){return ve.debug("SYSTEM","Worker health check failed",{},e),!1}}var d$=[{name:"__IMPORTANT",description:`3-LAYER WORKFLOW (ALWAYS FOLLOW): 1. search(query) \u2192 Get index with IDs (~50-100 tokens/result) 2. timeline(anchor=ID) \u2192 Get context around interesting results 3. get_observations([IDs]) \u2192 Fetch full details ONLY for filtered IDs diff --git a/plugin/scripts/worker-service.cjs b/plugin/scripts/worker-service.cjs index 0b897c2d..31296e8f 100755 --- a/plugin/scripts/worker-service.cjs +++ b/plugin/scripts/worker-service.cjs @@ -920,7 +920,7 @@ Set the \`cycles\` parameter to \`"ref"\` to resolve cyclical schemas with defs. WHERE s.project = ? `).get(r);w.info("CHROMA_SYNC","Backfilling user prompts",{project:r,missing:m.length,existing:n.prompts.size,total:y.count});let v=[];for(let b of m)v.push(this.formatUserPromptDoc(b));for(let b=0;bs.trim()).find(s=>s.length>0)||null}catch{return null}}function rK(t={}){let e=t.platform??process.platform,r=t.execPath??process.execPath;if(e!=="win32"||sA(r))return r;let n=t.env??process.env,i=t.homeDirectory??(0,N0.homedir)(),s=t.pathExists??Bt.existsSync,o=t.lookupInPath??tK,a=[n.BUN,n.BUN_PATH,bi.default.join(i,".bun","bin","bun.exe"),bi.default.join(i,".bun","bin","bun"),n.USERPROFILE?bi.default.join(n.USERPROFILE,".bun","bin","bun.exe"):void 0,n.LOCALAPPDATA?bi.default.join(n.LOCALAPPDATA,"bun","bun.exe"):void 0,n.LOCALAPPDATA?bi.default.join(n.LOCALAPPDATA,"bun","bin","bun.exe"):void 0];for(let c of a){let u=c?.trim();if(u&&(sA(u)&&s(u)||u.toLowerCase()==="bun"))return u}return o("bun",e)}function aA(t){(0,Bt.mkdirSync)(M0,{recursive:!0}),(0,Bt.writeFileSync)(Si,JSON.stringify(t,null,2))}function Um(){if(!(0,Bt.existsSync)(Si))return null;try{return JSON.parse((0,Bt.readFileSync)(Si,"utf-8"))}catch(t){return w.warn("SYSTEM","Failed to parse PID file",{path:Si},t),null}}function Yn(){if((0,Bt.existsSync)(Si))try{(0,Bt.unlinkSync)(Si)}catch(t){w.warn("SYSTEM","Failed to remove PID file",{path:Si},t)}}function Os(t){return process.platform==="win32"?Math.round(t*2):t}async function cA(t){if(process.platform!=="win32")return[];if(!Number.isInteger(t)||t<=0)return w.warn("SYSTEM","Invalid parent PID for child process enumeration",{parentPid:t}),[];try{let e=`powershell -NoProfile -NonInteractive -Command "Get-CimInstance Win32_Process -Filter 'ParentProcessId=${t}' | Select-Object -ExpandProperty ProcessId"`,{stdout:r}=await zm(e,{timeout:Cr.POWERSHELL_COMMAND,windowsHide:!0});return r.split(` `).map(n=>n.trim()).filter(n=>n.length>0&&/^\d+$/.test(n)).map(n=>parseInt(n,10)).filter(n=>n>0)}catch(e){return w.error("SYSTEM","Failed to enumerate child processes",{parentPid:t},e),[]}}async function uA(t){if(!Number.isInteger(t)||t<=0){w.warn("SYSTEM","Invalid PID for force kill",{pid:t});return}try{process.platform==="win32"?await zm(`taskkill /PID ${t} /T /F`,{timeout:Cr.POWERSHELL_COMMAND,windowsHide:!0}):process.kill(t,"SIGKILL"),w.info("SYSTEM","Killed process",{pid:t})}catch(e){w.debug("SYSTEM","Process already exited during force kill",{pid:t},e)}}async function lA(t,e){let r=Date.now();for(;Date.now()-r{try{return process.kill(i,0),!0}catch{return!1}});if(n.length===0){w.info("SYSTEM","All child processes exited");return}w.debug("SYSTEM","Waiting for processes to exit",{stillAlive:n}),await new Promise(i=>setTimeout(i,100))}w.warn("SYSTEM","Timeout waiting for child processes to exit")}function nK(t){if(!t||t.trim()==="")return-1;let e=t.trim(),r=0,n=e.match(/^(\d+)-(\d+):(\d+):(\d+)$/);if(n)return r=parseInt(n[1],10)*24*60+parseInt(n[2],10)*60+parseInt(n[3],10),r;let i=e.match(/^(\d+):(\d+):(\d+)$/);if(i)return r=parseInt(i[1],10)*60+parseInt(i[2],10),r;let s=e.match(/^(\d+):(\d+)$/);return s?parseInt(s[1],10):-1}var A0=["worker-service.cjs","chroma-mcp"],iK=["mcp-server.cjs"];async function dA(){let t=process.platform==="win32",e=process.pid,r=[],n=[...A0,...iK];try{if(t){let s=`powershell -NoProfile -NonInteractive -Command "Get-CimInstance Win32_Process -Filter '(${n.map(l=>`CommandLine LIKE '%${l}%'`).join(" OR ")}) AND ProcessId != ${e}' | Select-Object ProcessId, CommandLine, CreationDate | ConvertTo-Json"`,{stdout:o}=await zm(s,{timeout:Cr.POWERSHELL_COMMAND,windowsHide:!0});if(!o.trim()||o.trim()==="null"){w.debug("SYSTEM","No orphaned claude-mem processes found (Windows)");return}let a=JSON.parse(o),c=Array.isArray(a)?a:[a],u=Date.now();for(let l of c){let d=l.ProcessId;if(!Number.isInteger(d)||d<=0||d===e)continue;let p=l.CommandLine||"";if(A0.some(g=>p.includes(g)))r.push(d),w.debug("SYSTEM","Found orphaned process (aggressive)",{pid:d,commandLine:p.substring(0,80)});else{let g=l.CreationDate?.match(/\/Date\((\d+)\)\//);if(g){let _=parseInt(g[1],10),h=(u-_)/(1e3*60);h>=iA&&(r.push(d),w.debug("SYSTEM","Found orphaned process (age-gated)",{pid:d,ageMinutes:Math.round(h)}))}}}}else{let i=n.join("|"),{stdout:s}=await zm(`ps -eo pid,etime,command | grep -E "${i}" | grep -v grep || true`);if(!s.trim()){w.debug("SYSTEM","No orphaned claude-mem processes found (Unix)");return}let o=s.trim().split(` -`);for(let a of o){let c=a.trim().match(/^(\d+)\s+(\S+)\s+(.*)$/);if(!c)continue;let u=parseInt(c[1],10),l=c[2],d=c[3];if(!Number.isInteger(u)||u<=0||u===e)continue;if(A0.some(f=>d.includes(f)))r.push(u),w.debug("SYSTEM","Found orphaned process (aggressive)",{pid:u,command:d.substring(0,80)});else{let f=nK(l);f>=iA&&(r.push(u),w.debug("SYSTEM","Found orphaned process (age-gated)",{pid:u,ageMinutes:f,command:d.substring(0,80)}))}}}}catch(i){w.error("SYSTEM","Failed to enumerate orphaned processes during aggressive cleanup",{},i);return}if(r.length!==0){if(w.info("SYSTEM","Aggressive startup cleanup: killing orphaned processes",{platform:t?"Windows":"Unix",count:r.length,pids:r}),t){for(let i of r)if(!(!Number.isInteger(i)||i<=0))try{(0,Yi.execSync)(`taskkill /PID ${i} /T /F`,{timeout:Cr.POWERSHELL_COMMAND,stdio:"ignore",windowsHide:!0})}catch(s){w.debug("SYSTEM","Failed to kill process, may have already exited",{pid:i},s)}}else for(let i of r)try{process.kill(i,"SIGKILL")}catch(s){w.debug("SYSTEM","Process already exited",{pid:i},s)}w.info("SYSTEM","Aggressive startup cleanup complete",{count:r.length})}}var sK=".chroma-cleaned-v10.3";function pA(t){let e=t??M0,r=bi.default.join(e,sK),n=bi.default.join(e,"chroma");if((0,Bt.existsSync)(r)){w.debug("SYSTEM","Chroma migration marker exists, skipping wipe");return}w.warn("SYSTEM","Running one-time chroma data wipe (upgrade from pre-v10.3)",{chromaDir:n}),(0,Bt.existsSync)(n)&&((0,Bt.rmSync)(n,{recursive:!0,force:!0}),w.info("SYSTEM","Chroma data directory removed",{chromaDir:n})),(0,Bt.mkdirSync)(e,{recursive:!0}),(0,Bt.writeFileSync)(r,new Date().toISOString()),w.info("SYSTEM","Chroma migration marker written",{markerPath:r})}function D0(t,e,r={}){let n=process.platform==="win32",i={...process.env,CLAUDE_MEM_WORKER_PORT:String(e),...r};if(n){let a=rK();if(!a){w.error("SYSTEM","Failed to locate Bun runtime for Windows worker spawn");return}let c=a.replace(/'/g,"''"),u=t.replace(/'/g,"''"),l=`Start-Process -FilePath '${c}' -ArgumentList '${u}','--daemon' -WindowStyle Hidden`;try{return(0,Yi.execSync)(`powershell -NoProfile -Command "${l}"`,{stdio:"ignore",windowsHide:!0,env:i}),0}catch(d){w.error("SYSTEM","Failed to spawn worker daemon on Windows",{runtimePath:a},d);return}}let s="/usr/bin/setsid";if((0,Bt.existsSync)(s)){let a=(0,Yi.spawn)(s,[process.execPath,t,"--daemon"],{detached:!0,stdio:"ignore",env:i});return a.pid===void 0?void 0:(a.unref(),a.pid)}let o=(0,Yi.spawn)(process.execPath,[t,"--daemon"],{detached:!0,stdio:"ignore",env:i});if(o.pid!==void 0)return o.unref(),o.pid}function j0(t){if(t===0)return!0;if(!Number.isInteger(t)||t<0)return!1;try{return process.kill(t,0),!0}catch(e){return e.code==="EPERM"}}function fA(t=15e3){try{let e=(0,Bt.statSync)(Si);return Date.now()-e.mtimeMs{if(e.value){w.warn("SYSTEM",`Received ${r} but shutdown already in progress`);return}e.value=!0,w.info("SYSTEM",`Received ${r}, shutting down...`);try{await t(),process.exit(0)}catch(n){w.error("SYSTEM","Error during shutdown",{},n),process.exit(0)}}}var vA=nt(require("path"),1),yA=require("fs");ge();Zt();async function Wa(t){try{return(await fetch(`http://127.0.0.1:${t}/api/health`)).ok}catch{return!1}}async function _A(t,e,r,n){let i=Date.now();for(;Date.now()-isetTimeout(s,500))}return!1}function Ka(t,e=3e4){return _A(t,"/api/health",e,"Service not ready yet, will retry")}function bA(t,e=3e4){return _A(t,"/api/readiness",e,"Worker not ready yet, will retry")}async function Lm(t,e=1e4){let r=Date.now();for(;Date.now()-rsetTimeout(n,500))}return!1}async function qm(t){try{let e=await fetch(`http://127.0.0.1:${t}/api/admin/shutdown`,{method:"POST"});return e.ok?!0:(w.warn("SYSTEM","Shutdown request returned error",{port:t,status:e.status}),!1)}catch(e){return e instanceof Error&&e.message?.includes("ECONNREFUSED")?(w.debug("SYSTEM","Worker already stopped",{port:t},e),!1):(w.error("SYSTEM","Shutdown request failed unexpectedly",{port:t},e),!1)}}function oK(){try{let t=vA.default.join(Ki,"package.json");return JSON.parse((0,yA.readFileSync)(t,"utf-8")).version}catch(t){let e=t.code;if(e==="ENOENT"||e==="EBUSY")return w.debug("SYSTEM","Could not read plugin version (shutdown race)",{code:e}),"unknown";throw t}}async function aK(t){try{let e=await fetch(`http://127.0.0.1:${t}/api/version`);return e.ok?(await e.json()).version:null}catch{return w.debug("SYSTEM","Could not fetch worker version",{port:t}),null}}async function SA(t){let e=oK(),r=await aK(t);return!r||e==="unknown"?{matches:!0,pluginVersion:e,workerVersion:r}:{matches:e===r,pluginVersion:e,workerVersion:r}}ge();async function xA(t){w.info("SYSTEM","Shutdown initiated"),Yn();let e=await cA(process.pid);if(w.info("SYSTEM","Found child processes",{count:e.length,pids:e}),t.server&&(await cK(t.server),w.info("SYSTEM","HTTP server closed")),await t.sessionManager.shutdownAll(),t.mcpClient&&(await t.mcpClient.close(),w.info("SYSTEM","MCP client closed")),t.chromaMcpManager&&(w.info("SHUTDOWN","Stopping Chroma MCP connection..."),await t.chromaMcpManager.stop(),w.info("SHUTDOWN","Chroma MCP connection stopped")),t.dbManager&&await t.dbManager.close(),e.length>0){w.info("SYSTEM","Force killing remaining children");for(let r of e)await uA(r);await lA(e,5e3)}w.info("SYSTEM","Worker shutdown complete")}async function cK(t){t.closeAllConnections(),process.platform==="win32"&&await new Promise(e=>setTimeout(e,500)),await new Promise((e,r)=>{t.close(n=>n?r(n):e())}),process.platform==="win32"&&(await new Promise(e=>setTimeout(e,500)),w.info("SYSTEM","Waited for Windows port cleanup"))}var M2=nt(Kh(),1),HE=nt(require("fs"),1),Td=nt(require("path"),1);var x2=["search","context","summarize","import","export"],w2=["workflow","search_params","examples","all"];ge();var LE=nt(Kh(),1),O2=nt(I2(),1),R2=nt(require("path"),1);Zt();ge();function qE(t){let e=[];e.push(LE.default.json({limit:"50mb"})),e.push((0,O2.default)({origin:(i,s)=>{!i||i.startsWith("http://localhost:")||i.startsWith("http://127.0.0.1:")?s(null,!0):s(new Error("CORS not allowed"))},methods:["GET","HEAD","POST","PUT","PATCH","DELETE"],allowedHeaders:["Content-Type","Authorization","X-Requested-With"],credentials:!1})),e.push((i,s,o)=>{let c=[".html",".js",".css",".svg",".png",".jpg",".jpeg",".webp",".woff",".woff2",".ttf",".eot"].some(g=>i.path.endsWith(g)),u=i.path==="/api/logs";if(i.path.startsWith("/health")||i.path==="/"||c||u)return o();let l=Date.now(),d=`${i.method}-${Date.now()}`,p=t(i.method,i.path,i.body);w.info("HTTP",`\u2192 ${i.method} ${i.path}`,{requestId:d},p);let f=s.send.bind(s);s.send=function(g){let _=Date.now()-l;return w.info("HTTP",`\u2190 ${s.statusCode} ${i.path}`,{requestId:d,duration:`${_}ms`}),f(g)},o()});let r=tn(),n=R2.default.join(r,"plugin","ui");return e.push(LE.default.static(n)),e}function Jh(t,e,r){let n=t.ip||t.connection.remoteAddress||"";if(!(n==="127.0.0.1"||n==="::1"||n==="::ffff:127.0.0.1"||n==="localhost")){w.warn("SECURITY","Admin endpoint access denied - not localhost",{endpoint:t.path,clientIp:n,method:t.method}),e.status(403).json({error:"Forbidden",message:"Admin endpoints are only accessible from localhost"});return}r()}function FE(t,e,r){if(!r||Object.keys(r).length===0||e.includes("/init"))return"";if(e.includes("/observations")){let n=r.tool_name||"?",i=r.tool_input;return`tool=${w.formatTool(n,i)}`}return e.includes("/summarize")?"requesting summary":""}ge();var xc=class extends Error{constructor(r,n=500,i,s){super(r);this.statusCode=n;this.code=i;this.details=s;this.name="AppError"}};function P2(t,e,r,n){let i={error:t,message:e};return r&&(i.code=r),n&&(i.details=n),i}var C2=(t,e,r,n)=>{let i=t instanceof xc?t.statusCode:500;w.error("HTTP",`Error handling ${e.method} ${e.path}`,{statusCode:i,error:t.message,code:t instanceof xc?t.code:void 0},t);let s=P2(t.name||"Error",t.message,t instanceof xc?t.code:void 0,t instanceof xc?t.details:void 0);r.status(i).json(s)};function A2(t,e){e.status(404).json(P2("NotFound",`Cannot ${t.method} ${t.path}`))}var N2="10.5.2",Xh=class{app;server=null;options;startTime=Date.now();constructor(e){this.options=e,this.app=(0,M2.default)(),this.setupMiddleware(),this.setupCoreRoutes()}getHttpServer(){return this.server}async listen(e,r){return new Promise((n,i)=>{this.server=this.app.listen(e,r,()=>{w.info("SYSTEM","HTTP server started",{host:r,port:e,pid:process.pid}),n()}),this.server.on("error",i)})}async close(){this.server&&(this.server.closeAllConnections(),process.platform==="win32"&&await new Promise(e=>setTimeout(e,500)),await new Promise((e,r)=>{this.server.close(n=>n?r(n):e())}),process.platform==="win32"&&await new Promise(e=>setTimeout(e,500)),this.server=null,w.info("SYSTEM","HTTP server closed"))}registerRoutes(e){e.setupRoutes(this.app)}finalizeRoutes(){this.app.use(A2),this.app.use(C2)}setupMiddleware(){qE(FE).forEach(r=>this.app.use(r))}setupCoreRoutes(){this.app.get("/api/health",(e,r)=>{r.status(200).json({status:"ok",version:N2,workerPath:this.options.workerPath,uptime:Date.now()-this.startTime,managed:process.env.CLAUDE_MEM_MANAGED==="true",hasIpc:typeof process.send=="function",platform:process.platform,pid:process.pid,initialized:this.options.getInitializationComplete(),mcpReady:this.options.getMcpReady(),ai:this.options.getAiStatus()})}),this.app.get("/api/readiness",(e,r)=>{this.options.getInitializationComplete()?r.status(200).json({status:"ready",mcpReady:this.options.getMcpReady()}):r.status(503).json({status:"initializing",message:"Worker is still initializing, please retry"})}),this.app.get("/api/version",(e,r)=>{r.status(200).json({version:N2})}),this.app.get("/api/instructions",async(e,r)=>{let n=e.query.topic||"all",i=e.query.operation;if(n&&!w2.includes(n))return r.status(400).json({error:"Invalid topic"});try{let s;if(i){if(!x2.includes(i))return r.status(400).json({error:"Invalid operation"});let o=Td.default.resolve(__dirname,"../skills/mem-search/operations"),a=Td.default.resolve(o,`${i}.md`);if(!a.startsWith(o+Td.default.sep))return r.status(400).json({error:"Invalid request"});s=await HE.promises.readFile(a,"utf-8")}else{let o=Td.default.join(__dirname,"../skills/mem-search/SKILL.md"),a=await HE.promises.readFile(o,"utf-8");s=this.extractInstructionSection(a,n)}r.json({content:[{type:"text",text:s}]})}catch{r.status(404).json({error:"Instruction not found"})}}),this.app.post("/api/admin/restart",Jh,async(e,r)=>{r.json({status:"restarting"}),process.platform==="win32"&&process.env.CLAUDE_MEM_MANAGED==="true"&&process.send?(w.info("SYSTEM","Sending restart request to wrapper"),process.send({type:"restart"})):setTimeout(async()=>{try{await this.options.onRestart()}finally{process.exit(0)}},100)}),this.app.post("/api/admin/shutdown",Jh,async(e,r)=>{r.json({status:"shutting_down"}),process.platform==="win32"&&process.env.CLAUDE_MEM_MANAGED==="true"&&process.send?(w.info("SYSTEM","Sending shutdown request to wrapper"),process.send({type:"shutdown"})):setTimeout(async()=>{try{await this.options.onShutdown()}finally{process.exit(0)}},100)})}extractInstructionSection(e,r){let n={workflow:this.extractBetween(e,"## The Workflow","## Search Parameters"),search_params:this.extractBetween(e,"## Search Parameters","## Examples"),examples:this.extractBetween(e,"## Examples","## Why This Workflow"),all:e};return n[r]||n.all}extractBetween(e,r,n){let i=e.indexOf(r),s=e.indexOf(n);return i===-1?e:s===-1?e.substring(i):e.substring(i,s).trim()}};var kt=nt(require("path"),1),Od=require("os"),rr=require("fs"),z2=require("child_process"),U2=require("util");ge();Br();Zt();var Dn=require("fs"),Id=require("path");ge();function D2(t){try{return(0,Dn.existsSync)(t)?JSON.parse((0,Dn.readFileSync)(t,"utf-8")):{}}catch(e){return w.error("CONFIG","Failed to read Cursor registry, using empty registry",{file:t,error:e instanceof Error?e.message:String(e)}),{}}}function j2(t,e){let r=(0,Id.join)(t,"..");(0,Dn.mkdirSync)(r,{recursive:!0}),(0,Dn.writeFileSync)(t,JSON.stringify(e,null,2))}function ZE(t,e){let r=(0,Id.join)(t,".cursor","rules"),n=(0,Id.join)(r,"claude-mem-context.mdc"),i=`${n}.tmp`;(0,Dn.mkdirSync)(r,{recursive:!0});let s=`--- +`);for(let a of o){let c=a.trim().match(/^(\d+)\s+(\S+)\s+(.*)$/);if(!c)continue;let u=parseInt(c[1],10),l=c[2],d=c[3];if(!Number.isInteger(u)||u<=0||u===e)continue;if(A0.some(f=>d.includes(f)))r.push(u),w.debug("SYSTEM","Found orphaned process (aggressive)",{pid:u,command:d.substring(0,80)});else{let f=nK(l);f>=iA&&(r.push(u),w.debug("SYSTEM","Found orphaned process (age-gated)",{pid:u,ageMinutes:f,command:d.substring(0,80)}))}}}}catch(i){w.error("SYSTEM","Failed to enumerate orphaned processes during aggressive cleanup",{},i);return}if(r.length!==0){if(w.info("SYSTEM","Aggressive startup cleanup: killing orphaned processes",{platform:t?"Windows":"Unix",count:r.length,pids:r}),t){for(let i of r)if(!(!Number.isInteger(i)||i<=0))try{(0,Yi.execSync)(`taskkill /PID ${i} /T /F`,{timeout:Cr.POWERSHELL_COMMAND,stdio:"ignore",windowsHide:!0})}catch(s){w.debug("SYSTEM","Failed to kill process, may have already exited",{pid:i},s)}}else for(let i of r)try{process.kill(i,"SIGKILL")}catch(s){w.debug("SYSTEM","Process already exited",{pid:i},s)}w.info("SYSTEM","Aggressive startup cleanup complete",{count:r.length})}}var sK=".chroma-cleaned-v10.3";function pA(t){let e=t??M0,r=bi.default.join(e,sK),n=bi.default.join(e,"chroma");if((0,Bt.existsSync)(r)){w.debug("SYSTEM","Chroma migration marker exists, skipping wipe");return}w.warn("SYSTEM","Running one-time chroma data wipe (upgrade from pre-v10.3)",{chromaDir:n}),(0,Bt.existsSync)(n)&&((0,Bt.rmSync)(n,{recursive:!0,force:!0}),w.info("SYSTEM","Chroma data directory removed",{chromaDir:n})),(0,Bt.mkdirSync)(e,{recursive:!0}),(0,Bt.writeFileSync)(r,new Date().toISOString()),w.info("SYSTEM","Chroma migration marker written",{markerPath:r})}function D0(t,e,r={}){let n=process.platform==="win32",i={...process.env,CLAUDE_MEM_WORKER_PORT:String(e),...r};if(n){let a=rK();if(!a){w.error("SYSTEM","Failed to locate Bun runtime for Windows worker spawn");return}let c=a.replace(/'/g,"''"),u=t.replace(/'/g,"''"),l=`Start-Process -FilePath '${c}' -ArgumentList '${u}','--daemon' -WindowStyle Hidden`;try{return(0,Yi.execSync)(`powershell -NoProfile -Command "${l}"`,{stdio:"ignore",windowsHide:!0,env:i}),0}catch(d){w.error("SYSTEM","Failed to spawn worker daemon on Windows",{runtimePath:a},d);return}}let s="/usr/bin/setsid";if((0,Bt.existsSync)(s)){let a=(0,Yi.spawn)(s,[process.execPath,t,"--daemon"],{detached:!0,stdio:"ignore",env:i});return a.pid===void 0?void 0:(a.unref(),a.pid)}let o=(0,Yi.spawn)(process.execPath,[t,"--daemon"],{detached:!0,stdio:"ignore",env:i});if(o.pid!==void 0)return o.unref(),o.pid}function j0(t){if(t===0)return!0;if(!Number.isInteger(t)||t<0)return!1;try{return process.kill(t,0),!0}catch(e){return e.code==="EPERM"}}function fA(t=15e3){try{let e=(0,Bt.statSync)(Si);return Date.now()-e.mtimeMs{if(e.value){w.warn("SYSTEM",`Received ${r} but shutdown already in progress`);return}e.value=!0,w.info("SYSTEM",`Received ${r}, shutting down...`);try{await t(),process.exit(0)}catch(n){w.error("SYSTEM","Error during shutdown",{},n),process.exit(0)}}}var vA=nt(require("path"),1),yA=require("fs");ge();Zt();async function Wa(t){try{return(await fetch(`http://127.0.0.1:${t}/api/health`)).ok}catch{return!1}}async function _A(t,e,r,n){let i=Date.now();for(;Date.now()-isetTimeout(s,500))}return!1}function Ka(t,e=3e4){return _A(t,"/api/health",e,"Service not ready yet, will retry")}function bA(t,e=3e4){return _A(t,"/api/readiness",e,"Worker not ready yet, will retry")}async function Lm(t,e=1e4){let r=Date.now();for(;Date.now()-rsetTimeout(n,500))}return!1}async function qm(t){try{let e=await fetch(`http://127.0.0.1:${t}/api/admin/shutdown`,{method:"POST"});return e.ok?!0:(w.warn("SYSTEM","Shutdown request returned error",{port:t,status:e.status}),!1)}catch(e){return e instanceof Error&&e.message?.includes("ECONNREFUSED")?(w.debug("SYSTEM","Worker already stopped",{port:t},e),!1):(w.error("SYSTEM","Shutdown request failed unexpectedly",{port:t},e),!1)}}function oK(){try{let t=vA.default.join(Ki,"package.json");return JSON.parse((0,yA.readFileSync)(t,"utf-8")).version}catch(t){let e=t.code;if(e==="ENOENT"||e==="EBUSY")return w.debug("SYSTEM","Could not read plugin version (shutdown race)",{code:e}),"unknown";throw t}}async function aK(t){try{let e=await fetch(`http://127.0.0.1:${t}/api/version`);return e.ok?(await e.json()).version:null}catch{return w.debug("SYSTEM","Could not fetch worker version",{port:t}),null}}async function SA(t){let e=oK(),r=await aK(t);return!r||e==="unknown"?{matches:!0,pluginVersion:e,workerVersion:r}:{matches:e===r,pluginVersion:e,workerVersion:r}}ge();async function xA(t){w.info("SYSTEM","Shutdown initiated"),Yn();let e=await cA(process.pid);if(w.info("SYSTEM","Found child processes",{count:e.length,pids:e}),t.server&&(await cK(t.server),w.info("SYSTEM","HTTP server closed")),await t.sessionManager.shutdownAll(),t.mcpClient&&(await t.mcpClient.close(),w.info("SYSTEM","MCP client closed")),t.chromaMcpManager&&(w.info("SHUTDOWN","Stopping Chroma MCP connection..."),await t.chromaMcpManager.stop(),w.info("SHUTDOWN","Chroma MCP connection stopped")),t.dbManager&&await t.dbManager.close(),e.length>0){w.info("SYSTEM","Force killing remaining children");for(let r of e)await uA(r);await lA(e,5e3)}w.info("SYSTEM","Worker shutdown complete")}async function cK(t){t.closeAllConnections(),process.platform==="win32"&&await new Promise(e=>setTimeout(e,500)),await new Promise((e,r)=>{t.close(n=>n?r(n):e())}),process.platform==="win32"&&(await new Promise(e=>setTimeout(e,500)),w.info("SYSTEM","Waited for Windows port cleanup"))}var M2=nt(Kh(),1),HE=nt(require("fs"),1),Td=nt(require("path"),1);var x2=["search","context","summarize","import","export"],w2=["workflow","search_params","examples","all"];ge();var LE=nt(Kh(),1),O2=nt(I2(),1),R2=nt(require("path"),1);Zt();ge();function qE(t){let e=[];e.push(LE.default.json({limit:"50mb"})),e.push((0,O2.default)({origin:(i,s)=>{!i||i.startsWith("http://localhost:")||i.startsWith("http://127.0.0.1:")?s(null,!0):s(new Error("CORS not allowed"))},methods:["GET","HEAD","POST","PUT","PATCH","DELETE"],allowedHeaders:["Content-Type","Authorization","X-Requested-With"],credentials:!1})),e.push((i,s,o)=>{let c=[".html",".js",".css",".svg",".png",".jpg",".jpeg",".webp",".woff",".woff2",".ttf",".eot"].some(g=>i.path.endsWith(g)),u=i.path==="/api/logs";if(i.path.startsWith("/health")||i.path==="/"||c||u)return o();let l=Date.now(),d=`${i.method}-${Date.now()}`,p=t(i.method,i.path,i.body);w.info("HTTP",`\u2192 ${i.method} ${i.path}`,{requestId:d},p);let f=s.send.bind(s);s.send=function(g){let _=Date.now()-l;return w.info("HTTP",`\u2190 ${s.statusCode} ${i.path}`,{requestId:d,duration:`${_}ms`}),f(g)},o()});let r=tn(),n=R2.default.join(r,"plugin","ui");return e.push(LE.default.static(n)),e}function Jh(t,e,r){let n=t.ip||t.connection.remoteAddress||"";if(!(n==="127.0.0.1"||n==="::1"||n==="::ffff:127.0.0.1"||n==="localhost")){w.warn("SECURITY","Admin endpoint access denied - not localhost",{endpoint:t.path,clientIp:n,method:t.method}),e.status(403).json({error:"Forbidden",message:"Admin endpoints are only accessible from localhost"});return}r()}function FE(t,e,r){if(!r||Object.keys(r).length===0||e.includes("/init"))return"";if(e.includes("/observations")){let n=r.tool_name||"?",i=r.tool_input;return`tool=${w.formatTool(n,i)}`}return e.includes("/summarize")?"requesting summary":""}ge();var xc=class extends Error{constructor(r,n=500,i,s){super(r);this.statusCode=n;this.code=i;this.details=s;this.name="AppError"}};function P2(t,e,r,n){let i={error:t,message:e};return r&&(i.code=r),n&&(i.details=n),i}var C2=(t,e,r,n)=>{let i=t instanceof xc?t.statusCode:500;w.error("HTTP",`Error handling ${e.method} ${e.path}`,{statusCode:i,error:t.message,code:t instanceof xc?t.code:void 0},t);let s=P2(t.name||"Error",t.message,t instanceof xc?t.code:void 0,t instanceof xc?t.details:void 0);r.status(i).json(s)};function A2(t,e){e.status(404).json(P2("NotFound",`Cannot ${t.method} ${t.path}`))}var N2="10.5.3",Xh=class{app;server=null;options;startTime=Date.now();constructor(e){this.options=e,this.app=(0,M2.default)(),this.setupMiddleware(),this.setupCoreRoutes()}getHttpServer(){return this.server}async listen(e,r){return new Promise((n,i)=>{this.server=this.app.listen(e,r,()=>{w.info("SYSTEM","HTTP server started",{host:r,port:e,pid:process.pid}),n()}),this.server.on("error",i)})}async close(){this.server&&(this.server.closeAllConnections(),process.platform==="win32"&&await new Promise(e=>setTimeout(e,500)),await new Promise((e,r)=>{this.server.close(n=>n?r(n):e())}),process.platform==="win32"&&await new Promise(e=>setTimeout(e,500)),this.server=null,w.info("SYSTEM","HTTP server closed"))}registerRoutes(e){e.setupRoutes(this.app)}finalizeRoutes(){this.app.use(A2),this.app.use(C2)}setupMiddleware(){qE(FE).forEach(r=>this.app.use(r))}setupCoreRoutes(){this.app.get("/api/health",(e,r)=>{r.status(200).json({status:"ok",version:N2,workerPath:this.options.workerPath,uptime:Date.now()-this.startTime,managed:process.env.CLAUDE_MEM_MANAGED==="true",hasIpc:typeof process.send=="function",platform:process.platform,pid:process.pid,initialized:this.options.getInitializationComplete(),mcpReady:this.options.getMcpReady(),ai:this.options.getAiStatus()})}),this.app.get("/api/readiness",(e,r)=>{this.options.getInitializationComplete()?r.status(200).json({status:"ready",mcpReady:this.options.getMcpReady()}):r.status(503).json({status:"initializing",message:"Worker is still initializing, please retry"})}),this.app.get("/api/version",(e,r)=>{r.status(200).json({version:N2})}),this.app.get("/api/instructions",async(e,r)=>{let n=e.query.topic||"all",i=e.query.operation;if(n&&!w2.includes(n))return r.status(400).json({error:"Invalid topic"});try{let s;if(i){if(!x2.includes(i))return r.status(400).json({error:"Invalid operation"});let o=Td.default.resolve(__dirname,"../skills/mem-search/operations"),a=Td.default.resolve(o,`${i}.md`);if(!a.startsWith(o+Td.default.sep))return r.status(400).json({error:"Invalid request"});s=await HE.promises.readFile(a,"utf-8")}else{let o=Td.default.join(__dirname,"../skills/mem-search/SKILL.md"),a=await HE.promises.readFile(o,"utf-8");s=this.extractInstructionSection(a,n)}r.json({content:[{type:"text",text:s}]})}catch{r.status(404).json({error:"Instruction not found"})}}),this.app.post("/api/admin/restart",Jh,async(e,r)=>{r.json({status:"restarting"}),process.platform==="win32"&&process.env.CLAUDE_MEM_MANAGED==="true"&&process.send?(w.info("SYSTEM","Sending restart request to wrapper"),process.send({type:"restart"})):setTimeout(async()=>{try{await this.options.onRestart()}finally{process.exit(0)}},100)}),this.app.post("/api/admin/shutdown",Jh,async(e,r)=>{r.json({status:"shutting_down"}),process.platform==="win32"&&process.env.CLAUDE_MEM_MANAGED==="true"&&process.send?(w.info("SYSTEM","Sending shutdown request to wrapper"),process.send({type:"shutdown"})):setTimeout(async()=>{try{await this.options.onShutdown()}finally{process.exit(0)}},100)})}extractInstructionSection(e,r){let n={workflow:this.extractBetween(e,"## The Workflow","## Search Parameters"),search_params:this.extractBetween(e,"## Search Parameters","## Examples"),examples:this.extractBetween(e,"## Examples","## Why This Workflow"),all:e};return n[r]||n.all}extractBetween(e,r,n){let i=e.indexOf(r),s=e.indexOf(n);return i===-1?e:s===-1?e.substring(i):e.substring(i,s).trim()}};var kt=nt(require("path"),1),Od=require("os"),rr=require("fs"),z2=require("child_process"),U2=require("util");ge();Br();Zt();var Dn=require("fs"),Id=require("path");ge();function D2(t){try{return(0,Dn.existsSync)(t)?JSON.parse((0,Dn.readFileSync)(t,"utf-8")):{}}catch(e){return w.error("CONFIG","Failed to read Cursor registry, using empty registry",{file:t,error:e instanceof Error?e.message:String(e)}),{}}}function j2(t,e){let r=(0,Id.join)(t,"..");(0,Dn.mkdirSync)(r,{recursive:!0}),(0,Dn.writeFileSync)(t,JSON.stringify(e,null,2))}function ZE(t,e){let r=(0,Id.join)(t,".cursor","rules"),n=(0,Id.join)(r,"claude-mem-context.mdc"),i=`${n}.tmp`;(0,Dn.mkdirSync)(r,{recursive:!0});let s=`--- alwaysApply: true description: "Claude-mem context from past sessions (auto-updated)" --- @@ -1432,7 +1432,7 @@ Tips: `&&u++;if(u>=e||g===0)break;a=Math.min(a*2,i,o)}let l=c.split(` `);l.length>0&&l[l.length-1]===""&&l.pop();let d=Math.max(0,l.length-e),p=l.slice(d),f;if(i<=a)f=l.length;else{let g=c.length/Math.max(u,1);f=Math.round(i/g)}return{lines:p.join(` `),totalEstimate:f}}finally{(0,Sn.closeSync)(r)}}var gv=class extends jr{getLogFilePath(){let e=$e.get("CLAUDE_MEM_DATA_DIR"),r=(0,hv.join)(e,"logs"),n=new Date().toISOString().split("T")[0];return(0,hv.join)(r,`claude-mem-${n}.log`)}getLogsDir(){let e=$e.get("CLAUDE_MEM_DATA_DIR");return(0,hv.join)(e,"logs")}setupRoutes(e){e.get("/api/logs",this.handleGetLogs.bind(this)),e.post("/api/logs/clear",this.handleClearLogs.bind(this))}handleGetLogs=this.wrapHandler((e,r)=>{let n=this.getLogFilePath();if(!(0,Sn.existsSync)(n)){r.json({logs:"",path:n,exists:!1});return}let i=parseInt(e.query.lines||"1000",10),s=Math.min(i,1e4),{lines:o,totalEstimate:a}=gge(n,s),c=o===""?0:o.split(` -`).length;r.json({logs:o,path:n,exists:!0,totalLines:a,returnedLines:c})});handleClearLogs=this.wrapHandler((e,r)=>{let n=this.getLogFilePath();if(!(0,Sn.existsSync)(n)){r.json({success:!0,message:"Log file does not exist",path:n});return}(0,Sn.writeFileSync)(n,"","utf-8"),w.info("SYSTEM","Log file cleared via UI",{path:n}),r.json({success:!0,message:"Log file cleared",path:n})})};ge();var vv=class extends jr{constructor(r,n){super();this.dbManager=r;this.defaultProject=n}setupRoutes(r){r.post("/api/memory/save",this.handleSaveMemory.bind(this))}handleSaveMemory=this.wrapHandler(async(r,n)=>{let{text:i,title:s,project:o}=r.body,a=o||this.defaultProject;if(!i||typeof i!="string"||i.trim().length===0){this.badRequest(n,"text is required and must be non-empty");return}let c=this.dbManager.getSessionStore(),u=this.dbManager.getChromaSync(),l=c.getOrCreateManualSession(a),d={type:"discovery",title:s||i.substring(0,60).trim()+(i.length>60?"...":""),subtitle:"Manual memory",facts:[],narrative:i,concepts:[],files_read:[],files_modified:[]},p=c.storeObservation(l,a,d,0,0);w.info("HTTP","Manual observation saved",{id:p.id,project:a,title:d.title}),u.syncObservation(p.id,l,a,d,0,p.createdAtEpoch,0).catch(f=>{w.error("CHROMA","ChromaDB sync failed",{id:p.id},f)}),n.json({success:!0,id:p.id,title:d.title,project:a,message:`Memory saved as observation #${p.id}`})})};var Bge={},jge=120*1e3;function Rk(){return Ok.default.join($e.get("CLAUDE_MEM_DATA_DIR"),".worker-start-attempted")}function zge(){if(process.platform!=="win32")return!1;let t=Rk();if(!(0,ls.existsSync)(t))return!1;try{let e=(0,ls.statSync)(t).mtimeMs;return Date.now()-e{this.resolveInitialization=e}),this.dbManager=new Qh,this.sessionManager=new rg(this.dbManager),this.sseBroadcaster=new ng,this.sdkAgent=new qg(this.dbManager,this.sessionManager),this.geminiAgent=new Fg(this.dbManager,this.sessionManager),this.openRouterAgent=new Bg(this.dbManager,this.sessionManager),this.paginationHelper=new Vg(this.dbManager),this.settingsManager=new Gg(this.dbManager),this.sessionEventBroadcaster=new Xg(this.sseBroadcaster,this),this.sessionManager.setOnSessionDeleted(()=>{this.broadcastProcessingStatus()}),this.mcpClient=new qa({name:"worker-search-proxy",version:qge},{capabilities:{}}),this.server=new Xh({getInitializationComplete:()=>this.initializationCompleteFlag,getMcpReady:()=>this.mcpReady,onShutdown:()=>this.shutdown(),onRestart:()=>this.shutdown(),workerPath:__filename,getAiStatus:()=>{let e="claude";return Yc()&&Go()?e="openrouter":Xc()&&Vo()&&(e="gemini"),{provider:e,authMethod:Nm(),lastInteraction:this.lastAiInteraction?{timestamp:this.lastAiInteraction.timestamp,success:this.lastAiInteraction.success,...this.lastAiInteraction.error&&{error:this.lastAiInteraction.error}}:null}}}),this.registerRoutes(),this.registerSignalHandlers()}registerSignalHandlers(){let e={value:this.isShuttingDown},r=gA(()=>this.shutdown(),e);process.on("SIGTERM",()=>{this.isShuttingDown=e.value,r("SIGTERM")}),process.on("SIGINT",()=>{this.isShuttingDown=e.value,r("SIGINT")}),process.platform!=="win32"&&(process.argv.includes("--daemon")?process.on("SIGHUP",()=>{w.debug("SYSTEM","Ignoring SIGHUP in daemon mode")}):process.on("SIGHUP",()=>{this.isShuttingDown=e.value,r("SIGHUP")}))}registerRoutes(){this.server.app.get("/api/context/inject",async(e,r,n)=>{if(!this.initializationCompleteFlag||!this.searchRoutes){w.warn("SYSTEM","Context requested before initialization complete, returning empty"),r.status(200).json({content:[{type:"text",text:""}]});return}n()}),this.server.app.use("/api",async(e,r,n)=>{if(this.initializationCompleteFlag){n();return}let i=3e4,s=new Promise((o,a)=>setTimeout(()=>a(new Error("Database initialization timeout")),i));try{await Promise.race([this.initializationComplete,s]),n()}catch(o){w.error("HTTP",`Request to ${e.method} ${e.path} rejected \u2014 DB not initialized`,{},o),r.status(503).json({error:"Service initializing",message:"Database is still initializing, please retry"})}}),this.server.registerRoutes(new Qg(this.sseBroadcaster,this.dbManager,this.sessionManager)),this.server.registerRoutes(new rv(this.sessionManager,this.dbManager,this.sdkAgent,this.geminiAgent,this.openRouterAgent,this.sessionEventBroadcaster,this)),this.server.registerRoutes(new nv(this.paginationHelper,this.dbManager,this.sessionManager,this.sseBroadcaster,this,this.startTime)),this.server.registerRoutes(new mv(this.settingsManager)),this.server.registerRoutes(new gv),this.server.registerRoutes(new vv(this.dbManager,"claude-mem"))}async start(){let e=Et(),r=Am();await this.server.listen(e,r),aA({pid:process.pid,port:e,startedAt:new Date().toISOString()}),w.info("SYSTEM","Worker started",{host:r,port:e,pid:process.pid}),this.initializeBackground().catch(n=>{w.error("SYSTEM","Background initialization failed",{},n)})}async initializeBackground(){try{await dA();let{ModeManager:e}=await Promise.resolve().then(()=>(Wr(),Q2)),{SettingsDefaultsManager:r}=await Promise.resolve().then(()=>(or(),NC)),{USER_SETTINGS_PATH:n}=await Promise.resolve().then(()=>(Zt(),ZC)),i=r.loadFromFile(n);(i.CLAUDE_MEM_MODE==="local"||!i.CLAUDE_MEM_MODE)&&pA(),i.CLAUDE_MEM_CHROMA_ENABLED!=="false"?(this.chromaMcpManager=Ji.getInstance(),w.info("SYSTEM","ChromaMcpManager initialized (lazy - connects on first use)")):w.info("SYSTEM","Chroma disabled via CLAUDE_MEM_CHROMA_ENABLED=false, skipping ChromaMcpManager");let o=i.CLAUDE_MEM_MODE;e.getInstance().loadMode(o),w.info("SYSTEM",`Mode loaded: ${o}`),await this.dbManager.initialize();let{PendingMessageStore:a}=await Promise.resolve().then(()=>(Us(),jo)),u=new a(this.dbManager.getSessionStore().db,3).resetStaleProcessingMessages(0);u>0&&w.info("SYSTEM",`Reset ${u} stale processing messages to pending`);let l=new Kg,d=new Jg,p=new Wg(this.dbManager.getSessionSearch(),this.dbManager.getSessionStore(),this.dbManager.getChromaSync(),l,d);this.searchRoutes=new dv(p),this.server.registerRoutes(this.searchRoutes),w.info("WORKER","SearchManager initialized and search routes registered"),this.initializationCompleteFlag=!0,this.resolveInitialization(),w.info("SYSTEM","Core initialization complete (DB + search ready)"),this.chromaMcpManager&&Ga.backfillAllProjects().then(()=>{w.info("CHROMA_SYNC","Backfill check complete for all projects")}).catch(y=>{w.error("CHROMA_SYNC","Backfill failed (non-blocking)",{},y)});let f=Ok.default.join(__dirname,"mcp-server.cjs"),g=new Za({command:"node",args:[f],env:process.env}),_=3e5,h=this.mcpClient.connect(g),m=new Promise((y,v)=>setTimeout(()=>v(new Error("MCP connection timeout after 5 minutes")),_));await Promise.race([h,m]),this.mcpReady=!0,w.success("WORKER","MCP server connected"),this.stopOrphanReaper=X2(()=>{let y=new Set;for(let[v]of this.sessionManager.sessions)y.add(v);return y}),w.info("SYSTEM","Started orphan reaper (runs every 5 minutes)"),this.staleSessionReaperInterval=setInterval(async()=>{try{let y=await this.sessionManager.reapStaleSessions();y>0&&w.info("SYSTEM",`Reaped ${y} stale sessions`)}catch(y){w.error("SYSTEM","Stale session reaper error",{error:y instanceof Error?y.message:String(y)})}},120*1e3),this.processPendingQueues(50).then(y=>{y.sessionsStarted>0&&w.info("SYSTEM",`Auto-recovered ${y.sessionsStarted} sessions with pending work`,{totalPending:y.totalPendingSessions,started:y.sessionsStarted,sessionIds:y.startedSessionIds})}).catch(y=>{w.error("SYSTEM","Auto-recovery of pending queues failed",{},y)})}catch(e){throw w.error("SYSTEM","Background initialization failed",{},e),e}}getActiveAgent(){return Yc()&&Go()?this.openRouterAgent:Xc()&&Vo()?this.geminiAgent:this.sdkAgent}startSessionProcessor(e,r){if(!e)return;let n=e.sessionDbId,i=this.getActiveAgent(),s=i.constructor.name;e.abortController.signal.aborted&&(w.debug("SYSTEM","Replacing aborted AbortController before starting generator",{sessionId:e.sessionDbId}),e.abortController=new AbortController);let o=!1,a=!1;w.info("SYSTEM",`Starting generator (${r}) using ${s}`,{sessionId:n}),e.lastGeneratorActivity=Date.now(),e.generatorPromise=i.startSession(e,this).catch(async c=>{let u=c?.message||"";if(["Claude executable not found","CLAUDE_CODE_PATH","ENOENT","spawn","Invalid API key"].some(d=>u.includes(d))){o=!0,this.lastAiInteraction={timestamp:Date.now(),success:!1,provider:s,error:u},w.error("SDK","Unrecoverable generator error - will NOT restart",{sessionId:e.sessionDbId,project:e.project,errorMessage:u});return}if(this.isSessionTerminatedError(c))return w.warn("SDK","SDK resume failed, falling back to standalone processing",{sessionId:e.sessionDbId,project:e.project,reason:c instanceof Error?c.message:String(c)}),this.runFallbackForTerminatedSession(e,c);throw(u.includes("aborted by user")||u.includes("No conversation found"))&&e.memorySessionId&&(w.warn("SDK","Detected stale resume failure, clearing memorySessionId for fresh start",{sessionId:e.sessionDbId,memorySessionId:e.memorySessionId,errorMessage:u}),this.dbManager.getSessionStore().updateMemorySessionId(e.sessionDbId,null),e.memorySessionId=null,e.forceInit=!0),w.error("SDK","Session generator failed",{sessionId:e.sessionDbId,project:e.project,provider:s},c),a=!0,this.lastAiInteraction={timestamp:Date.now(),success:!1,provider:s,error:u},c}).finally(async()=>{let c=Ls(e.sessionDbId);if(c&&!c.process.killed&&c.process.exitCode===null&&await qs(c,5e3),e.generatorPromise=null,!a&&!o&&(this.lastAiInteraction={timestamp:Date.now(),success:!0,provider:s}),o){w.warn("SYSTEM","Skipping restart due to unrecoverable error",{sessionId:e.sessionDbId}),this.broadcastProcessingStatus();return}let{PendingMessageStore:u}=(Us(),su(jo)),l=new u(this.dbManager.getSessionStore().db,3);if(e.idleTimedOut){w.info("SYSTEM","Generator exited due to idle timeout, not restarting",{sessionId:e.sessionDbId}),e.idleTimedOut=!1,this.broadcastProcessingStatus();return}let d=l.getPendingCount(e.sessionDbId);d>0&&(w.info("SYSTEM","Pending work remains after generator exit, restarting with fresh AbortController",{sessionId:e.sessionDbId,pendingCount:d}),e.abortController=new AbortController,this.startSessionProcessor(e,"pending-work-restart")),this.broadcastProcessingStatus()})}isSessionTerminatedError(e){let n=(e instanceof Error?e.message:String(e)).toLowerCase();return n.includes("process aborted by user")||n.includes("processtransport")||n.includes("not ready for writing")||n.includes("session generator failed")||n.includes("claude code process")}async runFallbackForTerminatedSession(e,r){if(!e)return;let n=e.sessionDbId;if(!e.memorySessionId){let o=`fallback-${n}-${Date.now()}`;e.memorySessionId=o,this.dbManager.getSessionStore().updateMemorySessionId(n,o)}if(Vo())try{await this.geminiAgent.startSession(e,this);return}catch(o){w.warn("SDK","Fallback Gemini failed, trying OpenRouter",{sessionId:n,error:o instanceof Error?o.message:String(o)})}if(Go())try{await this.openRouterAgent.startSession(e,this);return}catch(o){w.warn("SDK","Fallback OpenRouter failed",{sessionId:n,error:o instanceof Error?o.message:String(o)})}let s=this.sessionManager.getPendingMessageStore().markAllSessionMessagesAbandoned(n);s>0&&w.warn("SDK","No fallback available; marked pending messages abandoned",{sessionId:n,abandoned:s}),this.sessionManager.removeSessionImmediate(n),this.sessionEventBroadcaster.broadcastSessionCompleted(n)}async processPendingQueues(e=10){let{PendingMessageStore:r}=await Promise.resolve().then(()=>(Us(),jo)),n=new r(this.dbManager.getSessionStore().db,3),i=this.dbManager.getSessionStore(),s=360*60*1e3,o=Date.now()-s;try{let u=i.db.prepare(` +`).length;r.json({logs:o,path:n,exists:!0,totalLines:a,returnedLines:c})});handleClearLogs=this.wrapHandler((e,r)=>{let n=this.getLogFilePath();if(!(0,Sn.existsSync)(n)){r.json({success:!0,message:"Log file does not exist",path:n});return}(0,Sn.writeFileSync)(n,"","utf-8"),w.info("SYSTEM","Log file cleared via UI",{path:n}),r.json({success:!0,message:"Log file cleared",path:n})})};ge();var vv=class extends jr{constructor(r,n){super();this.dbManager=r;this.defaultProject=n}setupRoutes(r){r.post("/api/memory/save",this.handleSaveMemory.bind(this))}handleSaveMemory=this.wrapHandler(async(r,n)=>{let{text:i,title:s,project:o}=r.body,a=o||this.defaultProject;if(!i||typeof i!="string"||i.trim().length===0){this.badRequest(n,"text is required and must be non-empty");return}let c=this.dbManager.getSessionStore(),u=this.dbManager.getChromaSync(),l=c.getOrCreateManualSession(a),d={type:"discovery",title:s||i.substring(0,60).trim()+(i.length>60?"...":""),subtitle:"Manual memory",facts:[],narrative:i,concepts:[],files_read:[],files_modified:[]},p=c.storeObservation(l,a,d,0,0);w.info("HTTP","Manual observation saved",{id:p.id,project:a,title:d.title}),u.syncObservation(p.id,l,a,d,0,p.createdAtEpoch,0).catch(f=>{w.error("CHROMA","ChromaDB sync failed",{id:p.id},f)}),n.json({success:!0,id:p.id,title:d.title,project:a,message:`Memory saved as observation #${p.id}`})})};var Bge={},jge=120*1e3;function Rk(){return Ok.default.join($e.get("CLAUDE_MEM_DATA_DIR"),".worker-start-attempted")}function zge(){if(process.platform!=="win32")return!1;let t=Rk();if(!(0,ls.existsSync)(t))return!1;try{let e=(0,ls.statSync)(t).mtimeMs;return Date.now()-e{this.resolveInitialization=e}),this.dbManager=new Qh,this.sessionManager=new rg(this.dbManager),this.sseBroadcaster=new ng,this.sdkAgent=new qg(this.dbManager,this.sessionManager),this.geminiAgent=new Fg(this.dbManager,this.sessionManager),this.openRouterAgent=new Bg(this.dbManager,this.sessionManager),this.paginationHelper=new Vg(this.dbManager),this.settingsManager=new Gg(this.dbManager),this.sessionEventBroadcaster=new Xg(this.sseBroadcaster,this),this.sessionManager.setOnSessionDeleted(()=>{this.broadcastProcessingStatus()}),this.mcpClient=new qa({name:"worker-search-proxy",version:qge},{capabilities:{}}),this.server=new Xh({getInitializationComplete:()=>this.initializationCompleteFlag,getMcpReady:()=>this.mcpReady,onShutdown:()=>this.shutdown(),onRestart:()=>this.shutdown(),workerPath:__filename,getAiStatus:()=>{let e="claude";return Yc()&&Go()?e="openrouter":Xc()&&Vo()&&(e="gemini"),{provider:e,authMethod:Nm(),lastInteraction:this.lastAiInteraction?{timestamp:this.lastAiInteraction.timestamp,success:this.lastAiInteraction.success,...this.lastAiInteraction.error&&{error:this.lastAiInteraction.error}}:null}}}),this.registerRoutes(),this.registerSignalHandlers()}registerSignalHandlers(){let e={value:this.isShuttingDown},r=gA(()=>this.shutdown(),e);process.on("SIGTERM",()=>{this.isShuttingDown=e.value,r("SIGTERM")}),process.on("SIGINT",()=>{this.isShuttingDown=e.value,r("SIGINT")}),process.platform!=="win32"&&(process.argv.includes("--daemon")?process.on("SIGHUP",()=>{w.debug("SYSTEM","Ignoring SIGHUP in daemon mode")}):process.on("SIGHUP",()=>{this.isShuttingDown=e.value,r("SIGHUP")}))}registerRoutes(){this.server.app.get("/api/context/inject",async(e,r,n)=>{if(!this.initializationCompleteFlag||!this.searchRoutes){w.warn("SYSTEM","Context requested before initialization complete, returning empty"),r.status(200).json({content:[{type:"text",text:""}]});return}n()}),this.server.app.use("/api",async(e,r,n)=>{if(this.initializationCompleteFlag){n();return}let i=3e4,s=new Promise((o,a)=>setTimeout(()=>a(new Error("Database initialization timeout")),i));try{await Promise.race([this.initializationComplete,s]),n()}catch(o){w.error("HTTP",`Request to ${e.method} ${e.path} rejected \u2014 DB not initialized`,{},o),r.status(503).json({error:"Service initializing",message:"Database is still initializing, please retry"})}}),this.server.registerRoutes(new Qg(this.sseBroadcaster,this.dbManager,this.sessionManager)),this.server.registerRoutes(new rv(this.sessionManager,this.dbManager,this.sdkAgent,this.geminiAgent,this.openRouterAgent,this.sessionEventBroadcaster,this)),this.server.registerRoutes(new nv(this.paginationHelper,this.dbManager,this.sessionManager,this.sseBroadcaster,this,this.startTime)),this.server.registerRoutes(new mv(this.settingsManager)),this.server.registerRoutes(new gv),this.server.registerRoutes(new vv(this.dbManager,"claude-mem"))}async start(){let e=Et(),r=Am();await this.server.listen(e,r),aA({pid:process.pid,port:e,startedAt:new Date().toISOString()}),w.info("SYSTEM","Worker started",{host:r,port:e,pid:process.pid}),this.initializeBackground().catch(n=>{w.error("SYSTEM","Background initialization failed",{},n)})}async initializeBackground(){try{await dA();let{ModeManager:e}=await Promise.resolve().then(()=>(Wr(),Q2)),{SettingsDefaultsManager:r}=await Promise.resolve().then(()=>(or(),NC)),{USER_SETTINGS_PATH:n}=await Promise.resolve().then(()=>(Zt(),ZC)),i=r.loadFromFile(n);(i.CLAUDE_MEM_MODE==="local"||!i.CLAUDE_MEM_MODE)&&pA(),i.CLAUDE_MEM_CHROMA_ENABLED!=="false"?(this.chromaMcpManager=Ji.getInstance(),w.info("SYSTEM","ChromaMcpManager initialized (lazy - connects on first use)")):w.info("SYSTEM","Chroma disabled via CLAUDE_MEM_CHROMA_ENABLED=false, skipping ChromaMcpManager");let o=i.CLAUDE_MEM_MODE;e.getInstance().loadMode(o),w.info("SYSTEM",`Mode loaded: ${o}`),await this.dbManager.initialize();let{PendingMessageStore:a}=await Promise.resolve().then(()=>(Us(),jo)),u=new a(this.dbManager.getSessionStore().db,3).resetStaleProcessingMessages(0);u>0&&w.info("SYSTEM",`Reset ${u} stale processing messages to pending`);let l=new Kg,d=new Jg,p=new Wg(this.dbManager.getSessionSearch(),this.dbManager.getSessionStore(),this.dbManager.getChromaSync(),l,d);this.searchRoutes=new dv(p),this.server.registerRoutes(this.searchRoutes),w.info("WORKER","SearchManager initialized and search routes registered"),this.initializationCompleteFlag=!0,this.resolveInitialization(),w.info("SYSTEM","Core initialization complete (DB + search ready)"),this.chromaMcpManager&&Ga.backfillAllProjects().then(()=>{w.info("CHROMA_SYNC","Backfill check complete for all projects")}).catch(y=>{w.error("CHROMA_SYNC","Backfill failed (non-blocking)",{},y)});let f=Ok.default.join(__dirname,"mcp-server.cjs"),g=new Za({command:"node",args:[f],env:process.env}),_=3e5,h=this.mcpClient.connect(g),m=new Promise((y,v)=>setTimeout(()=>v(new Error("MCP connection timeout after 5 minutes")),_));await Promise.race([h,m]),this.mcpReady=!0,w.success("WORKER","MCP server connected"),this.stopOrphanReaper=X2(()=>{let y=new Set;for(let[v]of this.sessionManager.sessions)y.add(v);return y}),w.info("SYSTEM","Started orphan reaper (runs every 5 minutes)"),this.staleSessionReaperInterval=setInterval(async()=>{try{let y=await this.sessionManager.reapStaleSessions();y>0&&w.info("SYSTEM",`Reaped ${y} stale sessions`)}catch(y){w.error("SYSTEM","Stale session reaper error",{error:y instanceof Error?y.message:String(y)})}},120*1e3),this.processPendingQueues(50).then(y=>{y.sessionsStarted>0&&w.info("SYSTEM",`Auto-recovered ${y.sessionsStarted} sessions with pending work`,{totalPending:y.totalPendingSessions,started:y.sessionsStarted,sessionIds:y.startedSessionIds})}).catch(y=>{w.error("SYSTEM","Auto-recovery of pending queues failed",{},y)})}catch(e){throw w.error("SYSTEM","Background initialization failed",{},e),e}}getActiveAgent(){return Yc()&&Go()?this.openRouterAgent:Xc()&&Vo()?this.geminiAgent:this.sdkAgent}startSessionProcessor(e,r){if(!e)return;let n=e.sessionDbId,i=this.getActiveAgent(),s=i.constructor.name;e.abortController.signal.aborted&&(w.debug("SYSTEM","Replacing aborted AbortController before starting generator",{sessionId:e.sessionDbId}),e.abortController=new AbortController);let o=!1,a=!1;w.info("SYSTEM",`Starting generator (${r}) using ${s}`,{sessionId:n}),e.lastGeneratorActivity=Date.now(),e.generatorPromise=i.startSession(e,this).catch(async c=>{let u=c?.message||"";if(["Claude executable not found","CLAUDE_CODE_PATH","ENOENT","spawn","Invalid API key"].some(d=>u.includes(d))){o=!0,this.lastAiInteraction={timestamp:Date.now(),success:!1,provider:s,error:u},w.error("SDK","Unrecoverable generator error - will NOT restart",{sessionId:e.sessionDbId,project:e.project,errorMessage:u});return}if(this.isSessionTerminatedError(c))return w.warn("SDK","SDK resume failed, falling back to standalone processing",{sessionId:e.sessionDbId,project:e.project,reason:c instanceof Error?c.message:String(c)}),this.runFallbackForTerminatedSession(e,c);throw(u.includes("aborted by user")||u.includes("No conversation found"))&&e.memorySessionId&&(w.warn("SDK","Detected stale resume failure, clearing memorySessionId for fresh start",{sessionId:e.sessionDbId,memorySessionId:e.memorySessionId,errorMessage:u}),this.dbManager.getSessionStore().updateMemorySessionId(e.sessionDbId,null),e.memorySessionId=null,e.forceInit=!0),w.error("SDK","Session generator failed",{sessionId:e.sessionDbId,project:e.project,provider:s},c),a=!0,this.lastAiInteraction={timestamp:Date.now(),success:!1,provider:s,error:u},c}).finally(async()=>{let c=Ls(e.sessionDbId);if(c&&!c.process.killed&&c.process.exitCode===null&&await qs(c,5e3),e.generatorPromise=null,!a&&!o&&(this.lastAiInteraction={timestamp:Date.now(),success:!0,provider:s}),o){w.warn("SYSTEM","Skipping restart due to unrecoverable error",{sessionId:e.sessionDbId}),this.broadcastProcessingStatus();return}let{PendingMessageStore:u}=(Us(),su(jo)),l=new u(this.dbManager.getSessionStore().db,3);if(e.idleTimedOut){w.info("SYSTEM","Generator exited due to idle timeout, not restarting",{sessionId:e.sessionDbId}),e.idleTimedOut=!1,this.broadcastProcessingStatus();return}let d=l.getPendingCount(e.sessionDbId);d>0&&(w.info("SYSTEM","Pending work remains after generator exit, restarting with fresh AbortController",{sessionId:e.sessionDbId,pendingCount:d}),e.abortController=new AbortController,this.startSessionProcessor(e,"pending-work-restart")),this.broadcastProcessingStatus()})}isSessionTerminatedError(e){let n=(e instanceof Error?e.message:String(e)).toLowerCase();return n.includes("process aborted by user")||n.includes("processtransport")||n.includes("not ready for writing")||n.includes("session generator failed")||n.includes("claude code process")}async runFallbackForTerminatedSession(e,r){if(!e)return;let n=e.sessionDbId;if(!e.memorySessionId){let o=`fallback-${n}-${Date.now()}`;e.memorySessionId=o,this.dbManager.getSessionStore().updateMemorySessionId(n,o)}if(Vo())try{await this.geminiAgent.startSession(e,this);return}catch(o){w.warn("SDK","Fallback Gemini failed, trying OpenRouter",{sessionId:n,error:o instanceof Error?o.message:String(o)})}if(Go())try{await this.openRouterAgent.startSession(e,this);return}catch(o){w.warn("SDK","Fallback OpenRouter failed",{sessionId:n,error:o instanceof Error?o.message:String(o)})}let s=this.sessionManager.getPendingMessageStore().markAllSessionMessagesAbandoned(n);s>0&&w.warn("SDK","No fallback available; marked pending messages abandoned",{sessionId:n,abandoned:s}),this.sessionManager.removeSessionImmediate(n),this.sessionEventBroadcaster.broadcastSessionCompleted(n)}async processPendingQueues(e=10){let{PendingMessageStore:r}=await Promise.resolve().then(()=>(Us(),jo)),n=new r(this.dbManager.getSessionStore().db,3),i=this.dbManager.getSessionStore(),s=360*60*1e3,o=Date.now()-s;try{let u=i.db.prepare(` SELECT id FROM sdk_sessions WHERE status = 'active' AND started_at_epoch < ? `).all(o);if(u.length>0){let l=u.map(f=>f.id),d=l.map(()=>"?").join(",");i.db.prepare(`