thedotmack--claude-mem/plugin/sqlite/observations/files.js

var __IMPORT_META_URL__ = require("node:url").pathToFileURL(__filename).href;
"use strict";var h=Object.defineProperty;var b=Object.getOwnPropertyDescriptor;var w=Object.getOwnPropertyNames;var F=Object.prototype.hasOwnProperty;var P=(o,r)=>{for(var e in r)h(o,e,{get:r[e],enumerable:!0})},U=(o,r,e,t)=>{if(r&&typeof r=="object"||typeof r=="function")for(let n of w(r))!F.call(o,n)&&n!==e&&h(o,n,{get:()=>r[n],enumerable:!(t=b(r,n))||t.enumerable});return o};var M=o=>U(h({},"__esModule",{value:!0}),o);var K={};P(K,{parseFileList:()=>Y});module.exports=M(K);var l=require("fs"),_=require("path");var i=require("path"),v=require("os"),f=require("fs"),k=require("url");var N=null;function B(o){return(N??process.stderr.write.bind(process.stderr))(o)}function u(o){B(o)}var rr=process.platform==="win32";function G(o){return o.replace(/^\uFEFF/,"")}function g(o){return JSON.parse(G(o))}function j(){return typeof __dirname<"u"?__dirname:(0,i.dirname)((0,k.fileURLToPath)(__IMPORT_META_URL__))}var ir=j();function W(){if(process.env.CLAUDE_MEM_DATA_DIR)return process.env.CLAUDE_MEM_DATA_DIR;let o=(0,i.join)((0,v.homedir)(),".claude-mem"),r=(0,i.join)(o,"settings.json");try{if((0,f.existsSync)(r)){let e=g((0,f.readFileSync)(r,"utf-8")),t=e.env??e;if(t.CLAUDE_MEM_DATA_DIR)return t.CLAUDE_MEM_DATA_DIR}}catch{}return o}var c=W(),H=process.env.CLAUDE_CONFIG_DIR||(0,i.join)((0,v.homedir)(),".claude"),or=(0,i.join)(H,"plugins","marketplaces","thedotmack"),J=(0,i.join)(c,"logs"),sr=(0,i.join)(c,"settings.json"),cr=(0,i.join)(c,"claude-mem.db"),z=(0,i.join)(c,"observer-sessions"),lr=(0,i.basename)(z);var D={dataDir:()=>c,workerPid:()=>(0,i.join)(c,"worker.pid"),serverPid:()=>(0,i.join)(c,".server-beta.pid"),serverPort:()=>(0,i.join)(c,".server-beta.port"),serverRuntime:()=>(0,i.join)(c,".server-beta.runtime.json"),settings:()=>(0,i.join)(c,"settings.json"),database:()=>(0,i.join)(c,"claude-mem.db"),chroma:()=>(0,i.join)(c,"chroma"),combinedCerts:()=>(0,i.join)(c,"combined_certs.pem"),transcriptsConfig:()=>(0,i.join)(c,"transcript-watch.json"),transcriptsState:()=>(0,i.join)(c,"transcript-watch-state.json"),cloudSyncState:()=>(0,i.join)(c,"cloud-sync-state.json"),corpora:()=>(0,i.join)(c,"corpora"),supervisorRegistry:()=>(0,i.join)(c,"supervisor.json"),envFile:()=>(0,i.join)(c,".env"),logsDir:()=>J};var O=(s=>(s[s.DEBUG=0]="DEBUG",s[s.INFO=1]="INFO",s[s.WARN=2]="WARN",s[s.ERROR=3]="ERROR",s[s.SILENT=4]="SILENT",s))(O||{}),$=null,C=class{level=null;useColor;logFilePath=null;logFileInitialized=!1;constructor(){this.useColor=process.stdout.isTTY??!1}ensureLogFileInitialized(){if(!this.logFileInitialized){this.logFileInitialized=!0;try{let r=D.logsDir();(0,l.existsSync)(r)||(0,l.mkdirSync)(r,{recursive:!0});let e=new Date().toISOString().split("T")[0];this.logFilePath=(0,_.join)(r,`claude-mem-${e}.log`)}catch(r){console.error("[LOGGER] Failed to initialize log file:",r instanceof Error?r.message:String(r)),this.logFilePath=null}}}getLevel(){if(this.level===null)try{let r=D.settings();if((0,l.existsSync)(r)){let e=(0,l.readFileSync)(r,"utf-8"),n=(g(e).CLAUDE_MEM_LOG_LEVEL||"INFO").toUpperCase();this.level=O[n]??1}else this.level=1}catch(r){console.error("[LOGGER] Failed to load log level from settings:",r instanceof Error?r.message:String(r)),this.level=1}return this.level}formatData(r){if(r==null)return"";if(typeof r=="string")return r;if(typeof r=="number"||typeof r=="boolean")return r.toString();if(typeof r=="object"){if(r instanceof Error)return this.getLevel()===0?`${r.message}
${r.stack}`:r.message;if(Array.isArray(r))return`[${r.length} items]`;let e=Object.keys(r);return e.length===0?"{}":e.length<=3?JSON.stringify(r):`{${e.length} keys: ${e.slice(0,3).join(", ")}...}`}return String(r)}formatTool(r,e){if(!e)return r;let t=e;if(typeof e=="string")try{t=JSON.parse(e)}catch{t=e}if(r==="Bash"&&t.command)return`${r}(${t.command})`;if(t.file_path)return`${r}(${t.file_path})`;if(t.notebook_path)return`${r}(${t.notebook_path})`;if(r==="Glob"&&t.pattern)return`${r}(${t.pattern})`;if(r==="Grep"&&t.pattern)return`${r}(${t.pattern})`;if(t.url)return`${r}(${t.url})`;if(t.query)return`${r}(${t.query})`;if(r==="Task"){if(t.subagent_type)return`${r}(${t.subagent_type})`;if(t.description)return`${r}(${t.description})`}return r==="Skill"&&t.skill?`${r}(${t.skill})`:r==="LSP"&&t.operation?`${r}(${t.operation})`:r}formatTimestamp(r){let e=r.getFullYear(),t=String(r.getMonth()+1).padStart(2,"0"),n=String(r.getDate()).padStart(2,"0"),s=String(r.getHours()).padStart(2,"0"),d=String(r.getMinutes()).padStart(2,"0"),m=String(r.getSeconds()).padStart(2,"0"),S=String(r.getMilliseconds()).padStart(3,"0");return`${e}-${t}-${n} ${s}:${d}:${m}.${S}`}log(r,e,t,n,s){if(r<this.getLevel())return;this.ensureLogFileInitialized();let d=this.formatTimestamp(new Date),m=O[r].padEnd(5),S=e.padEnd(6),y="";n?.correlationId?y=`[${n.correlationId}] `:n?.sessionId&&(y=`[session-${n.sessionId}] `);let a="";if(s!=null)if(s instanceof Error)a=this.getLevel()===0?`
${s.message}
${s.stack}`:` ${s.message}`;else if(this.getLevel()===0&&typeof s=="object")try{a=`
`+JSON.stringify(s,null,2)}catch{a=" "+this.formatData(s)}else a=" "+this.formatData(s);let R="";if(n){let{sessionId:p,memorySessionId:E,correlationId:V,...L}=n;Object.keys(L).length>0&&(R=` {${Object.entries(L).map(([T,A])=>`${T}=${A}`).join(", ")}}`)}let x=`[${d}] [${m}] [${S}] ${y}${t}${R}${a}`;if(this.logFilePath)try{(0,l.appendFileSync)(this.logFilePath,x+`
`,"utf8")}catch(p){let E=p instanceof Error?p:new Error(String(p));u(`[LOGGER] Failed to write to log file: ${E.message}
${E.stack??""}
`)}else u(x+`
`)}debug(r,e,t,n){this.log(0,r,e,t,n)}info(r,e,t,n){this.log(1,r,e,t,n)}warn(r,e,t,n){this.log(2,r,e,t,n)}setErrorSink(r){$=r}error(r,e,t,n){this.log(3,r,e,t,n),this.routeErrorToSink(e,t,n)}routeErrorToSink(r,e,t){try{if(!$||!(t instanceof Error))return;$(t)}catch{}}dataIn(r,e,t,n){this.info(r,`\u2192 ${e}`,t,n)}dataOut(r,e,t,n){this.info(r,`\u2190 ${e}`,t,n)}success(r,e,t,n){this.info(r,`\u2713 ${e}`,t,n)}failure(r,e,t,n){this.error(r,`\u2717 ${e}`,t,n)}},I=new C;function Y(o){if(!o)return[];try{let r=JSON.parse(o);return Array.isArray(r)?r:[String(r)]}catch(r){return I.debug("DB","File list is not JSON; treating value as a single path",{value:o},r instanceof Error?r:new Error(String(r))),[o]}}0&&(module.exports={parseFileList});