leo/lookingglass
1
0
Fork 0
mirror of https://github.com/hybula/lookingglass.git synced 2024-09-21 05:20:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Some experimenting

Browse source
This commit is contained in:
dqos 2023-03-25 15:35:05 +01:00
parent ff2d46080b
commit 41adb719f8
3 changed files with 201 additions and 80 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

195
LookingGlass.php
View file

@ -1,4 +1,5 @@
<?php declare(strict_types=1); <?php
declare(strict_types=1);
/** /**
* Hybula Looking Glass * Hybula Looking Glass
* *
@ -10,6 +11,7 @@
* @since File available since release 0.1 * @since File available since release 0.1
* @link https://github.com/hybula/lookingglass * @link https://github.com/hybula/lookingglass
*/ */
namespace Hybula; namespace Hybula;
class LookingGlass class LookingGlass
@ -41,31 +43,84 @@ class LookingGlass
public static function validateConfig(): void public static function validateConfig(): void
{ {
//@formatter:off //@formatter:off
if (!defined('LG_TITLE')) die('LG_TITLE not found in config.php'); if (!defined('LG_TITLE')) {
if (!defined('LG_LOGO')) die('LG_LOGO not found in config.php'); die('LG_TITLE not found in config.php');
if (!defined('LG_LOGO_URL')) die('LG_LOGO_URL not found in config.php'); }
if (!defined('LG_CSS_OVERRIDES')) die('LG_CSS_OVERRIDES not found in config.php'); if (!defined('LG_LOGO')) {
if (!defined('LG_BLOCK_NETWORK')) die('LG_BLOCK_NETWORK not found in config.php'); die('LG_LOGO not found in config.php');
if (!defined('LG_BLOCK_LOOKINGGLAS')) die('LG_BLOCK_LOOKINGGLAS not found in config.php'); }
if (!defined('LG_BLOCK_SPEEDTEST')) die('LG_BLOCK_SPEEDTEST not found in config.php'); if (!defined('LG_LOGO_URL')) {
if (!defined('LG_BLOCK_CUSTOM')) die('LG_BLOCK_CUSTOM not found in config.php'); die('LG_LOGO_URL not found in config.php');
if (!defined('LG_CUSTOM_HTML')) die('LG_CUSTOM_HTML not found in config.php'); }
if (!defined('LG_CUSTOM_PHP')) die('LG_CUSTOM_PHP not found in config.php'); if (!defined('LG_CSS_OVERRIDES')) {
if (!defined('LG_LOCATION')) die('LG_LOCATION not found in config.php'); die('LG_CSS_OVERRIDES not found in config.php');
if (!defined('LG_MAPS_QUERY')) die('LG_MAPS_QUERY not found in config.php'); }
if (!defined('LG_FACILITY')) die('LG_FACILITY not found in config.php'); if (!defined('LG_BLOCK_NETWORK')) {
if (!defined('LG_FACILITY_URL')) die('LG_FACILITY_URL not found in config.php'); die('LG_BLOCK_NETWORK not found in config.php');
if (!defined('LG_IPV4')) die('LG_IPV4 not found in config.php'); }
if (!defined('LG_IPV6')) die('LG_IPV6 not found in config.php'); if (!defined('LG_BLOCK_LOOKINGGLAS')) {
if (!defined('LG_METHODS')) die('LG_METHODS not found in config.php'); die('LG_BLOCK_LOOKINGGLAS not found in config.php');
if (!defined('LG_LOCATIONS')) die('LG_LOCATIONSnot found in config.php'); }
if (!defined('LG_SPEEDTEST_IPERF')) die('LG_SPEEDTEST_IPERF not found in config.php'); if (!defined('LG_BLOCK_SPEEDTEST')) {
if (!defined('LG_SPEEDTEST_LABEL_INCOMING')) die('LG_SPEEDTEST_LABEL_INCOMING not found in config.php'); die('LG_BLOCK_SPEEDTEST not found in config.php');
if (!defined('LG_SPEEDTEST_CMD_INCOMING')) die('LG_SPEEDTEST_CMD_INCOMING not found in config.php'); }
if (!defined('LG_SPEEDTEST_LABEL_OUTGOING')) die('LG_SPEEDTEST_LABEL_OUTGOING not found in config.php'); if (!defined('LG_BLOCK_CUSTOM')) {
if (!defined('LG_SPEEDTEST_CMD_OUTGOING')) die('LG_SPEEDTEST_CMD_OUTGOING not found in config.php'); die('LG_BLOCK_CUSTOM not found in config.php');
if (!defined('LG_SPEEDTEST_FILES')) die('LG_SPEEDTEST_FILES not found in config.php'); }
if (!defined('LG_TERMS')) die('LG_TERMS not found in config.php'); if (!defined('LG_CUSTOM_HTML')) {
die('LG_CUSTOM_HTML not found in config.php');
}
if (!defined('LG_CUSTOM_PHP')) {
die('LG_CUSTOM_PHP not found in config.php');
}
if (!defined('LG_LOCATION')) {
die('LG_LOCATION not found in config.php');
}
if (!defined('LG_MAPS_QUERY')) {
die('LG_MAPS_QUERY not found in config.php');
}
if (!defined('LG_FACILITY')) {
die('LG_FACILITY not found in config.php');
}
if (!defined('LG_FACILITY_URL')) {
die('LG_FACILITY_URL not found in config.php');
}
if (!defined('LG_IPV4')) {
die('LG_IPV4 not found in config.php');
}
if (!defined('LG_IPV6')) {
die('LG_IPV6 not found in config.php');
}
if (!defined('LG_METHODS')) {
die('LG_METHODS not found in config.php');
}
if (!defined('LG_LOCATIONS')) {
die('LG_LOCATIONSnot found in config.php');
}
if (!defined('LG_SPEEDTEST_IPERF')) {
die('LG_SPEEDTEST_IPERF not found in config.php');
}
if (!defined('LG_SPEEDTEST_LABEL_INCOMING')) {
die('LG_SPEEDTEST_LABEL_INCOMING not found in config.php');
}
if (!defined('LG_SPEEDTEST_CMD_INCOMING')) {
die('LG_SPEEDTEST_CMD_INCOMING not found in config.php');
}
if (!defined('LG_SPEEDTEST_LABEL_OUTGOING')) {
die('LG_SPEEDTEST_LABEL_OUTGOING not found in config.php');
}
if (!defined('LG_SPEEDTEST_CMD_OUTGOING')) {
die('LG_SPEEDTEST_CMD_OUTGOING not found in config.php');
}
if (!defined('LG_SPEEDTEST_FILES')) {
die('LG_SPEEDTEST_FILES not found in config.php');
}
if (!defined('LG_TERMS')) {
die('LG_TERMS not found in config.php');
}
if (!defined('LG_CHECK_LATENCY')) {
die('LG_CHECK_LATENCY not found in config.php');
}
//@formatter:on //@formatter:on
} }
@ -122,8 +177,8 @@ class LookingGlass
return ''; return '';
} }
if (filter_var('https://' . $host, FILTER_VALIDATE_URL)) { if (filter_var('https://'.$host, FILTER_VALIDATE_URL)) {
if ($host = parse_url('https://' . $host, PHP_URL_HOST)) { if ($host = parse_url('https://'.$host, PHP_URL_HOST)) {
if ($type === self::IPV4 && isset(dns_get_record($host, DNS_A)[0]['ip'])) { if ($type === self::IPV4 && isset(dns_get_record($host, DNS_A)[0]['ip'])) {
return $host; return $host;
} }
@ -167,7 +222,7 @@ class LookingGlass
*/ */
public static function ping(string $host, int $count = 4): bool public static function ping(string $host, int $count = 4): bool
{ {
return self::procExecute('ping -4 -c' . $count . ' -w15', $host); return self::procExecute('ping -4 -c'.$count.' -w15', $host);
} }
/** /**
@ -179,7 +234,7 @@ class LookingGlass
*/ */
public static function ping6(string $host, int $count = 4): bool public static function ping6(string $host, int $count = 4): bool
{ {
return self::procExecute('ping -6 -c' . $count . ' -w15', $host); return self::procExecute('ping -6 -c'.$count.' -w15', $host);
} }
/** /**
@ -190,7 +245,7 @@ class LookingGlass
*/ */
public static function mtr(string $host): bool public static function mtr(string $host): bool
{ {
return self::procExecute('mtr --raw -n -4 -c ' . self::MTR_COUNT, $host); return self::procExecute('mtr --raw -n -4 -c '.self::MTR_COUNT, $host);
} }
/** /**
@ -201,7 +256,7 @@ class LookingGlass
*/ */
public static function mtr6(string $host): bool public static function mtr6(string $host): bool
{ {
return self::procExecute('mtr --raw -n -6 -c ' . self::MTR_COUNT, $host); return self::procExecute('mtr --raw -n -6 -c '.self::MTR_COUNT, $host);
} }
/** /**
@ -286,17 +341,16 @@ class LookingGlass
if ($type === 'mtr') { if ($type === 'mtr') {
// correct output for mtr // correct output for mtr
$parser->update($str); $parser->update($str);
echo '---' . PHP_EOL . $parser->__toString() . PHP_EOL . str_pad('', 4096) . PHP_EOL; echo '---'.PHP_EOL.$parser->__toString().PHP_EOL.str_pad('', 4096).PHP_EOL;
// flush output buffering // flush output buffering
@ob_flush(); @ob_flush();
flush(); flush();
continue; continue;
} } // correct output for traceroute
// correct output for traceroute
elseif ($type === 'traceroute') { elseif ($type === 'traceroute') {
if ($match < 10 && preg_match('/^[0-9] /', $str, $string)) { if ($match < 10 && preg_match('/^[0-9] /', $str, $string)) {
$str = preg_replace('/^[0-9] /', '&nbsp;' . $string[0], $str); $str = preg_replace('/^[0-9] /', '&nbsp;'.$string[0], $str);
$match++; $match++;
} }
// check for consecutive failed hops // check for consecutive failed hops
@ -306,7 +360,7 @@ class LookingGlass
&& ($traceCount - 1) === $lastFail && ($traceCount - 1) === $lastFail
&& $fail >= $failCount && $fail >= $failCount
) { ) {
echo str_pad($str . '<br />-- Traceroute timed out --<br />', 4096, ' ', STR_PAD_RIGHT); echo str_pad($str.'<br />-- Traceroute timed out --<br />', 4096, ' ', STR_PAD_RIGHT);
break; break;
} }
$lastFail = $traceCount; $lastFail = $traceCount;
@ -315,7 +369,7 @@ class LookingGlass
} }
// pad string for live output // pad string for live output
echo str_pad($str . '<br />', 4096, ' ', STR_PAD_RIGHT); echo str_pad($str.'<br />', 4096, ' ', STR_PAD_RIGHT);
// flush output buffering // flush output buffering
@ob_flush(); @ob_flush();
@ -345,7 +399,7 @@ class LookingGlass
// kill remaining processes // kill remaining processes
foreach ($pids as $pid) { foreach ($pids as $pid) {
if (is_numeric($pid)) { if (is_numeric($pid)) {
posix_kill((int) $pid, 9); posix_kill((int)$pid, 9);
} }
} }
} }
@ -353,6 +407,66 @@ class LookingGlass
} }
return true; return true;
} }
public static function getLatency(): float
{
$getLatency = self::getLatencyFromSs(self::detectIpAddress());
if (isset($getLatency[0])) {
return (float)round($getLatency[0]['latency'], 2);
} else {
return 0.00;
}
}
/**
* This uses the command 'ss' in order to find out latency.
* A clever way coded by @ayyylias, so please keep credits and do not just steal.
*
* @param string $ip The command to execute.
* @return array Returns an array with results.
*/
private static function getLatencyFromSs(string $ip): array
{
$lines = shell_exec('/usr/sbin/ss -Hti state established');
$ss = [];
$i = 0;
$j = 0;
foreach (explode(PHP_EOL, $lines) as $line) {
if ($i > 1) {
$i = 0;
$j++;
}
if ($line !== '') {
@$ss[$j] .= $line;
$i++;
}
}
$output = [];
foreach ($ss as $socket) {
$socket = preg_replace('!\s+!', ' ', $socket);
$explodedsocket = explode(' ', $socket);
preg_match('/\d+\.\d+\.\d+\.\d+/', $explodedsocket[2], $temp);
if (!isset($temp[0])) {
continue;
} // when thsi cantt be filled just continue
$sock['local'] = $temp[0];
preg_match('/\d+\.\d+\.\d+\.\d+/', $explodedsocket[3], $temp);
$sock['remote'] = $temp[0];
preg_match('/segs_out:(\d+)/', $socket, $temp);
$sock['segs_out'] = $temp[1];
preg_match('/segs_in:(\d+)/', $socket, $temp);
$sock['segs_in'] = $temp[1];
preg_match_all('/rtt:(\d+\.\d+)\/(\d+\.\d+)/', $socket, $temp);
$sock['latency'] = $temp[1][0];
$sock['jitter'] = $temp[2][0];
preg_match_all('/retrans:\d+\/(\d+)/', $socket, $temp);
$sock['retransmissions'] = (isset($temp[1][0]) ? $temp[1][0] : 0);
if ($sock['remote'] == $ip) {
$output[] = $sock;
}
}
return $output;
}
} }
class Hop class Hop
@ -434,7 +548,6 @@ class Parser
} }
foreach ($hop->timings as $time) { foreach ($hop->timings as $time) {
if ($hop->best > $time) { if ($hop->best > $time) {
$hop->best = $time; $hop->best = $time;
} }
@ -501,7 +614,7 @@ class Parser
switch ($rawHop->dataType) { switch ($rawHop->dataType) {
case 'h': case 'h':
$hop->ips[] = $rawHop->value; $hop->ips[] = $rawHop->value;
$hop->hosts[] = gethostbyaddr($rawHop->value) ? : null; $hop->hosts[] = gethostbyaddr($rawHop->value) ?: null;
break; break;
case 'd': case 'd':
//Not entirely sure if multiple IPs. Better use -n in mtr and resolve later in summarize. //Not entirely sure if multiple IPs. Better use -n in mtr and resolve later in summarize.

3
config.dist.php
View file

@ -9,6 +9,9 @@ const LG_LOGO = '<h2>Company Looking Glass</h2>';
// Define the URL where the logo points to; // Define the URL where the logo points to;
const LG_LOGO_URL = 'https://github.com/hybula/lookingglass/'; const LG_LOGO_URL = 'https://github.com/hybula/lookingglass/';
// Enable the latency check feature;
const LG_CHECK_LATENCY = false;
// Define a custom CSS file which can be used to style the LG, set false to disable, else point to the CSS file; // Define a custom CSS file which can be used to style the LG, set false to disable, else point to the CSS file;
const LG_CSS_OVERRIDES = false; const LG_CSS_OVERRIDES = false;
// Define <head> content, this could be JS, CSS or meta tags; // Define <head> content, this could be JS, CSS or meta tags;

5
index.php
View file

@ -77,6 +77,10 @@ if (LG_BLOCK_CUSTOM) {
$templateData['custom_html'] = ob_get_clean(); $templateData['custom_html'] = ob_get_clean();
} }
if (LG_CHECK_LATENCY) {
$templateData['latency'] = LookingGlass::getLatency();
}
$templateData['csrfToken'] = $_SESSION[LookingGlass::SESSION_CSRF] = bin2hex(random_bytes(12)); $templateData['csrfToken'] = $_SESSION[LookingGlass::SESSION_CSRF] = bin2hex(random_bytes(12));
?> ?>
<!doctype html> <!doctype html>
@ -162,6 +166,7 @@ $templateData['csrfToken'] = $_SESSION[LookingGlass::SESSION_CSRF] = bin2hex(ran
<div class="col-md-4"> <div class="col-md-4">
<label class="mb-2 text-muted">Your IP</label> <label class="mb-2 text-muted">Your IP</label>
<div class="input-group"> <div class="input-group">
<?php if (LG_CHECK_LATENCY): ?><label class="input-group-text" title="Latency between this looking glass and your connection." style="cursor: help;"><?php echo $templateData['latency'] ?> ms</label><?php endif ?>
<input type="text" class="form-control" value="<?php echo $templateData['user_ip'] ?>" onfocus="this.select()" readonly=""> <input type="text" class="form-control" value="<?php echo $templateData['user_ip'] ?>" onfocus="this.select()" readonly="">
<button class="btn btn-outline-secondary" onclick="copyToClipboard('<?php echo $templateData['user_ip'] ?>', this)">Copy</button> <button class="btn btn-outline-secondary" onclick="copyToClipboard('<?php echo $templateData['user_ip'] ?>', this)">Copy</button>
</div> </div>