Cron detail page with output history, markdown skill rendering
- /cron/[id]: job details, prompt, output history from filesystem - Cron list items now link to detail pages - Skills render SKILL.md as proper markdown (headings, code, tables) - Cron output proxy reads from ~/.hermes/cron/output/
This commit is contained in:
@@ -0,0 +1,155 @@
|
|||||||
|
"use client";
|
||||||
|
|
||||||
|
import { use, useState, useEffect } from "react";
|
||||||
|
import { ArrowLeft, Play, RefreshCw, Loader2 } from "lucide-react";
|
||||||
|
import Link from "next/link";
|
||||||
|
import { timeAgo } from "@/lib/utils";
|
||||||
|
|
||||||
|
interface CronJob {
|
||||||
|
id: string;
|
||||||
|
name?: string;
|
||||||
|
prompt: string;
|
||||||
|
schedule: string;
|
||||||
|
status: string;
|
||||||
|
deliver: string;
|
||||||
|
skill?: string;
|
||||||
|
skills?: string[];
|
||||||
|
model?: string;
|
||||||
|
repeat?: number;
|
||||||
|
run_count?: number;
|
||||||
|
last_run?: string;
|
||||||
|
next_run?: string;
|
||||||
|
created_at?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
interface CronOutput {
|
||||||
|
timestamp: string;
|
||||||
|
content: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export default function CronDetailPage({ params }: { params: Promise<{ id: string }> }) {
|
||||||
|
const { id } = use(params);
|
||||||
|
const [job, setJob] = useState<CronJob | null>(null);
|
||||||
|
const [outputs, setOutputs] = useState<CronOutput[]>([]);
|
||||||
|
const [loading, setLoading] = useState(true);
|
||||||
|
const [triggering, setTriggering] = useState(false);
|
||||||
|
|
||||||
|
const load = () => {
|
||||||
|
setLoading(true);
|
||||||
|
Promise.all([
|
||||||
|
fetch("/cron/jobs/" + id).then((r) => r.json()).catch(() => null),
|
||||||
|
fetch("/cron/jobs/" + id + "/output").then((r) => r.json()).catch(() => ({ outputs: [] })),
|
||||||
|
]).then(([jobData, outputData]) => {
|
||||||
|
setJob(jobData?.job || jobData || null);
|
||||||
|
setOutputs(outputData?.outputs || []);
|
||||||
|
}).finally(() => setLoading(false));
|
||||||
|
};
|
||||||
|
|
||||||
|
useEffect(() => { load(); }, [id]);
|
||||||
|
|
||||||
|
const trigger = async () => {
|
||||||
|
setTriggering(true);
|
||||||
|
await fetch("/cron/jobs/" + id + "/run", { method: "POST" });
|
||||||
|
setTriggering(false);
|
||||||
|
setTimeout(load, 2000);
|
||||||
|
};
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className="space-y-4">
|
||||||
|
<div className="flex items-center gap-3">
|
||||||
|
<Link href="/cron" className="p-1 -ml-1 rounded-lg active:bg-white/[0.04]">
|
||||||
|
<ArrowLeft size={20} style={{ color: "var(--text-2)" }} />
|
||||||
|
</Link>
|
||||||
|
<div className="flex-1 min-w-0">
|
||||||
|
<div className="text-[15px] font-medium truncate" style={{ color: "var(--text-1)" }}>
|
||||||
|
{job?.name || job?.prompt?.slice(0, 40) || id}
|
||||||
|
</div>
|
||||||
|
{job && (
|
||||||
|
<div className="text-[12px] font-mono mt-0.5" style={{ color: "var(--text-3)" }}>
|
||||||
|
{job.schedule} → {job.deliver}
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
<button onClick={load} className="p-1.5 rounded-lg active:bg-white/[0.04]" style={{ color: "var(--text-2)" }}>
|
||||||
|
<RefreshCw size={16} />
|
||||||
|
</button>
|
||||||
|
<button
|
||||||
|
onClick={trigger}
|
||||||
|
disabled={triggering}
|
||||||
|
className="p-1.5 rounded-lg active:bg-white/[0.04] disabled:opacity-30"
|
||||||
|
style={{ color: "var(--accent)" }}
|
||||||
|
>
|
||||||
|
{triggering ? <Loader2 size={16} className="animate-spin" /> : <Play size={16} />}
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{loading ? (
|
||||||
|
<div className="space-y-3">
|
||||||
|
{[...Array(2)].map((_, i) => (
|
||||||
|
<div key={i} className="card p-4 animate-pulse">
|
||||||
|
<div className="h-4 rounded w-3/4 mb-2" style={{ background: "var(--bg-hover)" }} />
|
||||||
|
<div className="h-3 rounded w-1/2" style={{ background: "var(--bg-hover)" }} />
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
) : (
|
||||||
|
<>
|
||||||
|
{/* Job details */}
|
||||||
|
{job && (
|
||||||
|
<div className="card p-4 space-y-2">
|
||||||
|
<div className="section-label mb-2">Details</div>
|
||||||
|
<Row label="Status" value={job.status} />
|
||||||
|
<Row label="Schedule" value={job.schedule} />
|
||||||
|
<Row label="Deliver" value={job.deliver} />
|
||||||
|
{job.model && <Row label="Model" value={job.model} />}
|
||||||
|
{job.skills && job.skills.length > 0 && <Row label="Skills" value={job.skills.join(", ")} />}
|
||||||
|
{job.run_count != null && <Row label="Runs" value={String(job.run_count)} />}
|
||||||
|
{job.last_run && <Row label="Last run" value={timeAgo(new Date(job.last_run).getTime() / 1000)} />}
|
||||||
|
{job.next_run && <Row label="Next run" value={new Date(job.next_run).toLocaleString()} />}
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
|
||||||
|
{/* Prompt */}
|
||||||
|
{job?.prompt && (
|
||||||
|
<div className="card p-4">
|
||||||
|
<div className="section-label mb-2">Prompt</div>
|
||||||
|
<p className="text-[13px] whitespace-pre-wrap leading-relaxed" style={{ color: "var(--text-1)" }}>
|
||||||
|
{job.prompt}
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
|
||||||
|
{/* Outputs */}
|
||||||
|
<div>
|
||||||
|
<div className="section-label mb-2">Output History ({outputs.length})</div>
|
||||||
|
{outputs.length === 0 ? (
|
||||||
|
<p className="text-sm py-6 text-center" style={{ color: "var(--text-3)" }}>No outputs yet</p>
|
||||||
|
) : (
|
||||||
|
<div className="space-y-2">
|
||||||
|
{outputs.map((o, i) => (
|
||||||
|
<div key={i} className="card p-4">
|
||||||
|
<div className="text-[11px] mb-2" style={{ color: "var(--text-3)" }}>
|
||||||
|
{new Date(o.timestamp).toLocaleString()}
|
||||||
|
</div>
|
||||||
|
<pre className="text-[13px] whitespace-pre-wrap leading-relaxed overflow-x-auto" style={{ color: "var(--text-1)" }}>
|
||||||
|
{o.content}
|
||||||
|
</pre>
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
</>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
function Row({ label, value }: { label: string; value: string }) {
|
||||||
|
return (
|
||||||
|
<div className="flex justify-between text-[13px]">
|
||||||
|
<span style={{ color: "var(--text-2)" }}>{label}</span>
|
||||||
|
<span className="font-mono truncate ml-4 max-w-[60%] text-right" style={{ color: "var(--text-1)" }}>{value}</span>
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
@@ -0,0 +1,29 @@
|
|||||||
|
import { NextRequest, NextResponse } from "next/server";
|
||||||
|
import { promises as fs } from "fs";
|
||||||
|
import path from "path";
|
||||||
|
|
||||||
|
const OUTPUT_DIR = process.env.HERMES_CRON_OUTPUT || "/home/hermes/.hermes/cron/output";
|
||||||
|
|
||||||
|
export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
|
||||||
|
const { id } = await params;
|
||||||
|
const jobDir = path.join(OUTPUT_DIR, id);
|
||||||
|
|
||||||
|
try {
|
||||||
|
const files = await fs.readdir(jobDir);
|
||||||
|
const outputs = await Promise.all(
|
||||||
|
files
|
||||||
|
.filter((f) => f.endsWith(".md"))
|
||||||
|
.sort()
|
||||||
|
.reverse()
|
||||||
|
.slice(0, 20)
|
||||||
|
.map(async (f) => {
|
||||||
|
const content = await fs.readFile(path.join(jobDir, f), "utf-8");
|
||||||
|
const timestamp = f.replace(".md", "").replace(/_/g, " ");
|
||||||
|
return { timestamp, content };
|
||||||
|
})
|
||||||
|
);
|
||||||
|
return NextResponse.json({ outputs });
|
||||||
|
} catch {
|
||||||
|
return NextResponse.json({ outputs: [] });
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,17 @@
|
|||||||
|
import { NextRequest, NextResponse } from "next/server";
|
||||||
|
|
||||||
|
const GATEWAY = process.env.HERMES_GATEWAY_URL || "http://127.0.0.1:8642";
|
||||||
|
|
||||||
|
export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
|
||||||
|
const { id } = await params;
|
||||||
|
try {
|
||||||
|
const res = await fetch(GATEWAY + "/api/jobs/" + id);
|
||||||
|
const data = await res.text();
|
||||||
|
return new NextResponse(data, {
|
||||||
|
status: res.status,
|
||||||
|
headers: { "content-type": "application/json" },
|
||||||
|
});
|
||||||
|
} catch {
|
||||||
|
return NextResponse.json({ error: "gateway unreachable" }, { status: 502 });
|
||||||
|
}
|
||||||
|
}
|
||||||
+11
-7
@@ -1,7 +1,8 @@
|
|||||||
"use client";
|
"use client";
|
||||||
|
|
||||||
import { useState, useEffect } from "react";
|
import { useState, useEffect } from "react";
|
||||||
import { Timer, Play, RefreshCw } from "lucide-react";
|
import { Timer, Play, RefreshCw, Loader2 } from "lucide-react";
|
||||||
|
import Link from "next/link";
|
||||||
import { timeAgo } from "@/lib/utils";
|
import { timeAgo } from "@/lib/utils";
|
||||||
|
|
||||||
interface CronJob {
|
interface CronJob {
|
||||||
@@ -14,7 +15,6 @@ interface CronJob {
|
|||||||
skill?: string;
|
skill?: string;
|
||||||
skills?: string[];
|
skills?: string[];
|
||||||
model?: string;
|
model?: string;
|
||||||
repeat?: number;
|
|
||||||
run_count?: number;
|
run_count?: number;
|
||||||
last_run?: string;
|
last_run?: string;
|
||||||
next_run?: string;
|
next_run?: string;
|
||||||
@@ -36,7 +36,9 @@ export default function CronPage() {
|
|||||||
|
|
||||||
useEffect(() => { load(); }, []);
|
useEffect(() => { load(); }, []);
|
||||||
|
|
||||||
const trigger = async (id: string) => {
|
const trigger = async (e: React.MouseEvent, id: string) => {
|
||||||
|
e.preventDefault();
|
||||||
|
e.stopPropagation();
|
||||||
setTriggering(id);
|
setTriggering(id);
|
||||||
await fetch("/cron/jobs/" + id + "/run", { method: "POST" });
|
await fetch("/cron/jobs/" + id + "/run", { method: "POST" });
|
||||||
setTriggering(null);
|
setTriggering(null);
|
||||||
@@ -81,13 +83,14 @@ export default function CronPage() {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
function JobSection({ label, jobs, onTrigger, triggering }: { label: string; jobs: CronJob[]; onTrigger: (id: string) => void; triggering: string | null }) {
|
function JobSection({ label, jobs, onTrigger, triggering }: { label: string; jobs: CronJob[]; onTrigger: (e: React.MouseEvent, id: string) => void; triggering: string | null }) {
|
||||||
return (
|
return (
|
||||||
<div>
|
<div>
|
||||||
<div className="section-label mb-2">{label} ({jobs.length})</div>
|
<div className="section-label mb-2">{label} ({jobs.length})</div>
|
||||||
<div className="space-y-2">
|
<div className="space-y-2">
|
||||||
{jobs.map((j) => (
|
{jobs.map((j) => (
|
||||||
<div key={j.id} className="card p-4">
|
<Link key={j.id} href={"/cron/" + j.id}>
|
||||||
|
<div className="card card-hover p-4 transition-colors">
|
||||||
<div className="flex items-start justify-between gap-2 mb-2">
|
<div className="flex items-start justify-between gap-2 mb-2">
|
||||||
<div className="flex-1 min-w-0">
|
<div className="flex-1 min-w-0">
|
||||||
<div className="text-[14px] line-clamp-1" style={{ color: "var(--text-1)" }}>
|
<div className="text-[14px] line-clamp-1" style={{ color: "var(--text-1)" }}>
|
||||||
@@ -101,12 +104,12 @@ function JobSection({ label, jobs, onTrigger, triggering }: { label: string; job
|
|||||||
style={{ background: j.status === "active" || j.status === "enabled" ? "#34c759" : "var(--text-3)" }}
|
style={{ background: j.status === "active" || j.status === "enabled" ? "#34c759" : "var(--text-3)" }}
|
||||||
/>
|
/>
|
||||||
<button
|
<button
|
||||||
onClick={() => onTrigger(j.id)}
|
onClick={(e) => onTrigger(e, j.id)}
|
||||||
disabled={triggering === j.id}
|
disabled={triggering === j.id}
|
||||||
className="p-1.5 rounded-lg active:bg-white/[0.04] disabled:opacity-30"
|
className="p-1.5 rounded-lg active:bg-white/[0.04] disabled:opacity-30"
|
||||||
style={{ color: "var(--accent)" }}
|
style={{ color: "var(--accent)" }}
|
||||||
>
|
>
|
||||||
<Play size={14} />
|
{triggering === j.id ? <Loader2 size={14} className="animate-spin" /> : <Play size={14} />}
|
||||||
</button>
|
</button>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
@@ -118,6 +121,7 @@ function JobSection({ label, jobs, onTrigger, triggering }: { label: string; job
|
|||||||
{j.last_run && <span className="ml-auto">last: {timeAgo(new Date(j.last_run).getTime() / 1000)}</span>}
|
{j.last_run && <span className="ml-auto">last: {timeAgo(new Date(j.last_run).getTime() / 1000)}</span>}
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
</Link>
|
||||||
))}
|
))}
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
Reference in New Issue
Block a user