CDRTool SIP trace
Call ID: $callid $authorize
";
$basicURL = $protocolURL.$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI'];
$fullURL = $basicURL;
print "URLs for this trace: HTML | TEXT";
if ($this->mediaTrace) {
$media_query = array(
'cdr_source' => $this->mediaTrace,
'callid' => $callid,
'fromtag' => $fromtag,
'totag' => $totag,
'proxyIP' => $proxyIP
);
$this->mediaTraceLink = sprintf(
"",
http_build_query($media_query)
);
}
print "
Click on each packet to expand its body content
$this->mediaTraceLink| Packet | Time | "; $_seen_timeline = array(); foreach (array_keys($this->column) as $_key) { $IPels = explode(":", $_key); if (isset($this->hostnames[$IPels[0]])) { $_hostname = $this->hostnames[$IPels[0]]; } else { $_hostname = $_key; } print ""; if ($proxyIP != $IPels[0] && $this->isProxy($IPels[0], $proxyIP)) { $trace_query = array( 'cdr_source' => $this->cdr_source, 'callid' => $callid, 'fromtag' => $fromtag, 'totag' => $totag, 'proxyIP' => $IPels[0] ); $trace_link = sprintf( "%s:%s", http_build_query($trace_query), $_hostname, $this->column_port[$_key] ); printf("%s", $trace_link); } else { printf("%s", $_hostname); } print " | "; } print "|||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| $i/$this->rows | "; if ($direction == 'in') { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']); } else { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']); } echo " | "; } $arrowColor = $status_color; if ($arrow_direction == 'loop') { print ""; } if ($arrow_possition >= 2 * $msg_possition) { $arrow_span = ($arrow_possition * 2) - 4; echo " | "; } else { echo " | ";
}
if ($arrow_direction != 'loop') {
print "";
}
if ($arrow_direction == "left") {
print " $cell_content ";
} else {
print "$cell_content ";
}
echo " | ";
if ($column_current < count($this->column) && $column_current > $msg_possition) {
print ""; if ($direction == 'in') { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']); } else { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']); } echo " | "; } } else { if ($msg_possition == $column_current) { if ($msg_possition < $arrow_possition) { print ""; if ($direction == 'out') { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']); } else { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']); } } else { print " | "; if ($direction == 'out') { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']); } else { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']); } } } elseif ($arrow_possition != $column_current && ( $column_current == 1 || ( $arrow_possition < $column_current && $arrow_possition != $msg_possition) )) { print " | "; print " | "; print " "; } elseif ($arrow_possition == $msg_possition) { echo " | "; #} elseif ($column_current != $this->column[$fromip] && $column_current != $this->column[$toip]) { # echo " | "; } echo ""; } if ($arrow_possition == $column_current && $column_current == count($this->column)) { echo " | "; if ($direction == 'in') { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']); } else { $this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']); } echo " | "; } $column_current++; if ($arrow_direction == 'loop') { $seen_msg[$md5]++; } } echo "|||
|
";
if ($direction == "out" or $isProxy) {
print " SIP Proxy"; if ($timeline > 0) { printf(" +%s s ";
$msg = nl2br(htmlentities($msg));
print "$msg
|
|||||||||||||||
";
if (!count($this->trace_array)) {
print "SIP trace for session id $callid is not available.";
return false;
}
printf("SIP trace on proxy %s for session %s\n--\n\n", $proxyIP, $callid);
$i = 0;
foreach (array_keys($this->trace_array) as $key) {
$i++;
printf(
"Packet %d at %s from %s to %s (%s)\n",
$i,
$this->trace_array[$key]['date'],
$this->trace_array[$key]['fromip'],
$this->trace_array[$key]['toip'],
$this->trace_array[$key]['direction']
);
printf(
"\n%s\n",
htmlspecialchars($this->trace_array[$key]['msg'])
);
print "---\n";
}
print "";
}
public function togglePublicVisibility($callid, $fromtag, $public = '0')
{
$key="callid-".trim($callid).trim($fromtag);
if (!$public) {
$query = sprintf("delete from memcache where `key` = '%s'", addslashes($key));
$this->cdrtool->query($query);
} else {
$query = sprintf("delete from memcache where `key` = '%s'", addslashes($key));
$this->cdrtool->query($query);
$query = sprintf("insert into memcache values ('%s','public')", addslashes($key));
$this->cdrtool->query($query);
}
}
public function purgeRecords($days = '')
{
if ($this->enableThor) {
return true;
}
$b=time();
if ($days) {
$this->purgeRecordsAfter = $days;
} elseif (!$this->purgeRecordsAfter) {
$this->purgeRecordsAfter = 15;
}
$beforeDate=Date("Y-m-d", time()-$this->purgeRecordsAfter*3600*24);
$query = sprintf(
"SELECT id as min, time_stamp FROM %s ORDER BY id ASC limit 1",
addslashes($this->table)
);
if ($this->db->query($query)) {
if ($this->db->num_rows()) {
$this->db->next_record();
$min=$this->db->f('min');
$begindate=$this->db->f('date');
} else {
$log = sprintf("No records found in %s\n", $this->table);
print $log;
syslog(LOG_NOTICE, $log);
return false;
}
} else {
$log = sprintf("Error: %s (%s)\n", $this->db->Error, $query);
print $log;
syslog(LOG_NOTICE, $log);
return false;
}
$query=sprintf(
"select id as max from %s where time_stamp < '%s' order by id DESC limit 1",
addslashes($this->table),
addslashes($beforeDate)
);
if ($this->db->query($query) && $this->db->num_rows()) {
$this->db->next_record();
$max=$this->db->f('max');
} else {
$log=sprintf(
"No records found in %s before %s, records start after %s\n",
$this->table,
$beforeDate,
$begindate
);
syslog(LOG_NOTICE, $log);
print $log;
return false;
}
$deleted = 0;
$i = $min;
$interval = 1000;
$rows2delete = $max - $min;
$found = 0;
print "$rows2delete traces to delete between $min and $max\n";
$progress = 0;
while ($i<=$max) {
$found=$found+$interval;
if ($i + $interval < $max) {
$top=$i;
} else {
$top=$max;
}
$query = sprintf(
"delete low_priority from %s where id >= '%d' and id <='%d'",
addslashes($this->table),
addslashes($min),
addslashes($top)
);
if ($this->db->query($query)) {
$deleted = $deleted + $this->db->affected_rows();
} else {
$log = sprintf("Error: %s (%s)", $this->db->Error, $this->db->Errno);
syslog(LOG_NOTICE, $log);
return false;
}
if ($found > $progress * $rows2delete / 100) {
$progress++;
if ($progress % 10 == 0) {
print "$progress% ";
}
flush();
}
$i = $i + $interval;
}
print "\n";
$e = time();
$d = $e - $b;
$rps = 0;
if ($deleted && $d) {
$rps=$deleted/$d;
}
$log = sprintf(
"%s records before %s from %s deleted in %d s @ %.0f rps\n",
$deleted,
$beforeDate,
$this->table,
$d,
$rps
);
syslog(LOG_NOTICE, $log);
print $log;
return true;
}
}