#!/usr/bin/perl
#LSPhabrix.pl

use strict;
use warnings;
use IO::Socket::INET;
use POSIX;
use Term::ReadKey;

my $data = 0;
my $InputRed = 0;
my $InputGreen = 0;
my $InputBlue = 0;
my $scaling = 0;
my $KeyScale = 0;

# flush after every write
#$| = 1;

# there are no newlines, so use last tag as delimiter
IO::Handle->input_record_separator('</calibration>');
my ($Lssocket,$LSclient_socket);
my ($Pxsocket,$Pxclient_socket);

# user input and other minutia here
	
# Connect to Lightspace and listen
print "Connecting to Lightspace... ";
$Lssocket = new IO::Socket::INET (
	PeerHost => '127.0.0.1',
	PeerPort => '20002',
	Proto => 'tcp',
	Blocking => 0,
) or die "ERROR connecting to Lightspace : $!\n";

print "Connected to Lightspace.\n";

while ($data = <$Lssocket>) {
	#print "Received from Server : $data\n";
	
	$InputRed = index $data, "red=\"";
	$InputGreen = index $data, "green=\"";
	$InputBlue = index $data, "blue=\"";
	if ($InputRed == -1) {
		print "msg from server ng - no color data found\n";
		last;
	}
	
	#take the indexes and adjust to get the whole number

	# ------------ doing some math here that we don't need to worry about -------
	
	# and send them out
	phabrix ("4700", $InputRed);
        # *********** USUALLY HANGS HERE
	phabrix ("4800", $InputGreen);
        # ************ OR HERE 
	phabrix ("4900", $InputBlue);
	
	print "\n";
}

$Lssocket->close();

# phabrix subroutine
sub phabrix {
	# call using phabrix( command , value ) 
	# Where:	
	#		command is a string of 4 hex digits ie "0500"
	#		value is an unsigned int
	# Remember for command that hex is in intel little endian small byte first 
	# Also, because phabrix doesn't always respond or ack, we will do the 
	# operation up to 3 times before giving up and erroring out.
	print "\n*";
	my $Pxsocket = 0;
	$Pxsocket = new IO::Socket::INET (
		PeerHost => '192.168.200.5',
		PeerPort => '2100',
		Proto => 'tcp',
	) or die "ERROR connecting to Phabrix : $!\n";
	
	my $magicNumber = pack "H8", "12cb5aa5";
	my $commandType = pack ("H4", "0500");
	my $command = shift;
	my $spacer = pack ("H16", "0000000000000000");
	my $value = shift;
	my $phabrix_ACK = pack ("H12", "12cb5aa50000");
	my $response = 0;
	my $errCount = 0;
	
	# pack command and value
	$command = pack ("H4", $command);
	$value = pack ("L", $value);
		
	while (1) {
		# send command
		$Pxsocket->send($magicNumber);
		$Pxsocket->send($commandType);
		$Pxsocket->send($command);
		$Pxsocket->send($spacer);
		$Pxsocket->send($value);
		print "sent ";
		print (unpack ("H*",$magicNumber));
		print (unpack ("H*",$commandType));
		print (unpack ("H*",$command));
		print (unpack ("H*",$spacer));
		print (unpack ("H*",$value));
		print " - ";
		#get response
		$Pxsocket->recv($response,6);
		print " recv ";
		print (unpack ("H*", $response));
		print "";
		
		if ($response eq $phabrix_ACK) {
			print " ACK($errCount)";
			last;
		} elsif ($errCount == 3) {
			#die "ERROR Too many retries to Phabrix.  Exiting!\n";
			$Pxsocket->close();
			print "NO Ack, skipping";
			last;
		} else {
			$Pxsocket->close();
			$errCount = $errCount + 1;
			sleep (1);
		}
	}
}