Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
120 changes: 60 additions & 60 deletions plugin/scripts/add-memory.cjs

Large diffs are not rendered by default.

162 changes: 81 additions & 81 deletions plugin/scripts/context-hook.cjs

Large diffs are not rendered by default.

114 changes: 57 additions & 57 deletions plugin/scripts/recall-approve.cjs

Large diffs are not rendered by default.

116 changes: 58 additions & 58 deletions plugin/scripts/recall-hook.cjs

Large diffs are not rendered by default.

120 changes: 60 additions & 60 deletions plugin/scripts/save-project-memory.cjs

Large diffs are not rendered by default.

138 changes: 69 additions & 69 deletions plugin/scripts/search-memory.cjs

Large diffs are not rendered by default.

114 changes: 57 additions & 57 deletions plugin/scripts/status.cjs

Large diffs are not rendered by default.

136 changes: 68 additions & 68 deletions plugin/scripts/summary-hook.cjs

Large diffs are not rendered by default.

57 changes: 52 additions & 5 deletions src/lib/stdin.js
Original file line number Diff line number Diff line change
@@ -1,19 +1,66 @@
async function readStdin() {
const DEFAULT_STDIN_TIMEOUT_MS = 3000;

async function readStdin(timeoutMs = DEFAULT_STDIN_TIMEOUT_MS) {
return new Promise((resolve, reject) => {
let data = '';
let settled = false;
let timer = null;

// On Windows, piped stdin never emits 'end' for hook subprocesses, so we
// must stop stdin from keeping the event loop (and the process) alive
// once we've settled.
const releaseStdin = () => {
try {
process.stdin.pause();
} catch {}
try {
process.stdin.unref?.();
} catch {}
};

const settle = (fn, value) => {
if (settled) return;
settled = true;
clearTimeout(timer);
releaseStdin();
fn(value);
};

// Hooks receive a single JSON object; resolve as soon as it parses so
// platforms that never emit 'end' don't wait for the timeout.
const tryParse = () => {
if (!data.trim()) return;
try {
const parsed = JSON.parse(data);
settle(resolve, parsed);
} catch {
// Incomplete JSON; keep accumulating chunks.
}
};

timer = setTimeout(() => {
settle(resolve, {});
}, timeoutMs);

process.stdin.setEncoding('utf8');
process.stdin.on('data', (chunk) => {
data += chunk;
tryParse();
});
process.stdin.on('end', () => {
if (settled) return;
if (!data.trim()) {
settle(resolve, {});
return;
}
try {
resolve(data.trim() ? JSON.parse(data) : {});
settle(resolve, JSON.parse(data));
} catch (err) {
reject(new Error(`Failed to parse stdin JSON: ${err.message}`));
settle(reject, new Error(`Failed to parse stdin JSON: ${err.message}`));
}
});
process.stdin.on('error', reject);
if (process.stdin.isTTY) resolve({});
process.stdin.on('error', (err) => settle(reject, err));
if (process.stdin.isTTY) settle(resolve, {});
});
}

Expand Down