ffmpeg-fluent.ts

import { type NextApiRequest, type NextApiResponse } from 'next';
import Ffmpeg from 'fluent-ffmpeg';

export default function handler(req: NextApiRequest, res: NextApiResponse) {
  if (req.method === 'GET') {
    // Set response headers
    res.setHeader('Content-Type', 'video/mp4');
    res.setHeader('Connection', 'keep-alive');
    res.setHeader('Accept-Ranges', 'bytes');

    try {
const ffmpegCommand = Ffmpeg('rtsp://192.168.42.1/live')
  .addOptions([
    '-rtsp_transport', 'tcp', // Use TCP instead of UDP
    '-c:v', 'libx264', // Video codec
    '-movflags', 'frag_keyframe+empty_moov', // MP4 streaming settings
    '-bufsize', '512k', // Increase buffer size
  ])
  .format('mp4')  // Explicitly specify the format
  .on('end', () => {
    console.log('Stream end');
    clearTimeout(timeout);
  })
  .on('error', (err, stdout, stderr) => {
    console.error('Error:', err);
    console.error('ffmpeg stdout:', stdout);
    console.error('ffmpeg stderr:', stderr);
    res.status(500).send('Internal Server Error');
    clearTimeout(timeout);
  });
      // Pipe the output to the response
      ffmpegCommand.pipe(res);

      // Timeout for stale requests
      const timeoutDuration = 30000; // 30 seconds
      const timeout = setTimeout(() => {
        console.log('Request timed out. Stopping ffmpeg command.');
        ffmpegCommand.kill('SIGKILL');
      }, timeoutDuration);

      // Clear timeout and stop ffmpeg if client closes connection
      req.on('close', () => {
        console.log('Client closed connection. Stopping ffmpeg command.');
        clearTimeout(timeout);
        ffmpegCommand.kill('SIGKILL');
      });

    } catch (error) {
      console.error('Streaming Error:', error);
      res.status(500).send('Internal Server Error');
    }
  } else {
    res.status(405).send('Method Not Allowed');
  }
}