Miguel PalhasandClaude Opus 5
02356f84ab
ci / rust (pull_request) Successful in 3m0s
The CLI, TUI and end-to-end harness each carried their own client: three reqwest builders with three timeout policies, three copies of the success-or-body check, and route strings at every call site. Two of them discarded the daemon's structured error and reported only a status code. Deletes `maestro-cli/src/http.rs`, both `ws_base` copies in the TUI, the CLI's partial `DaemonInfo` (it dropped `version` and `presets`), and the e2e harness's `check_ok`. `maestro-web` gains a protocol dependency and stops building the error envelope with a format string and reading it back as untyped JSON; the daemon and the proxy now register routes from the same constants. `maestro_web::router` returns `Result` — an unusable daemon URL fails at startup instead of at first connect. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
79 lines
2.5 KiB
TypeScript
79 lines
2.5 KiB
TypeScript
import * as routes from "./routes.js";
|
|
import type {
|
|
ApiError,
|
|
CreateSessionRequest,
|
|
DaemonInfo,
|
|
DirListing,
|
|
GitRoot,
|
|
RecentDirs,
|
|
Session,
|
|
Uuid,
|
|
} from "./types.js";
|
|
|
|
async function jsonOrError<T>(res: Response): Promise<T> {
|
|
if (res.ok) {
|
|
if (res.status === 204) return undefined as unknown as T;
|
|
return (await res.json()) as T;
|
|
}
|
|
let detail = "";
|
|
try {
|
|
const body = (await res.json()) as ApiError;
|
|
detail = `${body.error.code}: ${body.error.message}`;
|
|
} catch {
|
|
detail = await res.text();
|
|
}
|
|
throw new Error(`${res.status} ${res.statusText}${detail ? ` — ${detail}` : ""}`);
|
|
}
|
|
|
|
export async function listSessions(): Promise<Session[]> {
|
|
return jsonOrError(await fetch(routes.SESSIONS, { credentials: "same-origin" }));
|
|
}
|
|
|
|
export async function createSession(req: CreateSessionRequest): Promise<Session> {
|
|
return jsonOrError(
|
|
await fetch(routes.SESSIONS, {
|
|
method: "POST",
|
|
credentials: "same-origin",
|
|
headers: { "content-type": "application/json" },
|
|
body: JSON.stringify(req),
|
|
}),
|
|
);
|
|
}
|
|
|
|
export async function killSession(id: Uuid): Promise<void> {
|
|
await jsonOrError(
|
|
await fetch(routes.session(id), {
|
|
method: "DELETE",
|
|
credentials: "same-origin",
|
|
}),
|
|
);
|
|
}
|
|
|
|
/** List one directory's immediate subdirectories (NAP-329). `path` may be empty,
|
|
* `~`, relative, or absolute — the daemon resolves it against its home dir. */
|
|
export async function listDir(path: string): Promise<DirListing> {
|
|
const url = routes.withPathQuery(routes.DIRS, path);
|
|
return jsonOrError(await fetch(url, { credentials: "same-origin" }));
|
|
}
|
|
|
|
/** Identity + spawn presets of the daemon this web app is connected to (#26). */
|
|
export async function getDaemonInfo(): Promise<DaemonInfo> {
|
|
return jsonOrError(await fetch(routes.INFO, { credentials: "same-origin" }));
|
|
}
|
|
|
|
/** Recently-used working dirs, newest-first and deduped by dir (#26). Drives the
|
|
* spawn form's recents picker. */
|
|
export async function recentDirs(): Promise<RecentDirs> {
|
|
return jsonOrError(await fetch(routes.RECENT_DIRS, { credentials: "same-origin" }));
|
|
}
|
|
|
|
/** Probe the enclosing git repo of `path` (#26). `root` is absent when the path
|
|
* isn't inside a repo. `path` may be `~`/relative/absolute; the daemon resolves
|
|
* it against its home dir. */
|
|
export async function gitRoot(path: string): Promise<GitRoot> {
|
|
const url = routes.withPathQuery(routes.GITROOT, path);
|
|
return jsonOrError(await fetch(url, { credentials: "same-origin" }));
|
|
}
|
|
|
|
export { eventsWsUrl } from "./routes.js";
|