Run: npm run build
"; -} - -export async function startVoiceServer(opts: VoiceServerOptions): Promise<() => PromiseSign in to continue
-Authentication complete. You can close this window.
`); - - // ── Chat branch API routes ────────────────────────────────────── - } else if (url.pathname === "/api/chat/list" && req.method === "GET") { - try { - const git = (cmd: string) => execSync(cmd, { cwd: agentRoot, encoding: "utf-8" }).trim(); - const current = git("git rev-parse --abbrev-ref HEAD"); - // List branches matching chat/* pattern, plus the current branch - let branches: string[]; - try { - branches = git("git branch --list 'chat/*' --sort=-committerdate --format='%(refname:short)|%(committerdate:relative)'") - .split("\n").filter(Boolean); - } catch { - branches = []; - } - const chats = branches.map((line) => { - const [branch, time] = line.split("|"); - const name = branch.replace("chat/", ""); - return { branch, name, time: time || "" }; - }); - // If current branch is not a chat/* branch, add it at the top - if (!current.startsWith("chat/")) { - chats.unshift({ branch: current, name: current, time: "current" }); - } - jsonReply(res, 200, { current, chats }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/chat/new" && req.method === "POST") { - try { - const git = (cmd: string) => execSync(cmd, { cwd: agentRoot, encoding: "utf-8" }).trim(); - // Generate branch name: chat/YYYY-MM-DD-HHMMSS - const now = new Date(); - const pad = (n: number) => String(n).padStart(2, "0"); - const branch = `chat/${now.getFullYear()}${pad(now.getMonth()+1)}${pad(now.getDate())}-${pad(now.getHours())}${pad(now.getMinutes())}${pad(now.getSeconds())}`; - // Stage and commit any pending changes on current branch - try { - git("git add -A"); - git('git commit -m "auto-save before new chat" --allow-empty'); - } catch { - // No changes to commit, that's fine - } - // Create and switch to new branch - git(`git checkout -b ${branch}`); - activeBranch = branch; - jsonReply(res, 200, { branch }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/chat/switch" && req.method === "POST") { - try { - const body = await readBody(req); - const { branch } = JSON.parse(body); - if (!branch) return jsonReply(res, 400, { error: "Missing branch" }); - const git = (cmd: string) => execSync(cmd, { cwd: agentRoot, encoding: "utf-8" }).trim(); - // Auto-save current branch - try { - git("git add -A"); - git('git commit -m "auto-save before switching chat" --allow-empty'); - } catch {} - git(`git checkout ${branch}`); - activeBranch = branch; - jsonReply(res, 200, { branch }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/chat/delete" && req.method === "POST") { - try { - const body = await readBody(req); - const { branch } = JSON.parse(body); - if (!branch) return jsonReply(res, 400, { error: "Missing branch" }); - const git = (cmd: string) => execSync(cmd, { cwd: agentRoot, encoding: "utf-8" }).trim(); - const current = git("git rev-parse --abbrev-ref HEAD"); - if (branch === current) return jsonReply(res, 400, { error: "Cannot delete the active branch" }); - git(`git branch -D ${branch}`); - deleteHistory(opts.agentDir, branch); - jsonReply(res, 200, { ok: true }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/chat/history" && req.method === "GET") { - const branch = url.searchParams.get("branch"); - if (!branch) return jsonReply(res, 400, { error: "Missing branch param" }); - const messages = loadHistory(opts.agentDir, branch); - jsonReply(res, 200, { branch, messages }); - - // ── Composio API routes ───────────────────────────────────────── - } else if (url.pathname === "/api/composio/toolkits" && req.method === "GET") { - if (!composioAdapter) return jsonReply(res, 501, { error: "Composio not configured" }); - try { - const toolkits = await composioAdapter.getToolkits(); - jsonReply(res, 200, toolkits); - } catch (err: any) { - jsonReply(res, 502, { error: err.message }); - } - - } else if (url.pathname === "/api/composio/connect" && req.method === "POST") { - if (!composioAdapter) return jsonReply(res, 501, { error: "Composio not configured" }); - const body = await readBody(req); - let parsed: { toolkit: string; redirectUrl?: string }; - try { parsed = JSON.parse(body); } catch { return jsonReply(res, 400, { error: "Invalid JSON" }); } - if (!parsed.toolkit) return jsonReply(res, 400, { error: "Missing toolkit" }); - try { - const result = await composioAdapter.connect(parsed.toolkit, parsed.redirectUrl); - jsonReply(res, 200, result); - } catch (err: any) { - jsonReply(res, 502, { error: err.message }); - } - - } else if (url.pathname === "/api/composio/connections" && req.method === "GET") { - if (!composioAdapter) return jsonReply(res, 501, { error: "Composio not configured" }); - try { - const connections = await composioAdapter.getConnections(); - jsonReply(res, 200, connections); - } catch (err: any) { - jsonReply(res, 502, { error: err.message }); - } - - } else if (url.pathname.match(/^\/api\/composio\/connections\/[^/]+$/) && req.method === "DELETE") { - if (!composioAdapter) return jsonReply(res, 501, { error: "Composio not configured" }); - const connId = url.pathname.split("/").pop()!; - try { - await composioAdapter.disconnect(connId); - jsonReply(res, 200, { ok: true }); - } catch (err: any) { - jsonReply(res, 502, { error: err.message }); - } - - // ── SkillFlows API ──────────────────────────────────────────── - } else if (url.pathname === "/api/skills/list" && req.method === "GET") { - try { - const skills = await discoverSkills(agentRoot); - jsonReply(res, 200, { skills }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/flows/list" && req.method === "GET") { - try { - const workflows = await discoverWorkflows(agentRoot); - const flows = workflows.filter((w) => w.type === "flow"); - jsonReply(res, 200, { flows }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/flows/save" && req.method === "POST") { - const body = await readBody(req); - let parsed: { name: string; description: string; steps: { skill: string; prompt: string; channel?: string }[] }; - try { parsed = JSON.parse(body); } catch { return jsonReply(res, 400, { error: "Invalid JSON" }); } - if (!parsed.name || !parsed.steps?.length) return jsonReply(res, 400, { error: "Missing name or steps" }); - try { - await saveFlowDefinition(agentRoot, parsed); - jsonReply(res, 200, { ok: true }); - } catch (err: any) { - jsonReply(res, 400, { error: err.message }); - } - - } else if (url.pathname === "/api/flows/delete" && req.method === "DELETE") { - const body = await readBody(req); - let parsed: { name: string }; - try { parsed = JSON.parse(body); } catch { return jsonReply(res, 400, { error: "Invalid JSON" }); } - if (!parsed.name) return jsonReply(res, 400, { error: "Missing name" }); - try { - await deleteFlowDefinition(agentRoot, parsed.name); - jsonReply(res, 200, { ok: true }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - // ── Scheduler API ────────────────────────────────────────────── - } else if (url.pathname === "/api/schedules/list" && req.method === "GET") { - try { - const schedules = await discoverSchedules(agentRoot); - jsonReply(res, 200, { schedules }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/schedules/save" && req.method === "POST") { - const body = await readBody(req); - let parsed: { id: string; prompt: string; cron?: string; mode?: string; runAt?: string; enabled?: boolean }; - try { parsed = JSON.parse(body); } catch { return jsonReply(res, 400, { error: "Invalid JSON" }); } - if (!parsed.id || !parsed.prompt) return jsonReply(res, 400, { error: "Missing id or prompt" }); - const mode = parsed.mode === "once" ? "once" as const : "repeat" as const; - if (mode === "once" && parsed.runAt) { - // runAt mode — validate the datetime is in the future - const runAtDate = new Date(parsed.runAt); - if (isNaN(runAtDate.getTime())) return jsonReply(res, 400, { error: "Invalid runAt datetime" }); - } else { - // cron mode — validate expression - if (!parsed.cron) return jsonReply(res, 400, { error: "Missing cron expression" }); - if (!cron.validate(parsed.cron)) return jsonReply(res, 400, { error: "Invalid cron expression" }); - } - try { - await saveSchedule(agentRoot, { - id: parsed.id, - prompt: parsed.prompt, - cron: parsed.cron || "", - mode, - ...(parsed.runAt ? { runAt: parsed.runAt } : {}), - enabled: parsed.enabled !== false, - createdAt: new Date().toISOString(), - }); - await reloadSchedules(schedulerOpts); - jsonReply(res, 200, { ok: true }); - } catch (err: any) { - jsonReply(res, 400, { error: err.message }); - } - - } else if (url.pathname === "/api/schedules/delete" && req.method === "DELETE") { - const body = await readBody(req); - let parsed: { id: string }; - try { parsed = JSON.parse(body); } catch { return jsonReply(res, 400, { error: "Invalid JSON" }); } - if (!parsed.id) return jsonReply(res, 400, { error: "Missing id" }); - try { - await deleteSchedule(agentRoot, parsed.id); - await reloadSchedules(schedulerOpts); - jsonReply(res, 200, { ok: true }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/schedules/toggle" && req.method === "POST") { - const body = await readBody(req); - let parsed: { id: string; enabled: boolean }; - try { parsed = JSON.parse(body); } catch { return jsonReply(res, 400, { error: "Invalid JSON" }); } - if (!parsed.id) return jsonReply(res, 400, { error: "Missing id" }); - try { - await updateScheduleMeta(agentRoot, parsed.id, { enabled: parsed.enabled }); - await reloadSchedules(schedulerOpts); - jsonReply(res, 200, { ok: true }); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/schedules/run" && req.method === "POST") { - const body = await readBody(req); - let parsed: { id: string }; - try { parsed = JSON.parse(body); } catch { return jsonReply(res, 400, { error: "Invalid JSON" }); } - if (!parsed.id) return jsonReply(res, 400, { error: "Missing id" }); - try { - const schedules = await discoverSchedules(agentRoot); - const schedule = schedules.find((s) => s.id === parsed.id); - if (!schedule) return jsonReply(res, 404, { error: "Schedule not found" }); - jsonReply(res, 200, { ok: true, message: "Job triggered" }); - executeScheduledJob(schedule, schedulerOpts); - } catch (err: any) { - jsonReply(res, 500, { error: err.message }); - } - - } else if (url.pathname === "/api/schedules/logs" && req.method === "GET") { - const id = url.searchParams.get("id"); - if (!id) return jsonReply(res, 400, { error: "Missing id param" }); - try { - const logFile = join(agentRoot, ".gitagent", "schedule-logs", `${id}.jsonl`); - const raw = readFileSync(logFile, "utf-8"); - const lines = raw.trim().split("\n").filter(Boolean); - const entries = lines.slice(-50).map((l) => { try { return JSON.parse(l); } catch { return null; } }).filter(Boolean); - jsonReply(res, 200, { entries }); - } catch { - jsonReply(res, 200, { entries: [] }); - } - - // ── Logs API ──────────────────────────────────────────────────── - } else if (url.pathname === "/api/logs" && req.method === "GET") { - const sinceParam = url.searchParams.get("since"); - const sourceFilter = url.searchParams.get("source") || ""; - const levelFilter = url.searchParams.get("level") || ""; - const searchFilter = (url.searchParams.get("q") || "").toLowerCase(); - let entries = sinceParam ? logBuffer.since(parseInt(sinceParam, 10)) : logBuffer.all(); - if (sourceFilter) entries = entries.filter(e => e.source === sourceFilter); - if (levelFilter) entries = entries.filter(e => e.level === levelFilter); - if (searchFilter) entries = entries.filter(e => e.message.toLowerCase().includes(searchFilter)); - jsonReply(res, 200, { entries }); - - // ── Skills Marketplace proxy ──────────────────────────────────── - } else if (url.pathname === "/api/skills-mp/proxy" && req.method === "GET") { - const proxyPath = url.searchParams.get("path") || "/"; - // Forward all query params except "path" to skills.sh - const forwardParams = new URLSearchParams(url.searchParams); - forwardParams.delete("path"); - const qs = forwardParams.toString(); - const targetUrl = `https://skills.sh${proxyPath.startsWith("/") ? proxyPath : "/" + proxyPath}${qs ? (proxyPath.includes("?") ? "&" : "?") + qs : ""}`; - - try { - const proxyRes = await fetch(targetUrl, { - headers: { - "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36", - "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8", - }, - redirect: "follow", - }); - - const contentType = proxyRes.headers.get("content-type") || ""; - - // Non-HTML resources: pass through directly - if (!contentType.includes("text/html")) { - const buffer = Buffer.from(await proxyRes.arrayBuffer()); - res.writeHead(proxyRes.status, { - "Content-Type": contentType, - "Cache-Control": proxyRes.headers.get("cache-control") || "public, max-age=3600", - "Access-Control-Allow-Origin": "*", - }); - res.end(buffer); - return; - } - - let html = await proxyRes.text(); - - // Rewrite relative src/href to absolute skills.sh URLs so assets load correctly - // (Do NOT rewrite href for navigation links — that breaks React hydration. - // Navigation is handled by client-side click/history interception instead.) - html = html.replace(/src="\/(?!\/)/g, 'src="https://skills.sh/'); - html = html.replace(/src='\/(?!\/)/g, "src='https://skills.sh/"); - // Rewrite stylesheet/preload hrefs to load from skills.sh - html = html.replace(/href="\/_(next|static)\//g, 'href="https://skills.sh/_$1/'); - html = html.replace(/href='\/_(next|static)\//g, "href='https://skills.sh/_$1/"); - - // Inject our custom script beforeCould not reach skills.sh: ${err.message}
-