|
|
<?phpclass SDPtoJingle { private $sdp; private $arr; private $jingle; private $content = null; private $transport = null;
private $action;
// Move the global fingerprint into each medias
private $global_fingerprint = array(); private $regex = array( 'candidate' => "/^a=candidate:(\w{1,32}) (\d{1,5}) (udp|tcp) (\d{1,10}) ([a-zA-Z0-9:\.]{1,45}) (\d{1,5}) (typ) (host|srflx|prflx|relay)( (raddr) ([a-zA-Z0-9:\.]{1,45}) (rport) (\d{1,5}))?( (generation) (\d) (network) (\d) (id) ([a-zA-Z0-9]{1,45}))?/i", //à partir de generation les attr sont spécifiques à XMPP..autant l'enlever de la REGEX et les traiter à part? En théorie ils peuvent être dans n'importe quel ordre.
'sess_id' => "/^o=(\S+) (\d+)/i", 'rtpmap' => "/^a=rtpmap:(\d+) (([^\s\/]+)(\/(\d+)(\/([^\s\/]+))?)?)?/i", 'fmtp' => "/^a=fmtp:(\d+) (.+)/i", 'rtcp_fb' => "/^a=rtcp-fb:(\S+) (\S+)( (\S+))?/i", 'rtcp_fb_trr_int' => "/^a=rtcp-fb:(\d+) trr-int (\d+)/i", 'pwd' => "/^a=ice-pwd:(\S+)/i", 'ufrag' => "/^a=ice-ufrag:(\S+)/i", 'ptime' => "/^a=ptime:(\d+)/i", 'maxptime' => "/^a=maxptime:(\d+)/i", 'ssrc' => "/^a=ssrc:(\d+) (\w+)(:(\S+))?( (\w+))?/i", 'rtcp_mux' => "/^a=rtcp-mux/i", 'crypto' => "/^a=crypto:(\d{1,9}) (\w+) (\S+)( (\S+))?/i", 'zrtp_hash' => "/^a=zrtp-hash:(\S+) (\w+)/i", 'fingerprint' => "/^a=fingerprint:(\S+) (\S+)/i", 'setup' => "/^a=setup:(\S+)/i", 'extmap' => "/^a=extmap:([^\s\/]+)(\/([^\s\/]+))? (\S+)/i", 'sctpmap' => "/^a=sctpmap:(\d+) (\S+) (\d+)/i", 'bandwidth' => "/^b=(\w+):(\d+)/i", 'media' => "/^m=(audio|video|application|data)/i" ); function __construct($sdp, $initiator, $responder, $action) { $this->sdp = $sdp; $this->arr = explode("\n", $this->sdp); $this->jingle = new SimpleXMLElement('<jingle></jingle>'); $this->jingle->addAttribute('xmlns', 'urn:xmpp:jingle:1'); $this->jingle->addAttribute('action',$action); $this->jingle->addAttribute('initiator',$initiator); $this->jingle->addAttribute('responder',$responder);
$this->action = $action; } function getSessionId(){ $s = Session::start('movim'); if($sid = $s->get('jingleSid')){ return $sid; } else{ $o = $this->arr[1]; $sid = explode(" ", $o); return substr(base_convert($sid[1], 30, 10), 0, 6); } }
function generate() { foreach($this->arr as $l) { foreach($this->regex as $key => $r) { if(preg_match($r, $l, $matches)) { switch($key) { case 'sess_id': $this->jingle->addAttribute('sid', $this->getSessionId()); break; case 'media': $this->content = $this->jingle->addChild('content'); $this->transport = $this->content->addChild('transport'); $this->transport->addAttribute('xmlns', "urn:xmpp:jingle:transports:ice-udp:1");
$this->content->addAttribute('creator', 'initiator'); // TODO à fixer !
$this->content->addAttribute('name', $matches[1]); // The description node
if($this->action != 'transport-info') { $description = $this->content->addChild('description'); $description->addAttribute('xmlns', "urn:xmpp:jingle:apps:rtp:1"); $description->addAttribute('media', $matches[1]); }
if(!empty($this->global_fingerprint)) { $fingerprint = $this->transport->addChild('fingerprint', $this->global_fingerprint['fingerprint']); $this->transport->addAttribute('pwd', $this->global_fingerprint['pwd']); $this->transport->addAttribute('ufrag', $this->global_fingerprint['ufrag']); $fingerprint->addAttribute('xmlns', "urn:xmpp:jingle:apps:dtls:0"); $fingerprint->addAttribute('hash', $this->global_fingerprint['hash']); } break; case 'bandwidth': $bandwidth = $description->addChild('bandwidth'); $bandwidth->addAttribute('type', $matches[1]); $bandwidth->addAttribute('value', $matches[2]); break; case 'rtpmap': $payloadtype = $description->addChild('payload-type'); $payloadtype->addAttribute('id', $matches[1]); $payloadtype->addAttribute('name', $matches[3]); if(isset($matches[4])) $payloadtype->addAttribute('clockrate', $matches[5]); if(isset($matches[7])) $payloadtype->addAttribute('channels', $matches[7]); break;
// http://xmpp.org/extensions/xep-0167.html#format
case 'fmtp': // This work only if fmtp is added just after
// the correspondant rtpmap
if($matches[1] == $payloadtype->attributes()->id) { $params = explode(';', $matches[2]);
foreach($params as $value) { $p = explode('=', trim($value)); $parameter = $payloadtype->addChild('parameter'); if(count($p) == 1) { $parameter->addAttribute('value', $p[0]); } else { $parameter->addAttribute('name', $p[0]); $parameter->addAttribute('value', $p[1]); } } } break; case 'rtcp_fb': if($matches[1] == '*') { $rtcpfp = $description->addChild('rtcp-fb'); } else { $rtcpfp = $payloadtype->addChild('rtcp-fb'); } $rtcpfp->addAttribute('xmlns', "urn:xmpp:jingle:apps:rtp:rtcp-fb:0"); $rtcpfp->addAttribute('id', $matches[1]); $rtcpfp->addAttribute('type', $matches[2]); if(isset($matches[4])) $rtcpfp->addAttribute('subtype', $matches[4]); break; case 'rtcp_fb_trr_int': $rtcpfp = $payloadtype->addChild('rtcp-fb-trr-int'); $rtcpfp->addAttribute('xmlns', "urn:xmpp:jingle:apps:rtp:rtcp-fb:0"); $rtcpfp->addAttribute('id', $matches[1]); $rtcpfp->addAttribute('value', $matches[2]); break; // http://xmpp.org/extensions/xep-0167.html#srtp
case 'crypto': $encryption = $description->addChild('encryption'); $crypto = $encryption->addChild('crypto'); $crypto->addAttribute('crypto-suite', $matches[2]); $crypto->addAttribute('key-params', $matches[3]); $crypto->addAttribute('tag', $matches[1]); if(isset($matches[5])) $crypto->addAttribute('session-params', $matches[5]); break; // http://xmpp.org/extensions/xep-0262.html
case 'zrtp-hash': $zrtphash = $encryption->addChild('zrtp-hash', $matches[2]); $zrtphash->addAttribute('xmlns', "urn:xmpp:jingle:apps:rtp:zrtp:1"); $zrtphash->addAttribute('version', $matches[1]); break; case 'rtcp_mux': $description->addChild('rtcp-mux'); break;
// http://xmpp.org/extensions/xep-0294.html
case 'extmap': $rtphdrext = $description->addChild('rtp-hdrext'); $rtphdrext->addAttribute('xmlns', "urn:xmpp:jingle:apps:rtp:rtp-hdrext:0"); $rtphdrext->addAttribute('id', $matches[1]); $rtphdrext->addAttribute('uri', $matches[4]); if(isset($matches[3]) && $matches[3] != '') $rtphdrext->addAttribute('senders', $matches[3]); break; // http://xmpp.org/extensions/inbox/jingle-source.html
case 'ssrc': if(!$description->source) { $ssrc = $description->addChild('source'); $ssrc->addAttribute('xmlns', "urn:xmpp:jingle:apps:rtp:ssma:0"); $ssrc->addAttribute('id', $matches[1]); } $param = $ssrc->addChild('parameter'); $param->addAttribute('name', $matches[2]); $param->addAttribute('value', $matches[4]); break; case 'ptime': $description->addAttribute('ptime', $matches[1]); break; case 'maxptime': $description->addAttribute('maxptime', $matches[1]); break; // http://xmpp.org/extensions/xep-0320.html
case 'fingerprint': if($this->content == null) { $this->global_fingerprint['fingerprint'] = $matches[2]; $this->global_fingerprint['hash'] = $matches[1]; } else { $fingerprint = $this->transport->addChild('fingerprint', $matches[2]); $fingerprint->addAttribute('xmlns', "urn:xmpp:jingle:apps:dtls:0"); $fingerprint->addAttribute('hash', $matches[1]); } break;
// http://xmpp.org/extensions/inbox/jingle-dtls.html
case 'sctpmap': $sctpmap = $this->transport->addChild('sctpmap'); $sctpmap->addAttribute('xmlns', "urn:xmpp:jingle:transports:dtls-sctp:1"); $sctpmap->addAttribute('number', $matches[1]); $sctpmap->addAttribute('protocol', $matches[2]); $sctpmap->addAttribute('streams', $matches[3]); break; case 'setup': if($this->content != null) { $fingerprint->addAttribute('setup', $matches[1]); } break; case 'pwd': if($this->content == null) { $this->global_fingerprint['pwd'] = $matches[1]; } else { $this->transport->addAttribute('pwd', $matches[1]); } break; case 'ufrag': if($this->content == null) { $this->global_fingerprint['ufrag'] = $matches[1]; } else { $this->transport->addAttribute('ufrag', $matches[1]); } break; case 'candidate': $generation = "0"; $network = "0"; $id = generateKey(10); if($key = array_search("generation", $matches)) $generation = $matches[($key+1)]; if($key = array_search("network", $matches)) $network = $matches[($key+1)]; if($key = array_search("id", $matches)) $id = $matches[($key+1)]; if(isset($matches[11]) && isset($matches[13])) { $reladdr = $matches[11]; $relport = $matches[13]; } else { $reladdr = $relport = null; } $candidate = $this->transport->addChild('candidate'); $candidate->addAttribute('component' , $matches[2]); $candidate->addAttribute('foundation', $matches[1]);
$candidate->addAttribute('generation', $generation); $candidate->addAttribute('id' , $id); $candidate->addAttribute('ip' , $matches[5]); $candidate->addAttribute('network' , $network); $candidate->addAttribute('port' , $matches[6]); $candidate->addAttribute('priority' , $matches[4]); $candidate->addAttribute('protocol' , $matches[3]); $candidate->addAttribute('type' , $matches[8]); if($reladdr) { $candidate->addAttribute('rel-addr' , $reladdr); $candidate->addAttribute('rel-port' , $relport); } break; } } } }
//$this->jingle->addChild('sdp', $this->sdp);
// We reindent properly the Jingle package
$xml = $this->jingle->asXML(); $doc = new \DOMDocument(); $doc->loadXML($xml); $doc->formatOutput = true; return substr($doc->saveXML() , strpos($doc->saveXML(), "\n")+1 ); }}
|
