PrimordialUniverse/webrtc/srs.js

import {SrsRTC } from './SrsRTC.js';
import { Connection } from './connection.js';
const sdk = new SrsRTC();
const testConfig ={
    userId: '11111',
    roomId: '111',
}
const connection =new Connection(testConfig);

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

connection.socket.emit('pushVideo',{
    // videoList:['0/0_1_0'],
    videoList:['sample-5s','output'],
    videoId: 'mini1'
})
setTimeout(()=>{
    console.log('第二个')

    connection.socket.emit('pushVideo',{
        // videoList:['0/0_1_0'],
        videoList:['output'],
        videoId: 'mini1'
    })

},10000)



setTimeout(()=>{
    console.log('第三个')
    connection.socket.emit('pushVideo',{
        videoList:["sample-5s"],
        videoId: 'mini1'
    })
},20000)

window.connection =connection
connection.socket.on('getVideo',async(videoId)=>{

    if(videoId){
        const steamUrl ='webrtc://demo-kms.4dage.com/live/' + videoId;
        
        console.log('getVideo',videoId);
        sdk.close();
        await getVideo(steamUrl)
    }
})


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);
    })
}



// sdk.pc.ondatachannel = function(ev) {
//     console.log('Data channel is created!');
//     ev.channel.onopen = function() {
//       console.log('Data channel is open and ready to be used.');
//     };
//   };