//Get the Medooze Media Server interface const MediaServer = require("medooze-media-server"); //Get Semantic SDP objects const SemanticSDP = require("semantic-sdp"); const SDPInfo = SemanticSDP.SDPInfo; const MediaInfo = SemanticSDP.MediaInfo; const CandidateInfo = SemanticSDP.CandidateInfo; const DTLSInfo = SemanticSDP.DTLSInfo; const ICEInfo = SemanticSDP.ICEInfo; const StreamInfo = SemanticSDP.StreamInfo; const TrackInfo = SemanticSDP.TrackInfo; const Direction = SemanticSDP.Direction; const CodecInfo = SemanticSDP.CodecInfo; const Capabilities = { data : { } }; module.exports = function(request,protocol,endpoint) { const connection = request.accept(protocol); connection.on('message', (frame) => { //Get cmd var msg = JSON.parse(frame.utf8Data); //Get cmd if (msg.cmd==="OFFER") { //Process the sdp var offer = SDPInfo.process(msg.offer); //Create an DTLS ICE transport in that enpoint const transport = endpoint.createTransport(offer); //transport.dump("/tmp/svc.pcap"); //Set RTP remote properties transport.setRemoteProperties({ audio : offer.getMedia("audio"), video : offer.getMedia("video") }); //Create local SDP info const answer = offer.answer({ dtls : transport.getLocalDTLSInfo(), ice : transport.getLocalICEInfo(), candidates : endpoint.getLocalCandidates(), capabilities : Capabilities }); //Set RTP local properties transport.setLocalProperties({ video : answer.getMedia("video") }); //Get offered stream info //Send response connection.sendUTF(JSON.stringify({ answer : answer.toString() })); //Close on disconnect connection.on("close",() => { //Stop transport.stop(); }); } }); };