feat(core): update

webrtc/connection.js

@@ -12,7 +12,9 @@ export class Connection {
     //192.168.0.52:9099/?userId=123
     console.log("init-startSocket");
     const {  roomId, userId } = config;
-    this.socket = io("wss://demo-kms.4dage.com", {
+    const socketUrl ='wss://demo-kms.4dage.com'
+    // const socketUrl ='ws://192.168.0.152:9099'
+    this.socket = io(socketUrl, {
       reconnectionDelayMax: 10000,
       transports: ["websocket"],
       query: {

webrtc/srs.js

@@ -14,7 +14,7 @@ console.log('sdk',connection)
 
 // console.log('第一个')
 connection.socket.emit('pushVideo',{
-    videoList:['sample-5s','output'],
+    videoList:['sample-5s','output','sample-5s','output','sample-5s','output','sample-5s','output'],
     sessionId:'1',
     sceneCode:testConfig.sceneCode,
     roomId:testConfig.roomId,
@@ -33,19 +33,19 @@ connection.socket.emit('pushVideo',{
 
 // },10000)
 
-setTimeout(()=>{
-    console.log('第二个')
-    connection.socket.emit('rotate',{
-        videoPath:'sample-5s',
-        sessionId:'2',
-        sceneCode:testConfig.sceneCode,
-        roomId:testConfig.roomId,
-        userId:testConfig.userId,
-        sangle: '0',
-        eangle:'900',
-        reverses:true,
-    })
-},12000)
+// setTimeout(()=>{
+//     console.log('第二个')
+//     connection.socket.emit('rotate',{
+//         videoPath:'sample-5s',
+//         sessionId:'2',
+//         sceneCode:testConfig.sceneCode,
+//         roomId:testConfig.roomId,
+//         userId:testConfig.userId,
+//         sangle: '0',
+//         eangle:'900',
+//         reverses:true,
+//     })
+// },12000)
 
 // setTimeout(()=>{
 //     console.log('正转')
@@ -73,16 +73,44 @@ setTimeout(()=>{
 
 window.connection =connection;
 
-connection.socket.on('getVideo',async(streamUrl)=>{
-    if(streamUrl){
-        const url ='webrtc://demo-kms.4dage.com/' + streamUrl;
-        console.log('getVideo',streamUrl);
-        sdk.close();
-        await getVideo(url)
-    }
+// connection.socket.on('getVideo',async(streamUrl)=>{
+//     if(streamUrl){
+//         const url ='webrtc://demo-kms.4dage.com/' + streamUrl;
+//         console.log('getVideo',streamUrl);
+//         sdk.close();
+//         await getVideo(url)
+//     }
+// })
+const downloadURL = function(r, n) {
+    const o = document.createElement("a");
+    o.href = r,
+    o.download = n,
+    document.body.appendChild(o),
+    o.style.display = "none",
+    o.click(),
+    o.remove()
+}
+let downloadBlob = (data, fileName, mimeType) => {
+    const blob = new Blob([data], {
+      type: mimeType,
+    })
+    const url = URL.createObjectURL(blob)
+    downloadURL(url, fileName)
+    setTimeout(function () {
+      return URL.revokeObjectURL(url)
+    }, 3000)
+  }
+
+connection.socket.emit('pushVideo_test',async(data)=>{
+   console.log(data)
+})
+connection.socket.on('pushVideo_test',async(data)=>{
+   console.log(data)
+   downloadBlob(data, 'test.mp4', 'application/video')
 })
 
 
+
 const getVideo =(videoUrl)=>{
     $('#testVideoFeed').prop('srcObject', sdk.stream);
     sdk.getVideo(videoUrl).then(function(session){

webrtc/srsRtc.js

@@ -41,13 +41,16 @@ export class SrsRTC {
                     }
                     // if(this.stream.removeTrack())
                     this.stream.addTrack(event.track);
-                }
-               const  mediaRecorder = new MediaRecorder(event.streams[0]);
-               console.log('mediaRecorder',mediaRecorder)
+                }      
             //    mediaRecorder.
-
-
             };
+            this.pc.ondatachannel =(data)=>{
+                console.log('data',data)
+            }
+            this.pc.onaddstream = function (obj) {
+                console.error(obj)
+            }
+
         }
      
         this.pc.addTransceiver("video", {direction: "recvonly"});