#!C:\\perl\
require Device::USB;
require IO::Socket;
require IO::Select;
 
print "Lancement de l'application rocket-server\n";
 
# Les variables pour cibler le périphérique usb
our $vendorID = 0x1130;
our $productID = 0x0202;
 
# Le périphérique
our $dev;
 
# La première séquence
our $initA = join ('', map { chr $_ } (85, 83, 66, 67,  0,  0,  4,  0));
 
# La seconde
our $initB = join ('', map { chr $_ } (85, 83, 66, 67,  0, 64,  2,  0));
 
# La séquence de commande principale
our $commandFill = join ('', map { chr $_ } (	8,  8,
												0,  0,  0,  0,  0,  0,  0,  0,
												0,  0,  0,  0,  0,  0,  0,  0,
												0,  0,  0,  0,  0,  0,  0,  0,
												0,  0,  0,  0,  0,  0,  0,  0,
												0,  0,  0,  0,  0,  0,  0,  0,
												0,  0,  0,  0,  0,  0,  0,  0,
												0,  0,  0,  0,  0,  0,  0,  0));
 
# La liste des commandes
$commandList->{stop}          = join('', map { chr $_ } ( 0,  0,  0,  0,  0,  0)).$commandFill;
$commandList->{left}          = join('', map { chr $_ } ( 0,  1,  0,  0,  0,  0)).$commandFill;
$commandList->{right}         = join('', map { chr $_ } ( 0,  0,  1,  0,  0,  0)).$commandFill;
$commandList->{up}            = join('', map { chr $_ } ( 0,  0,  0,  1,  0,  0)).$commandFill;
$commandList->{down}          = join('', map { chr $_ } ( 0,  0,  0,  0,  1,  0)).$commandFill;
$commandList->{leftup}        = join('', map { chr $_ } ( 0,  1,  0,  1,  0,  0)).$commandFill;
$commandList->{rightup}       = join('', map { chr $_ } ( 0,  0,  1,  1,  0,  0)).$commandFill;
$commandList->{leftdown}      = join('', map { chr $_ } ( 0,  1,  0,  0,  1,  0)).$commandFill;
$commandList->{rightdown}     = join('', map { chr $_ } ( 0,  0,  1,  0,  1,  0)).$commandFill;
$commandList->{fire}          = join('', map { chr $_ } ( 0,  0,  0,  0,  0,  1)).$commandFill;
 
# La méthode du périphérique USB
sub _initUSB
{
	# Séquence de démarrage
	print "Recherche du peripherique...\n";
 
	# Créer le contrôleur USB
	my $usb = Device::USB->new();
 
	# Recherche le périphérique
	$dev = $usb->find_device($vendorID, $productID);
 
	# Vérifier si le périphérique à été trouvé
	if (defined $dev)
	{
		# Initialiser le périphérique
		$dev->open();
		$dev->detach_kernel_driver_np(0);
		$dev->set_configuration(1);
		$dev->claim_interface(0);
		$dev->claim_interface(1);
 
		# C'est ok
		return 1;
	}
	else
	{
		# C'est pas ok
		return 0;
	}
}
 
# Envoyer des données
sub _sendUSB
{
	# Récupérer la commande
	my $commande = $_[0];
 
	# Envoie de la commande
	print "Envoie de la commande '".$commande."'\n";
 
	# Vérifier que cette commande existe bien
	if (defined $commandList->{$commande})
	{
		# Envoyer la commande
		$dev->control_msg(0x21, 9, 0x2, 0x01, $initA, 8, 1000);
		$dev->control_msg(0x21, 9, 0x2, 0x01, $initB, 8, 1000);
		$dev->control_msg(0x21, 9, 0x2, 0x0, $commandList->{$commande}, 64, 5000);
 
		# La commande a été envoyée
		print "Commande ok\n";
		return 1;
	}
	else
	{
		# On dit que ça marche pas
		print "Erreur: Commande introuvable.\n";
		return 0;
	}
}
 
# Initialisation du socket
sub _initSocket
{
	print "En attente de connection sur le port 1337\n";
 
	# Configurer le socket
	$/ = "\0";
 
	# Ouverture du socket
	my $server = IO::Socket::INET->new(LocalAddr => "localhost", LocalPort => 1337, Reuse => 1, Listen => 5, Proto => 'TCP') or return 0;
	my $listener = new IO::Select($server);
 
	# Ecouter les nouvelles connections
	while(my @data = $listener->can_read)
	{
		# Décortiquer les données
		foreach (@data)
		{
			# Nouvelle connection
			if ($_ == $server)
			{
				# Accepter la connection
				my $client = $server->accept;
 
				# Ajouter cet utilisateur
                $listener->add($client);
 
				# Signaler
				print "Connection ok\n";
			}
			else
			{
				# Récéption d'un message
				my $sysreadReturn = sysread($_, $infoRead, 2048);
 
				# Le message est vide
				if($sysreadReturn == 0)
				{
					# Message de déconnection
					$syswriteToClient = syswrite($_, '', 2048);
 
					# Déconnecter le client
					if($syswriteToClient == undef)
					{
						# L'enlever de la liste
						$listener -> remove($_);
 
						# Deconnection
						print "Deconnection...\n";
 
						# Péter la boucle
						return 1;
					}
				}
				else
				{
					# Tronquer la commande (bug de l'espace de fin)
					$command = substr($infoRead, 0, length($infoRead) - 1);
 
					# Exécuter la commande
					print "Receotion de la commande: [".$command."]\n";
 
					# Envoyer la commande au pilote USB
					_sendUSB($command);
				}
			}
		}
	}
 
	# Fin
	return 1;
}
 
# Initialiser
if (_initUSB())
{
	# Le périphérique à été trouvé, youpi
	print "Peripherique ok (".$dev->idVendor.", ".$dev->idProduct.")\n";
 
	# Initialiser le socket
	if (!_initSocket())
	{
		print "Erreur: Impossible de creer le socket!\n";
	}
}
else
{
	# Le périphérique n'a pas été trouvé
	print "Erreur: Le peripherique n'a pas ete trouve\n";
}
 
# Fermeture du programme
print "Fermeture du programme.\n";