Mohamed BoudraandGitHub
be41911083
* Add metrics collection and terminal performance tests * feat: add loop, schedule, and chat commands with slash-namespaced RPC Introduce three new server-side features with CLI command groups: - `paseo loop` — iterative agent execution with verify-check/verify-prompt - `paseo schedule` — recurring tasks on interval or cron cadence - `paseo chat` — chat rooms for agent-to-agent coordination All features use new slash-namespaced RPC methods (e.g. `loop/run`, `schedule/create`, `chat/post`) instead of flat message types, backed by file-based persistence and wired through the existing WebSocket session dispatch. * test: stabilize loop schedule chat rollout
83 lines
2.6 KiB
TypeScript
83 lines
2.6 KiB
TypeScript
import { Command } from "commander";
|
|
import { connectToDaemon, getDaemonHost } from "../../utils/client.js";
|
|
import type { CommandError, CommandOptions } from "../../output/index.js";
|
|
import type { LoopDaemonClient, LoopLogEntry } from "./types.js";
|
|
|
|
export interface LoopLogsOptions extends CommandOptions {
|
|
pollInterval?: string;
|
|
}
|
|
|
|
export function addLoopLogsOptions(command: Command): Command {
|
|
return command
|
|
.description("Stream loop logs")
|
|
.argument("<id>", "Loop ID")
|
|
.option("--poll-interval <ms>", "Polling interval in milliseconds", "1000");
|
|
}
|
|
|
|
function parsePollInterval(value: string): number {
|
|
const parsed = Number.parseInt(value, 10);
|
|
if (!Number.isInteger(parsed) || parsed <= 0) {
|
|
throw {
|
|
code: "INVALID_POLL_INTERVAL",
|
|
message: "--poll-interval must be a positive integer",
|
|
} satisfies CommandError;
|
|
}
|
|
return parsed;
|
|
}
|
|
|
|
function renderLogEntry(entry: LoopLogEntry): string {
|
|
const prefix = [
|
|
entry.timestamp,
|
|
entry.source,
|
|
entry.iteration === null ? null : `iteration=${entry.iteration}`,
|
|
entry.level === "error" ? "ERROR" : null,
|
|
]
|
|
.filter(Boolean)
|
|
.join(" ");
|
|
return `${prefix}\n${entry.text}`;
|
|
}
|
|
|
|
export async function runLoopLogsCommand(
|
|
id: string,
|
|
options: LoopLogsOptions,
|
|
_command: Command,
|
|
): Promise<void> {
|
|
const host = getDaemonHost({ host: options.host as string | undefined });
|
|
const pollInterval = parsePollInterval(options.pollInterval ?? "1000");
|
|
let client;
|
|
try {
|
|
client = (await connectToDaemon({
|
|
host: options.host as string | undefined,
|
|
})) as unknown as LoopDaemonClient;
|
|
} catch (error) {
|
|
const message = error instanceof Error ? error.message : String(error);
|
|
console.error(`Error: Cannot connect to daemon at ${host}: ${message}`);
|
|
console.error("Start the daemon with: paseo daemon start");
|
|
process.exit(1);
|
|
}
|
|
|
|
let cursor = 0;
|
|
try {
|
|
for (;;) {
|
|
const payload = await client.loopLogs(id, cursor);
|
|
if (payload.error || !payload.loop) {
|
|
throw new Error(payload.error ?? `Loop not found: ${id}`);
|
|
}
|
|
cursor = payload.nextCursor;
|
|
for (const entry of payload.entries) {
|
|
console.log(renderLogEntry(entry));
|
|
}
|
|
if (payload.loop.status !== "running") {
|
|
await client.close();
|
|
return;
|
|
}
|
|
await new Promise((resolve) => setTimeout(resolve, pollInterval));
|
|
}
|
|
} catch (error) {
|
|
await client.close().catch(() => {});
|
|
const message = error instanceof Error ? error.message : String(error);
|
|
console.error(`Error: Failed to stream loop logs: ${message}`);
|
|
process.exit(1);
|
|
}
|
|
}
|