Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788// Native notifications for the Aesel TUI, and its row in the AC network device// registry (POST /api/app-device).//// On macOS a finished turn, a failure or a waiting approval posts a native// notification, but only while the terminal running Aesel is not the frontmost// app. When the Aesel Mac app is running, the notification goes through it// (`aesel://notify`), so it carries Aesel's name and icon; otherwise it falls// back to `osascript`. Focus is read with `lsappinfo` and the process's parent// chain, so no Automation or Accessibility permission is needed.// AESEL_NOTIFY=0 turns notifications off.import { execFile } from "node:child_process";import { randomUUID } from "node:crypto";import { mkdirSync, readFileSync, writeFileSync } from "node:fs";import { arch, homedir, release } from "node:os";import { dirname, join } from "node:path";
// The released Mac app (release-mac.sh) and the App Store / Xcode build.const GUI_BUNDLES = ["computer.aesthetic.aesel.native", "computer.aesthetic.easel"];// Resolves stdout, or null when the command failed.const run = (file, args) => new Promise(resolve => execFile(file, args, { timeout: 3000 }, (error, stdout) => resolve(error ? null : String(stdout))));
async function ancestors(pid = process.pid) { const chain = new Set(); for (let i = 0; i < 24 && pid > 1; i++) { chain.add(pid); pid = Number((await run("/bin/ps", ["-o", "ppid=", "-p", String(pid)]) || "").trim()) || 0; } return chain;}
// True when the frontmost app is this process's terminal (one of its ancestors).export async function terminalFocused({ lsappinfo = run, chain = ancestors } = {}) { const front = (await lsappinfo("/usr/bin/lsappinfo", ["front"]) || "").trim(); if (!front) return false; const pid = Number((await lsappinfo("/usr/bin/lsappinfo", ["info", "-only", "pid", front]) || "").match(/(\d+)/)?.[1]); return Number.isInteger(pid) && (await chain()).has(pid);}
export function notifyURL({ title, body = "", kind = "done" }) { const query = new URLSearchParams({ title: title.slice(0, 120), body: body.slice(0, 240), kind, from: "tui" }); return `aesel://notify?${query}`;}
export async function notifyNative({ title, body = "", kind = "done" }, { platform = process.platform, env = process.env, exec = run } = {}) { if (platform !== "darwin" || env.AESEL_NOTIFY === "0") return "off"; if (await terminalFocused({ lsappinfo: exec })) return "focused"; const text = String(body).replace(/\s+/g, " ").trim(); // An older Aesel.app without the aesel:// scheme makes `open` fail; fall through. let running = false; for (const bundle of GUI_BUNDLES) if ((await exec("/usr/bin/lsappinfo", ["find", `bundleid=${bundle}`]) || "").trim()) { running = true; break; } if (running && await exec("/usr/bin/open", ["-g", notifyURL({ title, body: text, kind })]) !== null) return "aesel"; // argv, not string interpolation: titles and replies may contain quotes. await exec("/usr/bin/osascript", ["-e", "on run argv", "-e", "display notification (item 2 of argv) with title (item 1 of argv)", "-e", "end run", title, text.slice(0, 240)]); return "osascript";}
// One id per machine for the TUI, kept beside Aesel's other local state.function deviceId(home = homedir()) { const file = join(home, ".config", "aesel", "device-id"); try { return readFileSync(file, "utf8").trim(); } catch {} const id = randomUUID(); try { mkdirSync(dirname(file), { recursive: true }); writeFileSync(file, id, { mode: 0o600 }); } catch {} return id;}
const PLATFORMS = { darwin: "mac", linux: "linux", win32: "windows" };
export function deviceReport(event, { version, platform = process.platform } = {}) { return { app: "aesel", deviceId: deviceId(), event, platform: PLATFORMS[platform] || "linux", label: "Aesel TUI", os: `${platform} ${release()}`.slice(0, 40), model: arch(), ...(version && /^\d+(?:\.\d+){0,3}$/.test(version) ? { version } : {}), };}
// Best effort; a registry outage never touches the terminal.export async function reportDevice(event, { token, version, fetch = globalThis.fetch } = {}) { try { await fetch("https://aesthetic.computer/api/app-device", { method: "POST", signal: AbortSignal.timeout(8000), headers: { "Content-Type": "application/json", ...(token && event !== "logout" ? { Authorization: `Bearer ${token}` } : {}) }, body: JSON.stringify(deviceReport(event, { version })), }); } catch {}}