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