removing media files

Author: seongbin9786

.gitignore

@@ -2,4 +2,6 @@
 /files_server_side_record/*
 /node_modules
 /security/cert.key
-/security/cert.pem
+/security/cert.pem
+*.mp4
+*.webm

public_clientside_record/240p_mobile.webm

@@ -81,7 +81,7 @@ localVideo.addEventListener("loadedmetadata", function () {
 const IS_CALLER = false;
 
 let userMediaStream;
-let clientPc;
+let pcClient;
 
 function start() {
   trace("Requesting local stream");
@@ -132,29 +132,29 @@ function call() {
   if (audioTracks.length > 0) {
     trace("Using audio device: " + audioTracks[0].label);
   }
-  clientPc = new RTCPeerConnection(ICE_SERVERS_CONFIG);
+  pcClient = new RTCPeerConnection(ICE_SERVERS_CONFIG);
   trace("Created local peer connection object client:");
 
-  clientPc.onicecandidate = (event) => {
+  pcClient.onicecandidate = (event) => {
     socket.emit(NEW_PEER_ICE_CANDIDATE, event.candidate);
     // trace("ICE candidate:", event.candidate);
   };
 
   socket.on(NEW_PEER_ICE_CANDIDATE, (candidate) => {
     // trace("receiving new remote Ice Candidate: ");
-    clientPc
+    pcClient
       .addIceCandidate(candidate)
       .then(() => {
-        // trace("client: new Remote Ice Candidate: ");
+        trace("client: new Remote Ice Candidate: ", candidate);
       })
       .catch((e) => {
         trace("Error adding new Remote Ice Candidate: ", e);
       });
   });
 
-  clientPc.oniceconnectionstatechange = () => {
-    clientPc.addEventListener("connectionstatechange", () => {
-      switch (clientPc.connectionState) {
+  pcClient.oniceconnectionstatechange = () => {
+    pcClient.addEventListener("connectionstatechange", () => {
+      switch (pcClient.connectionState) {
         case "connected":
           // The connection has become fully connected
           trace("[WebRTC] User is fully connected");
@@ -174,7 +174,7 @@ function call() {
     });
   };
 
-  clientPc.addStream(userMediaStream);
+  pcClient.addStream(userMediaStream);
 
   // 선호 코덱을 가장 위에 배치한 배열을 setCodecPreferences로 넘기는 것.
   const { codecs } = RTCRtpSender.getCapabilities("video");
@@ -189,7 +189,7 @@ function call() {
   codecs.splice(selectedCodecIndex, 1);
   codecs.unshift(selectedCodec);
   console.log(codecs);
-  const transceiver = clientPc
+  const transceiver = pcClient
     .getTransceivers()
     .find(
       (t) => t.sender && t.sender.track === userMediaStream.getVideoTracks()[0]
@@ -203,7 +203,7 @@ function call() {
     // Answer 미리 등록해놓고
     socket.on(ANSWER, (desc) => {
       trace("received answer");
-      clientPc
+      pcClient
         .setRemoteDescription(desc)
         .then(() => {
           trace("client: setRemoteDescription complete");
@@ -217,10 +217,10 @@ function call() {
         });
     });
 
-    clientPc
+    pcClient
       .createOffer()
       .then((offerDesc) => {
-        clientPc.setLocalDescription();
+        pcClient.setLocalDescription();
         trace("setLocalDescription");
         return offerDesc;
       })
@@ -235,24 +235,24 @@ function call() {
       });
   } else {
     socket.on(OFFER, (offerDesc) => {
-      trace("received offer");
+      trace("received offer:", offerDesc.sdp);
 
-      clientPc
+      pcClient
         .setRemoteDescription(offerDesc)
         .then(() => {
-          trace("client: setRemoteDescription complete");
-          return clientPc.createAnswer();
+          trace("client: setRemoteDescription complete", offerDesc);
+          return pcClient.createAnswer();
         })
         .catch((error) => {
           trace("Failed to setRemoteDescription: " + error.toString());
         })
         .then((answerDesc) => {
-          clientPc.setLocalDescription(answerDesc);
+          pcClient.setLocalDescription(answerDesc);
           return answerDesc;
         })
         .then((answerDesc) => {
           trace("client: setLocalDescription complete");
-          trace("answer from client");
+          trace("answer from client", answerDesc);
           socket.emit(ANSWER, answerDesc);
           trace("Connection Succeeeded!");
         })
@@ -268,12 +268,12 @@ function hangup() {
   hangupButton.disabled = true;
   callButton.disabled = false;
   socket.close();
-  clientPc.close();
-  clientPc = null;
+  pcClient.close();
+  pcClient = null;
 }
 
 // logging utility
-function trace(arg) {
+function trace(...args) {
   const now = (window.performance.now() / 1000).toFixed(3);
-  console.log(now + ": ", arg);
+  console.log(now + ": ", ...args);
 }

public_clientside_record/500_1000kbps.webm

@@ -255,6 +255,9 @@ function beforeOffer(peerConnection) {
         "copy",
         `${VIDEO_OUTPUT_FILE}`,
       ];
+      // exec, spawn 둘 다 subprocess로 실행되는 거 같긴 한데 잘 모르겠다.
+      // 굳이 spawn을 쓰는 이유:
+      // https://stackoverflow.com/questions/42012342/running-ffmpeg-via-nodejs-error
       const mergeProcess = spawn(cmd, args);
       mergeProcess.stdout.on("data", (data) => {
         console.log(`stdout: ${data}`);

public_serverside_record/index.js

@@ -116,7 +116,7 @@ io.on("connection", async (serverSocket) => {
     // Connection이 연결되기도 전에 closed 됐다고 해서 짜증나서 제거함
     try {
       await pcServer.addIceCandidate(candidate);
-      // trace("Successfully added Ice Candidate: ", candidate);
+      trace("Successfully added Ice Candidate: ", candidate);
     } catch (error) {
       trace("Error while adding an ICE Candidate: ", error.toString());
     }
@@ -125,8 +125,10 @@ io.on("connection", async (serverSocket) => {
   // 시작점
   if (IS_CALLER) {
     try {
-      trace("Creating Offer: ");
       const offerDesc = await pcServer.createOffer();
+      // offerDesc.sdp +=
+      //   "a=candidate:4234997325 1 udp 2043278322 192.168.219.191 5000 typ host\r\n";
+      trace("Created Offer: ", offerDesc);
       await pcServer.setLocalDescription(offerDesc);
       serverSocket.emit(OFFER, offerDesc);
     } catch (error) {
@@ -135,7 +137,7 @@ io.on("connection", async (serverSocket) => {
 
     serverSocket.on(ANSWER, async (answerDesc) => {
       try {
-        trace("Received Offer: ");
+        trace("Received Answer: ", answerDesc);
         await pcServer.setRemoteDescription(answerDesc);
         trace("Connection Succeeeded!");
       } catch (error) {

server_ffmpeg.js

@@ -14,6 +14,7 @@ const io = new Server(secureServer);
 
 app.use(express.static(process.env.__public_path__));
 
+// 192.168.219.191 로 오픈할 수가 없다.
 secureServer.listen(3000, "0.0.0.0", () => {
   console.log("listening on *:3000");
 });

server_ffmpeg_wrapper.js

@@ -1,4 +1 @@
-file './recording-320x180-2.mp4'
-file './recording-480x270-3.mp4'
-file './recording-640x360-4.mp4'
-file './recording-960x540-5.mp4'
+file './recording-360x640-1.mp4'