[dnbd3] New module for managing dnbd3 servers - WIP

1 files changed, 96 insertions, 0 deletions

diff --git a/modules-available/dnbd3/page.inc.php b/modules-available/dnbd3/page.inc.php
new file mode 100644
index 00000000..309680a6
--- /dev/null
+++ b/modules-available/dnbd3/page.inc.php
@@ -0,0 +1,96 @@
+<?php
+
+class Page_Dnbd3 extends Page
+{
+
+	protected function doPreprocess()
+	{
+		User::load();
+
+		if (!User::isLoggedIn()) {
+			Message::addError('main.no-permission');
+			Util::redirect('?do=Main');
+		}
+		if (Request::post('re')) {
+			Dnbd3Util::updateServerStatus();
+			Util::redirect('?do=dnbd3');
+		}
+	}
+
+	protected function doRender()
+	{
+		$show = Request::get('show', false, 'string');
+		if ($show === 'clients') {
+			$this->showClientList();
+		} elseif ($show === false) {
+			$this->showServerList();
+		} else {
+			Util::redirect('?do=dnbd3');
+		}
+	}
+
+	private function showServerList()
+	{
+		$dynClients = RunMode::getForMode(Page::getModule(), 'proxy', true, true);
+		$res = Database::simpleQuery('SELECT serverid, machineuuid, fixedip, lastseen, uptime, totalup, totaldown, clientcount FROM dnbd3_server');
+		$servers = array();
+		$sort = array();
+		$NOW = time();
+		while ($server = $res->fetch(PDO::FETCH_ASSOC)) {
+			if (isset($dynClients[$server['machineuuid']])) {
+				$server += $dynClients[$server['machineuuid']];
+				unset($dynClients[$server['machineuuid']]);
+			}
+			if ($server['uptime'] != 0) {
+				$server['uptime'] += ($NOW - $server['lastseen']);
+			}
+			$server['lastseen_s'] = $server['lastseen'] ? date('d.m.Y H:i', $server['lastseen']) : '-';
+			$server['uptime_s'] = $server['uptime'] ? floor($server['uptime'] / 86400) . 'd ' . gmdate('H:i', $server['uptime']) : '-';
+			$server['totalup_s'] = Util::readableFileSize($server['totalup']);
+			$server['totaldown_s'] = Util::readableFileSize($server['totaldown']);
+			$servers[] = $server;
+			$sort[] = $server['fixedip'] . '.' . $server['machineuuid'];
+		}
+		foreach ($dynClients as $server) {
+			$servers[] = $server;
+			$sort[] = 'A' . $server['machineuuid'];
+		}
+		array_multisort($sort, SORT_ASC, $servers);
+		Render::addTemplate('page-serverlist', array('list' => $servers));
+	}
+
+	private function showClientList()
+	{
+		$serverId = Request::get('server', false, 'int');
+		if ($serverId === false) {
+			// TODO: Missing param
+		}
+		$server = Database::queryFirst('SELECT s.machineuuid, s.fixedip, m.clientip, m.hostname
+			FROM dnbd3_server s
+			LEFT JOIN machine m USING (machineuuid)
+			WHERE s.serverid = :serverId', compact('serverId'));
+		if ($server === false) {
+			// TODO: Not found
+		}
+		if (!is_null($server['clientip'])) {
+			$ip = $server['clientip'];
+		} elseif (!is_null($server['fixedip'])) {
+			$ip = $server['fixedip'];
+		} else {
+			$ip = '127.0.0.1';
+		}
+		$data = Dnbd3Rpc::query(false, true, false, $ip);
+		if ($data === false || !isset($data['clients'])) {
+			Message::addError('server-unreachable');
+		} else {
+			$sort = array();
+			foreach ($data['clients'] as &$c) {
+				$c['bytesSent_s'] = Util::readableFileSize($c['bytesSent']);
+				$sort[] = $c['bytesSent'];
+			}
+			array_multisort($sort, SORT_DESC, $data['clients']);
+			Render::addTemplate('page-clientlist', $data);
+		}
+	}
+
+}