Compare commits

...

10 Commits

Author SHA1 Message Date
dc6fa562cc Clean code
modified:   public/.well-known/assetlinks.json
modified:   src/lib/code-otp-sender.ts

### No issue
2026-03-06 16:35:34 +08:00
4fd7bb4a17 chore(release): 1.6.9 2026-03-06 16:29:50 +08:00
b2305a35a6 Fix WA Otp
### NO Issue
2026-03-05 16:38:31 +08:00
cbfd105134 chore(release): 1.6.8 2026-03-05 14:30:03 +08:00
3e6c94d77f Usulan Commit Message
fix: Implementasi retry mechanism dan error handling untuk database connections

Deskripsi:

Menambahkan withRetry wrapper pada berbagai API routes untuk menangani transient database errors dan meningkatkan reliabilitas koneksi

Memperbaiki error handling pada notification, authentication, dan user validation endpoints dengan response 503 untuk database connection errors

Update prisma.ts dengan konfigurasi logging yang lebih baik dan datasources configuration

Menambahkan validasi input parameters pada beberapa endpoints

Update dokumentasi QWEN.md dengan commit message format dan comment standards

Update .env.example dengan connection pool settings yang lebih lengkap

File yang diubah:

src/lib/prisma.ts — Konfigurasi Prisma client & logging

src/app/api/admin/notifikasi/count/route.tsx

src/app/api/auth/mobile-login/route.ts

src/app/api/mobile/notification/[id]/route.ts

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

Dan 27 file API routes lainnya (penerapan withRetry secara konsisten)

QWEN.md — Dokumentasi commit & comment standards

.env.example — Database connection pool configuration

### No Issue
2026-03-05 14:28:45 +08:00
a6c9182a01 Fix Server dengan penerapan Github build 2026-03-04 16:38:58 +08:00
453aa0a4ec chore(release): 1.6.7 2026-03-04 16:36:57 +08:00
fe37cce13e Fix publish.yml 2026-03-04 16:08:59 +08:00
ee05d0c71f Build Github 2026-03-04 15:18:01 +08:00
f8319b9ab5 Build with Github 2026-03-04 14:12:12 +08:00
44 changed files with 509 additions and 398 deletions

View File

@@ -1,8 +1,11 @@
# ==============================
# 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"
# Connection pool settings untuk mencegah connection exhaustion:
# - connection_limit=10: Maksimal 10 koneksi per Prisma Client instance
# - pool_timeout=20: Timeout menunggu koneksi tersedia (detik)
# - connect_timeout=10: Timeout untuk membuat koneksi baru (detik)
DATABASE_URL="postgresql://user:password@localhost:5432/dbname?connection_limit=10&pool_timeout=20&connect_timeout=10"
# ==============================
# Auth / Session

72
.github/workflows/publish.yml vendored Normal file
View File

@@ -0,0 +1,72 @@
name: Publish Docker to GHCR
on:
workflow_dispatch:
inputs:
environment:
description: "Target environment"
required: true
type: choice
options:
- production
- staging
tag:
description: "Image tag (e.g. v1.0.0)"
required: true
env:
REGISTRY: ghcr.io
IMAGE_NAME: ${{ github.repository }}
jobs:
publish:
name: Build & Push to GHCR (${{ github.event.inputs.environment }})
runs-on: ubuntu-latest
permissions:
contents: read
packages: write
steps:
- name: Free disk space
run: |
sudo rm -rf /usr/share/dotnet
sudo rm -rf /usr/local/lib/android
sudo rm -rf /opt/ghc
sudo rm -rf /opt/hostedtoolcache/CodeQL
sudo docker image prune --all --force
df -h
- name: Checkout repository
uses: actions/checkout@v4
- name: Set up QEMU
uses: docker/setup-qemu-action@v3
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@v3
- name: Log in to GitHub Container Registry
uses: docker/login-action@v3
with:
registry: ${{ env.REGISTRY }}
username: ${{ github.actor }}
password: ${{ secrets.GITHUB_TOKEN }}
- name: Generate image metadata
id: meta
uses: docker/metadata-action@v5
with:
images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
tags: |
type=raw,value=${{ github.event.inputs.environment }}-${{ github.event.inputs.tag }}
type=raw,value=${{ github.event.inputs.environment }}-latest
- name: Build and push Docker image
uses: docker/build-push-action@v6
with:
context: .
file: ./Dockerfile
push: true
platforms: linux/amd64
tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }}
no-cache: true

