#!/usr/bin/perl -w
require 5.002;
use strict;
use IO::Socket;
use IO::Select;
use DBI;
use DBD::Oracle;

our ($dbh);
our ($find_min_request_rec, $find_response_rec, $price_call_rec, $price_response_rec);
our($find_resp_pr1,$find_resp_pr2,$find_resp_pr3,$find_resp_pr4,$find_resp_pr5);
our  $read_set ;
our $rh;
our $ns;
our $buf;
our $find_resp;
our $iroam_req_type;

# Create the receiving socket
my $s = new IO::Socket::INET (
                         LocalHost => '172.17.8.201', # IP Address Host to listen on
                         LocalPort => '18490',  # Port Number Host to listen on
                         Proto => 'tcp',
                         Listen => 5,
                         Reuse => 1,
                        );
die "Could not create socket: $!\n" unless $s;

$find_resp = 'GCD 000'; #Used in Testing 
 
$read_set = new IO::Select(); # create handle set for reading
$read_set->add($s);           # add the main socket to the set
 
connect_to_oracle_db();

print "At Host/Port listening. Waiting to receive transactions from Iroam Client...\n";

while (1) { # Continous Listening on Port for a connection
    
        # get a set of readable handles (blocks until at least one handle is ready)
   my ($rh_set) = IO::Select->select($read_set, undef, undef, 0);
   
        # take all readable handles in turn
   foreach $rh (@$rh_set) {
   print "Process each readable handle...\n";
   print "Value of rh is $rh...\n";
   print "Value of rh_set is @$rh_set..\n";
          # if it is the main socket then we have an incoming connection and
          # we should accept() it and then add the new socket to the $read_set 
      if ($rh == $s) {
          print "Main socket and incoming connection.. add to the readable set...\n";
         $ns = $rh->accept();
         $read_set->add($ns); ##already added at beginning
         print "Value of rh_set is @$rh_set..after adding ns connection\n";
         # otherwise it is an ordinary socket and we should read and process the request
      }else{
           print "Its an ordinary socket, so read and process the request ...\n";
           print 	"Connected from: ", $rh->peerhost();  # Display Peer Connection from Info
	   print	" Port: ", $rh->peerport(), "\n";
           $buf = <$rh>;
           $iroam_req_type = substr($buf,0,8);   #Extract the requestor type from the string sent from the Iroam Client
           print "Requestor type extracted from the Iroam Data: $iroam_req_type||Requestor Type\n";   #Display value of the Iroam requestor
           
           if($buf) { # return normal input and process $buf
              print "Iroam transaction received from Iroam Client:\n"; #Display value of the Iroam data from Iroam
	            print "$buf\n"; #Display value of the Iroam data from Iroam
              if ($iroam_req_type  =~ /FindMin/){              
                  $find_min_request_rec = $buf;
              }elsif ($iroam_req_type  =~ /PriceCall/){
                  $price_call_rec = $buf;     
              }
              pass_transaction_to_iroam_package();
              ###print "s  send value is: $s->send($find_response_rec) \n";
              ###$s->send($find_response_rec);
              $rh->send($find_response_rec);
              print "rh send value is: $rh->send($find_response_rec) \n";
            }else { # the client has closed the socket
            print "Iroam client has closed the socket. Socket will be removed from the readbale set and closed...\n";
               # remove the socket from the $read_set and close it
             $read_set->remove($rh);
             close($rh);
         }
      }
   }
 }

sub connect_to_oracle_db{
    
    print "Connect to the Oracle Database sub....\n";
    
    $dbh = DBI->connect(
                                        'DBI:Oracle:dev',
                                        'perluser',
                                        'oraperl',
                                            {AutoCommit => 0, RaiseError => 1}
                                ) or die "Couldn't connect to database:".DBI->errstr;
}

sub pass_transaction_to_iroam_package{
       
    print "pass transaction to iroam package sub....\n";
    
    my $v_param_iroam_resp;
       
    if ($iroam_req_type  =~ /FindMin/){
        my $csr = $dbh->prepare(q{
                                   begin
                                     :v_param_iroam_resp:= WIRELESS_IROAM_PKG.Lookup_Min_Request(:find_min_request_rec);
                                  end;
                        });
       $csr->bind_param(":find_min_request_rec", $find_min_request_rec);
       $csr->bind_param_inout(":v_param_iroam_resp", \$v_param_iroam_resp,400);
       $csr->execute() or die "Couldn't execute pass transaction to iroam package sub ".DBI->errstr;
    
       $find_response_rec = $v_param_iroam_resp;
        
        $find_resp_pr1 = substr($find_response_rec ,0,90);
        $find_resp_pr2 = substr($find_response_rec ,91,90);
        $find_resp_pr3 = substr($find_response_rec ,182,90);
        $find_resp_pr4 = substr($find_response_rec ,273,90);
        $find_resp_pr5 = substr($find_response_rec ,364,11);
        print "Value of v param iroam resp is: $v_param_iroam_resp\n";
        print "Value of find response rec is:  $find_resp_pr1\n";
        print "Value of find response rec is:  $find_resp_pr2\n";
        print "Value of find response rec is:  $find_resp_pr3\n";
        print "Value of find response rec is:  $find_resp_pr4\n";
        print "Value of find response rec is:  $find_resp_pr5\n";
    
    }elsif ($iroam_req_type  =~ /PriceCall/){
             my $csr = $dbh->prepare(q{
                                   begin
                                     :v_param_iroam_resp:= WIRELESS_IROAM_PKG.Price_Call(:price_call_rec);
                                  end;
                        });
       $csr->bind_param(":price_call_rec", $price_call_rec);
       $csr->bind_param_inout(":v_param_iroam_resp", \$v_param_iroam_resp,400);
       $csr->execute() or die "Couldn't execute pass transaction to iroam package sub ".DBI->errstr;
    
       $price_response_rec = $v_param_iroam_resp;
             
        print "Value of v param iroam resp is:  $v_param_iroam_resp\n";
        print "Value of price response is:  $price_response_rec \n";   
       
    }
    
    print "Processed transaction through the Iroam package\n"; # Inform that connection to client is closed
   
}