56 lines
1.4 KiB
TypeScript
56 lines
1.4 KiB
TypeScript
import { PrismaClient } from "@prisma/client";
|
|
|
|
// Deklarasikan variabel global untuk menandai apakah listener sudah ditambahkan
|
|
declare global {
|
|
var prisma: PrismaClient;
|
|
var prismaListenersAdded: boolean; // Flag untuk menandai listener
|
|
}
|
|
|
|
let prisma: PrismaClient;
|
|
|
|
if (process.env.NODE_ENV === "production") {
|
|
prisma = new PrismaClient({
|
|
// Reduce logging in production to improve performance
|
|
log: ['error', 'warn'],
|
|
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
|
|
datasources: {
|
|
db: {
|
|
url: process.env.DATABASE_URL,
|
|
},
|
|
},
|
|
});
|
|
}
|
|
prisma = global.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);
|
|
});
|
|
|
|
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;
|
|
}
|
|
|
|
export default prisma;
|
|
export { prisma };
|