CLASS POUR SOCKETS

<?php
 /*
 --------------------------------------------
 ---Création: 13 Janvier 2008
 ---Modification: 16 Février 2008
 ---Auteur: Romain 'xSTyled' L.
  --------------------------------------------
 #vars
#public
Tableau des erreurs
 #array errors

#private
Tableau des nouveaux clients
 #array newclients
 
Tableau des connexions
 #array sockets
 
 #fonctions
#public
Ecoute un port [Retourne true si ça a réussi, false sinon]
 #bool listen ((string) nom, (string) ip, (int) port)

Se connecte à une machine distante [Retourne true si ça a réussi, false sinon]
 #bool connect ((string) nom, (string) ip, (int) port [, (string) localip ])

Lit une socket [Retourne la ligne reçue, false si la connexion n'existe pas]
 #mixed read ((string) nom [, (int) longueur ])

Retourne le nom du nouveau client s'il y en a un [false s'il n'y en a pas ou si la connexion n'existe pas]
 #mixed newclient ((string) nom)

Ferme une socket [Retourne true si ça a réussi, false sinon]
 #bool close ((string) nom)

Ecrit sur une socket [Retourne true si ça a réussi, false sinon]
 #bool write ((string) nom, (string) data, [, (bool) crlf ])

Renomme une connexion [Retourne true si ça a réussi, false sinon]
 #bool rename ((string) nom, (string) nouveau nom)

Verifie si une connexion existe [Retourne true si la connexion existe, false sinon]
 #bool exists ((string) nom)

Retourne les infos sur une connexion [Retourne false si la connexion n'existe pas]
 #mixed infos ((string) nom)

#private
Retourne le type d'une connexion [false si la connexion n'existe pas ou s'il y a une erreur]
 #mixed gettype ((string) nom)

Retourne le nom d'une connexion avec sa ressource socket. [false si la connexion n'existe pas]
 #mixed getnamebysocket ((ressource) socket)

*/
 
class socket {
	private $sockets = Array();
	private $newclient = Array();
	public $errors = Array();

	public function listen($name, $ip, $port) {
		$name = strtolower($name);
		if ($this->exists($name)) {
			$this->errors[] = 'socket name '.$name.' already exists (line: '.__LINE__.')';
			return false;
		}
		if (!($a = @socket_create(AF_INET, SOCK_STREAM, SOL_TCP))) {
			$this->errors[] = socket_strerror(socket_last_error()).' (line: '.__LINE__.')';
			return false;
		}
		if (!@socket_set_option($a, SOL_SOCKET, SO_REUSEADDR, 1)) {
			$this->errors[] = socket_strerror(socket_last_error($a)).' (line: '.__LINE__.')';
			return false;
		}
		if (!@socket_bind($a, $ip, $port)) {
			$this->errors[] = socket_strerror(socket_last_error($a)).' (line: '.__LINE__.')';
			return false;
		}
		if (!@socket_listen($a)) {
			$this->errors[] = socket_strerror(socket_last_error($a)).' (line: '.__LINE__.')';
			return false;
		}
		if (!@socket_set_nonblock($a)) {
			$this->errors[] = socket_strerror(socket_last_error($a)).' (line: '.__LINE__.')';
			return false;
		}
		$this->sockets[$name]['sock'] = $a;
		$this->sockets[$name]['read'] = '';
		$this->sockets[$name]['ip'] = $ip;
		$this->sockets[$name]['port'] = $port;
		$this->sockets[$name]['type'] = 'server';
		return true;
	}

	public function connect($name, $ip, $port, $localip = '0.0.0.0') {
		$name = strtolower($name);
		if ($this->exists($name)) {
			$this->errors[] = 'socket name '.$name.' already exists (line: '.__LINE__.')';
			return false;
		}
		if (!($r = @gethostbyname($localip))) {
			$this->errors[] = 'Unable to resolve '.$localip.' (line: '.__LINE__.')';
			return false;
		}
		else $localip = $r;
		if (!($a = socket_create(AF_INET, SOCK_STREAM, SOL_TCP))) {
			$this->errors[] = socket_strerror(socket_last_error()).' (line: '.__LINE__.')';
			return false;
		}
		if (!@socket_bind($a, $localip)) {
			$this->errors[] = socket_strerror(socket_last_error($a)).' (line: '.__LINE__.')';
			return false;
		}
		if (!@socket_connect($a, $ip, $port)) {
			$this->errors[] = socket_strerror(socket_last_error($a)).' (line: '.__LINE__.')';
			return false;
		}
		if (!@socket_set_nonblock($a)) {
			$this->errors[] = socket_strerror(socket_last_error($a)).' (line: '.__LINE__.')';
			return false;
		}
		$this->sockets[$name]['sock'] = $a;
		$this->sockets[$name]['read'] = '';
		$this->sockets[$name]['ip'] = $ip;
		$this->sockets[$name]['port'] = $port;
		$this->sockets[$name]['type'] = 'client';
		return true;
	}