View File

@@ -2,6 +2,12 @@
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.9](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.8...v1.6.9) (2026-03-06)
## [1.6.8](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.7...v1.6.8) (2026-03-05)
## [1.6.7](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.6...v1.6.7) (2026-03-04)
## [1.6.6](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.6.5...v1.6.6) (2026-03-03)

72
Dockerfile Normal file
View File

@@ -0,0 +1,72 @@
# ==============================
# Stage 1: Builder
# ==============================
FROM node:20-bookworm-slim AS builder
WORKDIR /app
# Install system deps
RUN apt-get update && apt-get install -y --no-install-recommends \
libc6 \
git \
openssl \
ca-certificates \
&& rm -rf /var/lib/apt/lists/*
# Copy dependency files first (for better caching)
COPY package.json package-lock.json* bun.lockb* ./
ENV SHARP_IGNORE_GLOBAL_LIBVIPS=1
ENV NEXT_TELEMETRY_DISABLED=1
ENV NODE_OPTIONS="--max-old-space-size=4096"
# 🔥 Skip postinstall scripts (fix onnxruntime error)
RUN npm install --legacy-peer-deps --ignore-scripts
# Copy full source
COPY . .
# Use .env.example as build env
# (Pastikan file ini ada di project)
RUN cp .env.example .env || true
# Generate Prisma Client
ENV PRISMA_CLI_BINARY_TARGETS=debian-openssl-3.0.x
RUN npx prisma generate
# Build Next.js
RUN npm run build
# ==============================
# Stage 2: Runner (Production)
# ==============================
FROM node:20-bookworm-slim AS runner
WORKDIR /app
ENV NODE_ENV=production
ENV NEXT_TELEMETRY_DISABLED=1
RUN apt-get update && apt-get install -y --no-install-recommends \
openssl \
ca-certificates \
&& rm -rf /var/lib/apt/lists/*
RUN groupadd --system --gid 1001 nodejs \
&& useradd --system --uid 1001 --gid nodejs nextjs
# Copy standalone output
COPY --from=builder /app/.next/standalone ./
COPY --from=builder /app/.next/static ./.next/static
COPY --from=builder /app/public ./public
RUN chown -R nextjs:nodejs /app
USER nextjs
EXPOSE 3000
ENV PORT=3000
ENV HOSTNAME="0.0.0.0"
CMD ["node", "server.js"]

64
QWEN.md
View File

@@ -120,14 +120,6 @@ The team follows a structured Git workflow:
- `style`: Styling changes
- `perf`: Performance improvements
### Code Standards
- TypeScript with strict mode enabled
- Component header comments with file description, creator, date
- Function comments with parameter and return value descriptions
- Custom type interface comments
- Error handling comments
- Complex logic comments
### Commit Message Format
```
type: Short description
@@ -140,6 +132,62 @@ Body:
References: #issue-number
```
**Example:**
```
feat: Tambahkan fitur kalkulator
Deskripsi:
- Menambahkan fungsi penambahan, pengurangan, perkalian, dan pembagian
- Memperbolehkan pengguna untuk memasukkan dua angka dan melakukan operasi matematika
Fixes #12
```
### Code Standards
- TypeScript with strict mode enabled
- Component header comments with file description, creator, date
- Function comments with parameter and return value descriptions
- Custom type interface comments
- Error handling comments
- Complex logic comments
### Comment Standards
**File Header:**
```typescript
/**
* Nama File: app.ts
* Deskripsi: Ini adalah file utama aplikasi.
* Pembuat: John Doe
* Tanggal: 27 Juli 2023
*/
```
**Function Comments:**
```typescript
/**
* Fungsi untuk menambahkan dua angka.
* @param {number} a - Angka pertama.
* @param {number} b - Angka kedua.
* @returns {number} Hasil penjumlahan a dan b.
*/
function addNumbers(a: number, b: number): number {
return a + b;
}
```
**Custom Type Comments:**
```typescript
/**
* Interface untuk merepresentasikan informasi pelanggan.
*/
interface Customer {
id: number; // ID pelanggan
name: string; // Nama pelanggan
age?: number; // Umur pelanggan (opsional)
}
```
## Project Structure
### Main Directories

View File

@@ -1,16 +0,0 @@
import { fileURLToPath } from "url";
import { dirname } from "path"; // Pastikan `dirname` diimpor
import { FlatCompat } from "@eslint/eslintrc";
const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);
const compat = new FlatCompat({
baseDirectory: __dirname,
});
const eslintConfig = [
...compat.extends("next/core-web-vitals", "next/typescript"),
];
export default eslintConfig;

View File

@@ -1,25 +1,21 @@
/** @type {import('next').NextConfig} */
const nextConfig = {
reactStrictMode: false,
output: "standalone",
eslint: { ignoreDuringBuilds: true },
typescript: { ignoreBuildErrors: true },
experimental: {
serverActions: true,
serverComponentsExternalPackages: ['@prisma/client'],
},
output: "standalone",
staticPageGenerationTimeout: 180, // tingkatkan menjadi 3 menit
eslint: {
ignoreDuringBuilds: true,
},
typescript: {
ignoreBuildErrors: true
serverComponentsExternalPackages: ["@prisma/client", ".prisma/client"],
},
webpack: (config, { isServer }) => {
if (isServer) {
config.externals = config.externals || [];
config.externals.push('@prisma/client');
config.externals.push("@prisma/client");
config.externals.push(".prisma/client");
}
return config;
},
};
module.exports = nextConfig;
module.exports = nextConfig;

View File

@@ -1,6 +1,6 @@
{
"name": "hipmi",
"version": "1.6.6",
"version": "1.6.9",
"private": true,
"prisma": {
"seed": "bun prisma/seed.ts"

View File

@@ -13,6 +13,6 @@ import { generate_seeder } from "./../src/app_modules/_global/fun/generate_seede
console.error("<< error seeder", e);
process.exit(1);
})
.finally(async () => {
await prisma.$disconnect();
});
// .finally(async () => {
// await prisma.$disconnect();
// });

View File

@@ -1,8 +1,10 @@
[{
"relation": ["delegate_permission/common.handle_all_urls"],
"target": {
"namespace": "android_app",
"package_name": "com.bip.hipmimobileapp",
"sha256_cert_fingerprints": ["CFF8431520BFAE665025B68138774A4E64AA6338D2DF6C7D900A71F0551FFD2D"]
[
{
"relation": ["delegate_permission/common.handle_all_urls"],
"target": {
"namespace": "android_app",
"package_name": "com.bip.hipmimobileapp",
"sha256_cert_fingerprints": ["CFF8431520BFAE665025B68138774A4E64AA6338D2DF6C7D900A71F0551FFD2D"]
}
}
}]
]

View File

@@ -43,9 +43,9 @@ 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');
// console.log('✓ .env file copied to standalone output');
} else {
console.warn('⚠ .env file not found, skipping...');
// console.warn('⚠ .env file not found, skipping...');
console.warn(' Pastikan DATABASE_URL di-set di system environment server!');
}
@@ -54,7 +54,7 @@ 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('✓ .env-local file copied to standalone output');
}
console.log('✅ Build script completed!');

View File

@@ -1,4 +1,5 @@
import { NextResponse } from "next/server";
import { withRetry } from "@/lib/prisma-retry";
import { prisma } from "@/lib";
export const dynamic = "force-dynamic";
@@ -16,13 +17,25 @@ export async function GET(request: Request) {
const { searchParams } = new URL(request.url);
const userId = searchParams.get("id");
const data = await prisma.notifikasi.count({
where: {
adminId: userId,
userRoleId: "2",
isRead: false,
},
});
if (!userId) {
return NextResponse.json(
{ success: false, message: "User ID is required" },
{ status: 400 }
);
}
const data = await withRetry(
() =>
prisma.notifikasi.count({
where: {
adminId: userId,
userRoleId: "2",
isRead: false,
},
}),
undefined,
"countAdminNotifications"
);
return NextResponse.json(
{
@@ -33,7 +46,25 @@ export async function GET(request: Request) {
{ status: 200 }
);
} catch (error) {
const errorMsg = error instanceof Error ? error.message : "Unknown error";
console.error("Error get count notifikasi", error);
// Check if it's a database connection error
if (
errorMsg.includes("Prisma") ||
errorMsg.includes("database") ||
errorMsg.includes("connection")
) {
return NextResponse.json(
{
success: false,
message: "Database connection error. Please try again.",
data: null,
},
{ status: 503 }
);
}
return NextResponse.json(
{
success: false,

View File

@@ -50,7 +50,5 @@ async function DELETE(
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -1,3 +1,4 @@
import { withRetry } from "@/lib/prisma-retry";
import { prisma } from "@/lib";
import { randomOTP } from "@/app_modules/auth/fun/rondom_otp";
import { NextResponse } from "next/server";
@@ -9,11 +10,26 @@ export async function POST(req: Request) {
const body = await req.json();
const { nomor } = body;
const user = await prisma.user.findUnique({
where: {
nomor: nomor,
},
});
if (!nomor) {
return NextResponse.json(
{
success: false,
message: "Nomor telepon diperlukan",
status: 400,
}
);
}
const user = await withRetry(
() =>
prisma.user.findUnique({
where: {
nomor: nomor,
},
}),
undefined,
"findUserByNomor"
);
if (!user)
return NextResponse.json({
@@ -22,12 +38,17 @@ export async function POST(req: Request) {
status: 404,
});
const createOtpId = await prisma.kodeOtp.create({
data: {
nomor: nomor,
otp: codeOtp,
},
});
const createOtpId = await withRetry(
() =>
prisma.kodeOtp.create({
data: {
nomor: nomor,
otp: codeOtp,
},
}),
undefined,
"createOTP"
);
if (!createOtpId)
return NextResponse.json(
@@ -59,6 +80,25 @@ export async function POST(req: Request) {
{ status: 200 },
);
} catch (error) {
const errorMsg = error instanceof Error ? error.message : "Unknown error";
console.error("Mobile login error:", error);
// Check if it's a database connection error
if (
errorMsg.includes("Prisma") ||
errorMsg.includes("database") ||
errorMsg.includes("connection")
) {
return NextResponse.json(
{
success: false,
message: "Database connection error. Please try again.",
status: 503,
},
{ status: 503 }
);
}
return NextResponse.json(
{
success: false,

View File

@@ -64,7 +64,5 @@ export async function POST(req: Request) {
},
{ status: 500 },
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -42,7 +42,5 @@ export async function GET(
{ success: false, message: "Gagal mendapatkan data" },
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -30,13 +30,11 @@ export async function GET(request: Request) {
fixData = false;
}
await prisma.$disconnect();
return NextResponse.json(
{ success: true, message: "Success get data", data: fixData },
{ status: 200 }
);
} catch (error) {
await prisma.$disconnect();
backendLogger.error("Error get data detail event:", error);
return NextResponse.json(
{

View File

@@ -41,13 +41,11 @@ export async function POST(
},
});
await prisma.$disconnect();
return NextResponse.json({
success: true,
message: "Success create sponsor",
});
} catch (error) {
await prisma.$disconnect();
backendLogger.error("Error create sponsor event", error);
return NextResponse.json(
{ success: false, message: "Failed create sponsor" },
@@ -100,7 +98,5 @@ export async function GET(
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -58,7 +58,6 @@ export async function GET(
});
}
await prisma.$disconnect();
return NextResponse.json({
success: true,
message: "Success create sponsor",
@@ -66,7 +65,6 @@ export async function GET(
});
} catch (error) {
backendLogger.error("Error get sponsor event", error);
await prisma.$disconnect();
return NextResponse.json(
{
success: false,

View File

@@ -33,7 +33,5 @@ export async function GET(request: Request) {
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -35,7 +35,5 @@ export async function GET(request: Request) {
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -21,13 +21,11 @@ export async function GET(request: Request) {
},
});
await prisma.$disconnect();
return NextResponse.json(
{ success: true, message: "Berhasil mendapatkan data", data: res },
{ status: 200 }
);
} catch (error) {
await prisma.$disconnect();
backendLogger.error("Error Get Master Status Transaksi >>", error);
return NextResponse.json(
{

View File

@@ -28,7 +28,5 @@ async function GET() {
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -1,3 +1,4 @@
import { withRetry } from "@/lib/prisma-retry";
import { prisma } from "@/lib";
import _ from "lodash";
import { NextRequest, NextResponse } from "next/server";
@@ -22,28 +23,38 @@ export async function GET(
let fixData;
try {
const data = await prisma.notifikasi.findMany({
take: page ? takeData : undefined,
skip: page ? skipData : undefined,
orderBy: {
createdAt: "desc",
},
where: {
recipientId: id,
kategoriApp: fixCategory,
},
});
const data = await withRetry(
() =>
prisma.notifikasi.findMany({
take: page ? takeData : undefined,
skip: page ? skipData : undefined,
orderBy: {
createdAt: "desc",
},
where: {
recipientId: id,
kategoriApp: fixCategory,
},
}),
undefined,
"getNotifications"
);
// Jika pagination digunakan, ambil juga total count untuk informasi
let totalCount;
let totalPages;
if (page) {
totalCount = await prisma.notifikasi.count({
where: {
recipientId: id,
kategoriApp: fixCategory,
},
});
totalCount = await withRetry(
() =>
prisma.notifikasi.count({
where: {
recipientId: id,
kategoriApp: fixCategory,
},
}),
undefined,
"countNotifications"
);
totalPages = Math.ceil(totalCount / takeData);
}
@@ -69,8 +80,23 @@ export async function GET(
return NextResponse.json(response);
} catch (error) {
const errorMsg = error instanceof Error ? error.message : "Unknown error";
console.error("Error getting notifications:", error);
// Check if it's a database connection error
if (
errorMsg.includes("Prisma") ||
errorMsg.includes("database") ||
errorMsg.includes("connection")
) {
return NextResponse.json(
{ error: "Database connection error. Please try again." },
{ status: 503 }
);
}
return NextResponse.json(
{ error: (error as Error).message },
{ error: errorMsg },
{ status: 500 },
);
}

View File

@@ -1,3 +1,4 @@
import { withRetry } from "@/lib/prisma-retry";
import { prisma } from "@/lib";
import { NextRequest, NextResponse } from "next/server";
@@ -9,12 +10,24 @@ export async function GET(
console.log("User ID:", id);
try {
const data = await prisma.notifikasi.count({
where: {
recipientId: id,
isRead: false,
},
});
if (!id) {
return NextResponse.json({
success: false,
message: "User ID is required",
});
}
const data = await withRetry(
() =>
prisma.notifikasi.count({
where: {
recipientId: id,
isRead: false,
},
}),
undefined,
"countUnreadNotifications"
);
console.log("List Notification >>", data);
@@ -23,6 +36,21 @@ export async function GET(
data: data,
});
} catch (error) {
const errorMsg = error instanceof Error ? error.message : "Unknown error";
console.error("Error getting unread count:", error);
// Check if it's a database connection error
if (
errorMsg.includes("Prisma") ||
errorMsg.includes("database") ||
errorMsg.includes("connection")
) {
return NextResponse.json({
success: false,
message: "Database connection error. Please try again.",
});
}
return NextResponse.json({
success: false,
message: "Failed to get unread count",

View File

@@ -131,7 +131,5 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -40,7 +40,5 @@ export async function GET(request: Request) {
status: 500,
}
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -27,18 +27,18 @@ export async function GET(request: Request) {
NOT: {
Profile: null,
},
OR: [
{
MasterUserRole: {
name: "User",
},
},
{
MasterUserRole: {
name: "Admin",
},
},
],
// OR: [
// {
// MasterUserRole: {
// name: "User",
// },
// },
// {
// MasterUserRole: {
// name: "Admin",
// },
// },
// ],
},
include: {
Profile: {

View File

@@ -78,7 +78,5 @@ export async function GET(request: Request) {
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -49,14 +49,11 @@ export async function GET(
});
}
await prisma.$disconnect();
return NextResponse.json(
{ success: true, message: "Success get data news", data: fixData },
{ status: 200 }
);
} catch (error) {
await prisma.$disconnect();
backendLogger.error("Error get data news", error);
return NextResponse.json(
{

View File

@@ -36,8 +36,6 @@ export async function GET(
});
}
await prisma.$disconnect();
return NextResponse.json(
{ success: true, message: "Success get data document", data: fixData },
{ status: 200 }

View File

@@ -104,7 +104,5 @@ async function PUT(request: Request) {
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -77,7 +77,5 @@ async function POST(request: Request) {
},
{ status: 500 }
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -1,4 +1,5 @@
import { decrypt } from "@/app/(auth)/_lib/decrypt";
import { withRetry } from "@/lib/prisma-retry";
import { prisma } from "@/lib";
import { cookies } from "next/headers";
import { NextResponse } from "next/server";
@@ -43,11 +44,16 @@ export async function GET(req: Request) {
);
}
const user = await prisma.user.findUnique({
where: {
id: decrypted.id,
},
});
const user = await withRetry(
() =>
prisma.user.findUnique({
where: {
id: decrypted.id,
},
}),
undefined,
"validateUser"
);
if (!user) {
return NextResponse.json(
@@ -76,25 +82,44 @@ export async function GET(req: Request) {
data: user,
});
} catch (error) {
const errorMsg = error instanceof Error ? error.message : 'Unknown error';
const errorStack = error instanceof Error ? error.stack : 'No stack';
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);
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: "Database connection error. Please try again.",
error: process.env.NODE_ENV === "development" ? errorMsg : "Internal server error",
},
{ status: 503 }
);
}
return NextResponse.json(
{
success: false,
message: "Terjadi kesalahan pada server",
error: process.env.NODE_ENV === 'development' ? errorMsg : 'Internal server error',
error:
process.env.NODE_ENV === "development" ? errorMsg : "Internal server error",
},
{ status: 500 }
);

View File

@@ -125,7 +125,5 @@ export async function GET(request: Request) {
status: 500,
}
);
} finally {
await prisma.$disconnect();
}
}

View File

@@ -669,10 +669,8 @@ const limit = pLimit(1);
export async function generate_seeder() {
try {
await Promise.all(listSeederQueue.map((fn) => limit(fn)));
await prisma.$disconnect();
} catch (error) {
console.error("error generate seeder", error);
await prisma.$disconnect();
}
return { status: 200, success: true };

View File

@@ -37,6 +37,5 @@ export async function AdminDonasi_getOneById(id: string) {
},
});
await prisma.$disconnect();
return res;
}

View File

@@ -33,12 +33,10 @@ export async function AdminDonasi_funUpdateStatusPublish(
});
if (!data) {
await prisma.$disconnect();
return { status: 400, message: "Data tidak ditemukan" };
}
revalidatePath(RouterAdminDonasi.table_review);
await prisma.$disconnect();
return {
data: data,

View File

@@ -36,12 +36,10 @@ export default async function adminNotifikasi_funCreateToAllUser({
},
});
if (!create) {
await prisma.$disconnect();
return { status: 400, message: "Gagal mengirim notifikasi" };
}
}
await prisma.$disconnect();
return {
status: 201,
message: "Berhasil mengirim notifikasi",

View File

@@ -25,10 +25,8 @@ export default async function adminNotifikasi_funCreateToUser({
});
if (!create) {
await prisma.$disconnect();
return { status: 400, message: "Gagal mengirim notifikasi" };
}
await prisma.$disconnect();
return { status: 201, message: "Berhasil mengirim notifikasi" };
}

View File

@@ -9,9 +9,6 @@ export async function donasi_checkStatus({ id }: { id: string }) {
},
});
await prisma.$disconnect();
if (checkStatus?.donasiMaster_StatusDonasiId == "2") return true;
return false;

View File

@@ -7,23 +7,22 @@ const sendCodeOtp = async ({
codeOtp?: string;
newMessage?: string;
}) => {
const msg = newMessage || `HIPMI - Kode ini bersifat RAHASIA dan JANGAN DI BAGIKAN KEPADA SIAPAPUN, termasuk anggota ataupun pengurus HIPMI lainnya.\n\n>> Kode OTP anda: ${codeOtp}.`;
const enCode = encodeURIComponent(msg);
const res = await fetch(
`https://cld-dkr-prod-wajs-server.wibudev.com/api/wa/code?nom=${nomor}&text=${enCode}`,
{
cache: "no-cache",
headers: {
Authorization: `Bearer ${process.env.WA_SERVER_TOKEN}`,
},
const msg =
newMessage ||
`HIPMI - Kode ini bersifat RAHASIA dan JANGAN DI BAGIKAN KEPADA SIAPAPUN, termasuk anggota ataupun pengurus HIPMI lainnya.\n\n>> Kode OTP anda: ${codeOtp}.`;
const enCode = msg;
const res = await fetch(`https://otp.wibudev.com/api/wa/send-text`, {
method: "POST",
headers: {
"Content-Type": "application/json",
Authorization: `Bearer ${process.env.WA_SERVER_TOKEN}`,
},
);
// const res = await fetch(
// `https://wa.wibudev.com/code?nom=${nomor}&text=HIPMI - Kode ini bersifat RAHASIA dan JANGAN DI BAGIKAN KEPADA SIAPAPUN, termasuk anggota ataupun pengurus HIPMI lainnya.
// \n
// >> Kode OTP anda: ${codeOtp}.
// `,
// );
body: JSON.stringify({
number: nomor,
text: enCode,
}),
});
return res;
};

