Merge pull request #40 from lucapiccio/master

Added usefull functions (getallvm,start,stop,...)

Author: CpuID

pve2_api.class.php

@@ -320,6 +320,229 @@ public function get_next_vmid () {
 		}
 	}
 
+	/*
+	 * array get_vms ()
+	 * Get List of all vms
+	 */
+	public function get_vms () {
+		$node_list = $this->get_node_list();
+		$result=[];
+		if (count($node_list) > 0) {
+			foreach ($node_list as $node_name) {
+				$vms_list = $this->get("nodes/" . $node_name . "/qemu/");
+				if (count($vms_list) > 0) {
+					$key_values = array_column($vms_list, 'vmid'); 
+					array_multisort($key_values, SORT_ASC, $vms_list);
+					foreach($vms_list as &$row) {
+						$row[node] = $node_name;
+					}
+					$result = array_merge($result, $vms_list);
+				}
+				if (count($result) > 0) {
+					$this->$cluster_vms_list = $result;
+					return $this->$cluster_vms_list;
+				} else {
+					error_log(" Empty list of vms returned in this cluster.");
+					return false;
+				}
+			}
+		} else {
+			error_log(" Empty list of nodes returned in this cluster.");
+			return false;
+		}
+	}
+	
+	/*
+	 * bool|int start_vm ($node,$vmid)
+	 * Start specific vm
+	 */
+	public function start_vm ($node,$vmid) {
+		if(isset($vmid) && isset($node)){
+			$parameters = array(
+				"vmid" => $vmid,
+				"node" => $node,
+			);
+			$url = "/nodes/" . $node . "/qemu/" . $vmid . "/status/start";
+			$post = $this->post($url,$parameters);
+			if ($post) {
+				error_log("Started vm " . $vmid . "");
+				return true;
+			} else {
+				error_log("Error starting vm " . $vmid . "");
+				return false;
+			}
+		} else {
+			error_log("no vm or node valid");
+			return false;
+		}
+	}
+	
+	/*
+	 * bool|int shutdown_vm ($node,$vmid)
+	 * Gracefully shutdown specific vm
+	 */
+	public function shutdown_vm ($node,$vmid) {
+		if(isset($vmid) && isset($node)){
+			$parameters = array(
+				"vmid" => $vmid,
+				"node" => $node,
+				"timeout" => 60,
+			);
+			$url = "/nodes/" . $node . "/qemu/" . $vmid . "/status/shutdown";
+			$post = $this->post($url,$parameters);
+			if ($post) {
+				error_log("Shutdown vm " . $vmid . "");
+				return true;
+			} else {
+				error_log("Error shutting down vm " . $vmid . "");
+				return false;
+			}
+		} else {
+			error_log("no vm or node valid");
+			return false;
+		}
+	}
+
+	/*
+	 * bool|int stop_vm ($node,$vmid)
+	 * Force stop specific vm
+	 */
+	public function stop_vm ($node,$vmid) {
+		if(isset($vmid) && isset($node)){
+			$parameters = array(
+				"vmid" => $vmid,
+				"node" => $node,
+				"timeout" => 60,
+			);
+			$url = "/nodes/" . $node . "/qemu/" . $vmid . "/status/stop";
+			$post = $this->post($url,$parameters);
+			if ($post) {
+				error_log("Stopped vm " . $vmid . "");
+				return true;
+			} else {
+				error_log("Error stopping vm " . $vmid . "");
+				return false;
+			}
+		} else {
+			error_log("no vm or node valid");
+			return false;
+		}
+	}
+	
+	/*
+	 * bool|int resume_vm ($node,$vmid)
+	 * Resume from suspend specific vm
+	 */
+	public function resume_vm ($node,$vmid) {
+		if(isset($vmid) && isset($node)){
+			$parameters = array(
+				"vmid" => $vmid,
+				"node" => $node,
+			);
+			$url = "/nodes/" . $node . "/qemu/" . $vmid . "/status/resume";
+			$post = $this->post($url,$parameters);
+			if ($post) {
+				error_log("Resumed vm " . $vmid . "");
+				return true;
+			} else {
+				error_log("Error resuming vm " . $vmid . "");
+				return false;
+			}
+		} else {
+			error_log("no vm or node valid");
+			return false;
+		}
+	}
+	
+	/*
+	 * bool|int suspend_vm ($node,$vmid)
+	 * Suspend specific vm
+	 */
+	public function suspend_vm ($node,$vmid) {
+		if(isset($vmid) && isset($node)){
+			$parameters = array(
+				"vmid" => $vmid,
+                		"node" => $node,
+			);
+			$url = "/nodes/" . $node . "/qemu/" . $vmid . "/status/suspend";
+			$post = $this->post($url,$parameters);
+			if ($post) {
+				error_log("Suspended vm " . $vmid . "");
+				return true;
+			} else {
+				error_log("Error suspending vm " . $vmid . "");
+				return false;
+			}
+		} else {
+			error_log("no vm or node valid");
+			return false;
+		}
+	}
+	
+	/*
+	 * bool|int clone_vm ($node,$vmid)
+	 * Create fullclone of vm
+	 */
+	public function clone_vm ($node,$vmid) {
+		if(isset($vmid) && isset($node)){
+			$lastid = $this->get_next_vmid();
+			$parameters = array(
+				"vmid" => $vmid,
+				"node" => $node,
+				"newid" => $lastid,
+				"full" => true,
+			);
+			$url = "/nodes/" . $node . "/qemu/" . $vmid . "/clone";
+			$post = $this->post($url,$parameters);
+			if ($post) {
+				error_log("Cloned vm " . $vmid . " to " . $lastid . "");
+				return true;
+			} else {
+				error_log("Error cloning vm " . $vmid . " to " . $lastid . "");
+				return false;
+			}
+		} else {
+			error_log("no vm or node valid");
+			return false;
+		}
+	}
+
+	/*
+	 * bool|int snapshot_vm ($node,$vmid,$snapname = NULL)
+	 * Create snapshot of vm
+	 */	
+	public function snapshot_vm ($node,$vmid,$snapname = NULL) {
+		if(isset($vmid) && isset($node)){
+			$lastid = $this->get_next_vmid();
+			if (is_null($snapname)){
+				$parameters = array(
+					"vmid" => $vmid,
+					"node" => $node,
+					"vmstate" => true,
+				);
+			} else {
+				$parameters = array(
+					"vmid" => $vmid,
+					"node" => $node,
+					"vmstate" => true,
+					"snapname" => $snapname,
+				);
+			}
+			$url = "/nodes/" . $node . "/qemu/" . $vmid . "/snapshot";
+			$post = $this->post($url,$parameters);
+			if ($post) {
+				error_log("Cloned vm " . $vmid . " to " . $lastid . "");
+				return true;
+			} else {
+				error_log("Error cloning vm " . $vmid . " to " . $lastid . "");
+				return false;
+			}
+		} else {
+			error_log("no vm or node valid");
+			return false;
+		}
+	}
+	
 	/*
 	 * bool|string get_version ()
 	 * Return the version and minor revision of Proxmox Server