#!/usr/bin/perl
#use strict;

# use both POE server and the filter needed
use POE qw(Component::Server::TCP Filter::Reference);
use CUPPS::Cupps;

my $Dest = Value("DestinationXMLLocation");
my $Src = Value("SourceXMLLocation");


POE::Component::Server::TCP->new(
  Alias        => "sum_server",
  Port         => 11211,
  ClientFilter => "POE::Filter::Reference",
  ClientPreConnect => sub {
     sleep(1);
     $socket = $_[ARG0];
	 sysread($socket, $buf, 1000);
	 print "Result = $buf\n";
	 open(FH,"$Src\\interfaceLevelsAvailableResponse-OK.xml");
     $buf = join("", <FH>);
     close(FH);
	 print "\n";
	 
	 syswrite($socket, $buf, 1000);
	 print "\n";
	$buffer = $buf;
	while ($buffer eq $buf) {
	sysread($socket, $buf, 1000);
	}
	 print "Result = $buf\n";
	 open(FH,"$Src\\interfaceLevelResponse-OK.xml");
     $buf = join("", <FH>);
     close(FH);
	 
	 syswrite($socket, $buf, 1000);
  },
  ClientInput => sub {
  },
);

POE::Component::Server::TCP->new(
  Alias        => "sum_server",
  Port         => 11212,
  ClientFilter => "POE::Filter::Reference",
  ClientPreConnect => sub {
     sleep(1);
     $socketd = $_[ARG0];
	 sysread($socketd, $bufd, 1000);
	 print "Result = $bufd\n";
	 open(FHD,"$Src\\authenticateResponse-OK.xml");
     $bufd = join("", <FHD>);
     close(FHD);
	 print "\n";
	 
	 syswrite($socketd, $bufd, 1000);
	 print "\n";
	$bufferd = $bufd;
	while ($bufferd eq $bufd) {
	sysread($socketd, $bufd, 1000);
	}
	 print "Result = $bufd\n";
	 open(FHD,"$Src\\byeResponse-OK.xml");
     $bufd = join("", <FHD>);
     close(FHD);
	 
	 syswrite($socketd, $bufd, 1000);
  },
  ClientInput => sub {
  },
);

$poe_kernel->run();
exit 0;