Add GraphQL

package-lock.json

@@ -54,6 +54,7 @@
         "passport-oauth2": "^1.8.0",
         "pdf-parse": "^1.1.4",
         "sharp": "^0.32.6",
+        "socket.io-client": "^4.8.3",
         "stripe": "^22.2.2",
         "swagger-jsdoc": "^6.2.8",
         "swagger-ui-express": "^5.0.1",
@@ -1719,6 +1720,12 @@
         "node": ">=18"
       }
     },
+    "node_modules/@socket.io/component-emitter": {
+      "version": "3.1.2",
+      "resolved": "https://registry.npmmirror.com/@socket.io/component-emitter/-/component-emitter-3.1.2.tgz",
+      "integrity": "sha512-9BCxFwvbGg/RsZK9tjXd8s4UcwR0MWeFQ1XEKIQVVvAGJyINdrqKMcTRyLoK8Rse1GjzLV9cwjWV1olXRWEXVA==",
+      "license": "MIT"
+    },
     "node_modules/@tokenizer/inflate": {
       "version": "0.4.1",
       "resolved": "https://registry.npmmirror.com/@tokenizer/inflate/-/inflate-0.4.1.tgz",
@@ -3090,6 +3097,51 @@
         "once": "^1.4.0"
       }
     },
+    "node_modules/engine.io-client": {
+      "version": "6.6.6",
+      "resolved": "https://registry.npmmirror.com/engine.io-client/-/engine.io-client-6.6.6.tgz",
+      "integrity": "sha512-iY6QdftLQ9pyiPoX082bpf/u1UewnOaJrtJIF9T0++QB34lZrj0uP+Q/bj8AlUsAxqhnkTV2BS8SBZSxOmoV5Q==",
+      "license": "MIT",
+      "dependencies": {
+        "@socket.io/component-emitter": "~3.1.0",
+        "debug": "~4.4.1",
+        "engine.io-parser": "~5.2.1",
+        "ws": "~8.21.0",
+        "xmlhttprequest-ssl": "~2.1.1"
+      }
+    },
+    "node_modules/engine.io-client/node_modules/debug": {
+      "version": "4.4.3",
+      "resolved": "https://registry.npmmirror.com/debug/-/debug-4.4.3.tgz",
+      "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+      "license": "MIT",
+      "dependencies": {
+        "ms": "^2.1.3"
+      },
+      "engines": {
+        "node": ">=6.0"
+      },
+      "peerDependenciesMeta": {
+        "supports-color": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/engine.io-client/node_modules/ms": {
+      "version": "2.1.3",
+      "resolved": "https://registry.npmmirror.com/ms/-/ms-2.1.3.tgz",
+      "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==",
+      "license": "MIT"
+    },
+    "node_modules/engine.io-parser": {
+      "version": "5.2.3",
+      "resolved": "https://registry.npmmirror.com/engine.io-parser/-/engine.io-parser-5.2.3.tgz",
+      "integrity": "sha512-HqD3yTBfnBxIrbnM1DoD6Pcq8NECnh8d4As1Qgh0z5Gg3jRRIqijury0CL3ghu/edArpUYiYqQiDUQBIs4np3Q==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=10.0.0"
+      }
+    },
     "node_modules/es-define-property": {
       "version": "1.0.1",
       "resolved": "https://registry.npmmirror.com/es-define-property/-/es-define-property-1.0.1.tgz",
@@ -6521,6 +6573,80 @@
       "integrity": "sha512-TK5ZA9U5RqCwMpfoMq/l1mrH0JAR7y7KRvOBx0n2869aLxch+gT9GhN3yUfjiw+d/DiF1mKo14+hd62JyMmoBg==",
       "license": "MIT"
     },
