wehub-resource-sync
070959e133
landing-page-staging / Deploy landing page to staging (push) Has been skipped
landing-page-ci / Validate landing page (push) Failing after 4s
visual-baseline / Capture visual baselines (push) Has been cancelled
bake-plugin-previews / Bake plugin previews (push) Has been cancelled
41 lines
1.4 KiB
JavaScript
41 lines
1.4 KiB
JavaScript
// Plain (raw stdout) renderer. OD's `plain` streamFormat (deepseek /
|
|
// qwen / grok / grok-build) treats stdout as the final assistant
|
|
// response. We emit ONLY the report content.
|
|
|
|
import { writeFile } from 'node:fs/promises';
|
|
|
|
const sleep = ms => new Promise(r => setTimeout(r, ms));
|
|
|
|
export async function renderAsPlain(events, opts = {}) {
|
|
const emit = opts.emit ?? (s => process.stdout.write(s));
|
|
const maxSleep = opts.maxSleepMs ?? 2000;
|
|
|
|
if (opts.includeToolTrace) {
|
|
const tools = events.filter(e => e.type === 'tool_call');
|
|
if (tools.length > 0) {
|
|
emit(`<!-- tools used (${tools.length}):\n`);
|
|
for (const tc of tools) {
|
|
const summary = (() => {
|
|
if (!tc.input || typeof tc.input !== 'object') return '';
|
|
const o = tc.input;
|
|
if (typeof o.file_path === 'string') return o.file_path;
|
|
if (typeof o.command === 'string') return o.command;
|
|
if (typeof o.pattern === 'string') return `${o.pattern} in ${o.path ?? '.'}`;
|
|
return JSON.stringify(o).slice(0, 80);
|
|
})();
|
|
emit(` ${tc.name} ${summary}\n`);
|
|
}
|
|
emit(`-->\n`);
|
|
}
|
|
}
|
|
|
|
for (const e of events) {
|
|
if (e.type === 'report') {
|
|
if (!opts.noDelay) await sleep(Math.min(maxSleep, 200));
|
|
emit(e.content);
|
|
if (!e.content.endsWith('\n')) emit('\n');
|
|
if (opts.reportFile) await writeFile(opts.reportFile, e.content).catch(() => {});
|
|
}
|
|
}
|
|
}
|