mirror of
https://github.com/ZoneMinder/zoneminder.git
synced 2026-05-30 09:26:00 -04:00
0183e7e05e
Fix two issues preventing HEVC video playback in the web interface: 1. output_file() Content-Range header missing dash separator between byte range start and end values. The 206 Partial Content response sent "bytes 04382586/4382587" instead of "bytes 0-4382586/4382587", which browsers cannot parse, breaking all video streaming via the files view. 2. Event HLS playback fails for HEVC because video.js VHS detects the codec as "hvc1" from the fMP4 segment but cannot construct the full codec string (e.g. "hvc1.1.6.L153.B0") required by MediaSource.addSourceBuffer(). VHS only knows how to parse avcC boxes (H.264), not hvcC boxes (HEVC). Use hls.js (already shipped for live stream views) for HLS event playback instead - it properly parses HEVC codec info from init segments. Non-HLS events continue using video.js natively. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
2466 lines
77 KiB
PHP
2466 lines
77 KiB
PHP
<?php
|
|
//
|
|
// ZoneMinder web function library, $Date$, $Revision$
|
|
// Copyright (C) 2001-2008 Philip Coombes
|
|
//
|
|
// This program is free software; you can redistribute it and/or
|
|
// modify it under the terms of the GNU General Public License
|
|
// as published by the Free Software Foundation; either version 2
|
|
// of the License, or (at your option) any later version.
|
|
//
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program; if not, write to the Free Software
|
|
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
//
|
|
//
|
|
require_once('Filter.php');
|
|
require_once('FilterTerm.php');
|
|
|
|
function noCacheHeaders() {
|
|
header('Expires: Mon, 26 Jul 1997 05:00:00 GMT'); // Date in the past
|
|
header('Last-Modified: '.gmdate( 'D, d M Y H:i:s' ).' GMT'); // always modified
|
|
header('Cache-Control: no-store, no-cache, must-revalidate'); // HTTP/1.1
|
|
header('Cache-Control: post-check=0, pre-check=0', false);
|
|
header('Pragma: no-cache'); // HTTP/1.0
|
|
}
|
|
|
|
function CSPHeaders($view, $nonce) {
|
|
global $Servers;
|
|
|
|
$additionalScriptSrc = implode(' ', array_map(function($S){return $S->Hostname();}, $Servers));
|
|
switch ($view) {
|
|
case 'login':
|
|
if (defined('ZM_OPT_USE_GOOG_RECAPTCHA')
|
|
&& defined('ZM_OPT_GOOG_RECAPTCHA_SITEKEY')
|
|
&& defined('ZM_OPT_GOOG_RECAPTCHA_SECRETKEY')
|
|
&& ZM_OPT_USE_GOOG_RECAPTCHA && ZM_OPT_GOOG_RECAPTCHA_SITEKEY && ZM_OPT_GOOG_RECAPTCHA_SECRETKEY) {
|
|
$additionalScriptSrc .= ' https://www.google.com';
|
|
}
|
|
// fall through
|
|
default:
|
|
// Enforce script-src on pages where inline scripts and event handlers have been fixed.
|
|
header("Content-Security-Policy: object-src 'self'; worker-src 'self' blob:; script-src 'self' 'nonce-$nonce' $additionalScriptSrc".
|
|
(ZM_CSP_REPORT_URI ? '; report-uri '.ZM_CSP_REPORT_URI : '' )
|
|
);
|
|
break;
|
|
}
|
|
}
|
|
|
|
function CORSHeaders() {
|
|
if (isset($_SERVER['HTTP_ORIGIN'])) {
|
|
# The following is left for future reference/use.
|
|
$valid = false;
|
|
global $Servers;
|
|
if (sizeof($Servers) < 1) {
|
|
# Only need CORSHeaders in the event that there are multiple servers in use.
|
|
# ICON: Might not be true. multi-port?
|
|
if (ZM_MIN_STREAMING_PORT) {
|
|
ZM\Debug('Setting default Access-Control-Allow-Origin from ' . $_SERVER['HTTP_ORIGIN']);
|
|
header('Access-Control-Allow-Origin: ' . $_SERVER['HTTP_ORIGIN']);
|
|
header('Access-Control-Allow-Credentials: true');
|
|
header('Access-Control-Allow-Headers: x-requested-with,x-request');
|
|
}
|
|
return;
|
|
}
|
|
foreach ($Servers as $Server) {
|
|
if (
|
|
preg_match('/^(https?:\/\/)?'.preg_quote($Server->Hostname(),'/').'/i', $_SERVER['HTTP_ORIGIN'])
|
|
or
|
|
preg_match('/^(https?:\/\/)?'.preg_quote($Server->Name(),'/').'/i', $_SERVER['HTTP_ORIGIN'])
|
|
) {
|
|
$valid = true;
|
|
ZM\Debug('CORS Setting Access-Control-Allow-Origin from '.$_SERVER['HTTP_ORIGIN']);
|
|
header('Access-Control-Allow-Origin: ' . $_SERVER['HTTP_ORIGIN']);
|
|
header('Access-Control-Allow-Credentials: true');
|
|
header('Access-Control-Allow-Headers: x-requested-with,x-request');
|
|
|
|
break;
|
|
}
|
|
}
|
|
if (!$valid) {
|
|
ZM\Warning($_SERVER['HTTP_ORIGIN'] . ' is not found in servers list.');
|
|
}
|
|
} else {
|
|
ZM\Debug('CORS: NO origin');
|
|
}
|
|
}
|
|
|
|
function getMimeType($file) {
|
|
if (function_exists('mime_content_type')) {
|
|
return mime_content_type($file);
|
|
} else if (function_exists('finfo_file')) {
|
|
$finfo = finfo_open(FILEINFO_MIME);
|
|
$mimeType = finfo_file($finfo, $file);
|
|
finfo_close($finfo);
|
|
return $mimeType;
|
|
}
|
|
return trim(exec('file -bi '.escapeshellarg($file).' 2>/dev/null'));
|
|
}
|
|
|
|
function outputVideoStream($id, $src, $width, $height, $format, $title='') {
|
|
echo getVideoStreamHTML($id, $src, $width, $height, $format, $title);
|
|
}
|
|
|
|
function getVideoStreamHTML($id, $src, $width, $height, $format, $title='') {
|
|
$html = '';
|
|
$width = validInt($width);
|
|
$height = validInt($height);
|
|
$title = validHtmlStr($title);
|
|
|
|
if ( file_exists($src) ) {
|
|
$mimeType = getMimeType($src);
|
|
} else {
|
|
switch( $format ) {
|
|
case 'asf' :
|
|
$mimeType = 'video/x-ms-asf';
|
|
break;
|
|
case 'avi' :
|
|
case 'wmv' :
|
|
$mimeType = 'video/x-msvideo';
|
|
break;
|
|
case 'mov' :
|
|
$mimeType = 'video/quicktime';
|
|
break;
|
|
case 'mpg' :
|
|
case 'mpeg' :
|
|
$mimeType = 'video/mpeg';
|
|
break;
|
|
case 'swf' :
|
|
$mimeType = 'application/x-shockwave-flash';
|
|
break;
|
|
case '3gp' :
|
|
$mimeType = 'video/3gpp';
|
|
break;
|
|
default :
|
|
$mimeType = 'video/'.$format;
|
|
break;
|
|
}
|
|
}
|
|
if ( !$mimeType || ($mimeType == 'application/octet-stream') )
|
|
$mimeType = 'video/'.$format;
|
|
|
|
switch ($mimeType) {
|
|
case 'video/mp4' :
|
|
global $rates, $cspNonce;
|
|
$playbackRates = implode(',',
|
|
array_map(function($r){return $r/100;},
|
|
array_filter(
|
|
array_keys($rates),
|
|
function($r){return $r >= 0 ? true : false;}
|
|
)));
|
|
|
|
return '<video id="videoobj" class="video-js"
|
|
controls autoplay preload="auto">
|
|
<source src="'. $src.'" type="video/mp4">
|
|
Your browser does not support the video tag.
|
|
</video>
|
|
<script nonce="'.$cspNonce.'">
|
|
document.addEventListener("DOMContentLoaded", function() {
|
|
if (typeof videojs === "undefined") {
|
|
console.error("videojs is not loaded");
|
|
return;
|
|
}
|
|
var player = videojs("videoobj", {
|
|
controls: true,
|
|
autoplay: true,
|
|
preload: "auto",
|
|
fluid: true,
|
|
responsive: true,
|
|
playbackRates: [' . $playbackRates . ']
|
|
});
|
|
player.zoomrotate({
|
|
zoom: 1,
|
|
rotate: 0
|
|
});
|
|
});
|
|
</script>';
|
|
default:
|
|
return '<embed'. ( isset($mimeType)?(' type="'.$mimeType.'"'):'' ). '
|
|
src="'.$src.'"
|
|
name="'.$title.'"
|
|
width="'.$width.'"
|
|
height="'.$height.'"
|
|
autostart="1"
|
|
autoplay="1"
|
|
showcontrols="0"
|
|
controller="0">
|
|
</embed>';
|
|
}
|
|
}
|
|
|
|
function outputImageStream( $id, $src, $width, $height, $title='' ) {
|
|
echo getImageStreamHTML( $id, $src, $width, $height, $title );
|
|
}
|
|
|
|
// width and height MUST be valid and include the px
|
|
function getImageStreamHTML( $id, $src, $width, $height, $title='' ) {
|
|
if (canStreamIframe()) {
|
|
return '<iframe id="'.$id.'" src="'.$src.'" alt="'. validHtmlStr($title) .'" '.($width? ' width="'. validInt($width).'"' : '').($height?' height="'.validInt($height).'"' : '' ).'/>';
|
|
} else {
|
|
return getImageStill($id, $src, $width, $height, $title);
|
|
}
|
|
}
|
|
|
|
function outputControlStream($src, $width, $height, $monitor, $scale, $target) {
|
|
?>
|
|
<form name="ctrlForm" method="post" action="?" target="<?php echo $target ?>">
|
|
<input type="hidden" name="view" value="blank"/>
|
|
<input type="hidden" name="mid" value="<?php echo $monitor['Id'] ?>"/>
|
|
<input type="hidden" name="action" value="control"/>
|
|
<?php
|
|
if ($monitor['CanMoveMap']) {
|
|
?>
|
|
<input type="hidden" name="control" value="moveMap"/>
|
|
<?php
|
|
} else if ($monitor['CanMoveRel']) {
|
|
?>
|
|
<input type="hidden" name="control" value="movePseudoMap"/>
|
|
<?php
|
|
} else if ($monitor['CanMoveCon']) {
|
|
?>
|
|
<input type="hidden" name="control" value="moveConMap"/>
|
|
<?php
|
|
}
|
|
?>
|
|
<input type="hidden" name="scale" value="<?php echo $scale ?>"/>
|
|
<input type="image" src="<?php echo $src ?>" width="<?php echo $width ?>" height="<?php echo $height ?>">
|
|
</form>
|
|
<?php
|
|
}
|
|
|
|
function outputImageStill($id, $src, $width, $height, $title='') {
|
|
echo getImageStill($id, $src, $width, $height, $title='');
|
|
}
|
|
function getImageStill($id, $src, $width, $height, $title='') {
|
|
return '<img id="'.$id.'" src="'.$src.'" alt="'. validHtmlStr($title) .'" style="'.
|
|
(($width and ($width !='auto')) ?'width:'.$width.';' : '').
|
|
(($height and ($height != 'auto'))?' height:'.$height.';':'').
|
|
'" />';
|
|
}
|
|
|
|
function getWebSiteUrl($id, $src, $width, $height, $title='') {
|
|
# Prevent unsightly warnings when php cannot verify the ssl certificate
|
|
stream_context_set_default( [
|
|
'ssl' => [
|
|
'verify_peer' => false,
|
|
'verify_peer_name' => false,
|
|
],
|
|
]);
|
|
# The End User can turn off the following warning under Options -> Web
|
|
if ( ZM_WEB_XFRAME_WARN ) {
|
|
$header = get_headers($src, 1);
|
|
# If the target website has set X-Frame-Options, check it for "sameorigin" and warn the end user
|
|
if ( array_key_exists('X-Frame-Options', $header) ) {
|
|
$header = $header['X-Frame-Options'];
|
|
if ( stripos($header, 'sameorigin') === 0 )
|
|
ZM\Warning('Web site '.$src.' has X-Frame-Options set to sameorigin. An X-Frame-Options browser plugin is required to display this site.');
|
|
}
|
|
}
|
|
return '<object id="'.$id.'" data="'.$src.'" alt="'.$title.'" width="'.$width.'" height="'.$height.'"></object>';
|
|
}
|
|
|
|
function outputControlStill($src, $width, $height, $monitor, $scale, $target) {
|
|
?>
|
|
<form name="ctrlForm" method="post" action="?" target="<?php echo $target ?>">
|
|
<input type="hidden" name="view" value="blank"/>
|
|
<input type="hidden" name="mid" value="<?php echo $monitor['Id'] ?>"/>
|
|
<input type="hidden" name="action" value="control"/>
|
|
<?php
|
|
if ( $monitor['CanMoveMap'] ) {
|
|
?>
|
|
<input type="hidden" name="control" value="moveMap"/>
|
|
<?php
|
|
} else if ( $monitor['CanMoveRel'] ) {
|
|
?>
|
|
<input type="hidden" name="control" value="movePseudoMap"/>
|
|
<?php
|
|
} else if ( $monitor['CanMoveCon'] ) {
|
|
?>
|
|
<input type="hidden" name="control" value="moveConMap"/>
|
|
<?php
|
|
}
|
|
?>
|
|
<input type="hidden" name="scale" value="<?php echo $scale ?>"/>
|
|
<input type="image" src="<?php echo $src ?>" width="<?php echo $width ?>" height="<?php echo $height ?>"/>
|
|
</form>
|
|
<?php
|
|
}
|
|
|
|
// Incoming args are shell-escaped. This function must escape any further arguments it cannot guarantee.
|
|
function getZmuCommand($args) {
|
|
$zmuCommand = ZMU_PATH;
|
|
|
|
if ( ZM_OPT_USE_AUTH ) {
|
|
global $user;
|
|
// Always include username, so that we can do lookups faster
|
|
$zmuCommand .= ' -U '.escapeshellarg($user->Username());
|
|
if ( ZM_AUTH_RELAY == 'hashed' ) {
|
|
$zmuCommand .= ' -A '.generateAuthHash(false, true);
|
|
} else if ( ZM_AUTH_RELAY == 'plain' ) {
|
|
$zmuCommand .= ' -P '.escapeshellarg($_SESSION['password']);
|
|
}
|
|
}
|
|
|
|
$zmuCommand .= $args;
|
|
|
|
return $zmuCommand;
|
|
}
|
|
|
|
function getEventDefaultVideoPath($event) {
|
|
$Event = new ZM\Event($event);
|
|
return $Event->getStreamSrc(array('mode'=>'mpeg', 'format'=>'h264'));
|
|
}
|
|
|
|
function deletePath( $path ) {
|
|
ZM\Debug('Deleting '.$path);
|
|
if (is_link($path)) {
|
|
if (!unlink($path)) ZM\Debug("Failed to unlink $path");
|
|
} else if (is_dir($path)) {
|
|
if (false === ($output = system('rm -rf '.escapeshellarg($path)))) {
|
|
ZM\Warning('Failed doing rm -rf '.escapeshellarg($path));
|
|
}
|
|
} else if (file_exists($path)) {
|
|
if (!unlink($path)) ZM\Debug("Failed to delete $path");
|
|
} else {
|
|
ZM\Warning("Path $path does not exist in deletePath()");
|
|
}
|
|
}
|
|
|
|
function deleteEvent($event) {
|
|
if (empty($event)) {
|
|
ZM\Error('Empty event passed to deleteEvent.');
|
|
return;
|
|
}
|
|
|
|
if (gettype($event) != 'array') {
|
|
# $event could be an eid, so turn it into an event hash
|
|
$event = new ZM\Event($event);
|
|
}
|
|
|
|
if ($event->Archived()) {
|
|
ZM\Info('Cannot delete Archived event.');
|
|
return;
|
|
} # end if Archived
|
|
|
|
global $user;
|
|
|
|
if ($user->Events() == 'Edit') {
|
|
$event->delete();
|
|
} # CAN EDIT
|
|
}
|
|
|
|
/**
|
|
* $label must be already escaped. It can't be done here since it sometimes contains HTML tags.
|
|
*/
|
|
function makeLink($url, $label, $condition=1, $options='') {
|
|
$string = '';
|
|
if ($condition) {
|
|
$string .= '<a href="'.$url.'"'.($options?(' '.$options):'').'>';
|
|
}
|
|
$string .= $label;
|
|
if ($condition) {
|
|
$string .= '</a>';
|
|
}
|
|
return $string;
|
|
}
|
|
|
|
//Make it slightly easier to create a link to help text modal
|
|
function makeHelpLink($ohndx) {
|
|
return ' (<a id="'.$ohndx.'" class="optionhelp">?</a>)';
|
|
}
|
|
|
|
function makeButton($url, $buttonValue, $condition=1, $options='') {
|
|
$string = '<button type="button" data-on-click-this="'.$buttonValue.'"';
|
|
$string .= ' data-url="' .$url. '"';
|
|
if (!$condition) {
|
|
$string .= ' disabled="disabled"';
|
|
}
|
|
$string .= ($options ? (' ' . $options) : '') . '/>'.translate($buttonValue).'</button>'.PHP_EOL;
|
|
return $string;
|
|
}
|
|
|
|
function htmlSelect($name, $contents, $values, $behaviours=false) {
|
|
$behaviourText = '';
|
|
if ( !empty($behaviours) ) {
|
|
if ( is_array($behaviours) ) {
|
|
foreach ( $behaviours as $event=>$action ) {
|
|
$behaviourText .= ' '.$event.'="'.$action.'"';
|
|
}
|
|
} else {
|
|
$behaviourText = ' onchange="'.$behaviours.'"';
|
|
}
|
|
}
|
|
|
|
return '<select name="'.$name.'" '.$behaviourText.'>'.PHP_EOL.htmlOptions($contents, $values).'</select>';
|
|
}
|
|
|
|
function htmlOptions($options, $values) {
|
|
$options_html = '';
|
|
$has_selected = false;
|
|
foreach ( $options as $value=>$option ) {
|
|
$disabled = 0;
|
|
$text = '';
|
|
if ( is_array($option) ) {
|
|
|
|
if ( isset($option['Name']) )
|
|
$text = $option['Name'];
|
|
else if ( isset($option['text']) )
|
|
$text = $option['text'];
|
|
|
|
if ( isset($option['disabled']) ) {
|
|
$disabled = $option['disabled'];
|
|
}
|
|
} else if ( is_object($option) ) {
|
|
$text = $option->Name();
|
|
} else {
|
|
$text = $option;
|
|
}
|
|
$selected = false;
|
|
if ($values !== null) {
|
|
$selected = is_array($values) ? in_array($value, $values) : (!strcmp($value, $values));
|
|
if ( !$has_selected )
|
|
$has_selected = $selected;
|
|
}
|
|
|
|
$options_html .= '<option value="'.htmlspecialchars($value, ENT_COMPAT | ENT_HTML401, ini_get('default_charset'), false).'"'.
|
|
($selected?' selected="selected"':'').
|
|
($disabled?' disabled="disabled"':'').
|
|
'>'.htmlspecialchars($text, ENT_COMPAT | ENT_HTML401, ini_get('default_charset'), false).'</option>'.PHP_EOL;
|
|
} # end foreach options
|
|
if ( $values and ((!is_array($values)) or count($values) ) and ! $has_selected ) {
|
|
$backTrace = debug_backtrace();
|
|
ZM\Warning('Specified value '.print_r($values, true).' not in contents: '.print_r($options, true). ' from ' . print_r($backTrace, true));
|
|
}
|
|
return $options_html;
|
|
} # end function htmlOptions
|
|
|
|
function truncText($text, $length, $deslash=1) {
|
|
return preg_replace('/^(.{'.$length.',}?)\b.*$/', '\\1…', ($deslash?stripslashes($text):$text));
|
|
}
|
|
|
|
function buildSelect($name, $contents, $behaviours=false) {
|
|
$value = '';
|
|
if ( preg_match('/^\s*(\w+)\s*(\[.*\])?\s*$/', $name, $matches) && (count($matches) > 2) ) {
|
|
$arr = $matches[1];
|
|
if ( isset($GLOBALS[$arr]) )
|
|
$value = $GLOBALS[$arr];
|
|
elseif ( isset($_REQUEST[$arr]) )
|
|
$value = $_REQUEST[$arr];
|
|
if ( !preg_match_all('/\[\s*[\'"]?(\w+)["\']?\s*\]/', $matches[2], $matches) ) {
|
|
ZM\Fatal("Can't parse selector '$name'");
|
|
}
|
|
for ( $i = 0; $i < count($matches[1]); $i++ ) {
|
|
$idx = $matches[1][$i];
|
|
$value = isset($value[$idx])?$value[$idx]:false;
|
|
}
|
|
} else {
|
|
if ( isset($GLOBALS[$name]) )
|
|
$value = $GLOBALS[$name];
|
|
elseif ( isset($_REQUEST[$name]) )
|
|
$value = $_REQUEST[$name];
|
|
}
|
|
ob_start();
|
|
$behaviourText = '';
|
|
if ( !empty($behaviours) ) {
|
|
if ( is_array($behaviours) ) {
|
|
foreach ( $behaviours as $event=>$action ) {
|
|
$behaviourText .= ' '.$event.'="'.$action.'"';
|
|
}
|
|
} else {
|
|
$behaviourText = ' data-on-change-this="'.$behaviours.'"';
|
|
}
|
|
}
|
|
?>
|
|
<select name="<?php echo $name ?>" id="<?php echo $name ?>"<?php echo $behaviourText ?>>
|
|
<?php
|
|
foreach ( $contents as $contentValue => $contentText ) {
|
|
?>
|
|
<option value="<?php echo $contentValue ?>"<?php if ( $value == $contentValue ) { ?> selected="selected"<?php } ?>><?php echo validHtmlStr($contentText) ?></option>
|
|
<?php
|
|
}
|
|
?>
|
|
</select>
|
|
<?php
|
|
$html = ob_get_contents();
|
|
ob_end_clean();
|
|
|
|
return $html;
|
|
}
|
|
|
|
function getFormChanges($values, $newValues, $types=false, $columns=false) {
|
|
$changes = array();
|
|
if ( !$types )
|
|
$types = array();
|
|
|
|
foreach ( $newValues as $key=>$value ) {
|
|
if ( $columns && !isset($columns[$key]) )
|
|
continue;
|
|
|
|
# Validate column name to prevent SQL injection via array keys
|
|
if ( !preg_match('/^[a-zA-Z0-9_]+$/', $key) ) {
|
|
ZM\Warning("Invalid column name rejected in getFormChanges: $key");
|
|
continue;
|
|
}
|
|
|
|
if ( !isset($types[$key]) )
|
|
$types[$key] = false;
|
|
|
|
switch ( $types[$key] ) {
|
|
case 'set' :
|
|
if ( is_array($newValues[$key]) ) {
|
|
if ( (!isset($values[$key])) or ( join(',',$newValues[$key]) != $values[$key] ) ) {
|
|
$changes[$key] = "`$key` = ".dbEscape(join(',',$newValues[$key]));
|
|
}
|
|
} else if ( (!isset($values[$key])) or $values[$key] ) {
|
|
$changes[$key] = "`$key` = ''";
|
|
}
|
|
break;
|
|
case 'image' :
|
|
if ( is_array( $newValues[$key] ) ) {
|
|
$imageData = getimagesize( $newValues[$key]['tmp_name'] );
|
|
if ( !is_array($imageData) ) {
|
|
ZM\Warning("getimagesize failed for uploaded field '$key'; skipping width/height update.");
|
|
} else {
|
|
$changes[$key.'Width'] = $key.'Width = '.intval($imageData[0]);
|
|
$changes[$key.'Height'] = $key.'Height = '.intval($imageData[1]);
|
|
}
|
|
$changes[$key.'Type'] = $key.'Type = '.dbEscape($newValues[$key]['type']);
|
|
$changes[$key.'Size'] = $key.'Size = '.intval($newValues[$key]['size']);
|
|
ob_start();
|
|
readfile( $newValues[$key]['tmp_name'] );
|
|
$changes[$key] = $key." = ".dbEscape( ob_get_contents() );
|
|
ob_end_clean();
|
|
} else {
|
|
$changes[$key] = "$key = ".dbEscape($value);
|
|
}
|
|
break;
|
|
case 'document' :
|
|
if ( is_array( $newValues[$key] ) ) {
|
|
$changes[$key.'Type'] = $key.'Type = '.dbEscape($newValues[$key]['type']);
|
|
$changes[$key.'Size'] = $key.'Size = '.intval($newValues[$key]['size']);
|
|
ob_start();
|
|
readfile( $newValues[$key]['tmp_name'] );
|
|
$changes[$key] = $key.' = '.dbEscape( ob_get_contents() );
|
|
ob_end_clean();
|
|
} else {
|
|
$changes[$key] = $key . ' = '.dbEscape($value);
|
|
}
|
|
break;
|
|
case 'file' :
|
|
$changes[$key.'Type'] = $key.'Type = '.dbEscape($newValues[$key]['type']);
|
|
$changes[$key.'Size'] = $key.'Size = '.dbEscape($newValues[$key]['size']);
|
|
ob_start();
|
|
readfile( $newValues[$key]['tmp_name'] );
|
|
$changes[$key] = $key.' = \''.dbEscape( ob_get_contents() ).'\'';
|
|
ob_end_clean();
|
|
break;
|
|
case 'raw' :
|
|
if ( (!isset($values[$key])) or ($values[$key] != $value) ) {
|
|
$changes[$key] = $key . ' = '.dbEscape($value);
|
|
}
|
|
break;
|
|
case 'toggle' :
|
|
if ( (!isset($values[$key])) or $values[$key] != $value ) {
|
|
if ( empty($value) ) {
|
|
$changes[$key] = $key.' = 0';
|
|
} else {
|
|
$changes[$key] = $key.' = 1';
|
|
//$changes[$key] = $key . ' = '.dbEscape(trim($value));
|
|
}
|
|
}
|
|
break;
|
|
case 'integer' :
|
|
if ( (!isset($values[$key])) or $values[$key] != $value ) {
|
|
$changes[$key] = $key . ' = '.intval($value);
|
|
}
|
|
break;
|
|
default :
|
|
if ( !isset($values[$key]) || ($values[$key] != $value) ) {
|
|
if ( ! isset($value) || $value == '' ) {
|
|
$changes[$key] = "`$key` = NULL";
|
|
} else {
|
|
$changes[$key] = "`$key` = ".dbEscape(trim($value));
|
|
}
|
|
}
|
|
break;
|
|
} // end switch
|
|
} // end foreach newvalues
|
|
|
|
foreach ( $values as $key=>$value ) {
|
|
if ( !empty($columns[$key]) ) {
|
|
if ( !empty($types[$key]) ) {
|
|
if ( $types[$key] == 'toggle' ) {
|
|
if ( !isset($newValues[$key]) && !empty($value) ) {
|
|
$changes[$key] = "`$key` = 0";
|
|
}
|
|
} else if ( $types[$key] == 'set' ) {
|
|
$changes[$key] = "`$key` = ''";
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return $changes;
|
|
}
|
|
|
|
function getBrowser(&$browser, &$version) {
|
|
if ( isset($_SESSION['browser']) ) {
|
|
$browser = $_SESSION['browser'];
|
|
$version = $_SESSION['version'];
|
|
} else {
|
|
if (
|
|
( preg_match('/MSIE (.*?);/', $_SERVER['HTTP_USER_AGENT'], $logVersion))
|
|
||
|
|
( preg_match('/.*Trident.*rv:(.*?)(;|\))/', $_SERVER['HTTP_USER_AGENT'], $logVersion))
|
|
) {
|
|
$version = $logVersion[1];
|
|
$browser = 'ie';
|
|
} else if ( preg_match('/Chrome\/([0-9]+)/', $_SERVER['HTTP_USER_AGENT'], $logVersion) ) {
|
|
// We only care about the major so don't count .
|
|
$version = $logVersion[1];
|
|
// Check for old version of Chrome with bug 5876
|
|
if ( $version < 7 ) {
|
|
$browser = 'oldchrome';
|
|
} else {
|
|
$browser = 'chrome';
|
|
}
|
|
} else if ( preg_match('/Safari\/([0-9.]+)/', $_SERVER['HTTP_USER_AGENT'], $logVersion) ) {
|
|
$version = $logVersion[1];
|
|
$browser = 'safari';
|
|
} else if ( preg_match('/Opera[ \/]([0-9].[0-9]{1,2})/', $_SERVER['HTTP_USER_AGENT'], $logVersion) ) {
|
|
$version = $logVersion[1];
|
|
$browser = 'opera';
|
|
} else if ( preg_match('/Konqueror\/([0-9.]+)/', $_SERVER['HTTP_USER_AGENT'], $logVersion) ) {
|
|
$version = $logVersion[1];
|
|
$browser = 'konqueror';
|
|
} else if ( preg_match('/Mozilla\/([0-9].[0-9]{1,2})/', $_SERVER['HTTP_USER_AGENT'], $logVersion) ) {
|
|
$version = $logVersion[1];
|
|
$browser = 'mozilla';
|
|
} else {
|
|
$version = 0;
|
|
$browser = 'unknown';
|
|
}
|
|
$_SESSION['browser'] = $browser;
|
|
$_SESSION['version'] = $version;
|
|
}
|
|
}
|
|
|
|
function isMozilla() {
|
|
getBrowser($browser, $version);
|
|
|
|
return $browser == 'mozilla';
|
|
}
|
|
|
|
function isKonqueror() {
|
|
getBrowser($browser, $version);
|
|
|
|
return $browser == 'konqueror';
|
|
}
|
|
|
|
function isInternetExplorer() {
|
|
getBrowser($browser, $version);
|
|
|
|
return $browser == 'ie';
|
|
}
|
|
|
|
function isOldChrome() {
|
|
getBrowser($browser, $version);
|
|
|
|
return $browser == 'oldchrome';
|
|
}
|
|
|
|
function isChrome() {
|
|
getBrowser($browser, $version);
|
|
|
|
return $browser == 'chrome';
|
|
}
|
|
|
|
function isOpera() {
|
|
getBrowser($browser, $version);
|
|
|
|
return $browser == 'opera';
|
|
}
|
|
|
|
function isSafari() {
|
|
getBrowser($browser, $version);
|
|
|
|
return $browser == 'safari';
|
|
}
|
|
|
|
function isWindows() {
|
|
return preg_match('/Win/', $_SERVER['HTTP_USER_AGENT']);
|
|
}
|
|
|
|
function canStreamIframe() {
|
|
return isKonqueror();
|
|
}
|
|
|
|
function canStreamNative() {
|
|
// Old versions of Chrome can display the stream, but then it blocks everything else (Chrome bug 5876)
|
|
return ( ZM_WEB_CAN_STREAM == 'yes' || ( ZM_WEB_CAN_STREAM == 'auto' && (!isInternetExplorer() && !isOldChrome()) ) );
|
|
}
|
|
|
|
function canStream() {
|
|
return canStreamNative();
|
|
}
|
|
|
|
function packageControl($command) {
|
|
$string = ZM_PATH_BIN.'/zmpkg.pl '.escapeshellarg($command);
|
|
$string .= ' 2>/dev/null >&- <&- >/dev/null';
|
|
exec($string);
|
|
}
|
|
|
|
function daemonControl($command, $daemon=false, $args=false) {
|
|
$string = escapeshellcmd(ZM_PATH_BIN).'/zmdc.pl '.$command;
|
|
if ( $daemon ) {
|
|
$string .= ' ' . $daemon;
|
|
if ( $args ) {
|
|
$string .= ' ' . $args;
|
|
}
|
|
}
|
|
$string = escapeshellcmd($string);
|
|
#$string .= ' 2>/dev/null >&- <&- >/dev/null';
|
|
ZM\Debug('daemonControl '.$string);
|
|
exec($string);
|
|
}
|
|
|
|
function zmcControl($monitor, $mode=false) {
|
|
$Monitor = new ZM\Monitor($monitor);
|
|
return $Monitor->zmcControl($mode);
|
|
}
|
|
|
|
function initDaemonStatus() {
|
|
global $daemon_status;
|
|
|
|
if ( !isset($daemon_status) ) {
|
|
if ( daemonCheck() ) {
|
|
$string = ZM_PATH_BIN.'/zmdc.pl status';
|
|
$daemon_status = shell_exec($string);
|
|
} else {
|
|
$daemon_status = '';
|
|
}
|
|
}
|
|
}
|
|
|
|
function daemonStatus($daemon, $args=false) {
|
|
global $daemon_status;
|
|
|
|
initDaemonStatus();
|
|
|
|
$string = $daemon;
|
|
if ( $args ) {
|
|
if ( is_array($args) ) {
|
|
$string .= join(' ', $args);
|
|
} else {
|
|
$string .= ' ' . $args;
|
|
}
|
|
}
|
|
return ( strpos($daemon_status, "'$string' running") !== false );
|
|
}
|
|
|
|
function zmcStatus($monitor) {
|
|
if ( $monitor['Type'] == 'Local' ) {
|
|
$zmcArgs = '-d '.escapeshellarg($monitor['Device']);
|
|
} else {
|
|
$zmcArgs = '-m '.escapeshellarg($monitor['Id']);
|
|
}
|
|
return daemonStatus('zmc', $zmcArgs);
|
|
}
|
|
|
|
function daemonCheck($daemon=false, $args=false) {
|
|
$string = ZM_PATH_BIN.'/zmdc.pl check';
|
|
if ( $daemon ) {
|
|
$string .= ' ' . $daemon;
|
|
if ( $args )
|
|
$string .= ' '. $args;
|
|
}
|
|
$string = escapeshellcmd($string);
|
|
$result = exec($string);
|
|
return preg_match('/running/', $result);
|
|
}
|
|
|
|
function zmcCheck($monitor) {
|
|
if ( $monitor['Type'] == 'Local' ) {
|
|
$zmcArgs = '-d '.escapeshellarg($monitor['Device']);
|
|
} else {
|
|
$zmcArgs = '-m '.escapeshellarg($monitor['Id']);
|
|
}
|
|
return daemonCheck('zmc', $zmcArgs);
|
|
}
|
|
|
|
function getImageSrc($event, $frame, $scale=SCALE_BASE, $captureOnly=false, $overwrite=false) {
|
|
$Event = new ZM\Event($event);
|
|
return $Event->getImageSrc($frame, $scale, $captureOnly, $overwrite);
|
|
}
|
|
|
|
function viewImagePath($path, $querySep='&') {
|
|
return '?view=image'.$querySep.'path='.$path;
|
|
}
|
|
|
|
function createListThumbnail($event, $overwrite=false) {
|
|
# Load the frame with the highest score to use as a thumbnail
|
|
if ( !($frame = dbFetchOne('SELECT * FROM Frames WHERE EventId=? AND Score=? ORDER BY FrameId LIMIT 1', NULL, array($event['Id'], $event['MaxScore']) )) )
|
|
return false;
|
|
|
|
$frameId = $frame['FrameId'];
|
|
|
|
if ( ZM_WEB_LIST_THUMB_WIDTH ) {
|
|
$thumbWidth = ZM_WEB_LIST_THUMB_WIDTH;
|
|
$scale = (SCALE_BASE*ZM_WEB_LIST_THUMB_WIDTH)/$event['Width'];
|
|
$thumbHeight = reScale($event['Height'], $scale);
|
|
} elseif ( ZM_WEB_LIST_THUMB_HEIGHT ) {
|
|
$thumbHeight = ZM_WEB_LIST_THUMB_HEIGHT;
|
|
$scale = (SCALE_BASE*ZM_WEB_LIST_THUMB_HEIGHT)/$event['Height'];
|
|
$thumbWidth = reScale($event['Width'], $scale);
|
|
} else {
|
|
ZM\Fatal('No thumbnail width or height specified, please check in Options->Web');
|
|
}
|
|
|
|
$imageData = getImageSrc($event, $frame, $scale, false, $overwrite);
|
|
if ( !$imageData ) {
|
|
return false;
|
|
}
|
|
|
|
$thumbData = $frame;
|
|
$thumbData['Path'] = $imageData['thumbPath'];
|
|
$thumbData['Width'] = (int)$thumbWidth;
|
|
$thumbData['Height'] = (int)$thumbHeight;
|
|
|
|
return $thumbData;
|
|
}
|
|
|
|
# This takes more than one scale amount, so it runs through each and alters dimension.
|
|
# I can't imagine why you would want to do that.
|
|
function reScale($dimension, $dummy) {
|
|
$new_dimension = $dimension;
|
|
for ( $i = 1; $i < func_num_args(); $i++ ) {
|
|
$scale = func_get_arg($i);
|
|
if ( !empty($scale) && ($scale != '0') && ($scale != 'auto') && ($scale != 'fixed') && ($scale != SCALE_BASE) )
|
|
$new_dimension = (int)(($new_dimension*$scale)/SCALE_BASE);
|
|
}
|
|
return $new_dimension;
|
|
}
|
|
|
|
function deScale($dimension, $dummy) {
|
|
$new_dimension = $dimension;
|
|
for ( $i = 1; $i < func_num_args(); $i++ ) {
|
|
$scale = func_get_arg($i);
|
|
if ( !empty($scale) && $scale != SCALE_BASE )
|
|
$new_dimension = (int)(($new_dimension*SCALE_BASE)/$scale);
|
|
}
|
|
return $new_dimension;
|
|
}
|
|
|
|
function monitorLimitSql() {
|
|
global $user;
|
|
if ( count($user->unviewableMonitorIds()) )
|
|
$midSql = ' AND MonitorId IN ('.join(',', $user->viewableMonitorIds()).')';
|
|
else
|
|
$midSql = '';
|
|
return $midSql;
|
|
}
|
|
|
|
function parseSort($saveToSession=false, $querySep='&') {
|
|
global $sortQuery, $sortColumn, $sortOrder, $limitQuery; // Outputs
|
|
if ( isset($_REQUEST['filter']['Query']['sort_field']) ) { //Handle both new and legacy filter passing
|
|
$_REQUEST['sort_field'] = $_REQUEST['filter']['Query']['sort_field'];
|
|
}
|
|
if ( isset($_REQUEST['filter']['Query']['sort_asc']) ) {
|
|
$_REQUEST['sort_asc'] = $_REQUEST['filter']['Query']['sort_asc'];
|
|
}
|
|
if ( isset($_REQUEST['filter']['Query']['limit']) ) {
|
|
$_REQUEST['limit'] = $_REQUEST['filter']['Query']['limit'];
|
|
}
|
|
if ( empty($_REQUEST['sort_field']) ) {
|
|
$_REQUEST['sort_field'] = ZM_WEB_EVENT_SORT_FIELD;
|
|
$_REQUEST['sort_asc'] = (ZM_WEB_EVENT_SORT_ORDER == 'asc');
|
|
}
|
|
switch( $_REQUEST['sort_field'] ) {
|
|
case 'Id' :
|
|
$sortColumn = 'E.Id';
|
|
break;
|
|
case 'MonitorName' :
|
|
$sortColumn = 'M.Name';
|
|
break;
|
|
case 'Name' :
|
|
$sortColumn = 'E.Name';
|
|
break;
|
|
case 'Cause' :
|
|
$sortColumn = 'E.Cause';
|
|
break;
|
|
case 'DateTime' :
|
|
$sortColumn = 'E.StartDateTime';
|
|
$_REQUEST['sort_field'] = 'StartDateTime';
|
|
break;
|
|
case 'DiskSpace' :
|
|
$sortColumn = 'E.DiskSpace';
|
|
break;
|
|
case 'StartTime' :
|
|
# legacy
|
|
$_REQUEST['sort_field'] = 'StartDateTime';
|
|
$sortColumn = 'E.StartDateTime';
|
|
break;
|
|
case 'StartDateTime' :
|
|
$sortColumn = 'E.StartDateTime';
|
|
break;
|
|
case 'EndTime' :
|
|
#legacy
|
|
$_REQUEST['sort_field'] = 'EndDateTime';
|
|
$sortColumn = 'E.EndDateTime';
|
|
break;
|
|
case 'EndDateTime' :
|
|
$sortColumn = 'E.EndDateTime';
|
|
break;
|
|
case 'Length' :
|
|
$sortColumn = 'E.Length';
|
|
break;
|
|
case 'Frames' :
|
|
$sortColumn = 'E.Frames';
|
|
break;
|
|
case 'AlarmFrames' :
|
|
$sortColumn = 'E.AlarmFrames';
|
|
break;
|
|
case 'TotScore' :
|
|
$sortColumn = 'E.TotScore';
|
|
break;
|
|
case 'AvgScore' :
|
|
$sortColumn = 'E.AvgScore';
|
|
break;
|
|
case 'MaxScore' :
|
|
$sortColumn = 'E.MaxScore';
|
|
break;
|
|
case 'FramesFrameId' :
|
|
$sortColumn = 'F.FrameId';
|
|
break;
|
|
case 'FramesType' :
|
|
$sortColumn = 'F.Type';
|
|
break;
|
|
case 'FramesTimeStamp' :
|
|
$sortColumn = 'F.TimeStamp';
|
|
break;
|
|
case 'FramesDelta' :
|
|
$sortColumn = 'F.Delta';
|
|
break;
|
|
case 'FramesScore' :
|
|
$sortColumn = 'F.Score';
|
|
break;
|
|
case 'Notes' :
|
|
$sortColumn = 'E.Notes';
|
|
break;
|
|
default:
|
|
ZM\Warning("Unsupported sort field ".$_REQUEST['sort_field']);
|
|
$sortColumn = 'E.StartDateTime';
|
|
break;
|
|
}
|
|
if ( !isset($_REQUEST['sort_asc']) )
|
|
$_REQUEST['sort_asc'] = 0;
|
|
$sortOrder = $_REQUEST['sort_asc'] ? 'asc' : 'desc';
|
|
$sortQuery = $querySep.'sort_field='.validHtmlStr($_REQUEST['sort_field']).$querySep.'sort_asc='.validHtmlStr($_REQUEST['sort_asc']);
|
|
if ( !isset($_REQUEST['limit']) )
|
|
$_REQUEST['limit'] = '';
|
|
if ( $saveToSession ) {
|
|
$_SESSION['sort_field'] = validHtmlStr($_REQUEST['sort_field']);
|
|
$_SESSION['sort_asc'] = validHtmlStr($_REQUEST['sort_asc']);
|
|
}
|
|
if ($_REQUEST['limit'] != '') {
|
|
$limitQuery = '&limit='.validInt($_REQUEST['limit']);
|
|
}
|
|
}
|
|
|
|
# Historically this function has just modified the passed in filter array.
|
|
# This would normally be $_REQUEST['filter']; We don't like modifying
|
|
# request parameters. For now we will keep this behaviour, but note that we
|
|
# now return the resulting array and other code should by modified to use that.
|
|
#
|
|
# Please note that I will be removing the savetosession code as well.
|
|
function parseFilter(&$filter, $saveToSession=false, $querySep='&') {
|
|
|
|
$Filter = ZM\Filter::parse($filter, $querySep);
|
|
|
|
if (isset($filter['Id']))
|
|
$filter['Id'] = validCardinal($filter['Id']);
|
|
$filter['sql'] = $Filter->sql();
|
|
$filter['querystring'] = $Filter->querystring('filter', $querySep);
|
|
$filter['hidden_fields'] = $Filter->hidden_fields();
|
|
$filter['pre_sql_conditions'] = $Filter->pre_sql_conditions();
|
|
$filter['post_sql_conditions'] = $Filter->post_sql_conditions();
|
|
|
|
if ( $filter['sql'] )
|
|
$filter['sql'] = ' AND ( '.$filter['sql'].' )';
|
|
|
|
#if ( 0 ) {
|
|
#// ICON I feel like these should be here, but not yet
|
|
#if ( isset($filter['Query']['sort_field']) ) {
|
|
#$filter['sql'] .= ' ORDER BY ' . $filter['Query']['sort_field'] . (
|
|
#( $filter['Query']['sort_asc'] ? ' ASC' : ' DESC' ) );
|
|
#}
|
|
#}
|
|
return $filter;
|
|
} // end function parseFilter(&$filter, $saveToSession=false, $querySep='&')
|
|
|
|
// Please note that the filter is passed in by copy, so you need to use the return value from this function.
|
|
//
|
|
function addFilterTerm($filter, $position, $term=false) {
|
|
if ( $position < 0 )
|
|
$position = 0;
|
|
|
|
if ( !isset($filter['Query']['terms']) )
|
|
$filter['Query']['terms'] = array();
|
|
else if ( $position > count($filter['Query']['terms']) )
|
|
$position = count($filter['Query']['terms']);
|
|
|
|
if ( $term && $position == 0 )
|
|
unset($term['cnj']);
|
|
array_splice($filter['Query']['terms'], $position, 0, array($term ? $term : array()));
|
|
|
|
return $filter;
|
|
}
|
|
|
|
function delFilterTerm($filter, $position) {
|
|
if ( $position < 0 )
|
|
$position = 0;
|
|
else if ( $position >= count($filter['Query']['terms']) )
|
|
$position = count($filter['Query']['terms']);
|
|
array_splice($filter['Query']['terms'], $position, 1);
|
|
|
|
return $filter;
|
|
}
|
|
|
|
function getPagination($pages, $page, $maxShortcuts, $query, $querySep='&') {
|
|
global $view;
|
|
|
|
$pageText = '';
|
|
if ( $pages > 1 ) {
|
|
if ( $page ) {
|
|
if ( $page < 0 )
|
|
$page = 1;
|
|
if ( $page > $pages )
|
|
$page = $pages;
|
|
|
|
if ( $page > 1 ) {
|
|
if ( false && $page > 2 ) {
|
|
$pageText .= '<a href="?view='.$view.$querySep.'page=1'.$query.'"><<</a>';
|
|
}
|
|
$pageText .= '<a href="?view='.$view.$querySep.'page='.($page-1).$query.'"><</a>';
|
|
|
|
$newPages = array();
|
|
$pagesUsed = array();
|
|
$lo_exp = max(2,log($page-1)/log($maxShortcuts));
|
|
for ( $i = 0; $i < $maxShortcuts; $i++ ) {
|
|
$newPage = round($page-pow($lo_exp,$i));
|
|
if ( isset($pagesUsed[$newPage]) )
|
|
continue;
|
|
if ( $newPage <= 1 )
|
|
break;
|
|
$pagesUsed[$newPage] = true;
|
|
array_unshift($newPages, $newPage);
|
|
}
|
|
if ( !isset($pagesUsed[1]) )
|
|
array_unshift( $newPages, 1 );
|
|
|
|
foreach ( $newPages as $newPage ) {
|
|
$pageText .= '<a href="?view='.$view.$querySep.'page='.$newPage.$query.'">'.$newPage.'</a> ';
|
|
}
|
|
} # end if page > 1
|
|
|
|
$pageText .= '- '.$page.' -';
|
|
if ( $page < $pages ) {
|
|
$newPages = array();
|
|
$pagesUsed = array();
|
|
$hi_exp = max(2,log($pages-$page)/log($maxShortcuts));
|
|
for ( $i = 0; $i < $maxShortcuts; $i++ ) {
|
|
$newPage = round($page+pow($hi_exp,$i));
|
|
if ( isset($pagesUsed[$newPage]) )
|
|
continue;
|
|
if ( $newPage > $pages )
|
|
break;
|
|
$pagesUsed[$newPage] = true;
|
|
array_push($newPages, $newPage);
|
|
}
|
|
if ( !isset($pagesUsed[$pages]) )
|
|
array_push($newPages, $pages);
|
|
|
|
foreach ( $newPages as $newPage ) {
|
|
$pageText .= ' <a href="?view='.$view.$querySep.'page='.$newPage.$query.'">'.$newPage.'</a>';
|
|
}
|
|
$pageText .= '<a href="?view='.$view.$querySep.'page='.($page+1).$query.'">></a>';
|
|
if ( false && $page < ($pages-1) ) {
|
|
$pageText .= '<a href="?view='.$view.$querySep.'page='.$pages.$query.'">>></a>';
|
|
}
|
|
} # end if $page < $pages
|
|
}
|
|
}
|
|
return $pageText;
|
|
}
|
|
|
|
function sortHeader($field, $querySep='&') {
|
|
global $view;
|
|
return implode($querySep, array(
|
|
'?view='.$view,
|
|
'page=1'.((isset($_REQUEST['filter']) and isset($_REQUEST['filter']['query'])) ? $_REQUEST['filter']['query'] : ''),
|
|
'sort_field='.$field,
|
|
'sort_asc='.( ( isset($_REQUEST['sort_field']) and ( $_REQUEST['sort_field'] == $field ) ) ? !validInt($_REQUEST['sort_asc']) : 0),
|
|
'limit='.(isset($_REQUEST['limit']) ? validInt($_REQUEST['limit']) : ''),
|
|
(isset($_REQUEST['eid']) ? 'eid='.validCardinal($_REQUEST['eid']) : '' ),
|
|
));
|
|
}
|
|
|
|
function sortTag($field) {
|
|
if ( isset($_REQUEST['sort_field']) ) {
|
|
if ( $_REQUEST['sort_field'] == $field )
|
|
if ( $_REQUEST['sort_asc'] )
|
|
return '(^)';
|
|
else
|
|
return '(v)';
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function getLoad() {
|
|
$load = sys_getloadavg();
|
|
return $load[0];
|
|
}
|
|
|
|
function getDiskPercent($path = ZM_DIR_EVENTS) {
|
|
$total = disk_total_space($path);
|
|
if ( $total === false ) {
|
|
ZM\Error('disk_total_space returned false. Verify the web account user has access to ' . $path);
|
|
return 0;
|
|
} elseif ( $total == 0 ) {
|
|
ZM\Error('disk_total_space indicates the following path has a filesystem size of zero bytes ' . $path);
|
|
return 100;
|
|
}
|
|
$free = disk_free_space($path);
|
|
if ( $free === false ) {
|
|
ZM\Error('disk_free_space returned false. Verify the web account user has access to ' . $path);
|
|
}
|
|
$space = round((($total - $free) / $total) * 100);
|
|
return $space;
|
|
}
|
|
|
|
function getDiskBlocks($path = ZM_DIR_EVENTS) {
|
|
$df = shell_exec('df '.escapeshellarg($path));
|
|
$space = -1;
|
|
if ( preg_match('/\s(\d+)\s+\d+\s+\d+%/ms', $df, $matches) )
|
|
$space = $matches[1];
|
|
return $space;
|
|
}
|
|
|
|
function systemStats() {
|
|
$load = getLoad();
|
|
$diskPercent = getDiskPercent();
|
|
$pathMapPercent = getDiskPercent(ZM_PATH_MAP);
|
|
$cpus = getcpus();
|
|
|
|
$normalized_load = $load / $cpus;
|
|
|
|
# Colorize the system load stat
|
|
if ( $normalized_load <= 0.75 ) {
|
|
$htmlLoad = $load;
|
|
} else if ( $normalized_load <= 0.9 ) {
|
|
$htmlLoad = '<span class="warning">'.$load.'</span>';
|
|
} else if ( $normalized_load <= 1.1 ) {
|
|
$htmlLoad = '<span class="error">'.$load.'</span>';
|
|
} else {
|
|
$htmlLoad = '<span class="critical">'.$load.'</span>';
|
|
}
|
|
|
|
# Colorize the disk space stat
|
|
if ( $diskPercent < 98 ) {
|
|
$htmlDiskPercent = $diskPercent.'%';
|
|
} else if ( $diskPercent <= 99 ) {
|
|
$htmlDiskPercent = '<span class="warning">'.$diskPercent.'%</span>';
|
|
} else {
|
|
$htmlDiskPercent = '<span class="error">'.$diskPercent.'%</span>';
|
|
}
|
|
|
|
# Colorize the PATH_MAP (usually /dev/shm) stat
|
|
if ( $pathMapPercent < 90 ) {
|
|
if ( disk_free_space(ZM_PATH_MAP) > 209715200 ) { # have to always have at least 200MiB free
|
|
$htmlPathMapPercent = $pathMapPercent.'%';
|
|
} else {
|
|
$htmlPathMapPercent = '<span class="warning">'.$pathMapPercent.'%</span>';
|
|
}
|
|
} else if ( $pathMapPercent < 100 ) {
|
|
$htmlPathMapPercent = '<span class="warning">'.$pathMapPercent.'%</span>';
|
|
} else {
|
|
$htmlPathMapPercent = '<span class="critical">'.$pathMapPercent.'%</span>';
|
|
}
|
|
|
|
$htmlString = translate('Load').': '.$htmlLoad.' - '.translate('Disk').': '.$htmlDiskPercent.' - '.ZM_PATH_MAP.': '.$htmlPathMapPercent;
|
|
|
|
return $htmlString;
|
|
}
|
|
|
|
function getcpus() {
|
|
if ( is_readable('/proc/cpuinfo') ) { # Works on Linux
|
|
preg_match_all('/^processor/m', file_get_contents('/proc/cpuinfo'), $matches);
|
|
$num_cpus = count($matches[0]);
|
|
} else { # Works on BSD
|
|
$matches = explode(':', shell_exec('sysctl hw.ncpu'));
|
|
$num_cpus = trim($matches[1]);
|
|
}
|
|
|
|
return $num_cpus;
|
|
}
|
|
|
|
// Function to fix a problem whereby the built in PHP session handling
|
|
// features want to put the sid as a hidden field after the form or
|
|
// fieldset tag, neither of which will work with strict XHTML Basic.
|
|
function sidField() {
|
|
if ( SID ) {
|
|
list($sessname, $sessid) = explode('=', SID);
|
|
?>
|
|
<input type="hidden" name="<?php echo $sessname ?>" value="<?php echo $sessid ?>"/>
|
|
<?php
|
|
}
|
|
}
|
|
|
|
function verNum($version) {
|
|
$vNum = '';
|
|
$maxFields = 3;
|
|
$vFields = explode('.', $version);
|
|
array_splice($vFields, $maxFields);
|
|
while ( count($vFields) < $maxFields ) {
|
|
$vFields[] = 0;
|
|
}
|
|
foreach ( $vFields as $vField ) {
|
|
$vField = sprintf('%02d', $vField);
|
|
while ( strlen($vField) < 2 ) {
|
|
$vField = '0'.$vField;
|
|
}
|
|
$vNum .= $vField;
|
|
}
|
|
return $vNum;
|
|
}
|
|
|
|
function fixSequences() {
|
|
$sequence = 1;
|
|
$sql = 'SELECT * FROM Monitors ORDER BY Sequence ASC, Id ASC';
|
|
foreach (dbFetchAll($sql) as $monitor) {
|
|
if ($monitor['Sequence'] != $sequence) {
|
|
dbQuery('UPDATE Monitors SET Sequence=? WHERE Id=?', array($sequence, $monitor['Id']));
|
|
}
|
|
$sequence++;
|
|
}
|
|
}
|
|
|
|
function firstSet() {
|
|
foreach (func_get_args() as $arg) {
|
|
if (!empty($arg))
|
|
return $arg;
|
|
}
|
|
}
|
|
|
|
function linesIntersect($line1, $line2) {
|
|
global $debug;
|
|
|
|
$min_x1 = min($line1[0]['x'], $line1[1]['x']);
|
|
$max_x1 = max($line1[0]['x'], $line1[1]['x']);
|
|
$min_x2 = min($line2[0]['x'], $line2[1]['x']);
|
|
$max_x2 = max($line2[0]['x'], $line2[1]['x']);
|
|
$min_y1 = min($line1[0]['y'], $line1[1]['y']);
|
|
$max_y1 = max($line1[0]['y'], $line1[1]['y']);
|
|
$min_y2 = min($line2[0]['y'], $line2[1]['y']);
|
|
$max_y2 = max($line2[0]['y'], $line2[1]['y']);
|
|
|
|
// Checking if bounding boxes intersect
|
|
if ( $max_x1 < $min_x2 || $max_x2 < $min_x1 ||$max_y1 < $min_y2 || $max_y2 < $min_y1 ) {
|
|
if ( $debug ) echo 'Not intersecting, out of bounds<br>';
|
|
return false;
|
|
}
|
|
|
|
$dx1 = $line1[1]['x'] - $line1[0]['x'];
|
|
$dy1 = $line1[1]['y'] - $line1[0]['y'];
|
|
$dx2 = $line2[1]['x'] - $line2[0]['x'];
|
|
$dy2 = $line2[1]['y'] - $line2[0]['y'];
|
|
|
|
if ( $dx1 ) {
|
|
$m1 = $dy1/$dx1;
|
|
$b1 = $line1[0]['y'] - ($m1 * $line1[0]['x']);
|
|
} else {
|
|
$b1 = $line1[0]['y'];
|
|
}
|
|
if ( $dx2 ) {
|
|
$m2 = $dy2/$dx2;
|
|
$b2 = $line2[0]['y'] - ($m2 * $line2[0]['x']);
|
|
} else {
|
|
$b2 = $line2[0]['y'];
|
|
}
|
|
|
|
if ( $dx1 && $dx2 ) { // Both not vertical
|
|
if ( $m1 != $m2 ) { // Not parallel or colinear
|
|
$x = ( $b2 - $b1 ) / ( $m1 - $m2 );
|
|
|
|
if ( $x >= $min_x1 && $x <= $max_x1 && $x >= $min_x2 && $x <= $max_x2 ) {
|
|
if ( $debug ) echo "Intersecting, at x $x<br>";
|
|
return true;
|
|
} else {
|
|
if ( $debug ) echo "Not intersecting, out of range at x $x<br>";
|
|
return false;
|
|
}
|
|
} elseif ( $b1 == $b2 ) {
|
|
// Colinear, must overlap due to box check, intersect?
|
|
if ( $debug ) echo 'Intersecting, colinear<br>';
|
|
return true;
|
|
} else {
|
|
// Parallel
|
|
if ( $debug ) echo 'Not intersecting, parallel<br>';
|
|
return false;
|
|
}
|
|
} elseif ( !$dx1 ) { // Line 1 is vertical
|
|
$y = ( $m2 * $line1[0]['x'] ) * $b2;
|
|
if ( $y >= $min_y1 && $y <= $max_y1 ) {
|
|
if ( $debug ) echo "Intersecting, at y $y<br>";
|
|
return true;
|
|
} else {
|
|
if ( $debug ) echo "Not intersecting, out of range at y $y<br>";
|
|
return false;
|
|
}
|
|
} elseif ( !$dx2 ) { // Line 2 is vertical
|
|
$y = ( $m1 * $line2[0]['x'] ) * $b1;
|
|
if ( $y >= $min_y2 && $y <= $max_y2 ) {
|
|
if ( $debug ) echo "Intersecting, at y $y<br>";
|
|
return true;
|
|
} else {
|
|
if ( $debug ) echo "Not intersecting, out of range at y $y<br>";
|
|
return false;
|
|
}
|
|
} else { // Both lines are vertical
|
|
if ( $line1[0]['x'] == $line2[0]['x'] ) {
|
|
// Colinear, must overlap due to box check, intersect?
|
|
if ( $debug ) echo 'Intersecting, vertical, colinear<br>';
|
|
return true;
|
|
} else {
|
|
// Parallel
|
|
if ( $debug ) echo 'Not intersecting, vertical, parallel<br>';
|
|
return false;
|
|
}
|
|
}
|
|
if ( $debug ) echo 'Whoops, unexpected scenario<br>';
|
|
return false;
|
|
}
|
|
|
|
function isSelfIntersecting($points) {
|
|
global $debug;
|
|
|
|
$n_coords = count($points);
|
|
$edges = array();
|
|
for ( $j = 0, $i = $n_coords-1; $j < $n_coords; $i = $j++ ) {
|
|
$edges[] = array( $points[$i], $points[$j] );
|
|
}
|
|
|
|
for ( $i = 0; $i <= ($n_coords-2); $i++ ) {
|
|
for ( $j = $i+2; $j < $n_coords+min(0,$i-1); $j++ ) {
|
|
if ( $debug ) echo "Checking $i and $j<br>";
|
|
if ( linesIntersect($edges[$i], $edges[$j]) ) {
|
|
if ( $debug ) echo "Lines $i and $j intersect<br>";
|
|
return true;
|
|
}
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function getPolyCentre($points, $area=0) {
|
|
$cx = 0.0;
|
|
$cy = 0.0;
|
|
if ( !$area )
|
|
$area = getPolyArea($points);
|
|
for ( $i = 0, $j = count($points)-1; $i < count($points); $j = $i++ ) {
|
|
$ct = ($points[$i]['x'] * $points[$j]['y']) - ($points[$j]['x'] * $points[$i]['y']);
|
|
$cx += ($points[$i]['x'] + $points[$j]['x']) * $ct;
|
|
$cy += ($points[$i]['y'] + $points[$j]['y']) * $ct;
|
|
}
|
|
$cx = intval(round(abs($cx/(6.0*$area))));
|
|
$cy = intval(round(abs($cy/(6.0*$area))));
|
|
return array('x'=>$cx, 'y'=>$cy);
|
|
}
|
|
|
|
function _CompareXY($a, $b) {
|
|
if ( $a['min_y'] == $b['min_y'] )
|
|
return intval($a['min_x'] - $b['min_x']);
|
|
else
|
|
return intval($a['min_y'] - $b['min_y']);
|
|
}
|
|
|
|
function _CompareX($a, $b) {
|
|
return intval($a['min_x'] - $b['min_x']);
|
|
}
|
|
|
|
function getPolyArea($points) {
|
|
// Shoelace formula - works correctly with both integer and float coordinates
|
|
$n = count($points);
|
|
$area = 0.0;
|
|
for ($i = 0; $i < $n - 1; $i++) {
|
|
$area += ((float)$points[$i]['x'] * (float)$points[$i+1]['y']
|
|
- (float)$points[$i+1]['x'] * (float)$points[$i]['y']);
|
|
}
|
|
$area += ((float)$points[$n-1]['x'] * (float)$points[0]['y']
|
|
- (float)$points[0]['x'] * (float)$points[$n-1]['y']);
|
|
return round(abs($area) / 2.0);
|
|
}
|
|
|
|
function getPolyAreaOld($points) {
|
|
$area = 0.0;
|
|
$edge = 0.0;
|
|
for ( $i = 0, $j = count($points)-1; $i < count($points); $j = $i++ ) {
|
|
$x_diff = ($points[$i]['x'] - $points[$j]['x']);
|
|
$y_diff = ($points[$i]['y'] - $points[$j]['y']);
|
|
$y_sum = ($points[$i]['y'] + $points[$j]['y']);
|
|
$trap_edge = sqrt(pow(abs($x_diff)+1,2) + pow(abs($y_diff)+1,2) );
|
|
$edge += $trap_edge;
|
|
$trap_area = ($x_diff * $y_sum );
|
|
$area += $trap_area;
|
|
printf('%d->%d, %d-%d=%.2f, %d+%d=%.2f(%.2f), %.2f, %.2f<br>',
|
|
$i, $j,
|
|
$points[$i]['x'], $points[$j]['x'],
|
|
$x_diff,
|
|
$points[$i]['y'], $points[$j]['y'],
|
|
$y_sum, $y_diff, $trap_area, $trap_edge);
|
|
}
|
|
$edge = intval(round(abs($edge)));
|
|
$area = intval(round((abs($area)+$edge)/2));
|
|
echo "E:$edge<br>";
|
|
echo "A:$area<br>";
|
|
return $area;
|
|
}
|
|
|
|
function mapCoords($a) {
|
|
return number_format((float)$a['x'], 2, '.', '').','.number_format((float)$a['y'], 2, '.', '');
|
|
}
|
|
|
|
function pointsToCoords($points) {
|
|
return join(' ', array_map('mapCoords', $points));
|
|
}
|
|
|
|
function coordsToPoints($coords) {
|
|
$points = array();
|
|
if ( preg_match_all('/([\d.]+,[\d.]+)+/', $coords, $matches) ) {
|
|
for ( $i = 0; $i < count($matches[1]); $i++ ) {
|
|
if ( preg_match('/([\d.]+),([\d.]+)/', $matches[1][$i], $cmatches) ) {
|
|
$points[] = array('x'=>(float)$cmatches[1], 'y'=>(float)$cmatches[2]);
|
|
} else {
|
|
echo('Bogus coordinates ('.$matches[$i].')');
|
|
return false;
|
|
}
|
|
}
|
|
} else {
|
|
echo('Bogus coordinate string '.$coords);
|
|
return false;
|
|
}
|
|
return $points;
|
|
}
|
|
|
|
function limitPoints(&$points, $min_x, $min_y, $max_x, $max_y) {
|
|
foreach ( $points as &$point ) {
|
|
if ( $point['x'] < $min_x ) {
|
|
ZM\Debug('Limiting point x'.$point['x'].' to min_x '.$min_x);
|
|
$point['x'] = $min_x;
|
|
} else if ( $point['x'] > $max_x ) {
|
|
ZM\Debug('Limiting point x'.$point['x'].' to max_x '.$max_x);
|
|
$point['x'] = $max_x;
|
|
}
|
|
if ( $point['y'] < $min_y ) {
|
|
ZM\Debug('Limiting point y'.$point['y'].' to min_y '.$min_y);
|
|
$point['y'] = $min_y;
|
|
} else if ( $point['y'] > $max_y ) {
|
|
ZM\Debug('Limiting point y'.$point['y'].' to max_y '.$max_y);
|
|
$point['y'] = $max_y;
|
|
}
|
|
} // end foreach point
|
|
} // end function limitPoints( $points, $min_x, $min_y, $max_x, $max_y )
|
|
|
|
function convertPixelPointsToPercent(&$points, $width, $height) {
|
|
if (!$width || !$height) return false;
|
|
$isPixel = false;
|
|
foreach ($points as $point) {
|
|
if ($point['x'] > 100 || $point['y'] > 100) {
|
|
$isPixel = true;
|
|
break;
|
|
}
|
|
}
|
|
if ($isPixel) {
|
|
foreach ($points as &$point) {
|
|
$point['x'] = round($point['x'] / $width * 100, 2);
|
|
$point['y'] = round($point['y'] / $height * 100, 2);
|
|
}
|
|
unset($point);
|
|
}
|
|
return $isPixel;
|
|
}
|
|
|
|
function scalePoints(&$points, $scale) {
|
|
foreach ( $points as &$point ) {
|
|
$point['x'] = reScale($point['x'], $scale);
|
|
$point['y'] = reScale($point['y'], $scale);
|
|
}
|
|
}
|
|
|
|
function getLanguages() {
|
|
$langs = array();
|
|
foreach ( glob('lang/*_*.php') as $file ) {
|
|
preg_match('/([^\/]+_.+)\.php/', $file, $matches);
|
|
$langs[$matches[1]] = $matches[1];
|
|
}
|
|
return $langs;
|
|
}
|
|
|
|
function trimString($string, $length) {
|
|
return preg_replace('/^(.{'.$length.',}?)\b.*$/', '\\1…', $string);
|
|
}
|
|
|
|
function monitorIdsToNames($ids) {
|
|
global $mITN_monitors;
|
|
if ( !$mITN_monitors ) {
|
|
$sql = 'SELECT Id, Name FROM Monitors WHERE `Deleted`=false';
|
|
foreach ( dbFetchAll($sql) as $monitor ) {
|
|
$mITN_monitors[$monitor['Id']] = $monitor;
|
|
}
|
|
}
|
|
$names = array();
|
|
if ( ! is_array($ids) ) {
|
|
$ids = preg_split('/\s*,\s*/', $ids);
|
|
}
|
|
foreach ( $ids as $id ) {
|
|
if ( visibleMonitor($id) ) {
|
|
if ( isset($mITN_monitors[$id]) ) {
|
|
$names[] = $mITN_monitors[$id]['Name'];
|
|
}
|
|
}
|
|
}
|
|
$name_string = join(', ', $names);
|
|
return $name_string;
|
|
}
|
|
|
|
function initX10Status() {
|
|
global $x10_status;
|
|
|
|
if ( !isset($x10_status) ) {
|
|
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
|
|
if ( $socket < 0 ) {
|
|
ZM\Fatal('socket_create() failed: '.socket_strerror($socket));
|
|
}
|
|
$sock_file = ZM_PATH_SOCKS.'/zmx10.sock';
|
|
if ( @socket_connect($socket, $sock_file) ) {
|
|
$command = 'status';
|
|
if ( !socket_write($socket, $command) ) {
|
|
ZM\Fatal('Can\'t write to control socket: '.socket_strerror(socket_last_error($socket)));
|
|
}
|
|
socket_shutdown($socket, 1);
|
|
$x10Output = '';
|
|
while ( $x10Response = socket_read($socket, 256) ) {
|
|
$x10Output .= $x10Response;
|
|
}
|
|
socket_close($socket);
|
|
} else {
|
|
// Can't connect so use script
|
|
$command = ZM_PATH_BIN.'/zmx10.pl --command status';
|
|
//$command .= " 2>/dev/null >&- <&- >/dev/null";
|
|
|
|
$x10Output = exec(escapeshellcmd($command));
|
|
}
|
|
foreach ( explode("\n", $x10Output) as $x10Response ) {
|
|
if ( preg_match('/^(\d+)\s+(.+)$/', $x10Response, $matches) ) {
|
|
$x10_status[$matches[1]] = $matches[2];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
function getDeviceStatusX10($key) {
|
|
global $x10_status;
|
|
|
|
initX10Status();
|
|
|
|
if ( empty($x10_status[$key]) || !($status = $x10_status[$key]) )
|
|
$status = 'unknown';
|
|
return $status;
|
|
}
|
|
|
|
function setDeviceStatusX10($key, $status) {
|
|
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
|
|
if ( $socket < 0 ) {
|
|
ZM\Fatal('socket_create() failed: '.socket_strerror($socket));
|
|
}
|
|
$sock_file = ZM_PATH_SOCKS.'/zmx10.sock';
|
|
if ( @socket_connect($socket, $sock_file) ) {
|
|
$command = "$status;$key";
|
|
if ( !socket_write($socket, $command) ) {
|
|
ZM\Fatal('Can\'t write to control socket: '.socket_strerror(socket_last_error($socket)));
|
|
}
|
|
socket_shutdown($socket, 1);
|
|
$x10Response = socket_read($socket, 256);
|
|
socket_close($socket);
|
|
} else {
|
|
// Can't connect so use script
|
|
$command = ZM_PATH_BIN.'/zmx10.pl --command '.escapeshellarg($status);
|
|
$command .= ' --unit-code '.escapeshellarg( $key );
|
|
//$command .= " 2>/dev/null >&- <&- >/dev/null";
|
|
$x10Response = exec($command);
|
|
}
|
|
if ( preg_match('/^'.$key.'\s+(.*)/', $x10Response, $matches) )
|
|
$status = $matches[1];
|
|
else
|
|
$status = 'unknown';
|
|
return $status;
|
|
}
|
|
|
|
function logState() {
|
|
$state = 'ok';
|
|
|
|
$levelCounts = array(
|
|
ZM\Logger::FATAL => array( ZM_LOG_ALERT_FAT_COUNT, ZM_LOG_ALARM_FAT_COUNT ),
|
|
ZM\Logger::ERROR => array( ZM_LOG_ALERT_ERR_COUNT, ZM_LOG_ALARM_ERR_COUNT ),
|
|
ZM\Logger::WARNING => array( ZM_LOG_ALERT_WAR_COUNT, ZM_LOG_ALARM_WAR_COUNT ),
|
|
);
|
|
|
|
# This is an expensive request, as it has to hit every row of the Logs Table
|
|
$sql = 'SELECT Level, COUNT(Level) AS LevelCount FROM Logs WHERE Level < '.ZM\Logger::INFO.' AND TimeKey > unix_timestamp(now() - interval '.ZM_LOG_CHECK_PERIOD.' second) GROUP BY Level ORDER BY Level ASC';
|
|
$counts = dbFetchAll($sql);
|
|
if ( $counts ) {
|
|
foreach ( $counts as $count ) {
|
|
if ( $count['Level'] <= ZM\Logger::PANIC )
|
|
$count['Level'] = ZM\Logger::FATAL;
|
|
if ( !($levelCount = $levelCounts[$count['Level']]) ) {
|
|
ZM\Error('Unexpected Log level '.$count['Level']);
|
|
next;
|
|
}
|
|
if ( $levelCount[1] && $count['LevelCount'] >= $levelCount[1] ) {
|
|
$state = 'alarm';
|
|
break;
|
|
} elseif ( $levelCount[0] && $count['LevelCount'] >= $levelCount[0] ) {
|
|
$state = 'alert';
|
|
}
|
|
}
|
|
}
|
|
return $state;
|
|
}
|
|
|
|
function isVector(&$array) {
|
|
$next_key = 0;
|
|
foreach ( array_keys($array) as $key ) {
|
|
if ( !is_int($key) )
|
|
return false;
|
|
if ( $key != $next_key++ )
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function checkJsonError($value) {
|
|
if ( function_exists('json_last_error') ) {
|
|
$value = var_export($value, true);
|
|
switch ( json_last_error() ) {
|
|
case JSON_ERROR_DEPTH :
|
|
ZM\Error("Unable to decode JSON string '$value', maximum stack depth exceeded");
|
|
$backTrace = debug_backtrace();
|
|
ZM\Debug($message.' from '.print_r($backTrace, true));
|
|
break;
|
|
case JSON_ERROR_CTRL_CHAR :
|
|
ZM\Error("Unable to decode JSON string '$value', unexpected control character found");
|
|
$backTrace = debug_backtrace();
|
|
ZM\Debug($message.' from '.print_r($backTrace, true));
|
|
break;
|
|
case JSON_ERROR_STATE_MISMATCH :
|
|
ZM\Error("Unable to decode JSON string '$value', invalid or malformed JSON");
|
|
$backTrace = debug_backtrace();
|
|
ZM\Debug($message.' from '.print_r($backTrace, true));
|
|
break;
|
|
case JSON_ERROR_SYNTAX :
|
|
ZM\Error("Unable to decode JSON string '$value', syntax error");
|
|
$backTrace = debug_backtrace();
|
|
ZM\Debug($message.' from '.print_r($backTrace, true));
|
|
break;
|
|
default :
|
|
ZM\Error("Unable to decode JSON string '$value', unexpected error ".json_last_error());
|
|
$backTrace = debug_backtrace();
|
|
ZM\Debug($message.' from '.print_r($backTrace, true));
|
|
break;
|
|
case JSON_ERROR_NONE:
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
function jsonEncode(&$value) {
|
|
if ( function_exists('json_encode') ) {
|
|
$string = json_encode( $value );
|
|
checkJsonError($value);
|
|
return $string;
|
|
}
|
|
|
|
switch ( gettype($value) ) {
|
|
case 'double':
|
|
case 'integer':
|
|
return $value;
|
|
case 'boolean':
|
|
return $value ? 'true' : 'false';
|
|
case 'string':
|
|
return '"'.preg_replace("/\r?\n/", '\\n', addcslashes($value,'"\\/')).'"';
|
|
case 'NULL':
|
|
return 'null';
|
|
case 'object':
|
|
return '"Object '.addcslashes(get_class($value),'"\\/').'"';
|
|
case 'array':
|
|
if ( isVector( $value ) )
|
|
return '['.join(',', array_map('jsonEncode', $value)).']';
|
|
else {
|
|
$result = '{';
|
|
foreach ($value as $subkey => $subvalue ) {
|
|
if ( $result != '{' )
|
|
$result .= ',';
|
|
$result .= '"'.$subkey.'":'.jsonEncode($subvalue);
|
|
}
|
|
return $result.'}';
|
|
}
|
|
default:
|
|
return '"'.addcslashes(gettype($value),'"\\/').'"';
|
|
}
|
|
}
|
|
|
|
function jsonDecode($value) {
|
|
if ( function_exists('json_decode') ) {
|
|
$object = json_decode($value, true);
|
|
checkJsonError($value);
|
|
return $object;
|
|
}
|
|
|
|
$comment = false;
|
|
$unescape = false;
|
|
$out = '$result=';
|
|
for ( $i = 0; $i < strlen($value); $i++ ) {
|
|
if ( !$comment ) {
|
|
if ( ($value[$i] == '{') || ($value[$i] == '[') ) {
|
|
$out .= ' array(';
|
|
} else if ( ($value[$i] == '}') || ($value[$i] == ']') ) {
|
|
$out .= ')';
|
|
} else if ( $value[$i] == ':' ) {
|
|
$out .= '=>';
|
|
} else {
|
|
$out .= $value[$i];
|
|
}
|
|
} else if ( !$unescape ) {
|
|
if ( $value[$i] == '\\' )
|
|
$unescape = true;
|
|
else
|
|
$out .= $value[$i];
|
|
} else {
|
|
if ( $value[$i] != '/' )
|
|
$out .= '\\';
|
|
$out .= $value[$i];
|
|
$unescape = false;
|
|
}
|
|
if ( $value[$i] == '"' ) {
|
|
$comment = !$comment;
|
|
}
|
|
}
|
|
eval($out.';');
|
|
return $result;
|
|
}
|
|
|
|
define('HTTP_STATUS_OK', 200);
|
|
define('HTTP_STATUS_BAD_REQUEST', 400);
|
|
define('HTTP_STATUS_FORBIDDEN', 403);
|
|
|
|
function ajaxError($message, $code=HTTP_STATUS_OK) {
|
|
$backTrace = debug_backtrace();
|
|
ZM\Debug($message.' from '.print_r($backTrace, true));
|
|
if ( function_exists('ajaxCleanup') )
|
|
ajaxCleanup();
|
|
if ( $code == HTTP_STATUS_OK ) {
|
|
$response = array('result'=>'Error', 'message'=>$message);
|
|
header('Content-type: application/json');
|
|
exit(jsonEncode($response));
|
|
}
|
|
header("HTTP/1.0 $code $message");
|
|
exit();
|
|
}
|
|
|
|
function ajaxResponse($result=false) {
|
|
if ( function_exists('ajaxCleanup') )
|
|
ajaxCleanup();
|
|
$response = array('result'=>'Ok');
|
|
if ( is_array($result) ) {
|
|
$response = array_merge($response, $result);
|
|
} else if ( !empty($result) ) {
|
|
$response['message'] = $result;
|
|
}
|
|
header('Content-type: application/json');
|
|
exit(jsonEncode($response));
|
|
}
|
|
|
|
function generateConnKey() {
|
|
return rand(1, 999999);
|
|
}
|
|
|
|
function detaintPathAllowAbsolute($path) {
|
|
// Strip out :// because php:// is a way to inject code apparently
|
|
$path = str_replace('://', '', $path);
|
|
// Remove any absolute paths, or relative ones that want to go up
|
|
do {
|
|
$path = str_replace('../', '', $path, $count);
|
|
} while($count);
|
|
return $path;
|
|
}
|
|
|
|
function detaintPath($path) {
|
|
|
|
// Strip out :// because php:// is a way to inject code apparently
|
|
$path = str_replace('://', '', $path);
|
|
// Remove any absolute paths, or relative ones that want to go up
|
|
do {
|
|
$path = str_replace('../', '', $path, $count);
|
|
} while($count);
|
|
$path = ltrim($path, '/');
|
|
return $path;
|
|
}
|
|
|
|
function cache_bust($file) {
|
|
# Use the last modified timestamp to create a link that gets a different filename
|
|
# To defeat caching. Should probably use md5 hash
|
|
$parts = pathinfo($file);
|
|
global $css;
|
|
$dirname = str_replace('/', '_', $parts['dirname']);
|
|
$cacheFile = $dirname.'_'.$parts['filename'].'-'.$css.'-'.filemtime($file).'.'.$parts['extension'];
|
|
if (
|
|
@symlink(ZM_PATH_WEB.'/'.$file, ZM_DIR_CACHE.'/'.$cacheFile)
|
|
or
|
|
file_exists(ZM_DIR_CACHE.'/'.$cacheFile)
|
|
) {
|
|
return 'cache/'.$cacheFile;
|
|
} else {
|
|
ZM\Warning('Failed linking '.$file.' to '.$cacheFile);
|
|
}
|
|
return $file;
|
|
}
|
|
|
|
function getSkinFile($file) {
|
|
global $skinBase;
|
|
$skinFile = false;
|
|
foreach ( $skinBase as $skin ) {
|
|
$tempSkinFile = detaintPath('skins/'.$skin.'/'.$file);
|
|
if ( file_exists($tempSkinFile) )
|
|
$skinFile = $tempSkinFile;
|
|
}
|
|
return $skinFile;
|
|
}
|
|
|
|
function getSkinIncludes($file, $includeBase=false, $asOverride=false) {
|
|
global $skinBase;
|
|
$skinFile = false;
|
|
foreach ( $skinBase as $skin ) {
|
|
$tempSkinFile = detaintPath('skins/'.$skin.'/'.$file);
|
|
if ( file_exists($tempSkinFile) )
|
|
$skinFile = $tempSkinFile;
|
|
}
|
|
$includeFiles = array();
|
|
if ( $asOverride ) {
|
|
if ( $skinFile )
|
|
$includeFiles[] = $skinFile;
|
|
else if ( $includeBase )
|
|
$includeFiles[] = $file;
|
|
} else {
|
|
if ( $includeBase )
|
|
$includeFiles[] = $file;
|
|
if ( $skinFile )
|
|
$includeFiles[] = $skinFile;
|
|
}
|
|
return $includeFiles;
|
|
}
|
|
|
|
function requestVar($name, $default='') {
|
|
return isset($_REQUEST[$name]) ? validHtmlStr($_REQUEST[$name]) : $default;
|
|
}
|
|
|
|
// For numbers etc in javascript or tags etc
|
|
function validInt($input) {
|
|
return preg_replace('/[^\-\d]/', '', $input);
|
|
}
|
|
|
|
function validCardinal($input) {
|
|
return preg_replace('/\D/', '', $input);
|
|
}
|
|
|
|
function validNum( $input ) {
|
|
return preg_replace('/[^\d.-]/', '', $input);
|
|
}
|
|
|
|
// For device path strings - must be a valid Unix device path
|
|
function validDevicePath($input) {
|
|
if (is_null($input) || $input === '') return '';
|
|
// Only allow typical device paths: /dev/video0, /dev/v4l/by-id/..., etc.
|
|
// Reject any shell metacharacters
|
|
if (!preg_match('#^/dev/[\w/.\-]+$#', $input)) {
|
|
ZM\Warning("Invalid device path rejected: ".validHtmlStr($input));
|
|
return '';
|
|
}
|
|
return $input;
|
|
}
|
|
|
|
// For general strings
|
|
function validStr($input) {
|
|
if (is_null($input)) return '';
|
|
return strip_tags($input);
|
|
}
|
|
|
|
// For strings in javascript or tags etc, expected to be in quotes so further quotes escaped rather than converted
|
|
function validJsStr($input) {
|
|
if (is_null($input)) return '';
|
|
return strip_tags(addslashes($input));
|
|
}
|
|
|
|
// For general text in pages outside of tags or quotes so quotes converted to entities
|
|
function validHtmlStr($input) {
|
|
if (is_null($input)) return '';
|
|
return htmlspecialchars($input, ENT_QUOTES);
|
|
}
|
|
|
|
/* options['width'] is the desired view width not necessarily the image width requested.
|
|
* It can be % in which case we us it to set the scale
|
|
* It can be px in which case we can use it to calculate the scale
|
|
* Same width height. If both are set we should calculate the smaller resulting scale
|
|
*/
|
|
function getStreamHTML($monitor, $options = array()) {
|
|
return $monitor->getStreamHTML($options);
|
|
} // end function getStreamHTML
|
|
|
|
function getStreamMode( ) {
|
|
$streamMode = '';
|
|
if ( (ZM_WEB_STREAM_METHOD == 'mpeg') && ZM_MPEG_LIVE_FORMAT ) {
|
|
$streamMode = 'mpeg';
|
|
} elseif ( canStream() ) {
|
|
$streamMode = 'jpeg';
|
|
} else {
|
|
$streamMode = 'single';
|
|
ZM\Info('The system has fallen back to single jpeg mode for streaming. Consider enabling Cambozola or upgrading the client browser.');
|
|
}
|
|
return $streamMode;
|
|
} // end function getStreamMode
|
|
|
|
function folder_size($dir) {
|
|
$size = 0;
|
|
foreach (glob(rtrim($dir, '/').'/*', GLOB_NOSORT) as $each) {
|
|
$size += is_file($each) ? filesize($each) : folder_size($each);
|
|
}
|
|
return $size;
|
|
} // end function folder_size
|
|
|
|
function human_filesize($size, $precision = 2) {
|
|
if ($size === null) {
|
|
return 'null';
|
|
}
|
|
$units = array('B ','kB','MB','GB','TB','PB','EB','ZB','YB');
|
|
$step = 1024;
|
|
$i = 0;
|
|
while (($size / $step) > 0.9) {
|
|
$size = $size / $step;
|
|
$i++;
|
|
}
|
|
# The idea is that we can right align this and have the digits columns line up nicely.
|
|
return sprintf('%.'.$precision.'f', round($size, $precision)).$units[$i];
|
|
}
|
|
|
|
function csrf_startup() {
|
|
csrf_conf('rewrite-js', 'includes/csrf/csrf-magic.js');
|
|
}
|
|
|
|
function check_timezone() {
|
|
$now = new DateTime();
|
|
|
|
$sys_tzoffset = trim(shell_exec('date "+%z"'));
|
|
$php_tzoffset = trim($now->format('O'));
|
|
$mysql_tzoffset = trim(dbFetchOne(
|
|
'SELECT TIME_FORMAT(TIMEDIFF(NOW(), UTC_TIMESTAMP),\'%H%i\');',
|
|
'TIME_FORMAT(TIMEDIFF(NOW(), UTC_TIMESTAMP),\'%H%i\')'
|
|
));
|
|
|
|
#Debug("System timezone offset determine to be: $sys_tzoffset,\x20
|
|
#PHP timezone offset determine to be: $php_tzoffset,\x20
|
|
#Mysql timezone offset determine to be: $mysql_tzoffset
|
|
#");
|
|
|
|
if ( $sys_tzoffset != $php_tzoffset )
|
|
ZM\Error("ZoneMinder is not configured properly: php's date.timezone $php_tzoffset does not match the system timezone $sys_tzoffset! Please check Options->System->Timezone.");
|
|
|
|
if ( $sys_tzoffset != $mysql_tzoffset )
|
|
ZM\Error('ZoneMinder is not configured properly: mysql\'s timezone does not match the system timezone! Event lists will display incorrect times.');
|
|
|
|
if (!ini_get('date.timezone') || !date_default_timezone_set(ini_get('date.timezone')))
|
|
ZM\Error('ZoneMinder is not configured properly: php\'s date.timezone is not set to a valid timezone. Please check Options->System->Timezone');
|
|
|
|
}
|
|
|
|
function unparse_url($parsed_url, $substitutions = array() ) {
|
|
$fields = array('scheme','host','port','user','pass','path','query','fragment');
|
|
|
|
foreach ( $fields as $field ) {
|
|
if ( isset( $substitutions[$field] ) ) {
|
|
$parsed_url[$field] = $substitutions[$field];
|
|
}
|
|
}
|
|
$scheme = isset($parsed_url['scheme']) ? $parsed_url['scheme'] . '://' : '';
|
|
$host = isset($parsed_url['host']) ? $parsed_url['host'] : '';
|
|
$port = isset($parsed_url['port']) ? ':' . $parsed_url['port'] : '';
|
|
$user = isset($parsed_url['user']) ? $parsed_url['user'] : '';
|
|
$pass = isset($parsed_url['pass']) ? ':' . $parsed_url['pass'] : '';
|
|
$pass = ($user || $pass) ? $pass.'@' : '';
|
|
$path = isset($parsed_url['path']) ? $parsed_url['path'] : '';
|
|
$query = isset($parsed_url['query']) ? '?' . $parsed_url['query'] : '';
|
|
$fragment = isset($parsed_url['fragment']) ? '#' . $parsed_url['fragment'] : '';
|
|
return $scheme.$user.$pass.$host.$port.$path.$query.$fragment;
|
|
}
|
|
|
|
// PP - POST request handler for PHP which does not need extensions
|
|
// credit: http://wezfurlong.org/blog/2006/nov/http-post-from-php-without-curl/
|
|
|
|
function do_request($method, $url, $data=array(), $optional_headers = null) {
|
|
global $php_errormsg;
|
|
|
|
$params = array('http' => array(
|
|
'method' => $method,
|
|
'content' => $data
|
|
));
|
|
if ( $optional_headers !== null ) {
|
|
$params['http']['header'] = $optional_headers;
|
|
}
|
|
$ctx = stream_context_create($params);
|
|
$fp = @fopen($url, 'rb', false, $ctx);
|
|
if ( !$fp ) {
|
|
throw new Exception("Problem with $url, $php_errormsg");
|
|
}
|
|
$response = @stream_get_contents($fp);
|
|
if ( $response === false ) {
|
|
throw new Exception("Problem reading data from $url, $php_errormsg");
|
|
}
|
|
return $response;
|
|
}
|
|
|
|
function do_post_request($url, $data, $optional_headers = null) {
|
|
$params = array('http' => array(
|
|
'method' => 'POST',
|
|
'content' => $data
|
|
));
|
|
if ( $optional_headers !== null ) {
|
|
$params['http']['header'] = $optional_headers;
|
|
}
|
|
$ctx = stream_context_create($params);
|
|
$fp = @fopen($url, 'rb', false, $ctx);
|
|
if ( !$fp ) {
|
|
throw new Exception('Problem with '.$url.', '
|
|
.print_r(error_get_last(),true));
|
|
}
|
|
$response = @stream_get_contents($fp);
|
|
if ( $response === false ) {
|
|
throw new Exception('Problem reading data from '.$url.', data: '.print_r($params,true)
|
|
.print_r(error_get_last(),true));
|
|
}
|
|
return $response;
|
|
}
|
|
|
|
// The following works around php not being built with semaphore functions.
|
|
if ( !function_exists('sem_get') ) {
|
|
function sem_get($key) {
|
|
return fopen(__FILE__ . '.sem.' . $key, 'w+');
|
|
}
|
|
function sem_acquire($sem_id) {
|
|
return flock($sem_id, LOCK_EX);
|
|
}
|
|
function sem_release($sem_id) {
|
|
return flock($sem_id, LOCK_UN);
|
|
}
|
|
}
|
|
|
|
if ( !function_exists('ftok') ) {
|
|
function ftok($filename = '', $proj = '') {
|
|
if ( empty($filename) || !file_exists($filename) ) {
|
|
return -1;
|
|
} else {
|
|
$filename = $filename . (string) $proj;
|
|
for($key = array(); sizeof($key) < strlen($filename); $key[] = ord(substr($filename, sizeof($key), 1)));
|
|
return dechex(array_sum($key));
|
|
}
|
|
}
|
|
}
|
|
|
|
function getAffectedIds( $name ) {
|
|
$names = $name.'s';
|
|
$ids = array();
|
|
if ( isset($_REQUEST[$names]) ) {
|
|
if ( is_array($_REQUEST[$names]) ) {
|
|
$ids = $_REQUEST[$names];
|
|
} else {
|
|
$ids = array($_REQUEST[$names]);
|
|
}
|
|
} else if ( isset($_REQUEST[$name]) ) {
|
|
if ( is_array($_REQUEST[$name]) ) {
|
|
$ids = $_REQUEST[$name];
|
|
} else {
|
|
$ids = array($_REQUEST[$name]);
|
|
}
|
|
}
|
|
return $ids;
|
|
}
|
|
|
|
function format_duration($time, $separator=':') {
|
|
return sprintf('%02d%s%02d%s%02d', floor($time/3600), $separator, ($time/60)%60, $separator, $time%60);
|
|
}
|
|
|
|
function array_recursive_diff($aArray1, $aArray2) {
|
|
$aReturn = array();
|
|
if ( ! (is_array($aArray1) and is_array($aArray2) ) ) {
|
|
$backTrace = debug_backtrace();
|
|
ZM\Warning('Bad arrays passed 1:' . print_r($aArray1,true) . PHP_EOL.'2: '.print_r($aArray2,true).PHP_EOL.' from: '.print_r($backTrace,true));
|
|
return;
|
|
}
|
|
|
|
foreach ( $aArray1 as $mKey => $mValue ) {
|
|
if ( array_key_exists($mKey, $aArray2) ) {
|
|
if ( is_array($mValue) ) {
|
|
if ( is_array($aArray2[$mKey]) ) {
|
|
$aRecursiveDiff = array_recursive_diff($mValue, $aArray2[$mKey]);
|
|
if ( count($aRecursiveDiff) ) {
|
|
$aReturn[$mKey] = $aRecursiveDiff;
|
|
}
|
|
} else {
|
|
$aReturn[$mKey] = $mValue;
|
|
}
|
|
} else {
|
|
if ( $mValue != $aArray2[$mKey] ) {
|
|
$aReturn[$mKey] = $mValue;
|
|
}
|
|
}
|
|
} else {
|
|
$aReturn[$mKey] = $mValue;
|
|
}
|
|
}
|
|
# Now check for keys in array2 that are not in array1
|
|
foreach ($aArray2 as $mKey => $mValue) {
|
|
if ( array_key_exists($mKey, $aArray1) ) {
|
|
# Already checked it... I think.
|
|
#if ( is_array($mValue) ) {
|
|
#$aRecursiveDiff = array_recursive_diff($mValue, $aArray2[$mKey]);
|
|
#if ( count($aRecursiveDiff) ) {
|
|
#$aReturn[$mKey] = $aRecursiveDiff;
|
|
#}
|
|
#} else {
|
|
#if ( $mValue != $aArray2[$mKey] ) {
|
|
#$aReturn[$mKey] = $mValue;
|
|
#}
|
|
#}
|
|
} else {
|
|
$aReturn[$mKey] = $mValue;
|
|
}
|
|
}
|
|
|
|
return $aReturn;
|
|
}
|
|
|
|
function html_input($name, $type='text', $value='', $options=array()) {
|
|
$html = '<input ';
|
|
$attributes = [];
|
|
$options = array_merge($options, ['name'=>$name, 'value'=>$value, 'type'=>$type]);
|
|
|
|
foreach (array_keys($options) as $k) {
|
|
$attributes[] = $k.'="'.$options[$k].'"';
|
|
}
|
|
$html .= join(' ', $attributes);
|
|
$html .= '/>';
|
|
return $html;
|
|
}
|
|
|
|
function html_radio($name, $values, $selected=null, $options=array(), $attrs=array()) {
|
|
|
|
$html = '';
|
|
if ( isset($options['default']) and ( $selected == null ) ) {
|
|
$selected = $options['default'];
|
|
} # end if
|
|
|
|
foreach ( $values as $value => $label ) {
|
|
if ( isset($options['container']) ) {
|
|
$html .= $options['container'][0];
|
|
}
|
|
$attributes = array_map(
|
|
function($attr, $value){return $attr.'="'.$value.'"';},
|
|
array_keys($attrs),
|
|
array_values($attrs)
|
|
);
|
|
$attributes_string = implode(' ', $attributes);
|
|
|
|
$html .= sprintf('
|
|
<div class="form-check%7$s">
|
|
<label class="form-check-label radio%7$s" for="%1$s%6$s%2$s">
|
|
<input class="form-check-input" type="radio" name="%1$s" value="%2$s" id="%1$s%6$s%2$s" %4$s%5$s />
|
|
%3$s</label></div>
|
|
', $name, $value, $label, ($value==$selected?' checked="checked"':''),
|
|
$attributes_string,
|
|
(isset($options['id']) ? $options['id'] : ''),
|
|
( ( (!isset($options['inline'])) or $options['inline'] ) ? '-inline' : '')
|
|
);
|
|
if ( isset($options['container']) ) {
|
|
$html .= $options['container'][1];
|
|
}
|
|
} # end foreach value
|
|
return $html;
|
|
} # end sub html_radio
|
|
|
|
|
|
function random_colour() {
|
|
return '#'.
|
|
str_pad( dechex( mt_rand(0, 255) ), 2, '0', STR_PAD_LEFT).
|
|
str_pad( dechex( mt_rand(0, 255) ), 2, '0', STR_PAD_LEFT).
|
|
str_pad( dechex( mt_rand(0, 255) ), 2, '0', STR_PAD_LEFT);
|
|
}
|
|
|
|
function zm_random_bytes($length = 32) {
|
|
if ( !isset($length) || intval($length) <= 8 ) {
|
|
$length = 32;
|
|
}
|
|
if ( function_exists('random_bytes') ) {
|
|
return random_bytes($length);
|
|
}
|
|
if ( function_exists('mcrypt_create_iv') ) {
|
|
return mcrypt_create_iv($length, MCRYPT_DEV_URANDOM);
|
|
}
|
|
if ( function_exists('openssl_random_pseudo_bytes') ) {
|
|
return openssl_random_pseudo_bytes($length);
|
|
}
|
|
ZM\Error('No random_bytes function found.');
|
|
}
|
|
|
|
function i18n() {
|
|
$string = explode('_', ZM_LANG_DEFAULT, 2);
|
|
$string[1] = strtoupper($string[1]);
|
|
|
|
return implode('-', $string);
|
|
}
|
|
|
|
function get_networks() {
|
|
$interfaces = array();
|
|
|
|
if (defined('ZM_PATH_IP') and ZM_PATH_IP and file_exists(ZM_PATH_IP)) {
|
|
exec(ZM_PATH_IP.' link', $output, $status);
|
|
if ( $status ) {
|
|
$html_output = implode('<br/>', $output);
|
|
ZM\Error("Unable to list network interfaces, status is '$status'. Output was:<br/><br/>$html_output");
|
|
} else {
|
|
foreach ( $output as $line ) {
|
|
if ( preg_match('/^\d+: ([[:alnum:]]+):/', $line, $matches ) ) {
|
|
if ( $matches[1] != 'lo' ) {
|
|
$interfaces[$matches[1]] = $matches[1];
|
|
} else {
|
|
ZM\Debug("No match for $line");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
$routes = array();
|
|
exec(ZM_PATH_IP.' route', $output, $status);
|
|
if ($status) {
|
|
$html_output = implode('<br/>', $output);
|
|
ZM\Error("Unable to list network interfaces, status is '$status'. Output was:<br/><br/>$html_output");
|
|
} else {
|
|
foreach ($output as $line) {
|
|
if ( preg_match('/^default via [.[:digit:]]+ dev ([[:alnum:]]+)/', $line, $matches) ) {
|
|
$interfaces['default'] = $matches[1];
|
|
} else if ( preg_match('/^([.[:digit:]]+\/[[:digit:]]+) dev ([[:alnum:]]+)/', $line, $matches) ) {
|
|
$interfaces[$matches[2]] .= ' ' . $matches[1];
|
|
ZM\Debug("Matched $line: $matches[2] .= $matches[1]");
|
|
} else {
|
|
ZM\Debug("Didn't match $line");
|
|
}
|
|
} # end foreach line of output
|
|
}
|
|
} else if (defined('ZM_PATH_IFCONFIG') and ZM_PATH_IFCONFIG and file_exists(ZM_PATH_IFCONFIG)) {
|
|
exec(ZM_PATH_IFCONFIG, $output, $status);
|
|
if ($status) {
|
|
$html_output = implode("\n", $output);
|
|
ZM\Error("Unable to list network interfaces, status is '$status'. Output was:$html_output");
|
|
} else {
|
|
preg_match("/^([eth|enp][A-z0-9]*)\s+Link\s+encap:([A-z]*)\s+HWaddr\s+([A-z0-9:]*).*".
|
|
"inet addr:([0-9.]+).*Bcast:([0-9.]+).*Mask:([0-9.]+).*".
|
|
"MTU:([0-9.]+).*Metric:([0-9.]+).*".
|
|
"RX packets:([0-9.]+).*errors:([0-9.]+).*dropped:([0-9.]+).*overruns:([0-9.]+).*frame:([0-9.]+).*".
|
|
"TX packets:([0-9.]+).*errors:([0-9.]+).*dropped:([0-9.]+).*overruns:([0-9.]+).*carrier:([0-9.]+).*".
|
|
"RX bytes:([0-9.]+).*\((.*)\).*TX bytes:([0-9.]+).*\((.*)\)".
|
|
"/ims", implode("\n", $output), $regex);
|
|
|
|
ZM\Debug(print_r( $regex,true));
|
|
}
|
|
}
|
|
return $interfaces;
|
|
}
|
|
|
|
# Returns an array of subnets like 192.168.1.0/24 for a given interface.
|
|
# Will ignore mdns networks.
|
|
|
|
function get_subnets($interface) {
|
|
$subnets = array();
|
|
if (defined('ZM_PATH_IP') and ZM_PATH_IP and file_exists(ZM_PATH_IP)) {
|
|
exec(ZM_PATH_IP.' route', $output, $status);
|
|
if ( $status ) {
|
|
$html_output = implode('<br/>', $output);
|
|
ZM\Error("Unable to list network interfaces, status is '$status'. Output was:<br/><br/>$html_output");
|
|
} else {
|
|
foreach ($output as $line) {
|
|
if (preg_match('/^([.[:digit:]]+\/[[:digit:]]+) dev ([[:alnum:]]+)/', $line, $matches)) {
|
|
if ($matches[1] == '169.254.0.0/16') {
|
|
# Ignore mdns
|
|
} else if ($matches[2] == $interface) {
|
|
$subnets[] = $matches[1];
|
|
} else {
|
|
ZM\Debug("Wrong interface $matches[1] != $interface");
|
|
}
|
|
} else {
|
|
ZM\Debug("Didn't match $line");
|
|
}
|
|
} # end foreach line of output
|
|
}
|
|
}
|
|
return $subnets;
|
|
} # end function get_subnets($interface)
|
|
|
|
function extract_auth_values_from_url($url) {
|
|
$protocolPrefixPos = strpos($url, '://');
|
|
if ($protocolPrefixPos === false)
|
|
return array();
|
|
|
|
$authSeparatorPos = strpos($url, '@', $protocolPrefixPos+3);
|
|
if ($authSeparatorPos === false)
|
|
return array();
|
|
|
|
$fieldsSeparatorPos = strpos($url, ':', $protocolPrefixPos+3);
|
|
if ($fieldsSeparatorPos === false || $authSeparatorPos < $fieldsSeparatorPos)
|
|
return array();
|
|
|
|
$username = substr( $url, $protocolPrefixPos+3, $fieldsSeparatorPos-($protocolPrefixPos+3) );
|
|
$password = substr( $url, $fieldsSeparatorPos+1, $authSeparatorPos-$fieldsSeparatorPos-1 );
|
|
|
|
// URL decode the credentials since they may contain encoded special characters
|
|
// from ONVIF probe or manual URL entry
|
|
$username = urldecode($username);
|
|
$password = urldecode($password);
|
|
|
|
return array( $username, $password );
|
|
}
|
|
|
|
function output_file($path, $chunkSize=1024) {
|
|
if (connection_status() != 0)
|
|
return false;
|
|
$parts = pathinfo($path);
|
|
$file = $parts['basename'];
|
|
|
|
$contentType = getMimeType($path);
|
|
|
|
header('Cache-Control: public');
|
|
header('Content-Transfer-Encoding: binary');
|
|
header("Content-Type: $contentType");
|
|
|
|
$contentDisposition = 'inline';
|
|
if (strstr($_SERVER['HTTP_USER_AGENT'], 'MSIE')) {
|
|
$file = preg_replace('/\./', '%2e', $file, substr_count($file, '.') - 1);
|
|
}
|
|
header("Content-Disposition: $contentDisposition;filename=\"$file\"");
|
|
|
|
header('Accept-Ranges: bytes');
|
|
$range = 0;
|
|
$size = filesize($path);
|
|
|
|
if (isset($_SERVER['HTTP_RANGE'])) {
|
|
list($a, $range) = explode('=', $_SERVER['HTTP_RANGE']);
|
|
str_replace($range, '-', $range);
|
|
$range = (int)$range; #fseek etc require integers not strings
|
|
$size2 = $size - 1;
|
|
$new_length = $size - $range;
|
|
header('HTTP/1.1 206 Partial Content');
|
|
header("Content-Length: $new_length");
|
|
header("Content-Range: bytes $range-$size2/$size");
|
|
} else {
|
|
$size2 = $size - 1;
|
|
header("Content-Range: bytes 0-$size2/$size");
|
|
header('Content-Length: ' . $size);
|
|
}
|
|
|
|
if ($size == 0) {
|
|
Error('Zero byte file! Aborting download');
|
|
}
|
|
@ini_set('magic_quotes_runtime', 0);
|
|
$fp = fopen($path, 'rb');
|
|
|
|
fseek($fp, $range);
|
|
|
|
while (!feof($fp) and (connection_status() == 0)) {
|
|
set_time_limit(0);
|
|
print(@fread($fp, 1024*$chunkSize));
|
|
flush();
|
|
ob_flush();
|
|
}
|
|
fclose($fp);
|
|
|
|
return ((connection_status() == 0) and !connection_aborted());
|
|
} # end function output_file
|
|
|
|
function array_to_hash_by_key($key, $array) {
|
|
$results = array();
|
|
foreach ($array as $a) {
|
|
if (is_array($a)) {
|
|
$results[$a[$key]] = $a;
|
|
} else {
|
|
$results[$a->$key()] = $a;
|
|
}
|
|
}
|
|
return $results;
|
|
}
|
|
|
|
function check_datetime($x) {
|
|
return (date('Y-m-d H:i:s', strtotime($x)) == $x);
|
|
}
|
|
|
|
function getHomeView() {
|
|
global $user;
|
|
global $skin;
|
|
if ($user and is_object($user) and $user->HomeView()) {
|
|
$view = detaintPath($user->HomeView());
|
|
if (preg_match('/^(\w+)([\w&=]*)$/', $view, $matches)) {
|
|
$path = dirname(__FILE__, 2).'/skins/'.$skin.'/views/'.$matches[1].'.php';
|
|
if (file_exists($path)) {
|
|
return $view;
|
|
} else {
|
|
ZM\Warning('Invalid view '.$user->HomeView().' in HomeView for user '.$user->Username().' does not exist at '.$path);
|
|
}
|
|
} else {
|
|
ZM\Warning('Invalid view '.$user->HomeView().' in HomeView for user '.$user->Username().' does not match regexp');
|
|
}
|
|
}
|
|
if (defined('ZM_WEB_HOMEVIEW') and ZM_WEB_HOMEVIEW) {
|
|
$view = detaintPath(ZM_WEB_HOMEVIEW);
|
|
if (preg_match('/^(\w+)([\w&=]*)$/', $view, $matches)) {
|
|
$path = dirname(__FILE__, 2).'/skins/'.$skin.'/views/'.$matches[1].'.php';
|
|
if (file_exists($path)) {
|
|
return $view;
|
|
} else {
|
|
ZM\Warning('Invalid view '.ZM_WEB_HOMEVIEW.' in ZM_WEB_HOMEVIEW does not exist at '.$path);
|
|
}
|
|
} else {
|
|
ZM\Warning('Invalid view '.ZM_WEB_HOMEVIEW.' in ZM_WEB_HOMEVIEW does not match regexp');
|
|
}
|
|
}
|
|
return 'console';
|
|
}
|
|
|
|
function systemd_isactive($service) {
|
|
$output = shell_exec("systemctl is-active $service");
|
|
return (trim($output) == 'active');
|
|
}
|
|
|
|
function to_string($thing) {
|
|
if (empty($thing)) return '';
|
|
if (is_array($thing)) return implode(', ', $thing);
|
|
return strval($thing);
|
|
}
|
|
?>
|