- prefs.yml -> prefs.json solving true/1 problem - disable non working scenarios: * incoming_foreign_dom * incoming_peer * invite_concurrent_max_out * invite_concurrent_max_out_per_account * invite_ignore_allowip * invite_peerout * invite_peerout_rewrite * invite_peerout_rewrite_pv_regex * register_allowip * register_ignore_allowip missing API parts: - peers settings - add/modify/delete peers * bin/create_peers.pl * bin/update_peer_host.pl TODO: - bin/create_ncos.pl - bin/create_rewrite_rules.pl - bin/create_subscribers_rewrite_rules.pl - bin/create_subscribers_speeddial_rules.pl Change-Id: I6d47e24669f9da22b5b3ac4fb410c50d2c9dbf53changes/66/2666/14
Victor Seva
11 years ago
parent
fc685d65b0
commit
129397e6fc
@ -1,5 +1,6 @@
|
||||
bench.sh /usr/share/kamailio-config-tests/
|
||||
bin/ /usr/share/kamailio-config-tests/
|
||||
get_results.sh /usr/share/kamailio-config-tests/
|
||||
lib/ /usr/share/kamailio-config-tests/
|
||||
run_tests.sh /usr/share/kamailio-config-tests/
|
||||
scenarios/ /usr/share/kamailio-config-tests/
|
||||
|
||||
@ -0,0 +1,377 @@
|
||||
#
|
||||
# Copyright: 2013-2015 Sipwise Development Team <support@sipwise.com>
|
||||
#
|
||||
# This program is free software: you can redistribute it and/or modify
|
||||
# it under the terms of the GNU General Public License as published by
|
||||
# the Free Software Foundation, either version 3 of the License, or
|
||||
# (at your option) any later version.
|
||||
#
|
||||
# This package is distributed in the hope that it will be useful,
|
||||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
# GNU General Public License for more details.
|
||||
#
|
||||
# You should have received a copy of the GNU General Public License
|
||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
#
|
||||
# On Debian systems, the complete text of the GNU General
|
||||
# Public License version 3 can be found in "/usr/share/common-licenses/GPL-3".
|
||||
#
|
||||
package Sipwise::API 0.001;
|
||||
|
||||
use strict;
|
||||
use warnings;
|
||||
|
||||
use English;
|
||||
use Hash::Merge qw( merge );
|
||||
use JSON qw();
|
||||
use LWP::UserAgent;
|
||||
use IO::Socket::SSL;
|
||||
use URI;
|
||||
use Data::Dumper;
|
||||
|
||||
my $opts_default = {
|
||||
host => '127.0.0.1',
|
||||
port => 1443,
|
||||
auth_user => 'administrator',
|
||||
auth_pwd => 'administrator',
|
||||
verbose => 0,
|
||||
sslverify => 'no',
|
||||
admin => 0
|
||||
};
|
||||
|
||||
sub _get_id {
|
||||
my $baseurl = shift;
|
||||
my $location = shift;
|
||||
my $id;
|
||||
|
||||
($id) = ($location =~ m/\Q$baseurl\E(\d+)/);
|
||||
return $id;
|
||||
}
|
||||
|
||||
sub new {
|
||||
my $class = shift;
|
||||
my $opts = shift;
|
||||
my $self = {};
|
||||
|
||||
$self->{opts} = merge($opts, $opts_default);
|
||||
bless $self, $class;
|
||||
|
||||
return $self;
|
||||
}
|
||||
|
||||
sub opts {
|
||||
my $self = shift;
|
||||
if (@_) {
|
||||
$self->{opts} = shift;
|
||||
}
|
||||
return $self->{opts};
|
||||
}
|
||||
|
||||
sub do_request {
|
||||
my $self = shift;
|
||||
my $ua = shift;
|
||||
my $url = shift;
|
||||
my $data = shift;
|
||||
my $req_type = shift || 'POST';
|
||||
my $ct = 'application/json';
|
||||
|
||||
if($req_type =~ 'PATCH') {
|
||||
$ct = 'application/json-patch+json';
|
||||
}
|
||||
|
||||
my $req = HTTP::Request->new($req_type, $url);
|
||||
$req->header('Content-Type' => $ct);
|
||||
$req->header('Prefer' => 'return=representation');
|
||||
$req->content(JSON::to_json($data));
|
||||
my $res = $ua->request($req);
|
||||
if(!$res->is_success) {
|
||||
print "$url\n";
|
||||
print Dumper $data unless $self->{opts}->{verbose};
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
sub do_query {
|
||||
my $self = shift;
|
||||
my $ua = shift;
|
||||
my $url = shift;
|
||||
my $data = shift;
|
||||
my $URL = URI->new($url);
|
||||
$URL->query_form($data);
|
||||
my $req = HTTP::Request->new('GET', $URL);
|
||||
|
||||
my $res = $ua->request($req);
|
||||
if(!$res->is_success) {
|
||||
print "$url\n";
|
||||
print Dumper $data unless $self->{opts}->{verbose};
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
sub create_ua {
|
||||
my $self = shift;
|
||||
my $ua = LWP::UserAgent->new();
|
||||
|
||||
if($self->{opts}->{sslverify} eq 'no') {
|
||||
$ua->ssl_opts(
|
||||
verify_hostname => 0,
|
||||
SSL_verify_mode => IO::Socket::SSL::SSL_VERIFY_NONE,
|
||||
);
|
||||
}
|
||||
$ua->credentials(
|
||||
$self->{opts}->{host}.':'.$self->{opts}->{port},
|
||||
'api_admin_http',
|
||||
$self->{opts}->{auth_user},
|
||||
$self->{opts}->{auth_pwd}
|
||||
);
|
||||
# debug!!
|
||||
if($self->{opts}->{verbose}) {
|
||||
$ua->show_progress(1);
|
||||
$ua->add_handler("request_send", sub { shift->dump; return });
|
||||
$ua->add_handler("response_done", sub { shift->dump; return });
|
||||
}
|
||||
return $ua;
|
||||
}
|
||||
|
||||
sub _create {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = shift;
|
||||
my $urlbase = 'https://'.$self->{opts}->{host}.':'.$self->{opts}->{port};
|
||||
|
||||
my $ua = $self->create_ua();
|
||||
my $res = $self->do_request($ua, $urlbase.$urldata, $data);
|
||||
if($res->is_success) {
|
||||
if($self->{opts}->{verbose}) {
|
||||
print $res->status_line . ' ' . $res->header('Location') . "\n";
|
||||
}
|
||||
return _get_id($urldata, $res->header('Location'));
|
||||
} else {
|
||||
die $res->as_string;
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
sub _get_content {
|
||||
my $self = shift;
|
||||
my $data = 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, $data);
|
||||
if($res->is_success) {
|
||||
return JSON::from_json( $res->decoded_content );
|
||||
}
|
||||
else {
|
||||
die $res->as_string;
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
sub _set_content {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = shift;
|
||||
my $urlbase = 'https://'.$self->{opts}->{host}.':'.$self->{opts}->{port};
|
||||
my $ua = $self->create_ua();
|
||||
|
||||
my $res = $self->do_request($ua, $urlbase.$urldata, $data, 'PUT');
|
||||
if($res->is_success) {
|
||||
return JSON::from_json( $res->decoded_content );
|
||||
}
|
||||
else {
|
||||
die $res->as_string;
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
sub _exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = shift;
|
||||
my $collection_id = shift;
|
||||
my $collection = $self->_get_content($data, $urldata);
|
||||
|
||||
if (defined $collection && $collection->{total_count} == 1) {
|
||||
return $collection->{_embedded}->{$collection_id}->{id};
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
sub check_contact_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $type = shift;
|
||||
my $urldata = "/api/${type}contacts/";
|
||||
my $collection_id = "ngcp:${type}contacts";
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub create_contact {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $type = shift;
|
||||
my $urldata = "/api/${type}contacts/";
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
|
||||
sub check_contract_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/contracts/';
|
||||
my $collection_id = 'ngcp:contracts';
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub create_contract {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/contracts/';
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
|
||||
sub check_reseller_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/resellers/';
|
||||
my $collection_id = 'ngcp:resellers';
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub create_reseller {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/resellers/';
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
|
||||
sub check_domain_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = "/api/domains/";
|
||||
my $collection_id = 'ngcp:domains';
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub get_domain_preferences {
|
||||
my $self = shift;
|
||||
my $id = shift;
|
||||
my $urldata = "/api/domains/${id}";
|
||||
my $collection_id = 'ngcp:domainpreferences';
|
||||
|
||||
return $self->_get_content(undef, $urldata);
|
||||
}
|
||||
|
||||
sub set_domain_preferences {
|
||||
my $self = shift;
|
||||
my $id = shift;
|
||||
my $data = shift;
|
||||
my $urldata = "/api/domainpreferences/${id}";
|
||||
my $collection_id = 'ngcp:domainpreferences';
|
||||
|
||||
return $self->_set_content($data, $urldata);
|
||||
}
|
||||
|
||||
sub create_domain {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/domains/';
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
|
||||
sub check_customer_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/customers/';
|
||||
my $collection_id = 'ngcp:customers';
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub create_customer {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/customers/';
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
|
||||
sub check_subscriber_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/subscribers/';
|
||||
my $collection_id = 'ngcp:subscribers';
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub get_subscriber_preferences {
|
||||
my $self = shift;
|
||||
my $id = shift;
|
||||
my $urldata = "/api/subscribers/${id}";
|
||||
my $collection_id = 'ngcp:subscriberpreferences';
|
||||
|
||||
return $self->_get_content(undef, $urldata);
|
||||
}
|
||||
|
||||
sub set_subscriber_preferences {
|
||||
my $self = shift;
|
||||
my $id = shift;
|
||||
my $data = shift;
|
||||
my $urldata = "/api/subscriberpreferences/${id}";
|
||||
my $collection_id = 'ngcp:subscriberpreferences';
|
||||
|
||||
return $self->_set_content($data, $urldata);
|
||||
}
|
||||
|
||||
sub create_subscriber {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/subscribers/';
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
|
||||
sub check_rewriterule_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/rewriterules/';
|
||||
my $collection_id = 'ngcp:rewriterules';
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub create_rewriterule {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/rewriterules/';
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
|
||||
sub check_rewriteruleset_exists {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/rewriterulesets/';
|
||||
my $collection_id = 'ngcp:rewriterules';
|
||||
|
||||
return $self->_exists($data, $urldata, $collection_id);
|
||||
}
|
||||
|
||||
sub create_rewriteruleset {
|
||||
my $self = shift;
|
||||
my $data = shift;
|
||||
my $urldata = '/api/rewriterulesets/';
|
||||
|
||||
return $self->_create($data, $urldata);
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
'@spce.test':
|
||||
unauth_inbound_calls: yes
|
||||
@ -0,0 +1,11 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"allowed_clis": [
|
||||
"43110029*",
|
||||
"43110021*"
|
||||
],
|
||||
"cli": 4311002,
|
||||
"user_cli": 43122122,
|
||||
"inbound_upn": "from_display"
|
||||
}
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
allowed_clis: [ "43110029*", "43110021*" ]
|
||||
user_cli: 43122122
|
||||
inbound_upn: from_display
|
||||
@ -0,0 +1,11 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"allowed_clis": [
|
||||
"43110029*",
|
||||
"43110021*"
|
||||
],
|
||||
"user_cli": 43122122,
|
||||
"inbound_upn": "from_display",
|
||||
"extension_in_npn": true
|
||||
}
|
||||
}
|
||||
@ -1,5 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
allowed_clis: [ "43110029*", "43110021*" ]
|
||||
user_cli: 43122122
|
||||
inbound_upn: from_display
|
||||
extension_in_npn: 1
|
||||
@ -0,0 +1,11 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"allowed_clis": [
|
||||
"43110029*",
|
||||
"43110021*"
|
||||
],
|
||||
"cli": 4311002,
|
||||
"user_cli": 43122122,
|
||||
"inbound_upn": "from_display"
|
||||
}
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
allowed_clis: [ "43110029*", "43110021*" ]
|
||||
user_cli: 43122122
|
||||
inbound_upn: from_display
|
||||
@ -0,0 +1,8 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"allowed_ips": [
|
||||
"1.2.3.4"
|
||||
],
|
||||
"cli": 4311002
|
||||
}
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
allowed_ips: [ "1.2.3.4" ]
|
||||
@ -0,0 +1,8 @@
|
||||
{
|
||||
"testuser1003@spce.test": {
|
||||
"block_in_list": [
|
||||
"4311001",
|
||||
"4311002"
|
||||
]
|
||||
}
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1003@spce.test:
|
||||
block_in_list: [ "4311001", "4311002" ]
|
||||
@ -0,0 +1,11 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"clir": true
|
||||
},
|
||||
"testuser1003@spce.test": {
|
||||
"block_in_list": [
|
||||
"4311001"
|
||||
],
|
||||
"block_in_clir": true
|
||||
}
|
||||
}
|
||||
@ -1,5 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
clir: 1
|
||||
testuser1003@spce.test:
|
||||
block_in_list: [ "4311001" ]
|
||||
block_in_clir: 1
|
||||
@ -0,0 +1,8 @@
|
||||
{
|
||||
"testuser1003@spce.test": {
|
||||
"block_in_list": [
|
||||
"4311001"
|
||||
],
|
||||
"block_in_mode": true
|
||||
}
|
||||
}
|
||||
@ -1,3 +0,0 @@
|
||||
testuser1003@spce.test:
|
||||
block_in_list: [ "4311001" ]
|
||||
block_in_mode: 1
|
||||
@ -0,0 +1,8 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"block_out_list": [
|
||||
"4311003",
|
||||
"4311001"
|
||||
]
|
||||
}
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
block_out_list: [ "4311003", "4311001" ]
|
||||
@ -0,0 +1,5 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"ncos": "ncos_test_00"
|
||||
}
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
ncos: ncos_test_00
|
||||
@ -0,0 +1,10 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"block_out_list": [
|
||||
"4311001",
|
||||
"4311003"
|
||||
],
|
||||
"block_out_override_pin": 444,
|
||||
"cli": 4311002
|
||||
}
|
||||
}
|
||||
@ -1,3 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
block_out_list: [ "4311001", "4311003" ]
|
||||
block_out_override_pin: 444
|
||||
@ -0,0 +1,9 @@
|
||||
{
|
||||
"testuser1002@spce.test": {
|
||||
"block_out_list": [
|
||||
"4311001",
|
||||
"4311002"
|
||||
],
|
||||
"block_out_mode": true
|
||||
}
|
||||
}
|
||||
@ -1,3 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
block_out_list: [ "4311001", "4311002" ]
|
||||
block_out_mode: 1
|
||||
@ -0,0 +1,5 @@
|
||||
{
|
||||
"testuser1003@spce.test": {
|
||||
"concurrent_max": 1
|
||||
}
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1003@spce.test:
|
||||
concurrent_max: 1
|
||||
@ -1,3 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
concurrent_max: 2
|
||||
concurrent_max_out: 1
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
concurrent_max_out_per_account: 1
|
||||
@ -0,0 +1,8 @@
|
||||
{
|
||||
"testuser1003@spce.test": {
|
||||
"concurrent_max_per_account": 2
|
||||
},
|
||||
"testuser1004@spce.test": {
|
||||
"concurrent_max_per_account": 2
|
||||
}
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
testuser1003@spce.test:
|
||||
concurrent_max_per_account: 2
|
||||
testuser1004@spce.test:
|
||||
concurrent_max_per_account: 2
|
||||
@ -0,0 +1,5 @@
|
||||
{
|
||||
"@spce.test": {
|
||||
"allow_out_foreign_domain": true
|
||||
}
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
'@spce.test':
|
||||
allow_out_foreign_domain: yes
|
||||
@ -1,3 +0,0 @@
|
||||
testuser1002@spce.test:
|
||||
allowed_ips: [ "1.2.3.4" ]
|
||||
ignore_allowed_ips: 1
|
||||
@ -1,4 +0,0 @@
|
||||
"@spce.test":
|
||||
rewrite_rule_set: rw_00
|
||||
peer_00_host0:
|
||||
rewrite_rule_set: rw_00
|
||||
@ -1,4 +0,0 @@
|
||||
"@spce.test":
|
||||
rewrite_rule_set: rw_00
|
||||
peer_00_host0:
|
||||
rewrite_rule_set: rw_00
|
||||
@ -0,0 +1,5 @@
|
||||
{
|
||||
"testuser1003@spce.test": {
|
||||
"allow_out_foreign_domain": true
|
||||
}
|
||||
}
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1003@spce.test:
|
||||
allow_out_foreign_domain: yes
|
||||
@ -1,2 +0,0 @@
|
||||
testuser1003@spce.test:
|
||||
allowed_ips: [ "1.2.3.4" ]
|
||||
@ -1,3 +0,0 @@
|
||||
testuser1003@spce.test:
|
||||
allowed_ips: [ "1.2.3.4" ]
|
||||
ignore_allowed_ips: 1
|
||||
@ -0,0 +1,5 @@
|
||||
{
|
||||
"@spce.test": {
|
||||
"unauth_inbound_calls": true
|
||||
}
|
||||
}
|
||||
@ -1,7 +1,21 @@
|
||||
test_uuid: incoming_foreign_dom
|
||||
domains:
|
||||
'spce.test':
|
||||
reseller_id: 1
|
||||
customers:
|
||||
'customer.test':
|
||||
contacts:
|
||||
- email: "customer.test@spce.test"
|
||||
reseller_id: 1
|
||||
details:
|
||||
status: 'active'
|
||||
type: 'sipaccount'
|
||||
billing_profile_id: 1
|
||||
reseller_id: 1
|
||||
subscribers:
|
||||
spce.test:
|
||||
testuser1003:
|
||||
customer: 'customer.test'
|
||||
password: testuser
|
||||
cc: 43
|
||||
ac: 1
|
||||
@ -1,7 +1,21 @@
|
||||
test_uuid: incoming_peer
|
||||
domains:
|
||||
'spce.test':
|
||||
reseller_id: 1
|
||||
customers:
|
||||
'customer.test':
|
||||
contacts:
|
||||
- email: "customer.test@spce.test"
|
||||
reseller_id: 1
|
||||
details:
|
||||
status: 'active'
|
||||
type: 'sipaccount'
|
||||
billing_profile_id: 1
|
||||
reseller_id: 1
|
||||
subscribers:
|
||||
spce.test:
|
||||
testuser1003:
|
||||
customer: 'customer.test'
|
||||
password: testuser
|
||||
cc: 43
|
||||
ac: 1
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue