Peer responders

bin/upgrade_peer.pl: Added script to upgrade ip:host peer info.
 - This is neeeded because we don't know for sure the port used on a responder
bin/check.sh: call upgrade_peerl script if needed
bin/scenario.pl: new peer_host option

bin/check.sh

@@ -157,6 +157,7 @@ function get_ip
   if [[ $? -ne 0 ]]; then
     error_helper "cannot find $1 ip on ${SCEN_CHECK_DIR}/scenario.csv" 10
   fi
+  peer_host=$(grep "$1" ${SCEN_CHECK_DIR}/scenario.csv|cut -d\; -f3| tr -d '\n')
 }
 
 # $1 sipp xml scenario file
@@ -186,6 +187,13 @@ function run_sipp
   for res in $(find ${SCEN_CHECK_DIR} -type f -name 'sipp_scenario_responder[0-9][0-9].xml'| sort); do
     base=$(basename $res .xml)
     get_ip $(basename $res)
+    if [ "${peer_host}" != "" ]; then
+      echo "$(date) - Update peer_host:${peer_host} ${ip}:${PORT} info"
+      ${BIN_DIR}/update_peer_host.pl --ip=${ip} --port=${PORT} ${peer_host} ${SCEN_CHECK_DIR}/scenario.yml
+      if [[ $? -ne 0 ]]; then
+        error_helper "$(date) - error updating peer info" 15
+      fi
+    fi
     echo "$(date) - Running ${base} $ip:${PORT}-${MPORT}"
     if [ -f ${SCEN_CHECK_DIR}/${base}_reg.xml ]; then
       echo "$(date) - Register ${base} $ip:${PORT}-${MPORT}"

bin/scenario.pl

@@ -103,13 +103,16 @@ sub generate
         $csv->{scenario}->print($io_scenario, $csv_data);
         foreach (@{$_->{responders}})
         {
-            get_subs_info($data->{subscribers}, $_);
+            get_subs_info($data->{subscribers}, $_) unless defined($_->{peer_host});
+            $_->{password} = "" unless defined($_->{password});
             # by default responder is active
             $_->{active} = "yes" unless defined($_->{active});
+            # by default peer_host is empty
+            $_->{peer_host} = "" unless defined($_->{peer_host});
             $auth   = "[authentication username=$_->{username} password=$_->{password}]";
             $csv_data = [$_->{username}, $_->{number}, $auth, $_->{domain}];
             $csv->{callee}->print($io_callee, $csv_data);
-            $csv_data = ["sipp_scenario_responder".sprintf("%02i", $res_id).".xml", $_->{ip}];
+            $csv_data = ["sipp_scenario_responder".sprintf("%02i", $res_id).".xml", $_->{ip}, $_->{peer_host}];
             $csv->{scenario}->print($io_scenario, $csv_data);
             if($_->{register} eq "yes" && $_->{active} eq "yes")
             {

bin/update_peer_host.pl

@@ -0,0 +1,110 @@
+#!/usr/bin/perl
+use strict;
+use warnings;
+
+use Cwd 'abs_path';
+use YAML;
+use Getopt::Long;
+use Sipwise::Provisioning::Voip;
+use Sipwise::Provisioning::Billing;
+use Sipwise::Provisioning::Config;
+use Data::Dumper;
+
+our %CONFIG = ( admin    => 'cmd' );
+
+my $config = Sipwise::Provisioning::Config->new()->get_config();
+
+unless ($CONFIG{password} = $config->{acl}->{$CONFIG{admin}}->{password}) {
+  die "Error: No provisioning password found for user $CONFIG{admin}\n";
+}
+
+sub usage;
+sub call_prov;
+
+my $help = 0;
+my $ip;
+my $port;
+GetOptions ("h|help" => \$help,
+            "i|ip=s" => \$ip,
+            "p|port=i" => \$port)
+  or die("Error in command line arguments\n".usage());
+
+die(usage()) unless (!$help);
+die("Wrong number of arguments\n".usage()) unless ($#ARGV == 1);
+
+our $bprov = Sipwise::Provisioning::Billing->new();
+our $vprov = Sipwise::Provisioning::Voip->new();
+my $data;
+$data->{ip} = $ip unless !defined($ip);
+$data->{port} = $port unless !defined($port);
+die("ip or port option has to be set\n".usage()) unless defined($data);
+
+print Dumper($data), "\n";
+
+do_update($data);
+
+sub do_update {
+    my ($data) = @_;
+    my $filename = abs_path($ARGV[1]);
+    my $r = YAML::LoadFile($filename);
+
+    for (keys $r)
+    {
+        my $peer = $r->{$_};
+        # groups
+        my $group = {}; # name = id
+        my $result = call_prov( $vprov, 'get_peer_groups');
+        foreach (@{$result})
+        {
+            $group->{$_->{name}} = $_->{id};
+        }
+        for (keys $group)
+        {
+            $result = call_prov( $vprov, 'get_peer_group_details', { id => $group->{$_} });
+            foreach (@{$result->{peers}})
+            {
+                if ($_->{name} eq $ARGV[0])
+                {
+                    my $param = {
+                        id => $_->{id},
+                        data => $data
+                    };
+                    call_prov( $vprov, 'update_peer_host', $param);
+                }
+            }
+        }
+    }
+    exit;
+}
+
+sub call_prov {
+    #   scalar,    scalar,    hash-ref
+    my ($prov, $function, $parameter) = @_;
+    my $result;
+
+    eval {
+        $result = $prov->handle_request( $function,
+                                          {
+                                            authentication => {
+                                                                type     => 'system',
+                                                                username => $CONFIG{admin},
+                                                                password => $CONFIG{password},
+                                                              },
+                                            parameters => $parameter,
+                                        });
+    };
+
+    if($@) {
+        if(ref $@ eq 'SOAP::Fault') {
+            die "Voip\::$function failed: ". $@->faultstring;
+        } else {
+            die "Voip\::$function failed: $@";
+        }
+    }
+
+    return $result;
+}
+
+sub usage {
+    return "Usage:\n$0 [-h] [-i IP] [-p PORT] peer_host_name peer.yml\n";
+}