Subversion-Projekte lars-tiefland.openvz_admin

<?php
        //$Id: vServer.class.php 143 2008-08-08 22:06:36Z lars $
        /**
         *      @package        openvz_admin
         *      @author         Lars Tiefland <ltiefland@gmail.com> 
         **/
        class vServer
        {
                protected $status;
                protected $name;
                protected $hn_id;
                protected $dist;
                protected $dist_id;
                protected $v_id;
                
                function toArray()
                {
                        $ret["hn_id"]=$this->hn_id;
                        $ret["v_id"]=$this->v_id;
                        $ret["dist_id"]=$this->dist_id;
                        $ret["dist"]=$this->dist;
                        $ret["name"]=$this->name;
                        $ret["status"]=$this->status;
                        return $ret;
                }
                function __construct($v_id = null, $hn_id = 1)
                {
                        global $db;
                        if (is_numeric($v_id))
                        {
                                $sql = "SELECT * FROM vservers, distributions WHERE v_id=$v_id AND hn_id=$hn_id AND dist_id=v_dist";
                                $res = $db->query($sql);
                                if (!PEAR::isError($res))
                                {
                                        $row = $res->fetchRow();
                                        $this->v_id = $v_id;
                                        $this->dist = $row["dist_name"];
                                        $this->dist_id = $row["dist_id"];
                                        $this->name = $row["v_name"];
                                        $this->hn_id = $hn_id;
                                        $this->status = $this->getStatus();
                                }
                                else
                                {
                                        echo $res->getUserInfo();
                                        return false;
                                }
                        }
                        else
                        {
                                $this->v_id = 0;
                                $this->dist_id = 1;
                                $this->dist = "gentoo";
                                $this->hn_id = 1;
                                $this->name = "";
                                $this->status["status"] = "";
                                $this->status["code"] = "0";
                        }
                }

                function getStatus()
                {
                        if (!$this->status)
                        {

                                unset($out);
                                if ($this->v_id != 0)
                                {
                                        $id = $this->v_id;
                                        $hn = HN::getHN($this->hn_id);
                                        $cmd = "ssh root@" . $hn["name"] . " vzctl status $id";
                                        exec($cmd, $out, $ret);
                                        if (!$ret)
                                        {
                                                $out_v["status"] = $out[0];
                                        }
                                        else
                                        {
                                                $out_v["status"] = "unknown";
                                        }
                                        $out_v["code"] = $ret;
                                }
                                else
                                {
                                        $id = $this->v_id;
                                        $hn = HN::getHN($this->hn_id);
                                        $hn_status = $hn["status"];
                                        $out_v["status"] = "Hardware node is $hn_status";
                                        if ($hn_status == "online")
                                        {
                                                $out_v["code"] = 0;
                                        }
                                        else
                                        {
                                                $out_v["code"] = 1;
                                        }
                                }
                                if (eregi("running", $out_v["status"]) || eregi("online", $out_v["status"]))
                                {
                                        $out_v["started"] = true;
                                }
                                else
                                {
                                        $out_v["started"] = false;
                                }
                                if (!$out_v["code"] && $out_v["started"])
                                {
                                        $class = "success_upd";
                                }
                                else
                                {
                                        $class = "error_upd";
                                }
                                $out_v["status"] = "<div class=\"$class\">" . $out_v["status"] . "</div>";
                                $this->status = $out_v;

                        }
                        return $this->status;
                }

                static function getvServers($hn_id = 1)
                {
                        global $db;
                        $sql = "SELECT * FROM vservers WHERE hn_id=$hn_id ORDER BY v_id";
                        $res = $db->query($sql);
                        $id = 0;
                        while ($row = $res->fetchRow())
                        {
                                $vservers[$id] = $row;
                                $v = new vServer($row["v_id"], $row["hn_id"]);
                                $ret = $v->getStatus();
                                $dist = new Dist($row["v_dist"]);
                                $dist_info = $dist->toArray();
                                $vservers[$id]["id"] = $row["id"];
                                $vservers[$id]["v_dist_name"] = $dist_info["dist_name"];
                                $vservers[$id]["v_status"] = $ret["status"];
                                $vservers[$id]["code"] = $ret["code"];
                                $vservers[$id]["started"] = $ret["started"];
                                $id++;
                        }
                        return $vservers;
                }

                function control($cmd = "")
                {
                        $cmds = array("start", "stop", "restart", "destroy");
                        if ($cmd == "" || !in_array($cmd, $cmds))
                        {
                                return false;
                        }
                        unset($out);
                        if ($this->v_id != 0)
                        {
                                $id = $this->v_id;
                                $hn = HN::getHN($this->hn_id);
                                $cmd = "ssh root@" . $hn["name"] . " vzctl $cmd $id";
                                exec($cmd, $out, $ret);
                                if (!$ret)
                                {
                                        $out_v["status"] = implode("<br>", $out);
                                        $out_v["error"] = false;
                                }
                                else
                                {
                                        $out_v["status"] = "unknown";
                                        $out_v["error"] = true;
                                }
                                $out_v["code"] = $ret;
                        }
                        else
                        {
                                $hn = HN::getHN($this->hn_id);
                                switch ($cmd)
                                {
                                        case "restart":
                                                $cmd = "ssh root@" . $hn["name"] . " reboot";
                                                exec($cmd, $out, $ret);
                                                if (!$ret)
                                                {
                                                        $out_v["status"] = implode("<br>", $out);
                                                        $out_v["error"] = false;
                                                }
                                                else
                                                {
                                                        $out_v["status"] = "unknown";
                                                        $out_v["error"] = true;
                                                }
                                                $out_v["code"] = $ret;
                                                break;
                                        default:
                                                $out_v["code"]=255;
                                                $out_v["error"]=true;
                                                $out_v["status"]="n/a";
                                                break;
                                }
                        }
                        return $out_v;
                }

                function save($v_name, $v_dist, $v_ip, $v_r_pw)
                {
                        global $db, $smarty;
                        $this->name = $v_name;
                        $this->dist_id = $v_dist;
                        unset($out);
                        $d = new Dist($v_dist);
                        $dist = $d->toArray();
                        $ip = IP::getIP($v_ip);
                        $d_name = $dist["dist_name"];
                        $this->dist = $d_name;
                        $d_template = $dist["template"];
                        $db->beginTransaction();
                        $sql = "INSERT into vservers (v_id, hn_id, v_name, v_dist) VALUES ($this->v_id, $this->hn_id, '$this->name', $this->dist_id)";
                        $res = $db->query($sql);
                        if (!PEAR::isError($res))
                        {
                                $v_id = $db->lasinsertid();
                                $sql_ip = "SELECT id FROM ips WHERE ip='$v_ip'";
                                $res_ip = $db->query($sql_ip);
                                if (!PEAR::isError($res_ip))
                                {
                                        $row_ip = $res->fetchRow();
                                        $ip_id = $row_ip["id"];
                                        $sql = "INSERT INTO host_2_ip (ve_id, ip) VALUES ($v_id,$ip_id)";
                                        $res = $db->query($sql);
                                        if (!PEAR::isError($res))
                                        {
                                                $cmd = "ssh root@mainframe vzctl create $this->v_id --hostname $v_name --ostemplate $d_template --config vps.$d_name --ipadd " .
                                                        $ip["ip"];
                                                exec($cmd, $out, $ret);
                                                if (!$ret)
                                                {
                                                        $smarty->assign("meld", "vServer erfolgreich angelegt!");
                                                        $smarty->assign("error", false);
                                                        $db->commit();
                                                }
                                                else
                                                {
                                                        $smarty->assign("error", true);
                                                        $smarty->assign("meld", "Ein Fehler ist aufgetreten!");
                                                        $smarty->assign("db_meld", $cmd . "<br>" . implde("<br>", $out));
                                                        $db->rollback();
                                                }
                                        }
                                        else
                                        {
                                                $smarty->assign("error", true);
                                                $smarty->assign("meld", "Ein Fehler ist aufgetreten!");
                                                $smarty->assign("db_meld", $res->getUserInfo());
                                                $db->rollback();
                                        }
                                }
                                else
                                {
                                        $smarty->assign("error", true);
                                        $smarty->assign("meld", "Ein Fehler ist aufgetreten!");
                                        $smarty->assign("db_meld", $res_ip->getUserInfo());
                                        $db->rollback();
                                }
                        }
                        else
                        {
                                $smarty->assign("error", true);
                                $smarty->assign("meld", "Ein Fehler ist aufgetreten!");
                                $smarty->assign("db_meld", $res->getUserInfo());
                                $db->rollback();
                        }
                }
        }
?>