Feature/auth backend

src/controllers/courseController.js

@@ -1,15 +1,19 @@
+const cloudinary = require('cloudinary').v2;
 const supabase = require('../config/supabase');
 
+const ffmpeg = require('fluent-ffmpeg');
+const { Readable } = require('stream');
+
 const STRIPE_API_KEY = process.env.STRIPE_API_KEY;
 const stripe = require('stripe')(STRIPE_API_KEY);
 
 const FRONTEND_URL = process.env.FRONTEND_URL;
 
-const {
-  cloudflareUpload,
-  cloudflareDelete,
-  cloudinaryVideoUpload,
-} = require('./fileUploader');
+cloudinary.config({
+  secure: true,
+});
+
+const { cloudflareUpload, cloudflareDelete } = require('./fileUploader');
 
 //Secret to use stripe webhook
 const endpointSecret = process.env.STRIPE_WEBHOOK_SECRET;
@@ -42,6 +46,43 @@ async function checkAdmin(req) {
   return user.admin_access;
 }
 
+async function trimVideo(videoBuffer, mimeType) {
+  const startTime = '00:00:00';
+  const duration = 15; // seconds
+  const inputFormat = mimeType.split('/')[1];
+  const outputFormat = 'mp4';
+
+  return new Promise((resolve, reject) => {
+    // Turn the Buffer into a one-chunk Readable
+    const inputStream = Readable.from([videoBuffer]);
+
+    // collect the output
+    const chunks = [];
+    const command = ffmpeg(inputStream)
+      .inputFormat(inputFormat) // tell ffmpeg the incoming stream format
+      .setStartTime(startTime) // where to start
+      .setDuration(duration) // how long
+      .outputOptions([
+        '-movflags frag_keyframe+empty_moov', // allow streaming mp4
+      ])
+      .format(outputFormat) // output format
+      .on('error', (err) => {
+        console.error('FFmpeg failed:', err);
+        reject(new Error('Video trimming failed.'));
+      });
+
+    // pipe stdout to our collector
+    const ffStream = command.pipe();
+
+    ffStream.on('data', (chunk) => chunks.push(chunk));
+    ffStream.on('end', () => resolve(Buffer.concat(chunks)));
+    ffStream.on('error', (err) => {
+      console.error('Stream error:', err);
+      reject(new Error('Error while streaming trimmed video.'));
+    });
+  });
+}
+
 async function deleteFiles(urls) {
   for (const url of urls) {
     if (url) {
@@ -114,7 +155,14 @@ const courseController = {
           /\s+/g,
           '-'
         );
-        restricted_video_link = await cloudinaryVideoUpload(video_link, true);
+        const trimmedVideoBuffer = await trimVideo(videoBuffer, video.mimetype);
+        const restrictedResult = await cloudflareUpload(
+          videoFileName,
+          video.mimetype,
+          trimmedVideoBuffer
+        );
+        if (restrictedResult.error) throw new Error(restrictedResult.error);
+        restricted_video_link = restrictedResult.data.url;
         timings.restrictedVideo = Date.now() - restrictedStartTime;
         console.log(
           `Restricted video upload took ${timings.restrictedVideo}ms`
@@ -287,13 +335,21 @@ const courseController = {
         const videoBuffer = video.buffer;
         console.log('Updating video...');
         let videoFileName = null;
+        let restrictedFileName = null;
 
         if (!currentCourse.video_link) {
           // New Online course conversion
           videoFileName = `video-${title}-${Date.now()}`.replace(/\s+/g, '-');
+          restrictedFileName = `restricted-${title}-${Date.now()}`.replace(
+            /\s+/g,
+            '-'
+          );
         } else {
           // Existing Online course update
           videoFileName = currentCourse.video_link.split('/').pop();
+          restrictedFileName = currentCourse.restricted_video_link
+            .split('/')
+            .pop();
         }
 
         // Update existing files
@@ -305,10 +361,15 @@ const courseController = {
         if (videoResult.error) throw new Error(videoResult.error);
         updateObj.video_link = videoResult.data.url;
 
-        updateObj.restricted_video_link = await cloudinaryVideoUpload(
-          updateObj.video_link,
-          true
+        console.log('Updating restricted video...');
+        const trimmedVideoBuffer = await trimVideo(videoBuffer, video.mimetype);
+        const restrictedResult = await cloudflareUpload(
+          restrictedFileName,
+          video.mimetype,
+          trimmedVideoBuffer
         );
+        if (restrictedResult.error) throw new Error(restrictedResult.error);
+        updateObj.restricted_video_link = restrictedResult.data.url;
       }
 
       // Handle image upload if provided