github-personal/control-pane
1
0
Fork 0
mirror of https://github.com/outbackdingo/control-pane.git synced 2026-02-06 17:20:23 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
ddff7b3ba505843bf679da753fa7ce0d4b7da383
control-pane/php/clonos.php
olevole ddff7b3ba5 wip
2017-01-28 21:43:33 +03:00

1508 lines
43 KiB
PHP
Raw Blame History

<?php
//include_once($_REALPATH.'/forms.php');
class ClonOS
{
public $workdir='';
public $realpath_php='';
public $realpath_public='';
public $realpath_page='';
public $json_name='';
public $language='en';
public $language_file_loaded=false;
public $translate_arr=array();
public $table_templates=array();
private $_post=false;
private $_db=null;
private $_client_ip='';
private $_dialogs=array();
private $_cmd_array=array('jcreate','jstart','jstop','jrestart','jedit','jremove','jexport','jimport','jclone','madd','sstart','sstop','projremove','bcreate','bstart','bstop','brestart','bremove','vm_obtain','removesrc','srcup','removebase','world','repo');
/*
public $projectId=0;
public $jailId=0;
public $moduleId=0;
public $helper='';
public $mode='';
public $form='';
private $_vars=array();
private $_db_tasks=null;
private $_db_jails=null;
*/
const CBSD_CMD='env NOCOLOR=1 /usr/local/bin/sudo /usr/local/bin/cbsd ';
function cbsd_cmd($cmd)
{
$descriptorspec = array(
0 => array('pipe','r'),
1 => array('pipe','w'),
2 => array('pipe','r')
);
$process = proc_open(self::CBSD_CMD.trim($cmd),$descriptorspec,$pipes,null,null);
$full_cmd=self::CBSD_CMD.trim($cmd);
$error=false;
$error_message='';
$message='';
if (is_resource($process))
{
$buf=stream_get_contents($pipes[1]);
$buf0=stream_get_contents($pipes[0]);
$buf1=stream_get_contents($pipes[2]);
fclose($pipes[0]);
fclose($pipes[1]);
fclose($pipes[2]);
$task_id=-1;
$return_value = proc_close($process);
if($return_value!=0)
{
$error=true;
$error_message=$buf;
}else{
$message=trim($buf);
}
return array('cmd'=>$cmd,'full_cmd'=>$full_cmd,'retval'=>$return_value, 'message'=>$message, 'error'=>$error,'error_message'=>$error_message);
}
}
function __construct($_REALPATH) # /usr/home/web/cp/clonos
{
$this->_post=($_SERVER['REQUEST_METHOD']=='POST');
$this->_vars=$_POST;
if(isset($_COOKIE['lang'])) $this->language=$_COOKIE['lang'];
$this->workdir=getenv('WORKDIR');
# // /usr/jails
$this->realpath_php=$_REALPATH.'/php/';
# /usr/home/web/cp/clonos/php/
$this->realpath_public=$_REALPATH.'/public/';
# /usr/home/web/cp/clonos/public/
$translate_filename=$this->realpath_public.'/lang/'.$this->language.'.php';
$translate_filename_alt=$this->realpath_public.'/lang/en.php';
if(file_exists($translate_filename)) $t_filename=$translate_filename; else $t_filename=$translate_filename_alt;
include($t_filename);
$this->translate_arr=$lang;
unset($lang);
unset($t_filename);
$this->_client_ip=$_SERVER['REMOTE_ADDR'];
if(isset($this->_vars['path']))
{
$this->realpath_page=$this->realpath_public.'pages/'.trim($this->_vars['path'],'/').'/';
$this->json_name=$this->realpath_page.'a.json.php';
}else if($_SERVER['REQUEST_URI']){
$this->realpath_page=$this->realpath_public.'pages/'.trim($_SERVER['REQUEST_URI'],'/').'/';
}
// $this->json_name=$this->realpath_php.'pages'
// $clonos->json_name=$file_path.'a.json.php';
include('config.php');
include('db.php');
include('menu.php');
$this->_db_tasks=new Db('base','cbsdtaskd');
$this->_db_local=new Db('base','local');
$this->config=new Config();
$this->menu=new Menu($this->config->menu,$this);
if(isset($this->_vars['mode'])) $this->mode=$this->_vars['mode'];
if(isset($this->_vars['form_data'])) $this->form=$this->_vars['form_data'];
if($this->_post && isset($this->mode))
{
unset($_POST);
switch($this->mode)
{
case 'getTasksStatus':
echo json_encode($this->_getTasksStatus($this->form['jsonObj']));
return;break;
case 'getJsonPage':
if(file_exists($this->json_name)) include($this->json_name); else echo '{}';
return;break;
case 'freejname':
echo json_encode($this->getFreeJname());
break;
case 'jailAdd':
echo json_encode($this->jailAdd());
return;break;
case 'jailEdit':
echo json_encode($this->jailEdit());
return;break;
case 'jailEditVars':
echo json_encode($this->jailEditVars());
return;break;
case 'bhyveAdd':
echo json_encode($this->bhyveAdd());
return;break;
case 'bhyveEdit':
echo json_encode($this->bhyveEdit());
return;break;
case 'bhyveEditVars':
echo json_encode($this->bhyveEditVars());
return;break;
case 'bhyveObtain':
echo json_encode($this->bhyveObtain());
return;break;
case 'authkeyAdd':
echo json_encode($this->authkeyAdd());
return;break;
case 'authkeyRemove':
echo json_encode($this->authkeyRemove());
return;break;
case 'vpnetAdd':
echo json_encode($this->vpnetAdd());
return;break;
case 'vpnetRemove':
echo json_encode($this->vpnetRemove());
return;break;
case 'mediaAdd':
//echo json_encode($this->mediaAdd());
return;break;
case 'mediaRemove':
echo json_encode($this->mediaRemove());
return;break;
case 'logLoad':
echo json_encode($this->logLoad());
return;break;
case 'logFlush':
echo json_encode($this->logFlush());
return;break;
case 'basesCompile':
echo json_encode($this->basesCompile());
return;break;
case 'repoCompile':
echo json_encode($this->repoCompile());
return;break;
}
}
return;
//echo base64_encode(file_get_contents($rp.'/images/tree-minus.gif'));exit;
if(substr($rp,-7)=='/webdev')
{
$this->realpath=substr($rp,0,-7);
}else{
$this->realpath=$rp;
}
include_once($this->realpath.'/db.php');
$this->_db=new Db('sqlite_webdev');
$this->_db_tasks=new Db('sqlite_cbsd','tasks');
$this->_db_jails=new Db('sqlite_cbsd','jails');
$this->_post=($_SERVER['REQUEST_METHOD']=='POST');
if(isset($_POST['groupsUpdate'])) return;
if($this->_post)
{
$this->_vars=$_POST;
unset($_POST);
$this->projectId=intval($this->_vars['project']);
$this->jailId=intval($this->_vars['jail']);
$this->moduleId=intval($this->_vars['module']);
if(isset($this->_vars['helper']))
$this->helper=$this->_vars['helper'];
$this->mode=$this->_vars['mode'];
if(isset($this->_vars['form_data'])) $this->form=$this->_vars['form_data'];
switch($this->mode)
{
case 'getProjectsList':
$projects=$this->getProjectsList();
echo json_encode(array('projects'=>$projects));
return;break;
case 'getJailsList':
$projects=$this->getProjectsList();
$jails=$this->getJailsList();
echo json_encode(array('jails'=>$jails,'projects'=>$projects));
return;break;
case 'getModulesList':
$jails=$this->getJailsList();
$modules=$this->getModulesList();
echo json_encode(array('jails'=>$jails,'modules'=>$modules));
return;break;
case 'getModuleSettings':
$modules=$this->getModulesList();
$settings=$this->getModuleSettings();
echo json_encode(array('modules'=>$modules,'settings'=>$settings));
return;break;
case 'getHelpersList':
$jails=$this->getJailsList();
$helpers=$this->getHelpersList();
echo json_encode(array('jails'=>$jails,'helpers'=>$helpers));
return;break;
case 'getHelper':
//$jails=$this->getJailsList();
$modules=$this->getHelpersList();
$helper=$this->getHelper();
echo json_encode(array('modules'=>$modules,'helpers'=>$helper));
return;break;
case 'installHelper':
$res=$this->installHelper();
$modules=$this->getHelpersList();
$helper=$this->getHelper();
echo json_encode(array('modules'=>$modules,'helpers'=>$helper,'res'=>$res));
return;break;
case 'saveHelperValues':
$res=$this->saveHelperValues();
echo json_encode($res);
return;break;
case 'getServicesList':
$jails=$this->getJailsList();
$services=$this->getServicesList();
echo json_encode(array('jails'=>$jails,'services'=>$services));
return;break;
case 'getUsersList':
$jails=$this->getJailsList();
$users=$this->getUsersList();
echo json_encode(array('jails'=>$jails,'users'=>$users));
return;break;
case 'getModulesListForInstall':
//$this->updateCountsModules();
$modules=$this->getModulesListForInstallHtml();
echo json_encode(array('html'=>$modules));
return;break;
/*
case 'getInstalledModulesList':
$jails=$this->getJailsList();
$modules=$this->getInstalledModules();
echo json_encode(array('jails'=>$jails,'html'=>$modules));
return;break;
*/
case 'addProject':
echo json_encode($this->projectAdd());
return;break;
case 'editProject':
echo json_encode($this->projectEdit());
return;break;
case 'addJail':
echo json_encode($this->addJail());
return;break;
case 'editJail':
echo json_encode($this->editJail());
return;break;
/*
case 'jailClone':
echo json_encode($this->jailClone());
return;break;
*/
/*
case 'addModule':
$this->addModule();
return;break;
*/
/*
case 'removeModules':
$this->removeModules();
return;break;
*/
case 'jailStart':
echo json_encode($this->jailStart($this->form['jail_name']));
return;break;
case 'getTasksStatus':
echo json_encode($this->_getTasksStatus($this->form['jsonObj']));
return;break;
case 'getJailSettings':
echo json_encode($this->getJailSettings($this->form['id']));
return;break;
case 'getExportedFiles':
echo json_encode($this->getExportedFiles());
return;break;
case 'getImportedFileInfo':
echo json_encode($this->getImportedFileInfo($this->form));
return;break;
case 'addNewUser':
$new_user=$this->addNewUser($this->form);
$jails=$this->getJailsList();
$users=$this->getUsersList();
echo json_encode(array('jails'=>$jails,'users'=>$users,'new_user'=>$new_user));
return;break;
case 'editUser':
$edit_user=$this->editUser($this->form);
$user=array();
$jails=$this->getJailsList();
$users=$this->getUsersList();
echo json_encode(array('jails'=>$jails,'users'=>$users,'new_user'=>$edit_user));
return;break;
case 'getTaskLog':
$jails=$this->getJailsList();
$log=$this->getTaskLog();
echo json_encode(array('jails'=>$jails,'tasklog'=>$log));
return;break;
case 'getTaskLogItem':
$jails=$this->getJailsList();
$item=$this->getTaskLogItem();
echo json_encode(array('jails'=>$jails,'item'=>$item));
return;break;
case 'getForm':
$res=$this->getForm();
echo json_encode($res);
return;break;
}
}
}
function getLang()
{
return $this->language;
}
function translate($phrase)
{
if(isset($this->translate_arr[$phrase]))
return $this->translate_arr[$phrase];
else
return $phrase;
}
function getTableChunk($table_name='',$tag)
{
if(empty($table_name)) return false;
if(isset($this->table_templates[$table_name][$tag])) return $this->table_templates[$table_name][$tag];
$file_name=$this->realpath_page.$table_name.'.table';
if(!file_exists($file_name)) return false;
$file=file_get_contents($file_name);
$pat='#[\s]*?<'.$tag.'[^>]*>(.*)<\/'.$tag.'>#iUs';
if(preg_match($pat,$file,$res))
{
$this->table_templates[$table_name][$tag]=$res;
return $res;
}
}
function check_locktime($nodeip)
{
$lockfile=$this->workdir."/ftmp/shmux_${nodeip}.lock";
if (!file_exists($lockfile)) {
return 0;
}
$cur_time = time();
$st_time=filemtime($lockfile);
$difftime=(( $cur_time - $st_time ) / 60 );
if ( $difftime > 1 ) {
return round($difftime);
} else {
return 0; //lock exist but too fresh
}
}
function check_vmonline($vm)
{
$vmmdir="/dev/vmm";
if(!file_exists($vmmdir)) return 0;
if($handle=opendir($vmmdir))
{
while(false!==($entry=readdir($handle)))
{
if($entry[0]==".") continue;
if($vm==$entry) return 1;
}
closedir($handle);
}
return 0;
}
/* function get_node_info($nodename,$value)
{
$db = new SQLite3($this->realpath."/var/db/nodes.sqlite"); $db->busyTimeout(5000);
if (!$db) return;
$sql = "SELECT $value FROM nodelist WHERE nodename=\"$nodename\"";
$result = $db->query($sql);//->fetchArray(SQLITE3_ASSOC);
$row = array();
while($res = $result->fetchArray(SQLITE3_ASSOC)){
if(!isset($res["$value"])) return;
return $res["$value"];
}
} */
function getRunningTasks($ids=array())
{
$check_arr=array(
'jcreate'=>'Creating',
'jstart'=>'Starting',
'jstop'=>'Stopping',
'jrestart'=>'Restarting',
'jremove'=>'Removing',
'jexport'=>'Exporting',
'jclone'=>'Cloning',
'bcreate'=>'Creating',
'bstart'=>'Starting',
'bstop'=>'Stopping',
'brestart'=>'Restarting',
'bremove'=>'Removing',
'vm_obtain'=>'Creating',
'removesrc'=>'Removing',
'srcup'=>'Updating',
'removebase'=>'Removing',
'world'=>'Compiling',
'repo'=>'Fetching',
);
$res=array();
if(!empty($ids))
{
$tid=join("','",$ids);
$query="select id,cmd,status,jname from taskd where status<2 and jname in ('{$tid}')";
//echo $query;
$tasks=$this->_db_tasks->select($query);
if(!empty($tasks)) foreach($tasks as $task)
{
$rid=preg_replace('/^#/','',$task['jname']);
foreach($check_arr as $key=>$val)
{
if(strpos($task['cmd'],$key)!==false)
{
$cmd=$key;
$txt_status=$val;
break;
}
}
$res[$rid]['status']=$task['status'];
$res[$rid]['task_cmd']=$cmd;
$res[$rid]['txt_status']=$txt_status;
$res[$rid]['task_id']=$task['id'];
}
return $res;
}
return null;
}
/*
function getProjectsListOnStart()
{
$query='select * from projects';
$res=$this->_db->select($query);
echo ' var projects=',json_encode($res),PHP_EOL;
}
*/
/*
function getTaskStatus($task_id)
{
$status=$this->_db_tasks->selectAssoc("select status,logfile,errcode from taskd where id='{$task_id}'");
if($status['errcode']>0)
{
$status['errmsg']=file_get_contents($status['logfile']);
}
return $status;
}
*/
function _getTasksStatus($jsonObj)
{
$tasks=array();
$obj=json_decode($jsonObj,true);
if(isset($obj['proj_ops'])) return $this->GetProjectTasksStatus($obj);
if(isset($obj['mod_ops'])) return $this->GetModulesTasksStatus($obj);
$ops_array=$this->_cmd_array;
$stat_array=array(
'jcreate'=>array($this->translate('Creating'),$this->translate('Created')),
'jstart'=>array($this->translate('Starting'),$this->translate('Launched')),
'jstop'=>array($this->translate('Stopping'),$this->translate('Stopped')),
'jrestart'=>array($this->translate('Restarting'),$this->translate('Restarted')),
'jedit'=>array($this->translate('Saving'),$this->translate('Saved')),
'jremove'=>array($this->translate('Removing'),$this->translate('Removed')),
'jexport'=>array($this->translate('Exporting'),$this->translate('Exported')),
'jimport'=>array($this->translate('Importing'),$this->translate('Imported')),
'jclone'=>array($this->translate('Cloning'),$this->translate('Cloned')),
'madd'=>array($this->translate('Installing'),$this->translate('Installed')),
//'mremove'=>array('Removing','Removed'),
'sstart'=>array($this->translate('Starting'),$this->translate('Started')),
'sstop'=>array($this->translate('Stopping'),$this->translate('Stopped')),
'vm_obtain'=>array($this->translate('Creating'),$this->translate('Created')),
'srcup'=>array($this->translate('Updating'),$this->translate('Updated')),
'world'=>array($this->translate('Compiling'),$this->translate('Compiled')),
'repo'=>array($this->translate('Fetching'),$this->translate('Fetched')),
//'projremove'=>array('Removing','Removed'),
);
$stat_array['bcreate']=&$stat_array['jcreate'];
$stat_array['bstart']=&$stat_array['jstart'];
$stat_array['bstop']=&$stat_array['jstop'];
$stat_array['brestart']=&$stat_array['jrestart'];
$stat_array['bremove']=&$stat_array['jremove'];
$stat_array['removesrc']=&$stat_array['jremove'];
$stat_array['removebase']=&$stat_array['jremove'];
if(!empty($obj)) foreach($obj as $key=>$task)
{
$op=$task['operation'];
$status=$task['status'];
if(in_array($op,$ops_array))
{
$res=false;
if($status==-1)
{
switch($op)
{
case 'jstart': $res=$this->jailStart($key);break;
case 'jstop': $res=$this->jailStop($key);break;
case 'jrestart':$res=$this->jailRestart($key);break;
//case 'jedit': $res=$this->jailEdit('jail'.$key);break;
case 'jremove': $res=$this->jailRemove($key);break;
case 'bstart': $res=$this->bhyveStart($key);break;
case 'bstop': $res=$this->bhyveStop($key);break;
case 'brestart':$res=$this->bhyveRestart($key);break;
case 'bremove': $res=$this->bhyveRemove($key);break;
case 'removesrc': $res=$this->srcRemove($key);break;
case 'srcup': $res=$this->srcUpdate($key);break;
case 'removebase': $res=$this->baseRemove($key);break;
//case 'jexport': $res=$this->jailExport('jail'.$key,$task['jname'],$key);break;
//case 'jimport': $res=$this->jailImport('jail'.$key,$task['jname'],$key);break;
//case 'jclone': $res=$this->jailClone('jail'.$key,$key,$obj[$key]);break;
//case 'madd': $res=$this->moduleAdd('jail'.$key,$task['jname'],$key);break;
////case 'mremove': $res=$this->moduleRemove('jail'.$key,$task['jname'],$key);break;
//case 'sstart': $res=$this->serviceStart($task);break;
//case 'sstop': $res=$this->serviceStop($task);break;
////case 'projremove': $res=$this->projectRemove($key,$task);break;
}
}
if($res!==false)
{
if($res['error'])
$obj[$key]['retval']=$res['retval'];
if(!empty($res['error_message']))
$obj[$key]['error_message']=$res['error_message'];
if(isset($res['message']))
{
$task_id=intval($res['message']);
if($task_id>0)
{
$tasks[]=$task_id;
$obj[$key]['task_id']=$task_id;
//$obj[$key]['txt_log']=file_get_contents('/tmp/taskd.'.$task_id.'.log');
}
}
}else{
$tasks[]=$task['task_id'];
}
}
if($status==-1) $obj[$key]['status']=0;
}
$ids=join(',',$tasks);
if(!empty($ids))
{
$query="select id,status,logfile,errcode from taskd where id in ({$ids})";
$statuses=$this->_db_tasks->select($query);
//print_r($statuses);
if(!empty($obj)) foreach($obj as $key=>$task)
{
if(!empty($statuses)) foreach($statuses as $stat)
{
if($task['task_id']==$stat['id'])
{
$obj[$key]['status']=$stat['status'];
$num=($stat['status']<2?0:1);
$obj[$key]['txt_status']=$stat_array[$obj[$key]['operation']][$num];
if($stat['errcode']>0)
{
$obj[$key]['errmsg']=file_get_contents($stat['logfile']);
$obj[$key]['txt_status']=$this->translate('Error');
}
# Возвращаем IP клонированному джейлу, если он был присвоен по DHCP
if($stat['status']==2)
{
switch($task['operation'])
{
case 'jclone':
//$obj[$key]['new_ip']=$this->getJailIpOnJcloneEnd($key);
break;
case 'repo':
$res=$this->fillRepoTr($obj[$key]['jail_id'],true,false);
if(isset($res['html'])) $obj[$key]['new_html']=$res['html'];
break;
case 'srcup':
$res=$this->getSrcInfo($obj[$key]['jail_id']);
if(isset($res['html'])) $obj[$key]['new_html']=$res['html'];
break;
}
}
}
}
}
}
return $obj;
}
function jailAdd()
{
$form=$this->_vars['form_data'];
$err=array();
$arr=array(
'workdir'=>$this->workdir,
'mount_devfs'=>1,
'arch'=>'native',
'mkhostfile'=>1,
'devfs_ruleset'=>4,
'ver'=>'native',
'mount_src'=>0,
'mount_obj'=>0,
'mount_kernel'=>0,
'applytpl'=>1,
'floatresolv'=>1,
'allow_mount'=>1,
'allow_devfs'=>1,
'allow_nullfs'=>1,
'mkhostsfile'=>1,
'pkg_bootstrap'=>0,
'mdsize'=>0,
'runasap'=>0,
'with_img_helpers'=>'',
);
$arr_copy=array('jname','host_hostname','ip4_addr','user_pw_root','interface');
foreach($arr_copy as $a) if(isset($form[$a])) $arr[$a]=$form[$a];
$arr_copy=array('baserw','mount_ports','astart','vnet');
foreach($arr_copy as $a) if(isset($form[$a]) && $form[$a]=='on') $arr[$a]=1; else $arr[$a]=0;
$sysrc=array();
if(isset($form['serv-ftpd'])) $sysrc[]=$form['serv-ftpd'];
if(isset($form['serv-sshd'])) $sysrc[]=$form['serv-sshd'];
$arr['sysrc_enable']=join($sysrc,' ');
/* create jail */
$file_name='/tmp/'.$arr['jname'].'.conf';
$file=file_get_contents($this->realpath_public.'templates/jail.tpl');
if(!empty($file))
{
foreach($arr as $var=>$val)
{
$file=str_replace('#'.$var.'#',$val,$file);
}
}
file_put_contents($file_name,$file);
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd jcreate inter=0 jconf='.$file_name);
$err='Jail is not create!';
$taskId=-1;
if($res['retval']==0)
{
$err='Jail was created!';
$taskId=$res['message'];
}
// local - поменять на реальный сервер, на котором создаётся клетка!
$jid=$arr['jname'];
$html='';
$hres=$this->getTableChunk('jailslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$vars=array(
'nth-num'=>'nth0', // исправить на актуальные данные!
'node'=>'local', // исправить на актуальные данные!
'ip4_addr'=>str_replace(',',',<wbr />',$form['ip4_addr']),
'jname'=>$arr['jname'],
'jstatus'=>$this->translate('Creating'),
'icon'=>'spin6 animate-spin',
'desktop'=>'s-on',
'maintenance'=>' maintenance',
'protected'=>'icon-cancel',
'protitle'=>$this->translate('Delete'),
'vnc_title'=>$this->translate('Open VNC'),
'reboot_title'=>$this->translate('Restart jail'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
return array('errorMessage'=>$err,'jail_id'=>$jid,'taskId'=>$taskId,'html'=>$html,'mode'=>$this->mode);
}
function jailEditVars()
{
$form=$this->_vars['form_data'];
if(!isset($form['jail_id'])) return array('error'=>true,'error_message'=>'Bad jail id!');
$db=new Db('base','local');
if($db!==false)
{
$query="SELECT jname,host_hostname,ip4_addr,allow_mount,interface,mount_ports,astart,vnet FROM jails WHERE jname='{$form['jail_id']}';";
$res['vars']=$db->selectAssoc($query);
}
$res['error']=false;
$res['dialog']=$form['dialog'];
$res['jail_id']=$form['jail_id'];
return $res;
}
function jailEdit()
{
$form=$this->_vars['form_data'];
$str=array();
$jname=$form['jname'];
$arr=array('host_hostname','ip4_addr','allow_mount','interface','mount_ports','astart','vnet');
foreach($arr as $a)
{
if(isset($form[$a]))
{
$val=$form[$a];
if($val=='on') $val=1;
$str[]=$a.'='.$val;
}else{
$str[]=$a.'=0';
}
}
$cmd='jset jname='.$jname.' '.join(' ',$str);
$res=$this->cbsd_cmd($cmd);
$res['mode']='jailEdit';
$res['form']=$form;
return $res;
}
function jailStart($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd jstart inter=0 jname='.$name); // autoflush=2
return $res;
}
function jailStop($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd jstop inter=0 jname='.$name); // autoflush=2
return $res;
}
function jailRestart($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd jrestart inter=0 jname='.$name); // autoflush=2
return $res;
}
function jailRemove($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd jremove inter=0 jname='.$name); // autoflush=2
return $res;
}
function bhyveEditVars()
{
$form=$this->_vars['form_data'];
if(!isset($form['jail_id'])) return array('error'=>true,'error_message'=>'Bad jail id!');
$db=new Db('base','local');
if($db!==false)
{
$query="SELECT b.jname as vm_name,vm_cpus,vm_ram,vm_vnc_port as vnc_port,interface FROM bhyve as b inner join jails as j on b.jname=j.jname and b.jname='{$form['jail_id']}';";
//$query="SELECT jname as vm_name,vm_cpus,vm_ram,vm_vnc_port as vnc_port FROM bhyve WHERE jname='{$form['jail_id']}';";
$res['vars']=$db->selectAssoc($query);
$res['vars']['vm_ram']=$this->fileSizeConvert($res['vars']['vm_ram']);
}
$res['error']=false;
$res['dialog']=$form['dialog'];
$res['jail_id']=$form['jail_id'];
return $res;
}
function bhyveEdit()
{
$form=$this->_vars['form_data'];
$str=array();
$jname=$form['jname'];
$ram=$form['vm_ram'];
$ram_tmp=$ram;
$ram=str_replace(' ','',$ram);
$ram=str_ireplace('mb','m',$ram);
$ram=str_ireplace('gb','g',$ram);
$form['vm_ram']=$ram;
$arr=array('vm_cpus','vm_ram','vnc_port','interface');
foreach($arr as $a)
{
if(isset($form[$a]))
{
$val=$form[$a];
if($val=='on') $val=1;
$str[]=$a.'='.$val;
}else{
$str[]=$a.'=0';
}
}
$form['vm_ram']=$ram_tmp;
$cmd='bset jname='.$jname.' '.join(' ',$str);
$res=$this->cbsd_cmd($cmd);
$res['mode']='bhyveEdit';
$res['form']=$form;
return $res;
}
function bhyveAdd()
{
$form=$this->_vars['form_data'];
$os_types=$this->config->os_types;
$sel_os=$form['vm_os_profile'];
list($os_num,$item_num)=explode('.',$sel_os);
if(!isset($os_types[$os_num])) return array('error'=>true,'errorMessage'=>'Error in list of OS types!');
$os_name=$os_types[$os_num]['os'];
$os_items=$os_types[$os_num]['items'][$item_num];
$err=array();
$arr=array(
'workdir'=>$this->workdir,
'jname'=>$form['vm_name'],
'host_hostname'=>'',
'ip4_addr'=>'',
'arch'=>'native',
'ver'=>'native',
'astart'=>0,
'interface'=>$form['interface'],
'vm_size'=>$form['vm_size'],
'vm_cpus'=>$form['vm_cpus'],
'vm_ram'=>$form['vm_ram'],
'vm_os_type'=>$os_items['type'],
'vm_efi'=>'uefi',
'vm_os_profile'=>$os_items['profile'],
'vm_guestfs'=>'',
);
/* create vm */
$file_name='/tmp/'.$arr['jname'].'.conf';
$file=file_get_contents($this->realpath_public.'templates/vm.tpl');
if(!empty($file))
{
foreach($arr as $var=>$val)
{
$file=str_replace('#'.$var.'#',$val,$file);
}
}
file_put_contents($file_name,$file);
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd bcreate inter=0 jconf='.$file_name);
$err='Virtual Machine is not create!';
$taskId=-1;
if($res['retval']==0)
{
$err='Virtual Machine was created!';
$taskId=$res['message'];
}
// local - поменять на реальный сервер, на котором создаётся клетка!
$jid=$arr['jname'];
$vm_ram=str_replace('g',' GB',$form['vm_ram']);
$html='';
$hres=$this->getTableChunk('bhyveslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$vars=array(
'nth-num'=>'nth0', // исправить на актуальные данные!
'node'=>'local', // исправить на актуальные данные!
'jname'=>$arr['jname'],
'vm_status'=>$this->translate('Creating'),
'vm_cpus'=>$form['vm_cpus'],
'vm_ram'=>$vm_ram,
'vm_os_type'=>$os_items['type'], //$os_name,
'icon'=>'spin6 animate-spin',
'desktop'=>' s-off',
'maintenance'=>' maintenance',
'protected'=>'icon-cancel',
'protitle'=>$this->translate('Delete'),
'vnc_title'=>$this->translate('Open VNC'),
'reboot_title'=>$this->translate('Restart VM'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
return array('errorMessage'=>$err,'jail_id'=>$jid,'taskId'=>$taskId,'html'=>$html,'mode'=>$this->mode);
}
function bhyveObtain()
{
$form=$this->_vars['form_data'];
$os_types=$this->config->os_types;
$sel_os=$form['vm_os_profile'];
list($os_num,$item_num)=explode('.',$sel_os);
if(!isset($os_types[$os_num])) return array('error'=>true,'errorMessage'=>'Error in list of OS types!');
//$os_name=$os_types[$os_num]['os'];
$os_items=$os_types[$os_num]['items'][$item_num];
$os_type=$os_items['type'];
$key_name='/usr/home/olevole/.ssh/authorized_keys';
$key_id=$form['vm_authkey'];
$db=new Db('base','authkey');
$nres=$db->selectAssoc('select name from authkey where idx='.$key_id);
if($nres['name']!==false)
{
$key_name=$nres['name'];
}
$cmd="task owner=cbsdweb mode=new /usr/local/bin/cbsd vm_obtain jname={$form['vm_name']} vm_size={$form['vm_size']} vm_cpus={$form['vm_cpus']} vm_ram={$form['vm_ram']} vm_os_type={$os_type} mask={$form['mask']} ip4_addr={$form['ip4_addr']} gw={$form['gateway']} authkey={$key_name} pw={$form['vm_password']}";
$res=$this->cbsd_cmd($cmd);
$err='Virtual Machine is not create!';
$taskId=-1;
if($res['retval']==0)
{
$err='Virtual Machine was created!';
$taskId=$res['message'];
}
$vm_ram=str_replace('g',' GB',$form['vm_ram']);
$html='';
$hres=$this->getTableChunk('bhyveslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$vars=array(
'nth-num'=>'nth0', // исправить на актуальные данные!
'node'=>'local', // исправить на актуальные данные!
'jname'=>$form['vm_name'],
'vm_status'=>$this->translate('Creating'),
'vm_cpus'=>$form['vm_cpus'],
'vm_ram'=>$vm_ram,
'vm_os_type'=>$os_type,
'icon'=>'spin6 animate-spin',
'desktop'=>' s-off',
'maintenance'=>' maintenance',
'protected'=>'icon-cancel',
'protitle'=>$this->translate('Delete'),
'vnc_title'=>$this->translate('Open VNC'),
'reboot_title'=>$this->translate('Restart VM'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
return array('errorMessage'=>$err,'jail_id'=>$form['vm_name'],'taskId'=>$taskId,'html'=>$html,'mode'=>$this->mode);
}
function bhyveStart($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd bstart inter=0 jname='.$name); // autoflush=2
return $res;
}
function bhyveStop($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd bstop inter=0 jname='.$name); // autoflush=2
return $res;
}
function bhyveRestart($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd brestart inter=0 jname='.$name); // autoflush=2
return $res;
}
function bhyveRemove($name)
{
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd bremove inter=0 jname='.$name); // autoflush=2
return $res;
}
function authkeyAdd()
{
$form=$this->_vars['form_data'];
$query="insert into authkey (name,authkey) values ('{$form['keyname']}','{$form['keysrc']}')";
$db=new Db('base','authkey');
//$res=array('error'=>false,'lastId'=>2);
$res=$db->insert($query);
if($res['error'])
{
return array('error'=>$res);
}
$html='';
$hres=$this->getTableChunk('authkeyslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$vars=array(
'keyid'=>$res['lastID'],
'keyname'=>$form['keyname'],
'keysrc'=>$form['keysrc'],
'deltitle'=>$this->translate('Delete'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
return array('keyname'=>$form['keyname'],'html'=>$html);
}
function authkeyRemove()
{
$form=$this->_vars['form_data'];
$db=new Db('base','authkey');
$res=$db->update('delete from authkey where idx='.$form['auth_id']);
if($res===false) return array('error'=>true,'res'=>print_r($res,true));
return array('error'=>false,'auth_id'=>$form['auth_id']);
}
function vpnetAdd()
{
$form=$this->_vars['form_data'];
$query="insert into vpnet (name,vpnet) values ('{$form['netname']}','{$form['network']}')";
$db=new Db('base','vpnet');
$res=$db->insert($query);
if($res['error'])
{
return array('error'=>$res);
}
$html='';
$hres=$this->getTableChunk('vpnetslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$vars=array(
'netid'=>$res['lastID'],
'netname'=>$form['netname'],
'network'=>$form['network'],
'deltitle'=>$this->translate('Delete'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
return array('netname'=>$form['netname'],'html'=>$html);
}
function vpnetRemove()
{
$form=$this->_vars['form_data'];
$db=new Db('base','vpnet');
$res=$db->update('delete from vpnet where idx='.$form['vpnet_id']);
if($res===false) return array('error'=>true,'res'=>print_r($res,true));
return array('error'=>false,'vpnet_id'=>$form['vpnet_id']);
}
function mediaRemove()
{
$form=$this->_vars['form_data'];
/*
$db=new Db('base','storage_media');
$res=$db->update('delete from media where idx='.$form['media_id']);
if($res===false) return array('error'=>true,'res'=>print_r($res,true));
*/
return array('error'=>false,'media_id'=>$form['media_id']);
}
function srcRemove($ver)
{
$ver=str_replace('src','',$ver);
if(empty($ver)) return array('error'=>true,'errorMessage'=>'Version of sources is emtpy!');
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd removesrc inter=0 ver='.$ver.' jname=#src'.$ver);
return $res;
}
function srcUpdate($ver)
{
$ver=str_replace('src','',$ver);
$stable=(preg_match('#\.\d#',$ver))?0:1;
if(empty($ver)) return array('error'=>true,'errorMessage'=>'Version of sources is emtpy!');
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd srcup stable='.$stable.' inter=0 ver='.$ver.' jname=#src'.$ver);
return $res;
}
function getSrcInfo($id)
{
$id=str_replace('src','',$id);
if(!is_numeric($id)) return array('error'=>true,'errorMessage'=>'Wrong ID of sources!');
$db=new Db('base','local');
if($db!==false)
{
$res=$db->selectAssoc("SELECT idx,name,platform,ver,rev,date FROM bsdsrc where ver={$id}");
$hres=$this->getTableChunk('srcslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$ver=$res['ver'];
$vars=array(
'nth-num'=>'nth0',
'maintenance'=>' busy',
'node'=>'local',
'ver'=>$res['ver'],
'ver1'=>strlen(intval($res['ver']))<strlen($res['ver'])?'release':'stable',
'rev'=>$res['rev'],
'date'=>$res['date'],
'protitle'=>$this->translate('Update'),
'protitle'=>$this->translate('Delete'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
}
$html=preg_replace('#<tr[^>]*>#','',$html);
$html=str_replace(array('</tr>',"\n","\r","\t"),'',$html);
return array('html'=>$html,'arr'=>$res);
}
function baseRemove($ver)
{
$ver=str_replace('base','',$ver);
$stable=(preg_match('#\.\d#',$ver))?0:1;
if(empty($ver)) return array('error'=>true,'errorMessage'=>'Version of base is emtpy!');
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd removebase inter=0 stable='.$stable.' ver='.$ver.' jname=#base'.$ver);
return $res;
}
function basesCompile()
{
$form=$this->_vars['form_data'];
if(!isset($form['sources']) || !is_numeric($form['sources'])) return array('error'=>true,'errorMessage'=>'Wrong OS type selected!');
$id=$form['sources'];
$res=$this->fillRepoTr($id);
$html=$res['html'];
$res=$res['arr'];
$ver=$res['ver'];
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd world inter=0 stable='.$res['stable'].' ver='.$ver.' jname=#base'.$ver);
//$res['retval']=0;$res['message']=3;
$err='';
$taskId=-1;
if($res['retval']==0)
{
$err='World compile start!';
$taskId=$res['message'];
}
return array('errorMessage'=>'','jail_id'=>'base'.$ver,'taskId'=>$taskId,'html'=>$html,'mode'=>$this->mode,'txt_status'=>$this->translate('Compiling'));
}
function fillRepoTr($id,$only_td=false,$bsdsrc=true)
{
$id=str_replace('base','',$id);
$html='';
$db=new Db('base','local');
if($db!==false)
{
if($bsdsrc)
{
$res=$db->selectAssoc("SELECT idx,platform,ver FROM bsdsrc where idx={$id}");
$res['name']='—';
$res['arch']='—';
$res['targetarch']='—';
$res['stable']=strlen(intval($res['ver']))<strlen($res['ver'])?0:1;
$res['elf']='—';
$res['date']='—';
}else{
$res=$db->selectAssoc("SELECT idx,platform,name,arch,targetarch,ver,stable,elf,date FROM bsdbase where ver={$id}");
}
$hres=$this->getTableChunk('baseslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$ver=$res['ver'];
$vars=array(
'nth-num'=>'nth0',
'node'=>'local',
'ver'=>$res['ver'],
'name'=>'base',
'platform'=>$res['platform'],
'arch'=>$res['arch'],
'targetarch'=>$res['targetarch'],
'stable'=>$res['stable']==0?'release':'stable',
'elf'=>$res['elf'],
'date'=>$res['date'],
'maintenance'=>' busy',
'protitle'=>$this->translate('Delete'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
}
if($only_td)
{
$html=preg_replace('#<tr[^>]*>#','',$html);
$html=str_replace(array('</tr>',"\n","\r","\t"),'',$html);
}
return array('html'=>$html,'arr'=>$res);
}
function repoCompile()
{
$form=$this->_vars['form_data'];
if(!isset($form['version']) || !is_numeric($form['version'])) return array('error'=>true,'errorMessage'=>'Wrong OS type input!');
$id=$form['version'];
$html='';
$hres=$this->getTableChunk('baseslist','tbody');
if($hres!==false)
{
$html_tpl=$hres[1];
$ver=$form['version'];
$stable=strlen(intval($ver))<strlen($ver)?'release':'stable';
$vars=array(
'nth-num'=>'nth0',
'node'=>'local',
'ver'=>$ver,
'name'=>'base',
'platform'=>'—',
'arch'=>'—',
'targetarch'=>'—',
'stable'=>$stable,
'elf'=>'—',
'date'=>'—',
'maintenance'=>' busy',
'protitle'=>$this->translate('Delete'),
);
foreach($vars as $var=>$val)
$html_tpl=str_replace('#'.$var.'#',$val,$html_tpl);
$html=$html_tpl;
}
$res=$this->cbsd_cmd('task owner=cbsdwebsys mode=new /usr/local/bin/cbsd repo action=get sources=base inter=0 stable='.$stable.' ver='.$ver.' jname=#base'.$ver);
//$res['retval']=0;$res['message']=3;
$err='';
$taskId=-1;
if($res['retval']==0)
{
$err='Repo download start!';
$taskId=$res['message'];
}
return array('errorMessage'=>'','jail_id'=>'base'.$ver,'taskId'=>$taskId,'html'=>$html,'mode'=>$this->mode,'txt_status'=>$this->translate('Fetching'));
}
function logLoad()
{
$form=$this->_vars['form_data'];
$log_id=$form['log_id'];
if(!is_numeric($log_id)) return array('error'=>'Log ID must be a number');
$html='';
$log_file='/tmp/taskd.'.$log_id.'.log';
if(file_exists($log_file))
{
$filesize=filesize($log_file);
if($filesize<=204800)
{
$html=file_get_contents($log_file);
}else{
$fp=fopen($log_file,'r');
if($fp)
{
fseek($fp,-1000,SEEK_END); //204800
$html='<strong>Last 1000 Bytes of big file data:<strong><hr />'.fread($fp,1000); //204800
}
fclose($fp);
}
$html=str_replace("\n",'<br />',$html);
return array('html'=>'<div style="font-weight:bold;">Log ID: '.$log_id.'</div><br />'.$html);
}
return array('error'=>'Log file is not exists!');
}
function logFlush()
{
$res=$this->cbsd_cmd('task mode=flushall');
return $res;
}
function getBasesCompileList()
{
$db1=new Db('base','local');
if($db1!==false)
{
$bases=$db1->select("SELECT idx,platform,ver FROM bsdsrc order by cast(ver AS int)");
if(!empty($bases)) foreach($bases as $base)
{
$val=$base['idx'];
$stable=strlen(intval($base['ver']))<strlen($base['ver'])?'release':'stable';
$name=$base['platform'].' '.$base['ver'].' '.$stable;
echo ' <option value="'.$val.'">'.$name.'</option>',PHP_EOL;
}
}
}
function useDialogs($arr=array())
{
//print_r($arr);
$this->_dialogs=$arr;
}
function placeDialogs()
{
if(empty($this->_dialogs)) return;
echo PHP_EOL;
foreach($this->_dialogs as $dialog_name)
{
$file_name=$this->realpath_public.'dialogs/'.$dialog_name.'.php';
if(file_exists($file_name))
{
include($file_name);
echo PHP_EOL,PHP_EOL;
}
}
}
function runVNC($jname)
{
$res=$this->cbsd_cmd("vm_vncwss jname={$jname} permit={$this->_client_ip}");
$res=$this->_db_local->selectAssoc('select nodeip from local');
$nodeip=$res['nodeip'];
// need for IPv4/IPv6 regex here, instead of strlen
if(strlen($nodeip)<7) $nodeip='127.0.0.1';
header('Location: http://'.$nodeip.':6080/vnc_auto.html?host='.$nodeip.'&port=6080');
exit;
}
function getFreeJname()
{
$arr=array();
$res=$this->cbsd_cmd("freejname");
if($res['error'])
{
$arr['error']=true;
$arr['error_message']=$err['error_message'];
}else{
$arr['error']=false;
$arr['freejname']=$res['message'];
}
return $arr;
}
function GhzConvert($Hz=0)
{
$h=1;$l='Mhz';
if($Hz>1000){$h=1000;$l='Ghz';}
return round($Hz/$h,2).' '.$l;
}
function fileSizeConvert($bytes,$bytes_in_mb=1024,$round=false)
{
$bytes = floatval($bytes);
$arBytes = array(
0 => array(
"UNIT" => "TB",
"VALUE" => pow($bytes_in_mb, 4)
),
1 => array(
"UNIT" => "GB",
"VALUE" => pow($bytes_in_mb, 3)
),
2 => array(
"UNIT" => "MB",
"VALUE" => pow($bytes_in_mb, 2)
),
3 => array(
"UNIT" => "KB",
"VALUE" => $bytes_in_mb
),
4 => array(
"UNIT" => "B",
"VALUE" => 1
),
);
$result='0 MB';
foreach($arBytes as $arItem)
{
if($bytes >= $arItem["VALUE"])
{
$result = $bytes / $arItem["VALUE"];
if($round) $result=round($result);
$result = str_replace(".", "," , strval(round($result, 2)))." ".$arItem["UNIT"];
break;
}
}
return $result;
}
function colorizeCmd($cmd_string)
{
$arr=$this->_cmd_array;
foreach($arr as $item)
{
$cmd_string=str_replace($item,'<span class="cbsd-cmd">'.$item.'</span>',$cmd_string);
}
$cmd_string=preg_replace('#(\/.+/cbsd)#','<span class="cbsd-lnch">$1</span>',$cmd_string);
return '<span class="cbsd-str">'.$cmd_string.'</span>';
}
}
Reference in New Issue View Git Blame Copy Permalink