[CLOSE] Teamspeak Automation Modul

<?php
/* Copyright by Steekarlkani */


session_start();


class SSH {
	public $connect;
	public $ip;
	public $port;
	public $debug;

	public function __construct($ip, $port)
	{
		$this->ip = $ip;
		$this->port = $port;
	}

	public function setDebugMode($debug)
	{
		$this->debug = $debug;
	}

	public function login($username, $password)
	{	
		try {
			if($this->connect = ssh2_connect($this->ip, $this->port)){
				if(ssh2_auth_password($this->connect, $username, $password)){
					return true;
				}else{
					return false;
				}
			}else{
				return false;
			}
		}catch(Exception $ex){
			echo $ex->getMessage();
		}
	}

	public function debug()
	{
		if($this->debug == true){
			return true;
		}else{
			return false;
		}
	}

	public function execute($command)
	{
		try {
			if($this->stream = ssh2_exec($this->connect, $command)){
				stream_set_blocking($this->stream, true);

				while($buf = fread($this->stream, 4096)){
					$this->data .= $buf;
				}

				if($this->debug() == true){
					print_r($this->data);
				}

				fclose($stream);
				return true;
			}else{
				return false;
			}	

		}catch(Exception $ex){
			die($ex->getMessage());
		}
	}

	public function UploadFile($filename)
	{
		try {
			$resSFTP = ssh2_sftp($this->connect);
			$file = $filename;

			if($contents = file_get_contents("admin/ownmodules/uploadinstances/".$file."")){
				if(file_put_contents("ssh2.sftp://{$resSFTP}/home/user-webi/{$file}", $contents)){
					return true;
				}else{
					return false;
				}
			}else{
				return false;
			}

			fclose($resSFTP);
			fclose($contents);
			fclose($this->connect);

		}catch(Exception $ex){
			die($ex->getMessage());
		}
	}


	public function DaemonExists()
	{
		try {
			$resSFTP = ssh2_sftp($this->connect);

			if(file_exists("ssh2.sftp://{$resSFTP}/home/skripte/daemon")){
				return true;
			}else{
				return false;
			}


		}catch(Exception $ex){
			die($ex->getMessage());
		}
	}
}
?>

