chore(release): 1.6.6

- prisma/schema.prisma: tambah binaryTargets debian & linux-musl untuk Docker
- src/lib/prisma.ts: pakai global singleton di dev & prod, hapus eager $connect()
- src/lib/firebase-admin.ts: lazy initialization agar tidak crash saat build time
- .env.example: lengkap dengan semua env variable + connection_limit & pool_timeout

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

.env.example

@@ -0,0 +1,53 @@
+# ==============================
+# Database
+# ==============================
+# Tambahkan connection_limit dan pool_timeout untuk mencegah connection exhaustion
+DATABASE_URL="postgresql://user:password@localhost:5432/dbname?connection_limit=10&pool_timeout=20"
+
+# ==============================
+# Auth / Session
+# ==============================
+WIBU_PWD="your_wibu_password"
+NEXT_PUBLIC_BASE_TOKEN_KEY="your_token_key"
+NEXT_PUBLIC_BASE_SESSION_KEY="your_session_key"
+
+# ==============================
+# Payment Gateway (Midtrans)
+# ==============================
+Client_KEY="your_midtrans_client_key"
+Server_KEY="your_midtrans_server_key"
+
+# ==============================
+# Maps
+# ==============================
+MAPBOX_TOKEN="your_mapbox_token"
+
+# ==============================
+# Realtime (WebSocket)
+# ==============================
+WS_APIKEY="your_ws_api_key"
+NEXT_PUBLIC_WIBU_REALTIME_TOKEN="your_realtime_token"
+
+# ==============================
+# Email (Resend)
+# ==============================
+RESEND_APIKEY="your_resend_api_key"
+
+# ==============================
+# WhatsApp
+# ==============================
+WA_SERVER_TOKEN="your_wa_server_token"
+
+# ==============================
+# Firebase Admin (Push Notification)
+# ==============================
+FIREBASE_ADMIN_PROJECT_ID="your_firebase_project_id"
+FIREBASE_ADMIN_CLIENT_EMAIL="your_firebase_client_email@project.iam.gserviceaccount.com"
+# Private key: salin dari service account JSON, ganti newline dengan \n
+FIREBASE_ADMIN_PRIVATE_KEY="-----BEGIN PRIVATE KEY-----\nYOUR_PRIVATE_KEY_HERE\n-----END PRIVATE KEY-----\n"
+
+# ==============================
+# App
+# ==============================
+NEXT_PUBLIC_API_URL="http://localhost:3000"
+LOG_LEVEL="info"

CHANGELOG.md

