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'],
    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 getVideo =(videoUrl)=>{
    $('#testVideoFeed').prop('srcObject', sdk.stream);
    sdk.getVideo(videoUrl).then(function(session){
        console.log('session',session.sessionid)
    
    }).catch(function (reason) {
        console.error(reason);
    })
}