<?php
if(is_admin($admin)) {
function admintest($ids, $test, $save) {
    global $prefix, $admin, $db;
	global $dbconnect;
	global $dbserver;
	global $onlinestatus;


	$ids = filter($ids, "", 1);
	$test = filter($test, "", 1);


        include ("admin/header.php");
	include ("teamspeakclasses/Database/class.pdo.config.php");
	include ("teamspeakclasses/libraries/TeamSpeak3/TeamSpeak3.php");
	include ("teamspeakclasses/SSH/class.ssh.php");
	include ("teamspeakclasses/Random/class.random.php");

	$adminmsg = admin_title("cmodules", ""._TEAMSPEAK."", ""._ASSISTENTAPPLIST."", $iconset, "");
	echo ''.$adminmsg.'';

	switch($_GET["api"]){
		case "importfromtekbase":
				$query = $dbconnect->RunQuery("SELECT name, serverip, sshuser, sshport, daemonpasswd FROM teklab_rootserver WHERE serverip = ".$dbconnect->Escape($_POST["rootserverauswahl"])."");
				$row = $dbconnect->FetchAssoc();

				$teamspeak = $dbconnect->RunQuery("SELECT * FROM teklab_teamspeak WHERE serverip = ".$dbconnect->Escape($_POST["rootserverauswahl"])."");
				$teamspeakrow = $dbconnect->FetchAssoc();

				$random = new Random();
				$username = $random->generateRandomUsername();
				$encrypted = $random->generateQueryPassword();

				$ssh = new ssh($row["serverip"], $row["sshport"]);
				$ssh->setDebugMode(false);

				if($dbconnect->NumRows($dbconnect->RunQuery("SELECT id FROM teamspeak_nodes WHERE rootserverauswahl = ".$dbconnect->Escape($_POST["rootserverauswahl"])."")) > 0){
					$false = "Dein Grundserver wurde schon importiert, bitte wähle einen anderen Grundserver aus.";
				}else{
					if($ssh){
						if($ssh->login($row["sshuser"], $row["daemonpasswd"])){
							if($ssh->DaemonExists()){
								if($dbconnect->NumRows($dbconnect->RunQuery("SELECT slots, serverport, serverip, memberid FROM teklab_voiceserver WHERE serverip = ".$dbconnect->Escape($_POST["rootserverauswahl"])."")) > 0){
									$row = $dbconnect->FetchAssoc();
									$dbconnect->RunQuery("INSERT INTO teamspeak_nodes (teamspeakip, teamspeakusername, teamspeakpassword, rootserverauswahl, nodeimported, nodepfad, query_ip_whitelist_angepasst, teamspeaknodedebuggingerror, queryport, voiceport) VALUES (".$dbconnect->Escape($row["serverip"]).", 'serveradmin', '$encrypted', ".$dbconnect->Escape($_POST["rootserverauswahl"]).", '1', ".$dbconnect->Escape($teamspeakrow["path"]).", '0', '0', ".$dbconnect->Escape($teamspeakrow["queryport"]).", '9987')");

									$countvserver = $dbconnect->RunQuery("SELECT COUNT(id) FROM teklab_voiceserver WHERE serverip = ".$dbconnect->Escape($_POST["rootserverauswahl"])."")->fetchColumn();

									$virtualserverquery = $dbconnect->RunQuery("SELECT serverip, serverport, slots FROM teklab_voiceserver");
									while($virtualserver = $dbconnect->FetchAssoc())
									{
										$virtualserverow[] = $virtualserver;
									}

									$importedvserver = array();
									foreach($virtualserverow as $importedvserver)
									{
										$dbconnect->RunQuery("INSERT INTO teamspeak_virtualserver (name, teamspeakip, teamspeakport, slots, rootserverauswahl, kunden, gesperrt, imported) VALUES(".$dbconnect->Escape($username).", ".$dbconnect->Escape($importedvserver["serverip"]).",".$dbconnect->Escape($importedvserver["serverport"]).",".$dbconnect->Escape($importedvserver["slots"]).", ".$dbconnect->Escape($_POST["rootserverauswahl"]).", '', '0', '1')");
									}

									$nodepfad = $dbconnect->HtmlEscape($teamspeakrow["path"]);
									$ssh->execute("cd /home/skripte && sudo -u user-webi ./daemon stop 1 $nodepfad"); 
									$true = "Deine Grundserver/V-Server(".$dbconnect->HtmlEscape($countvserver).") sind erfolgreich importiert worden.";
								}else{
									$nodepfad = $dbconnect->HtmlEscape($teamspeakrow["path"]);
                                                                        $ssh->execute("cd /home/skripte && sudo -u user-webi ./daemon stop 1 $nodepfad"); 
                                                                        $dbconnect->RunQuery("INSERT INTO teamspeak_nodes (teamspeakip, teamspeakusername, teamspeakpassword, rootserverauswahl, nodeimported, nodepfad, query_ip_whitelist_angepasst, teamspeaknodedebuggingerror, queryport, voiceport) VALUES (".$dbconnect->Escape($row["serverip"]).", 'serveradmin', '$encrypted', ".$dbconnect->Escape($_POST["rootserverauswahl"]).", '1', ".$dbconnect->Escape($teamspeakrow["path"]).", '0', '0', ".$dbconnect->Escape($teamspeakrow["queryport"]).", '9987')");
									$true = "Deine Grundserver/V-Server(0) sind erfolgreich importiert worden.";
								}
							}else{
								$false = "Bitte installieren sie denn Daemon.";
							}
						}else{
							$false = "SSH-Username oder SSH-Password ist falsch.";
						}
					}else{
						$false = "Konnte keine Verbindung zum Host: ".$dbconnect->HtmlEscape($teamspeakrow["serverip"])." und Port: ".$dbconnect->HtmlEscape($teamspeakrow["sshport"])." herstellen.";
					}
				}
		break;	
	}

	include ("templates/teamspeaknode/teamspeaktekbaseimport.php");
        include ("admin/footer.php");
}


switch ($op) {

	case "adminteamspeaktekbaseimport":
	admintest($ids, $test, $save);
	break;


}
}else{
adminLogin($admin);
}
?>