CLASSE D'INTERFACE SFTP

<?php
function debug($msg, $var = 'debug')
	{
		if (isset($_GET[$var]))
		{
			echo  trim($msg), "\n";
			ob_flush();
			flush();
		}
	}
if (!function_exists("ssh2_connect")) die("La bibliotheque ssh2 n'est pas disponible sur le serveur, pour l'installer visitez par exemple <a href=\"http://naeh.net/installer-libssh2-ssh2-pour-php/\">http://naeh.net/installer-libssh2-ssh2-pour-php</a>/\n");
/** @class sftp
*	@brief interface sftp
*
*/
class sftp
{
	private $id = false, $server = false, $url = false;	
	
	/** @brief Constructeur
	*
	* Tente d'etablir une connexion SFTP à un serveur distant.
	* @param	$server
	*	ip/host du server
	* @param 	$user
	*	Identifiant de la connexion
	* @param	$pass
	*	Mot de passe
	* @throw
	*	Une exception remontera en cas d'erreur
	*/
	public function __construct ($server, $user, $pass)
	{
		debug("Tentative de connexion au serveur SSH " . $server);
		$this->id = ssh2_connect($server, 22);
		if(!$this->id || empty($this->id))
			throw new Exception ('Échec de connexion à ' . $server);
		debug("Tentative d'authentification");
		if (!ssh2_auth_password($this->id, $user, $pass))		
			throw new Exception ("Échec d'identification à " . $server);
		$this->url = ssh2_sftp($this->id);
		if (!$this->url)
			throw new Exception ("Echec d'ouverture du SFTP sur le serveur " . $server);
		debug("SFTP ouvert");							
		$this->server = $server;
	}

	/** @brief Destructeur
	*
	* Ferme une connection sftp
	*/
	public function __destruct()
	{
		debug("Fermeture de la connexion SSH\n");
		ssh2_exec($this->id, "exit");			
	}		

	/** @brief Retourne la taille d'un fichier sur le serveur distant
	* @param	$file
	*	chemin absolu du fichier
	* @return
	*	taille du fichier en octet
	*/
	private function getfilesize($file)
	{
		return filesize("ssh2.sftp://" . $this->url . $file);
    }	
	
	/** @brief Recupere un fichier sur le serveur distant
	*
	* Tente de recuperer un fichier sur le serveur distant, 
	* user friendly , $name  n'a pas besoin d'être le chemin absolu vers le fichier
	* par exemple get("foo/zomg/lol.csv") va recuperer le fichier /../foo/zomg/lol.csv sur le serveur 
	* dans le fichier lol.csv du dossier courant local
	* @param	$name 
	*	nom du fichier à récuperer sur le serveur
	* @param 	$local_name
	*	facultatif, nom du fichier en local après transfert
	* @return
	*	Renvois le chemin du fichier recupéré en local
	* @throw
	*	Une exception remontera en cas d'erreur
	*/
	public function get($name, $local_name = false)
	{
		try {$name = $this->fpath($name);}
		catch (Exception $e) {throw $e;}
		if (!$local_name)
			$local_name = '.' . (strpos(name, '/') === false?strrchr($name, '/'):('/' . $name));			
		debug("Tentative de transfert du fichier '" .$local_name ."' depuis le serveur '" .$name . "'");
		$handle = @fopen("ssh2.sftp://" . $this->url . $name, 'r');
		if (!$handle)
			throw new Exception ("Impossible d'ouvrir le fichier " . $name . " sur le serveur distant " . $this->server);			
		$size = $this->getfilesize($name);
		$contents = '';
		$transfered = 0;$i = 0;
		while ($transfered < $size && ($buffer = fread($handle, $size - $transfered)))
		{
			debug($transfered, " transfere sur ", $size);
			$transfered += strlen($buffer);
			$contents .= $buffer;
			if ($i++ > 1000)
				{
					fclose($handle);
					throw new Exception ('Erreur pendant le transfert du fichier ' . $name . 'depuis le serveur' . $this->server . ' : timeout');
				}
		}       
		file_put_contents ($local_name, $contents);
		fclose($handle);
		debug("\nTransfert du fichier '" . $name . "' depuis le serveur " . $this->server . " reussi");
		return ($local_name);
	}
	
