Merge pull request #10 from GeneralMagicio/add/status-for-videos

Add status field to videos collection for content moderation

Author: mhmdksh

config/migrations.js

@@ -108,6 +108,31 @@ const migrations = [
         console.log('❌ userId index did not exist or could not be dropped');
       }
     }
+  },
+  {
+    version: '1.2.0',
+    description: 'Add status field to video schema for content moderation',
+    up: async () => {
+      const db = mongoose.connection.db;
+      console.log('Using database:', db.databaseName);
+      
+      // No need to modify existing documents - new fields are optional with default values
+      // Mongoose schema will handle validation and default values for new uploads
+      console.log('✅ Schema updated to support status field with enum [rejected, pending, approved]');
+      console.log('📋 Note: Existing documents preserved. New uploads can optionally specify status (defaults to "pending")');
+    },
+    down: async () => {
+      const db = mongoose.connection.db;
+      const collection = db.collection('videos');
+      
+      // Remove status field from existing documents
+      try {
+        const result = await collection.updateMany({}, { $unset: { status: "" } });
+        console.log(`❌ Status field removed from ${result.modifiedCount} documents`);
+      } catch (error) {
+        console.log('❌ Could not remove status field:', error.message);
+      }
+    }
   }
 ];
 

middleware/validation.js

@@ -4,7 +4,8 @@ const videoUploadSchema = Joi.object({
   userId: Joi.string().optional().trim().min(1).max(100),  // Make optional
   latitude: Joi.number().required().min(-90).max(90),
   longitude: Joi.number().required().min(-180).max(180),
-  type: Joi.string().optional().valid('before', 'after')   // Make optional
+  type: Joi.string().optional().valid('before', 'after'),   // Make optional
+  status: Joi.string().optional().valid('rejected', 'pending', 'approved')  // Make optional
 });
 
 const validateVideoUpload = (req, res, next) => {

models/Video.js

@@ -30,6 +30,12 @@ const videoSchema = new mongoose.Schema({
     required: false,  // Make optional for backward compatibility
     index: true
   },
+  status: {
+    type: String,
+    required: false,  // Make optional for backward compatibility
+    enum: ['rejected', 'pending', 'approved'],
+    default: 'pending'
+  },
   gpsCoordinates: {
     latitude: {
       type: Number,

routes/videos.js

@@ -9,14 +9,14 @@ const videoService = new VideoService();
 
 router.post('/upload', upload.single('video'), validateVideoUpload, async (req, res) => {
   try {
-    const { userId, latitude, longitude, type } = req.body;
+    const { userId, latitude, longitude, type, status } = req.body;
     const file = req.file;
 
     if (!file) {
       return sendBadRequest(res, 'No video file provided');
     }
 
-    const uploadData = await videoService.uploadVideo(file, userId, latitude, longitude, type);
+    const uploadData = await videoService.uploadVideo(file, userId, latitude, longitude, type, status);
     return sendCreated(res, 'Video uploaded successfully to IPFS', uploadData);
 
   } catch (error) {

services/videoService.js

@@ -7,7 +7,7 @@ class VideoService {
     // Using S3-compatible API instead of invalid RPC endpoint
   }
 
-  async uploadVideo(file, userId, latitude, longitude, type) {
+  async uploadVideo(file, userId, latitude, longitude, type, status) {
     console.log('Starting video upload process...', {
       userId,
       originalFilename: file.originalname,
@@ -50,6 +50,9 @@ class VideoService {
     if (userId) {
       videoData.userId = userId;
     }
+    if (status) {
+      videoData.status = status;
+    }
 
     console.log('Video data to save:', videoData);