v6ole/streamdock-ai-monitor
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v2.2: Codex + Claude working, opencode process monitoring scaffold

Browse Source
This commit is contained in:
v6ole
2026-06-18 16:44:12 +08:00
parent 3313d3ac81
commit 42fac626ce
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
com.streamdock.ai-monitor.sdPlugin/plugin/index.js
+15 -4
View File
@@ -164,11 +164,22 @@ function tailFile(filePath, ctx, agent) {
function poll(ctx) { function poll(ctx) {
var ss = states[ctx]; if (!ss || !ss.agent) return; var ss = states[ctx]; if (!ss || !ss.agent) return;
var detected = false; var detected = false;
var files = findFiles(ss.agent.scanDir, '.jsonl'); if (ss.agent.type === "process") {
files.sort(function(a,b) { return fs.statSync(b).mtimeMs - fs.statSync(a).mtimeMs; }); // Process-based monitoring: check if the named process exists
for (var i = 0; i < Math.min(files.length, 3); i++) { if (tailFile(files[i], ctx, ss.agent)) detected = true; } try {
var check = childProcess.execSync("cmd /c tasklist", { timeout: 500, encoding: "utf-8" });
if (check.indexOf(ss.agent.processName) >= 0) {
setState(ctx, "working");
detected = true;
}
} catch (_) {}
} else {
var files = findFiles(ss.agent.scanDir, ".jsonl");
files.sort(function(a,b) { return fs.statSync(b).mtimeMs - fs.statSync(a).mtimeMs; });
for (var i = 0; i < Math.min(files.length, 3); i++) { if (tailFile(files[i], ctx, ss.agent)) detected = true; }
}
if (detected) ss.lastActivity = Date.now(); if (detected) ss.lastActivity = Date.now();
if (ss.currentState !== 'idle' && ss.currentState !== 'done' && Date.now() - ss.lastActivity > IDLE_TIMEOUT_MS) { setState(ctx, 'idle'); } if (ss.currentState !== "idle" && ss.currentState !== "done" && Date.now() - ss.lastActivity > IDLE_TIMEOUT_MS) { setState(ctx, "idle"); }
} }
function makeActionFn(agentKey) { function makeActionFn(agentKey) {