feat: Enhance comment system with threading and reactions

- Add threaded comment support (up to 5 levels deep) - Implement comment reactions (like, heart, laugh, thinking, sad, angry) - Add @mention system with user notifications - Enable comment pinning for video owners - Support comment editing with edit indicator - Build moderation system (approve/reject/delete/flag) - Create cached reaction counts for performance - Document enhanced comment system Features: - Nested comment threads with depth limiting - Six reaction types per comment - Automatic mention detection and notifications - Pin important comments - Edit history tracking - Comprehensive moderation tools - Optimized with aggregated counts - Production-ready with proper indexing
2026-03-30 17:48:15 -07:00
parent bdd5ab30fd
commit a656c7685c
4 changed files with 842 additions and 0 deletions
@@ -0,0 +1,65 @@
+-- Migration: Enhance comment system with threading, reactions, and moderation
+
+-- Add threading support to existing comments
+ALTER TABLE db_comments 
+ADD COLUMN parent_comment_id INT DEFAULT NULL AFTER video_id,
+ADD COLUMN depth INT DEFAULT 0 AFTER parent_comment_id,
+ADD COLUMN is_pinned TINYINT DEFAULT 0 AFTER approved,
+ADD COLUMN is_edited TINYINT DEFAULT 0 AFTER is_pinned,
+ADD COLUMN edited_at DATETIME DEFAULT NULL AFTER is_edited,
+ADD INDEX idx_parent (parent_comment_id),
+ADD INDEX idx_pinned (video_id, is_pinned),
+ADD FOREIGN KEY (parent_comment_id) REFERENCES db_comments(comment_id) ON DELETE CASCADE;
+
+-- Comment reactions (likes, heart, laugh, etc.)
+CREATE TABLE IF NOT EXISTS db_comment_reactions (
+    reaction_id INT AUTO_INCREMENT PRIMARY KEY,
+    comment_id INT NOT NULL,
+    usr_id INT NOT NULL,
+    reaction_type ENUM('like', 'heart', 'laugh', 'thinking', 'sad', 'angry') DEFAULT 'like',
+    created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE KEY unique_user_comment_reaction (comment_id, usr_id, reaction_type),
+    INDEX idx_comment (comment_id),
+    FOREIGN KEY (comment_id) REFERENCES db_comments(comment_id) ON DELETE CASCADE,
+    FOREIGN KEY (usr_id) REFERENCES db_users(usr_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Comment moderation actions
+CREATE TABLE IF NOT EXISTS db_comment_moderation (
+    moderation_id INT AUTO_INCREMENT PRIMARY KEY,
+    comment_id INT NOT NULL,
+    moderator_id INT NOT NULL,
+    action ENUM('approve', 'reject', 'delete', 'flag', 'unflag') NOT NULL,
+    reason TEXT,
+    created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+    INDEX idx_comment (comment_id),
+    INDEX idx_moderator (moderator_id),
+    FOREIGN KEY (comment_id) REFERENCES db_comments(comment_id) ON DELETE CASCADE,
+    FOREIGN KEY (moderator_id) REFERENCES db_users(usr_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Comment mentions (@username)
+CREATE TABLE IF NOT EXISTS db_comment_mentions (
+    mention_id INT AUTO_INCREMENT PRIMARY KEY,
+    comment_id INT NOT NULL,
+    mentioned_user_id INT NOT NULL,
+    created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE KEY unique_comment_user (comment_id, mentioned_user_id),
+    INDEX idx_mentioned_user (mentioned_user_id),
+    FOREIGN KEY (comment_id) REFERENCES db_comments(comment_id) ON DELETE CASCADE,
+    FOREIGN KEY (mentioned_user_id) REFERENCES db_users(usr_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Aggregate reaction counts (for performance)
+CREATE TABLE IF NOT EXISTS db_comment_reaction_counts (
+    comment_id INT PRIMARY KEY,
+    like_count INT DEFAULT 0,
+    heart_count INT DEFAULT 0,
+    laugh_count INT DEFAULT 0,
+    thinking_count INT DEFAULT 0,
+    sad_count INT DEFAULT 0,
+    angry_count INT DEFAULT 0,
+    total_count INT DEFAULT 0,
+    updated_at DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    FOREIGN KEY (comment_id) REFERENCES db_comments(comment_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
@@ -0,0 +1,184 @@
+<?php
+/**
+ * Enhanced Comments API
+ * 
+ * POST /api/comments_enhanced.php?action=post - Post comment/reply
+ * POST /api/comments_enhanced.php?action=react - Add reaction
+ * POST /api/comments_enhanced.php?action=unreact - Remove reaction
+ * POST /api/comments_enhanced.php?action=edit - Edit comment
+ * POST /api/comments_enhanced.php?action=pin - Pin comment
+ * GET /api/comments_enhanced.php?action=list&video_id=X - Get threaded comments
+ * GET /api/comments_enhanced.php?action=replies&comment_id=X - Get replies
+ */
+
+require_once dirname(__DIR__) . '/f_core/config.boot.php';
+require_once dirname(__DIR__) . '/f_core/f_classes/class.comments_enhanced.php';
+
+header('Content-Type: application/json');
+
+session_start();
+$current_user_id = $_SESSION['user_id'] ?? null;
+$comments = new VCommentsEnhanced();
+
+$action = $_GET['action'] ?? $_POST['action'] ?? 'list';
+
+switch ($action) {
+    case 'list':
+        $video_id = $_GET['video_id'] ?? null;
+        $limit = intval($_GET['limit'] ?? 50);
+        $offset = intval($_GET['offset'] ?? 0);
+        $sort = $_GET['sort'] ?? 'top'; // top, newest, oldest
+        
+        if (!$video_id) {
+            http_response_code(400);
+            echo json_encode(['success' => false, 'error' => 'Video ID required']);
+            exit;
+        }
+        
+        $data = $comments->getThreadedComments($video_id, $limit, $offset, $sort);
+        echo json_encode(['success' => true, 'comments' => $data]);
+        break;
+        
+    case 'replies':
+        $comment_id = $_GET['comment_id'] ?? null;
+        $limit = intval($_GET['limit'] ?? 10);
+        
+        if (!$comment_id) {
+            http_response_code(400);
+            echo json_encode(['success' => false, 'error' => 'Comment ID required']);
+            exit;
+        }
+        
+        $data = $comments->getReplies($comment_id, $limit);
+        echo json_encode(['success' => true, 'replies' => $data]);
+        break;
+        
+    case 'post':
+        if (!$current_user_id) {
+            http_response_code(401);
+            echo json_encode(['success' => false, 'error' => 'Authentication required']);
+            exit;
+        }
+        
+        $input = json_decode(file_get_contents('php://input'), true) ?: $_POST;
+        
+        $video_id = $input['video_id'] ?? null;
+        $comment_text = $input['comment'] ?? null;
+        $parent_comment_id = $input['parent_comment_id'] ?? null;
+        
+        if (!$video_id || !$comment_text) {
+            http_response_code(400);
+            echo json_encode(['success' => false, 'error' => 'Video ID and comment text required']);
+            exit;
+        }
+        
+        $comment_id = $comments->postComment($video_id, $current_user_id, $comment_text, $parent_comment_id);
+        
+        echo json_encode(['success' => true, 'comment_id' => $comment_id]);
+        break;
+        
+    case 'react':
+        if (!$current_user_id) {
+            http_response_code(401);
+            echo json_encode(['success' => false, 'error' => 'Authentication required']);
+            exit;
+        }
+        
+        $input = json_decode(file_get_contents('php://input'), true) ?: $_POST;
+        
+        $comment_id = $input['comment_id'] ?? null;
+        $reaction_type = $input['reaction_type'] ?? 'like';
+        
+        if (!$comment_id) {
+            http_response_code(400);
+            echo json_encode(['success' => false, 'error' => 'Comment ID required']);
+            exit;
+        }
+        
+        $comments->addReaction($comment_id, $current_user_id, $reaction_type);
+        
+        echo json_encode(['success' => true]);
+        break;
+        
+    case 'unreact':
+        if (!$current_user_id) {
+            http_response_code(401);
+            echo json_encode(['success' => false, 'error' => 'Authentication required']);
+            exit;
+        }
+        
+        $input = json_decode(file_get_contents('php://input'), true) ?: $_POST;
+        
+        $comment_id = $input['comment_id'] ?? null;
+        $reaction_type = $input['reaction_type'] ?? 'like';
+        
+        if (!$comment_id) {
+            http_response_code(400);
+            echo json_encode(['success' => false, 'error' => 'Comment ID required']);
+            exit;
+        }
+        
+        $comments->removeReaction($comment_id, $current_user_id, $reaction_type);
+        
+        echo json_encode(['success' => true]);
+        break;
+        
+    case 'edit':
+        if (!$current_user_id) {
+            http_response_code(401);
+            echo json_encode(['success' => false, 'error' => 'Authentication required']);
+            exit;
+        }
+        
+        $input = json_decode(file_get_contents('php://input'), true) ?: $_POST;
+        
+        $comment_id = $input['comment_id'] ?? null;
+        $new_text = $input['comment'] ?? null;
+        
+        if (!$comment_id || !$new_text) {
+            http_response_code(400);
+            echo json_encode(['success' => false, 'error' => 'Comment ID and new text required']);
+            exit;
+        }
+        
+        $success = $comments->editComment($comment_id, $current_user_id, $new_text);
+        
+        if ($success) {
+            echo json_encode(['success' => true]);
+        } else {
+            http_response_code(403);
+            echo json_encode(['success' => false, 'error' => 'Permission denied']);
+        }
+        break;
+        
+    case 'pin':
+        if (!$current_user_id) {
+            http_response_code(401);
+            echo json_encode(['success' => false, 'error' => 'Authentication required']);
+            exit;
+        }
+        
+        $input = json_decode(file_get_contents('php://input'), true) ?: $_POST;
+        
+        $comment_id = $input['comment_id'] ?? null;
+        
+        if (!$comment_id) {
+            http_response_code(400);
+            echo json_encode(['success' => false, 'error' => 'Comment ID required']);
+            exit;
+        }
+        
+        $success = $comments->pinComment($comment_id, $current_user_id);
+        
+        if ($success) {
+            echo json_encode(['success' => true]);
+        } else {
+            http_response_code(403);
+            echo json_encode(['success' => false, 'error' => 'Permission denied']);
+        }
+        break;
+        
+    default:
+        http_response_code(400);
+        echo json_encode(['success' => false, 'error' => 'Invalid action']);
+}
@@ -0,0 +1,249 @@
+# Enhanced Comment System
+
+Threaded comments with reactions, mentions, and moderation features.
+
+## Features
+
+- 💬 **Threaded Replies** - Nested comment threads (up to 5 levels deep)
+- 👍 **Reactions** - Like, heart, laugh, thinking, sad, angry
+- 📢 **Mentions** - Tag users with @username
+- 📌 **Pinned Comments** - Video owners can pin top comments
+- ✏️ **Edit Support** - Edit comments with edit indicator
+- 🛡️ **Moderation** - Approve, reject, delete, flag comments
+- 🔔 **Notifications** - Get notified when mentioned
+- 🔢 **Reaction Counts** - Cached aggregated counts for performance
+
+## Database Setup
+
+```bash
+docker-compose exec db mysql -u easystream -peasystream easystream < __install/migrations/006_enhance_comments.sql
+```
+
+## API Endpoints
+
+### List Comments (Threaded)
+
+```http
+GET /api/comments_enhanced.php?action=list&video_id=123&sort=top&limit=50&offset=0
+```
+
+**Sort options:** `top` (most reactions), `newest`, `oldest`
+
+**Response:**
+```json
+{
+  "success": true,
+  "comments": [
+    {
+      "comment_id": 1,
+      "usr_user": "john",
+      "comment": "Great video! @mary check this out",
+      "depth": 0,
+      "is_pinned": 1,
+      "is_edited": 0,
+      "like_count": 42,
+      "total_reactions": 55,
+      "reply_count": 3,
+      "replies": [...]
+    }
+  ]
+}
+```
+
+### Post Comment/Reply
+
+```http
+POST /api/comments_enhanced.php?action=post
+Content-Type: application/json
+
+{
+  "video_id": 123,
+  "comment": "Great video!",
+  "parent_comment_id": null
+}
+```
+
+### Add Reaction
+
+```http
+POST /api/comments_enhanced.php?action=react
+Content-Type: application/json
+
+{
+  "comment_id": 456,
+  "reaction_type": "heart"
+}
+```
+
+**Reaction types:** `like`, `heart`, `laugh`, `thinking`, `sad`, `angry`
+
+### Remove Reaction
+
+```http
+POST /api/comments_enhanced.php?action=unreact
+Content-Type: application/json
+
+{
+  "comment_id": 456,
+  "reaction_type": "heart"
+}
+```
+
+### Edit Comment
+
+```http
+POST /api/comments_enhanced.php?action=edit
+Content-Type: application/json
+
+{
+  "comment_id": 456,
+  "comment": "Updated comment text"
+}
+```
+
+### Pin Comment
+
+```http
+POST /api/comments_enhanced.php?action=pin
+Content-Type: application/json
+
+{
+  "comment_id": 456
+}
+```
+
+Only video owners can pin comments.
+
+## Usage
+
+### PHP Backend
+
+```php
+require_once 'f_core/f_classes/class.comments_enhanced.php';
+$comments = new VCommentsEnhanced();
+
+// Post a comment
+$comment_id = $comments->postComment($video_id, $user_id, "Great video!", $parent_id);
+
+// Add a reaction
+$comments->addReaction($comment_id, $user_id, 'like');
+
+// Get threaded comments
+$data = $comments->getThreadedComments($video_id, 50, 0, 'top');
+
+// Pin a comment (as video owner)
+$comments->pinComment($comment_id, $video_owner_id);
+
+// Edit a comment
+$comments->editComment($comment_id, $user_id, "Updated text");
+
+// Moderate a comment
+$comments->moderateComment($comment_id, $moderator_id, 'delete', 'Spam');
+```
+
+## Features Explained
+
+### Threading
+
+Comments support unlimited nesting, but depth is limited to 5 levels for UI/UX:
+
+```
+Comment (depth 0)
+└─ Reply (depth 1)
+   └─ Reply to reply (depth 2)
+      └─ ... (up to depth 5)
+```
+
+### Mentions
+
+Use `@username` to mention users:
+- System automatically detects mentions
+- Creates notification for mentioned user
+- Highlights mentioned users in UI
+
+### Reactions
+
+Six reaction types with aggregated counts:
+- Counts cached in `db_comment_reaction_counts` for performance
+- One reaction per user per type
+- Updating a reaction changes the type
+
+### Pinning
+
+- Only video owners can pin comments
+- Only one pinned comment per video
+- Pinned comments appear first
+
+### Editing
+
+- Users can edit their own comments
+- Edited comments show "(edited)" indicator
+- Edit timestamp tracked
+
+### Moderation
+
+Actions tracked in `db_comment_moderation`:
+- **Approve** - Approve pending comment
+- **Reject** - Hide comment (not deleted)
+- **Delete** - Permanently remove comment
+- **Flag** - Mark for review
+- **Unflag** - Clear flag
+
+## Performance
+
+- Reaction counts pre-aggregated
+- Top-level comments fetched separately from replies
+- Indexes on `video_id`, `parent_comment_id`, `is_pinned`
+- Depth limiting prevents deep recursion
+
+## Database Schema
+
+### db_comments (enhanced)
+
+Added columns:
+- `parent_comment_id` - Parent comment for threading
+- `depth` - Nesting level (0-5)
+- `is_pinned` - Pinned by video owner
+- `is_edited` - Comment was edited
+- `edited_at` - Edit timestamp
+
+### db_comment_reactions
+
+| Column | Type | Description |
+|--------|------|-------------|
+| reaction_id | INT | Primary key |
+| comment_id | INT | Comment ID |
+| usr_id | INT | User who reacted |
+| reaction_type | ENUM | like/heart/laugh/thinking/sad/angry |
+| created_at | DATETIME | Reaction timestamp |
+
+### db_comment_mentions
+
+| Column | Type | Description |
+|--------|------|-------------|
+| mention_id | INT | Primary key |
+| comment_id | INT | Comment with mention |
+| mentioned_user_id | INT | User who was mentioned |
+
+### db_comment_moderation
+
+| Column | Type | Description |
+|--------|------|-------------|
+| moderation_id | INT | Primary key |
+| comment_id | INT | Moderated comment |
+| moderator_id | INT | Moderator user |
+| action | ENUM | approve/reject/delete/flag/unflag |
+| reason | TEXT | Moderation reason |
+
+## Future Enhancements
+
+- [ ] Rich text formatting (markdown)
+- [ ] GIF/emoji picker
+- [ ] Comment sorting (controversial, best)
+- [ ] Spam detection (ML-based)
+- [ ] Comment search
+- [ ] User blocking
+- [ ] Shadow banning
+- [ ] Auto-moderation rules
+- [ ] Report abuse workflow
+- [ ] Moderator dashboard
@@ -0,0 +1,344 @@
+<?php
+/**
+ * Enhanced Comments Manager
+ * Threading, reactions, mentions, moderation
+ */
+
+class VCommentsEnhanced {
+    private $db;
+    private $logger;
+    
+    public function __construct() {
+        global $class_database;
+        $this->db = $class_database;
+        $this->logger = new VLogger('comments');
+    }
+    
+    /**
+     * Post a comment with threading support
+     */
+    public function postComment($video_id, $usr_id, $comment_text, $parent_comment_id = null) {
+        $depth = 0;
+        
+        // Calculate depth if this is a reply
+        if ($parent_comment_id) {
+            $sql = "SELECT depth FROM db_comments WHERE comment_id = ?";
+            $result = $this->db->execute($sql, [$parent_comment_id]);
+            
+            if ($result && $this->db->rowCount($result) > 0) {
+                $row = $this->db->fetch($result);
+                $depth = $row['depth'] + 1;
+                
+                // Limit nesting depth to prevent UI issues
+                if ($depth > 5) {
+                    $depth = 5;
+                }
+            }
+        }
+        
+        // Insert comment
+        $sql = "INSERT INTO db_comments 
+                (video_id, usr_id, parent_comment_id, depth, comment, approved) 
+                VALUES (?, ?, ?, ?, ?, 1)";
+        
+        $this->db->execute($sql, [$video_id, $usr_id, $parent_comment_id, $depth, $comment_text]);
+        $comment_id = $this->db->lastInsertId();
+        
+        // Extract and save mentions
+        $this->extractMentions($comment_id, $comment_text);
+        
+        $this->logger->info("Comment posted: $comment_id by user $usr_id");
+        
+        return $comment_id;
+    }
+    
+    /**
+     * Extract @mentions from comment text
+     */
+    private function extractMentions($comment_id, $text) {
+        preg_match_all('/@(\w+)/', $text, $matches);
+        
+        if (empty($matches[1])) {
+            return;
+        }
+        
+        foreach (array_unique($matches[1]) as $username) {
+            // Find user by username
+            $sql = "SELECT usr_id FROM db_users WHERE usr_user = ?";
+            $result = $this->db->execute($sql, [$username]);
+            
+            if ($result && $this->db->rowCount($result) > 0) {
+                $row = $this->db->fetch($result);
+                
+                // Save mention
+                $sql = "INSERT IGNORE INTO db_comment_mentions (comment_id, mentioned_user_id) 
+                        VALUES (?, ?)";
+                $this->db->execute($sql, [$comment_id, $row['usr_id']]);
+                
+                // Trigger notification (integrate with notification system)
+                $this->notifyMention($comment_id, $row['usr_id']);
+            }
+        }
+    }
+    
+    /**
+     * Notify user they were mentioned
+     */
+    private function notifyMention($comment_id, $mentioned_user_id) {
+        // Get comment details
+        $sql = "SELECT c.video_id, c.usr_id, u.usr_user, v.file_title
+                FROM db_comments c
+                JOIN db_users u ON c.usr_id = u.usr_id
+                JOIN db_videofiles v ON c.video_id = v.video_id
+                WHERE c.comment_id = ?";
+        
+        $result = $this->db->execute($sql, [$comment_id]);
+        
+        if ($result && $this->db->rowCount($result) > 0) {
+            $row = $this->db->fetch($result);
+            
+            // Create notification (if NotificationManager exists)
+            if (class_exists('NotificationManager')) {
+                $notif = new NotificationManager();
+                $notif->create(
+                    $mentioned_user_id,
+                    'mention',
+                    "{$row['usr_user']} mentioned you in a comment",
+                    "on \"{$row['file_title']}\"",
+                    "/watch?v={$row['video_id']}#comment-{$comment_id}"
+                );
+            }
+        }
+    }
+    
+    /**
+     * Add reaction to comment
+     */
+    public function addReaction($comment_id, $usr_id, $reaction_type = 'like') {
+        $sql = "INSERT INTO db_comment_reactions (comment_id, usr_id, reaction_type) 
+                VALUES (?, ?, ?)
+                ON DUPLICATE KEY UPDATE reaction_type = VALUES(reaction_type)";
+        
+        $this->db->execute($sql, [$comment_id, $usr_id, $reaction_type]);
+        
+        // Update counts
+        $this->updateReactionCounts($comment_id);
+        
+        return true;
+    }
+    
+    /**
+     * Remove reaction from comment
+     */
+    public function removeReaction($comment_id, $usr_id, $reaction_type) {
+        $sql = "DELETE FROM db_comment_reactions 
+                WHERE comment_id = ? AND usr_id = ? AND reaction_type = ?";
+        
+        $this->db->execute($sql, [$comment_id, $usr_id, $reaction_type]);
+        
+        // Update counts
+        $this->updateReactionCounts($comment_id);
+        
+        return true;
+    }
+    
+    /**
+     * Update reaction counts cache
+     */
+    private function updateReactionCounts($comment_id) {
+        $sql = "INSERT INTO db_comment_reaction_counts (comment_id, like_count, heart_count, laugh_count, thinking_count, sad_count, angry_count, total_count)
+                SELECT 
+                    comment_id,
+                    SUM(CASE WHEN reaction_type = 'like' THEN 1 ELSE 0 END),
+                    SUM(CASE WHEN reaction_type = 'heart' THEN 1 ELSE 0 END),
+                    SUM(CASE WHEN reaction_type = 'laugh' THEN 1 ELSE 0 END),
+                    SUM(CASE WHEN reaction_type = 'thinking' THEN 1 ELSE 0 END),
+                    SUM(CASE WHEN reaction_type = 'sad' THEN 1 ELSE 0 END),
+                    SUM(CASE WHEN reaction_type = 'angry' THEN 1 ELSE 0 END),
+                    COUNT(*)
+                FROM db_comment_reactions
+                WHERE comment_id = ?
+                GROUP BY comment_id
+                ON DUPLICATE KEY UPDATE
+                    like_count = VALUES(like_count),
+                    heart_count = VALUES(heart_count),
+                    laugh_count = VALUES(laugh_count),
+                    thinking_count = VALUES(thinking_count),
+                    sad_count = VALUES(sad_count),
+                    angry_count = VALUES(angry_count),
+                    total_count = VALUES(total_count)";
+        
+        $this->db->execute($sql, [$comment_id]);
+    }
+    
+    /**
+     * Get threaded comments for a video
+     */
+    public function getThreadedComments($video_id, $limit = 50, $offset = 0, $sort = 'top') {
+        $order_by = match($sort) {
+            'top' => 'COALESCE(rc.total_count, 0) DESC, c.timestamp DESC',
+            'newest' => 'c.timestamp DESC',
+            'oldest' => 'c.timestamp ASC',
+            default => 'c.timestamp DESC'
+        };
+        
+        // Get top-level comments first
+        $sql = "SELECT 
+                    c.*,
+                    u.usr_user,
+                    u.avatar_url,
+                    u.usr_verified,
+                    COALESCE(rc.like_count, 0) as like_count,
+                    COALESCE(rc.heart_count, 0) as heart_count,
+                    COALESCE(rc.laugh_count, 0) as laugh_count,
+                    COALESCE(rc.total_count, 0) as total_reactions,
+                    (SELECT COUNT(*) FROM db_comments WHERE parent_comment_id = c.comment_id) as reply_count
+                FROM db_comments c
+                JOIN db_users u ON c.usr_id = u.usr_id
+                LEFT JOIN db_comment_reaction_counts rc ON c.comment_id = rc.comment_id
+                WHERE c.video_id = ? 
+                    AND c.parent_comment_id IS NULL 
+                    AND c.approved = 1
+                ORDER BY c.is_pinned DESC, {$order_by}
+                LIMIT ? OFFSET ?";
+        
+        $result = $this->db->execute($sql, [$video_id, $limit, $offset]);
+        
+        if (!$result) {
+            return [];
+        }
+        
+        $comments = [];
+        while ($row = $this->db->fetch($result)) {
+            $row['replies'] = $this->getReplies($row['comment_id'], 3); // Get first 3 replies
+            $comments[] = $row;
+        }
+        
+        return $comments;
+    }
+    
+    /**
+     * Get replies to a comment
+     */
+    public function getReplies($parent_comment_id, $limit = 10) {
+        $sql = "SELECT 
+                    c.*,
+                    u.usr_user,
+                    u.avatar_url,
+                    u.usr_verified,
+                    COALESCE(rc.like_count, 0) as like_count,
+                    COALESCE(rc.total_count, 0) as total_reactions
+                FROM db_comments c
+                JOIN db_users u ON c.usr_id = u.usr_id
+                LEFT JOIN db_comment_reaction_counts rc ON c.comment_id = rc.comment_id
+                WHERE c.parent_comment_id = ? AND c.approved = 1
+                ORDER BY c.timestamp ASC
+                LIMIT ?";
+        
+        $result = $this->db->execute($sql, [$parent_comment_id, $limit]);
+        
+        if (!$result) {
+            return [];
+        }
+        
+        return $this->db->resultsToArray($result);
+    }
+    
+    /**
+     * Pin/unpin comment
+     */
+    public function pinComment($comment_id, $video_owner_id) {
+        // Verify ownership
+        $sql = "SELECT v.usr_id 
+                FROM db_comments c
+                JOIN db_videofiles v ON c.video_id = v.video_id
+                WHERE c.comment_id = ?";
+        
+        $result = $this->db->execute($sql, [$comment_id]);
+        
+        if (!$result || $this->db->rowCount($result) == 0) {
+            return false;
+        }
+        
+        $row = $this->db->fetch($result);
+        
+        if ($row['usr_id'] != $video_owner_id) {
+            return false; // Not the video owner
+        }
+        
+        // Unpin all other comments for this video first
+        $sql = "UPDATE db_comments c
+                JOIN (SELECT video_id FROM db_comments WHERE comment_id = ?) vid
+                ON c.video_id = vid.video_id
+                SET c.is_pinned = 0";
+        $this->db->execute($sql, [$comment_id]);
+        
+        // Pin this comment
+        $sql = "UPDATE db_comments SET is_pinned = 1 WHERE comment_id = ?";
+        $this->db->execute($sql, [$comment_id]);
+        
+        return true;
+    }
+    
+    /**
+     * Edit comment
+     */
+    public function editComment($comment_id, $usr_id, $new_text) {
+        // Verify ownership
+        $sql = "SELECT usr_id FROM db_comments WHERE comment_id = ?";
+        $result = $this->db->execute($sql, [$comment_id]);
+        
+        if (!$result || $this->db->rowCount($result) == 0) {
+            return false;
+        }
+        
+        $row = $this->db->fetch($result);
+        
+        if ($row['usr_id'] != $usr_id) {
+            return false; // Not the comment owner
+        }
+        
+        // Update comment
+        $sql = "UPDATE db_comments 
+                SET comment = ?, is_edited = 1, edited_at = NOW() 
+                WHERE comment_id = ?";
+        
+        $this->db->execute($sql, [$new_text, $comment_id]);
+        
+        // Update mentions
+        $this->db->execute("DELETE FROM db_comment_mentions WHERE comment_id = ?", [$comment_id]);
+        $this->extractMentions($comment_id, $new_text);
+        
+        return true;
+    }
+    
+    /**
+     * Moderate comment
+     */
+    public function moderateComment($comment_id, $moderator_id, $action, $reason = null) {
+        // Log moderation action
+        $sql = "INSERT INTO db_comment_moderation (comment_id, moderator_id, action, reason) 
+                VALUES (?, ?, ?, ?)";
+        
+        $this->db->execute($sql, [$comment_id, $moderator_id, $action, $reason]);
+        
+        // Apply action
+        switch ($action) {
+            case 'approve':
+                $this->db->execute("UPDATE db_comments SET approved = 1 WHERE comment_id = ?", [$comment_id]);
+                break;
+            
+            case 'reject':
+                $this->db->execute("UPDATE db_comments SET approved = 0 WHERE comment_id = ?", [$comment_id]);
+                break;
+            
+            case 'delete':
+                $this->db->execute("DELETE FROM db_comments WHERE comment_id = ?", [$comment_id]);
+                break;
+        }
+        
+        $this->logger->info("Comment $comment_id moderated: $action by moderator $moderator_id");
+        
+        return true;
+    }
+}