Update server.js

server.js

@@ -3,127 +3,226 @@ const cors = require('cors');
 const { Octokit } = require('@octokit/rest');
 
 const app = express();
-app.use(cors()); // 2.
-app.use(express.json()); // لتمكين السيرفر من قراءة بيانات JSON المرسلة
+app.use(cors({ origin: '*' }));
+app.use(express.json({ limit: '50mb' })); // لضمان استقبال محتويات الفصول والصور الكبيرة
 
-// المنفذ الإجباري الخاص بـ Hugging Face Spaces
 const PORT = process.env.PORT || 7860; 
 
-// تهيئة الاتصال بـ GitHub API باستخدام الـ Token السري الخاص بك
-const octokit = new Octokit({
-    auth: process.env.GITHUB_TOKEN // سيتم تمريره كـ Environment Variable في Hugging Face
-});
-
-// إعدادات المستودع
-const REPO_OWNER = 'Nour774'; 
-const REPO_NAME = 's'; // أو 'novels-repo' حسب المستودع
+const octokit = new Octokit({ auth: process.env.GITHUB_TOKEN });
+const REPO_OWNER = 'Nour774';
+const REPO_NAME = 's'; // أو novels-repo
 const BRANCH = 'main';
 
-// 📥 طابور الذاكرة المؤقت لتجميع العمليات خلال الـ 15 ثانية
-let actionQueue = [];
+// طابور الذاكرة المؤقت للعمليات الذكية
+let operationQueue = [];
+
+// مسار ترحيبي
+app.get('/', (req, res) => res.send('🌌 محرك السماء السوداء الذكي يعمل ومستعد لمعالجة المصفوفات!'));
 
 /**
- * API إستقبال العمليات من المساهمين
- * يدعم أنواع العمليات: 'create', 'update', 'delete'
+ * 1. API إضافة عمل جديد (رواية أو مانجا)
  */
