Connected to MediaProxy2 dispatcher %s:%s",$this->dispatcher_ip, $this->dispatcher_port); if (!count($this->allowedDomains)) { fputs($fp, "summary\r\n"); $line = fgets($fp); $this->relays = json_decode($line); } fputs($fp, "sessions\r\n"); $line = fgets($fp); $_sessions=json_decode($line); if (count($this->allowedDomains)) { foreach ($_sessions as $_session) { list($user1,$domain1)=explode("@",$_session->from_uri); list($user2,$domain2)=explode("@",$_session->to_uri); if (!in_array($domain1,$this->allowedDomains) && !in_array($domain2,$this->allowedDomains)) { continue; } if (strlen($this->filters['user'])) { $user=$this->filters['user']; if (preg_match("/$user/",$_session->from_uri) || preg_match("/$user/",$_session->to_uri) ) { $this->sessions[] = $_session; } } } } else { $this->sessions = $_sessions; } fclose($fp); return true; } else { printf ("

Error connecting to %s:%s: %s (%s) \n",$this->dispatcher_ip,$this->dispatcher_port,$errstr,$errno); return false; } } function showSearch() { if (!count($this->sessions)) return; printf ("

", $_SERVER['PHP_SELF'], $_REQUEST['user'] ); } function showHeader() { print " "; } function showFooter() { } function show() { $this->showHeader(); print "

Media sessions

"; $this->showSearch(); if (!count($this->allowedDomains)) { $this->showRelays(); } $this->showSessions(); $this->showFooter(); } function showRelays() { print " "; $i = 1; foreach ($this->relays as $relay) { unset($media_types); unset($streams); foreach ($relay->stream_count as $key => $value) { $media_types++; } if ($media_types > 1) { $streams = "

		Address		Version		Uptime		Relayed traffic		Sessions		Streams		Status

"; foreach ($relay->stream_count as $key => $value) { $streams .= sprintf("",$key,$value); } $streams .= "

%s

%s

"; } else { foreach ($relay->stream_count as $key => $value) { $streams=sprintf("%s %s",$key,$value); } } printf (" %d %s %s %s %s %d %s %s ", $i, $relay->ip, $relay->version, $this->normalizeTime($relay->uptime), $this->normalizeTraffic($relay->bps_relayed), $relay->session_count, $streams, ucfirst($relay->status) ); $i++; } print "
"; } function showSessions () { if (!count($this->sessions)) return; print " "; $i = 1; foreach ($this->sessions as $session) { $from = $session->from_uri; $to = $session->to_uri; $fromAgent = $session->caller_ua; $toAgent = $session->callee_ua; $fromImage = $this->getImageForUserAgent($fromAgent); $toImage = $this->getImageForUserAgent($toAgent); $sc = count($session->streams); print " "; $duration = $this->normalizeTime($session->duration); foreach ($session->streams as $streamInfo) { $status = $streamInfo->status; if ($status=="idle" || $status=='hold') { $idletime = $this->normalizeTime($streamInfo->timeout_wait); $status = sprintf("%s %s", $status, $idletime); } $caller = $streamInfo->caller_remote; $callee = $streamInfo->callee_remote; $relay_caller = $streamInfo->caller_local; $relay_callee = $streamInfo->callee_local; $codec = $streamInfo->caller_codec; $type = $streamInfo->media_type; if ($caller == '?.?.?.?:?') { $caller = '–'; // a dash $align1 = 'center'; } else { $align1 = 'left'; } if ($callee == '?.?.?.?:?') { $callee = '–'; // a dash $align2 = 'center'; } else { $align2 = 'left'; } if ($codec == 'Unknown') $codec = '–'; // a dash if ($type == 'Unknown') $type = '–'; // a dash $bytes_in1 = $this->normalizeBytes($streamInfo->caller_bytes); $bytes_in2 = $this->normalizeBytes($streamInfo->callee_bytes); print " "; } $i++; } print "

	Callers	Phones		Media Streams
				Caller address	Relay caller	Relay callee	Callee address	Status	Codec	Type	Duration	Bytes Caller	Bytes Called
$i	From: $from To: $to			$caller	$relay_caller	$relay_callee	$callee	$status	$codec	$type	$duration	$bytes_in1	$bytes_in2

"; } function normalizeBytes($bytes) { $mb = $bytes/1024/1024.0; $kb = $bytes/1024.0; if ($mb >= 0.95) { return sprintf("%.2fM", $mb); } else if ($kb >= 1) { return sprintf("%.2fk", $kb); } else { return sprintf("%d", $bytes); } } function normalizeTime($period) { $sec = $period % 60; $min = floor($period/60); $h = floor($min/60); $min = $min % 60; if ($h >= 1) { return sprintf('%dh%02d\'%02d"', $h, $min, $sec); } else { return sprintf('%d\'%02d"', $min, $sec); } } function normalizeTraffic($traffic) { // input is in bytes/second $mb = $traffic/1024/1024.0; $kb = $traffic/1024.0; if ($mb >= 0.95) { return sprintf("%.2fMbps", $mb); } else if ($kb >= 1) { return sprintf("%.2fkbps",$kb); } else { return sprintf("%dbps",$traffic); } } function getImageForUserAgent($agent) { foreach ($this->userAgentImages as $agentRegexp => $image) { if (preg_match("/$agentRegexp/i", $agent)) { return $image; } } return "unknown.png"; } } ?>