PrimordialUniverse/webrtc/srs.js

import {SrsRTC } from './SrsRTC.js';
import { Connection } from './connection.js';
const sdk = new SrsRTC();
const testConfig ={
    sceneCode:"testApp",
    userId: 'testUser',
    roomId: '8888',
}
const connection =new Connection(testConfig);

console.log('sdk',sdk)
console.log('sdk',connection)

// console.log('第一个')
connection.socket.emit('pushVideo',{
    videoList:['sample-5s','output','sample-5s','output','sample-5s','output','sample-5s','output'],
    sessionId:'1',
    sceneCode:testConfig.sceneCode,
    roomId:testConfig.roomId,
    userId:testConfig.userId,
})
// setTimeout(()=>{
//     console.log('第二个')

//     connection.socket.emit('pushVideo',{
//         videoList:['output'],
//         sessionId:'',
//         sceneCode:testConfig.sceneCode,
//         roomId:testConfig.roomId,
//         userId:testConfig.userId,
//     })

// },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',{
//         videoList:['output'],
//         sessionId:'3',
//         sceneCode:testConfig.sceneCode,
//         roomId:testConfig.roomId,
//         userId:testConfig.userId,
//     })
// },14000)



// setTimeout(()=>{
//     console.log('第三个')
//     connection.socket.emit('pushVideo',{
//         videoList:['sample-5s'],
//         sessionId:'4',
//         sceneCode:testConfig.sceneCode,
//         roomId:testConfig.roomId,
//         userId:testConfig.userId,
//     })
// },20000)

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)
//     }
// })
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){
        console.log('session',session.sessionid)
    
    }).catch(function (reason) {
        console.error(reason);
    })
}