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.
174 lines
7.7 KiB
174 lines
7.7 KiB
use strict;
|
|
use warnings;
|
|
|
|
use threads;
|
|
use Test::Collection;
|
|
use Test::FakeData;
|
|
use JSON;
|
|
use Test::More;
|
|
use Data::Dumper;
|
|
use Clone qw/clone/;
|
|
|
|
#use NGCP::Panel::Utils::Subscriber;
|
|
|
|
my $test_machine = Test::Collection->new(
|
|
name => 'numbers',
|
|
);
|
|
$test_machine->methods->{collection}->{allowed} = {map {$_ => 1} qw(GET HEAD OPTIONS)};
|
|
$test_machine->methods->{item}->{allowed} = {map {$_ => 1} qw(GET HEAD OPTIONS PUT PATCH)};
|
|
|
|
|
|
my $fake_data = Test::FakeData->new;
|
|
|
|
$fake_data->set_data_from_script({
|
|
'numbers' => {
|
|
'data' => {
|
|
subscriber_id => sub { return shift->get_id('subscribers',@_); },
|
|
cc => 1,
|
|
ac => 1,
|
|
sn => 1,
|
|
},
|
|
},
|
|
});
|
|
|
|
my $fake_data_processed = $fake_data->process('numbers');
|
|
$test_machine->DATA_ITEM_STORE($fake_data_processed);
|
|
$test_machine->form_data_item();
|
|
|
|
my ($res,$content,$req);
|
|
|
|
my $subscriber = $test_machine->get_item_hal('subscribers', '/api/subscribers/'.$test_machine->DATA_ITEM->{subscriber_id}, 1);
|
|
|
|
# cc WILL loose leading zero, as far as column billing.voip_numbers.cc is a integer and truncates leading zero
|
|
my $number_aliases_data = [
|
|
{'cc' => '11', 'ac' => '0022', 'sn' => '00444'.time().seq(),},
|
|
{'cc' => '11', 'ac' => '0022', 'sn' => '00444'.time().seq(),},
|
|
{'cc' => '11', 'ac' => '0022', 'sn' => '00444'.time().seq(),},
|
|
];
|
|
|
|
($res,$content,$req) = $test_machine->request_patch( [ {
|
|
op => 'replace',
|
|
path => '/alias_numbers',
|
|
value => $number_aliases_data
|
|
} ], $subscriber->{location} );
|
|
$test_machine->http_code_msg(200, "Check patch alias_numbers", $res, $content);
|
|
|
|
my $number_aliases = $test_machine->get_collection_hal('numbers', '/api/numbers/?type=alias&subscriber_id='.$test_machine->DATA_ITEM->{subscriber_id}, 1)->{collection};
|
|
my $number_primary = $test_machine->get_item_hal('numbers', '/api/numbers/?type=primary&subscriber_id='.$test_machine->DATA_ITEM->{subscriber_id}, 1);
|
|
|
|
#check that we didn't loose leading zeros
|
|
my $number_aliases_got = [ map {{'ac' => $_->{content}->{ac}, 'cc' => $_->{content}->{cc}, 'sn' => $_->{content}->{sn}}} @$number_aliases];
|
|
is_deeply($number_aliases_got, $number_aliases_data,"check that we didn't loose leading zeros in ac, cc, sn");
|
|
|
|
$test_machine->check_bundle();
|
|
$test_machine->check_get2put( {location => $number_aliases->[0]->{location}});
|
|
$test_machine->check_patch2get({location => $number_aliases->[0]->{location}});
|
|
|
|
$test_machine->check_patch2get({
|
|
location => $number_aliases->[0]->{location},
|
|
content => [
|
|
{'op' => 'replace', 'path' => '/is_devid', 'value' => JSON::true },
|
|
],
|
|
});
|
|
|
|
#Two tests below will fail with error: Unprocessable Entity: Cannot reassign primary number, already at subscriber 357
|
|
#$test_machine->check_get2put( {location => $number_primary->{location}});
|
|
#$test_machine->check_patch2get({location => $number_primary->{location}}, undef, {
|
|
##we can exclude subscriber_id from patch, but anyway old_resource will provide it
|
|
# patch_exclude_fields => ['subscriber_id'],
|
|
#});
|
|
|
|
{
|
|
my $ticket = '32913';
|
|
my $time = time();
|
|
my $subscriber_test_machine = Test::Collection->new(
|
|
name => 'subscribers',
|
|
);
|
|
$subscriber_test_machine->DATA_ITEM_STORE($fake_data->process('subscribers'));
|
|
my $subscriber1 = $fake_data->create('subscribers')->[0];
|
|
my $subscriber2 = $fake_data->create('subscribers')->[0];
|
|
#print Dumper $subscriber1;
|
|
$subscriber1->{content}->{alias_numbers} = [
|
|
{ cc=> '111', ac => $ticket, sn => $time },
|
|
{ cc=> '112', ac => $ticket, sn => $time },
|
|
{ cc=> '113', ac => $ticket, sn => $time },
|
|
# { cc=> '114', ac => $ticket, sn => $time },
|
|
# { cc=> '115', ac => $ticket, sn => $time },
|
|
];
|
|
$subscriber2->{content}->{alias_numbers} = [
|
|
{ cc=> '211', ac => $ticket, sn => $time },
|
|
{ cc=> '212', ac => $ticket, sn => $time },
|
|
{ cc=> '213', ac => $ticket, sn => $time },
|
|
# { cc=> '214', ac => $ticket, sn => $time },
|
|
# { cc=> '215', ac => $ticket, sn => $time },
|
|
];
|
|
my ($res,$content,$request);
|
|
($res,$content,$request) = $subscriber_test_machine->request_put(@{$subscriber1}{qw/content location/});
|
|
($res,$content,$request) = $subscriber_test_machine->request_put(@{$subscriber2}{qw/content location/});
|
|
my ($aliases1) = $test_machine->get_collection_hal('numbers', '/api/numbers/?type=alias&subscriber_id='.$subscriber1->{content}->{id}, 1)->{collection};
|
|
my ($aliases2) = $test_machine->get_collection_hal('numbers','/api/numbers/?type=alias&subscriber_id='.$subscriber2->{content}->{id}, 1)->{collection};
|
|
test_numbers_reassign($aliases1->[0],$aliases2->[0],$subscriber1,$subscriber2);
|
|
|
|
my $pbxsubscriberadmin = $fake_data->create('subscribers')->[0];
|
|
($res) = $subscriber_test_machine->request_patch([
|
|
{ op => 'replace', path => '/administrative', value => 1 },
|
|
{ op => 'replace', path => '/webpassword', value => 'pbxadminpwd' },
|
|
{ op => 'replace', path => '/password', value => 'pbxadminpwd' }
|
|
] , $pbxsubscriberadmin->{location});
|
|
$subscriber_test_machine->http_code_msg(200, "PATCH for /pbxsubscriberadmin/", $res);
|
|
$pbxsubscriberadmin = $subscriber_test_machine->get_item_hal('subscribers', $pbxsubscriberadmin->{location});
|
|
|
|
$test_machine->set_subscriber_credentials($pbxsubscriberadmin->{content});
|
|
$test_machine->runas('subscriber');
|
|
|
|
test_numbers_reassign($aliases1->[0],$aliases2->[0],$subscriber1,$subscriber2);
|
|
my @threads;
|
|
for(my $i = 0; $i < @{$aliases1} && $i < @{$aliases2}; $i++ ){
|
|
push @threads, threads->create(\&test_numbers_reassign,$aliases1->[$i],$aliases2->[$i],$subscriber1,$subscriber2);
|
|
}
|
|
for(my $i=0; $i < @threads; $i++ ){
|
|
$threads[$i]->join();
|
|
}
|
|
$test_machine->runas('admin');
|
|
|
|
$subscriber_test_machine->clear_test_data_all();#fake data aren't registered in this test
|
|
}
|
|
|
|
$fake_data->clear_test_data_all();
|
|
$test_machine->clear_test_data_all();#fake data aren't registered in this test machine, so they will stay.
|
|
$fake_data->clear_test_data_all();
|
|
undef $test_machine;
|
|
undef $fake_data;
|
|
done_testing;
|
|
|
|
sub test_numbers_reassign{
|
|
my($alias1,$alias2,$subscriber1,$subscriber2) = @_;
|
|
my $res;
|
|
my $test_machine_l = Test::Collection->new(
|
|
name => 'numbers',
|
|
);
|
|
|
|
#print Dumper [
|
|
# [ { op => 'replace', path => '/subscriber_id', value => $subscriber2->{content}->{id} } ] , $alias1,
|
|
# [ { op => 'replace', path => '/subscriber_id', value => $subscriber1->{content}->{id} } ] , $alias1,
|
|
# [ { op => 'replace', path => '/subscriber_id', value => $subscriber1->{content}->{id} } ] , $alias2,
|
|
# [ { op => 'replace', path => '/subscriber_id', value => $subscriber2->{content}->{id} } ] , $alias2
|
|
#
|
|
#];
|
|
my $tid = threads->tid();
|
|
$alias1->{content}->{subscriber_id} = $subscriber2->{content}->{id};
|
|
($res) = $test_machine_l->request_patch([ { op => 'replace', path => '/subscriber_id', value => $subscriber2->{content}->{id} } ] , $alias1->{location});
|
|
$test_machine_l->http_code_msg(200, "PATCH 1 for /numbers/ in tid $tid;", $res);
|
|
|
|
($res) = $test_machine_l->request_patch([ { op => 'replace', path => '/subscriber_id', value => $subscriber1->{content}->{id} } ] , $alias1->{location});
|
|
$test_machine_l->http_code_msg(200, "PATCH 2 for /numbers/ in tid $tid;", $res);
|
|
|
|
($res) = $test_machine_l->request_patch([ { op => 'replace', path => '/subscriber_id', value => $subscriber1->{content}->{id} } ] , $alias2->{location});
|
|
$test_machine_l->http_code_msg(200, "PATCH 3 for /numbers/ in tid $tid;", $res);
|
|
|
|
($res) = $test_machine_l->request_patch([ { op => 'replace', path => '/subscriber_id', value => $subscriber2->{content}->{id} } ] , $alias2->{location});
|
|
$test_machine_l->http_code_msg(200, "PATCH 4 for /numbers/ in tid $tid;", $res);
|
|
}
|
|
|
|
# vim: set tabstop=4 expandtab:
|