View File

@@ -1,21 +1,55 @@
import { PrismaClient } from "@prisma/client";
/**
* Instance global Prisma client untuk connection pooling
* Menggunakan pattern globalThis untuk mencegah multiple instance selama:
* - Hot module replacement (HMR) di development
* - Multiple import di seluruh aplikasi
* - Server-side rendering di Next.js
*/
declare global {
// eslint-disable-next-line no-var
var prisma: PrismaClient | undefined;
}
if (!process.env.DATABASE_URL) {
throw new Error("DATABASE_URL is required but not found in environment variables");
}
// Konfigurasi connection pool via parameter query DATABASE_URL:
// connection_limit=10&pool_timeout=20&connect_timeout=10
const prisma =
global.prisma ??
globalThis.prisma ??
new PrismaClient({
log: process.env.NODE_ENV === "development" ? ["error", "warn", "query"] : ["error", "warn"],
log:
process.env.NODE_ENV === "development"
? ["error", "warn"]
: ["error"],
datasources: {
db: {
url: process.env.DATABASE_URL,
},
},
});
// Selalu assign ke global agar hanya ada 1 instance (dev: cegah hot-reload, prod: cegah multiple instances)
global.prisma = prisma;
// Hanya assign ke global di development untuk mencegah multiple instance saat HMR
// Di production, ini di-skip karena tidak ada HMR
if (process.env.NODE_ENV !== "production") {
globalThis.prisma = prisma;
}
/**
* Handler graceful shutdown untuk koneksi Prisma
* Panggil ini HANYA saat terminasi process (SIGINT/SIGTERM)
* JANGAN panggil $disconnect() setelah query individual
*/
async function gracefulShutdown(): Promise<void> {
console.log("[Prisma] Menutup koneksi database...");
await prisma.$disconnect();
console.log("[Prisma] Semua koneksi ditutup");
}
// Register shutdown handlers (hanya di environment Node.js)
if (typeof process !== "undefined") {
process.on("SIGINT", gracefulShutdown);
process.on("SIGTERM", gracefulShutdown);
}
export default prisma;
export { prisma };

