index.js

// // // // // server.js
// // // // import express from 'express';
// // // // import { WebSocketServer } from 'ws';
// // // // import { spawn } from 'child_process';

// // // // const app = express();
// // // // const port = 5000;

// // // // // Basic route
// // // // app.get('/', (req, res) => {
// // // //   res.send('WebRTC RTSP server running');
// // // // });

// // // // const server = app.listen(port, () => {
// // // //   console.log(`HTTP server running at http://localhost:${port}`);
// // // // });

// // // // // WebSocket server for signaling
// // // // const wss = new WebSocketServer({ server });

// // // // wss.on('connection', (ws) => {
// // // //   console.log('Client connected for WebRTC signaling');

// // // //   ws.on('message', (message) => {
// // // //     const data = JSON.parse(message);

// // // //     if (data.type === 'start') {
// // // //       const rtspUrl = data.url; // RTSP URL sent from client
// // // //       console.log('Starting streaming for', rtspUrl);

// // // //       // Spawn FFmpeg to convert RTSP → WebRTC-friendly format (RTP/H.264)
// // // //       const ffmpeg = spawn('ffmpeg', [
// // // //         '-i', rtspUrl,
// // // //         '-f', 'rtp',            // send RTP
// // // //         '-payload_type', '96',
// // // //         'rtp://127.0.0.1:5004'  // send RTP to local WebRTC pipeline
// // // //       ]);

// // // //       ffmpeg.stderr.on('data', (data) => {
// // // //         console.log(`FFmpeg: ${data}`);
// // // //       });

// // // //       ffmpeg.on('close', (code) => {
// // // //         console.log(`FFmpeg exited with code ${code}`);
// // // //       });
// // // //     }
// // // //   });
// // // // });


// // // // ws-rtsp-proxy.js
// // // import WebSocket, { WebSocketServer } from 'ws';
// // // import { spawn } from 'child_process';

// // // const wss = new WebSocketServer({ port: 8080 });

// // // wss.on('connection', (ws, req) => {
// // //   console.log('Client connected');

// // //   // You can send the RTSP URL from the client, or hardcode it
// // //   const rtspUrl = "rtsp://rtspViewer:rtspViewerPass321@13.201.247.124:8554/synqkriya1";

// // //   // FFmpeg: RTSP → fragmented MP4 → stdout
// // //   // FFmpeg: RTSP → fragmented MP4 → stdout
// // // const ffmpeg = spawn('ffmpeg', [
// // //   '-rtsp_transport', 'tcp',
// // //   '-i', rtspUrl,
// // //   '-an',                 // no audio
// // //   '-c:v', 'copy',        // copy video codec instead of re-encoding
// // //   '-f', 'mp4',
// // //   '-movflags', 'frag_keyframe+empty_moov',
// // //   'pipe:1'
// // // ]);


// // //   ffmpeg.stdout.on('data', (chunk) => {
// // //     if (ws.readyState === WebSocket.OPEN) {
// // //       ws.send(chunk);
// // //     }
// // //   });

// // //   ffmpeg.stderr.on('data', (data) => {
// // //     console.log(`FFmpeg: ${data}`);
// // //   });

// // //   ffmpeg.on('close', () => {
// // //     console.log('FFmpeg process closed');
// // //   });

// // //   ws.on('close', () => {
// // //     console.log('Client disconnected');
// // //     ffmpeg.kill('SIGINT');
// // //   });
// // // });

// // // console.log('WebSocket RTSP proxy running on ws://localhost:8080');


// // import WebSocket, { WebSocketServer } from 'ws';
// // import { spawn } from 'child_process';
// // import ffmpegPath from 'ffmpeg-static';   // ✅ ffmpeg binary bundled with npm

// // const wss = new WebSocketServer({ port: 8080 });

// // wss.on('connection', (ws, req) => {
// //   console.log('Client connected');

// //   // RTSP URL (hardcoded for now, can be sent from client later)
// //   const rtspUrl = "rtsp://rtspviewer1:rtspviewerpass1@13.201.247.124:8554/sherbrooke";

// //   // FFmpeg: RTSP → fragmented MP4 → stdout
// // //   const ffmpeg = spawn(ffmpegPath, [
// // //     '-rtsp_transport', 'tcp',
// // //     '-i', rtspUrl,
// // //     '-an',                   // drop audio
// // //     '-c:v', 'copy',          // copy video codec (no re-encode)
// // //     '-f', 'mp4',
// // //     '-movflags', 'frag_keyframe+empty_moov',
// // //     'pipe:1'
// // //   ]);

