Compare commits
60 Commits
mobile-api
...
clean-code
| Author | SHA1 | Date | |
|---|---|---|---|
| dc6fa562cc | |||
| 4fd7bb4a17 | |||
| b2305a35a6 | |||
| cbfd105134 | |||
| 3e6c94d77f | |||
| a6c9182a01 | |||
| 453aa0a4ec | |||
| fe37cce13e | |||
| ee05d0c71f | |||
| f8319b9ab5 | |||
| 2c1d74973b | |||
| 04c2e0d580 | |||
|
|
6dba07baac | ||
| b76c7a4b1c | |||
| 240f6eb7c2 | |||
| f64ae42825 | |||
| df5d1aad48 | |||
| 82e69309a1 | |||
| a6588818b5 | |||
| 58e1afaa45 | |||
| f65f9b7834 | |||
| 250b7c5261 | |||
| 935e519662 | |||
| 36b9248ed7 | |||
| c6dbd152d5 | |||
| 714cf5cd5a | |||
| a2c5f053da | |||
| a68343599d | |||
| 419b87fc92 | |||
| bedc0cc88b | |||
| 0271c87ba9 | |||
| a9fbd544e5 | |||
| 5551f30721 | |||
| 00d36454d1 | |||
| a762fbe9b1 | |||
| a98ab18423 | |||
| 9afd741d4f | |||
| 1c227a2850 | |||
| 817919f8f7 | |||
| 5bdb998d2e | |||
| 90031e23ef | |||
| b585aa3024 | |||
| 596ebd2ff4 | |||
| aa700523ca | |||
| 236ab4d4a4 | |||
| eaa7692359 | |||
| d51ce346e6 | |||
| 91f4bb6c9e | |||
| 1fe0001994 | |||
| b82a283731 | |||
| 6d7d0fd07e | |||
| bc80bb3441 | |||
| 8ab94b9c86 | |||
| 6e37b18e42 | |||
| a6db03d0b4 | |||
| c550a4e922 | |||
| 2431a3fa3e | |||
| 1ed0da8c7d | |||
| e15a5d796d | |||
| 836ebfaef0 |
56
.env.example
Normal file
56
.env.example
Normal file
@@ -0,0 +1,56 @@
|
||||
# ==============================
|
||||
# Database
|
||||
# ==============================
|
||||
# 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
|
||||
# ==============================
|
||||
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"
|
||||
72
.github/workflows/publish.yml
vendored
Normal file
72
.github/workflows/publish.yml
vendored
Normal 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
|
||||
37
CHANGELOG.md
37
CHANGELOG.md
@@ -2,6 +2,43 @@
|
||||
|
||||
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)
|
||||
|
||||
|
||||
### 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)
|
||||
|
||||
@@ -1,63 +0,0 @@
|
||||
# Changelog for Branch: fixed-bug/12-feb-26
|
||||
|
||||
## Summary
|
||||
This branch contains several bug fixes and performance improvements, primarily focusing on:
|
||||
- Database connection management
|
||||
- MQTT client stability
|
||||
- Logging optimization
|
||||
- API enhancements
|
||||
|
||||
## Detailed Changes
|
||||
|
||||
### Fixed Issues
|
||||
1. **Database Connection Management**
|
||||
- Removed `prisma.$disconnect()` from user-validate API route to prevent connection pool exhaustion
|
||||
- Added proper connection handling in global Prisma setup
|
||||
- Reduced logging verbosity in production environments
|
||||
|
||||
2. **MQTT Client Improvements**
|
||||
- Enhanced MQTT client initialization with proper error handling
|
||||
- Added reconnection logic with configurable intervals
|
||||
- Implemented cleanup functions to prevent memory leaks
|
||||
- Added separate initialization logic for server and client-side code
|
||||
|
||||
3. **Logging Optimization**
|
||||
- Removed excessive logging in middleware that was causing high CPU usage
|
||||
- Configured appropriate log levels for development and production
|
||||
|
||||
4. **Component Stability**
|
||||
- Added safety checks in text editor component to prevent MQTT operations on the server side
|
||||
- Improved MQTT publishing logic with client availability checks
|
||||
|
||||
### New Files
|
||||
- `src/lib/prismaUtils.ts` - Utility functions for safe database operations
|
||||
|
||||
### Modified Files
|
||||
1. `src/app/api/user-validate/route.ts`
|
||||
- Removed problematic `prisma.$disconnect()` call
|
||||
|
||||
2. `src/lib/prisma.ts`
|
||||
- Configured different logging levels for dev/prod
|
||||
- Removed process listeners that were causing disconnections
|
||||
- Exported prisma instance separately
|
||||
|
||||
3. `src/middleware.tsx`
|
||||
- Removed excessive logging statements
|
||||
|
||||
4. `src/util/mqtt_client.ts`
|
||||
- Enhanced initialization with error handling
|
||||
- Added reconnection and timeout configurations
|
||||
|
||||
5. `src/util/mqtt_loader.tsx`
|
||||
- Added proper cleanup functions
|
||||
- Improved connection handling
|
||||
|
||||
6. `src/app_modules/_global/component/new/comp_V3_text_editor_stiker.tsx`
|
||||
- Added MQTT client availability checks
|
||||
- Prevented server-side MQTT operations
|
||||
|
||||
### Performance Improvements
|
||||
- Reduced database connection overhead
|
||||
- Optimized MQTT connection handling
|
||||
- Eliminated unnecessary logging in production
|
||||
- Better memory management with proper cleanup functions
|
||||
39
CHANGELOG_COMMIT.md
Normal file
39
CHANGELOG_COMMIT.md
Normal file
@@ -0,0 +1,39 @@
|
||||
## Catatan Perubahan untuk Commit
|
||||
|
||||
### Fitur: Penambahan Pagination pada Endpoint Admin Mobile
|
||||
|
||||
#### Deskripsi Umum
|
||||
Telah dilakukan penambahan fitur pagination pada beberapa endpoint admin mobile untuk meningkatkan kinerja dan pengalaman pengguna saat mengakses data dalam jumlah besar.
|
||||
|
||||
#### File yang Diubah
|
||||
|
||||
1. **src/app/api/mobile/admin/job/route.ts**
|
||||
- Ditambahkan parameter `page` dari `searchParams`
|
||||
- Diterapkan logika pagination dengan `takeData` (default 10) dan `skipData`
|
||||
- Query `prisma.job.findMany` telah dimodifikasi untuk mendukung pagination
|
||||
|
||||
2. **src/app/api/mobile/admin/event/route.ts**
|
||||
- Diperbaiki definisi variabel `page` untuk memastikan tipe data yang konsisten
|
||||
- Ditambahkan default value 1 untuk parameter `page`
|
||||
- Perhitungan `skipData` disesuaikan agar lebih efisien
|
||||
|
||||
3. **src/app/api/mobile/admin/event/[id]/participants/route.ts**
|
||||
- Ditambahkan parameter `page` dari `searchParams`
|
||||
- Diterapkan logika pagination dengan `takeData` (default 10) dan `skipData`
|
||||
- Query `prisma.event_Peserta.findMany` telah dimodifikasi untuk mendukung pagination
|
||||
|
||||
#### Tujuan Perubahan
|
||||
- Meningkatkan kinerja aplikasi saat mengambil data dalam jumlah besar
|
||||
- Memungkinkan pengguna untuk mengakses data secara bertahap melalui halaman-halaman
|
||||
- Mengurangi beban server saat mengambil data dalam jumlah besar
|
||||
- Memberikan pengalaman pengguna yang lebih baik saat mengakses data admin
|
||||
|
||||
#### Cara Penggunaan
|
||||
Untuk menggunakan fitur pagination, cukup tambahkan parameter `page` pada query string saat melakukan permintaan ke endpoint yang telah dimodifikasi. Contoh:
|
||||
```
|
||||
GET /api/mobile/admin/job?page=2
|
||||
GET /api/mobile/admin/event?page=3
|
||||
GET /api/mobile/admin/event/{id}/participants?page=1
|
||||
```
|
||||
|
||||
Default jumlah data per halaman adalah 10 item.
|
||||
72
Dockerfile
Normal file
72
Dockerfile
Normal 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"]
|
||||
@@ -1,5 +1,5 @@
|
||||
|
||||
File utama: src/app/api/mobile/admin/user/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
|
||||
|
||||
66
QWEN.md
66
QWEN.md
@@ -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
|
||||
@@ -198,4 +246,4 @@ References: #issue-number
|
||||
### Data Protection
|
||||
- Encrypted tokens
|
||||
- Secure API routes
|
||||
- Proper CORS configuration
|
||||
- Proper CORS configuration
|
||||
|
||||
@@ -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;
|
||||
@@ -1,27 +1,21 @@
|
||||
/** @type {import('next').NextConfig} */
|
||||
const nextConfig = {
|
||||
reactStrictMode: false,
|
||||
output: "standalone",
|
||||
eslint: { ignoreDuringBuilds: true },
|
||||
typescript: { ignoreBuildErrors: true },
|
||||
experimental: {
|
||||
serverActions: true,
|
||||
serverComponentsExternalPackages: ["@prisma/client", ".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");
|
||||
config.externals.push(".prisma/client");
|
||||
}
|
||||
return config;
|
||||
},
|
||||
// async headers() {
|
||||
// return [
|
||||
// {
|
||||
// source: "/(.*)",
|
||||
// headers: [
|
||||
// {
|
||||
// key: "Cache-Control",
|
||||
// value: "no-store, max-age=0",
|
||||
// },
|
||||
// ],
|
||||
// },
|
||||
// ];
|
||||
// },
|
||||
};
|
||||
|
||||
module.exports = nextConfig;
|
||||
module.exports = nextConfig;
|
||||
@@ -1,15 +1,16 @@
|
||||
{
|
||||
"name": "hipmi",
|
||||
"version": "1.5.40",
|
||||
"version": "1.6.9",
|
||||
"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"
|
||||
},
|
||||
|
||||
@@ -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 {
|
||||
|
||||
@@ -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();
|
||||
// });
|
||||
|
||||
@@ -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"]
|
||||
}
|
||||
}
|
||||
}]
|
||||
]
|
||||
60
scripts/postbuild.js
Normal file
60
scripts/postbuild.js
Normal file
@@ -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!');
|
||||
@@ -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,
|
||||
|
||||
@@ -50,7 +50,5 @@ async function DELETE(
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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,
|
||||
|
||||
@@ -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: {
|
||||
|
||||
@@ -64,7 +64,5 @@ export async function POST(req: Request) {
|
||||
},
|
||||
{ status: 500 },
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -42,7 +42,5 @@ export async function GET(
|
||||
{ success: false, message: "Gagal mendapatkan data" },
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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(
|
||||
{
|
||||
|
||||
@@ -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();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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,
|
||||
|
||||
@@ -33,7 +33,5 @@ export async function GET(request: Request) {
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -35,7 +35,5 @@ export async function GET(request: Request) {
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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(
|
||||
{
|
||||
|
||||
@@ -10,6 +10,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 { POST, GET };
|
||||
|
||||
@@ -154,7 +155,7 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
const { searchParams } = new URL(request.url);
|
||||
const category = searchParams.get("category");
|
||||
const page = searchParams.get("page");
|
||||
const takeData = 10;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = Number(page) * takeData - takeData;
|
||||
|
||||
console.log("[CATEGORY]", category);
|
||||
@@ -174,6 +175,7 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
id: true,
|
||||
createdAt: true,
|
||||
nominalCair: true,
|
||||
title: true,
|
||||
},
|
||||
});
|
||||
} else if (category === "get-one") {
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import _ from "lodash";
|
||||
import { NextResponse } from "next/server";
|
||||
import { prisma } from "@/lib";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET };
|
||||
|
||||
@@ -9,7 +10,7 @@ async function GET(req: Request, { params }: { params: { id: string } }) {
|
||||
const { searchParams } = new URL(req.url);
|
||||
const page = searchParams.get("page");
|
||||
const status = searchParams.get("status");
|
||||
const takeData = 10;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = Number(page) * takeData - takeData;
|
||||
const fixStatus = _.startCase(status || "");
|
||||
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import _ from "lodash";
|
||||
import { NextResponse } from "next/server";
|
||||
import prisma from "@/lib/prisma";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET };
|
||||
|
||||
@@ -9,11 +10,10 @@ async function GET(request: Request) {
|
||||
const category = searchParams.get("category");
|
||||
const page = searchParams.get("page");
|
||||
const search = searchParams.get("search");
|
||||
const takeData = 10;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = Number(page) * takeData - takeData;
|
||||
console.log("[CATEGORY]", category);
|
||||
let fixData;
|
||||
|
||||
|
||||
try {
|
||||
if (category === "dashboard") {
|
||||
const publish = await prisma.donasi.count({
|
||||
@@ -48,7 +48,7 @@ async function GET(request: Request) {
|
||||
where: {
|
||||
active: true,
|
||||
},
|
||||
}
|
||||
},
|
||||
);
|
||||
|
||||
const categoryDonation = countCategoryDonation.length;
|
||||
@@ -68,7 +68,6 @@ async function GET(request: Request) {
|
||||
},
|
||||
});
|
||||
|
||||
console.log("[STATUS]", checkStatus);
|
||||
|
||||
if (!checkStatus) {
|
||||
return NextResponse.json(
|
||||
@@ -77,7 +76,7 @@ async function GET(request: Request) {
|
||||
message: "Failed to get data donation",
|
||||
reason: "Status not found",
|
||||
},
|
||||
{ status: 500 }
|
||||
{ status: 500 },
|
||||
);
|
||||
}
|
||||
|
||||
@@ -100,6 +99,12 @@ async function GET(request: Request) {
|
||||
select: {
|
||||
id: true,
|
||||
title: true,
|
||||
target: true,
|
||||
DonasiMaster_Durasi: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
Author: {
|
||||
select: {
|
||||
id: true,
|
||||
@@ -109,7 +114,6 @@ async function GET(request: Request) {
|
||||
},
|
||||
});
|
||||
|
||||
console.log("[LIST]", fixData);
|
||||
}
|
||||
|
||||
return NextResponse.json(
|
||||
@@ -118,7 +122,7 @@ async function GET(request: Request) {
|
||||
message: `Success get data donation ${category}`,
|
||||
data: fixData,
|
||||
},
|
||||
{ status: 200 }
|
||||
{ status: 200 },
|
||||
);
|
||||
} catch (error) {
|
||||
console.error("Error get data donation:", error);
|
||||
@@ -128,7 +132,7 @@ async function GET(request: Request) {
|
||||
message: "Failed to get data donation",
|
||||
reason: (error as Error).message,
|
||||
},
|
||||
{ status: 500 }
|
||||
{ status: 500 },
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,9 +1,15 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
import prisma from "@/lib/prisma";
|
||||
import { NextResponse } from "next/server";
|
||||
|
||||
export { GET };
|
||||
|
||||
async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
const { searchParams } = new URL(request.url);
|
||||
const page = Number(searchParams.get("page")) || 1;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
|
||||
try {
|
||||
const { id } = params;
|
||||
|
||||
@@ -12,6 +18,7 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
eventId: id,
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
eventId: true,
|
||||
userId: true,
|
||||
isPresent: true,
|
||||
@@ -35,6 +42,8 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
},
|
||||
},
|
||||
},
|
||||
take: page ? takeData : undefined,
|
||||
skip: page ? skipData : undefined,
|
||||
});
|
||||
|
||||
return NextResponse.json(
|
||||
|
||||
@@ -1,7 +1,8 @@
|
||||
import _ from "lodash";
|
||||
import { prisma } from "@/lib";
|
||||
import { NextResponse } from "next/server";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
import _ from "lodash";
|
||||
import moment from "moment";
|
||||
import { NextResponse } from "next/server";
|
||||
|
||||
export { GET };
|
||||
|
||||
@@ -11,13 +12,12 @@ async function GET(request: Request) {
|
||||
const fixStatus = _.startCase(category || "");
|
||||
|
||||
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")) || 1;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
let fixData;
|
||||
|
||||
console.log("[CATEGORY]", category);
|
||||
// console.log("[FIX STATUS]", fixStatus);
|
||||
|
||||
|
||||
try {
|
||||
if (category === "dashboard") {
|
||||
@@ -71,7 +71,6 @@ async function GET(request: Request) {
|
||||
typeOfEvent,
|
||||
};
|
||||
} else if (category === "history") {
|
||||
console.log("[HISTORY HERE]");
|
||||
|
||||
const data = await prisma.event.findMany({
|
||||
take: page ? takeData : undefined,
|
||||
@@ -151,21 +150,22 @@ async function GET(request: Request) {
|
||||
},
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
title: true,
|
||||
tanggal: true,
|
||||
Author: {
|
||||
select: {
|
||||
id: true,
|
||||
username: true,
|
||||
Profile: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
id: true,
|
||||
title: true,
|
||||
tanggal: true,
|
||||
tanggalSelesai: true,
|
||||
Author: {
|
||||
select: {
|
||||
id: true,
|
||||
username: true,
|
||||
Profile: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
fixData = data;
|
||||
@@ -177,7 +177,7 @@ async function GET(request: Request) {
|
||||
message: `Success get data event ${category}`,
|
||||
data: fixData,
|
||||
},
|
||||
{ status: 200 }
|
||||
{ status: 200 },
|
||||
);
|
||||
} catch (error) {
|
||||
console.log(`[ERROR GET DATA EVENT: ${category}]`, error);
|
||||
@@ -187,7 +187,7 @@ async function GET(request: Request) {
|
||||
message: `Error get data event ${category}`,
|
||||
reason: (error as Error).message,
|
||||
},
|
||||
{ status: 500 }
|
||||
{ status: 500 },
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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 {
|
||||
|
||||
@@ -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 },
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { prisma } from "@/lib";
|
||||
import _ from "lodash";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET };
|
||||
|
||||
@@ -9,7 +10,7 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
|
||||
const category = searchParams.get("category");
|
||||
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;
|
||||
@@ -79,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,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
@@ -139,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) => {
|
||||
@@ -151,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,
|
||||
@@ -193,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) => {
|
||||
@@ -205,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(
|
||||
{
|
||||
@@ -216,7 +249,7 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
|
||||
message: "Invalid category",
|
||||
reason: "Invalid category",
|
||||
},
|
||||
{ status: 400 }
|
||||
{ status: 400 },
|
||||
);
|
||||
}
|
||||
|
||||
@@ -226,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(
|
||||
@@ -235,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 },
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,19 +1,20 @@
|
||||
import _ from "lodash";
|
||||
import { NextResponse } from "next/server";
|
||||
import prisma from "@/lib/prisma";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export async function GET(
|
||||
request: Request,
|
||||
{ params }: { params: { id: string } }
|
||||
{ params }: { params: { id: string } },
|
||||
) {
|
||||
try {
|
||||
let fixData;
|
||||
const { id } = params;
|
||||
const { searchParams } = new URL(request.url);
|
||||
const page = searchParams.get("page");
|
||||
const page = Number(searchParams.get("page"));
|
||||
const status = searchParams.get("status");
|
||||
const takeData = 10;
|
||||
const skipData = Number(page) * takeData - takeData;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
|
||||
const fixStatus = _.startCase(status ? status : "");
|
||||
|
||||
@@ -43,6 +44,7 @@ export async function GET(
|
||||
id: true,
|
||||
Author: true,
|
||||
StatusInvoice: true,
|
||||
nominal: true,
|
||||
},
|
||||
});
|
||||
|
||||
@@ -54,7 +56,7 @@ export async function GET(
|
||||
message: "Success get status transaksi",
|
||||
data: fixData,
|
||||
},
|
||||
{ status: 200 }
|
||||
{ status: 200 },
|
||||
);
|
||||
} catch (error) {
|
||||
console.error("Eror get status transaksi", error);
|
||||
@@ -64,7 +66,7 @@ export async function GET(
|
||||
message: "Error get status transaksi",
|
||||
reason: (error as Error).message,
|
||||
},
|
||||
{ status: 500 }
|
||||
{ status: 500 },
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import _ from "lodash";
|
||||
import { NextResponse } from "next/server";
|
||||
import { prisma } from "@/lib";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET };
|
||||
|
||||
@@ -9,12 +10,9 @@ async function GET(request: Request) {
|
||||
const category = searchParams.get("category");
|
||||
const search = searchParams.get("search");
|
||||
const page = searchParams.get("page");
|
||||
const takeData = 10;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = Number(page) * takeData - takeData;
|
||||
|
||||
console.log("[CATEGORY]", category);
|
||||
console.log("[PAGE]", page);
|
||||
|
||||
let fixData;
|
||||
try {
|
||||
if (category === "dashboard") {
|
||||
@@ -49,7 +47,6 @@ async function GET(request: Request) {
|
||||
};
|
||||
} else {
|
||||
const fixCategoryToStatus = _.startCase(category || "");
|
||||
console.log("[STATUS]", fixCategoryToStatus);
|
||||
|
||||
const data = await prisma.investasi.findMany({
|
||||
take: page ? takeData : undefined,
|
||||
@@ -70,6 +67,12 @@ async function GET(request: Request) {
|
||||
select: {
|
||||
id: true,
|
||||
title: true,
|
||||
targetDana: true,
|
||||
MasterPencarianInvestor: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
author: {
|
||||
select: {
|
||||
id: true,
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import _ from "lodash";
|
||||
import { NextResponse } from "next/server";
|
||||
import { prisma } from "@/lib";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET };
|
||||
|
||||
@@ -8,6 +9,9 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
|
||||
const { searchParams } = new URL(request.url);
|
||||
const category = searchParams.get("category");
|
||||
const search = searchParams.get("search");
|
||||
const page = Number(searchParams.get("page")) || 1;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
let fixData;
|
||||
|
||||
try {
|
||||
@@ -66,6 +70,8 @@ async function GET(request: Request, { params }: { params: { name: string } }) {
|
||||
title: true,
|
||||
Author: true,
|
||||
},
|
||||
take: page ? takeData : undefined,
|
||||
skip: page ? skipData : undefined,
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
@@ -1,14 +1,22 @@
|
||||
import { prisma } from "@/lib";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
import { NextResponse } from "next/server";
|
||||
|
||||
export { GET, POST };
|
||||
|
||||
async function GET() {
|
||||
async function GET(request: Request) {
|
||||
try {
|
||||
const { searchParams } = new URL(request.url);
|
||||
const page = Number(searchParams.get("page"));
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
|
||||
const data = await prisma.masterBank.findMany({
|
||||
orderBy: {
|
||||
updatedAt: "desc",
|
||||
},
|
||||
take: page ? takeData : undefined,
|
||||
skip: page ? skipData : undefined,
|
||||
});
|
||||
|
||||
return NextResponse.json(
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { prisma } from "@/lib";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
import { NextResponse } from "next/server";
|
||||
|
||||
export { GET, PUT };
|
||||
|
||||
@@ -11,6 +12,10 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
const category = searchParams.get("category");
|
||||
const subBidangId = searchParams.get("subBidangId");
|
||||
|
||||
const page = Number(searchParams.get("page")) || 1;
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
|
||||
if (category === "all") {
|
||||
const bidang = await prisma.masterBidangBisnis.findUnique({
|
||||
where: {
|
||||
@@ -45,6 +50,16 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
},
|
||||
});
|
||||
|
||||
fixData = subBidang;
|
||||
} else if (category === "only-sub-bidang") {
|
||||
const subBidang = await prisma.masterSubBidangBisnis.findMany({
|
||||
where: {
|
||||
masterBidangBisnisId: id,
|
||||
},
|
||||
take: takeData,
|
||||
skip: skipData,
|
||||
});
|
||||
|
||||
fixData = subBidang;
|
||||
}
|
||||
|
||||
@@ -71,9 +86,6 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||
const { searchParams } = new URL(request.url);
|
||||
const category = searchParams.get("category");
|
||||
|
||||
console.log("category", category);
|
||||
console.log("data", data);
|
||||
|
||||
try {
|
||||
if (category === "bidang") {
|
||||
const updateData = await prisma.masterBidangBisnis.update({
|
||||
|
||||
@@ -2,15 +2,24 @@ import { NextResponse } from "next/server";
|
||||
import { prisma } from "@/lib";
|
||||
import _ from "lodash";
|
||||
import { Prisma } from "@prisma/client";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET, POST };
|
||||
|
||||
async function GET(request: Request) {
|
||||
try {
|
||||
const { searchParams } = new URL(request.url);
|
||||
const page = Number(searchParams.get("page"));
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
|
||||
|
||||
const data = await prisma.masterBidangBisnis.findMany({
|
||||
orderBy: {
|
||||
createdAt: "asc",
|
||||
},
|
||||
take: page ? takeData : undefined,
|
||||
skip: page ? skipData : undefined,
|
||||
});
|
||||
|
||||
return NextResponse.json({
|
||||
|
||||
@@ -1,10 +1,14 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { NextRequest, NextResponse } from "next/server";
|
||||
import prisma from "@/lib/prisma";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET, POST };
|
||||
|
||||
async function GET(request: Request) {
|
||||
async function GET(request: NextRequest) {
|
||||
const { searchParams } = new URL(request.url);
|
||||
const page = Number(searchParams.get("page"));
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
// const category = searchParams.get("category");
|
||||
let fixData;
|
||||
|
||||
@@ -13,6 +17,8 @@ async function GET(request: Request) {
|
||||
orderBy: {
|
||||
createdAt: "asc",
|
||||
},
|
||||
take: page ? takeData : undefined,
|
||||
skip: page ? skipData : undefined,
|
||||
});
|
||||
|
||||
// if (category === "category") {
|
||||
|
||||
@@ -1,14 +1,22 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { NextRequest, NextResponse } from "next/server";
|
||||
import prisma from "@/lib/prisma";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET, POST };
|
||||
|
||||
async function GET(request: Request) {
|
||||
async function GET(request: NextRequest) {
|
||||
try {
|
||||
const searchParams = request.nextUrl.searchParams;
|
||||
const page = Number(searchParams.get("page"));
|
||||
const takeData = PAGINATION_DEFAULT_TAKE;
|
||||
const skipData = page * takeData - takeData;
|
||||
|
||||
const data = await prisma.eventMaster_TipeAcara.findMany({
|
||||
orderBy: {
|
||||
updatedAt: "desc",
|
||||
},
|
||||
take: page ? takeData : undefined,
|
||||
skip: page ? skipData : undefined,
|
||||
});
|
||||
|
||||
return NextResponse.json({
|
||||
|
||||
@@ -2,6 +2,7 @@ import _ from "lodash";
|
||||
import moment from "moment";
|
||||
import { NextResponse } from "next/server";
|
||||
import { prisma } from "@/lib";
|
||||
import { PAGINATION_DEFAULT_TAKE } from "@/lib/constans-value/constansValue";
|
||||
|
||||
export { GET };
|
||||
|
||||
@@ -12,7 +13,7 @@ async function GET(request: Request) {
|
||||
|
||||
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;
|
||||
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import prisma from "@/lib/prisma"
|
||||
|
||||
export async function GET(
|
||||
request: Request,
|
||||
|
||||
@@ -28,7 +28,5 @@ async function GET() {
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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 },
|
||||
);
|
||||
}
|
||||
|
||||
@@ -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",
|
||||
|
||||
@@ -131,7 +131,5 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -40,7 +40,5 @@ export async function GET(request: Request) {
|
||||
status: 500,
|
||||
}
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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: {
|
||||
|
||||
@@ -78,7 +78,5 @@ export async function GET(request: Request) {
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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(
|
||||
{
|
||||
|
||||
@@ -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 }
|
||||
|
||||
@@ -104,7 +104,5 @@ async function PUT(request: Request) {
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -77,7 +77,5 @@ async function POST(request: Request) {
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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,15 +82,46 @@ 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: "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",
|
||||
},
|
||||
{ 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
|
||||
}
|
||||
|
||||
@@ -125,7 +125,5 @@ export async function GET(request: Request) {
|
||||
status: 500,
|
||||
}
|
||||
);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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 };
|
||||
|
||||
@@ -37,6 +37,5 @@ export async function AdminDonasi_getOneById(id: string) {
|
||||
},
|
||||
});
|
||||
|
||||
await prisma.$disconnect();
|
||||
return res;
|
||||
}
|
||||
|
||||
@@ -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,
|
||||
|
||||
@@ -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",
|
||||
|
||||
@@ -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" };
|
||||
}
|
||||
|
||||
@@ -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);
|
||||
}}
|
||||
/>
|
||||
|
||||
|
||||
@@ -9,9 +9,6 @@ export async function donasi_checkStatus({ id }: { id: string }) {
|
||||
},
|
||||
});
|
||||
|
||||
await prisma.$disconnect();
|
||||
|
||||
|
||||
if (checkStatus?.donasiMaster_StatusDonasiId == "2") return true;
|
||||
return false;
|
||||
|
||||
|
||||
@@ -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>
|
||||
|
||||
@@ -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;
|
||||
};
|
||||
|
||||
@@ -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),
|
||||
};
|
||||
|
||||
188
src/lib/prisma-retry.ts
Normal file
188
src/lib/prisma-retry.ts
Normal file
@@ -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 };
|
||||
@@ -1,44 +1,54 @@
|
||||
import { PrismaClient } from "@prisma/client";
|
||||
|
||||
// Deklarasikan variabel global untuk menandai apakah listener sudah ditambahkan
|
||||
/**
|
||||
* 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 {
|
||||
var prisma: PrismaClient;
|
||||
var prismaListenersAdded: boolean; // Flag untuk menandai listener
|
||||
// eslint-disable-next-line no-var
|
||||
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'],
|
||||
// Konfigurasi connection pool via parameter query DATABASE_URL:
|
||||
// connection_limit=10&pool_timeout=20&connect_timeout=10
|
||||
const prisma =
|
||||
globalThis.prisma ??
|
||||
new PrismaClient({
|
||||
log:
|
||||
process.env.NODE_ENV === "development"
|
||||
? ["error", "warn"]
|
||||
: ["error"],
|
||||
datasources: {
|
||||
db: {
|
||||
url: process.env.DATABASE_URL,
|
||||
},
|
||||
},
|
||||
});
|
||||
} else {
|
||||
if (!global.prisma) {
|
||||
global.prisma = new PrismaClient({
|
||||
log: ['error', 'warn', 'info', 'query'], // More verbose logging in development
|
||||
});
|
||||
}
|
||||
prisma = global.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;
|
||||
}
|
||||
|
||||
// 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);
|
||||
});
|
||||
/**
|
||||
* 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");
|
||||
}
|
||||
|
||||
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;
|
||||
// Register shutdown handlers (hanya di environment Node.js)
|
||||
if (typeof process !== "undefined") {
|
||||
process.on("SIGINT", gracefulShutdown);
|
||||
process.on("SIGTERM", gracefulShutdown);
|
||||
}
|
||||
|
||||
export default prisma;
|
||||
|
||||
@@ -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);
|
||||
|
||||
4
types/env.d.ts
vendored
4
types/env.d.ts
vendored
@@ -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;
|
||||
}
|
||||
}
|
||||
|
||||
204
zCoba.js
204
zCoba.js
@@ -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()
|
||||
})
|
||||
Reference in New Issue
Block a user