chore: migrate Prisma to v7

Author: giovannibaratta

app/external/src/database/database-client.ts

@@ -1,16 +1,15 @@
 import {Injectable, OnModuleInit} from "@nestjs/common"
 import {PrismaClient} from "@prisma/client"
 import {ConfigProvider} from "../config"
+import {PrismaPg} from "@prisma/adapter-pg"
 
 @Injectable()
 export class DatabaseClient extends PrismaClient implements OnModuleInit {
   constructor(readonly config: ConfigProvider) {
     super({
-      datasources: {
-        db: {
-          url: config.dbConnectionUrl
-        }
-      }
+      adapter: new PrismaPg({
+        connectionString: config.dbConnectionUrl
+      })
     })
   }
 

app/external/src/database/errors.ts

@@ -1,36 +1,56 @@
 import {Prisma} from "@prisma/client"
+import {DriverAdapterError, isDriverAdapterError} from "@prisma/driver-adapter-utils"
+
+// Reference for error structure https://github.com/prisma/prisma/blob/7.2.0/packages/driver-adapter-utils/src/types.ts
+//
+// The cause of the DriverAdapterError is a discriminated union of types that can be narrowed down
+// to extract the specific error details.
+
+/**
+ * Helper to safely extract driver-specific details from the adapter error.
+ */
+function getDriverAdapterError(error: Prisma.PrismaClientKnownRequestError): DriverAdapterError | undefined {
+  const adapterError = error.meta?.driverAdapterError
+  if (adapterError && isDriverAdapterError(adapterError)) return adapterError
+  return undefined
+}
 
 export function isPrismaUniqueConstraintError(error: unknown, fields: string[]): boolean {
-  const uniqueFields = new Set(fields)
+  if (!(error instanceof Prisma.PrismaClientKnownRequestError) || error.code !== "P2002") return false
+
+  const adapterError = getDriverAdapterError(error)
+  if (!adapterError) return false
 
-  if (uniqueFields.size !== fields.length) throw new Error("Fields array contains duplicates")
-  if (!(error instanceof Prisma.PrismaClientKnownRequestError)) return false
-  if (error.code !== "P2002" || !Array.isArray(error.meta?.target)) return false
+  const cause = adapterError.cause
+  if (cause.kind !== "UniqueConstraintViolation") return false
 
-  const violatedFields = error.meta.target as string[]
+  const violatedFields = cause.constraint && "fields" in cause.constraint ? cause.constraint.fields : []
   return fields.length === violatedFields.length && fields.every(field => violatedFields.includes(field))
 }
 
-export function isPrismaForeignKeyConstraintError(error: unknown, constraint: string): boolean {
-  if (!(error instanceof Prisma.PrismaClientKnownRequestError)) return false
-  if (error.code !== "P2003" || !error.meta?.constraint) return false
+export function isPrismaForeignKeyConstraintError(error: unknown, constraintName: string): boolean {
+  if (!(error instanceof Prisma.PrismaClientKnownRequestError) || error.code !== "P2003") return false
 
-  const violatedField = error.meta.constraint as string
-  return constraint === violatedField
-}
+  const adapterError = getDriverAdapterError(error)
+  if (!adapterError) return false
 
-export function isPrismaRecordNotFoundError(error: unknown, modelName: Prisma.ModelName): boolean {
-  if (!(error instanceof Prisma.PrismaClientKnownRequestError)) return false
-  if (error.code !== "P2025" || !error.meta?.modelName) return false
+  const cause = adapterError.cause
+  if (cause.kind !== "ForeignKeyConstraintViolation") return false
 
-  const violatedModel = error.meta.modelName as string
-  return modelName === violatedModel
+  return cause.constraint !== undefined && "index" in cause.constraint && cause.constraint.index === constraintName
 }
 
-export function isPrismaCheckConstraintError(error: unknown, constraint: string): boolean {
-  if (!(error instanceof Prisma.PrismaClientKnownRequestError)) return false
-  if (error.code !== "P2004" || !error.meta?.constraint) return false
+export function isPrismaRecordNotFoundError(error: unknown, modelName: Prisma.ModelName): boolean {
+  if (!(error instanceof Prisma.PrismaClientKnownRequestError) || error.code !== "P2025") return false
+
+  /**
+   * P2025 "Record not found" is slightly different. Usually, the DB doesn't throw
+   * an error for a missing record (it just returns 0 rows), so Prisma's engine
+   * generates this error.
+   *
+   * Based on your captured debug log, 'modelName' is at the root of 'meta'.
+   */
+  const violatedModel = error.meta?.modelName as string | undefined
 
-  const violatedConstraint = error.meta.constraint as string
-  return constraint === violatedConstraint
+  return modelName === violatedModel
 }

app/external/src/database/vote.repository.ts

@@ -8,7 +8,7 @@ import {TaskEither} from "fp-ts/TaskEither"
 import {none, Option, some} from "fp-ts/lib/Option"
 import {pipe} from "fp-ts/lib/function"
 import {DatabaseClient} from "./database-client"
-import {isPrismaForeignKeyConstraintError, isPrismaCheckConstraintError} from "./errors"
+import {isPrismaForeignKeyConstraintError} from "./errors"
 import {traverseArray} from "fp-ts/lib/Either"
 
 @Injectable()
@@ -50,13 +50,7 @@ export class VoteDbRepository implements VoteRepository {
           if (isPrismaForeignKeyConstraintError(error, "fk_votes_workflow")) return "workflow_not_found"
           if (isPrismaForeignKeyConstraintError(error, "fk_votes_user")) return "voter_not_found"
           if (isPrismaForeignKeyConstraintError(error, "fk_votes_agent")) return "voter_not_found"
-          if (isPrismaCheckConstraintError(error, "chk_votes_single_voter")) {
-            Logger.error(
-              `Voter constraint violation for workflow ${vote.workflowId} and voter ${vote.voter.entityId}`,
-              error
-            )
-            return "unknown_error"
-          }
+
           Logger.error(
             `Error saving vote for workflow ${vote.workflowId} and voter ${getNormalizedEntityId(vote.voter)}`,
             error

app/test/database.ts

@@ -1,22 +1,19 @@
 import {PrismaClient} from "@prisma/client"
 import {randomUUID} from "crypto"
+import {PrismaPg} from "@prisma/adapter-pg"
 // eslint-disable-next-line node/no-unpublished-import
 import Redis from "ioredis"
 
 /** Create a duplicated database using the reference database as template
  * @returns the connection string to the new database
  */
 export async function prepareDatabase(): Promise<string> {
-  const referenceDb = process.env.DATABASE_URL
-  // Create a client connected to the reference database
-  const prismaClient = new PrismaClient({
-    datasources: {
-      db: {
-        url: referenceDb
-      }
-    }
+  const adapter = new PrismaPg({
+    connectionString: process.env.DATABASE_URL
   })
 
+  const prismaClient = new PrismaClient({adapter})
+
   // Generate a unique database name to isolate test runs
   const databaseName = `integration_test_${randomUUID().replace(/-/g, "")}`
 

package.json

@@ -20,7 +20,7 @@
     "liquibase:update:test": "docker run --network host --rm -v ./db-migrations:/liquibase/changelog liquibase/liquibase:4.31.1 --defaultsFile=/liquibase/changelog/integration-test.liquibase.docker.properties update",
     "lint": "yarn eslint --cache --fix .",
     "format:prettier": "yarn prettier --config .prettierrc . --write",
-    "prisma:pull": "yarn prisma db pull && prisma-case-format --file prisma/schema.prisma -p --table-case pascal,singular --field-case camel",
+    "prisma:pull": "yarn dotenv -e .env.local -- yarn prisma db pull && prisma-case-format --file prisma/schema.prisma -p --table-case pascal,singular --field-case camel",
     "prisma:generate": "yarn prisma generate",
     "build": "nest build backend && nest build worker",
     "start:worker": "dotenv -e .env.local -- nest start worker",
@@ -39,7 +39,9 @@
     "@nestjs/jwt": "11.0.2",
     "@nestjs/passport": "11.0.5",
     "@nestjs/platform-express": "11.1.9",
-    "@prisma/client": "6.19.1",
+    "@prisma/adapter-pg": "7.2.0",
+    "@prisma/client": "7.2.0",
+    "@prisma/driver-adapter-utils": "7.2.0",
     "axios": "1.13.2",
     "bull": "4.16.5",
     "class-transformer": "0.5.1",
@@ -81,7 +83,7 @@
     "node-loader": "^2.1.0",
     "prettier": "3.7.4",
     "pretty-format": "30.2.0",
-    "prisma": "6.19.1",
+    "prisma": "7.2.0",
     "prisma-case-format": "2.2.1",
     "rxjs": "7.8.2",
     "supertest": "7.1.4",

prisma.config.ts

@@ -0,0 +1,5 @@
+export default {
+  datasource: {
+    url: process.env.DATABASE_URL
+  }
+}

prisma/schema.prisma

@@ -5,7 +5,6 @@ generator client {
 
 datasource db {
   provider = "postgresql"
-  url      = "postgresql://developer:Safe1!@localhost:5432/approvio?schema=public"
 }
 
 model Databasechangelog {

scripts/testing/bootstrap-env.ts

@@ -7,6 +7,7 @@
 
 import axios, {AxiosInstance, isAxiosError} from "axios"
 import {PrismaClient} from "../../generated/prisma/client"
+import {PrismaPg} from "@prisma/adapter-pg"
 import * as crypto from "crypto"
 
 // Configuration
@@ -25,7 +26,11 @@ const VOTER_USER = {
   displayName: "Voter User"
 }
 
-const prisma = new PrismaClient()
+const prisma = new PrismaClient({
+  adapter: new PrismaPg({
+    connectionString: process.env.DATABASE_URL
+  })
+})
 
 // Helper Types
 interface Entity {