Lines 1-35javascript
1import { createRequire as __createRequire } from "node:module";
2const require = __createRequire(import.meta.url);
3// clavue v1.56.4 mao-command (built from source)
4var __create=Object.create;var __defProp=Object.defineProperty;var __getOwnPropDesc=Object.getOwnPropertyDescriptor;var __getOwnPropNames=Object.getOwnPropertyNames;var __getProtoOf=Object.getPrototypeOf,__hasOwnProp=Object.prototype.hasOwnProperty;var __name=(target,value)=>
5GFS4: `),console.error(m)},"debug"));fs6[gracefulQueue]||(queue=global[gracefulQueue]||[],publishQueue(fs6,queue),fs6.close=(function(fs$close){function close(fd,cb){return fs$close.call(fs6,fd,function(err){err||resetQueue(),typeof cb=="function"&&cb.apply(this,arguments)})}return __name(close,"close"),Object.defineProperty(close,previousSymbol,{value:fs$close}),close})(fs6.close),fs6.closeSync=(function(fs$closeSync){function closeSync(fd){fs$closeSync.apply(fs6,arguments),resetQueue()}return __name(closeSync,"closeSync"),Object.defineProperty(closeSync,previousSymbol,{value:fs$closeSync}),c ...
6`,"utf8"),process4.platform!=="win32")try{fs.chmodSync(filePath,384)}catch{}}__name(defaultWriteJsonFile,"defaultWriteJsonFile");function defaultSafeReadFile(filePath){try{return
7`,"utf8"),nextState}__name(saveState,"saveState");function updateState(cwd,mutate){let state=loadState(cwd);return mutate(state),saveState(cwd,state)}__name(updateState,"updateState");function generateJobId(prefix="mao"){let random=Math.random().toString(36).slice(2,8);return`${prefix}-${Date.now().toString(36)}-${random}`}__name(generateJobId,"generateJobId");function resolveJobMetaFile(cwd,jobId){return ensureStateDir(cwd),path2.join(resolveJobsDir(cwd),`${jobId}.json`)}__name(resolveJobMetaFile,"resolveJobMetaFile");function resolveJobLogFile(cwd,jobId){return ensureStateDir(cwd),path2.join ...
8`,"utf8")}__name(appendLogLine,"appendLogLine");function appendLogBlock(logFile,title,body){let normalizedBody=String(body??"").trimEnd();normalizedBody&&fs.appendFileSync
11`,"utf8")}__name(appendLogBlock,"appendLogBlock");function pidIsRunning(pid){if(!Number.isFinite(pid))return!1;try{return killImpl(pid,0),!0}catch(error){return error?.code==="EPERM"}}__name(pidIsRunning,"pidIsRunning");function sortJobsNewestFirst(jobs){return[...jobs].sort((left,right)=>String(right.updatedAt??"").localeCompare(String(left.updatedAt??"")))}__name(sortJobsNewestFirst,"sortJobsNewestFirst");function readJobProgressPreview(logFile,maxLines=4){return!logFile||!fs.existsSync(logFile)?[]:fs.readFileSync(logFile,"utf8").split(/\r?\n/).map(line=>line.trim()).filter(Boolean).filter(l ...
12`)}__name(buildAdversarialReviewPrompt,"buildAdversarialReviewPrompt");function buildAdversarialReviewCommand({profile,model,context,focusText,schemaFile,resultFile,writeJsonFile:writeJsonFile2}){return writeJsonFile2(schemaFile,REVIEW_SCHEMA
13${result.stdout}`.trim();if(!result.error&&looksLikeMissingProcessMessage(combinedOutput))return{attempted:!0,delivered:!1,method:"taskkill",result};if(result.error?.code==="ENOENT")try{return killImpl(pid),{attempted:!0,delivered:!0,method:"kill"}}catch(error){if(error?.code==="ESRCH")return{attempted:!0,delivered:!1,method:"kill"};throw error}throw result.error?result.error:new Error(formatCommandFailure(result))}try{return killImpl(-pid,"SIGTERM"),{attempted:!0,delivered:!0,method:"process-group"}}catch(error){if(error?.code!=="ESRCH")try{return killImpl(pid,"SIGTERM"),{attempted:!0,deliver ...
14${result.stderr}`),exitCode:result.status});if(result.error)throw result.error;return result.status!==0?{type:"text"
15${formatCommandFailure(result)}
16`}:{type:"text",value:renderJobResult2(completedJob)}}__name(runForegroundJob2,"runForegroundJob");function getStatusJobs2(cwd,limit=8,all=!1){let
17`,"utf8")}finally{try{await release()}catch{}}return filePath}__name(writeMaoCoordinationLedger,"writeMaoCoordinationLedger");async function acquireLedgerLock(filePath){try{await fs3.writeFile(filePath,await readExistingLedgerOrEmpty(filePath),{flag:"a"});let properLockfile=await Promise.resolve().then(()=>__toESM(require_proper_lockfile())),lock=properLockfile.lock??properLockfile.default?.lock;return typeof lock!="function"?async()=>{}:await lock(filePath,{retries:{retries:5,factor:1.5,minTimeout:25,maxTimeout:250},stale:5e3,realpath:!1})}catch{return async()=>{}}}__name(acquireLedgerLock,"a ...
18`;function errnoCode(error){if(typeof error!="object"||error===null||!("code"in error))return;let code=error.code;return typeof code=="string"?code:
19`,"utf8"),run}__name(writeTaskRun,"writeTaskRun");async function readWorkflowTaskRun({rootDir=process.cwd(),runId=""}={}){let filePath=resolveRunPath(rootDir,sanitizePathSegment2(runId));return{...JSON.parse(await fs4.readFile(filePath,"utf8")),runPath:filePath}}__name(readWorkflowTaskRun,"readWorkflowTaskRun");async function updateWorkflowTaskRun({rootDir=process.cwd(),runId="",status,changedFiles,testsRun,review,ci,summary,nowIso:nowIso2=__name(()=>new Date().toISOString(),"nowIso")}={}){let current=await readWorkflowTaskRun({rootDir,runId}),updatedAt=nowIso2(),next={...current,status:normal ...
20`,"utf8")}__name(writeJsonFile,"writeJsonFile");function safeReadFile(filePath){try{return fs5.existsSync(filePath)?fs5.readFileSync(filePath,"utf8"):
22`}let verdict=String(parsed.verdict??"").trim(),summary=String(parsed.summary??"").trim(),findings=Array.isArray(parsed.findings)?parsed.findings.map(normalizeReviewFinding):[],nextSteps=Array.isArray(parsed.next_steps)?parsed.next_steps.filter(step=>typeof step=="string"&&step.trim()).map(step=>step.trim()):[],lines=[`# ${meta.title}`,"",`Target: ${meta.targetLabel}`,`Verdict: ${verdict||"unknown"}`,"",summary||"No summary provided.",""];if(findings.length>0){lines.push("## Findings","");for(let finding of findings.sort((left,right)=>getSeverityRank(left.severity)-getSeverityRank(right.severi ...
24`}__name(formatStructuredReviewResult,"formatStructuredReviewResult");function renderJobResult(job){let resultText=safeReadFile(job.resultFile).trim(),logText=safeReadFile(job.logFile);if(job.kind==="adversarial-review")return formatStructuredReviewResult(resultText,{title:"Mao Adversarial Review",targetLabel:job.targetLabel??"repository review"});if(resultText)return resultText.endsWith(`
25`)?resultText:`${resultText}
26`;let lastLogLine=firstMeaningfulLine3(logText.split(/\r?\n/).reverse().find(line=>line.trim()),"");return lastLogLine?`${lastLogLine}
27`:`${job.title} has no stored result output.
28`}__name(renderJobResult,"renderJobResult");var maoJobRunner=createMaoJobRunner({jobStore:maoJobs,nowIso,resolveWorkspaceRoot,getCodexCommandSpec,runCommand:runCommand2,safeReadFile,renderJobResult}),{createJob,spawnBackgroundJob,runForegroundJob,getStatusJobs,waitForJob,findEnrichedJob,cancelJob}=maoJobRunner;function renderStatusTable(jobs){if(jobs.length===0)return"No /mao jobs found for this repository yet.";let lines=["| Job | Kind | Status | Model | Summary | Actions |","| --- | --- | --- | --- | --- | --- |"];for(let job of jobs){let actions=job.status==="queued"||job.status==="running" ...
29`)}__name(renderStatusTable,"renderStatusTable");function renderSupervisorStatus(ledger){if(!ledger)return"";let lines=["## Silent Mao Supervisor","",`- Session: ${ledger.sessionId||"unknown"}`,`- Goal: ${
30`)}__name(renderSupervisorStatus,"renderSupervisorStatus");function renderWorkerEvidence(workerResults,limit=8){let results=Array.isArray(workerResults)?workerResults:[];if(results.length===0)return["- No worker evidence recorded."];let lines=[];for(let result of results.slice(0,limit)){let changedFiles=Array.isArray(result.changedFiles)?result.changedFiles:[],testsRun=Array.isArray(result.testsRun)?result.testsRun:[],blockers=Array.isArray(result.blockers)?result.blockers:[];lines.push(`- ${result.worker||"unknown worker"}: ${result.status||"unknown"}; changed=${changedFiles.length}; tests=
31`);let finalGate=ledger.finalGate&&typeof ledger.finalGate=="object"?ledger.finalGate:{},findings=Array.isArray(ledger.findings)?ledger.findings:[],blockingFindings=Array.isArray(finalGate.blockingFindings)?finalGate.blockingFindings:findings.filter(finding=>finding.severity==="critical"||finding.severity==="high"),canDeliver=finalGate.canDeliver===!0||finalGate.status==="passed",lines=["# Mao Delivery Gate","",`Status: ${finalGate.status||(canDeliver?"passed":"blocked")}`,`Can deliver: ${canDeliver?"yes":"no"}`,`
33`}__name(renderMaoGate,"renderMaoGate");function buildMaoGatePayload(ledger,{workflowProof=null}={}){if(!ledger)return{schemaVersion:"mao_delivery_gate_v1",status:"missing-ledger",canDeliver:!
Long lines were clipped for display.