	public function read($name, $length = 1024) {
		$name = strtolower($name);
		if (!$this->exists($name)) {
			$this->errors[] = 'Unknow socket name '.$name.' (line: '.__LINE__.')';
			return false;
		}
		$a = Array();
		foreach ($this->sockets as $b => $c) {
			if (isset($c['sock'])) $a[] = $c['sock'];
			else unset($this->sockets[$b]);
		}
		if (((bool) $a) && (socket_select($a, $write = NULL, $except = NULL, 0) !== false)) {
			foreach ($a as $b) {
				if ($this->gettype($this->getnamebysocket($b)) == 'server') {
					$i = null;
					$j = null;
					if ($z = @socket_accept($b)) {
						$x = (function_exists('mt_rand') ? 'mt_rand' : 'rand');
						for ($y = chr($x(97,122)).chr($x(97,122)).chr($x(97,122)).chr($x(97,122)); $this->exists($y); );
						socket_getpeername($z, $i, $j);
						$this->sockets[$y]['server'] = $this->getnamebysocket($b);
						$this->sockets[$y]['sock'] = $z;
						$this->sockets[$y]['read'] = '';
						$this->sockets[$y]['ip'] = $i;
						$this->sockets[$y]['port'] = $j;
						$this->sockets[$y]['type'] = 'serverclient';
						$this->newclient[$y] = $this->getnamebysocket($b);
					}
				}
				else {
					$c = @socket_read($b, $length, PHP_BINARY_READ);
					if ((!strlen($c)) || ($c === false)) {
						if ($this->sockets[$name]['read'] === false) {
							if (($d = $this->getnamebysocket($b)) !== false) $this->close($d);
							else @socket_close($b);
							return false;
						}
						$c = $this->sockets[$name]['read'];
						$this->sockets[$name]['read'] = false;
						return $c;
					}
					else {
						if ((($d = $this->getnamebysocket($b)) !== false)) {
							$this->sockets[$d]['read'] .= $c;
						}
					}
				}
			}
		}
		if ($a =& $this->sockets[$name]['read']) {
			if (preg_match("/^([^\n]*)[\n](.*)/s", $a, $r)) {
				$a = $r[2];
				return str_replace(Array("\r", "\n"), '', $r[1]);
			}
		}
		return '';
	}

	public function newclient($name) {
		$name = strtolower($name);
		if (!$this->exists($name)) {
			$this->errors[] = 'Unknow socket name '.$name.' (line: '.__LINE__.')';
			return false;
		}
		if ($this->gettype($name) != 'server') {
			$this->errors[] = 'listenqueue: '.$name.' is not a server socket (line: '.__LINE__.')';
			return false;
		}
		if ((bool) $this->newclient) {
			foreach ($this->newclient as $a => $b) {
				if ($b == $name) {
					unset($this->newclient[$a]);
					return $a;
				}
			}
		}
		return false;
	}

	public function close($name) {
		$name = strtolower($name);
		if (!$this->exists($name)) {
			$this->errors[] = 'Unknow socket name '.$name.' (line: '.__LINE__.')';
			return false;
		}
		if (isset($this->newclient[$name])) unset($this->newclient[$name]);
		if (isset($this->sockets[$name]['sock'])) @socket_close($this->sockets[$name]['sock']);
		unset($this->sockets[$name]);
		return true;
	}

	public function write($name, $data, $lf = true) {
		$name = strtolower($name);
		if (!$this->exists($name)) {
			$this->errors[] = 'Unknow socket name '.$name.' data : '.(ereg('PASS',$data) === 1 ? 'PASS ******' : $data).' (line: '.__LINE__.')';
			return false;
		}
		if ($lf) $data .= "\n";
		if ((socket_write($this->sockets[$name]['sock'], $data, strlen($data))) === false) return false;
		return true;
	}

	public function rename($name, $newname) {
		$name = strtolower($name);
		$newname = strtolower($newname);
		if (!$this->exists($name)) {
			$this->errors[] = 'Unknow socket name '.$name.' (line: '.__LINE__.')';
			return false;
		}
		if ($this->exists($newname)) {
			$this->errors[] = 'Socket name '.$newname.' already exists (line: '.__LINE__.')';
			return false;
		}
		$this->sockets[$newname] = $this->sockets[$name];
		unset($this->sockets[$name]);
		return true;
	}

	public function exists($name) {
		$name = strtolower($name);
		if (isset($this->sockets[$name])) return true;
		return false;
	}

	private function getnamebysocket($sock) {
		foreach ($this->sockets as $a => $b) {
			if ($b['sock'] == $sock) return $a;
		}
		return false;
	}

	private function gettype($name) {
		$name = strtolower($name);
		if (!$this->exists($name)) {
			$this->errors[] = 'Unknow socket name '.$name.' (line: '.__LINE__.')';
			return false;
		}
		if (isset($this->sockets[$name]['type'])) return $this->sockets[$name]['type'];
		$this->errors[] = 'Unknow option \'type\' for socket '.$name.' (line: '.__LINE__.')';
		return false;
	}

	public function infos($name) {
		$name = strtolower($name);
		if (!$this->exists($name)) {
			$this->errors[] = 'Unknow socket name '.$name.' (line: '.__LINE__.')';
			return false;
		}
		$a = Array('ip' => NULL, 'port' => NULL, 'type' => NULL);
		$b = $this->sockets[$name];
		if (isset($b['ip'])) $a['ip'] = $b['ip'];
		if (isset($b['port'])) $a['port'] = $b['port'];
		if (isset($b['type'])) $a['type'] = $b['type'];
		if (isset($b['server'])) $a['server'] = $b['server'];
		return $a;
	}

	public final function __construct() {
		
		if (!extension_loaded('sockets')) {
			if (strtoupper(substr(PHP_OS, 0, 3)) == 'WIN') {
				@dl('php_sockets.dll') or die('You must have installed socket extension.');
			}
			else {
				@dl('sockets.so') or die('You must have installed socket extension.');
			}
		}
		
	}
	
}
?>