freenetis-github/application/controllers/web_interface.php @ 2a7bec72
| 8baed187 | Michal Kliment | <?php defined('SYSPATH') or die('No direct script access.');
|
|
/*
|
|||
* This file is part of open source system FreenetIS
|
|||
* and it is released under GPLv3 licence.
|
|||
*
|
|||
* More info about licence can be found:
|
|||
* http://www.gnu.org/licenses/gpl-3.0.html
|
|||
*
|
|||
* More info about project can be found:
|
|||
* http://www.freenetis.org/
|
|||
*
|
|||
*/
|
|||
/**
|
|||
* Controller used for communication between Freenetis and other remote devices,
|
|||
* for example network gateways, routers, access points etc.
|
|||
*
|
|||
* @author Jiri Svitak
|
|||
* @package Controller
|
|||
*/
|
|||
class Web_interface_Controller extends Controller
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | // predefined QoS classes
|
|
| 8baed187 | Michal Kliment | const MEMBERS_QOS_PARENT = 1;
|
|
const MEMBERS_QOS_ORDINARY = 2;
|
|||
const MEMBERS_QOS_ACTIVE = 3;
|
|||
const MEMBERS_QOS_HIGH_PRIORITY = 4;
|
|||
const MEMBERS_QOS_MEMBERS = 5;
|
|||
| c1bdc1c4 | Michal Kliment | // QoS priority types
|
|
| 8baed187 | Michal Kliment | const MEMBERS_QOS_PRIORITY_NORMAL = 1;
|
|
const MEMBERS_QOS_PRIORITY_HIGH = 0;
|
|||
| c1bdc1c4 | Michal Kliment | // QoS protocol
|
|
| 8baed187 | Michal Kliment | const MEMBERS_QOS_PROTOCOL_ALL = 'all';
|
|
| c1bdc1c4 | Michal Kliment | /**
|
|
* Preprocesor not useful here.
|
|||
*
|
|||
* @return boolean
|
|||
*/
|
|||
protected function is_preprocesor_enabled()
|
|||
{
|
|||
return FALSE;
|
|||
}
|
|||
| 8baed187 | Michal Kliment | /**
|
|
* Index prints about message
|
|||
*/
|
|||
public function index()
|
|||
{
|
|||
echo __('Interface for communication over http protocol with remote devices');
|
|||
}
|
|||
/**
|
|||
* Prints to output all subnets which have enabled redirection.
|
|||
* Any IP address belonging to these subnet ranges can be redirected.
|
|||
*
|
|||
* @author Jiri Svitak
|
|||
*/
|
|||
| c1bdc1c4 | Michal Kliment | public function redirected_ranges()
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // if gateway set uped - anly allow to access this page from it
|
|
// also if redirection is not enabled
|
|||
if (!module::e('redirection') ||
|
|||
!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | $ranges = ORM::factory('subnet')->get_redirected_ranges();
|
|
$items = array();
|
|||
| c1bdc1c4 | Michal Kliment | foreach ($ranges as $range)
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | $items[] = $range->subnet_range;
|
|
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | echo implode("\n", $items)."\n";
|
|
| 8baed187 | Michal Kliment | // set state of module (last activation time)
|
|
Settings::set('redirection_state', date('Y-m-d H:i:s'));
|
|||
}
|
|||
/**
|
|||
* Prints all allowed IP addresses.
|
|||
* These are registered IP addresses, which have no redirection set.
|
|||
* Unknown IP addresses (not present in system) and
|
|||
* IP addresses with a redirection set are not exported.
|
|||
*
|
|||
* @author Jiri Svitak
|
|||
*/
|
|||
| c1bdc1c4 | Michal Kliment | public function allowed_ip_addresses()
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // if gateway set uped - anly allow to access this page from it
|
|
// also if redirection is not enabled
|
|||
if (!module::e('redirection') ||
|
|||
!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | $ip_adresses = ORM::factory('ip_address')->get_allowed_ip_addresses();
|
|
$items = array();
|
|||
| c1bdc1c4 | Michal Kliment | foreach ($ip_adresses as $ip_adress)
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | $items[] = $ip_adress->ip_address;
|
|
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | ||
echo implode("\n", $items)."\n";
|
|||
// set state of module (last activation time)
|
|||
Settings::set('redirection_state', date('Y-m-d H:i:s'));
|
|||
| 8baed187 | Michal Kliment | }
|
|
/**
|
|||
* Prints all unallowed ip addresses, otherwise same as previous method
|
|||
| 53cf4ce8 | Ondřej Fibich | *
|
|
* @param int $message_type message type to filter only IP redirected with
|
|||
* the specified type or NULL for all types
|
|||
* @author Michal Kliment
|
|||
* @author Ondřej Fibich
|
|||
| 8baed187 | Michal Kliment | */
|
|
| 53cf4ce8 | Ondřej Fibich | public function unallowed_ip_addresses($message_type = NULL)
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // if gateway set uped - anly allow to access this page from it
|
|
// also if redirection is not enabled
|
|||
if (!module::e('redirection') ||
|
|||
!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 53cf4ce8 | Ondřej Fibich | ||
$ipm = new Ip_address_Model();
|
|||
$mt_num = intval($message_type);
|
|||
if ($message_type != NULL && $mt_num >= 0)
|
|||
{
|
|||
$ip_adresses = $ipm->get_unallowed_ip_addresses_by_type($mt_num);
|
|||
}
|
|||
else
|
|||
{
|
|||
$ip_adresses = $ipm->get_unallowed_ip_addresses();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | ||
$items = array();
|
|||
| c1bdc1c4 | Michal Kliment | foreach ($ip_adresses as $ip_adress)
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | $items[] = $ip_adress->ip_address;
|
|
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | echo implode("\n", $items)."\n";
|
|
| 8baed187 | Michal Kliment | // set state of module (last activation time)
|
|
Settings::set('redirection_state', date('Y-m-d H:i:s'));
|
|||
}
|
|||
/**
|
|||
| c1bdc1c4 | Michal Kliment | * Prints list of IP addresses which are redirected by a message that is self
|
|
* canceble.
|
|||
*
|
|||
| 8baed187 | Michal Kliment | * @author Michal Kliment
|
|
*/
|
|||
| c1bdc1c4 | Michal Kliment | public function self_cancelable_ip_addresses()
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // if gateway set uped - anly allow to access this page from it
|
|
// also if redirection is not enabled
|
|||
if (!module::e('redirection') ||
|
|||
!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | $ip_adresses = ORM::factory('ip_address')->get_ip_addresses_with_self_cancel();
|
|
$items = array();
|
|||
| c1bdc1c4 | Michal Kliment | foreach ($ip_adresses as $ip_adress)
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | $items[] = $ip_adress->ip_address;
|
|
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | echo implode("\n", $items)."\n";
|
|
| 8baed187 | Michal Kliment | // set state of module (last activation time)
|
|
Settings::set('redirection_state', date('Y-m-d H:i:s'));
|
|||
}
|
|||
/**
|
|||
* Prints all local subnets
|
|||
*
|
|||
* @author Michal Kliment
|
|||
*/
|
|||
| c1bdc1c4 | Michal Kliment | public function local_subnets()
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // only enabled if IP address that requested for this page is from
|
|
// one of allowed ranges in the FreenetIS
|
|||
if (!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | $local_subnets = ORM::factory('local_subnet')->get_all_local_subnets();
|
|
$items = array();
|
|||
| c1bdc1c4 | Michal Kliment | foreach ($local_subnets as $local_subnet)
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | $items[] = $local_subnet->address;
|
|
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | ||
echo implode("\n", $items)."\n";
|
|||
| 8baed187 | Michal Kliment | }
|
|
/**
|
|||
* Function is used for VoIP callback.
|
|||
| c1bdc1c4 | Michal Kliment | *
|
|
* @see http://www.voip-info.org/wiki/index.php?page=Asterisk+Manager+API+Action+Originate
|
|||
| 8baed187 | Michal Kliment | * @param integer $user
|
|
* @param string $pass
|
|||
* @param integer $number
|
|||
*/
|
|||
| c1bdc1c4 | Michal Kliment | public function voip_callback($user = null, $pass = null, $number = null)
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // only enabled if IP address that requested for this page is from
|
|
// one of allowed ranges in the FreenetIS
|
|||
if (!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
// VoIP is not enabled, quit
|
|||
if (!Settings::get('voip_enabled'))
|
|||
return;
|
|||
| 8baed187 | Michal Kliment | if ($user == null || $pass == null || $number == null)
|
|
{
|
|||
| c1bdc1c4 | Michal Kliment | die('No input data');
|
|
| 8baed187 | Michal Kliment | }
|
|
if (!valid::digit($user) || !valid::digit($number))
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | die('Not valid input data');
|
|
| 8baed187 | Michal Kliment | }
|
|
$voip = ORM::factory('voip_sip')->get_voip_sip_by_name($user);
|
|||
if (count($voip) == 0 || $voip->current()->secret != $pass)
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | die('Bad user or password');
|
|
| 8baed187 | Michal Kliment | }
|
|
else
|
|||
{
|
|||
$asm = new AsteriskManager();
|
|||
| c1bdc1c4 | Michal Kliment | $ahostname = Settings::get('voip_asterisk_hostname');
|
|
$auser = Settings::get('voip_asterisk_user');
|
|||
$apass = Settings::get('voip_asterisk_pass');
|
|||
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | if (empty($ahostname) || empty($auser) || empty($apass))
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | die('Error. Check FreenetIS settings.');
|
|
| 8baed187 | Michal Kliment | }
|
|
if ($asm->connect($ahostname, $auser, $apass))
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | $asm->Originate(
|
|
| 8baed187 | Michal Kliment | 'SIP/' . $user, $number, 'internal', 1,
|
|
| c1bdc1c4 | Michal Kliment | NULL, NULL, 30000, $user, NULL, NULL, 'Async', NULL
|
|
| 8baed187 | Michal Kliment | );
|
|
$asm->disconnect();
|
|||
echo 'Success';
|
|||
}
|
|||
else
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | die('Error. Could not connect to server.');
|
|
| 8baed187 | Michal Kliment | }
|
|
}
|
|||
}
|
|||
/**
|
|||
* Generates authorized keys to device
|
|||
*
|
|||
* @author Michal Kliment
|
|||
* @param integer $device_id
|
|||
* @return mixed
|
|||
*/
|
|||
public function authorized_keys($device_id = NULL)
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | // only enabled if IP address that requested for this page is from
|
|
// one of allowed ranges in the FreenetIS
|
|||
if (!network::ip_address_in_ranges(server::remote_addr()))
|
|||
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | @header('HTTP/1.0 403 Forbidden');
|
|
die();
|
|||
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | ||
// device_id is set
|
|||
if ($device_id && is_numeric($device_id))
|
|||
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // device load
|
|
$d = new Device_Model($device_id);
|
|||
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | // finds all keys by device
|
|
if ($d->id)
|
|||
{
|
|||
$keys = ORM::factory('users_key')->get_keys_by_device($d->id);
|
|||
echo "#\n";
|
|||
echo "# Generated by FreenetIS at " . date("Y-m-d H:i:s") . "\n";
|
|||
echo "#\n";
|
|||
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | foreach ($keys as $key)
|
|
{
|
|||
echo "$key->key\n";
|
|||
}
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | ||
// not founded
|
|||
@header('HTTP/1.0 404 Not Found');
|
|||
die();
|
|||
| 8baed187 | Michal Kliment | }
|
|
/**
|
|||
* Prints all user's keys
|
|||
*
|
|||
* @author Michal Kliment
|
|||
* @param integer $user_id
|
|||
* @return mixed
|
|||
*/
|
|||
public function key($user_id = NULL)
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | // only enabled if IP address that requested for this page is from
|
|
// one of allowed ranges in the FreenetIS
|
|||
if (!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | // bad parameter
|
|
| c1bdc1c4 | Michal Kliment | if ($user_id || is_numeric($user_id))
|
|
{
|
|||
// device load
|
|||
$u = new User_Model($user_id);
|
|||
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | // finds all keys by device
|
|
if ($u->id)
|
|||
{
|
|||
// finds all keys by user
|
|||
$keys = ORM::factory('users_key')->where('user_id', $u->id)->find_all();
|
|||
echo "#\n";
|
|||
echo "# Generated by FreenetIS at " . date("Y-m-d H:i:s") . "\n";
|
|||
echo "#\n";
|
|||
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | foreach ($keys as $key)
|
|
{
|
|||
echo "$key->key\n";
|
|||
}
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | ||
// not founded
|
|||
@header('HTTP/1.0 404 Not Found');
|
|||
die();
|
|||
| 8baed187 | Michal Kliment | }
|
|
/**
|
|||
* Prints members QoS's data in columns
|
|||
*
|
|||
* @author Michal Kliment
|
|||
* @return type
|
|||
*/
|
|||
public function members_qos_ceil_rate()
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | // only enabled if IP address that requested for this page is from
|
|
// one of allowed ranges in the FreenetIS
|
|||
if (!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | // qos is not enabled, we ends
|
|
if (!Settings::get('qos_enabled'))
|
|||
return;
|
|||
// finds total qos speed
|
|||
$total = network::speed_size(Settings::get('qos_total_speed'), "M");
|
|||
$members_upload_rate = $total['upload'];
|
|||
$members_download_rate = $total['download'];
|
|||
// ulogd is enabled
|
|||
if (Settings::get('ulogd_enabled'))
|
|||
{
|
|||
// finds qos speed for active members
|
|||
$active = network::speed_size(Settings::get('qos_active_speed'), "M");
|
|||
$members_upload_rate -= $active['upload'];
|
|||
$members_download_rate -= $active['download'];
|
|||
}
|
|||
$i = self::MEMBERS_QOS_MEMBERS;
|
|||
$total_upload_rate = 0;
|
|||
$total_download_rate = 0;
|
|||
$data = array();
|
|||
$members_data = array();
|
|||
// finds all members with guaranteed speed
|
|||
$members = ORM::factory('member')->get_members_qos_ceil_rate();
|
|||
foreach ($members as $member)
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | $ceil = network::speed($member->u_ceil) . '/'
|
|
. network::speed($member->d_ceil);
|
|||
$rate = network::speed($member->u_rate) . '/'
|
|||
. network::speed($member->d_rate);
|
|||
$qos_ceil = network::speed_size($ceil,"M");
|
|||
$qos_rate = network::speed_size($rate,"M");
|
|||
| 8baed187 | Michal Kliment | ||
$total_upload_rate += $qos_rate['upload'];
|
|||
$total_download_rate += $qos_rate['download'];
|
|||
$members_data[$i] = array
|
|||
(
|
|||
"id" => $i,
|
|||
"upload_ceil" => num::decimal_point($qos_ceil['upload'])."M",
|
|||
"download_ceil" => num::decimal_point($qos_ceil['download'])."M",
|
|||
"upload_rate" => num::decimal_point($qos_rate['upload'])."M",
|
|||
"download_rate" => num::decimal_point($qos_rate['download'])."M",
|
|||
"parent" => self::MEMBERS_QOS_PARENT,
|
|||
"ipset" => "member_".($i-self::MEMBERS_QOS_MEMBERS+1),
|
|||
"priority" => self::MEMBERS_QOS_PRIORITY_NORMAL,
|
|||
"protocol" => self::MEMBERS_QOS_PROTOCOL_ALL
|
|||
);
|
|||
$i++;
|
|||
}
|
|||
// deducts qos rate of member with guaranteed speed from total qos rate
|
|||
if ($members_upload_rate > $total_upload_rate
|
|||
&& $members_download_rate > $total_download_rate)
|
|||
{
|
|||
$members_upload_rate -= $total_upload_rate;
|
|||
$members_download_rate -= $total_download_rate;
|
|||
}
|
|||
// adds line for parent (total qos rate)
|
|||
$data[self::MEMBERS_QOS_PARENT] = array
|
|||
(
|
|||
"id" => self::MEMBERS_QOS_PARENT,
|
|||
"upload_ceil" => $total['upload']."M",
|
|||
"download_ceil" => $total['download']."M",
|
|||
"upload_rate" => $total['upload']."M",
|
|||
"download_rate" => $total['download']."M",
|
|||
"priority" => self::MEMBERS_QOS_PRIORITY_NORMAL,
|
|||
"protocol" => self::MEMBERS_QOS_PROTOCOL_ALL
|
|||
);
|
|||
// adds line for ordinary members
|
|||
$data[self::MEMBERS_QOS_ORDINARY] = array
|
|||
(
|
|||
"id" => self::MEMBERS_QOS_ORDINARY,
|
|||
"upload_ceil" => "0M",
|
|||
"download_ceil" => "0M",
|
|||
"upload_rate" => num::decimal_point($members_upload_rate)."M",
|
|||
"download_rate" => num::decimal_point($members_download_rate)."M",
|
|||
"parent" => self::MEMBERS_QOS_PARENT,
|
|||
"priority" => self::MEMBERS_QOS_PRIORITY_NORMAL,
|
|||
"protocol" => self::MEMBERS_QOS_PROTOCOL_ALL
|
|||
);
|
|||
// ulogd is enabled
|
|||
if (Settings::get('ulogd_enabled'))
|
|||
{
|
|||
// adds line for active members
|
|||
$data[self::MEMBERS_QOS_ACTIVE] = array
|
|||
(
|
|||
"id" => self::MEMBERS_QOS_ACTIVE,
|
|||
"upload_ceil" => "0M",
|
|||
"download_ceil" => "0M",
|
|||
"upload_rate" => $active['upload']."M",
|
|||
"download_rate" => $active['download']."M",
|
|||
"parent" => self::MEMBERS_QOS_PARENT,
|
|||
"ipset" => "active",
|
|||
"priority" => self::MEMBERS_QOS_PRIORITY_NORMAL,
|
|||
"protocol" => self::MEMBERS_QOS_PROTOCOL_ALL
|
|||
);
|
|||
}
|
|||
$data[self::MEMBERS_QOS_HIGH_PRIORITY] = array
|
|||
(
|
|||
"id" => self::MEMBERS_QOS_HIGH_PRIORITY,
|
|||
"upload_ceil" => "0M",
|
|||
"download_ceil" => "0M",
|
|||
"upload_rate" => "10M",
|
|||
"download_rate" => "10M",
|
|||
"parent" => self::MEMBERS_QOS_PARENT,
|
|||
"priority" => self::MEMBERS_QOS_PRIORITY_HIGH,
|
|||
"protocol" => self::MEMBERS_QOS_PROTOCOL_ALL,
|
|||
"ipset" => "priority"
|
|||
);
|
|||
// adds lines with qos rates of member with guaranteed speed
|
|||
$data = arr::merge($data, $members_data);
|
|||
// definition of columns
|
|||
$columns = array
|
|||
(
|
|||
"id",
|
|||
"upload_ceil",
|
|||
"download_ceil",
|
|||
"upload_rate",
|
|||
"download_rate",
|
|||
"priority",
|
|||
"protocol",
|
|||
"parent",
|
|||
"ipset"
|
|||
);
|
|||
echo text::print_in_columns($data, $columns);
|
|||
// set state of module (last activation time)
|
|||
Settings::set('qos_state', date('Y-m-d H:i:s'));
|
|||
}
|
|||
/**
|
|||
* Prints ip addresses of members with guaranteed speed
|
|||
*
|
|||
* @author Michal Kliment
|
|||
* @return type
|
|||
*/
|
|||
public function ip_addresses_qos_ceil_rate()
|
|||
{
|
|||
| c1bdc1c4 | Michal Kliment | // only enabled if IP address that requested for this page is from
|
|
// one of allowed ranges in the FreenetIS
|
|||
if (!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | // qos is not enabled, we ends
|
|
if (!Settings::get('qos_enabled'))
|
|||
return;
|
|||
$data = array();
|
|||
if (Settings::get('ulogd_enabled'))
|
|||
{
|
|||
$ips = ORM::factory('member')->get_active_traffic_members_ip_addresses(date('Y-m-d'));
|
|||
foreach ($ips as $ip)
|
|||
{
|
|||
$data[] = array
|
|||
(
|
|||
"id" => self::MEMBERS_QOS_ACTIVE,
|
|||
"ip_address" => $ip->ip_address
|
|||
);
|
|||
}
|
|||
}
|
|||
foreach (explode(",", Settings::get('qos_high_priority_ip_addresses'))
|
|||
as $qos_high_priority_ip_address)
|
|||
{
|
|||
$data[] = array
|
|||
(
|
|||
"id" => self::MEMBERS_QOS_HIGH_PRIORITY,
|
|||
"ip_address" => $qos_high_priority_ip_address
|
|||
);
|
|||
}
|
|||
$ip_addresses = ORM::factory('ip_address')->get_ip_addresses_qos_ceil_rate();
|
|||
$i = self::MEMBERS_QOS_MEMBERS-1;
|
|||
$member_id = 0;
|
|||
foreach ($ip_addresses as $ip_address)
|
|||
{
|
|||
if ($ip_address->member_id != $member_id)
|
|||
{
|
|||
$i++;
|
|||
$member_id = $ip_address->member_id;
|
|||
}
|
|||
$data[] = array
|
|||
(
|
|||
"id" => $i,
|
|||
"ip_address" => $ip_address->ip_address
|
|||
);
|
|||
}
|
|||
// definition of columns
|
|||
$columns = array ("id", "ip_address");
|
|||
echo text::print_in_columns($data, $columns);
|
|||
// set state of module (last activation time)
|
|||
Settings::set('qos_state', date('Y-m-d H:i:s'));
|
|||
}
|
|||
/**
|
|||
* Prints all IP addresses of hosts to monitored
|
|||
*
|
|||
* @author Michal Kliment
|
|||
* @param type $priority
|
|||
*/
|
|||
public function monitoring_hosts($priority = NULL)
|
|||
{
|
|||
if (!Settings::get('monitoring_enabled') ||
|
|||
(server::remote_addr() != Settings::get('monitoring_server_ip_address')))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
$monitor_host_model = new Monitor_host_Model();
|
|||
$hosts = $monitor_host_model->get_all_monitored_hosts($priority);
|
|||
foreach ($hosts as $host)
|
|||
{
|
|||
echo $host->ip_address."\n";
|
|||
}
|
|||
// set state of module (last activation time)
|
|||
Settings::set('monitoring_state', date('Y-m-d H:i:s'));
|
|||
}
|
|||
/**
|
|||
* Sets states of monitored hosts
|
|||
*
|
|||
* @author Michal Kliment
|
|||
* @return type
|
|||
*/
|
|||
public function monitoring_states()
|
|||
| c1bdc1c4 | Michal Kliment | {
|
|
| 8baed187 | Michal Kliment | if (!Settings::get('monitoring_enabled') ||
|
|
(server::remote_addr() != Settings::get('monitoring_server_ip_address')))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
$ips = $this->input->post('ip');
|
|||
$states = $this->input->post('state');
|
|||
$lats = $this->input->post('lat');
|
|||
$monitor_host_model = new Monitor_host_Model();
|
|||
if (is_array($ips) && is_array($states) && is_array($lats))
|
|||
{
|
|||
foreach ($ips as $i => $ip)
|
|||
{
|
|||
if (isset($states[$i]) && isset($lats[$i]))
|
|||
$monitor_host_model->update_host($ip, Monitor_host_Model::get_state($states[$i]), $lats[$i]);
|
|||
}
|
|||
// set state of module (last activation time)
|
|||
Settings::set('monitoring_state', date('Y-m-d H:i:s'));
|
|||
}
|
|||
}
|
|||
/**
|
|||
| c1bdc1c4 | Michal Kliment | * Configuration for Prometheus QoS utility.
|
|
* This configuration does not includes handlind of upload values of speed,
|
|||
* it takes just download.
|
|||
| 8baed187 | Michal Kliment | *
|
|
| c1bdc1c4 | Michal Kliment | * @author Ondřej Fibich
|
|
* @see http://freecode.com/projects/prometheus-qos
|
|||
| 8baed187 | Michal Kliment | */
|
|
| c1bdc1c4 | Michal Kliment | public function qos_prometheus()
|
|
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | // only enabled if IP address that requested for this page is from
|
|
// one of allowed ranges in the FreenetIS
|
|||
if (!network::ip_address_in_ranges(server::remote_addr()))
|
|||
{
|
|||
@header('HTTP/1.0 403 Forbidden');
|
|||
die();
|
|||
}
|
|||
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | $speed_class_model = new Speed_class_Model();
|
|
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | echo "# Prometheus QoS configuration\n";
|
|
echo "# generated on " . date('Y-m-d H:i:s') . "\n";
|
|||
echo "# FreenetIS " . Version::get_version() . "\n\n";
|
|||
$speed_classes = $speed_class_model->orderby('d_ceil', 'DESC')->find_all();
|
|||
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | foreach ($speed_classes as $speed_class)
|
|
{
|
|||
echo "\n######## $speed_class->name ################################\n";
|
|||
$ips = $speed_class_model->get_ip_addresses_to_class($speed_class->id);
|
|||
$last_member_id = NULL;
|
|||
$last_id = NULL;
|
|||
foreach ($ips as $ip)
|
|||
{
|
|||
// last two parts of IP address
|
|||
$ip_end = mb_substr($ip->ip_address, mb_strpos(
|
|||
$ip->ip_address, '.',
|
|||
mb_strpos($ip->ip_address, '.') + 1
|
|||
) + 1);
|
|||
// first row
|
|||
if ($last_id === NULL)
|
|||
| 8baed187 | Michal Kliment | {
|
|
| c1bdc1c4 | Michal Kliment | $last_id = "$ip->user_login.$ip_end";
|
|
| 8baed187 | Michal Kliment | }
|
|
| c1bdc1c4 | Michal Kliment | echo "$ip->ip_address\t$ip->user_login.$ip_end\t\t";
|
|
| 8baed187 | Michal Kliment | ||
| c1bdc1c4 | Michal Kliment | // group same member by comments
|
|
if ($last_member_id != $ip->member_id)
|
|||
{
|
|||
$min = intval($speed_class->d_rate / 1024); // convert B => kB
|
|||
$max = intval($speed_class->d_ceil / 1024); // convert B => kB
|
|||
echo "#via-prometheus-$min-$max\n";
|
|||
// change member values
|
|||
$last_member_id = $ip->member_id;
|
|||
$last_id = "$ip->user_login.$ip_end";
|
|||
}
|
|||
else
|
|||
{
|
|||
echo "#sharing-$last_id\n";
|
|||
}
|
|||
}
|
|||
| 8baed187 | Michal Kliment | }
|
|
}
|
|||
| c1bdc1c4 | Michal Kliment | ||
| 8baed187 | Michal Kliment | }
|