Api Nodejs - Video Streaming

app.get('/video/:filename', (req, res) => { const filename = req.params.filename; const filePath = path.join(__dirname, 'videos', filename);

stream.pipe(res); } else { res.writeHead(200, { 'Content-Length': fileSize, 'Content-Type': 'video/mp4', }); fs.createReadStream(filePath).pipe(res); } }); video streaming api nodejs

const stream = fs.createReadStream(filePath, { start, end }); { const filename = req.params.filename

app.listen(3000, () => { console.log('Streaming server running on port 3000'); }); 1. Authentication & Authorization const jwt = require('jsonwebtoken'); app.use('/video/:filename', (req, res, next) => { const token = req.headers.authorization; if (!token) return res.status(401).send('Unauthorized'); const filePath = path.join(__dirname

res.writeHead(206, { 'Content-Range': `bytes ${start}-${end}/${fileSize}`, 'Accept-Ranges': 'bytes', 'Content-Length': chunksize, 'Content-Type': 'video/mp4', });

try { req.user = jwt.verify(token, process.env.JWT_SECRET); next(); } catch(err) { res.status(403).send('Invalid token'); } }); const ffmpeg = require('fluent-ffmpeg'); function generateThumbnail(videoPath, timestamp = '00:00:01') { return new Promise((resolve, reject) => { const outputPath = videoPath.replace('.mp4', '-thumb.jpg'); ffmpeg(videoPath) .screenshots({ timestamps: [timestamp], filename: path.basename(outputPath), folder: path.dirname(outputPath), size: '320x240' }) .on('end', () => resolve(outputPath)) .on('error', reject); }); } 3. Rate Limiting const rateLimit = require('express-rate-limit'); const streamLimiter = rateLimit({ windowMs: 60 * 1000, // 1 minute max: 5, // 5 requests per minute message: 'Too many streaming requests' });

const stat = fs.statSync(filePath); const fileSize = stat.size; const range = req.headers.range;