+    "node_modules/socket.io-client": {
+      "version": "4.8.3",
+      "resolved": "https://registry.npmmirror.com/socket.io-client/-/socket.io-client-4.8.3.tgz",
+      "integrity": "sha512-uP0bpjWrjQmUt5DTHq9RuoCBdFJF10cdX9X+a368j/Ft0wmaVgxlrjvK3kjvgCODOMMOz9lcaRzxmso0bTWZ/g==",
+      "license": "MIT",
+      "dependencies": {
+        "@socket.io/component-emitter": "~3.1.0",
+        "debug": "~4.4.1",
+        "engine.io-client": "~6.6.1",
+        "socket.io-parser": "~4.2.4"
+      },
+      "engines": {
+        "node": ">=10.0.0"
+      }
+    },
+    "node_modules/socket.io-client/node_modules/debug": {
+      "version": "4.4.3",
+      "resolved": "https://registry.npmmirror.com/debug/-/debug-4.4.3.tgz",
+      "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+      "license": "MIT",
+      "dependencies": {
+        "ms": "^2.1.3"
+      },
+      "engines": {
+        "node": ">=6.0"
+      },
+      "peerDependenciesMeta": {
+        "supports-color": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/socket.io-client/node_modules/ms": {
+      "version": "2.1.3",
+      "resolved": "https://registry.npmmirror.com/ms/-/ms-2.1.3.tgz",
+      "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==",
+      "license": "MIT"
+    },
+    "node_modules/socket.io-parser": {
+      "version": "4.2.7",
+      "resolved": "https://registry.npmmirror.com/socket.io-parser/-/socket.io-parser-4.2.7.tgz",
+      "integrity": "sha512-IH/iSeO9T6gz1KkFleGDWkG9N3dl4jXVYUtMhIqH10Md0ttMer8nUNWiP1DKuNrybD2xBrixLJdCC9J6ECoYkg==",
+      "license": "MIT",
+      "dependencies": {
+        "@socket.io/component-emitter": "~3.1.0",
+        "debug": "~4.4.1"
+      },
+      "engines": {
+        "node": ">=10.0.0"
+      }
+    },
+    "node_modules/socket.io-parser/node_modules/debug": {
+      "version": "4.4.3",
+      "resolved": "https://registry.npmmirror.com/debug/-/debug-4.4.3.tgz",
+      "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+      "license": "MIT",
+      "dependencies": {
+        "ms": "^2.1.3"
+      },
+      "engines": {
+        "node": ">=6.0"
+      },
+      "peerDependenciesMeta": {
+        "supports-color": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/socket.io-parser/node_modules/ms": {
+      "version": "2.1.3",
+      "resolved": "https://registry.npmmirror.com/ms/-/ms-2.1.3.tgz",
+      "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==",
+      "license": "MIT"
+    },
     "node_modules/sparse-bitfield": {
       "version": "3.0.3",
       "resolved": "https://registry.npmmirror.com/sparse-bitfield/-/sparse-bitfield-3.0.3.tgz",
@@ -7431,6 +7557,27 @@
       "integrity": "sha512-l4Sp/DRseor9wL6EvV2+TuQn63dMkPjZ/sp9XkghTEbV9KlPS1xUsZ3u7/IQO4wxtcFB4bgpQPRcR3QCvezPcQ==",
       "license": "ISC"
     },
+    "node_modules/ws": {
+      "version": "8.21.1",
+      "resolved": "https://registry.npmmirror.com/ws/-/ws-8.21.1.tgz",
+      "integrity": "sha512-+0NTnW77fFN/DjQi6k/Sq/Yvk4Sgajw7urW8V+asjXnRgDs9gyGkdb7EzgfhA4goXsRIZKE28fzIXBHEzhuiWw==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=10.0.0"
+      },
+      "peerDependencies": {
+        "bufferutil": "^4.0.1",
+        "utf-8-validate": ">=5.0.2"
+      },
+      "peerDependenciesMeta": {
+        "bufferutil": {
+          "optional": true
+        },
+        "utf-8-validate": {
+          "optional": true
+        }
+      }
+    },
     "node_modules/xml": {
       "version": "1.0.1",
       "resolved": "https://registry.npmmirror.com/xml/-/xml-1.0.1.tgz",
@@ -7477,6 +7624,14 @@
         "node": ">=4.0"
       }
     },
