Update server.js

server.js

@@ -9,72 +9,81 @@ dotenv.config();
 // إعداد ضغط البيانات (MessagePack)
 const packr = new Packr();
 
-// إعداد قاعدة بيانات Turso (يتم جلب الروابط من المتغيرات البيئية بأمان)
+// إعداد قاعدة بيانات Turso (احتياطياً للمستقبل)
 const db = createClient({
     url: process.env.TURSO_URL || 'file:local.db',
     authToken: process.env.TURSO_AUTH_TOKEN || ''
 });
 
-// إعدادات العوالم
 const MAX_PLAYERS_PER_WORLD = 30;
-const DISCONNECT_GRACE_PERIOD = 60 * 1000; // 60 ثانية فقط
+const DISCONNECT_GRACE_PERIOD = 60 * 1000;
+
+// خوارزمية توليد قارات بكسلية (Cellular Automata)
+function generatePixelMap(width, height) {
+    const grid = new Uint8Array(width * height);
+    // عشوائية أولية
+    for (let i = 0; i < grid.length; i++) {
+        grid[i] = Math.random() > 0.55 ? 1 : 0; // 1 يابسة، 0 ماء
+    }
+    // تنعيم لإنشاء قارات
+    for (let iter = 0; iter < 4; iter++) {
+        const newGrid = new Uint8Array(width * height);
+        for (let y = 0; y < height; y++) {
+            for (let x = 0; x < width; x++) {
+                let neighbors = 0;
+                for (let dy = -1; dy <= 1; dy++) {
+                    for (let dx = -1; dx <= 1; dx++) {
+                        if (dx === 0 && dy === 0) continue;
+                        let nx = x + dx, ny = y + dy;
+                        if (nx >= 0 && nx < width && ny >= 0 && ny < height) {
+                            neighbors += grid[ny * width + nx];
+                        }
+                    }
+                }
+                // قواعد الحياة للقارات
+                newGrid[y * width + x] = neighbors > 4 || (neighbors === 4 && grid[y * width + x]) ? 1 : 0;
+            }
+        }
+        for (let i = 0; i < grid.length; i++) grid[i] = newGrid[i];
+    }
+    return grid;
+}
 
 class World {
     constructor(id) {
         this.id = id;
-        this.players = new Map(); // RAM is the source of truth
-        this.territories = new Map();
-        this.isDirty = false; // لمعرفة هل نحتاج للحفظ في Turso
-        this.tickRate = 10; // يبدأ بـ 10 TPS
-        this.activeEvents = 0;
+        this.players = new Map();
+        
+        // إعداد الخريطة البكسلية (مثلاً 250x250 بكسل/مربع)
+        this.mapWidth = 250;
+        this.mapHeight = 250;
+        this.mapGrid = generatePixelMap(this.mapWidth, this.mapHeight);
     }
 
     get playerCount() {
-        // حساب اللاعبين المتصلين فقط
         let count = 0;
         this.players.forEach(p => { if (p.online) count++; });
         return count;
     }
 
-    // Tick Rate ديناميكي
-    updateTickRate() {
-        if (this.activeEvents > 10) this.tickRate = 60;
-        else if (this.activeEvents > 0) this.tickRate = 30;
-        else this.tickRate = 10;
-    }
-
     addPlayer(ws, playerData) {
         this.players.set(ws.id, playerData);
-        this.isDirty = true;
     }
 
     removePlayer(wsId) {
         this.players.delete(wsId);
-        this.isDirty = true;
     }
 }
 
 // إنشاء 5 عوالم
 const worlds = [1, 2, 3, 4, 5].map(id => new World(id));
 
