Move FumaDB policy test into FumaDB package

Author: RhysSullivan

bun.lock

@@ -86,9 +86,11 @@
   },
   "devDependencies": {
     "@effect/vitest": "catalog:",
+    "@types/better-sqlite3": "^7.6.13",
     "@types/node": "catalog:",
     "@types/pg": "^8.20.0",
     "@types/semver": "^7.7.1",
+    "better-sqlite3": "^12.9.0",
     "tsup": "catalog:",
     "typescript": "catalog:",
     "vitest": "catalog:"

packages/core/fumadb/package.json

@@ -118,12 +118,12 @@ const v1 = schema({
   },
 });
 
-const policyDB = fumadb({
-  namespace: "policy_black_box",
+const tablePolicyDB = fumadb({
+  namespace: "table_policy_test",
   schemas: [v1],
 });
 
-type PolicyQuery = AbstractQuery<typeof v1>;
+type TablePolicyQuery = AbstractQuery<typeof v1>;
 
 const makeContext = (allowedTenantIds: readonly string[], marker: string): TenantPolicyContext => ({
   allowedTenantIds: new Set(allowedTenantIds),
@@ -136,22 +136,22 @@ const makeHarness = async () => {
   sqlite.pragma("foreign_keys = ON");
   const runtimeSchema = createDrizzleRuntimeSchemaFromTables({
     tables: v1.tables,
-    namespace: "policy_black_box",
+    namespace: "table_policy_test",
     version: "1.0.0",
     provider: "sqlite",
   });
   const drizzleDb = drizzle(sqlite, { schema: runtimeSchema });
 
   for (const statement of createDrizzleRuntimeSchemaSqlFromTables({
     tables: v1.tables,
-    namespace: "policy_black_box",
+    namespace: "table_policy_test",
     version: "1.0.0",
     provider: "sqlite",
   })) {
     sqlite.exec(statement);
   }
 
-  const client = policyDB.client(
+  const client = tablePolicyDB.client(
     drizzleAdapter({
       db: drizzleDb,
       provider: "sqlite",
@@ -166,14 +166,14 @@ const makeHarness = async () => {
   };
 };
 
-const useHarness = <A>(run: (orm: PolicyQuery) => Promise<A>) =>
+const useHarness = <A>(run: (orm: TablePolicyQuery) => Promise<A>) =>
   Effect.acquireUseRelease(
     Effect.promise(makeHarness),
     ({ orm }) => Effect.promise(() => run(orm)),
     ({ close }) => Effect.promise(close),
   );
 
-const seedTenants = async (orm: PolicyQuery) => {
+const seedTenants = async (orm: TablePolicyQuery) => {
   const seed = withQueryContext(orm, makeContext(["tenant-a", "tenant-b"], "seed"));
 
   await seed.createMany("authors", [

…e/sdk/src/fumadb-policy-blackbox.test.ts …re/fumadb/src/query/table-policy.test.tspackages/core/sdk/src/fumadb-policy-blackbox.test.ts renamed to packages/core/fumadb/src/query/table-policy.test.ts packages/core/sdk/src/fumadb-policy-blackbox.test.ts renamed to packages/core/fumadb/src/query/table-policy.test.ts

@@ -1,5 +1,17 @@
+import * as fs from "node:fs";
+import * as path from "node:path";
 import { afterAll } from "vitest";
-import { cleanupFiles } from "./shared";
+
+const sqlitePath = path.join(
+  import.meta.dirname,
+  "../node_modules/sqlite.sqlite",
+);
+const prismaDir = path.join(import.meta.dirname, "./prisma");
+
+const cleanupFiles = () => {
+  fs.rmSync(sqlitePath, { force: true });
+  fs.rmSync(prismaDir, { recursive: true, force: true });
+};
 
 afterAll(() => {
   cleanupFiles();