pg-adapter

Author: jrCleber

package.json

@@ -45,6 +45,7 @@
   "dependencies": {
     "@adiwajshing/keyed-db": "^0.2.4",
     "@hapi/boom": "^10.0.1",
+    "@prisma/adapter-pg": "^7.2.0",
     "@prisma/client": "^7.2.0",
     "@whiskeysockets/baileys": "7.0.0-rc.9",
     "axios": "^1.13.2",

src/repository/repository.service.ts

@@ -43,9 +43,14 @@ export class Query<T> {
 
 import { Prisma, PrismaClient, Webhook } from '@prisma/client';
 import { WebhookEvents } from '../whatsapp/dto/webhook.dto';
-import { BadRequestException, NotFoundException } from '../exceptions';
+import {
+  BadRequestException,
+  InternalServerErrorException,
+  NotFoundException,
+} from '../exceptions';
 import { Logger } from '../config/logger.config';
 import { ConfigService, Database } from '../config/env.config';
+import { PrismaPg } from '@prisma/adapter-pg';
 
 type CreateLogs = {
   context: string;
@@ -56,7 +61,16 @@ type CreateLogs = {
 
 export class Repository extends PrismaClient {
   constructor(private readonly configService: ConfigService) {
-    super();
+    super({
+      adapter: new PrismaPg(
+        { connectionString: process.env.DATABASE_URL },
+        {
+          onConnectionError(err) {
+            throw new InternalServerErrorException(err);
+          },
+        },
+      ),
+    });
   }
 
   private readonly logger = new Logger(this.configService, Repository.name);
@@ -94,7 +108,7 @@ export class Repository extends PrismaClient {
         }
 
         const k = `ARRAY['${key}']`;
-        const v = `to_jsonb(${value}::boolean)`;
+        const v = `to_jsonb(${value as string}::boolean)`;
 
         await this.$queryRaw(
           Prisma.sql`UPDATE "Webhook" SET events = jsonb_set(events, ${Prisma.raw(