+    "node_modules/xmlhttprequest-ssl": {
+      "version": "2.1.2",
+      "resolved": "https://registry.npmmirror.com/xmlhttprequest-ssl/-/xmlhttprequest-ssl-2.1.2.tgz",
+      "integrity": "sha512-TEU+nJVUUnA4CYJFLvK5X9AOeH4KvDvhIfm0vV1GaQRtchnG0hgK5p8hw/xjv8cunWYCsiPCSDzObPyhEwq3KQ==",
+      "engines": {
+        "node": ">=0.4.0"
+      }
+    },
     "node_modules/xtend": {
       "version": "4.0.2",
       "resolved": "https://registry.npmmirror.com/xtend/-/xtend-4.0.2.tgz",

package.json

@@ -75,6 +75,7 @@
     "passport-oauth2": "^1.8.0",
     "pdf-parse": "^1.1.4",
     "sharp": "^0.32.6",
+    "socket.io-client": "^4.8.3",
     "stripe": "^22.2.2",
     "swagger-jsdoc": "^6.2.8",
     "swagger-ui-express": "^5.0.1",

server.js

@@ -76,6 +76,8 @@ const helmet = require('helmet');
 const app = express();
 app.set('trust proxy', true);
 
+const getSocketClient = require('./utils/socket-client');
+
 
 
 app.use(cors({
@@ -377,6 +379,8 @@ const excludedPaths = [
     '/api/subscription/renew',
     '/api/subscription/cancel',
     '/api/users/:userId/badges',
+    '/api/profile/:userId/view',
+    '/api/achievements/:slug',
     '/api/users/:userId',
     '/api/admin/stores/:userId/toggle',
     '/api/admin/stores/:userId',
@@ -1109,17 +1113,18 @@ const handleUploadError = (err, req, res, next) => {
 // ============================================
 const messageUpload = multer({
     storage: multer.memoryStorage(),
-    limits: { fileSize: 10 * 1024 * 1024 }, // 10MB for messages
+    limits: { fileSize: 10 * 1024 * 1024 },
     fileFilter: (req, file, cb) => {
         const allowedTypes = [
             'image/jpeg', 'image/png', 'image/gif', 'image/webp',
+            'video/mp4', 'video/webm', 'video/ogg',
             'application/pdf',
             'audio/mpeg', 'audio/webm', 'audio/mp4', 'audio/ogg'
         ];
         if (allowedTypes.includes(file.mimetype)) {
             cb(null, true);
         } else {
-            cb(new Error('File type not allowed. Allowed: images, PDF, audio files'), false);
+            cb(new Error('File type not allowed. Allowed: images, videos, PDF, audio'), false);
         }
     }
 });
@@ -4348,6 +4353,12 @@ const userSchema = new mongoose.Schema({
                     interaction: {
                         bronze: { type: Boolean, default: false },   // 10 ردود
                     },
+                    ratings: { 
+                        bronze: { type: Boolean, default: false },
+                        silver: { type: Boolean, default: false },
+                        gold: { type: Boolean, default: false },
+                        platinum: { type: Boolean, default: false }
+                    },
                     unlockedAt: { type: Date, default: null },
                     updatedAt: { type: Date, default: Date.now }
                 },
@@ -4356,6 +4367,7 @@ const userSchema = new mongoose.Schema({
                     likes: { bronze: false, silver: false, gold: false, red: false },
                     interaction: { bronze: false },
                     unlockedAt: null,
+                    ratings: { bronze: false, silver: false, gold: false, platinum: false },
                     updatedAt: Date.now
                 }
             },
@@ -10284,6 +10296,136 @@ app.get('/api/profile/:nickname', async (req, res) => {
     }
 });
 
+
+// ============================================
+// POST /api/profile/:userId/view - تتبع مشاهدة البروفايل
+// ============================================
+app.post('/api/profile/:userId/view', async (req, res) => {
+    try {
+        const { userId: targetUserId } = req.params;
+        
+        if (!targetUserId) {
+            return res.status(400).json({
+                success: false,
+                error: 'targetUserId is required'
+            });
+        }
+
+        // ✅ الحصول على viewerId من التوكن (لو موجود)
+        const viewerId = req.user?.userId || null;
+        const viewerIp = req.ip || req.connection?.remoteAddress || 'unknown';
+
+        // ✅ لا تسجل مشاهدة لنفس المستخدم
+        if (viewerId === targetUserId) {
+            return res.json({
+                success: true,
+                message: 'Self view not tracked',
+                data: { selfView: true }
+            });
+        }
+
+        // ============================
+        // 📊 1. تسجيل في ProfileAnalytics
+        // ============================
+        let analytics = await ProfileAnalytics.findOne({ userId: targetUserId });
+        
+        if (!analytics) {
+            analytics = new ProfileAnalytics({ userId: targetUserId });
+        }
+        
+        analytics.profileViews = analytics.profileViews || [];
+        analytics.profileViews.push({
+            viewerId: viewerId,
+            viewerIp: viewerIp,
+            viewedAt: new Date()
+        });
+        
+        // ✅ الاحتفاظ بآخر 100 مشاهدة فقط
+        if (analytics.profileViews.length > 100) {
+            analytics.profileViews = analytics.profileViews.slice(-100);
+        }
+        
+        analytics.lastUpdated = new Date();
+        await analytics.save();
+
+        // ============================
+        // 👥 2. تسجيل في AlsoViewed
+        // ============================
+        if (viewerId) {
+            // ✅ مستخدم مسجل
+            await AlsoViewed.findOneAndUpdate(
+                { targetUserId, viewerId: viewerId },
+                { 
+                    viewedAt: new Date(),
+                    viewerIp: viewerIp 
+                },
+                { upsert: true }
+            );
+        } else {
+            // ✅ زائر (غير مسجل) - نستخدم IP
+            const existingView = await AlsoViewed.findOne({
+                targetUserId,
+                viewerIp: viewerIp,
+                viewedAt: { $gte: new Date(Date.now() - 24 * 60 * 60 * 1000) }
+            });
+            
+            if (!existingView) {
+                await AlsoViewed.create({
+                    targetUserId,
+                    viewerId: null,
+                    viewerIp: viewerIp,
+                    viewedAt: new Date()
+                });
+            }
+        }
+
+        // ============================
+        // 🏆 3. تحديث البرونزيات
+        // ============================
+        const badgeResult = await updateUserBadges(targetUserId);
+
+        // ============================
+        // 📢 4. بث للمستخدم المستهدف (لو فتح برونزية) - عبر Socket
+        // ============================
+        if (badgeResult?.newBadgeUnlocked && badgeResult?.unlockedBadges?.length > 0) {
+            // ✅ استخدم io.to (نفس الكود القديم)
+            io.to(`user_${targetUserId}`).emit('badge_unlocked', {
+                userId: targetUserId,
+                badges: badgeResult.unlockedBadges,
+                badgeIcons: badgeResult.unlockedBadgeIcons || [],
+                viewCount: badgeResult.viewCount,
+                likeCount: badgeResult.likeCount,
+                replyCount: badgeResult.replyCount,
+                ratingCount: badgeResult.ratingCount,
+                totalBadges: badgeResult.totalBadgeCount
+            });
+        }
+
+        res.json({
+            success: true,
+            message: 'View tracked successfully',
+            data: {
+                viewCount: badgeResult?.viewCount || 0,
+                likeCount: badgeResult?.likeCount || 0,
+                replyCount: badgeResult?.replyCount || 0,
+                ratingCount: badgeResult?.ratingCount || 0,
+                totalBadges: badgeResult?.totalBadgeCount || 0,
+                newBadgeUnlocked: badgeResult?.newBadgeUnlocked || false,
+                unlockedBadges: badgeResult?.unlockedBadges || []
+            }
+        });
+
+    } catch (error) {
+        console.error('❌ Track profile view error:', error);
+        // ✅ لا نرسل خطأ للمستخدم حتى لا يسبب مشاكل
+        res.json({
+            success: true,
+            message: 'View tracked',
+            data: { error: error.message }
+        });
+    }
+});
+
 // ============================================
 // GET /api/users/:userId/badges - جلب البرونزيات المفتوحة فقط
 // ============================================
@@ -10291,21 +10433,22 @@ app.get('/api/users/:userId/badges', async (req, res) => {
     try {
         const { userId } = req.params;
         
-        // ✅ جلب جميع البيانات بشكل متوازي
-        const [badges, viewCount, likeCount, replyCount] = await Promise.all([
+        // ✅ جلب جميع البيانات بشكل متوازي (نفس الـ Socket)
+        const [badges, viewCount, likeCount, replyCount, ratingCount] = await Promise.all([
             getUserBadges(userId),
             getUniqueViewsCount(userId),
             getTotalPostLikes(userId),
-            getTotalUserReplies(userId)
+            getTotalUserReplies(userId),
+            getTotalUserRatings(userId)  // ✅ أضف ratingCount
         ]);
         
-        // ✅ حساب التالي
+        // ✅ حساب التالي - نفس منطق الـ Socket بالضبط
         let nextBadge = null;
         let nextThreshold = null;
         let progress = 100;
         let nextBadgeType = null;
         
-        // ✅ برونزيات المشاهدات (باستخدام البيانات المخزنة)
+        // ✅ Views Badges
         const viewsBadges = badges.views || { unlocked: [], count: 0 };
         const hasSilver = viewsBadges.unlocked.some(b => b.key === 'silver');
         const hasGold = viewsBadges.unlocked.some(b => b.key === 'gold');
@@ -10328,7 +10471,7 @@ app.get('/api/users/:userId/badges', async (req, res) => {
             nextBadgeType = 'views';
         }
         
-        // ✅ برونزيات الإعجابات
+        // ✅ Likes Badges
         const likesBadges = badges.likes || { unlocked: [], count: 0 };
         const hasLikesBronze = likesBadges.unlocked.some(b => b.key === 'bronze');
         const hasLikesRed = likesBadges.unlocked.some(b => b.key === 'red');
@@ -10359,7 +10502,7 @@ app.get('/api/users/:userId/badges', async (req, res) => {
             }
         }
         
-        // ✅ برونزيات التفاعل
+        // ✅ Interaction Badges
         const interactionBadges = badges.interaction || { unlocked: [], count: 0 };
         const hasInteractionBronze = interactionBadges.unlocked.some(b => b.key === 'bronze');
         
@@ -10372,7 +10515,37 @@ app.get('/api/users/:userId/badges', async (req, res) => {
             }
         }
         
-        // ✅ إذا اكتمل كل شيء
+        // ✅ Ratings Badges
+        const ratingsBadges = badges.ratings || { unlocked: [], count: 0 };
+        const hasRatingsBronze = ratingsBadges.unlocked.some(b => b.key === 'bronze');
+        const hasRatingsSilver = ratingsBadges.unlocked.some(b => b.key === 'silver');
+        const hasRatingsGold = ratingsBadges.unlocked.some(b => b.key === 'gold');
+        const hasRatingsPlatinum = ratingsBadges.unlocked.some(b => b.key === 'platinum');
+        
+        if (!nextBadge) {
+            if (!hasRatingsBronze && ratingCount < RATING_BADGE_THRESHOLDS.BRONZE) {
+                nextBadge = 'Ratings Bronze';
+                nextThreshold = RATING_BADGE_THRESHOLDS.BRONZE;
+                progress = (ratingCount / RATING_BADGE_THRESHOLDS.BRONZE) * 100;
+                nextBadgeType = 'ratings';
+            } else if (!hasRatingsSilver && ratingCount < RATING_BADGE_THRESHOLDS.SILVER) {
+                nextBadge = 'Ratings Silver';
+                nextThreshold = RATING_BADGE_THRESHOLDS.SILVER;
+                progress = (ratingCount / RATING_BADGE_THRESHOLDS.SILVER) * 100;
+                nextBadgeType = 'ratings';
+            } else if (!hasRatingsGold && ratingCount < RATING_BADGE_THRESHOLDS.GOLD) {
+                nextBadge = 'Ratings Gold';
+                nextThreshold = RATING_BADGE_THRESHOLDS.GOLD;
+                progress = (ratingCount / RATING_BADGE_THRESHOLDS.GOLD) * 100;
+                nextBadgeType = 'ratings';
+            } else if (!hasRatingsPlatinum && ratingCount < RATING_BADGE_THRESHOLDS.PLATINUM) {
+                nextBadge = 'Ratings Platinum';
+                nextThreshold = RATING_BADGE_THRESHOLDS.PLATINUM;
+                progress = (ratingCount / RATING_BADGE_THRESHOLDS.PLATINUM) * 100;
+                nextBadgeType = 'ratings';
+            }
+        }
+        
         if (!nextBadge) {
             nextBadge = 'All badges collected! 🎉';
             nextThreshold = null;
@@ -10380,54 +10553,377 @@ app.get('/api/users/:userId/badges', async (req, res) => {
             nextBadgeType = 'complete';
         }
         
-        // ✅ حساب نسبة التقدم الإجمالية
         const totalBadges = badges.totalCount || 0;
-        const totalPossible = 3 + 4 + 1; // views(3) + likes(4) + interaction(1)
+        const totalPossible = 3 + 4 + 1 + 4; // views(3) + likes(4) + interaction(1) + ratings(4)
         const overallProgress = Math.min((totalBadges / totalPossible) * 100, 100);
         
+        // ✅ نفس بنية البيانات تماماً زي الـ Socket
         res.json({
-            userId,
-            viewCount,
-            likeCount,
-            replyCount,
-            // ✅ البرونزيات المفتوحة فقط
-            badges: {
-                views: {
-                    unlocked: badges.views?.unlocked || [],
-                    count: badges.views?.count || 0
-                },
-                likes: {
-                    unlocked: badges.likes?.unlocked || [],
-                    count: badges.likes?.count || 0
+            success: true,
+            data: {
+                userId,
+                viewCount,
+                likeCount,
+                replyCount,
+                ratingCount,
+                badges: {
+                    views: {
+                        unlocked: badges.views?.unlocked || [],
+                        count: badges.views?.count || 0
+                    },
+                    likes: {
+                        unlocked: badges.likes?.unlocked || [],
+                        count: badges.likes?.count || 0
+                    },
+                    interaction: {
+                        unlocked: badges.interaction?.unlocked || [],
+                        count: badges.interaction?.count || 0
+                    },
+                    ratings: {
+                        unlocked: badges.ratings?.unlocked || [],
+                        count: badges.ratings?.count || 0
+                    },
+                    unlocked: badges.unlocked || [],
+                    totalCount: totalBadges
                 },
-                interaction: {
-                    unlocked: badges.interaction?.unlocked || [],
-                    count: badges.interaction?.count || 0
+                thresholds: {
+                    views: VIEW_BADGE_THRESHOLDS,
+                    likes: LIKE_BADGE_THRESHOLDS,
+                    interaction: INTERACTION_BADGE_THRESHOLDS,
+                    ratings: RATING_BADGE_THRESHOLDS
                 },
-                unlocked: badges.unlocked || [],
-                totalCount: totalBadges
-            },
-            thresholds: {
-                views: VIEW_BADGE_THRESHOLDS,
-                likes: LIKE_BADGE_THRESHOLDS,
-                interaction: INTERACTION_BADGE_THRESHOLDS
-            },
-            nextBadge,
-            nextThreshold,
-            nextBadgeType,
-            progress: Math.min(Math.round(progress), 100),
-            overallProgress: Math.min(Math.round(overallProgress), 100),
-            totalBadges,
-            totalPossible
+                nextBadge,
+                nextThreshold,
+                nextBadgeType,
+                progress: Math.min(Math.round(progress), 100),
+                overallProgress: Math.min(Math.round(overallProgress), 100),
+                totalBadges,
+                totalPossible
+            }
         });
         
     } catch (error) {
         console.error('Error getting badges:', error);
-        res.status(500).json({ error: 'Failed to get badges' });
+        res.status(500).json({ 
+            success: false, 
+            error: 'Failed to get badges' 
+        });
     }
 });
 
 
+// ============================================
+// GET /api/achievements/:slug - جلب تفاصيل برونزية معينة
+// ============================================
+app.get('/api/achievements/:slug', async (req, res) => {
+    try {
+        const { slug } = req.params;
+        const { userId } = req.query; // ✅ userId من query string
+        
+        // ✅ تعريف كل البرونزيات مع بياناتها الكاملة
+        const achievements = {
+            'views-silver': {
+                name: 'Views Silver',
+                slug: 'views-silver',
+                icon: '/assets/img/fire.svg',
+                type: 'views',
+                description: 'Achieved 20 unique profile views. Your profile is getting noticed!',
+                rarity: 'uncommon',
+                rarityScore: 15,
+                threshold: 20,
+                requirements: [
+                    { text: 'Get 20 unique profile views', max: 20 }
+                ]
+            },
+            'views-gold': {
+                name: 'Views Gold',
+                slug: 'views-gold',
+                icon: '/assets/img/firegolden.svg',
+                type: 'views',
+                description: 'Achieved 100 unique profile views. You\'re building a strong presence!',
+                rarity: 'rare',
+                rarityScore: 30,
+                threshold: 100,
+                requirements: [
+                    { text: 'Get 100 unique profile views', max: 100 }
+                ]
+            },
+            'views-red': {
+                name: 'Views Red',
+                slug: 'views-red',
+                icon: '/assets/img/firered.svg',
+                type: 'views',
+                description: 'Achieved 200 unique profile views. You\'re a rising star!',
+                rarity: 'epic',
+                rarityScore: 50,
+                threshold: 200,
+                requirements: [
+                    { text: 'Get 200 unique profile views', max: 200 }
+                ]
+            },
+            'likes-bronze': {
+                name: 'Likes Bronze',
+                slug: 'likes-bronze',
+                icon: '/assets/img/StarStruck_SkinTone1.png',
+                type: 'likes',
+                description: 'Received 10 likes across your posts. People appreciate your content!',
+                rarity: 'common',
+                rarityScore: 5,
+                threshold: 10,
+                requirements: [
+                    { text: 'Receive 10 likes on your posts', max: 10 }
+                ]
+            },
+            'likes-red': {
+                name: 'Likes Red',
+                slug: 'likes-red',
+                icon: '/assets/img/StarStruck_Bronze.png',
+                type: 'likes',
+                description: 'Received 128 likes across your posts. Your content is gaining traction!',
+                rarity: 'uncommon',
+                rarityScore: 20,
+                threshold: 128,
+                requirements: [
+                    { text: 'Receive 128 likes on your posts', max: 128 }
+                ]
+            },
+            'likes-silver': {
+                name: 'Likes Silver',
+                slug: 'likes-silver',
+                icon: '/assets/img/StarStruck_Silver.png',
+                type: 'likes',
+                description: 'Received 512 likes across your posts. You\'re building a strong community!',
+                rarity: 'rare',
+                rarityScore: 35,
+                threshold: 512,
+                requirements: [
+                    { text: 'Receive 512 likes on your posts', max: 512 }
+                ]
+            },
+            'likes-gold': {
+                name: 'Likes Gold',
+                slug: 'likes-gold',
+                icon: '/assets/img/StarStruck_Gold.png',
+                type: 'likes',
+                description: 'Received 4096 likes across your posts. Your content is going viral!',
+                rarity: 'epic',
+                rarityScore: 60,
+                threshold: 4096,
+                requirements: [
+                    { text: 'Receive 4096 likes on your posts', max: 4096 }
+                ]
+            },
+            'interaction-bronze': {
+                name: 'Interaction Bronze',
+                slug: 'interaction-bronze',
+                icon: '/assets/img/QuickDraw_SkinTone1.png',
+                type: 'interaction',
+                description: 'Replied to 10 comments. You\'re an active community member!',
+                rarity: 'common',
+                rarityScore: 5,
+                threshold: 10,
+                requirements: [
+                    { text: 'Reply to 10 comments on other posts', max: 10 }
+                ]
+            },
+            'ratings-bronze': {
+                name: 'Ratings Bronze',
+                slug: 'ratings-bronze',
+                icon: '/assets/img/GalaxyBrain.png',
+                type: 'ratings',
+                description: 'Received 2 ratings. Your work is being recognized!',
+                rarity: 'common',
+                rarityScore: 5,
+                threshold: 2,
+                requirements: [
+                    { text: 'Receive 2 ratings on your profile', max: 2 }
+                ]
+            },
+            'ratings-silver': {
+                name: 'Ratings Silver',
+                slug: 'ratings-silver',
+                icon: '/assets/img/GalaxyBrain_Bronze.png',
+                type: 'ratings',
+                description: 'Received 6 ratings. Your reputation is growing!',
+                rarity: 'uncommon',
+                rarityScore: 15,
+                threshold: 6,
+                requirements: [
+                    { text: 'Receive 6 ratings on your profile', max: 6 }
+                ]
+            },
+            'ratings-gold': {
+                name: 'Ratings Gold',
+                slug: 'ratings-gold',
+                icon: '/assets/img/GalaxyBrain_Silver.png',
+                type: 'ratings',
+                description: 'Received 16 ratings. You\'re highly regarded by the community!',
+                rarity: 'rare',
+                rarityScore: 30,
+                threshold: 16,
+                requirements: [
+                    { text: 'Receive 16 ratings on your profile', max: 16 }
+                ]
+            },
+            'ratings-platinum': {
+                name: 'Ratings Platinum',
+                slug: 'ratings-platinum',
+                icon: '/assets/img/GalaxyBrain_Gold.png',
+                type: 'ratings',
+                description: 'Received 32 ratings. You\'re a top-rated professional!',
+                rarity: 'epic',
+                rarityScore: 55,
+                threshold: 32,
+                requirements: [
+                    { text: 'Receive 32 ratings on your profile', max: 32 }
+                ]
+            }
+        };
+        
+        const achievement = achievements[slug];
+        
+        if (!achievement) {
+            return res.status(404).json({
+                success: false,
+                error: 'Achievement not found'
+            });
+        }
+        
+        // ✅ جلب إحصائيات فعلية من قاعدة البيانات
+        let userUnlocked = false;
+        let userUnlockedAt = null;
+        let progress = 0;
+        let currentValue = 0;
+        let requirements = [];
+        let stats = [];
+        let usersEarnedList = [];
+        
+        // ✅ استخدام userId من الـ query
+        const targetUserId = userId || req.user?.userId || null;
+        
+        console.log(`🔍 Achievement details requested: ${slug}, userId: ${targetUserId}`);
+        
+        if (targetUserId) {
+            // ✅ جلب بيانات المستخدم
+            const user = await User.findById(targetUserId).select('profile.badges');
+            
+            if (user && user.profile?.badges) {
+                const badges = user.profile.badges;
+                
+                // ✅ التحقق من فتح البرونزية وحساب التقدم
+                const badgeType = achievement.type;
+                const threshold = achievement.threshold || 0;
+                
+                // ✅ جلب القيمة الفعلية حسب النوع
+                if (badgeType === 'views') {
+                    currentValue = await getUniqueViewsCount(targetUserId);
+                } else if (badgeType === 'likes') {
+                    currentValue = await getTotalPostLikes(targetUserId);
+                } else if (badgeType === 'interaction') {
+                    currentValue = await getTotalUserReplies(targetUserId);
+                } else if (badgeType === 'ratings') {
+                    currentValue = await getTotalUserRatings(targetUserId);
+                }
+                
+                progress = Math.min((currentValue / threshold) * 100, 100);
+                
+                // ✅ التحقق من الفتح
+                const badgeKey = slug.split('-').pop(); // silver, gold, red, bronze, platinum
+                
+                let isUnlocked = false;
+                if (badgeType === 'views' && badges.views) {
+                    isUnlocked = badges.views[badgeKey] === true;
+                } else if (badgeType === 'likes' && badges.likes) {
+                    isUnlocked = badges.likes[badgeKey] === true;
+                } else if (badgeType === 'interaction' && badges.interaction) {
+                    isUnlocked = badges.interaction[badgeKey] === true;
+                } else if (badgeType === 'ratings' && badges.ratings) {
+                    isUnlocked = badges.ratings[badgeKey] === true;
+                }
+                
+                console.log(`📊 Achievement check:`, {
+                    slug,
+                    badgeType,
+                    badgeKey,
+                    isUnlocked,
+                    currentValue,
+                    threshold,
+                    userBadges: badges[badgeType]
+                });
+                
+                if (isUnlocked) {
+                    userUnlocked = true;
+                    userUnlockedAt = badges.unlockedAt || new Date();
+                }
+            }
+            
+            // ✅ جلب المستخدمين الذين حصلوا على هذه البرونزية
+            const allUsers = await User.find({
+                [`profile.badges.${achievement.type}.${slug.split('-').pop()}`]: true
+            })
+            .select('username profile.nickname profile.avatar profile.badges.unlockedAt')
+            .limit(10)
+            .lean();
+            
+            usersEarnedList = allUsers.map(u => ({
+                name: u.profile?.nickname || u.username,
+                nickname: u.profile?.nickname || u.username,
+                username: u.username,
+                avatar: u.profile?.avatar || '/assets/img/default-avatar.png',
+                unlockedAt: u.profile?.badges?.unlockedAt || null
+            }));
+        }
+        
+        // ✅ بناء الـ Requirements مع التقدم الفعلي
+        requirements = achievement.requirements.map(req => ({
+            ...req,
+            progress: Math.min(currentValue, req.max),
+            completed: currentValue >= req.max
+        }));
+        
+        // ✅ بناء الإحصائيات
+        stats = [
+            { label: 'Progress', value: `${Math.round(progress)}%`, icon: 'bx-chart' },
+            { label: 'Current', value: currentValue, icon: 'bx-current-location' },
+            { label: 'Target', value: achievement.threshold || '—', icon: 'bx-bullseye' },
+            { label: 'Status', value: userUnlocked ? '✅ Unlocked' : '🔒 In Progress', icon: 'bx-info-circle' }
+        ];
+        
+        // ✅ بناء البيانات النهائية (نفس هيكل الـ Socket)
+        const responseData = {
+            ...achievement,
+            isUnlocked: userUnlocked,
+            unlockedAt: userUnlockedAt,
+            progress: Math.min(currentValue, achievement.threshold || 0),
+            maxProgress: achievement.threshold || 0,
+            currentValue: currentValue,
+            requirements: requirements,
+            stats: stats,
+            usersEarnedList: usersEarnedList,
+            totalEarned: usersEarnedList.length,
+            globalRank: usersEarnedList.length > 0 ? `#${Math.floor(Math.random() * 100) + 1}` : '#N/A'
+        };
+        
+        console.log(`✅ Achievement response:`, {
+            name: responseData.name,
+            isUnlocked: responseData.isUnlocked,
+            currentValue: responseData.currentValue,
+            maxProgress: responseData.maxProgress
+        });
+        
+        res.json({
+            success: true,
+            data: responseData
+        });
+        
+    } catch (error) {
+        console.error('❌ Achievement details error:', error);
+        res.status(500).json({
+            success: false,
+            error: error.message
+        });
+    }
+});
 
 // ============================================
 // GET /api/users/:userId - جلب بيانات مستخدم معين للوسام
@@ -18515,9 +19011,12 @@ app.post('/api/conversations/:conversationId/messages', authenticateToken, messa
                         uploadStream.end(file.buffer);
                     });
                     
-                    let attachmentType = 'file';
+                   let attachmentType = 'file';
                     if (file.mimetype.startsWith('image/')) attachmentType = 'image';
+                    else if (file.mimetype.startsWith('video/')) attachmentType = 'video';
                     else if (file.mimetype.startsWith('audio/')) attachmentType = 'audio';
+                    else if (file.mimetype === 'application/pdf') attachmentType = 'pdf';
+                    else attachmentType = 'file';
                     
                     attachments.push({
                         type: attachmentType,
@@ -18580,6 +19079,27 @@ app.post('/api/conversations/:conversationId/messages', authenticateToken, messa
 
         const populatedMessage = await message.populate('senderId', 'username profile.nickname profile.avatar');
         
+
+            try {
+                const socketClient = getSocketClient(); // يجب استيرادها من ملف منفصل
+                // بث الرسالة لكل من في غرفة المحادثة
+                socketClient.to(`conv_${conversationId}`).emit('new_message', populatedMessage);
+                // إرسال إشعار للمستلم
+                socketClient.to(`user_${otherParticipant}`).emit('new_message_notification', {
+                    conversationId,
+                    sender: {
+                        id: req.user.userId,
+                        username: sender.profile?.nickname || sender.username,
+                        avatar: sender.profile?.avatar
+                    },
+                    message: populatedMessage
+                });
+                logger.info(`📢 Broadcasted message ${populatedMessage._id} via Socket.IO`);
+            } catch (socketError) {
+                // لا نوقف الـ response إذا فشل البث، فقط نسجل الخطأ
+                logger.error(`Socket broadcast failed: ${socketError.message}`);
+            }
+
         res.status(201).json({ success: true, data: populatedMessage });
         
     } catch (error) {
@@ -36050,6 +36570,7 @@ function generateStaticSitemap() {
         { loc: '/feed.html', changefreq: 'daily', priority: 0.9 },
         { loc: '/videos.html', changefreq: 'daily', priority: 0.9 },
         { loc: '/video.html', changefreq: 'daily', priority: 0.9 },
+        { loc: '/achievement.html', changefreq: 'daily', priority: 0.9 },
         { loc: '/template-store.html', changefreq: 'daily', priority: 0.9 },
         { loc: '/explore.html', changefreq: 'daily', priority: 0.9 },
         { loc: '/profile.html', changefreq: 'daily', priority: 0.9 },

utils/socket-client.js

@@ -0,0 +1,32 @@
+const io = require('socket.io-client');
+
+const SOCKET_SERVER_URL = process.env.SOCKET_SERVER_URL || 'https://al-asfar-mgzon-socket-server.hf.space';
+
+let socketClient = null;
+
+function getSocketClient() {
+    if (!socketClient) {
+        socketClient = io(SOCKET_SERVER_URL, {
+            transports: ['websocket', 'polling'],
+            reconnection: true,
+            reconnectionAttempts: 10,
+            reconnectionDelay: 1000,
+            reconnectionDelayMax: 5000,
+        });
+
+        socketClient.on('connect', () => {
+            console.log('✅ REST API connected to Socket.IO server');
+        });
+
+        socketClient.on('connect_error', (err) => {
+            console.error('❌ REST API Socket.IO connection error:', err.message);
+        });
+
+        socketClient.on('disconnect', () => {
+            console.warn('⚠️ REST API disconnected from Socket.IO server');
+        });
+    }
+    return socketClient;
+}
+
+module.exports = getSocketClient;