Add getD1Database(dbName) using getPlatformProxy

jplhomer · Jul 25, 2024 · fe766b9 · fe766b9
1 parent 9889492
commit fe766b9
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/packages/superflare/cli/d1-database.ts b/packages/superflare/cli/d1-database.ts
@@ -12,3 +12,13 @@ export async function createD1Database(
   const db = new D1Database(new D1DatabaseAPI(sqliteDb));
   return db as any as D1DatabaseType;
 }
+
+export async function getD1Database(dbName: string, logger = console.log) {
+  const { npxImport } = await import("npx-import");
+  const { getPlatformProxy } = await npxImport<typeof import("wrangler")>(
+    "wrangler",
+    logger
+  );
+  const { env } = await getPlatformProxy({ experimentalJsonConfig: true });
+  return env[dbName] as D1DatabaseType | undefined;
+}