// // const ffmpeg = spawn('ffmpeg', [
// //   '-rtsp_transport', 'tcp',
// //   '-i', rtspUrl,
// //   '-an',
// //   '-c:v', 'libx264',          // ✅ re-encode to H.264
// //   '-preset', 'ultrafast',     // ✅ low latency
// //   '-tune', 'zerolatency',
// //   '-f', 'mp4',
// //   '-movflags', 'frag_keyframe+empty_moov',
// //   'pipe:1'
// // ]);

// //   // Send FFmpeg output chunks to WebSocket
// //   ffmpeg.stdout.on('data', (chunk) => {
// //     if (ws.readyState === WebSocket.OPEN) {
// //       ws.send(chunk);
// //     }
// //   });

// //   // Log FFmpeg status/errors
// //   ffmpeg.stderr.on('data', (data) => {
// //     console.log(`FFmpeg: ${data}`);
// //   });

// //   ffmpeg.on('close', (code) => {
// //     console.log(`FFmpeg process closed with code ${code}`);
// //   });

// //   // Kill FFmpeg when client disconnects
// //   ws.on('close', () => {
// //     console.log('Client disconnected');
// //     ffmpeg.kill('SIGINT');
// //   });
// // });

// // console.log('WebSocket RTSP proxy running on ws://localhost:8080');



// import WebSocket, { WebSocketServer } from 'ws';
// import { spawn } from 'child_process';
// import ffmpegPath from 'ffmpeg-static';   // ✅ use static ffmpeg binary

// const wss = new WebSocketServer({ port: 8080 });

// wss.on('connection', (ws, req) => {
//   console.log('Client connected');

//   const rtspUrl = "rtsp://rtspviewer1:rtspviewerpass1@13.201.247.124:8554/sherbrooke";

//   const ffmpeg = spawn(ffmpegPath, [   // ✅ use ffmpegPath here
//     '-rtsp_transport', 'tcp',
//     '-i', rtspUrl,
//     '-an',
//     '-c:v', 'libx264',
//     '-preset', 'ultrafast',
//     '-tune', 'zerolatency',
//     '-f', 'mp4',
//     '-movflags', 'frag_keyframe+empty_moov',
//     'pipe:1'
//   ]);

//   ffmpeg.stdout.on('data', (chunk) => {
//     if (ws.readyState === WebSocket.OPEN) {
//       ws.send(chunk);
//     }
//   });

//   ffmpeg.stderr.on('data', (data) => {
//     console.log(`FFmpeg: ${data}`);
//   });

//   ffmpeg.on('close', (code) => {
//     console.log(`FFmpeg process closed with code ${code}`);
//   });

//   ws.on('close', () => {
//     console.log('Client disconnected');
//     ffmpeg.kill('SIGINT');
//   });
// });

// console.log('WebSocket RTSP proxy running on ws://localhost:8080');
import { spawn } from "child_process";
import ffmpegPath from "ffmpeg-static";
import WebSocket, { WebSocketServer } from "ws";

const wss = new WebSocketServer({ port: 8080 });
console.log("WebSocket RTSP proxy running on ws://localhost:8080");

wss.on("connection", (ws) => {
  console.log("Client connected");

  const ffmpeg = spawn(ffmpegPath, [
    "-rtsp_transport", "tcp",
    "-i", "rtsp://rtspviewer1:rtspviewerpass1@13.201.247.124:8554/sherbrooke",
    "-an",
    "-c:v", "libx264",
    "-preset", "ultrafast",
    "-tune", "zerolatency",
    "-f", "mp4",
    "-movflags", "frag_keyframe+empty_moov+default_base_moof", // ✅ very important
    "pipe:1"
  ]);

  ffmpeg.stdout.on("data", (data) => {
    if (ws.readyState === WebSocket.OPEN) {
      ws.send(data);
    }
  });

  ffmpeg.stderr.on("data", (data) => {
    console.log("FFmpeg:", data.toString());
  });

  ffmpeg.on("close", () => {
    console.log("FFmpeg process closed");
    ws.close();
  });

  ws.on("close", () => {
    console.log("Client disconnected");
    ffmpeg.kill("SIGINT");
  });
});