<?php
/*
 * CVM is more free software. It is licensed under the WTFPL, which
 * allows you to do pretty much anything with it, without having to
 * ask permission. Commercial use is allowed, and no attribution is
 * required. We do politely request that you share your modifications
 * to benefit other developers, but you are under no enforced
 * obligation to do so :)
 * 
 * Please read the accompanying LICENSE document for the full WTFPL
 * licensing text.
 */
 
if(!isset($_CVM)) { die("Unauthorized."); }

class SshConnector extends CPHPBaseClass
{
	public $connected = false;
	public $authenticated = false;
	public $connection = null;
	
	public $host = "localhost";
	public $port = 22;
	public $user = "root";
	public $key = "";
	public $pubkey = "";
	public $keytype = "ssh-rsa";
	
	public function RunCommand($command)
	{
		if($this->connected == false && $this->authenticated == false)
		{
			try
			{
				$this->Connect();
				$this->DoCommand($command);
			}
			catch (SshConnectException $e)
			{
				$error = $e->getMessage();
				throw new SshCommandException("Could not run command {$command}: Failed to connect: {$error}");
			}
			catch (SshCommandException $e)
			{
				$error = $e->getMessage();
				throw new SshCommandException($error);
			}
		}
		else
		{
			try
			{
				$this->DoCommand($command);
			}
			catch (SshCommandException $e)
			{
				$error = $e->getMessage();
				throw new SshCommandException($error);
			}
		}
	}
	
	public function Connect()
	{
		$options = array(
			'hostkey' => $this->keytype
		);
		
		if($this->connection = ssh2_connect($this->host, $this->port, $options))
		{
			$this->connected = true;
			
			if(empty($this->passphrase))
			{
				$result = ssh2_auth_pubkey_file($this->connection, $this->user, $this->pubkey, $this->key);
			}
			else
			{
				$result = ssh2_auth_pubkey_file($this->connection, $this->user, $this->pubkey, $this->key, $this->passphrase);
			}
			
			if($result === true)
			{
				$this->authenticated = true;
				return true;
			}
			else
			{
				throw new SshAuthException("Could not connect to {$this->host}:{$this->port}: Key authentication failed");
			}
		}
		else
		{
			throw new SshConnectException("Could not connect to {$this->host}:{$this->port}: {$error}");
		}
		
		return false;
	}
	
	private function DoCommand($command)
	{
		$stream = ssh2_exec($this->connection, $command);
		var_dump($stream);
	}
}

?>