Use prisma planetscale adapter

app/package.json

@@ -16,11 +16,11 @@
   "dependencies": {
     "@aws-sdk/client-s3": "^3.19.0",
     "@aws-sdk/s3-request-presigner": "^3.19.0",
-    "@prisma/client": "^5.4.0",
+    "@prisma/client": "^5.11.0",
     "@types/react": "^18.2.39",
     "@types/react-dom": "^18.2.0",
     "aws-sdk": "^2.935.0",
-    "prisma": "^5.4.0",
+    "prisma": "^5.11.0",
     "stripe": "^11.4.0"
   },
   "devDependencies": {

functions/stripe/stripe.ts

@@ -9,6 +9,7 @@ import {
   PaymentStatus,
   SUBSCRIPTION_LEVELS,
 } from '~/global/subscriptions.ts';
+import {createEdgeDatabaseConnection} from '~/global/database.ts';
 
 import type {Email, EmailType, PropsForEmail} from '../email/index.tsx';
 
@@ -81,18 +82,7 @@ router.post('internal/stripe/webhooks', async (request, {env}) => {
 
   console.log(event);
 
-  const [{PrismaClient}, {withAccelerate}] = await Promise.all([
-    import('@prisma/client/edge'),
-    import('@prisma/extension-accelerate'),
-  ]);
-
-  const prisma = new PrismaClient({
-    datasources: {
-      db: {
-        url: env.DATABASE_URL,
-      },
-    },
-  }).$extends(withAccelerate());
+  const prisma = await createEdgeDatabaseConnection({url: env.DATABASE_URL});
 
   try {
     // @see https://stripe.com/docs/webhooks/stripe-events

functions/tmdb-refresher-scheduler/tmdb-refresher-scheduler.ts

@@ -3,6 +3,8 @@ import {
   type ExportedHandlerScheduledHandler,
 } from '@cloudflare/workers-types';
 
+import {createEdgeDatabaseConnection} from '~/global/database.ts';
+
 import {type Message} from '../tmdb-refresher/tmdb-refresher.ts';
 
 interface Environment {
@@ -12,21 +14,10 @@ interface Environment {
 
 const scheduled: ExportedHandlerScheduledHandler<Environment> =
   async function scheduled(event, env) {
-    const [{PrismaClient}, {withAccelerate}] = await Promise.all([
-      import('@prisma/client/edge'),
-      import('@prisma/extension-accelerate'),
-    ]);
-
-    const prisma = new PrismaClient({
-      datasources: {
-        db: {
-          url: env.DATABASE_URL,
-        },
-      },
-    }).$extends(withAccelerate());
-
     console.log(event);
 
+    const prisma = await createEdgeDatabaseConnection({url: env.DATABASE_URL});
+
     const series = await prisma.series.findMany({
       where: {status: 'RETURNING'},
     });

functions/tmdb-refresher-scheduler/tsconfig.json

@@ -3,6 +3,7 @@
   "compilerOptions": {
     "outDir": "build/typescript",
     "paths": {
+      "~/global/*": ["../../global/*"],
       "~/shared/*": ["../shared/*"]
     }
   },

functions/tmdb-refresher/tmdb-refresher.ts

@@ -3,6 +3,7 @@ import {Buffer} from 'buffer-polyfill';
 import type {ExportedHandlerQueueHandler} from '@cloudflare/workers-types';
 
 import {updateSeries} from '~/global/tmdb.ts';
+import {createEdgeDatabaseConnection} from '~/global/database.ts';
 
 interface Environment {
   DATABASE_URL: string;
@@ -169,20 +170,6 @@ let prismaPromise:
   | undefined;
 
 async function createPrisma(url: string) {
-  prismaPromise ??= (async () => {
-    const [{PrismaClient}, {withAccelerate}] = await Promise.all([
-      import('@prisma/client/edge'),
-      import('@prisma/extension-accelerate'),
-    ]);
-
-    const prisma = new PrismaClient({
-      datasources: {
-        db: {url},
-      },
-    }).$extends(withAccelerate());
-
-    return prisma as any;
-  })();
-
+  prismaPromise ??= createEdgeDatabaseConnection({url});
   return await prismaPromise;
 }

global/database.ts

@@ -0,0 +1,23 @@
+export async function createEdgeDatabaseConnection({url}: {url: string}) {
+  const [{Client: PlanetScaleClient}, {PrismaClient}, {PrismaPlanetScale}] =
+    await Promise.all([
+      import('@planetscale/database'),
+      import('@prisma/client/edge'),
+      import('@prisma/adapter-planetscale'),
+    ]);
+
+  const client = new PlanetScaleClient({
+    url,
+    // @see https://github.com/cloudflare/workerd/issues/698
+    fetch(url, init) {
+      if (init) delete init['cache'];
+      return fetch(url, init);
+    },
+  });
+
+  const adapter = new PrismaPlanetScale(client);
+
+  const prisma = new PrismaClient({adapter});
+
+  return prisma;
+}

package.json

@@ -23,8 +23,9 @@
   "devDependencies": {
     "@changesets/changelog-github": "^0.4.3",
     "@changesets/cli": "^2.26.2",
-    "@prisma/client": "^5.4.0",
-    "@prisma/extension-accelerate": "^0.6.2",
+    "@planetscale/database": "^1.16.0",
+    "@prisma/client": "^5.11.0",
+    "@prisma/adapter-planetscale": "^5.11.0",
     "@quilted/browserslist-config": "^0.1.9",
     "@quilted/cloudflare": "^0.2.4",
     "@quilted/craft": "^0.2.5",
@@ -45,7 +46,7 @@
     "nodemon": "^2.0.0",
     "preact": "^10.19.2",
     "prettier": "^3.1.0",
-    "prisma": "^5.4.0",
+    "prisma": "^5.11.0",
     "react": "npm:@quilted/react@^18.2.0",
     "react-dom": "npm:@quilted/react-dom@^18.2.0",
     "rollup": "^4.6.0",
@@ -56,7 +57,7 @@
     "vitest": "^1.1.1",
     "wrangler": "^3.28.4"
   },
-  "packageManager": "pnpm@8.10.5+sha256.a4bd9bb7b48214bbfcd95f264bd75bb70d100e5d4b58808f5cd6ab40c6ac21c5",
+  "packageManager": "pnpm@8.15.4+sha256.cea6d0bdf2de3a0549582da3983c70c92ffc577ff4410cbf190817ddc35137c2",
   "prettier": "@quilted/prettier",
   "browserslist": [
     "defaults and not dead"

prisma/schema.prisma

@@ -9,6 +9,7 @@ datasource db {
 
 generator client {
   provider = "prisma-client-js"
+  previewFeatures = ["driverAdapters"]
 }
 
 enum SpoilerAvoidance {

tsconfig.json

@@ -1,10 +1,6 @@
 {
   "extends": "@quilted/typescript/workspace.json",
-  "include": [
-    "configuration/**/*.ts",
-    "scripts/**/*.ts",
-    "graphql.config.ts"
-  ],
+  "include": ["configuration/**/*.ts", "scripts/**/*.ts", "graphql.config.ts"],
   "compilerOptions": {
     "outDir": "build/typescript/workspace",
     "module": "ESNext",