#!/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);
our ($price_call_rec, $price_response_rec);
our ($find_resp_pr1,$find_resp_pr2,$find_resp_pr3);
our ($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 list
+en on
                LocalPort => '18490',  # Port Number Host to listen on
                Proto => 'tcp',
                Listen => 5,
                Reuse => 1,
                );
die "Could not create socket: $!\n" unless $s;

 
$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...\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/incoming connection add to readable set\n";
        $ns = $rh->accept();
        $read_set->add($ns); ##already added at beginning
        print "Value of rh_set is @$rh_set.after adding 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 Co
+nnection
          print    " Port: ", $rh->peerport(), "\n";
        $buf = <$rh>;
        $iroam_req_type = substr($buf,0,8);#Extract the requestor type
        print "Requestor type extracted is: $iroam_req_type\n";#Displa
+y Iroam req
           
        if($buf) { # return normal input and process $buf
          print "Iroam transaction recd:\n";# Iroam Data
            print "$buf\n"; #Display value of the Iroam data from Iroa
+m
          if ($iroam_req_type  =~ /FindMin/){              
              $find_min_request_rec = $buf;
          }elsif ($iroam_req_type  =~ /PriceCall/){
                  $price_call_rec = $buf;     
          }
           pass_transaction_to_iroam_package();
           $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.\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_r
+esp,400);
       $csr->execute() 
        or die "Couldn't exe pass transaction iroam pkg sub ".DBI->err
+str;
    
       $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);
    
    }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_res
+p,400);
     $csr->execute() or die "Couldn't exe pass iroam pkg sub ".DBI->er
+rstr;
    
     $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";
   
}
[download]