Create app.js

app.js

@@ -0,0 +1,213 @@
+const express = require('express');
+const admin = require('firebase-admin');
+
+const app = express();
+app.use(express.json());
+
+// ==========================================
+// ১. ফায়ারবেজ মাল্টিপল অ্যাডমিন সেটআপ
+// ==========================================
+// Note: Environment Variable এ FIREBASE_ADMIN_1, FIREBASE_ADMIN_3, FIREBASE_ADMIN_4 এবং 
+// তাদের নিজ নিজ ডাটাবেজ URL (FIREBASE_DB_URL_1, 3, 4) থাকতে হবে।
+const initFirebase = (envAdmin, envUrl, appName) => {
+    if (!process.env[envAdmin] || !process.env[envUrl]) {
+        console.warn(`Warning: ${envAdmin} or ${envUrl} is missing.`);
+        return null;
+    }
+    return admin.initializeApp({
+        credential: admin.credential.cert(JSON.parse(process.env[envAdmin])),
+        databaseURL: process.env[envUrl]
+    }, appName);
+};
+
+// অ্যাপগুলো ইনিশিয়ালাইজ করা হচ্ছে
+const app1 = initFirebase('FIREBASE_ADMIN_1', 'FIREBASE_DB_URL_1', 'Admin1');
+// Admin 2 এর কথা লজিকে নেই, তাই ইনিশিয়ালাইজ করলাম না। প্রয়োজন হলে একই নিয়মে করতে পারবে।
+const app3 = initFirebase('FIREBASE_ADMIN_3', 'FIREBASE_DB_URL_3', 'Admin3');
+const app4 = initFirebase('FIREBASE_ADMIN_4', 'FIREBASE_DB_URL_4', 'Admin4');
+
+const db1 = app1 ? app1.database() : null;
+const db3 = app3 ? app3.database() : null;
+const db4 = app4 ? app4.database() : null;
+
+// ==========================================
+// ২. হেলথ চেক রাউটস (যেকোনো রিকোয়েস্ট)
+// ==========================================
+const healthHandler = (req, res) => {
+    res.send('Ok, yes, done');
+};
+app.all('/health', healthHandler);
+app.all('/ch', healthHandler);
+app.all('/unps', healthHandler);
+
+// ==========================================
+// ৩. মিডলওয়্যার: শুধুমাত্র POST রিকোয়েস্ট পারমিট করা
+// ==========================================
+const checkPostMethod = (req, res, next) => {
+    if (req.method !== 'POST') {
+        return res.status(405).json({ error: 'Method Not Allowed. Only POST is accepted.' });
+    }
+    next();
+};
+
+// ==========================================
+// ৪. API: ক্রিয়েট অ্যাকাউন্ট (/creataccoumt)
+// ==========================================
+app.post('/creataccoumt', checkPostMethod, async (req, res) => {
+    const { user_id, refer_id, name, username, profile_pic_url } = req.body;
+
+    if (!user_id) return res.status(400).json({ error: 'user_id is required' });
+
+    try {
+        const userRef = db1.ref('user').child(user_id);
+        const snapshot = await userRef.once('value');
+
+        // যদি অ্যাকাউন্ট আগে থেকেই থাকে, রিকোয়েস্ট ক্লোজ
+        if (snapshot.exists()) {
+            return res.status(200).json({ message: 'Account already exists. No action taken.' });
+        }
+
+        // নতুন অ্যাকাউন্ট তৈরি
+        const newUserData = {
+            user_id,
+            refer_id: refer_id || null,
+            name: name || null,
+            username: username || null,
+            profile_pic_url: profile_pic_url || null,
+            balance: 0,
+            total_withdraw: 0,
+            total_withdraw_amount: 0,
+            join_date: admin.database.ServerValue.TIMESTAMP,
+            total_refer: 0
+        };
+        await userRef.set(newUserData);
+
+        // রেফারেল লজিক (যদি refer_id থাকে)
+        if (refer_id) {
+            const referUserRef = db1.ref('user').child(refer_id);
+            const referUserSnap = await referUserRef.once('value');
+
+            if (referUserSnap.exists()) {
+                // Admin 1 এ total refer +1 করা
+                await referUserRef.child('total_refer').transaction((currentValue) => {
+                    return (currentValue || 0) + 1;
+                });
+
+                // Admin 3 তে refer/uid এ ডাটা যুক্ত করা
+                const referListRef = db3.ref('refer').child(refer_id);
+                await referListRef.push(user_id); // নতুন user_id লিস্টে পুশ করা হলো
+            }
+        }
+
+        res.status(201).json({ message: 'Account created successfully!' });
+    } catch (error) {
+        console.error('Account Creation Error:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+});
+
+// ==========================================
+// ৫. API: উইথড্র মেইন ব্যালেন্স (/withdraw-main)
+// ==========================================
+app.post('/withdraw-main', checkPostMethod, async (req, res) => {
+    const { user_id, method, address, time, amount } = req.body;
+    const allowedMethods = ['bkash', 'mobile-gp', 'mobile-ar', 'mobile-ro', 'mobile-bl', 'mobile-tk', 'nagad', 'binance', 'usdt', 'ton'];
+
+    if (!user_id || !method || !address || !amount) {
+        return res.status(400).json({ error: 'Missing required fields' });
+    }
+
+    if (!allowedMethods.includes(method)) {
+        return res.status(400).json({ error: 'Invalid withdrawal method' });
+    }
+
+    try {
+        const userRef = db1.ref('user').child(user_id);
+        const snapshot = await userRef.once('value');
+
+        if (!snapshot.exists()) return res.status(404).json({ error: 'User not found' });
+
+        const userData = snapshot.val();
+        const currentBalance = Number(userData.balance || 0);
+        const requestAmount = Number(amount);
+
+        // ব্যালেন্স চেক
+        if (currentBalance < requestAmount) {
+            return res.status(400).json({ error: 'Insufficient balance' });
+        }
+
+        // Admin 1 থেকে ব্যালেন্স কাটা
+        await userRef.child('balance').set(currentBalance - requestAmount);
+
+        // Admin 3 তে পেন্ডিং উইথড্র লিস্টে যুক্ত করা
+        const pendingRef = db3.ref('withdrow/painding').child(user_id);
+        await pendingRef.push({
+            method,
+            address,
+            time: time || admin.database.ServerValue.TIMESTAMP,
+            amount: requestAmount,
+            status: 'pending'
+        });
+
+        res.status(200).json({ message: 'Withdrawal request successful' });
+    } catch (error) {
+        console.error('Withdraw Main Error:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+});
+
+// ==========================================
+// ৬. API: অ্যাড ব্যালেন্স উইথড্র (Admin 4 -> Admin 1)
+// ==========================================
+const adWithdrawPaths = [
+    '/withdraw-link-visit', '/withdraw-adsgram-1', '/withdraw-adsgram-2', 
+    '/withdraw-gigapub-1', '/withdraw-gigapub-2', '/withdraw-monetag-1', '/withdraw-monetag-2'
+];
+
+app.post(adWithdrawPaths, checkPostMethod, async (req, res) => {
+    const { user_id, amount, method } = req.body;
+
+    if (!user_id || !amount || method !== 'wallet') {
+        return res.status(400).json({ error: 'Invalid request. Method must be wallet and amount is required.' });
+    }
+
+    // Path থেকে অরিজিনাল অ্যাড নেটওয়ার্কের নাম বের করা (যেমন: link-visit)
+    const adNetworkName = req.path.replace('/withdraw-', ''); 
+    const requestAmount = Number(amount);
+
+    try {
+        // Admin 4 (আগের সার্ভার) এর নির্দিষ্ট পাথে ব্যালেন্স চেক
+        const adRef = db4.ref(adNetworkName).child(user_id);
+        const adSnapshot = await adRef.once('value');
+
+        if (!adSnapshot.exists()) return res.status(404).json({ error: 'No ad earnings found for this user' });
+
+        // ধরে নিচ্ছি আগের সার্ভারে ইউজারের মোট ব্যালেন্স `balance` নোডে আছে। 
+        // (যদি আগের সিস্টেমে ব্যালেন্স পুশ করা লিস্ট হিসেবে থাকে, তবে এখানে সেটা যোগ করার লজিক লিখতে হবে)
+        let adCurrentBalance = Number(adSnapshot.val().balance || 0); 
+
+        if (adCurrentBalance < requestAmount) {
+            return res.status(400).json({ error: 'Insufficient ad balance' });
+        }
+
+        // Admin 4 থেকে ব্যালেন্স মাইনাস করা
+        await adRef.child('balance').set(adCurrentBalance - requestAmount);
+
+        // Admin 1 এর মেইন ব্যালেন্সে ট্রান্সফার (যোগ) করা
+        const mainUserRef = db1.ref('user').child(user_id);
+        await mainUserRef.child('balance').transaction((currentMainBalance) => {
+            return (currentMainBalance || 0) + requestAmount;
+        });
+
+        res.status(200).json({ message: `Success! ${requestAmount} transferred to main balance from ${adNetworkName}` });
+    } catch (error) {
+        console.error('Ad Withdraw Error:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+});
+
+// সার্ভার স্টার্ট
+const PORT = process.env.PORT || 7860;
+app.listen(PORT, () => {
+    console.log(`Server is running on port ${PORT}`);
+});