kienan
/
AlternC
mirror of https://github.com/kienanstewart/AlternC.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Remote control plus générique 

Multi mysql serveur compliant :)
This commit is contained in:
Alan Garcia 2013-04-22 13:37:48 +00:00
parent c1d2971463
commit c5357f6be2
2 changed files with 108 additions and 104 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bureau/admin/vm.php
View File

@ -61,10 +61,13 @@ include_once("head.php");
echo "<table class='tedit'>"; echo "<table class='tedit'>";
echo "<tr><th>"._("Hostname")."</th><td>".$infos['serialized_object']['hostname']."</td></tr>"; echo "<tr><th>"._("Hostname")."</th><td>".$infos['serialized_object']['hostname']."</td></tr>";
echo "<tr><th>"._("Start time")."</th><td>".$infos['date_start']."</td></tr>"; echo "<tr><th>"._("Start time")."</th><td>".$infos['date_start']."</td></tr>";
echo "<tr><th>"._("Usefull command")."</th><td><pre>";
echo "ssh ".$mem->user['login']."@".$infos['serialized_object']['hostname']."\n";
echo "rsync ".$mem->user['login']."@".$infos['serialized_object']['hostname']."\n";
echo "</pre></td></tr>";
echo "<tr><td colspan='2'><a href='vm.php?action=stop'>"._("Click here to stop the machine")."</a></td></tr>"; echo "<tr><td colspan='2'><a href='vm.php?action=stop'>"._("Click here to stop the machine")."</a></td></tr>";
echo "</table>"; echo "</table>";
} // empty infos ?> } // empty infos ?>
</div> </div>

207
bureau/class/m_lxc.php
View File

@ -38,120 +38,121 @@ class m_lxc implements vm
} }
private function sendMessage($action, $user = FALSE, $password=FALSE, $uid=FALSE) private function sendMessage($params) {
{ $fp = fsockopen($this->IP, $this->PORT, $errno, $errstr, $this->TIMEOUT);
$fp = fsockopen($this->IP, $this->PORT, $errno, $errstr, $this->TIMEOUT); if (!$fp)
if (!$fp) {
{ $this->error[] = 'Unable to connect';
$this->error[] = 'Unable to connect'; return FALSE;
return FALSE; }
}
$msg = sprintf("%s|%s|%s|%d\n", $action, $user, $password, $uid); $msg = sprintf("%s\n", serialize($params) );
if (fwrite ($fp, $msg) < 0) if (fwrite ($fp, $msg) < 0)
{ {
$this->error[] = 'Unable to send data'; $this->error[] = 'Unable to send data';
return FALSE; return FALSE;
} }
$resp = ''; $resp = '';
#while (($resp .= fgets($fp, 4096)) !== FALSE); #while (($resp .= fgets($fp, 4096)) !== FALSE);
$resp = fgets($fp, 4096); $resp = fgets($fp, 4096);
fclose ($fp); fclose ($fp);
return $resp;
if (stripos($resp, 'error') > 0)
{
$data = unserialize($resp);
$this->error[] = $data['msg'];
return FALSE;
}
else
{
return $resp;
}
}
public function start($login = FALSE, $pass = FALSE, $uid = FALSE)
{
global $mem, $db, $err, $mysql;
if ($this->getvm() !== FALSE)
{
$err->raise('lxc', _('VM already started'));
return FALSE;
}
$login = $login ? $login : $mem->user['login'];
$pass = $pass ? $pass : $mem->user['pass'];
$uid = $uid ? $uid : $mem->user['uid'];
$msgg = array('action'=>'start', 'login'=>$login, 'pass' => $pass, 'uid'=> $uid);
$msgg['mysql_host'] = $mysql->dbus->Host;
$res = $this->sendMessage($msgg);
if ($res === FALSE)
return $this->error;
else
{
$data = unserialize($res);
$error = $data['error'];
$hostname = $data['hostname'];
$msg = $data['msg'];
$date_start = 'NOW()';
$uid = $mem->user['uid'];
if ((int)$data['error'] != 0)
{
$err->raise('lxc', _($data['msg']));
return FALSE;
}
$db->query("INSERT INTO vm_history (ip,date_start,uid,serialized_object) VALUES ('$hostname', $date_start, '$uid', '$res')");
return $res;
}
}
return $resp; public function monit()
{
if (stripos($resp, 'error') > 0) echo "1 / 5 used ";
{ }
$data = unserialize($resp);
$this->error[] = $data['msg'];
return FALSE;
}
else
{
return $resp;
}
}
public function start($login = FALSE, $pass = FALSE, $uid = FALSE) public function getvm()
{ {
global $db, $mem;
global $mem, $db, $err;
if ($this->getvm() !== FALSE) $uid = $mem->user['uid'];
{ $res = array();
$err->raise('lxc', _('VM already started'));
return FALSE;
}
$user = $login ? $login : $mem->user['login']; $res = $db->query("SELECT * FROM vm_history WHERE date_end IS NULL AND uid= '$uid' ORDER BY id DESC LIMIT 1");
$pass = $pass ? $pass : $mem->user['pass'];
$uid = $uid ? $uid : $mem->user['uid'];
$res = $this->sendMessage('start', $user, $pass, $uid); if ($db->next_record())
if ($res === FALSE) {
return $this->error; $db->Record['serialized_object'] = unserialize($db->Record['serialized_object']);
else return $db->Record;
{ }
$data = unserialize($res); else
$error = $data['error']; return FALSE;
$hostname = $data['hostname']; }
$msg = $data['msg'];
$date_start = 'NOW()';
$uid = $mem->user['uid'];
if ((int)$data['error'] != 0) public function stop()
{ {
$err->raise('lxc', _($data['msg'])); global $db, $mem;
return FALSE;
}
$db->query("INSERT INTO vm_history (ip,date_start,uid,serialized_object) VALUES ('$hostname', $date_start, '$uid', '$res')"); $vm = $this->getvm();
return $res; if ($vm === FALSE)
} return TRUE;
}
$vm_id = $vm['serialized_object']['vm'];
$uid = $mem->user['uid'];
$vid = $vm['id'];
public function monit() if ($this->sendMessage(array('action' => 'stop', 'vm' => $vm_id)) === FALSE)
{ return FALSE;
echo "1 / 5 used ";
}
public function getvm() return $db->query("UPDATE vm_history SET date_end = NOW() WHERE uid = '$uid' AND id = '$vid' LIMIT 1");
{ }
global $db, $mem;
$uid = $mem->user['uid'];
$res = array();
$res = $db->query("SELECT * FROM vm_history WHERE date_end IS NULL AND uid= '$uid' ORDER BY id DESC LIMIT 1");
if ($db->next_record())
{
$db->Record['serialized_object'] = unserialize($db->Record['serialized_object']);
return $db->Record;
}
else
return FALSE;
}
public function stop()
{
global $db, $mem;
$vm = $this->getvm();
if ($vm === FALSE)
return TRUE;
$vm_id = $vm['serialized_object']['vm'];
$uid = $mem->user['uid'];
$vid = $vm['id'];
if ($this->sendMessage('stop', $vm_id, FALSE, FALSE) === FALSE)
return FALSE;
return $db->query("UPDATE vm_history SET date_end = NOW() WHERE uid = '$uid' AND id = '$vid' LIMIT 1");
}
} }