@@ -2,6 +2,37 @@
 
 All notable changes to this project will be documented in this file. See [commit-and-tag-version](https://github.com/absolute-version/commit-and-tag-version) for commit guidelines.
 
+## [1.6.6](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.5...v1.6.6) (2026-03-03)
+
+
+### Bug Fixes
+
+* prisma connection exhaustion & firebase lazy init ([6dba07b](https://wibugit.wibudev.com/wibu/hipmi/commit/6dba07baac6a3ef7d264c13e378a905002401e1b))
+
+## [1.6.5](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.4...v1.6.5) (2026-03-03)
+
+
+### Bug Fixes
+
+* error koneksi Prisma - DATABASE_URL tidak loaded di ([a658881](https://wibugit.wibudev.com/wibu/hipmi/commit/a6588818b5d8018b3a634e0ae0846e309569d370))
+
+## [1.6.4](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.3...v1.6.4) (2026-03-03)
+
+## [1.6.3](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.2...v1.6.3) (2026-03-03)
+
+## [1.6.2](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.1...v1.6.2) (2026-02-25)
+
+## [1.6.1](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.0...v1.6.1) (2026-02-25)
+
+## [1.6.0](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.40...v1.6.0) (2026-02-23)
+
+
+### Features
+
+* Implementasi pagination pada endpoint mobile donation ([e89886e](https://wibugit.wibudev.com/wibu/hipmi/commit/e89886e1dbc8cb4d95e6cc7c2787fb22a1dcaf56))
+* Tambahkan pagination pada API mobile investasi ([a7694bd](https://wibugit.wibudev.com/wibu/hipmi/commit/a7694bd7d5d72b6499443faf99301faca730d3ed))
+* update mobile donation API and related dependencies ([934d6a3](https://wibugit.wibudev.com/wibu/hipmi/commit/934d6a3ef1015367bee85779796df4f11c5e779c))
+
 ## [1.5.40](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.39...v1.5.40) (2026-02-06)
 
 ## [1.5.39](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.38...v1.5.39) (2026-01-30)

PROMPT-AI.md

@@ -1,5 +1,5 @@
 
-File utama: src/app/api/mobile/admin/investment/[id]/investor/route.ts
+File utama: src/app/api/mobile/admin/forum/[id]/comment/route.ts
 
 Terapkan pagination pada file "File utama" pada method GET
 Analisa juga file "File utama", jika belum memiliki page dari seachParams maka terapkan. Juga pastikan take dan skip sudah sesuai dengan pagination. Buat default nya menjadi 10 untuk take data

next.config.js

@@ -3,12 +3,20 @@ const nextConfig = {
   reactStrictMode: false,
   experimental: {
     serverActions: true,
+    serverComponentsExternalPackages: ['@prisma/client'],
   },
   output: "standalone",
   staticPageGenerationTimeout: 180, // tingkatkan menjadi 3 menit
   eslint: {
     ignoreDuringBuilds: true,
   },
+  webpack: (config, { isServer }) => {
+    if (isServer) {
+      config.externals = config.externals || [];
+      config.externals.push('@prisma/client');
+    }
+    return config;
+  },
   // async headers() {
   //   return [
   //     {

package.json

@@ -1,15 +1,16 @@
 {
   "name": "hipmi",
-  "version": "1.5.40",
+  "version": "1.6.6",
   "private": true,
   "prisma": {
     "seed": "bun prisma/seed.ts"
   },
   "scripts": {
     "dev": "next dev --experimental-https",
-    "build": "next build",
-    "build:dev": "next build",
+    "build": "prisma generate && next build",
+    "build:dev": "prisma generate && next build",
     "start": "next start",
+    "postbuild": "node scripts/postbuild.js",
     "lint": "next lint",
     "ver": "bunx commit-and-tag-version -- --prerelease"
   },

prisma/schema.prisma

@@ -4,7 +4,7 @@
 generator client {
   provider      = "prisma-client-js"
   engineType    = "binary"
-  binaryTargets = ["native"]
+  binaryTargets = ["native", "debian-openssl-3.0.x", "linux-musl-openssl-3.0.x"]
 }
 
 datasource db {

scripts/postbuild.js

@@ -0,0 +1,60 @@
+const fs = require('fs');
+const path = require('path');
+
+const standaloneDir = path.join(__dirname, '../.next/standalone');
+const prismaDir = path.join(__dirname, '../node_modules/.prisma');
+
+console.log('🚀 Running postbuild script...');
+
+// Copy Prisma binaries ke standalone output
+if (fs.existsSync(prismaDir)) {
+  const dest = path.join(standaloneDir, 'node_modules/.prisma');
+  fs.mkdirSync(path.dirname(dest), { recursive: true });
+  fs.cpSync(prismaDir, dest, { recursive: true });
+  console.log('✓ Prisma binaries copied to standalone output');
+} else {
+  console.warn('⚠ Prisma binaries directory not found, skipping...');
+}
+
+// Copy schema.prisma jika diperlukan
+const schemaSrc = path.join(__dirname, '../prisma/schema.prisma');
+const schemaDest = path.join(standaloneDir, 'prisma/schema.prisma');
+if (fs.existsSync(schemaSrc)) {
+  fs.mkdirSync(path.dirname(schemaDest), { recursive: true });
+  fs.copyFileSync(schemaSrc, schemaDest);
+  console.log('✓ schema.prisma copied to standalone output');
+} else {
+  console.warn('⚠ schema.prisma not found, skipping...');
+}
+
+// Copy prisma client dari node_modules/@prisma/client
+const prismaClientSrc = path.join(__dirname, '../node_modules/@prisma/client');
+const prismaClientDest = path.join(standaloneDir, 'node_modules/@prisma/client');
+if (fs.existsSync(prismaClientSrc)) {
+  fs.mkdirSync(path.dirname(prismaClientDest), { recursive: true });
+  fs.cpSync(prismaClientSrc, prismaClientDest, { recursive: true });
+  console.log('✓ @prisma/client copied to standalone output');
+} else {
+  console.warn('⚠ @prisma/client not found, skipping...');
+}
+
+// Copy .env file jika ada (untuk production)
+const envSrc = path.join(__dirname, '../.env');
+const envDest = path.join(standaloneDir, '.env');
+if (fs.existsSync(envSrc)) {
+  fs.copyFileSync(envSrc, envDest);
+  console.log('✓ .env file copied to standalone output');
+} else {
+  console.warn('⚠ .env file not found, skipping...');
+  console.warn('  Pastikan DATABASE_URL di-set di system environment server!');
+}
+
+// Copy .env-local file jika ada (opsional)
+const envLocalSrc = path.join(__dirname, '../.env-local');
+const envLocalDest = path.join(standaloneDir, '.env-local');
+if (fs.existsSync(envLocalSrc)) {
+  fs.copyFileSync(envLocalSrc, envLocalDest);
+  console.log('✓ .env-local file copied to standalone output');
+}
+
+console.log('✅ Build script completed!');

src/app/api/auth/register/route.ts

@@ -14,8 +14,6 @@ export async function POST(req: Request) {
   try {
     const { data } = await req.json();
 
-    console.log("data >>", data);
-
     const cekUsername = await prisma.user.findUnique({
       where: {
         username: data.username,
@@ -29,12 +27,12 @@ export async function POST(req: Request) {
       });
 
     // ✅ Validasi wajib setuju Terms
-    if (data.termsOfServiceAccepted !== true) {
-      return NextResponse.json({
-        success: false,
-        message: "You must agree to the Terms of Service",
-      });
-    }
+    // if (data.termsOfServiceAccepted !== true) {
+    //   return NextResponse.json({
+    //     success: false,
+    //     message: "You must agree to the Terms of Service",
+    //   });
+    // }
 
     const createUser = await prisma.user.create({
       data: {

src/app/api/mobile/admin/forum/[id]/comment/route.ts

@@ -7,6 +7,7 @@ import {
   NotificationMobileTitleType,
 } from "../../../../../../../../types/type-mobile-notification";
 import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
+import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
 
 export { GET, PUT };
 
@@ -14,9 +15,9 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
   const { id } = params;
   const { searchParams } = new URL(request.url);
   const search = searchParams.get("search");
-  const page = searchParams.get("page");
-  const takeData = 10;
-  const skipData = Number(page) * takeData - takeData;
+  const page = Number(searchParams.get("page"));
+  const takeData = PAGINATION_DEFAULT_TAKE;
+  const skipData = page * takeData - takeData;
   const category = searchParams.get("category");
   let fixData;
   try {

src/app/api/mobile/admin/forum/[id]/report-posting/route.ts

@@ -1,15 +1,16 @@
 import { NextResponse } from "next/server";
 import { prisma } from "@/lib";
+import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
 
 export async function GET(
   request: Request,
-  { params }: { params: { id: string } }
+  { params }: { params: { id: string } },
 ) {
   const { id } = params;
   const { searchParams } = new URL(request.url);
   const search = searchParams.get("search");
   const page = searchParams.get("page");
-  const takeData = 10;
+  const takeData = PAGINATION_DEFAULT_TAKE;
   const skipData = Number(page) * takeData - takeData;
   let fixData;
 
@@ -60,7 +61,7 @@ export async function GET(
         message: "Success get list report posting",
         data: fixData,
       },
-      { status: 200 }
+      { status: 200 },
     );
   } catch (error) {
     console.error("[ERROR GET LIST REPORT POSTING]", error);
@@ -70,7 +71,7 @@ export async function GET(
         message: "Error get list report posting",
         reason: (error as Error).message,
       },
-      { status: 500 }
+      { status: 500 },
     );
   }
 }

src/app/api/mobile/admin/forum/route.ts

@@ -80,7 +80,11 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
           _count: {
             select: {
               Forum_ReportPosting: true,
-              Forum_Komentar: true,
+              Forum_Komentar: {
+                where: {
+                  isActive: true,
+                },
+              },
             },
           },
         },
@@ -140,6 +144,14 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
         },
       });
 
+      // Hitung count report untuk setiap Forum_Posting id
+      const countByPostingId = data.reduce((acc: any, item: any) => {
+        const key = item.Forum_Posting?.id;
+        if (!key) return acc;
+        acc[key] = (acc[key] || 0) + 1;
+        return acc;
+      }, {});
+
       const filterLatest = (data: any) =>
         Object.values(
           data.reduce((acc: any, item: any) => {
@@ -152,10 +164,16 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
               acc[key] = item;
             }
             return acc;
-          }, {})
+          }, {}),
         );
 
-      fixData = filterLatest(data);
+      const filteredData = filterLatest(data);
+
+      // Tambahkan count ke setiap item
+      fixData = filteredData.map((item: any) => ({
+        ...item,
+        count: countByPostingId[item.Forum_Posting?.id] || 0,
+      }));
     } else if (category === "report_comment") {
       const data = await prisma.forum_ReportKomentar.findMany({
         take: page ? takeData : undefined,
@@ -194,6 +212,14 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
         },
       });
 
+      // Hitung count report untuk setiap Forum_Komentar id
+      const countByKomentarId = data.reduce((acc: any, item: any) => {
+        const key = item.Forum_Komentar?.id;
+        if (!key) return acc;
+        acc[key] = (acc[key] || 0) + 1;
+        return acc;
+      }, {});
+
       const filterLatest = (data: any) =>
         Object.values(
           data.reduce((acc: any, item: any) => {
@@ -206,10 +232,16 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
               acc[key] = item;
             }
             return acc;
-          }, {})
+          }, {}),
         );
 
-      fixData = filterLatest(data);
+      const filteredData = filterLatest(data);
+
+      // Tambahkan count ke setiap item
+      fixData = filteredData.map((item: any) => ({
+        ...item,
+        count: countByKomentarId[item.Forum_Komentar?.id] || 0,
+      }));
     } else {
       return NextResponse.json(
         {
@@ -217,7 +249,7 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
           message: "Invalid category",
           reason: "Invalid category",
         },
-        { status: 400 }
+        { status: 400 },
       );
     }
 
@@ -227,7 +259,7 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
         message: `Success get data forum ${category}`,
         data: fixData,
       },
-      { status: 200 }
+      { status: 200 },
     );
   } catch (error) {
     return NextResponse.json(
@@ -236,7 +268,7 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
         message: `Error get data forum ${category}`,
         reason: (error as Error).message,
       },
-      { status: 500 }
+      { status: 500 },
     );
   }
 }

src/app/api/user-validate/route.ts

@@ -76,15 +76,27 @@ export async function GET(req: Request) {
       data: user,
     });
   } catch (error) {
-    console.error("Error in user validation:", error);
+    const errorMsg = error instanceof Error ? error.message : 'Unknown error';
+    const errorStack = error instanceof Error ? error.stack : 'No stack';
+    
+    // Log detailed error for debugging
+    console.error("❌ [USER-VALIDATE] Error:", errorMsg);
+    console.error("❌ [USER-VALIDATE] Stack:", errorStack);
+    console.error("❌ [USER-VALIDATE] Time:", new Date().toISOString());
+    
+    // Check if it's a database connection error
+    if (errorMsg.includes("Prisma") || errorMsg.includes("database") || errorMsg.includes("connection")) {
+      console.error("❌ [USER-VALIDATE] Database connection error detected!");
+      console.error("❌ [USER-VALIDATE] DATABASE_URL exists:", !!process.env.DATABASE_URL);
+    }
+    
     return NextResponse.json(
       {
         success: false,
         message: "Terjadi kesalahan pada server",
+        error: process.env.NODE_ENV === 'development' ? errorMsg : 'Internal server error',
       },
       { status: 500 }
     );
   }
