sipwise
/
kamailio-config-tests
mirror of https://github.com/sipwise/kamailio-config-tests.git
1
0
Fork 0
Code Issues Releases Wiki Activity

MT#7571 bin/create_rewrite_rules.pl: use REST API

Browse Source 
Change-Id: Icbefc9291c8c5719485b34c68fb5256517795de2
changes/74/3974/3
Victor Seva 10 years ago
parent 1c77b3df68
commit 9a7814994b
3 changed files with 91 additions and 93 deletions
Show Stats Download Patch File Download Diff File

2
bin/check.sh
Unescape View File

@ -151,7 +151,7 @@ function delete_voip
if [ -f "${SCEN_CHECK_DIR}/rewrite.yml" ]; then if [ -f "${SCEN_CHECK_DIR}/rewrite.yml" ]; then
echo "$(date) - Deleting rewrite rules" echo "$(date) - Deleting rewrite rules"
"${BIN_DIR}/create_rewrite_rules.pl" -d "${SCEN_CHECK_DIR}/rewrite.yml" "${BIN_DIR}/create_rewrite_rules.pl" -delete "${SCEN_CHECK_DIR}/rewrite.yml"
fi fi
if [ -f "${SCEN_CHECK_DIR}/hosts" ]; then if [ -f "${SCEN_CHECK_DIR}/hosts" ]; then

155
bin/create_rewrite_rules.pl
Unescape View File

