gitfor/platform

import { beforeEach, describe, expect, mock, test } from "bun:test";
import { Database } from "bun:sqlite";
import { readdirSync, readFileSync } from "node:fs";
import { join } from "node:path";
import type { ReporterKind } from "./abuse";

const published: string[] = [];
mock.module("cloudflare:workers", () => ({
  waitUntil: () => undefined,
  env: {
    PUBLIC_URL: "https://forge.example.com",
    SITES_DOMAIN: "sites.example.net",
    SECRETS_KEY: "test-secret",
    ABUSE_FORWARD_TO: "",
    KV: { put: async (key: string) => void published.push(key) },
  },
}));

const db = new Database(":memory:");
const migrations = join(import.meta.dir, "../../migrations");
for (const file of readdirSync(migrations).sort()) db.exec(readFileSync(join(migrations, file), "utf8"));

mock.module("./db", () => ({
  first: async (sql: string, ...params: unknown[]) => db.query(sql).get(...(params as never[])) ?? null,
  all: async (sql: string, ...params: unknown[]) => db.query(sql).all(...(params as never[])),
  run: async (sql: string, ...params: unknown[]) => ({
    meta: { changes: db.query(sql).run(...(params as never[])).changes },
  }),
}));
const notified: string[] = [];
mock.module("./account-disable-actions", () => ({
  notifyAdmins: async (title: string) => void notified.push(title),
}));
const invalidated: string[] = [];
mock.module("./user-inbox", () => ({ invalidateUnread: async (ids: string[]) => void invalidated.push(...ids) }));
mock.module("./events/emit", () => ({ publicUrl: (path: string) => `https://forge.example.com${path}` }));
mock.module("./pages/serve", () => ({ pagesRepoIdForUrl: async () => null }));
mock.module("./sites/deploy", () => ({
  loadSiteById: async (id: string) => db.query("SELECT * FROM sites WHERE id = ?").get(id) ?? null,
}));