	/** @brief Dépose un fichier sur le serveur distant
	*
	* Tente de déposer un fichier sur le serveur distant, 
	* user friendly , $name n'a pas besoin d'être le chemin absolu vers le fichier
	* par exemple put("foo/zomg/lol.csv") va deposer le fichier lol.csv du dossier courant dans le dossier /../foo/zomg/lol.csv du serveur
	* @param	$name 
	*	nom du fichier à déposer sur le serveur
	* @param 	$local_name
	*	facultatif, nom du fichier 
	* @throw
	*	Une exception remontera en cas d'erreur
	*/
	public function put($name, $remote_name = false)	
	{
		try
		{
			if (!$remote_name)
			{
				$remote_name = $this->fpath($name);						
				$name = '.' . (strpos($name, '/') === false ?('/' . $name):strrchr($name, '/'));
			}
			else
				$remote_name = $this->path(substr($remote_name, 0 , strrpos($remote_name, '/'))) . strrchr($remote_name, '/');																								
		}
		catch (Exception $e) {throw $e;}
		debug("Tentative de transfert du fichier '" . $name . "' sur le serveur " . $this->server);
		$handle = fopen("ssh2.sftp://" . $this->url . $remote_name, 'w');
		if (!$handle)
			throw new Exception('Impossible d\'ouvrir le fichier ' . $remote_name . ' en ecriture sur le serveur ' . $this->server);
		$data = file_get_contents(strpos($name, "/")?'.' . strrchr($name, "/"):$name);
		if ($data === false)
			throw new Exception("Impossible d'ouvrir le fichier local " . $name);
		$transfered = fwrite($handle, $data);
		if ($transfered === false)
			throw new Exception("Impossible de transferer le fichier " . $name);
		$size = strlen($data);
		if ($transfered != $size)
		{
			while ($transfered < $size && ($transfered += fwrite($handle, mb_substr($data, $transfered, $size - $transfered))))
				debug($transfered . " transfere sur " . $size);
		}
		debug("Fichier " . $remote_name . " correctement depose");
		fclose($handle);
	}
	
	
	/** @brief Deplace un fichier sur le serveur distant
	*
	* Tente de deplacer un fichier sur le serveur distant
	* user friendly , les chemins n'ont pas besoin d'être absolu
	* par exemple mv("foo/zomg/lol.csv", "omfg/lolz.txt") va deplacer /../foo/zomg/lol.csv vers /../omfg/lolz.txt
	* @param	$old
	*	nom du fichier à déplacer
	* @param 	$new
	*	nouveau nom & chemin
	* @throw
	*	Une exception remontera en cas d'erreur
	*/
	public function mv($old, $new)
	{
		try
		{
			$old = $this->fpath($old);
			$new = $this->fpath($new);
		}
		catch (Exception $e)
		{
			throw $e;
		}
		debug('Tentative de deplacement du fichier \'' . $old . '\' vers \'' . $new . "'");
		$old_handle = fopen("ssh2.sftp://" . $this->url .$old, 'r');
		if (!$old_handle)
			throw new Exception ("Impossible d'ouvrir en lecture le fichier  '" . $old . "' sur le serveur distant");
		$new_handle = fopen("ssh2.sftp://" . $this->url .$new, 'w');
		if (!$new_handle)
			throw new Exception ("Impossible d'ouvrir en ecriture le fichier  '" . $new . "' sur le serveur distant");
		$size = $this->getfilesize($old);
		$read = 0;
		$wrote = 0;
		while ($read < $size && ($buffer = fread($old_handle, $size - $read)))
		{
			$tmp_size = strlen($buffer);
			$read += $tmp_size;
			$tmp_wrote = 0;
			while ($tmp_wrote <$tmp_size)
			{
				$tmp = fwrite($new_handle, substr($buffer, $tmp_wrote));				
				if (!$tmp)
					break;
				$tmp_wrote += $tmp;
			}
			$wrote += $tmp_size;
		}
		debug("taille du fichier = " . $size . " , " . $read . " octets lu, " . $wrote . " octets ecrit");		
		fclose($new_handle);
		fclose($old_handle);
		if ($size == $read && $read == $wrote)
			unlink("ssh2.sftp://" . $this->url . $old);
		else
			throw new Exception ("Erreur pendant le deplacement du fichier " . $old . " en " . $old . "\ntaille du fichier = " . $size . " , " . $read . " octets lu, " . $wrote . " octets ecrit\n");		
	}
	