@ -22,66 +22,56 @@ use strict;
use warnings; use warnings;
use English; use English;
use Getopt::Std; use Getopt::Long;
use Cwd 'abs_path'; use Cwd 'abs_path';
use Config::Tiny;
use Sipwise::API qw(all);
use YAML; use YAML;
use Getopt::Long;
use Sipwise::Provisioning::Voip;
use Sipwise::Provisioning::Billing;
use Sipwise::Provisioning::Config;
our %CONFIG = ( admin => 'cmd' );
my $config = Sipwise::Provisioning::Config->new()->get_config(); my $config = Config::Tiny->read('/etc/default/ngcp-api');
my $opts;
unless ($CONFIG{password} = $config->{acl}->{$CONFIG{admin}}->{password}) { if ($config) {
die "Error: No provisioning password found for user $CONFIG{admin}\n"; $opts = {};
$opts->{host} = $config->{_}->{NGCP_API_IP};
$opts->{port} = $config->{_}->{NGCP_API_PORT};
$opts->{sslverify} = $config->{_}->{NGCP_API_SSLVERIFY};
} }
my $api = Sipwise::API->new($opts);
$opts = $api->opts;
my $del;
sub usage; sub usage {
sub call_prov; return "Usage:\n$PROGRAM_NAME rewrite.yml\n".
"Options:\n".
" -delete\n".
" -d debug\n".
" -h this help\n";
}
my $help = 0; my $help = 0;
my $del = 0;
GetOptions ("h|help" => \$help, GetOptions ("h|help" => \$help,
"d|delete" => \$del) "d|debug" => \$opts->{verbose},
or die("Error in command line arguments\n".usage()); "delete" => \$del)
or die("Error in command line arguments\n".usage());
die(usage()) unless (!$help); die(usage()) unless (!$help);
die("Wrong number of arguments\n".usage()) unless ($#ARGV == 0); die("Wrong number of arguments\n".usage()) unless ($#ARGV == 0);
our $bprov = Sipwise::Provisioning::Billing->new();
our $vprov = Sipwise::Provisioning::Voip->new();
my $filename = abs_path($ARGV[0]);
my $r = YAML::LoadFile($filename);
if ($del)
{
do_delete($r);
}
else
{
do_create($r);
}
sub do_delete sub do_delete
{ {
my ($data) = @_; my ($data) = @_;
for my $rule_set_name (keys $data) for my $rule_set_name (keys %{$data})
{ {
my $rule_set; my $param = { reseller_id => 1, name => $rule_set_name };
my $result = call_prov( $vprov, 'get_rewrite_rule_sets'); my $rws_id = $api->check_rewriteruleset_exists($param);
foreach (@{$result}) if(defined $rws_id) {
{ if($api->delete_rewriteruleset($rws_id)) {
$rule_set->{$_->{name}} = $_->{id}; print "rewriteruleset [$rule_set_name] deleted [$rws_id]\n";
}
if ($rule_set)
{
for my $rule_set_name (keys $rule_set)
{
call_prov($vprov, 'delete_rewrite_rule_set', {id => $rule_set->{$rule_set_name}});
} }
else {
die "rewriteruleset [$rule_set_name] can't be removed [$rws_id]\n";
}
} else {
print "rewriteruleset [$rule_set_name] not there\n";
} }
} }
exit; exit;
@ -90,58 +80,45 @@ sub do_delete
sub do_create sub do_create
{ {
my ($data) = @_; my ($data) = @_;
for my $rule_set_name (keys $data) for my $rule_set_name (keys %{$data})
{ {
my $param = { name => $rule_set_name }; my $param = { reseller_id => 1, name => $rule_set_name };
call_prov( $vprov, 'create_rewrite_rule_set', $param ); my $rws_id = $api->check_rewriteruleset_exists($param);
} if(defined $rws_id) {
my $rule_set; print "rewriteruleset [$rule_set_name] already there [$rws_id]\n";
my $result = call_prov( $vprov, 'get_rewrite_rule_sets'); } else {
foreach (@{$result}) $rws_id = $api->create_rewriteruleset($param);
{ print "rewriteruleset [$rule_set_name] created [$rws_id]\n";
$rule_set->{$_->{name}} = $_->{id}; }
} foreach my $param (@{$data->{$rule_set_name}}) {
# rules $param->{set_id} = $rws_id;
for my $rule_set_name (keys $data) my $rw_id = $api->create_rewriterule($param);
{ if(defined $rw_id) {
my $rs = $data->{$rule_set_name}; print "rewriterule [".
foreach (@{$rs}) $param->{field}."/".$param->{direction}.
{ "] created [$rw_id]\n";
my $param = { set_id => $rule_set->{$rule_set_name}, data => $_ }; }
call_prov($vprov, 'create_rewrite_rule', $param); else {
die "Can't create rewriterule"
}
} }
} }
exit; exit;
} }
sub call_prov { sub main {
# scalar, scalar, hash-ref my $r = shift;
my ($prov, $function, $parameter) = @_;
my $result;
eval {
$result = $prov->handle_request( $function,
{
authentication => {
type => 'system',
username => $CONFIG{admin},
password => $CONFIG{password},
},
parameters => $parameter,
});
};
if($EVAL_ERROR) { if ($del)
if(ref $EVAL_ERROR eq 'SOAP::Fault') { {
die "Voip\::$function failed: ". $EVAL_ERROR->faultstring; print "delete rewriterules\n" unless $opts->{debug};
} else { return do_delete($r);
die "Voip\::$function failed: $EVAL_ERROR"; }
} else
{
print "create rewriterules\n" unless $opts->{debug};
return do_create($r);
} }
return $result;
} }
sub usage { main(YAML::LoadFile(abs_path($ARGV[0])));
return "Usage:\n$PROGRAM_NAME scenario.yml\n";
}

27
lib/Sipwise/API.pm
Unescape View File

@ -97,9 +97,10 @@ sub do_query {
my $ua = shift; my $ua = shift;
my $url = shift; my $url = shift;
my $data = shift; my $data = shift;
my $req_type = shift || 'GET';
my $URL = URI->new($url); my $URL = URI->new($url);
$URL->query_form($data); $URL->query_form($data);
my $req = HTTP::Request->new('GET', $URL); my $req = HTTP::Request->new($req_type, $URL);
my $res = $ua->request($req); my $res = $ua->request($req);
if(!$res->is_success) { if(!$res->is_success) {
@ -153,6 +154,16 @@ sub _create {
return; return;
} }
sub _delete {
my $self = shift;
my $urldata = shift;
my $urlbase = 'https://'.$self->{opts}->{host}.':'.$self->{opts}->{port};
my $ua = $self->create_ua();
my $res = $self->do_query($ua, $urlbase.$urldata, undef, 'DELETE');
return $res->is_success;
}
sub _get_content { sub _get_content {
my $self = shift; my $self = shift;
my $data = shift; my $data = shift;
@ -195,7 +206,9 @@ sub _exists {
my $collection = $self->_get_content($data, $urldata); my $collection = $self->_get_content($data, $urldata);
if (defined $collection && $collection->{total_count} == 1) { if (defined $collection && $collection->{total_count} == 1) {
return $collection->{_embedded}->{$collection_id}->{id}; my $links = $collection->{_embedded}->{$collection_id}->{_links};
my $href = $links->{$collection_id}->{href};
return _get_id($urldata, $href);
} }
return; return;
} }
@ -363,7 +376,7 @@ sub check_rewriteruleset_exists {
my $self = shift; my $self = shift;
my $data = shift; my $data = shift;
my $urldata = '/api/rewriterulesets/'; my $urldata = '/api/rewriterulesets/';
my $collection_id = 'ngcp:rewriterules'; my $collection_id = 'ngcp:rewriterulesets';
return $self->_exists($data, $urldata, $collection_id); return $self->_exists($data, $urldata, $collection_id);
} }
@ -375,3 +388,11 @@ sub create_rewriteruleset {
return $self->_create($data, $urldata); return $self->_create($data, $urldata);
} }
sub delete_rewriteruleset {
my $self = shift;
my $id = shift;
my $urldata = "/api/rewriterulesets/${id}";
return $self->_delete($urldata);
}

Write Preview
Loading…
Cancel
Save