// Internal APIs. var __internal = { defaultPath: '/rtc/v1/play/', prepareUrl: function (webrtcUrl) { var urlObject = self.__internal.parse(webrtcUrl); var schema="http:"; var port = urlObject.port || 1985; if (schema === 'https:') { port = urlObject.port || 443; } // @see https://github.com/rtcdn/rtcdn-draft var api = urlObject.user_query.play || self.__internal.defaultPath; if (api.lastIndexOf('/') !== api.length - 1) { api += '/'; } apiUrl = schema + '//' + urlObject.server + ':' + port + api; for (var key in urlObject.user_query) { if (key !== 'api' && key !== 'play') { apiUrl += '&' + key + '=' + urlObject.user_query[key]; } } // Replace /rtc/v1/play/&k=v to /rtc/v1/play/?k=v var apiUrl = apiUrl.replace(api + '&', api + '?'); var streamUrl = urlObject.url; return { apiUrl: apiUrl, streamUrl: streamUrl, schema: schema, urlObject: urlObject, port: port, tid: Number(parseInt(new Date().getTime()*Math.random()*100)).toString(16).substr(0, 7) }; }, parse: function (url) { // @see: http://stackoverflow.com/questions/10469575/how-to-use-location-object-to-parse-url-without-redirecting-the-page-in-javascri var a = document.createElement("a"); a.href = url.replace("rtmp://", "http://") .replace("webrtc://", "http://") .replace("rtc://", "http://"); var vhost = a.hostname; var app = a.pathname.substr(1, a.pathname.lastIndexOf("/") - 1); var stream = a.pathname.substr(a.pathname.lastIndexOf("/") + 1); // parse the vhost in the params of app, that srs supports. app = app.replace("...vhost...", "?vhost="); if (app.indexOf("?") >= 0) { var params = app.substr(app.indexOf("?")); app = app.substr(0, app.indexOf("?")); if (params.indexOf("vhost=") > 0) { vhost = params.substr(params.indexOf("vhost=") + "vhost=".length); if (vhost.indexOf("&") > 0) { vhost = vhost.substr(0, vhost.indexOf("&")); } } } // when vhost equals to server, and server is ip, // the vhost is __defaultVhost__ if (a.hostname === vhost) { var re = /^(\d+)\.(\d+)\.(\d+)\.(\d+)$/; if (re.test(a.hostname)) { vhost = "__defaultVhost__"; } } // parse the schema var schema = "rtmp"; if (url.indexOf("://") > 0) { schema = url.substr(0, url.indexOf("://")); } var port = a.port; if (!port) { if (schema === 'http') { port = 80; } else if (schema === 'https') { port = 443; } else if (schema === 'rtmp') { port = 1935; } } var ret = { url: url, schema: schema, server: a.hostname, port: port, vhost: vhost, app: app, stream: stream }; self.__internal.fill_query(a.search, ret); // For webrtc API, we use 443 if page is https, or schema specified it. if (!ret.port) { if (schema === 'webrtc' || schema === 'rtc') { if (ret.user_query.schema === 'https') { ret.port = 443; } else if (window.location.href.indexOf('https://') === 0) { ret.port = 443; } else { // For WebRTC, SRS use 1985 as default API port. ret.port = 1985; } } } return ret; }, fill_query: function (query_string, obj) { // pure user query object. obj.user_query = {}; if (query_string.length === 0) { return; } // split again for angularjs. if (query_string.indexOf("?") >= 0) { query_string = query_string.split("?")[1]; } var queries = query_string.split("&"); for (var i = 0; i < queries.length; i++) { var elem = queries[i]; var query = elem.split("="); obj[query[0]] = query[1]; obj.user_query[query[0]] = query[1]; } // alias domain for vhost. if (obj.domain) { obj.vhost = obj.domain; } } }; function StartMetaRTC(url,player){ var conf = __internal.prepareUrl(url); pc = new RTCPeerConnection({ iceServers: ICEServerkvm,//ICEServer }); if(bVideo) { const { receivervideo } = pc.addTransceiver('video', { direction: 'recvonly' }); OnTrack(pc) } if(bAudio) { const { receiveraudio } = pc.addTransceiver('audio', { direction: 'recvonly' }); OnTrack(pc) } // Populate SDP field when finished gathering pc.oniceconnectionstatechange = e => { log(pc.iceConnectionState) var state ={ t: kconnectStatusResponse, s: pc.connectionState } player.postMessage(state) } pc.onicecandidate = event => { if (event.candidate === null) { var offer=pc.localDescription var data = { api: conf.apiUrl, tid: conf.tid, streamurl: conf.streamUrl, clientip: null, sdp: offer.sdp }; console.log("Generated offer: ", data); Ajax.post(conf.apiUrl, offer.sdp+"}", function(res){ console.log('返回的数据:',res) pc.setRemoteDescription(new RTCSessionDescription({type: 'answer', sdp: res.sdp})); // await self.pc.setRemoteDescription( // new RTCSessionDescription({type: 'answer', sdp: session.sdp}) // ); // .... }) // ajax({ // type: "POST", url: conf.apiUrl, data: offer.sdp+"}", // contentType:'text/plain', dataType: 'json', // crossDomain:true // }).done(function(data) { // if (data.code) { // reject(data); return; // } // console.log("Got sdp: ", data.sdp); // resolve(data); // }).fail(function(reason){ // reject(reason); // }); } } pc.createOffer().then(d => pc.setLocalDescription(d)).catch(log) }