Update app.js

app.js

@@ -5,11 +5,9 @@ import os from 'os';
 
 const totalCpus = os.cpus().length;
 
-// --- মাল্টি-কোর ক্লাস্টার সেটআপ ---
 if (cluster.isPrimary) {
   console.log(`Primary Master Process ${process.pid} is running`);
   
-  // প্রতিটি CPU কোরের জন্য একটি করে ওয়ার্কার প্রসেস তৈরি হবে
   for (let i = 0; i < totalCpus; i++) {
     cluster.fork();
   }
@@ -20,14 +18,13 @@ if (cluster.isPrimary) {
   });
 
 } else {
-  // ওয়ার্কার প্রসেস - যা মূল API হ্যান্ডেল করবে
   const app = express();
   app.use(express.json());
 
   const PORT = process.env.PORT || 7860;
   const BOT_TOKEN = process.env.BOT_TOKEN;
 
-  // --- ফায়ারবেস এডমিন ১ ও ২ ইনিশিয়ালাইজেশন ---
+  // --- ফায়ারবেস ইনিশিয়ালাইজেশন ---
   let app1, app2;
   try {
     const firebaseAdmin1 = JSON.parse(process.env.FIREBASE_ADMIN_1 || '{}');
@@ -48,19 +45,35 @@ if (cluster.isPrimary) {
     console.error('Firebase initialization error:', error.message);
   }
 
-  // --- ডাটা ভ্যালিডেশন ফাংশন (একই ফাইলে) ---
+  // --- কাস্টম রিকোয়েস্ট-রেসপন্স লগার মিডলওয়্যার ---
+  app.use((req, res, next) => {
+    const startTime = Date.now();
+    
+    // রেসপন্স শেষ হলে এই ফাংশনটি রান করবে
+    res.on('finish', () => {
+      const duration = Date.now() - startTime;
+      console.log(`\n=================== REQUEST LOG [Worker: ${process.pid}] ===================`);
+      console.log(`[${new Date().toISOString()}] ${req.method} ${req.originalUrl}`);
+      console.log(`➜ Incoming Body:`, JSON.stringify(req.body || {}));
+      console.log(`➜ HTTP Status: ${res.statusCode}`);
+      console.log(`➜ Execution Time: ${duration}ms`);
+      console.log(`=================================================================\n`);
+    });
+    
+    next();
+  });
+
+  // --- ডাটা ভ্যালিডেশন ফাংশন ---
   function verifyIntegrity(intdata, uid, fullName) {
     if (!intdata || !uid || !fullName) return false;
-    
-    // আপনার আইডিয়া অনুযায়ী BOT_TOKEN এবং intdata ম্যাচিং বা ডিক্রিপশন লজিক এখানে হবে
-    // সাময়িকভাবে ভ্যালিডেশন পাস করানোর জন্য true দেওয়া হলো
     return true; 
   }
 
   // --- এপিআই এন্ডপয়েন্ট সমূহ ---
 
-  // ১. /health এন্ডপয়েন্ট (যেকোনো মেথড আসলে জাস্ট ওকে ব্যাক করবে)
+  // ১. /health এন্ডপয়েন্ট
   app.all('/health', (req, res) => {
+    console.log(`[Worker ${process.pid}] Processing /health request...`);
     res.status(200).json({ status: "OK", message: "Server is healthy" });
   });
 
@@ -68,27 +81,36 @@ if (cluster.isPrimary) {
   app.post('/profile', async (req, res) => {
     const { intdata, uid, full_name } = req.body;
 
-    // টোকেন ও ডাটা ভ্যালিডেশন চেক
+    console.log(`[Worker ${process.pid}] Processing /profile for UID: ${uid}`);
+
+    // ভ্যালিডেশন চেক
     if (!verifyIntegrity(intdata, uid, full_name)) {
+      console.log(`[Worker ${process.pid}] Validation FAILED for UID: ${uid}`);
       return res.status(400).json({ error: "Bad Request: Integrity check failed" });
     }
 
     let responseData = {};
 
     try {
-      // লজিক ১: FIREBASE_ADMIN_1 থেকে database/withdraw/{uid} আনা
+      // কাজের ধাপ ১: DB 1 থেকে উইথড্র ডাটা চেক
+      console.log(`[Worker ${process.pid}] Fetching withdraw data from DB_1 for UID: ${uid}`);
       const db1 = admin.database(app1);
       const snapshot1 = await db1.ref(`database/withdraw/${uid}`).once('value');
       
       if (snapshot1.exists()) {
         responseData.withdraw = snapshot1.val();
+        console.log(`[Worker ${process.pid}] Withdraw data FOUND for UID: ${uid}`);
+      } else {
+        console.log(`[Worker ${process.pid}] No withdraw data found for UID: ${uid}`);
       }
 
-      // জিক ২: FIREBASE_ADMIN_2 থেকে user/{uid} এর সব ডাটা আনা
+      // কাজের ধাপ ২: DB 2 থেকে ইউজার ডাটা চেক
+      console.log(`[Worker ${process.pid}] Fetching user info from DB_2 for UID: ${uid}`);
       const db2 = admin.database(app2);
       const snapshot2 = await db2.ref(`user/${uid}`).once('value');
       
       responseData.user_info = snapshot2.exists() ? snapshot2.val() : {};
+      console.log(`[Worker ${process.pid}] User info processed successfully for UID: ${uid}`);
 
       // ফাইনাল রেসপন্স পাঠানো
       return res.status(200).json({
@@ -97,6 +119,7 @@ if (cluster.isPrimary) {
       });
 
     } catch (error) {
+      console.error(`[Worker ${process.pid}] Error processing profile:`, error.message);
       return res.status(500).json({
         error: "Internal Server Error",
         details: error.message