-  // Removed prisma.$disconnect() from here to prevent connection pool exhaustion
-  // Prisma connections are handled globally and shouldn't be disconnected on each request
 }

src/app_modules/auth/login/view.tsx

@@ -28,13 +28,10 @@ export default function Login({ version }: { version: string }) {
   const [countryCode, setCountryCode] = useState<string>("62"); // default ke Indonesia
 
   async function onLogin() {
-    console.log("phone >>", phone);
-
     const nomor = phone;
     if (nomor.length <= 4) return setError(true);
 
     const fixPhone = `${countryCode}${nomor}`;
-    console.log("fixPhone >>", fixPhone);
 
     try {
       setLoading(true);
@@ -46,7 +43,6 @@ export default function Login({ version }: { version: string }) {
         router.push("/validasi", { scroll: false });
       } else {
         setLoading(false);
-        console.log("respone >>", respone);
         ComponentGlobal_NotifikasiPeringatan(respone?.message);
       }
     } catch (error) {
@@ -108,9 +104,6 @@ export default function Login({ version }: { version: string }) {
                 // Simpan hasil akhir
                 setCountryCode(dialCode);
                 setPhone(localNumber);
-
-                // console.log("Country Code:", dialCode);
-                // console.log("Clean Local Number:", localNumber);
               }}
             />
 

src/app_modules/waiting_room/view.tsx

@@ -25,15 +25,21 @@ export default function WaitingRoom_View({
   const [isLoadingHome, setIsLoadingHome] = useState(false);
 
   async function onClickLogout() {
-    setLoading(true);
-    const res = await fetch(`/api/auth/logout?id=${userLoginId}`, {
-      method: "GET",
-    });
+    try {
+      setLoading(true);
+      const res = await fetch(`/api/auth/logout?id=${userLoginId}`, {
+        method: "GET",
+      });
 
-    const result = await res.json();
-    if (res.status === 200) {
-      ComponentGlobal_NotifikasiBerhasil(result.message);
-      router.push("/", { scroll: false });
+      const result = await res.json();
+      if (res.status === 200) {
+        ComponentGlobal_NotifikasiBerhasil(result.message);
+        router.push("/", { scroll: false });
+      }
+    } catch (error) {
+      console.error("Error button to home", error);
+    } finally {
+      setLoading(false);
     }
   }
 
@@ -83,7 +89,8 @@ export default function WaitingRoom_View({
                   </Text>
                   <Text fw={"bold"} c={"white"} align="center">
                     Harap tunggu, Anda akan menerima pemberitahuan melalui
-                    Whatsapp setelah disetujui.
+                    Whatsapp setelah disetujui, untuk sementara anda bisa
+                    menunggu pada halaman ini atau keluar.
                   </Text>
                 </Stack>
                 {isAccess && (
@@ -110,6 +117,10 @@ export default function WaitingRoom_View({
                     Home
                   </Button>
                 )}
+
+                <Button color="red" loading={loading} onClick={onClickLogout}>
+                  Keluar
+                </Button>
               </Stack>
             )}
           </ComponentGlobal_CardStyles>

src/lib/firebase-admin.ts

@@ -1,24 +1,25 @@
 // lib/firebase-admin.ts
 import { cert, getApp, getApps, initializeApp } from 'firebase-admin/app';
-import { getMessaging } from 'firebase-admin/messaging';
+import { getMessaging, Messaging } from 'firebase-admin/messaging';
 
-// Ambil dari environment
-const serviceAccount = {
-  projectId: process.env.FIREBASE_ADMIN_PROJECT_ID,
-  clientEmail: process.env.FIREBASE_ADMIN_CLIENT_EMAIL,
-  privateKey: process.env.FIREBASE_ADMIN_PRIVATE_KEY?.replace(/\\n/g, '\n'),
-};
+function getAdminApp() {
+  if (getApps().length > 0) return getApp();
 
-if (!serviceAccount.projectId || !serviceAccount.clientEmail || !serviceAccount.privateKey) {
-  throw new Error('Firebase Admin credentials are missing in environment variables');
+  const privateKey = process.env.FIREBASE_ADMIN_PRIVATE_KEY?.replace(/\\n/g, '\n');
+  const projectId = process.env.FIREBASE_ADMIN_PROJECT_ID;
+  const clientEmail = process.env.FIREBASE_ADMIN_CLIENT_EMAIL;
+
+  if (!projectId || !clientEmail || !privateKey) {
+    throw new Error('Firebase Admin credentials are missing in environment variables');
+  }
+
+  return initializeApp({
+    credential: cert({ projectId, clientEmail, privateKey }),
+    projectId,
+  });
 }
 
-// Inisialisasi hanya sekali
-const app = !getApps().length
-  ? initializeApp({
-      credential: cert(serviceAccount),
-      projectId: serviceAccount.projectId,
-    })
-  : getApp();
-
-export const adminMessaging = getMessaging(app);
+export const adminMessaging: Pick<Messaging, 'send' | 'sendEachForMulticast'> = {
+  send: (message) => getMessaging(getAdminApp()).send(message),
+  sendEachForMulticast: (message) => getMessaging(getAdminApp()).sendEachForMulticast(message),
+};

src/lib/prisma-retry.ts

@@ -0,0 +1,188 @@
+import { prisma } from './prisma';
+
+/**
+ * Retry configuration for database operations
+ */
+interface RetryConfig {
+  maxRetries: number;
+  initialDelay: number;
+  maxDelay: number;
+  factor: number;
+}
+
+const DEFAULT_RETRY_CONFIG: RetryConfig = {
+  maxRetries: 3,
+  initialDelay: 100,
+  maxDelay: 5000,
+  factor: 2,
+};
+
+/**
+ * Check if error is retryable (transient error)
+ */
+function isRetryableError(error: any): boolean {
+  const errorMsg = error instanceof Error ? error.message : '';
+  
+  // Retry on connection-related errors
+  const retryablePatterns = [
+    'ECONNRESET',
+    'ECONNREFUSED',
+    'ETIMEDOUT',
+    'ENOTFOUND',
+    'connection closed',
+    'connection terminated',
+    'connection timeout',
+    'socket hang up',
+    'too many connections',
+    'pool is full',
+    'server login has been failing',
+    'FATAL:',
+    'PrismaClientUnknownRequestError',
+  ];
+  
+  return retryablePatterns.some(pattern => 
+    errorMsg.toLowerCase().includes(pattern.toLowerCase())
+  );
+}
+
+/**
+ * Execute database operation with retry mechanism
+ * 
+ * @param operation - The database operation to execute
+ * @param config - Retry configuration (optional)
+ * @param operationName - Name of the operation for logging
+ * 
+ * @example
+ * const user = await withRetry(
+ *   () => prisma.user.findUnique({ where: { id: '123' } }),
+ *   undefined,
+ *   'findUser'
+ * );
+ */
+export async function withRetry<T>(
+  operation: () => Promise<T>,
+  config?: Partial<RetryConfig>,
+  operationName?: string
+): Promise<T> {
+  const retryConfig = { ...DEFAULT_RETRY_CONFIG, ...config };
+  let lastError: any;
+  
+  for (let attempt = 1; attempt <= retryConfig.maxRetries; attempt++) {
+    try {
+      const result = await operation();
+      
+      // Log success if it was a retry
+      if (attempt > 1 && operationName) {
+        console.log(`✅ [DB-RETRY] ${operationName} succeeded after ${attempt} attempts`);
+      }
+      
+      return result;
+    } catch (error) {
+      lastError = error;
+      const errorMsg = error instanceof Error ? error.message : 'Unknown error';
+      
+      // Check if we should retry
+      if (attempt < retryConfig.maxRetries && isRetryableError(error)) {
+        // Calculate delay with exponential backoff + jitter
+        const delay = Math.min(
+          retryConfig.initialDelay * Math.pow(retryConfig.factor, attempt - 1),
+          retryConfig.maxDelay
+        );
+        const jitter = Math.random() * 0.3 * delay; // Add 30% jitter
+        
+        if (operationName) {
+          console.warn(
+            `⚠️ [DB-RETRY] ${operationName} failed (attempt ${attempt}/${retryConfig.maxRetries}): ${errorMsg}`
+          );
+          console.log(`⏳ [DB-RETRY] Retrying in ${Math.round(delay + jitter)}ms...`);
+        }
+        
+        await new Promise(resolve => setTimeout(resolve, delay + jitter));
+      } else {
+        // Don't retry - either max retries reached or not a retryable error
+        if (operationName) {
+          console.error(
+            `❌ [DB-RETRY] ${operationName} failed after ${attempt} attempts: ${errorMsg}`
+          );
+        }
+        break;
+      }
+    }
+  }
+  
+  // All retries exhausted, throw the last error
+  throw lastError;
+}
+
+/**
+ * Execute database operation with timeout
+ * 
+ * @param operation - The database operation to execute
+ * @param timeout - Timeout in milliseconds (default: 30000)
+ * @param operationName - Name of the operation for logging
+ */
+export async function withTimeout<T>(
+  operation: () => Promise<T>,
+  timeout: number = 30000,
+  operationName?: string
+): Promise<T> {
+  const timeoutPromise = new Promise<never>((_, reject) => {
+    setTimeout(() => {
+      reject(new Error(`Operation timed out after ${timeout}ms`));
+    }, timeout);
+  });
+  
+  try {
+    return await Promise.race([operation(), timeoutPromise]);
+  } catch (error) {
+    const errorMsg = error instanceof Error ? error.message : 'Unknown error';
+    if (errorMsg.includes('timed out')) {
+      if (operationName) {
+        console.error(`⏱️ [DB-TIMEOUT] ${operationName} timed out after ${timeout}ms`);
+      }
+    }
+    throw error;
+  }
+}
+
+/**
+ * Combine retry and timeout for robust database operations
+ * 
+ * @param operation - The database operation to execute
+ * @param options - Retry and timeout options
+ * @param operationName - Name of the operation for logging
+ */
+export async function withRetryAndTimeout<T>(
+  operation: () => Promise<T>,
+  options?: {
+    retry?: Partial<RetryConfig>;
+    timeout?: number;
+  },
+  operationName?: string
+): Promise<T> {
+  return withRetry(
+    () => withTimeout(operation, options?.timeout, operationName),
+    options?.retry,
+    operationName
+  );
+}
+
+/**
+ * Health check for database connection
+ */
+export async function checkDatabaseConnection(): Promise<boolean> {
+  try {
+    await withTimeout(
+      () => prisma.$queryRaw`SELECT 1`,
+      5000,
+      'healthCheck'
+    );
+    return true;
+  } catch (error) {
+    const errorMsg = error instanceof Error ? error.message : 'Unknown error';
+    console.error('❌ [DB-HEALTH] Database connection check failed:', errorMsg);
+    return false;
+  }
+}
+
+export { prisma };

src/lib/prisma.ts

@@ -1,45 +1,21 @@
 import { PrismaClient } from "@prisma/client";
 
-// Deklarasikan variabel global untuk menandai apakah listener sudah ditambahkan
 declare global {
-  var prisma: PrismaClient;
-  var prismaListenersAdded: boolean; // Flag untuk menandai listener
+  var prisma: PrismaClient | undefined;
 }
 
-let prisma: PrismaClient;
-
-if (process.env.NODE_ENV === "production") {
-  prisma = new PrismaClient({
-    // Reduce logging in production to improve performance
-    log: ['error', 'warn'],
-  });
-} else {
-  if (!global.prisma) {
-    global.prisma = new PrismaClient({
-      log: ['error', 'warn', 'info', 'query'], // More verbose logging in development
-    });
-  }
-  prisma = global.prisma;
+if (!process.env.DATABASE_URL) {
+  throw new Error("DATABASE_URL is required but not found in environment variables");
 }
 
-// Tambahkan listener hanya jika belum ditambahkan sebelumnya
-if (!global.prismaListenersAdded) {
-  // Handle graceful shutdown
-  process.on("SIGINT", async () => {
-    console.log("Received SIGINT signal. Closing database connections...");
-    await prisma.$disconnect();
-    process.exit(0);
+const prisma =
+  global.prisma ??
+  new PrismaClient({
+    log: process.env.NODE_ENV === "development" ? ["error", "warn", "query"] : ["error", "warn"],
   });
 
-  process.on("SIGTERM", async () => {
-    console.log("Received SIGTERM signal. Closing database connections...");
-    await prisma.$disconnect();
-    process.exit(0);
-  });
-
-  // Tandai bahwa listener sudah ditambahkan
-  global.prismaListenersAdded = true;
-}
+// Selalu assign ke global agar hanya ada 1 instance (dev: cegah hot-reload, prod: cegah multiple instances)
+global.prisma = prisma;
 
 export default prisma;
 export { prisma };

src/middleware.tsx

@@ -65,11 +65,7 @@ export const middleware = async (req: NextRequest) => {
 
   const { pathname } = req.nextUrl;
 
-  const apiBaseUrl = new URL(req.url).origin || process.env.NEXT_PUBLIC_API_URL;
-  // Removed excessive logging that was causing high CPU usage
-  // const dbUrl = process.env.DATABASE_URL;
-  // console.log("DATABASE_URL >>", dbUrl);
-  // console.log("URL Access >>", req.url);
+  const apiBaseUrl = process.env.NEXT_PUBLIC_API_URL || new URL(req.url).origin;
 
   // Handle CORS preflight
   const corsResponse = handleCors(req);

types/env.d.ts

@@ -11,5 +11,9 @@ declare namespace NodeJS {
     NEXT_PUBLIC_BASE_SESSION_KEY?: string;
     RESEND_APIKEY?: string;
     WA_SERVER_TOKEN?: string;
+    FIREBASE_ADMIN_PRIVATE_KEY?: string;
+    FIREBASE_ADMIN_CLIENT_EMAIL?: string;
+    FIREBASE_ADMIN_PROJECT_ID?: string;
+    NEXT_PUBLIC_API_URL?: string;
   }
 }