-// نظام الحفظ الاقتصادي (كل 5 دقائق إذا حدث تغيير)
-setInterval(() => {
-    worlds.forEach(world => {
-        if (world.isDirty) {
-            console.log(`Saving World ${world.id} to Turso...`);
-            // هنا كود الحفظ في Turso
-            world.isDirty = false;
-        }
-    });
-}, 5 * 60 * 1000);
-
 const app = uWS.App().ws('/*', {
     compression: uWS.SHARED_COMPRESSOR,
     maxPayloadLength: 16 * 1024 * 1024,
-    idleTimeout: 60, // فصل اللاعب إذا لم يرسل شيء
+    idleTimeout: 60,
 
     upgrade: (res, req, context) => {
-        // التحقق من الأمان (IP, Headers) لمنع الـ Spam
         const ip = res.getRemoteAddressAsText();
         res.upgrade(
             { id: Math.random().toString(36).substr(2, 9), ip },
@@ -87,31 +96,19 @@ const app = uWS.App().ws('/*', {
 
     open: (ws) => {
         ws.isAlive = true;
-        // إرسال حالة العوالم فور الاتصال
         const worldStats = worlds.map(w => ({ id: w.id, players: w.playerCount }));
         ws.send(packr.pack({ type: 'SERVER_LIST', data: worldStats }), true);
     },
 
     message: (ws, message, isBinary) => {
         try {
-            // فك التشفير (نقبل فقط Binary MessagePack)
             if (!isBinary) return; 
             const data = packr.unpack(message);
 
-            // الخادم لا يثق بالعميل (Authoritative)
             switch (data.type) {
                 case 'JOIN_WORLD':
                     handleJoinWorld(ws, data.worldId, data.playerName);
                     break;
-                case 'CLAIM_TERRITORY':
-                    handleClaimTerritory(ws, data.territoryId);
-                    break;
-                case 'BUY_ITEM':
-                    handleBuyItem(ws, data.itemId, data.amount);
-                    break;
-                case 'LAUNCH_ATTACK':
-                    handleAttack(ws, data.targetId, data.weaponType, data.amount);
-                    break;
                 case 'PING':
                     ws.send(packr.pack({ type: 'PONG' }), true);
                     break;
@@ -129,25 +126,14 @@ const app = uWS.App().ws('/*', {
         if (ws.worldId) {
             const world = worlds.find(w => w.id === ws.worldId);
             if (world && world.players.has(ws.id)) {
-                // تعيين اللاعب كـ Offline فوراً حتى لا يظهر في العدد
                 const player = world.players.get(ws.id);
                 player.online = false;
-                world.isDirty = true;
 
-                // حفظ مؤقت لمدة 60 ثانية قبل الحذف النهائي
                 setTimeout(() => {
                     const checkPlayer = world.players.get(ws.id);
                     if (checkPlayer && !checkPlayer.online) {
-                        // اللاعب لم يعد، تفكيك دولته وحذف بياناته
                         world.removePlayer(ws.id);
-                        
-                        // إزالة ألوانه من المقاطعات التي احتلها
-                        for (let [tId, pId] of world.territories.entries()) {
-                            if (pId === ws.id) {
-                                world.territories.delete(tId);
-                                broadcast(world, { type: 'TERRITORY_CLAIMED', tId: tId, color: '#1e1e28' }); // إعادة اللون الافتراضي
-                            }
-                        }
+                        broadcast(world, { type: 'PLAYER_REMOVED', id: ws.id });
                     }
                 }, DISCONNECT_GRACE_PERIOD);
             }
@@ -164,290 +150,36 @@ function handleJoinWorld(ws, worldId, playerName) {
         return;
     }
 
-    // تنظيف الاسم (أمان)
     const safeName = String(playerName).substring(0, 20).replace(/[^a-zA-Z0-9أ-ي]/g, '');
-    
     ws.worldId = worldId;
     ws.subscribe(`world-${worldId}`);
-    // إصلاح مشكلة الألوان الناقصة التي تجعل الدولة تبدو فارغة
     const color = `#${Math.floor(Math.random()*16777215).toString(16).padStart(6, '0')}`;
     
-    // إضافة بيانات الاقتصاد والجيش للاعب (تبدأ بـ 0 حتى يحتل أول منطقة)
     world.addPlayer(ws, { 
         id: ws.id, 
         name: safeName, 
         color: color, 
-        territories: [], 
-        online: true,
-        money: 0,
-        power: 0,
-        income: 0, // يبدأ بـ 0
-        armyIncome: 0, // يبدأ بـ 0
-        assets: {}, // الممتلكات
-        cooldowns: {} // لتتبع التهدئة (Spam Prevention)
+        online: true
     });
     
     ws.send(packr.pack({ type: 'JOIN_SUCCESS', worldId, color, name: safeName }), true);
     
-    // إرسال حالة الخريطة الحالية للاعب الجديد (لكي يرى اللاعبين الآخرين)
-    const worldState = [];
-    for (let [tId, pId] of world.territories.entries()) {
-        if (!pId.startsWith('CLAIMING_')) {
-            const owner = world.players.get(pId);
-            if (owner && owner.online) {
-                worldState.push({ tId, color: owner.color, name: owner.name, power: owner.power });
-            }
-        }
-    }
-    ws.send(packr.pack({ type: 'INIT_STATE', territories: worldState }), true);
+    // إرسال الخريطة البكسلية للعميل (عرض، طول، والمصفوفة)
+    ws.send(packr.pack({ 
+        type: 'MAP_DATA', 
+        width: world.mapWidth, 
+        height: world.mapHeight, 
+        grid: world.mapGrid 
+    }), true);
 
     broadcast(world, { type: 'PLAYER_JOINED', id: ws.id, name: safeName });
 }
 
-// بيانات المتجر في السيرفر (شراء مرة واحدة فقط لكل عنصر لمنع الاحتيال)
-const SHOP_DATA = {
-    // الاقتصاد
-    'farm': { cost: 0, income: 0.1, type: 'eco', max: 1, cd: 0 },
-    'mine': { cost: 5, income: 0.4, type: 'eco', max: 1, cd: 0 },
-    'shop1': { cost: 20, income: 2, type: 'eco', max: 1, cd: 0 },
-    'shop2': { cost: 100, income: 10, type: 'eco', max: 1, cd: 0 },
-    'iron': { cost: 300, income: 30, type: 'eco', max: 1, cd: 0 },
-    'glass': { cost: 600, income: 50, type: 'eco', max: 1, cd: 0 },
-    'steel': { cost: 1000, income: 70, type: 'eco', max: 1, cd: 0 },
-    'gold': { cost: 1500, income: 150, type: 'eco', max: 1, cd: 0 },
-    'car': { cost: 5000, income: 400, type: 'eco', max: 1, cd: 0 },
-    'plane': { cost: 20000, income: 1000, type: 'eco', max: 1, cd: 0 },
-    'gpu': { cost: 100000, income: 10000, type: 'eco', max: 1, cd: 0 },
-    
-    // العسكري
-    'soldier': { cost: 0.1, power: 1, type: 'mil', max: 1, cd: 0 },
-    'armor': { cost: 1, power: 10, type: 'mil', max: 1, cd: 0 },
-    'tank': { cost: 20, power: 250, type: 'mil', max: 1, cd: 0 },
-    'mlrs': { cost: 50, power: 700, type: 'mil', max: 1, cd: 0 },
-    'sam': { cost: 100, power: 1500, type: 'mil', max: 1, cd: 0 },
-    'aaa': { cost: 150, power: 2000, type: 'mil', max: 1, cd: 0 },
-    'fighter': { cost: 350, power: 5000, type: 'mil', max: 1, cd: 0 },
-    'attack_plane': { cost: 1000, power: 15000, type: 'mil', max: 1, cd: 0 },
-    'stealth': { cost: 2500, power: 40000, type: 'mil', max: 1, cd: 0 },
-    'bomber': { cost: 10000, power: 150000, type: 'mil', max: 1, cd: 0 },
-    'bm1': { cost: 1000, power: 20000, type: 'mil', max: 1, cd: 0 },
-    'bm2': { cost: 5000, power: 100000, type: 'mil', max: 1, cd: 0 },
-    'bm3': { cost: 15000, power: 300000, type: 'mil', max: 1, cd: 0 }
-};
-function handleBuyItem(ws, itemId, amount) {
-    const world = worlds.find(w => w.id === ws.worldId);
-    if (!world) return;
-    const player = world.players.get(ws.id);
-    if (!player) return;
-
-    // لا يمكن الشراء إذا لم يكن لديه دولة
-    if (player.territories.length === 0) {
-        ws.send(packr.pack({ type: 'ERROR', msg: 'يجب أن تحتل منطقة أولاً لتأسيس دولتك!' }), true);
-        return;
-    }
-
-    const item = SHOP_DATA[itemId];
-    if (!item) return;
-
-    // التحقق من الحد الأقصى للشراء في الدفعة الواحدة
-    if (item.maxBuy && amount > item.maxBuy) amount = item.maxBuy;
-
-    // التحقق من الحد الأقصى للمتلاك (مثل المزرعة 1 فقط)
-    if (item.max && (player.assets[itemId] || 0) + amount > item.max) {
-        ws.send(packr.pack({ type: 'ERROR', msg: `لا يمكنك امتلاك أكثر من ${item.max} من هذا العنصر` }), true);
-        return;
-    }
-
-    // التحقق من التهدئة (Cooldown) لمنع الـ Spam
-    const now = Date.now();
-    if (item.cd > 0) {
-        const lastBought = player.cooldowns[itemId] || 0;
-        if (now - lastBought < item.cd) {
-            const timeLeft = Math.ceil((item.cd - (now - lastBought)) / 60000);
-            ws.send(packr.pack({ type: 'ERROR', msg: `يجب الانتظار ${timeLeft} دقيقة لشراء هذا العنصر مجدداً` }), true);
-            return;
-        }
-    }
-
-    const totalCost = item.cost * amount;
-    
-    // التحقق من المال
-    if (player.money >= totalCost) {
-        player.money -= totalCost;
-        
-        if (!player.assets[itemId]) player.assets[itemId] = 0;
-        player.assets[itemId] += amount;
-
-        // تسجيل وقت الشراء للتهدئة
-        if (item.cd > 0) player.cooldowns[itemId] = now;
-
-        if (item.type === 'eco') {
-            player.income += (item.income * amount);
-        } else if (item.type === 'mil') {
-            player.power += (item.power * amount);
-            broadcast(world, { type: 'UPDATE_POWER', pId: player.id, power: player.power });
-        }
-
-        world.isDirty = true;
-        ws.send(packr.pack({ 
-            type: 'SYNC_STATS', 
-            money: player.money, 
-            power: player.power, 
-            income: player.income, 
-            armyIncome: player.armyIncome,
-            assets: player.assets
-        }), true);
-    } else {
-        ws.send(packr.pack({ type: 'ERROR', msg: 'لا تملك المال الكافي' }), true);
-    }
-}
-
-// نظام الاقتصاد (يتم التحديث كل 30 ثانية لمنع الـ Spam والسرعة المبالغ فيها)
-setInterval(() => {
-    worlds.forEach(world => {
-        world.players.forEach(player => {
-            if (player.online && player.territories.length > 0) {
-                // نضرب الدخل في 30 لأنه يحسب بالثانية
-                player.money += (player.income * 30);
-                player.power += (player.armyIncome * 30);
-                world.isDirty = true;
-            }
-        });
-    });
-}, 30000);
-
-// مزامنة البيانات مع العملاء كل 5 ثواني (لتخفيف الضغط، العميل يتنبأ بالباقي)
-setInterval(() => {
-    worlds.forEach(world => {
-        world.players.forEach((player, wsId) => {
-            if (player.online) {
-                // يجب إيجاد كائن ws الخاص باللاعب لإرسال الرسالة
-                // في uWebSockets نحتاج لطريقة لحفظ ws، للتبسيط سنفترض أننا نرسل للجميع
-                broadcast(world, { type: 'SYNC_STATS_SILENT', pId: player.id, money: player.money, power: player.power });
-            }
-        });
-    });
-}, 5000);
-
-function handleClaimTerritory(ws, territoryId) {
-    const world = worlds.find(w => w.id === ws.worldId);
-    if (!world) return;
-    const player = world.players.get(ws.id);
-
-    if (world.territories.has(territoryId)) {
-        ws.send(packr.pack({ type: 'ERROR', msg: 'المنطقة غير متاحة' }), true);
-        return;
-    }
-
-    // المنطقة الأولى مجانية لتأسيس الدولة، التوسع اللاحق رخيص ليتناسب مع الدخل
-    const isFirstClaim = player.territories.length === 0;
-    const CLAIM_COST_MONEY = isFirstClaim ? 0 : 0.05;
-    const CLAIM_COST_POWER = isFirstClaim ? 0 : 10;
-
-    if (player.money < CLAIM_COST_MONEY || player.power < CLAIM_COST_POWER) {
-        ws.send(packr.pack({ type: 'ERROR', msg: `لا تملك موارد كافية للتوسع (مطلوب ${CLAIM_COST_MONEY}$ و ${CLAIM_COST_POWER} قوة)` }), true);
-        return;
-    }
-
-    // خصم الموارد
-    player.money -= CLAIM_COST_MONEY;
-    player.power -= CLAIM_COST_POWER;
-    
-    // منع ثغرة الاحتلال المتعدد في نفس الوقت
-    if (player.isClaiming) {
-        ws.send(packr.pack({ type: 'ERROR', msg: 'أنت تقوم بعملية احتلال حالياً، انتظر!' }), true);
-        return;
-    }
-    player.isClaiming = true;
-
-    world.territories.set(territoryId, 'CLAIMING_' + player.id);
-    
-    // إذا كان أول احتلال، يتم فوراً (0 ثانية)
-    const claimDuration = isFirstClaim ? 0 : 60000;
-
-    broadcast(world, { type: 'CLAIM_STARTED', tId: territoryId, pId: player.id, color: player.color, duration: claimDuration / 1000 });
-
-    setTimeout(() => {
-        player.isClaiming = false;
-        // التأكد أن اللاعب لم يخرج من اللعبة
-        if (world.players.has(ws.id) && world.territories.get(territoryId) === 'CLAIMING_' + player.id) {
-            world.territories.set(territoryId, player.id);
-            player.territories.push(territoryId);
-            
-            // تفعيل الاقتصاد إذا كانت هذه أول منطقة له
-            if (player.territories.length === 1) {
-                player.income = 0.001;
-                player.armyIncome = 1;
-            }
-            
-            world.isDirty = true;
-
-            broadcast(world, { 
-                type: 'TERRITORY_CLAIMED', 
-                tId: territoryId, 
-                color: player.color, 
-                pId: player.id, 
-                name: player.name, 
-                power: player.power 
-            });
-        } else {
-            // إذا خرج اللاعب، نلغي الاحتلال
-            world.territories.delete(territoryId);
-            broadcast(world, { type: 'TERRITORY_CLAIMED', tId: territoryId, color: '#1e1e28' });
-        }
-    }, claimDuration); // 60 ثانية أو 0 ثانية
-}
-
-// نظام الهجوم المبسط (سيتم تطويره للنووي لاحقاً)
-function handleAttack(ws, targetId, weaponType, amount) {
-    const world = worlds.find(w => w.id === ws.worldId);
-    if (!world) return;
-    const attacker = world.players.get(ws.id);
-    
-    // التحقق من امتلاك السلاح
-    if (!attacker.assets[weaponType] || attacker.assets[weaponType] < amount) {
-        ws.send(packr.pack({ type: 'ERROR', msg: 'لا تملك هذا العدد من السلاح' }), true);
-        return;
-    }
-
-    // خصم السلاح من المهاجم
-    attacker.assets[weaponType] -= amount;
-    
-    // حساب قوة الهجوم (مثال: الدبابة قوتها 250)
-    const weaponPower = SHOP_DATA[weaponType].power * amount;
-    
-    // إرسال إشعار للجميع ببدء الهجوم (يستغرق وقت حسب المسافة، للتبسيط هنا 60ث)
-    broadcast(world, { type: 'ATTACK_LAUNCHED', from: attacker.name, target: targetId, time: 60 });
-
-    setTimeout(() => {
-        const defenderId = world.territories.get(targetId);
-        if (defenderId && world.players.has(defenderId)) {
-            const defender = world.players.get(defenderId);
-            // خصم قوة المدافع
-            defender.power = Math.max(0, defender.power - weaponPower);
-            broadcast(world, { type: 'UPDATE_POWER', pId: defender.id, power: defender.power });
-            
-            // إذا وصلت قوة المدافع لـ 0، تسقط المنطقة (يمكن برمجتها لاحقاً)
-        }
-    }, 60000);
-}
-
 function broadcast(world, messageObj) {
     const buffer = packr.pack(messageObj);
-    // إرسال البيانات لجميع اللاعبين المتصلين بنفس العالم بسرعة خارقة
     app.publish(`world-${world.id}`, buffer, true);
 }
 
-// تقديم ملف الخريطة (world.svg)
-app.get('/world.svg', (res, req) => {
-    try {
-        const svg = fs.readFileSync('world.svg', 'utf8');
-        res.writeHeader('Content-Type', 'image/svg+xml; charset=utf-8').end(svg);
-    } catch (e) {
-        res.writeStatus('404 Not Found').end('Map not found');
-    }
-});
-
 // تقديم ملف الواجهة (index.html)
 app.get('/*', (res, req) => {
     try {
@@ -461,7 +193,7 @@ app.get('/*', (res, req) => {
 const PORT = process.env.PORT || 7860;
 app.listen(PORT, (token) => {
     if (token) {
-        console.log(`Server running on port ${PORT} (Hugging Face Ready)`);
+        console.log(`Server running on port ${PORT} (Pixel Grid Engine Ready)`);
     } else {
         console.log(`Failed to listen to port ${PORT}`);
     }