#!/usr/local/bin/php
<?php
/**
* Projet WIG (Wdmédia IRC Gateway)
* Passerelle de liaison IRC / flash
* IRC / flash Gateway
*
* Ce code est sous license
* Creative Commons Attribution-NonCommercial-ShareAlike 1.0
* Plus d'information : http://creativecommons.org/licenses/by-nc-sa/1.0/
*
* @author Nicolas Lafont aka Manico (wig@wdmedia.net)
* @copyright Copyright 2003,2004 Nicolas Lafont aka Manico
* @package WIG
* @link http://www.wdmedia.org/WIG/
* @version 0.7
* @since 10-12-2003
* @last-modified 06-08-2004
*/

/*
* Configuration
*/
define('IRC_ADDR', '127.0.0.1');
define('IRC_PORT', '6667');
define('FLASH_ADDR', '127.0.0.1');
define('FLASH_PORT', '6679');
define('MAXLINE', '2048');
define('MAXCONCURRENT', '25');
/*
* Fin de la configuration
*/

// Modification de configuration php
error_reporting (E_ALL);
set_time_limit(0);
ob_implicit_flush ();

// Fonction de decodage utf8
// hack for utf8
function smart_utf8_decode($in_str) {
   $new_str = str_replace('?', 'q0u0e0s0t0i0o0n', $in_str);
   $new_str=utf8_decode($new_str);
   if (strpos($new_str,'?') !== false) {
       $new_str=$in_str;
   } else {
       $new_str = str_replace('q0u0e0s0t0i0o0n', '?', $new_str);
   }
   return $new_str;
}

// Création du socket d'écoute (vers flash)
$socketHandler = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ( !$socketHandler ) {
	fwrite(STDOUT, 'Creation du socket vers le flash [FAILED]'."\n");
	fwrite(STDOUT, 'Erreur lors du socket_create : '.socket_strerror($socketHandler)."\n");
} else {
	fwrite(STDOUT, 'Creation du serveur [OK]'."\n");
}

// Adressage du socket
socket_setopt($socketHandler, SOL_SOCKET, SO_REUSEADDR, 1);
$bindRes = socket_bind($socketHandler, FLASH_ADDR, FLASH_PORT);
if ( !$bindRes ) {
	fwrite(STDOUT, 'Erreur lors du socket_bind du flash : '.socket_strerror($bindRes)."\n");
} else {
	fwrite(STDOUT, 'Socket du flash adressé : '."\n");
}

// Mise en ecoute
$listenRes = socket_listen($socketHandler, MAXCONCURRENT);
if ( !$listenRes ) {
	fwrite(STDOUT, 'Erreur lors du socket_listen du flash  '."\n");
} else {
	fwrite(STDOUT, 'Socket du flash en écoute  '."\n");
}

// Initialisation des clients flash
$maxi = -1;
for ($i = 0; $i < MAXCONCURRENT; $i++) {
	$client[$i] = null;
	$clientBuff[$i] = '';
}

// Initialisation des liaison irc
$maxi = -1;
for ($i = 0; $i < MAXCONCURRENT; $i++) {
	$irc[$i] = null;
	$ircBuff[$i] = '';
}

$h = 0;
// Boucle Principale
while(true) {
	++$h;
	// On recompose le tableau tabSocket
	// Socket Principal
	$tabSocket[0] = $socketHandler;
	// Les clients flash
	for ($i = 0; $i < MAXCONCURRENT; $i++) {
		if ($client[$i] != null)  {
			$tabSocket[$i + 1] = $client[$i];
		}
	}
	// Les liaisons irc
	for ($i = 0; $i < MAXCONCURRENT; $i++) {
		if ($irc[$i] != null)  {
			$tabSocket[MAXCONCURRENT + $i] = $irc[$i];
		}
	}

	// On nettoie les connexion fermees
	foreach ($tabSocket as $key=>$value) {
		if (get_resource_type($value)=='Unknown') {
			unset($tabSocket[$key]);
		}
	}

	// On bloque en attendant une connexion
	$pret = socket_select($tabSocket, $null = null, $null = null, null);

	// Si on detecte une nouvelle connexion
	if (in_array($socketHandler, $tabSocket)) {
		for ($i=0; $i < MAXCONCURRENT; $i++) {
			if ($client[$i]==null) {
				// On se met à l'écoute
				$client[$i] = socket_accept($socketHandler);
				socket_setopt($client[$i], SOL_SOCKET, SO_REUSEADDR, 1);
				socket_getpeername($client[$i], $remote_host[$i], $remote_port[$i]);
				// On fait une liaison à l'ircd
				$todisconnect = false;
				$irc[$i] = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
				if(!$irc[$i]) {
					$todisconnect = true;
				} else {
					$test = socket_connect($irc[$i], IRC_ADDR, IRC_PORT);
					if(!$test) {
						$todisconnect = true;
					}
				}
				if ($todisconnect) {
					// Y'a eut un probleme de connexion irc, on deconnecte le client
					socket_shutdown($client[$i]);
					socket_close($client[$i]);
					$client[$i] = null;
					unset($remote_host[$i]);
					unset($remote_port[$i]);
				}
				break;
			}
			if ($i == MAXCONCURRENT - 1) {
				echo 'Trop de clients'."\n";
			}
		}
		if ($i>$maxi) {
			$maxi = $i;
		}
		if (--$pret<=0) {
			continue;
		}
	}

	// On balaye les clients pour voir si un client a parlé
	for ($i = 0; $i <= $maxi; $i++) {
		if ($client[$i]==null) {
			continue;
		}
		if (in_array($client[$i], $tabSocket)) {
			$buff = trim(socket_read($client[$i], MAXLINE));
			if (!$buff) {
				// On ferme la connexion flash
				socket_shutdown($client[$i]);
				socket_close($client[$i]);
				$client[$i] = null;
				unset($remote_host[$i]);
				unset($remote_port[$i]);
				// On ferme la connexion ircd
				socket_shutdown($irc[$i]);
				socket_close($irc[$i]);
				$irc[$i] = null;
			} else {
				// On modifie les < pour que ca passe bien
				$buff = str_replace('&lt;','<', $buff);
				// On envoie du flash vers le irc
				socket_write($irc[$i], $buff."\n");
			}
		}
	}

	// On balaye connexionx irc pour voir si un irc a parlé
	for ($i = 0; $i <= $maxi; $i++) {
		if ($irc[$i]==null) {
			continue;
		}
		if (in_array($irc[$i], $tabSocket)) {
			$buff = trim(socket_read($irc[$i], MAXLINE));
			if (!$buff) {
				// On ferme la connexion flash
				socket_shutdown($client[$i]);
				socket_close($client[$i]);
				$client[$i] = null;
				unset($remote_host[$i]);
				unset($remote_port[$i]);
				// On ferme la connexion ircd
				socket_shutdown($irc[$i]);
				socket_close($irc[$i]);
				$irc[$i] = null;
			} else {
				// On decode si c'est en utf8
				$buff = smart_utf8_decode($buff);
				// On modifie les < en &lt;
				$buff = str_replace('<', '&lt;', $buff);
				// On envoie de irc vers flash
				$tabout = explode("\r\n", $buff);
				foreach($tabout as $value) {
					socket_write($client[$i], $value."\0");
				}
			}
		}
	}
}

// Fermeture du serveur
socket_close($socketHandler);
?>