ff64056
@@ -0,0 +1,156 @@
/**
 * The cost line on /apps (#6874): today's dollars across only the apps the
 * viewer can write, how many sit paused at their ceiling, and nothing — no
 * sentence, no figure — for a guest or a reader who writes no app. Runs are
 * created now, so "today" holds without the test reading the clock itself.
 */
import { afterAll, beforeAll, describe, expect, test } from "bun:test";
import { mkdtemp, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { enableApp } from "../src/actions/apps.ts";
import { addToCrew, createAgent } from "../src/actions/crew.ts";
import {
  commitToBranch,
  createRepo,
  updateRepoSettings,
} from "../src/actions/repos.ts";
import { claimRun, createRun, noteRunProgress } from "../src/core/runs.ts";
import { createUser, getUserByName, type User } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { promote } from "./helpers/members.ts";
describe("the cost line on /apps", () => {
  let dataDir: string;
  let app: App;
  let servers: Servers;
  let base: string;
  const cookies: Record<string, string> = {};
  const person = async (username: string, adminIfFirst = false): Promise<User> => {
    const u = await createUser(app.db, {
      origin: "seed",
      trusted: true,
      username,
      email: `${username}@forge.local`,
      password: "a-good-passphrase",
      ...(adminIfFirst ? { adminIfFirst } : {}),
    });
    if (!u.ok) throw new Error(u.error);
    promote(app.db, u.value);
    cookies[username] = (
      (
        await fetch(`${base}/signin`, {
          method: "POST",
          body: new URLSearchParams({ username, password: "a-good-passphrase" }),
          redirect: "manual",
        })
      ).headers.get("set-cookie") ?? ""
    ).split(";")[0]!;
    return u.value;
  };
  /** A public app owned by `owner` (the admin makes its agent), with one crew run costing `cost` today;
   * `ceiling` turns autonomy on with that daily ceiling. */
  const appWithSpend = async (
    admin: User,
    owner: User,
    name: string,
    cost: number,
    ceiling?: number,
  ) => {
    const made = await createRepo(app, owner, {
      name,
      visibility: "public",
      description: `${name} app`,
    });
    if (!made.ok) throw new Error(String(made.error));
    const repo = made.value;
    const seeded = await commitToBranch(app, owner, repo, {
      message: "Start",
      files: [{ path: "README.md", content: `${name}\n` }],
    });
    if (!seeded.ok) throw new Error(JSON.stringify(seeded.error));
    const enabled = await enableApp(app, owner, repo, { slug: name });
    if (!enabled.ok) throw new Error(String(enabled.error));
    const agent = `${name}-bot`;
    const created = await createAgent(app, admin, { username: agent });
    if (!created.ok) throw new Error(String(created.error));
    expect(addToCrew(app, owner, repo, agent).ok).toBe(true);
    if (ceiling !== undefined) {
      const on = await updateRepoSettings(app, owner, repo, {
        autonomy: "assisted",
        autonomyDirection: "",
        autonomyCeilingUsd: ceiling,
        autonomySlots: 2,
        autonomyBy: owner.id,
      });
      expect(on.ok).toBe(true);
    }
    const run = createRun(app.db, {
      repoId: repo.id,
      kind: "agent",
      actorId: getUserByName(app.db, agent)!.id,
      reason: "assigned",
    });
    claimRun(app.db, run.id);
    noteRunProgress(app.db, run.id, { costUsd: cost });
  };
  const apps = (cookie?: string) =>
    fetch(`${base}/apps`, {
      headers: cookie ? { cookie: `${cookie}; forge_mode=studio` } : {},
      redirect: "manual",
    }).then((r) => r.text());
  beforeAll(async () => {
    dataDir = await mkdtemp(join(tmpdir(), "forge-apps-cost-line-"));
    app = createApp({ dataDir, port: 0 });
    servers = await serve(app);
    base = servers.url;
    const boss = await person("boss", true); // an admin writes every app: only makes agents
    const alice = await person("alice");
    const dave = await person("dave");
    await person("carol"); // writes no app
    await appWithSpend(boss, alice, "beacon", 6, 5); // paused: $6 >= $5
    await appWithSpend(boss, alice, "loom", 2); // no autonomy: never paused
    await appWithSpend(boss, dave, "other", 3.5); // alice cannot write it
  });
  afterAll(async () => {
    servers.stop();
    app.close();
    await rm(dataDir, { recursive: true, force: true });
  });
  test("the owner reads the sum of only their own two apps and the one paused", async () => {
    const text = (await apps(cookies.alice)).replace(/\s+/g, " ");
    expect(text).toContain(
      "$8.00 spent today across 2 apps you can write · 1 paused at <a href=\"/board\">their ceiling</a>",
    );
    expect(text).not.toContain("$11.50");
  });
  test("a guest and a reader who writes no app see no cost line and no dollars", async () => {
    for (const html of [await apps(), await apps(cookies.carol)]) {
      expect(html).not.toContain("spent today");
      expect(html).not.toContain("studio-cost");
      expect(html).not.toMatch(/\$\d/);
    }
  });
  test("one app reads '1 app', and the ceiling link answers the owner 200", async () => {
    const html = (await apps(cookies.dave)).replace(/\s+/g, " ");
    expect(html).toContain("$3.50 spent today across 1 app you can write · 0 paused");
    expect(html).not.toContain("1 apps");
    const href = /<a href="([^"]+)">their ceiling<\/a>/.exec(html)?.[1];
    expect(href).toBe("/board");
    const res = await fetch(`${base}${href}`, {
      headers: { cookie: `${cookies.dave}; forge_mode=studio` },
      redirect: "manual",
    });
    expect(res.status).toBe(200);
  });
});
		@@ -0,0 +1,156 @@
	1	/**
	2	* The cost line on /apps (#6874): today's dollars across only the apps the
	3	* viewer can write, how many sit paused at their ceiling, and nothing — no
	4	* sentence, no figure — for a guest or a reader who writes no app. Runs are
	5	* created now, so "today" holds without the test reading the clock itself.
	6	*/
	7
	8	import { afterAll, beforeAll, describe, expect, test } from "bun:test";
	9	import { mkdtemp, rm } from "node:fs/promises";
	10	import { tmpdir } from "node:os";
	11	import { join } from "node:path";
	12	import { createApp, type App } from "../src/app.ts";
	13	import { enableApp } from "../src/actions/apps.ts";
	14	import { addToCrew, createAgent } from "../src/actions/crew.ts";
	15	import {
	16	commitToBranch,
	17	createRepo,
	18	updateRepoSettings,
	19	} from "../src/actions/repos.ts";
	20	import { claimRun, createRun, noteRunProgress } from "../src/core/runs.ts";
	21	import { createUser, getUserByName, type User } from "../src/core/users.ts";
	22	import { serve, type Servers } from "../src/http/server.ts";
	23	import { promote } from "./helpers/members.ts";
	24
	25	describe("the cost line on /apps", () => {
	26	let dataDir: string;
	27	let app: App;
	28	let servers: Servers;
	29	let base: string;
	30	const cookies: Record<string, string> = {};
	31
	32	const person = async (username: string, adminIfFirst = false): Promise<User> => {
	33	const u = await createUser(app.db, {
	34	origin: "seed",
	35	trusted: true,
	36	username,
	37	email: `${username}@forge.local`,
	38	password: "a-good-passphrase",
	39	...(adminIfFirst ? { adminIfFirst } : {}),
	40	});
	41	if (!u.ok) throw new Error(u.error);
	42	promote(app.db, u.value);
	43	cookies[username] = (
	44	(
	45	await fetch(`${base}/signin`, {
	46	method: "POST",
	47	body: new URLSearchParams({ username, password: "a-good-passphrase" }),
	48	redirect: "manual",
	49	})
	50	).headers.get("set-cookie") ?? ""
	51	).split(";")[0]!;
	52	return u.value;
	53	};
	54
	55	/** A public app owned by `owner` (the admin makes its agent), with one crew run costing `cost` today;
	56	* `ceiling` turns autonomy on with that daily ceiling. */
	57	const appWithSpend = async (
	58	admin: User,
	59	owner: User,
	60	name: string,
	61	cost: number,
	62	ceiling?: number,
	63	) => {
	64	const made = await createRepo(app, owner, {
	65	name,
	66	visibility: "public",
	67	description: `${name} app`,
	68	});
	69	if (!made.ok) throw new Error(String(made.error));
	70	const repo = made.value;
	71	const seeded = await commitToBranch(app, owner, repo, {
	72	message: "Start",
	73	files: [{ path: "README.md", content: `${name}\n` }],
	74	});
	75	if (!seeded.ok) throw new Error(JSON.stringify(seeded.error));
	76	const enabled = await enableApp(app, owner, repo, { slug: name });
	77	if (!enabled.ok) throw new Error(String(enabled.error));
	78	const agent = `${name}-bot`;
	79	const created = await createAgent(app, admin, { username: agent });
	80	if (!created.ok) throw new Error(String(created.error));
	81	expect(addToCrew(app, owner, repo, agent).ok).toBe(true);
	82	if (ceiling !== undefined) {
	83	const on = await updateRepoSettings(app, owner, repo, {
	84	autonomy: "assisted",
	85	autonomyDirection: "",
	86	autonomyCeilingUsd: ceiling,
	87	autonomySlots: 2,
	88	autonomyBy: owner.id,
	89	});
	90	expect(on.ok).toBe(true);
	91	}
	92	const run = createRun(app.db, {
	93	repoId: repo.id,
	94	kind: "agent",
	95	actorId: getUserByName(app.db, agent)!.id,
	96	reason: "assigned",
	97	});
	98	claimRun(app.db, run.id);
	99	noteRunProgress(app.db, run.id, { costUsd: cost });
	100	};
	101
	102	const apps = (cookie?: string) =>
	103	fetch(`${base}/apps`, {
	104	headers: cookie ? { cookie: `${cookie}; forge_mode=studio` } : {},
	105	redirect: "manual",
	106	}).then((r) => r.text());
	107
	108	beforeAll(async () => {
	109	dataDir = await mkdtemp(join(tmpdir(), "forge-apps-cost-line-"));
	110	app = createApp({ dataDir, port: 0 });
	111	servers = await serve(app);
	112	base = servers.url;
	113	const boss = await person("boss", true); // an admin writes every app: only makes agents
	114	const alice = await person("alice");
	115	const dave = await person("dave");
	116	await person("carol"); // writes no app
	117	await appWithSpend(boss, alice, "beacon", 6, 5); // paused: $6 >= $5
	118	await appWithSpend(boss, alice, "loom", 2); // no autonomy: never paused
	119	await appWithSpend(boss, dave, "other", 3.5); // alice cannot write it
	120	});
	121
	122	afterAll(async () => {
	123	servers.stop();
	124	app.close();
	125	await rm(dataDir, { recursive: true, force: true });
	126	});
	127
	128	test("the owner reads the sum of only their own two apps and the one paused", async () => {
	129	const text = (await apps(cookies.alice)).replace(/\s+/g, " ");
	130	expect(text).toContain(
	131	"$8.00 spent today across 2 apps you can write · 1 paused at <a href=\"/board\">their ceiling</a>",
	132	);
	133	expect(text).not.toContain("$11.50");
	134	});
	135
	136	test("a guest and a reader who writes no app see no cost line and no dollars", async () => {
	137	for (const html of [await apps(), await apps(cookies.carol)]) {
	138	expect(html).not.toContain("spent today");
	139	expect(html).not.toContain("studio-cost");
	140	expect(html).not.toMatch(/\$\d/);
	141	}
	142	});
	143
	144	test("one app reads '1 app', and the ceiling link answers the owner 200", async () => {
	145	const html = (await apps(cookies.dave)).replace(/\s+/g, " ");
	146	expect(html).toContain("$3.50 spent today across 1 app you can write · 0 paused");
	147	expect(html).not.toContain("1 apps");
	148	const href = /<a href="([^"]+)">their ceiling<\/a>/.exec(html)?.[1];
	149	expect(href).toBe("/board");
	150	const res = await fetch(`${base}${href}`, {
	151	headers: { cookie: `${cookies.dave}; forge_mode=studio` },
	152	redirect: "manual",
	153	});
	154	expect(res.status).toBe(200);
	155	});
	156	});