-app.post('/api/sync', (req, res) => {
-    const { action, filePath, content } = req.body;
-
-    if (!action || !filePath) {
-        return res.status(400).json({ error: 'البيانات المرسلة غير كاملة.' });
-    }
-
-    // تجهيز الكائن المتوافق مع Git Trees API
-    const treeObject = {
-        path: filePath,
-        mode: '100644', // ملف نصي عادي
-        type: 'blob'
-    };
-
-    if (action === 'delete') {
-        // في الـ Git Trees API الحذف يتم بتمرير sha كـ null أو استثنائه تماماً من الشجرة الأساسية
-        // سنحدد هنا علامة للحذف لتتعامل معها الدالة الدورية
-        treeObject.sha = null; 
-    } else {
-        // في حالة الإضافة أو التعديل نضع المحتوى الجديد للملف
-        treeObject.content = content;
-    }
-
-    // ضخ العملية في الطابور اللحظي
-    actionQueue.push(treeObject);
-
-    // نرد على المساهم فوراً بأنه تم الاستلام لكي لا ينتظر جيثب
-    res.status(200).json({ status: 'queued', message: 'تم جدولة طلبك، سيتم النشر خلال ثوانٍ.' });
+app.post('/api/add-novel', (req, res) => {
+    const { englishName, arabicName, slug, genres, status, rating, views, author, coverType, coverUrl, uploaderId, uploaderUsername, description } = req.body;
+    
+    operationQueue.push({
+        type: 'ADD_NOVEL',
+        data: { englishName, arabicName, slug, genres, status, rating, views, author, coverType, coverUrl, uploaderId, uploaderUsername, description }
+    });
+    
+    res.status(200).json({ status: 'queued', message: 'جاري إنشاء العمل وتوليد المعرف والفهرسة صامتاً...' });
 });
 
 /**
- * 🔄 المايسترو الدوري: يفرغ الطابور ويدفع شجرة Git المجمعة كل 15 ثانية
+ * 2. API إضافة فصل جديد لعمل موجود
  */
-setInterval(async () => {
-    if (actionQueue.length === 0) return;
-
-    // أخذ لقطة من الطابور وتفريغه فوراً لاستقبال العمليات الجديدة
-    const currentBatch = [...actionQueue];
-    actionQueue = [];
+app.post('/api/add-chapter', (req, res) => {
+    const { novelId, chapterNum, chapterTitle, chapterType, contributor, chapterData } = req.body;
+    
+    operationQueue.push({
+        type: 'ADD_CHAPTER',
+        data: { novelId: parseInt(novelId), chapterNum, chapterTitle, chapterType, contributor, chapterData }
+    });
+    
+    res.status(200).json({ status: 'queued', message: 'جاري حقن الفصل وتحديث الفهارس والعدادات...' });
+});
 
-    console.log(`[Sync] جاري معالجة حزمة تحتوي على ${currentBatch.length} عملية مجمعة...`);
+/**
+ * 3. API التعديل السريع (الحالة أو الاسم)
+ */
+app.post('/api/update-info', (req, res) => {
+    const { novelId, field, newValue } = req.body; // field قد يكون 'status' أو 'arabicName'.. إلخ
+    
+    operationQueue.push({
+        type: 'UPDATE_INFO',
+        data: { novelId: parseInt(novelId), field, newValue }
+    });
+    
+    res.status(200).json({ status: 'queued', message: 'تم جدولة تعديل البيانات البسيطة...' });
+});
 
+/**
+ * دالة مساعدة لجلب محتوى ملف نصي مباشرة من جيثب
+ */
+async function fetchFileContent(path) {
     try {
-        // 1. جلب الـ SHA الخاص بآخر الالتزام (Commit) الحالي على الفرع
-        const { data: refData } = await octokit.git.getRef({
+        const { data } = await octokit.repos.getContent({
             owner: REPO_OWNER,
             repo: REPO_NAME,
-            ref: `heads/${BRANCH}`
+            path: path,
+            ref: BRANCH
         });
-        const lastCommitSha = refData.object.sha;
+        return Buffer.from(data.content, 'base64').toString('utf8');
+    } catch (e) {
+        return null; // الملف غير موجود بعد
+    }
+}
 
-        // 2. جلب الـ SHA الخاص بالشجرة الأساسية (Base Tree) المنبثقة من آخر Commit
-        const { data: commitData } = await octokit.git.getCommit({
-            owner: REPO_OWNER,
-            repo: REPO_NAME,
-            commit_sha: lastCommitSha
+/**
+ * 🔄 محرك المعالجة والدمج الذكي كل 15 ثانية
+ */
+setInterval(async () => {
+    if (operationQueue.length === 0) return;
+
+    const currentOps = [...operationQueue];
+    operationQueue = [];
+
+    console.log(`[Engine] جاري تطبيق ${currentOps.length} عملية ذكية على الفهارس...`);
+
+    try {
+        // حزمة الملفات النهائية التي سنرسلها لـ Git Tree
+        let finalTreeChanges = [];
+
+        // 1. جلب ملف الفهرس الحالي من جيثب وتفكيكه
+        let searchIndexContent = await fetchFileContent('novel/search_index.js');
+        if (!searchIndexContent) {
+            // كود مبدئي إذا كان الملف فارغاً تماماً في البداية
+            searchIndexContent = `window.blackSkyConfig = window.blackSkyConfig || {}; window.novelIndex = [];`;
+        }
+
+        // عزل المصفوفة المستهدفة برمجياً للتعامل معها كـ JavaScript حقيقي
+        let novelIndexMatch = searchIndexContent.match(/window\.novelIndex\s*=\s*([\s\S]*?);/);
+        let novelIndex = novelIndexMatch ? eval(novelIndexMatch[1]) : [];
+
+        // 2. معالجة العمليات واحدة تلو الأخرى داخل الذاكرة
+        for (const op of currentOps) {
+            const timestamp = Math.floor(Date.now() / 1000);
+
+            if (op.type === 'ADD_NOVEL') {
+                const d = op.data;
+                // توليد الـ ID تلقائياً بناءً على آخر عنصر
+                const nextId = novelIndex.length > 0 ? novelIndex[novelIndex.length - 1][0] + 1 : 1;
+                
+                // تحديد قيمة معرف الصورة (رابط كامل أو صيغة فقط)
+                const coverValue = d.coverUrl ? d.coverUrl : d.coverType; // 'png' أو 'jpg' أو الرابط الكامل
+
+                // إضافة السطر الجديد للمصوفة الشاملة
+                // [ID, الاسم الإنجليزي, الاسم العربي, Slug, [التصنيفات], الحالة, التقييم, المشاهدات, الـ Timestamp, عدد_الفصول, المؤلف, معرف_الغلاف]
+                novelIndex.push([
+                    nextId, d.englishName, d.arabicName, d.slug, d.genres, 
+                    parseInt(d.status), parseFloat(d.rating), parseInt(d.views), 
+                    timestamp, 0, d.author, coverValue
+                ]);
+
+                // توليد ملف الوصف الفردي الجديد للعمل (novels/ID.js)
+                const novelDescriptionContent = `window.currentNovelData = {
+  "id": ${nextId},
+  "slug": "${d.slug}",
+  "uploader_id": ${d.uploaderId},
+  "uploader_username": "${d.uploaderUsername}",
+  "description": "${d.description.replace(/"/g, '\\"')}",
+  "chapters": []
+};`;
+                finalTreeChanges.push({
+                    path: `novels/${nextId}.js`,
+                    mode: '100644',
+                    type: 'blob',
+                    content: novelDescriptionContent
+                });
+
+            } else if (op.type === 'ADD_CHAPTER') {
+                const d = op.data;
+                
+                // تحديث ملف وصف الرواية (novels/ID.js)
+                let novelDocContent = await fetchFileContent(`novels/${d.novelId}.js`);
+                if (novelDocContent) {
+                    let docMatch = novelDocContent.match(/window\.currentNovelData\s*=\s*([\s\S]*?);/);
+                    if (docMatch) {
+                        let novelData = eval(`(${docMatch[1]})`);
+                        
+                        // إضافة الفصل الجديد للمصفوفة داخل ملف الوصف
+                        novelData.chapters.push({
+                            num: d.chapterNum,
+                            title: d.chapterTitle,
+                            type: d.chapterType,
+                            contributor: d.contributor,
+                            data: d.chapterData // كود الاستدعاء أو الحزمة
+                        });
+
+                        finalTreeChanges.push({
+                            path: `novels/${d.novelId}.js`,
+                            mode: '100644',
+                            type: 'blob',
+                            content: `window.currentNovelData = ${JSON.stringify(novelData, null, 2)};`
+                        });
+
+                        // تحديث عداد الفصول والـ Timestamp في ملف الفهرس العام (search_index.js)
+                        let row = novelIndex.find(r => r[0] === d.novelId);
+                        if (row) {
+                            row[9] = novelData.chapters.length; // تحديث عدد الفصول
+                            row[8] = timestamp; // تحديث الطابع الزمني لآخر تحديث فصول
+                        }
+                    }
+                }
+
+            } else if (op.type === 'UPDATE_INFO') {
+                const d = op.data;
+                let row = novelIndex.find(r => r[0] === d.novelId);
+                if (row) {
+                    // خريطة لتحديد مكان العمود المراد تعديله في المصفوفة
+                    const fieldMap = { 'englishName': 1, 'arabicName': 2, 'slug': 3, 'status': 5, 'rating': 6, 'views': 7, 'author': 10 };
+                    const colIndex = fieldMap[d.field];
+                    if (colIndex !== undefined) {
+                        row[colIndex] = d.newValue;
+                    }
+                }
+            }
+        }
+
+        // 3. إعادة بناء كود ملف الفهرس بالبيانات الجديدة
+        // سنحافظ على الهيكل الثابت للتهيئة والـ Config ونستبدل فقط مصفوفة الـ novelIndex
+        const headerPart = searchIndexContent.split('window.novelIndex =')[0];
+        const updatedSearchIndexContent = `${headerPart}window.novelIndex = ${JSON.stringify(novelIndex, null, 4)};`;
+
+        finalTreeChanges.push({
+            path: 'novel/search_index.js',
+            mode: '100644',
+            type: 'blob',
+            content: updatedSearchIndexContent
         });
-        const baseTreeSha = commitData.tree.sha;
 
-        // 3. بناء الشجرة الجديدة (New Tree) عبر دمج العمليات الحالية مع الشجرة الأساسية
-        // جيثب هنا يتكفل بالإضافات والتعديلات والحجوزات دفعة واحدة بطلب واحد!
+        // 4. ضخ كل التعديلات الذكية المجمعة إلى جيثب بـ Commit واحد حاسم!
+        const { data: refData } = await octokit.git.getRef({ owner: REPO_OWNER, repo: REPO_NAME, ref: `heads/${BRANCH}` });
+        const lastCommitSha = refData.object.sha;
+        const { data: commitData } = await octokit.git.getCommit({ owner: REPO_OWNER, repo: REPO_NAME, commit_sha: lastCommitSha });
+        
         const { data: newTreeData } = await octokit.git.createTree({
-            owner: REPO_OWNER,
-            repo: REPO_NAME,
-            base_tree: baseTreeSha,
-            tree: currentBatch
+            owner: REPO_OWNER, repo: REPO_NAME, base_tree: commitData.tree.sha, tree: finalTreeChanges
         });
 
-        // 4. إنشاء الالتزام الجديد (New Commit) وربطه بالشجرة الجديدة والالتزام السابق
         const { data: newCommitData } = await octokit.git.createCommit({
-            owner: REPO_OWNER,
-            repo: REPO_NAME,
-            message: `🤖 السماء السوداء: تحديث مجمع آلي (${currentBatch.length} ملفات)`,
-            tree: newTreeData.sha,
-            parents: [lastCommitSha]
+            owner: REPO_OWNER, repo: REPO_NAME,
+            message: `🤖 محرك السماء السوداء: معالجة مصفوفات ودمج آلي (${finalTreeChanges.length} ملفات معدلة)`,
+            tree: newTreeData.sha, parents: [lastCommitSha]
         });
 
-        // 5. تحريك إشارة الفرع (Update Reference) لتشير إلى الالتزام الجديد ليرى العالم التحديثات
-        await octokit.git.updateRef({
-            owner: REPO_OWNER,
-            repo: REPO_NAME,
-            ref: `heads/${BRANCH}`,
-            sha: newCommitData.sha
-        });
-
-        console.log(`[Success] تم تحديث جيثب بنجاح بـ Commit واحد مجمع!`);
-
-        // 6. [هنا يمكنك استدعاء دالة إسقاط كاش كلوفلير صامتاً]
-        // await purgeCloudflareCache();
+        await octokit.git.updateRef({ owner: REPO_OWNER, repo: REPO_NAME, ref: `heads/${BRANCH}`, sha: newCommitData.sha });
+        console.log(`[Success Engine] تم تحديث وفهرسة وتوليد المعرفات للبيانات بنجاح!`);
 
     } catch (error) {
-        console.error('[Error] فشلت عملية المزام��ة المجمعة مع جيثب:', error);
-        // في حال الفشل، نعيد الحزمة إلى الطابور حتى لا تضيع بيانات الفصول
-        actionQueue = [...currentBatch, ...actionQueue];
+        console.error('[Engine Error] فشلت معالجة المصفوفات الحيوية:', error);
+        operationQueue = [...currentOps, ...operationQueue]; // حفظ البيانات من الضياع
     }
-}, 15000); // تيك تاك.. كل 15 ثانية
+}, 15000);
 
-// تشغيل السيرفر والاستماع للمنفذ
-app.listen(PORT, () => {
-    console.log(`سيرفر السماء السوداء يعمل بنجاح على المنفذ ${PORT}`);
-});
+app.listen(PORT, () => console.log(`المحرك الذكي مستعد على المنفذ ${PORT}`));