sipwise
/
ngcp-panel
mirror of https://github.com/sipwise/ngcp-panel.git
1
0
Fork 0
Code Issues Releases Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'edf5da9bad'
${ noResults }
ngcp-panel/t/api-journals.t

879 lines
37 KiB
Raw Blame History

use Sipwise::Base;
use Net::Domain qw(hostfqdn);
use LWP::UserAgent;
use JSON qw();
use Test::More;
use Storable qw();
use LWP::Debug;
BEGIN {
unshift(@INC,'../lib');
}
use NGCP::Panel::Utils::Journal qw();
use Config::General;
#taken 1:1 from /lib/NGCP/Panel.pm
my $panel_config;
for my $path(qw#/etc/ngcp-panel/ngcp_panel.conf etc/ngcp_panel.conf ngcp_panel.conf#) {
if(-f $path) {
$panel_config = $path;
last;
}
}
$panel_config //= 'ngcp_panel.conf';
#my $catalyst_config = Config::General->new("../ngcp_panel.conf");
my $catalyst_config = Config::General->new($panel_config);
my %config = $catalyst_config->getall();
my $enable_journal_tests = 1;
my $uri = $ENV{CATALYST_SERVER} || ('https://'.hostfqdn.':4443');
my $valid_ssl_client_cert = $ENV{API_SSL_CLIENT_CERT} ||
"/etc/ngcp-panel/api_ssl/NGCP-API-client-certificate.pem";
my $valid_ssl_client_key = $ENV{API_SSL_CLIENT_KEY} ||
$valid_ssl_client_cert;
my $ssl_ca_cert = $ENV{API_SSL_CA_CERT} || "/etc/ngcp-panel/api_ssl/api_ca.crt";
my ($ua, $req, $res);
$ua = LWP::UserAgent->new;
$ua->ssl_opts(
SSL_cert_file => $valid_ssl_client_cert,
SSL_key_file => $valid_ssl_client_key,
SSL_ca_file => $ssl_ca_cert,
);
#$ua->ssl_opts(
# verify_hostname => 0,
#);
#$ua->credentials("127.0.0.1:4443", "api_admin_http", 'administrator', 'administrator');
##$ua->timeout(500); #useless, need to change the nginx timeout
my $t = time;
my $default_reseller_id = 1;
my $billingprofile = test_billingprofile($t,$default_reseller_id);
my $systemcontact = test_systemcontact($t);
my $contract = test_contract($billingprofile,$systemcontact);
(my $reseller,$billingprofile) = test_reseller($t,$contract);
my $domain = test_domain($t,$reseller);
my $customercontact = test_customercontact($t,$reseller);
my $customer = test_customer($customercontact,$billingprofile);
my $subscriber = test_subscriber($t,$customer,$domain);
#test_customerpreferences();
done_testing;
#sub test_customerpreferences {
#
# $req = HTTP::Request->new('PUT', $uri.'/api/customerpreferences/'.$customer->{id});
# $req->header('Content-Type' => 'application/json');
# $req->header('Prefer' => 'return=representation');
# $req->content(JSON::to_json({
# name => "test profile $t PUT",
# handle => "testprofile$t",
# reseller_id => $reseller_id,
# }));
# $res = $ua->request($req);
# is($res->code, 200, "PUT test billingprofile");
# $req = HTTP::Request->new('GET', $billingprofile_uri);
# $res = $ua->request($req);
# is($res->code, 200, "fetch PUT test billingprofile");
# $billingprofile = JSON::from_json($res->decoded_content);
#
# $req = HTTP::Request->new('GET', $uri.'/api/customerpreferences/136');
# $res = $ua->request($req);
# is($res->code, 200, "fetch blah");
#
#}
sub test_billingprofile {
my ($t,$reseller_id) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/billingprofiles/');
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
name => "test profile $t",
handle => "testprofile$t",
reseller_id => $reseller_id,
}));
$res = $ua->request($req);
is($res->code, 201, "POST test billing profile");
my $billingprofile_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $billingprofile_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed billing profile");
my $billingprofile = JSON::from_json($res->decoded_content);
_test_item_journal_link('billingprofiles',$billingprofile);
_test_journal_options_head('billingprofiles',$billingprofile->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('billingprofiles',$billingprofile->{id},$billingprofile,'create',$journals);
_test_journal_options_head('billingprofiles',$billingprofile->{id},$journal->{id});
$req = HTTP::Request->new('PUT', $billingprofile_uri);
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
name => "test profile $t PUT",
handle => "testprofile$t",
reseller_id => $reseller_id,
}));
$res = $ua->request($req);
is($res->code, 200, "PUT test billingprofile");
$req = HTTP::Request->new('GET', $billingprofile_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PUT test billingprofile");
$billingprofile = JSON::from_json($res->decoded_content);
_test_item_journal_link('billingprofiles',$billingprofile);
$journal = _test_journal_top_journalitem('billingprofiles',$billingprofile->{id},$billingprofile,'update',$journals,$journal);
$req = HTTP::Request->new('PATCH', $billingprofile_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/name', value => "test profile $t PATCH" } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test billingprofile");
$req = HTTP::Request->new('GET', $billingprofile_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test billingprofile");
$billingprofile = JSON::from_json($res->decoded_content);
_test_item_journal_link('billingprofiles',$billingprofile);
$journal = _test_journal_top_journalitem('billingprofiles',$billingprofile->{id},$billingprofile,'update',$journals,$journal);
_test_journal_collection('billingprofiles',$billingprofile->{id},$journals);
return $billingprofile;
}
sub test_contract {
my ($billingprofile,$systemcontact) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/contracts/');
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
status => "active",
contact_id => $systemcontact->{id},
type => "reseller",
billing_profile_id => $billingprofile->{id},
}));
$res = $ua->request($req);
is($res->code, 201, "POST test reseller contract");
my $contract_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $contract_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test reseller contract");
my $contract = JSON::from_json($res->decoded_content);
_test_item_journal_link('contracts',$contract);
_test_journal_options_head('contracts',$contract->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('contracts',$contract->{id},$contract,'create',$journals);
_test_journal_options_head('contracts',$contract->{id},$journal->{id});
$req = HTTP::Request->new('PUT', $contract_uri);
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
status => "active",
contact_id => $systemcontact->{id},
type => "reseller",
billing_profile_id => $billingprofile->{id},
external_id => int(rand(10)),
}));
$res = $ua->request($req);
is($res->code, 200, "PUT test reseller contract");
$req = HTTP::Request->new('GET', $contract_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PUT test reseller contract");
$contract = JSON::from_json($res->decoded_content);
_test_item_journal_link('contracts',$contract);
$journal = _test_journal_top_journalitem('contracts',$contract->{id},$contract,'update',$journals,$journal);
$req = HTTP::Request->new('PATCH', $contract_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/external_id', value => int(rand(10)) } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test reseller contract");
$req = HTTP::Request->new('GET', $contract_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test reseller contract");
$contract = JSON::from_json($res->decoded_content);
_test_item_journal_link('contracts',$contract);
$journal = _test_journal_top_journalitem('contracts',$contract->{id},$contract,'update',$journals,$journal);
_test_journal_collection('contracts',$contract->{id},$journals);
return $contract;
}
sub test_customercontact {
my ($t,$reseller) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/customercontacts/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
firstname => "cust_contact_".($t-1)."_first",
lastname => "cust_contact_".($t-1)."_last",
email => "cust_contact_".($t-1)."\@custcontact.invalid",
reseller_id => $reseller->{id},
}));
$res = $ua->request($req);
is($res->code, 201, "POST test customercontact");
my $customercontact_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $customercontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test customercontact");
my $customercontact = JSON::from_json($res->decoded_content);
_test_item_journal_link('customercontacts',$customercontact);
_test_journal_options_head('customercontacts',$customercontact->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('customercontacts',$customercontact->{id},$customercontact,'create',$journals);
_test_journal_options_head('customercontacts',$customercontact->{id},$journal->{id});
$req = HTTP::Request->new('PUT', $customercontact_uri);
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
firstname => "cust_contact_".($t-1)."_first_put",
lastname => "cust_contact_".($t-1)."_last_put",
email => "cust_contact_".($t-1)."_put\@custcontact.invalid",
reseller_id => $reseller->{id},
external_id => int(rand(10)),
}));
$res = $ua->request($req);
is($res->code, 200, "PUT test customercontact");
$req = HTTP::Request->new('GET', $customercontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PUT test customercontact");
$customercontact = JSON::from_json($res->decoded_content);
_test_item_journal_link('customercontacts',$customercontact);
$journal = _test_journal_top_journalitem('customercontacts',$customercontact->{id},$customercontact,'update',$journals,$journal);
$req = HTTP::Request->new('PATCH', $customercontact_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/firstname', value => "cust_contact_".($t-1)."_first_patch" } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test customercontact");
$req = HTTP::Request->new('GET', $customercontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test customercontact");
$customercontact = JSON::from_json($res->decoded_content);
_test_item_journal_link('customercontacts',$customercontact);
$journal = _test_journal_top_journalitem('customercontacts',$customercontact->{id},$customercontact,'update',$journals,$journal);
$req = HTTP::Request->new('DELETE', $customercontact_uri);
$res = $ua->request($req);
is($res->code, 204, "delete POSTed test customercontact");
#$domain = JSON::from_json($res->decoded_content);
$journal = _test_journal_top_journalitem('customercontacts',$customercontact->{id},$customercontact,'delete',$journals,$journal);
_test_journal_collection('customercontacts',$customercontact->{id},$journals);
$req = HTTP::Request->new('POST', $uri.'/api/customercontacts/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
firstname => "cust_contact_".$t."_first",
lastname => "cust_contact_".$t."_last",
email => "cust_contact_".$t."\@custcontact.invalid",
reseller_id => $reseller->{id},
}));
$res = $ua->request($req);
is($res->code, 201, "POST another test customercontact");
$customercontact_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $customercontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test customercontact");
$customercontact = JSON::from_json($res->decoded_content);
return $customercontact;
}
sub test_reseller {
my ($t,$contract) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/resellers/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
contract_id => $contract->{id},
name => "test reseller $t",
status => "active",
}));
$res = $ua->request($req);
is($res->code, 201, "POST test reseller");
my $reseller_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $reseller_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test reseller");
my $reseller = JSON::from_json($res->decoded_content);
_test_item_journal_link('resellers',$reseller);
_test_journal_options_head('resellers',$reseller->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('resellers',$reseller->{id},$reseller,'create',$journals);
_test_journal_options_head('resellers',$reseller->{id},$journal->{id});
$req = HTTP::Request->new('PUT', $reseller_uri);
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
contract_id => $contract->{id},
name => "test reseller $t PUT",
status => "active",
}));
$res = $ua->request($req);
is($res->code, 200, "PUT test reseller");
$req = HTTP::Request->new('GET', $reseller_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PUT test reseller");
$reseller = JSON::from_json($res->decoded_content);
_test_item_journal_link('resellers',$reseller);
$journal = _test_journal_top_journalitem('resellers',$reseller->{id},$reseller,'update',$journals,$journal);
$req = HTTP::Request->new('PATCH', $reseller_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/name', value => "test reseller $t PATCH" } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test reseller");
$req = HTTP::Request->new('GET', $reseller_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test reseller");
$reseller = JSON::from_json($res->decoded_content);
_test_item_journal_link('resellers',$reseller);
$journal = _test_journal_top_journalitem('resellers',$reseller->{id},$reseller,'update',$journals,$journal);
#$req = HTTP::Request->new('DELETE', $reseller_uri);
#$res = $ua->request($req);
#is($res->code, 204, "delete POSTed test reseller");
##$domain = JSON::from_json($res->decoded_content);
#
#$journal = _test_journal_top_journalitem('resellers',$reseller->{id},$reseller,'delete',$journals,$journal);
_test_journal_collection('resellers',$reseller->{id},$journals);
#$req = HTTP::Request->new('POST', $uri.'/api/resellers/');
#$req->header('Content-Type' => 'application/json');
#$req->content(JSON::to_json({
# contract_id => $contract->{id},
# name => "test reseller $t 1",
# status => "active",
#}));
#$res = $ua->request($req);
#is($res->code, 201, "POST another test reseller");
#$reseller_uri = $uri.'/'.$res->header('Location');
#$req = HTTP::Request->new('GET', $reseller_uri);
#$res = $ua->request($req);
#is($res->code, 200, "fetch POSTed test reseller");
#$reseller = JSON::from_json($res->decoded_content);
my $billingprofile_uri = $uri.'/api/billingprofiles/'.$contract->{billing_profile_id};
$req = HTTP::Request->new('PATCH', $billingprofile_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/reseller_id', value => $reseller->{id} } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test billingprofile");
$req = HTTP::Request->new('GET', $billingprofile_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test billingprofile");
my $billingprofile = JSON::from_json($res->decoded_content);
return ($reseller,$billingprofile);
}
sub test_systemcontact {
my ($t) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/systemcontacts/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
firstname => "syst_contact_".($t-1)."_first",
lastname => "syst_contact_".($t-1)."_last",
email => "syst_contact_".($t-1)."\@systcontact.invalid",
}));
$res = $ua->request($req);
is($res->code, 201, "POST test systemcontact");
my $systemcontact_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $systemcontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test systemcontact");
my $systemcontact = JSON::from_json($res->decoded_content);
_test_item_journal_link('systemcontacts',$systemcontact);
_test_journal_options_head('systemcontacts',$systemcontact->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('systemcontacts',$systemcontact->{id},$systemcontact,'create',$journals);
_test_journal_options_head('systemcontacts',$systemcontact->{id},$journal->{id});
$req = HTTP::Request->new('PUT', $systemcontact_uri);
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
firstname => "syst_contact_".($t-1)."_first_put",
lastname => "syst_contact_".($t-1)."_last_put",
email => "syst_contact_".($t-1)."_put\@systcontact.invalid",
external_id => int(rand(10)),
}));
$res = $ua->request($req);
is($res->code, 200, "PUT test systemcontact");
$req = HTTP::Request->new('GET', $systemcontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PUT test systemcontact");
$systemcontact = JSON::from_json($res->decoded_content);
_test_item_journal_link('systemcontacts',$systemcontact);
$journal = _test_journal_top_journalitem('systemcontacts',$systemcontact->{id},$systemcontact,'update',$journals,$journal);
$req = HTTP::Request->new('PATCH', $systemcontact_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/firstname', value => "syst_contact_".($t-1)."_first_patch" } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test systemcontact");
$req = HTTP::Request->new('GET', $systemcontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test systemcontact");
$systemcontact = JSON::from_json($res->decoded_content);
_test_item_journal_link('systemcontacts',$systemcontact);
$journal = _test_journal_top_journalitem('systemcontacts',$systemcontact->{id},$systemcontact,'update',$journals,$journal);
$req = HTTP::Request->new('DELETE', $systemcontact_uri);
$res = $ua->request($req);
is($res->code, 204, "delete POSTed test systemcontact");
#$domain = JSON::from_json($res->decoded_content);
$journal = _test_journal_top_journalitem('systemcontacts',$systemcontact->{id},$systemcontact,'delete',$journals,$journal);
_test_journal_collection('systemcontacts',$systemcontact->{id},$journals);
$req = HTTP::Request->new('POST', $uri.'/api/systemcontacts/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
firstname => "syst_contact_".$t."_first",
lastname => "syst_contact_".$t."_last",
email => "syst_contact_".$t."\@systcontact.invalid",
}));
$res = $ua->request($req);
is($res->code, 201, "POST another test systemcontact");
$systemcontact_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $systemcontact_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test systemcontact");
$systemcontact = JSON::from_json($res->decoded_content);
return $systemcontact;
}
sub test_domain {
my ($t,$reseller) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/domains/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
domain => 'test' . ($t-1) . '.example.org',
reseller_id => $reseller->{id},
}));
$res = $ua->request($req);
is($res->code, 201, "POST test domain");
my $domain_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $domain_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test domain");
my $domain = JSON::from_json($res->decoded_content);
_test_item_journal_link('domains',$domain);
_test_journal_options_head('domains',$domain->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('domains',$domain->{id},$domain,'create',$journals);
_test_journal_options_head('domains',$domain->{id},$journal->{id});
$req = HTTP::Request->new('DELETE', $domain_uri);
$res = $ua->request($req);
is($res->code, 204, "delete POSTed test domain");
#$domain = JSON::from_json($res->decoded_content);
$journal = _test_journal_top_journalitem('domains',$domain->{id},$domain,'delete',$journals,$journal);
_test_journal_collection('domains',$domain->{id},$journals);
$req = HTTP::Request->new('POST', $uri.'/api/domains/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
domain => 'test' . $t . '.example.org',
reseller_id => $reseller->{id},
}));
$res = $ua->request($req);
is($res->code, 201, "POST another test domain");
$domain_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $domain_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test domain");
$domain = JSON::from_json($res->decoded_content);
return $domain;
}
sub test_customer {
my ($customer_contact,$billing_profile) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/customers/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
status => "active",
contact_id => $customer_contact->{id},
type => "sipaccount",
billing_profile_id => $billing_profile->{id},
max_subscribers => undef,
external_id => undef,
}));
$res = $ua->request($req);
is($res->code, 201, "POST test customer");
my $customer_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $customer_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test customer");
my $customer = JSON::from_json($res->decoded_content);
_test_item_journal_link('customers',$customer);
_test_journal_options_head('customers',$customer->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('customers',$customer->{id},$customer,'create',$journals);
_test_journal_options_head('customers',$customer->{id},$journal->{id});
$req = HTTP::Request->new('PUT', $customer_uri);
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
status => "active",
contact_id => $customer_contact->{id},
type => "sipaccount",
billing_profile_id => $billing_profile->{id}, #$billing_profile_id,
max_subscribers => undef,
external_id => int(rand(10)),
}));
$res = $ua->request($req);
is($res->code, 200, "PUT test customer");
$req = HTTP::Request->new('GET', $customer_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PUT test customer");
$customer = JSON::from_json($res->decoded_content);
_test_item_journal_link('customers',$customer);
$journal = _test_journal_top_journalitem('customers',$customer->{id},$customer,'update',$journals,$journal);
$req = HTTP::Request->new('PATCH', $customer_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/status', value => 'pending' } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test customer");
$req = HTTP::Request->new('GET', $customer_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test customer");
$customer = JSON::from_json($res->decoded_content);
_test_item_journal_link('customers',$customer);
$journal = _test_journal_top_journalitem('customers',$customer->{id},$customer,'update',$journals,$journal);
_test_journal_collection('customers',$customer->{id},$journals);
return $customer;
}
sub test_subscriber {
my ($t,$customer,$domain) = @_;
$req = HTTP::Request->new('POST', $uri.'/api/subscribers/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
domain_id => $domain->{id},
username => 'test_customer_subscriber_'.($t-1),
password => 'test_customer_subscriber_password',
customer_id => $customer->{id},
#primary_number
#status => "active",
#administrative
#is_pbx_pilot
#profile_set_id
#profile_id
#id
#alias_numbers => []
#customer_id - pbxaccount
#admin
#pbx_extension
#is_pbx_group
#pbx_group_ids => []
#display_name
#external_id
#preferences
#groups
#status => "active",
#contact_id => $customer_contact->{id},
#type => "sipaccount",
#billing_profile_id => $billing_profile->{id},
#max_subscribers => undef,
#external_id => undef,
}));
$res = $ua->request($req);
is($res->code, 201, "POST test subscriber");
my $subscriber_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $subscriber_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test subscriber");
my $subscriber = JSON::from_json($res->decoded_content);
_test_item_journal_link('subscribers',$subscriber);
_test_journal_options_head('subscribers',$subscriber->{id});
my $journals = {};
my $journal = _test_journal_top_journalitem('subscribers',$subscriber->{id},$subscriber,'create',$journals);
_test_journal_options_head('subscribers',$subscriber->{id},$journal->{id});
$req = HTTP::Request->new('PUT', $subscriber_uri);
$req->header('Content-Type' => 'application/json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json({
domain_id => $domain->{id},
username => 'test_customer_subscriber_'.($t-1),
password => => 'test_customer_subscriber_password_PUT',
customer_id => $customer->{id},
}));
$res = $ua->request($req);
is($res->code, 200, "PUT test subscriber");
$req = HTTP::Request->new('GET', $subscriber_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PUT test subscriber");
$subscriber = JSON::from_json($res->decoded_content);
_test_item_journal_link('subscribers',$subscriber);
$journal = _test_journal_top_journalitem('subscribers',$subscriber->{id},$subscriber,'update',$journals,$journal);
$req = HTTP::Request->new('PATCH', $subscriber_uri);
$req->header('Content-Type' => 'application/json-patch+json');
$req->header('Prefer' => 'return=representation');
$req->content(JSON::to_json(
[ { op => 'replace', path => '/password', value => 'test_customer_subscriber_password_PATCH', } ]
));
$res = $ua->request($req);
is($res->code, 200, "PATCH test subscriber");
$req = HTTP::Request->new('GET', $subscriber_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch PATCHed test subscriber");
$subscriber = JSON::from_json($res->decoded_content);
_test_item_journal_link('subscribers',$subscriber);
$journal = _test_journal_top_journalitem('subscribers',$subscriber->{id},$subscriber,'update',$journals,$journal);
$req = HTTP::Request->new('DELETE', $subscriber_uri);
$res = $ua->request($req);
is($res->code, 204, "delete POSTed test subscriber");
#$domain = JSON::from_json($res->decoded_content);
$journal = _test_journal_top_journalitem('subscribers',$subscriber->{id},$subscriber,'delete',$journals,$journal);
_test_journal_collection('subscribers',$subscriber->{id},$journals);
$req = HTTP::Request->new('POST', $uri.'/api/subscribers/');
$req->header('Content-Type' => 'application/json');
$req->content(JSON::to_json({
domain_id => $domain->{id},
username => 'test_customer_subscriber_'.$t,
password => => 'test_customer_subscriber_password',
customer_id => $customer->{id},
}));
$res = $ua->request($req);
is($res->code, 201, "POST another test subscriber");
$subscriber_uri = $uri.'/'.$res->header('Location');
$req = HTTP::Request->new('GET', $subscriber_uri);
$res = $ua->request($req);
is($res->code, 200, "fetch POSTed test subscriber");
$subscriber = JSON::from_json($res->decoded_content);
return $subscriber;
}
sub _test_item_journal_link {
my ($resource,$item) = @_;
if (_is_journal_resource_enabled($resource)) {
ok(exists $item->{_links}, "check existence of _links");
ok($item->{_links}->{'ngcp:journal'}, "check existence of ngcp:journal link");
ok($item->{_links}->{'ngcp:journal'}->{href} eq '/api/'.$resource . '/' . $item->{id} . '/journal/', "check if ngcp:journal link equals '/api/$resource/$item->{id}/journal/'");
}
}
sub _test_journal_top_journalitem {
my ($resource,$item_id,$content,$op,$journals,$old_journal) = @_;
if (_is_journal_resource_enabled($resource)) {
my $url = $uri.'/api/'.$resource . '/' . $item_id . '/journal/recent';
if (defined $op) {
$url .= '?operation=' . $op;
}
$req = HTTP::Request->new('GET',$url);
$res = $ua->request($req);
is($res->code, 200, "check recent '$op' journalitem request");
my $journal = JSON::from_json($res->decoded_content);
ok(exists $journal->{id}, "check existence of id");
ok(exists $journal->{operation}, "check existence of operation");
ok(exists $journal->{username}, "check existence of username");
ok(exists $journal->{timestamp}, "check existence of timestamp");
ok(exists $journal->{content}, "check existence of content");
ok(exists $journal->{_links}, "check existence of _links");
#ok(exists $journal->{_embedded}, "check existence of _embedded");
ok($journal->{_links}->{self}, "check existence of self link");
ok($journal->{_links}->{collection}, "check existence of collection link");
ok($journal->{_links}->{'ngcp:'.$resource}, "check existence of ngcp:$resource link");
ok($journal->{_links}->{'ngcp:'.$resource}->{href} eq '/api/'.$resource . '/' . $item_id, "check if ngcp:$resource link equals '/api/$resource/$item_id'");
if (defined $old_journal) {
ok($journal->{timestamp} ge $old_journal->{timestamp},"check incremented timestamp");
}
if (defined $content) {
my $original = Storable::dclone($content);
delete $original->{_links};
#delete $original->{_embedded};
is_deeply($journal->{content}, $original, "check resource '/api/$resource/$item_id' content deeply");
}
if (defined $journals) {
$journals->{$journal->{_links}->{self}->{href}} = $journal;
}
return $journal;
}
return undef;
}
sub _test_journal_options_head {
my ($resource,$item_id,$id) = @_;
if (_is_journal_resource_enabled($resource)) {
my $url = $uri.'/api/'.$resource . '/' . $item_id . '/journal/';
if (defined $id) {
$url .= $id . '/';
}
$req = HTTP::Request->new('OPTIONS', $url);
$res = $ua->request($req);
is($res->code, 200, "check journal options request");
#is($res->header('Accept-Post'), "application/hal+json; profile=http://purl.org/sipwise/ngcp-api/#rel-customers", "check Accept-Post header in options response");
my $opts = JSON::from_json($res->decoded_content);
my @hopts = split /\s*,\s*/, $res->header('Allow');
ok(exists $opts->{methods} && ref $opts->{methods} eq "ARRAY", "check for valid 'methods' in body");
foreach my $opt(qw( GET HEAD OPTIONS )) {
ok(grep(/^$opt$/, @hopts), "check for existence of '$opt' in Allow header");
ok(grep(/^$opt$/, @{ $opts->{methods} }), "check for existence of '$opt' in body");
}
$req = HTTP::Request->new('HEAD', $url);
$res = $ua->request($req);
is($res->code, 200, "check options request");
}
}
sub _test_journal_collection {
my ($resource,$item_id,$journals) = @_;
if (_is_journal_resource_enabled($resource)) {
my $total_count = (defined $journals ? (scalar keys %$journals) : undef);
my $nexturi = $uri.'/api/'.$resource . '/' . $item_id . '/journal/?page=1&rows=' . ((not defined $total_count or $total_count <= 2) ? 2 : $total_count - 1);
do {
$res = $ua->get($nexturi);
is($res->code, 200, "fetch journal collection page");
my $collection = JSON::from_json($res->decoded_content);
my $selfuri = $uri . $collection->{_links}->{self}->{href};
is($selfuri, $nexturi, "check _links.self.href of collection");
my $colluri = URI->new($selfuri);
ok(defined $total_count ? ($collection->{total_count} == $total_count) : ($collection->{total_count} > 0), "check 'total_count' of collection");
my %q = $colluri->query_form;
ok(exists $q{page} && exists $q{rows}, "check existence of 'page' and 'row' in 'self'");
my $page = int($q{page});
my $rows = int($q{rows});
if($page == 1) {
ok(!exists $collection->{_links}->{prev}->{href}, "check absence of 'prev' on first page");
} else {
ok(exists $collection->{_links}->{prev}->{href}, "check existence of 'prev'");
}
if(($collection->{total_count} / $rows) <= $page) {
ok(!exists $collection->{_links}->{next}->{href}, "check absence of 'next' on last page");
} else {
ok(exists $collection->{_links}->{next}->{href}, "check existence of 'next'");
}
if($collection->{_links}->{next}->{href}) {
$nexturi = $uri . $collection->{_links}->{next}->{href};
} else {
$nexturi = undef;
}
# TODO: I'd expect that to be an array ref in any case!
ok(ref $collection->{_links}->{'ngcp:journal'} eq "ARRAY", "check if 'ngcp:journal' is array");
my $page_journals = {};
foreach my $journal (@{ $collection->{_links}->{'ngcp:journal'} }) {
#delete $customers{$c->{href}};
ok(exists $journals->{$journal->{href}},"check page journal item link");
$req = HTTP::Request->new('GET',$uri . $journal->{href});
$res = $ua->request($req);
is($res->code, 200, "fetch page journal item");
my $original = delete $journals->{$journal->{href}};
$page_journals->{$original->{id}} = $original;
}
foreach my $journal (@{ $collection->{_embedded}->{'ngcp:journal'} }) {
ok(exists $page_journals->{$journal->{id}},"check existence of linked journal item among embedded");
my $original = delete $page_journals->{$journal->{id}};
delete $original->{content};
is_deeply($original,$journal,"compare created and embedded journal item deeply");
}
ok((scalar keys $page_journals) == 0,"check if all embedded journal items are linked");
} while($nexturi);
ok((scalar keys $journals) == 0,"check if journal collection lists all created journal items" . (defined $total_count ? " ($total_count)" : ''));
}
}
sub _is_journal_resource_enabled {
my ($resource) = @_;
my $cfg = NGCP::Panel::Utils::Journal::get_journal_resource_config(\%config,$resource);
if (not $cfg->{journal_resource_enabled}) {
diag("'api/$resource' journal disabled, skipping tests");
}
return ($enable_journal_tests && $cfg->{journal_resource_enabled});
}
# vim: set tabstop=4 expandtab:
Reference in new issue View Git Blame Copy Permalink