	/** @brief Récupere le chemin absolu d'un dossier
	*
	* @param	$dir
	*	nom du dossier
	* @return
	*	chemin absolu du dossier $dir sur le serveur distant
	*/
	private function path($dir)
	{
		$rlpath = @ssh2_sftp_realpath($this->url, $dir);
		if (!$rlpath)
			throw new Exception ("Dossier introuvable sur le serveur distant : "  . $dir);
		return $rlpath;
	}

	/** @brief Récupere le chemin absolu d'un fichier sur le serveur
	*
	* @param	$name
	*	nom du fichier
	* @return
	*	chemin absolu du fichier sur le serveur
	*/	
	private function fpath($name)
	{
		try 
		{
			if (strpos($name, '/') === false)
				$name = $this->path('.') . '/' . $name;
			else
				$name = $this->path(substr($name, 0 , strrpos($name, '/'))) . strrchr($name, '/');
		}
		catch (Exception $e)
		{
			throw $e;
		}
		return $name;
	}
	
	/** @brief Liste le contenu d'un dossier
	*
	* Liste le contenu d'un dossier passé en parametre ou le dossier courant si aucun dossié donné.
	* Ne renvois pas les dossiers
	* Offre la possibilitée de filtrer les resultats possedant l'extension "$ext" et la chaîne de caractere $like dans leur noms
	* @param	$directory
	*	nom du dossier
	* @param	$like
	*	pattern à respeceter
	* @param	$ext
	*	extension des fichiers à respecter
	* @return
	*	renvois la liste des fichiers sous la forme d'un tableau non associatif
	* @throw
	*	une exception remontera en cas d'erreur
	*/
	public function flist($directory = './' , $like = false, $ext = false)
	{
		$dir = $this->path($directory);
		$handle = opendir("ssh2.sftp://" . $this->url . $dir);
		if (!$handle)
			throw new Exception ("Impossible d'ouvrir le dossier " .  $directory . " sur le serveur " . $this->server);
		$files = array();
		while (false !== ($file = readdir($handle))) 
		{
			if (substr($file, 0, 1) != "." && !is_dir($file))
			{
				if ($like && $ext)
				{
					if (stripos($file, $like) !== false && strrchr($file , ".") == (strpos($ext, ".") !== false?$ext:(".".$ext)))
						$files[] = $dir . '/' . $file;
				}
				else
					$files[] =  $dir . '/' . $file;
			}
		}
		sort($files);
		return $files;		
	}

	/** @brief Recupere une liste de fichier
	*
	* Recupere une liste de fichier et les deplace (sur le serveur distant) ds le dossier $dir_if_success si spécifié
	* @param	$files_ar 
	*	tableau de fichiers
	* @param	$like
	*	pattern à respeceter
	* @param	$ext
	*	extension des fichiers à respecter
	* @return
	*	renvois la liste des fichiers sous la forme d'un tableau non associatif
	* @throw
	*	une exception remontera en cas d'erreur
	*/
	public function get_files($files_ar, $dir_if_success = false)
	{
		$error = count($files_ar);
		$files = array();
		foreach ($files_ar as $k =>$v)
		{
			debug("Transfert de $v.");
			try
			{
				$files[$k] = $this->get($v);
				if ($dir_if_success)
					$this->mv($v, $dir_if_success . strrchr($files[$k], "/"));
				debug("Transfert reussi");
			}
			catch (Exception $e)
			{
				debug("Echec dans le transfer du fichier $v :\n" . $e->getMessage());;
				$error--;
			}
		}
		if (!$error)
			throw new Exception ("Impossible de récuperer les fichiers spécifié, vérifiez les droit, le type de transfert ou type de connexion");
		if (empty($files))
			return false;
		sort($files);
		return $files;
	}
}
/* Exemple d'utilisation : */
try
{
        $_GET['debug'] = true;
	$sftp = new sftp(SERVER, USER, PASS);	
	$files = $sftp->flist("data/");
	print_r($files);
	$sftp->get_files($files, "data/treated/");
}
catch (Exception $e)
{
	die ($e->getMessage()."\n");	
}