204
zCoba.js
View File

@@ -1,204 +0,0 @@
const { PrismaClient } = require('@prisma/client')
const axios = require('axios')
const prisma = new PrismaClient()
// Daftar contoh data
const donationDataList = [
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Bantuan Pendidikan Anak-anak Kurang Mampu",
"target": 50000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Central Asia",
"rekening": "1234567890",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Kami ingin membantu anak-anak kurang mampu mendapatkan pendidikan yang layak.",
"cerita": "Pendidikan adalah hak dasar setiap anak. Namun, banyak anak-anak di pelosok negeri yang tidak bisa menikmati pendidikan karena keterbatasan ekonomi. Melalui kampanye ini, kami ingin mengumpulkan dana untuk membantu biaya pendidikan mereka.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj0"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Pembangunan Masjid di Desa Terpencil",
"target": 100000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Mandiri",
"rekening": "0987654321",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Membangun masjid untuk masyarakat di daerah terpencil yang belum memiliki tempat ibadah.",
"cerita": "Di sebuah desa terpencil, masyarakat setiap hari harus berjalan jauh untuk bisa melaksanakan sholat berjamaah. Kami ingin membantu membangun masjid di tengah-tengah mereka agar ibadah bisa dilakukan dengan lebih tenang dan khusyuk.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj1"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Bantuan Korban Bencana Alam",
"target": 75000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Rakyat Indonesia",
"rekening": "5678901234",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Membantu meringankan beban korban bencana alam berupa kebutuhan pokok dan kebutuhan darurat.",
"cerita": "Beberapa wilayah dilanda bencana banjir dan tanah longsor. Masyarakat kehilangan harta benda dan membutuhkan bantuan segera. Dana yang terkumpul akan digunakan untuk menyediakan makanan, obat-obatan, dan kebutuhan pokok lainnya.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj2"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Pengadaan Alat Medis Rumah Sakit",
"target": 150000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Negara Indonesia",
"rekening": "4321098765",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Meningkatkan kualitas pelayanan kesehatan dengan menyediakan alat medis yang lebih baik.",
"cerita": "Rumah sakit daerah kekurangan alat medis untuk melayani pasien. Melalui donasi ini, kami ingin membantu pengadaan alat-alat medis penting seperti ventilator, USG, dan alat laboratorium untuk meningkatkan kualitas pelayanan kesehatan.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj3"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Program Beasiswa Mahasiswa Berprestasi",
"target": 80000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Danamon",
"rekening": "1122334455",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Memberikan kesempatan kepada mahasiswa berprestasi untuk melanjutkan pendidikan tanpa beban biaya.",
"cerita": "Banyak mahasiswa berprestasi yang tidak mampu melanjutkan pendidikan karena keterbatasan biaya. Program beasiswa ini akan membantu mereka menyelesaikan kuliah hingga sarjana.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj4"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Pengadaan Air Bersih untuk Desa Kekeringan",
"target": 60000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Permata",
"rekening": "6677889900",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Menyediakan akses air bersih bagi masyarakat yang tinggal di daerah rawan kekeringan.",
"cerita": "Beberapa desa mengalami kekeringan setiap tahunnya, membuat warga kesulitan mendapatkan air bersih. Kami ingin membangun sumur bor dan sistem distribusi air untuk membantu masyarakat setempat.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj5"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Pengobatan Gratis untuk Warga Tidak Mampu",
"target": 40000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Panin",
"rekening": "9988776655",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Memberikan layanan kesehatan gratis bagi warga yang tidak mampu membayar biaya pengobatan.",
"cerita": "Banyak warga yang menunda pengobatan karena keterbatasan biaya. Melalui program ini, kami akan menyelenggarakan pengobatan gratis secara berkala di berbagai wilayah.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj6"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Pembangunan Taman Bacaan Masyarakat",
"target": 35000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank Mega",
"rekening": "1357924680",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Membangun taman bacaan untuk meningkatkan minat baca masyarakat di wilayah pedesaan.",
"cerita": "Minat baca masyarakat di pedesaan masih rendah karena keterbatasan akses buku. Taman bacaan ini akan menyediakan ribuan buku gratis dan ruang baca yang nyaman untuk semua usia.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj7"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Pelatihan Keterampilan untuk Pengangguran",
"target": 55000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank CIMB Niaga",
"rekening": "2468135790",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Memberikan pelatihan keterampilan untuk membantu pengangguran mendapatkan pekerjaan atau usaha mandiri.",
"cerita": "Angka pengangguran masih tinggi di beberapa wilayah. Program pelatihan ini akan memberikan keterampilan yang dibutuhkan pasar kerja, seperti menjahit, memasak, teknologi informasi, dan lainnya.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj8"
}
},
{
"data": {
"authorId": "cmha6wb9w0001cfndwl9fcse6",
"title": "Renovasi Gedung Sekolah Rusak",
"target": 90000000,
"donasiMaster_DurasiId": 3,
"donasiMaster_KategoriId": 3,
"namaBank": "Bank OCBC NISP",
"rekening": "1029384756",
"imageId": "cm60j9q3m000xc9dc584v8rh8",
"pembukaan": "Merestrukturasi gedung sekolah yang rusak agar siswa bisa belajar dengan aman dan nyaman.",
"cerita": "Banyak gedung sekolah yang rusak parah dan membahayakan keselamatan siswa. Dana dari kampanye ini akan digunakan untuk renovasi dan perbaikan gedung sekolah yang membutuhkan.",
"imageCeritaId": "cm60j9q3m000xc9dc584v8rj9"
}
}
];
async function sendDonationData() {
const baseUrl = 'http://localhost:3000/api/mobile/donation'; // Sesuaikan dengan URL server Anda
const headers = {
'Content-Type': 'application/json',
};
for (let i = 0; i < donationDataList.length; i++) {
try {
console.log(`Mengirim data ke-${i + 1}...`);
const response = await axios.post(`${baseUrl}?category=permanent`, donationDataList[i], {
headers: headers
});
console.log(`Data ke-${i + 1} berhasil dikirim:`, response.data);
} catch (error) {
console.error(`Error saat mengirim data ke-${i + 1}:`, error.response?.data || error.message);
}
}
}
async function main() {
// Menjalankan fungsi untuk mengirim data donasi
await sendDonationData();
// Fungsi asli untuk update notifikasi
const result = await prisma.notifikasi.updateMany({
where: {
recipientId: 'cmha7p6yc0000cfoe5w2e7gdr',
},
data: {
isRead: false,
readAt: null,
},
})
console.log(`✅ Rows affected: ${result.count}`)
}
main()
.catch((err) => {
console.error('❌ Error:', err)
process.exit(1)
})
.finally(async () => {
await prisma.$disconnect()
})