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.
2383 lines
119 KiB
2383 lines
119 KiB
use strict;
|
|
use warnings;
|
|
use threads qw();
|
|
use threads::shared qw();
|
|
|
|
#use Sipwise::Base; #causes segfault when creating threads..
|
|
use Net::Domain qw(hostfqdn);
|
|
use LWP::UserAgent;
|
|
use JSON qw();
|
|
use Test::More;
|
|
use Time::HiRes; #prevent warning from Time::Warp
|
|
use Time::Warp qw();
|
|
use DateTime::Format::Strptime;
|
|
use DateTime::Format::ISO8601;
|
|
use Data::Dumper;
|
|
use Storable;
|
|
use Text::Table;
|
|
use Text::Wrap;
|
|
$Text::Wrap::columns = 58;
|
|
#use Sys::CpuAffinity;
|
|
|
|
use JSON::PP;
|
|
use LWP::Debug;
|
|
|
|
BEGIN {
|
|
unshift(@INC,'../../lib');
|
|
}
|
|
use NGCP::Panel::Utils::DateTime qw();
|
|
#use NGCP::Panel::Utils::ProfilePackages qw(); #since it depends on Utils::Subscribers and thus Sipwise::Base, importin it causes segfault when creating threads..
|
|
|
|
my $is_local_env = 0;
|
|
my $disable_parallel_catchup = 1;
|
|
my $disable_hourly_intervals = 1;
|
|
#my $enable_profile_packages = NGCP::Panel::Utils::ProfilePackages::ENABLE_PROFILE_PACKAGES;
|
|
#my $enable_profile_packages = 1;
|
|
|
|
use Config::General;
|
|
my $catalyst_config;
|
|
if ($is_local_env) {
|
|
$catalyst_config = Config::General->new("../../ngcp_panel.conf");
|
|
} else {
|
|
#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';
|
|
$catalyst_config = Config::General->new($panel_config);
|
|
}
|
|
my %config = $catalyst_config->getall();
|
|
|
|
my $uri = $ENV{CATALYST_SERVER} || ('https://'.hostfqdn.':4443');
|
|
my ($netloc) = ($uri =~ m!^https?://(.*)/?.*$!);
|
|
|
|
my ($ua, $req, $res);
|
|
$ua = LWP::UserAgent->new;
|
|
|
|
$ua->ssl_opts(
|
|
verify_hostname => 0,
|
|
SSL_verify_mode => 0,
|
|
);
|
|
my $user = $ENV{API_USER} // 'administrator';
|
|
my $pass = $ENV{API_PASS} // 'administrator';
|
|
$ua->credentials($netloc, "api_admin_http", $user, $pass);
|
|
|
|
my $req_identifier;
|
|
my $infinite_future;
|
|
|
|
{
|
|
my $future = NGCP::Panel::Utils::DateTime::infinite_future;
|
|
my $past = NGCP::Panel::Utils::DateTime::infinite_past;
|
|
my $now = NGCP::Panel::Utils::DateTime::current_local;
|
|
|
|
my $dtf = DateTime::Format::Strptime->new(
|
|
pattern => '%F %T',
|
|
);
|
|
$infinite_future = $dtf->format_datetime($future);
|
|
is($infinite_future,'9999-12-31 23:59:59','check if infinite future is 9999-12-31 23:59:59');
|
|
is($dtf->format_datetime($past),'1000-01-01 00:00:00','check if infinite past is 1000-01-01 00:00:00');
|
|
|
|
foreach my $offset ((0,'+'. 80*365*24*60*60 .'s','-'. 80*365*24*60*60 .'s')) {
|
|
|
|
my ($fake_now,$offset_label);
|
|
if ($offset) {
|
|
_set_time($offset);
|
|
$fake_now = NGCP::Panel::Utils::DateTime::current_local;
|
|
my $delta = $fake_now->epoch - $now->epoch;
|
|
my $delta_offset = substr($offset,0,length($offset)-2) * 1;
|
|
ok(abs($delta) > abs($delta_offset) && abs($delta_offset) > 0,"'Great Scott!'");
|
|
ok($delta > $delta_offset,'check fake time offset of ' . $offset . ': ' . $delta) if $delta_offset > 0;
|
|
ok(-1 * $delta > -1 * $delta_offset,'check fake time offset of ' . $offset . ': ' . $delta) if $delta_offset < 0;
|
|
$offset_label = 'fake time offset: ' . $offset . ': ';
|
|
} else {
|
|
$fake_now = $now;
|
|
$offset_label = '';
|
|
}
|
|
|
|
ok($future > $fake_now,$offset_label . 'future is greater than now');
|
|
ok(!($future < $fake_now),$offset_label . 'future is not smaller than now');
|
|
|
|
ok($past < $fake_now,$offset_label . 'past is smaller than now');
|
|
ok(!($past > $fake_now),$offset_label . 'past is not greater than now');
|
|
|
|
ok($future->epoch > $fake_now->epoch,$offset_label . 'future is greater than now (epoch)');
|
|
ok(!($future->epoch < $fake_now->epoch),$offset_label . 'future is not smaller than now (epoch)');
|
|
|
|
ok($past->epoch < $fake_now->epoch,$offset_label . 'past is smaller than now (epoch)');
|
|
ok(!($past->epoch > $fake_now->epoch),$offset_label . 'past is not greater than now (epoch)');
|
|
}
|
|
_set_time();
|
|
}
|
|
|
|
my $t = time;
|
|
my $default_reseller_id = 1;
|
|
|
|
my $default_custcontact = _create_customer_contact();
|
|
|
|
$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 => $default_reseller_id,
|
|
}));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test domain");
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed test domain");
|
|
my $domain = JSON::from_json($res->decoded_content);
|
|
|
|
|
|
my %customer_map :shared = ();
|
|
my %subscriber_map :shared = ();
|
|
|
|
my $customer_contact_map = {};
|
|
my $package_map = {};
|
|
my $voucher_map = {};
|
|
my $profile_map = {};
|
|
|
|
my $billingprofile = _create_billing_profile("test_default");
|
|
|
|
my $tb;
|
|
my $tb_cnt;
|
|
my $gantt_events;
|
|
|
|
if (_get_allow_fake_client_time()) { # && $enable_profile_packages) {
|
|
|
|
#goto SKIP;
|
|
#goto THREADED;
|
|
if ('Europe/Vienna' eq NGCP::Panel::Utils::DateTime::current_local()->time_zone->name) {
|
|
if (!$disable_hourly_intervals) {
|
|
my $package = _create_profile_package('create','hour',1);
|
|
|
|
{
|
|
my $dt = NGCP::Panel::Utils::DateTime::from_string('2015-03-29 01:27:00');
|
|
ok(!$dt->is_dst(),NGCP::Panel::Utils::DateTime::to_string($dt)." is not in daylight saving time (winter)");
|
|
_set_time($dt);
|
|
my $customer = _create_customer($package,'hourly_interval_dst_at');
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-03-29 00:00:00', stop => '2015-03-29 00:59:59' },
|
|
{ start => '2015-03-29 01:00:00', stop => '2015-03-29 01:59:59' },
|
|
]);
|
|
|
|
$dt = NGCP::Panel::Utils::DateTime::from_string('2015-03-29 03:27:00');
|
|
ok($dt->is_dst(),NGCP::Panel::Utils::DateTime::to_string($dt)." is in daylight saving time (summer)");
|
|
_set_time($dt);
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-03-29 00:00:00', stop => '2015-03-29 00:59:59' },
|
|
{ start => '2015-03-29 01:00:00', stop => '2015-03-29 01:59:59' },
|
|
#{ start => '2015-03-29 02:00:00', stop => '2015-03-29 02:59:59' }, #a dead one
|
|
{ start => '2015-03-29 03:00:00', stop => '2015-03-29 03:59:59' },
|
|
]);
|
|
|
|
_set_time();
|
|
}
|
|
{
|
|
my $dt = NGCP::Panel::Utils::DateTime::from_string('2015-10-25 01:27:00');
|
|
ok($dt->is_dst(),NGCP::Panel::Utils::DateTime::to_string($dt)." is in daylight saving time (summer)");
|
|
_set_time($dt);
|
|
my $customer = _create_customer($package,'hourly_interval_dst_at');
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-10-25 00:00:00', stop => '2015-10-25 00:59:59' },
|
|
{ start => '2015-10-25 01:00:00', stop => '2015-10-25 01:59:59' },
|
|
]);
|
|
|
|
#$dt = NGCP::Panel::Utils::DateTime::from_string('2015-10-25 02:27:00');
|
|
#ok(!$dt->is_dst(),NGCP::Panel::Utils::DateTime::to_string($dt)." is not in daylight saving time (winter)");
|
|
#_set_time($dt);
|
|
#
|
|
#_check_interval_history($customer,[
|
|
# { start => '2015-10-25 00:00:00', stop => '2015-10-25 00:59:59' },
|
|
# { start => '2015-10-25 01:00:00', stop => '2015-10-25 01:59:59' },
|
|
# { start => '2015-10-25 02:00:00', stop => '2015-10-25 02:59:59' },
|
|
#]);
|
|
|
|
$dt = NGCP::Panel::Utils::DateTime::from_string('2015-10-25 03:27:00');
|
|
ok(!$dt->is_dst(),NGCP::Panel::Utils::DateTime::to_string($dt)." is not in daylight saving time (winter)");
|
|
_set_time($dt);
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-10-25 00:00:00', stop => '2015-10-25 00:59:59' },
|
|
{ start => '2015-10-25 01:00:00', stop => '2015-10-25 01:59:59' },
|
|
{ start => '2015-10-25 02:00:00', stop => '2015-10-25 02:59:59' },
|
|
{ start => '2015-10-25 03:00:00', stop => '2015-10-25 03:59:59' },
|
|
]);
|
|
|
|
_set_time();
|
|
}
|
|
}
|
|
} else {
|
|
diag("time zone '" . NGCP::Panel::Utils::DateTime::current_local()->time_zone->name . "', skipping DST test");
|
|
}
|
|
|
|
if (!$disable_hourly_intervals) {
|
|
my $package = _create_profile_package('create','hour',1);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-09-02 01:59:41'));
|
|
|
|
my $customer = _create_customer($package,'hourly_interval');
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-09-02 00:00:00', stop => '2015-09-02 00:59:59' },
|
|
{ start => '2015-09-02 01:00:00', stop => '2015-09-02 01:59:59' },
|
|
]);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-09-02 02:00:01'));
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-09-02 00:00:00', stop => '2015-09-02 00:59:59' },
|
|
{ start => '2015-09-02 01:00:00', stop => '2015-09-02 01:59:59' },
|
|
{ start => '2015-09-02 02:00:00', stop => '2015-09-02 02:59:59' },
|
|
]);
|
|
|
|
_set_time();
|
|
}
|
|
|
|
if (!$disable_hourly_intervals) {
|
|
my $package = _create_profile_package('create','minute',1);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-09-03 00:01:41'));
|
|
|
|
my $customer = _create_customer($package,'minute_interval');
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-09-03 00:00:00', stop => '2015-09-03 00:00:59' },
|
|
{ start => '2015-09-03 00:01:00', stop => '2015-09-03 00:01:59' },
|
|
]);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-09-03 00:02:01'));
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-09-03 00:00:00', stop => '2015-09-03 00:00:59' },
|
|
{ start => '2015-09-03 00:01:00', stop => '2015-09-03 00:01:59' },
|
|
{ start => '2015-09-03 00:02:00', stop => '2015-09-03 00:02:59' },
|
|
]);
|
|
|
|
_set_time();
|
|
}
|
|
|
|
#SKIP:
|
|
{
|
|
my $profile_initial = _create_billing_profile('UNDERRUN1_INITIAL',prepaid => 0);
|
|
my $profile_topup = _create_billing_profile('UNDERRUN1_TOPUP',prepaid => 0);
|
|
my $profile_underrun = _create_billing_profile('UNDERRUN1_UNDERRUN',prepaid => 1);
|
|
|
|
my $package = _create_profile_package('1st','month',1, initial_balance => 100,
|
|
carry_over_mode => 'discard', underrun_lock_threshold => 50, underrun_lock_level => 4, underrun_profile_threshold => 50,
|
|
initial_profiles => [ { profile_id => $profile_initial->{id}, }, ],
|
|
topup_profiles => [ { profile_id => $profile_topup->{id}, }, ],
|
|
underrun_profiles => [ { profile_id => $profile_underrun->{id}, }, ],
|
|
);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-14 13:00:00'));
|
|
|
|
my $customer = _create_customer($package,'underrun_1');
|
|
my $subscriber = _create_subscriber($customer,'of customer underrun_1');
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-06-01 00:00:00', stop => '2015-06-30 23:59:59', cash => 1, profile => $profile_initial->{id} },
|
|
]);
|
|
is(_get_subscriber_lock_level($subscriber),undef,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_cash_balance($customer,0.51);
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-06-01 00:00:00', stop => '2015-06-30 23:59:59', cash => 0.51, profile => $profile_initial->{id} },
|
|
]);
|
|
is(_get_subscriber_lock_level($subscriber),undef,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_cash_balance($customer,0.49);
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-06-01 00:00:00', stop => '2015-06-30 23:59:59', cash => 0.49, profile => $profile_initial->{id} },
|
|
]);
|
|
is(_get_actual_billing_profile_id($customer),$profile_underrun->{id},"check customer id " . $customer->{id} . " actual billing profile id");
|
|
is(_get_subscriber_lock_level($subscriber),4,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-07-14 13:00:00'));
|
|
|
|
_perform_topup_cash($subscriber,0.5);
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-06-01 00:00:00', stop => '2015-06-30 23:59:59', cash => 0.49, profile => $profile_initial->{id} },
|
|
{ start => '2015-07-01 00:00:00', stop => '2015-07-31 23:59:59', cash => 0.5, profile => $profile_underrun->{id} },
|
|
]);
|
|
is(_get_actual_billing_profile_id($customer),$profile_topup->{id},"check customer id " . $customer->{id} . " actual billing profile id");
|
|
is(_get_subscriber_lock_level($subscriber),4,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time();
|
|
|
|
}
|
|
|
|
{
|
|
#underrun due to switching to package with lower thresholds:
|
|
my $profile_initial_1 = _create_billing_profile('UNDERRUN2_INITIAL_1');
|
|
my $profile_underrun_1 = _create_billing_profile('UNDERRUN2_UNDERRUN_1');
|
|
|
|
my $profile_initial_2 = _create_billing_profile('UNDERRUN2_INITIAL_2');
|
|
my $profile_topup_2 = _create_billing_profile('UNDERRUN2_TOPUP_2');
|
|
my $profile_underrun_2 = _create_billing_profile('UNDERRUN2_UNDERRUN_2');
|
|
|
|
my $package_1 = _create_profile_package('1st','month',1, initial_balance => 49,
|
|
carry_over_mode => 'discard', underrun_lock_threshold => 50, underrun_lock_level => 4, underrun_profile_threshold => 52,
|
|
initial_profiles => [ { profile_id => $profile_initial_1->{id}, }, ],
|
|
underrun_profiles => [ { profile_id => $profile_underrun_1->{id}, }, ],
|
|
);
|
|
|
|
my $package_2 = _create_profile_package('topup_interval','month',1, initial_balance => 99,
|
|
carry_over_mode => 'carry_over', underrun_lock_threshold => 51, underrun_lock_level => 4, underrun_profile_threshold => 51,
|
|
initial_profiles => [ { profile_id => $profile_initial_2->{id}, }, ],
|
|
underrun_profiles => [ { profile_id => $profile_underrun_2->{id}, }, ],
|
|
);
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-01-23 13:00:00'));
|
|
|
|
my $customer = _create_customer($package_1,'1');
|
|
my $subscriber = _create_subscriber($customer,'of customer 1');
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-01-01 00:00:00', stop => '2015-01-31 23:59:59', cash => 0.49, profile => $profile_underrun_1->{id} },
|
|
]);
|
|
is(_get_subscriber_lock_level($subscriber),4,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_switch_package($customer,$package_2);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-01-24 13:00:00'));
|
|
|
|
_perform_topup_cash($subscriber,0.01);
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-01-01 00:00:00', stop => '~2015-01-24 13:00:00', cash => 0.49, profile => $profile_underrun_1->{id} },
|
|
{ start => '~2015-01-24 13:00:00', stop => '~2015-02-24 13:00:00', cash => 0.5, profile => $profile_underrun_2->{id} },
|
|
]);
|
|
is(_get_subscriber_lock_level($subscriber),4,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time();
|
|
}
|
|
|
|
{
|
|
|
|
my $profile_initial = _create_billing_profile('UNDERRUN3_INITIAL');
|
|
my $profile_topup = _create_billing_profile('UNDERRUN3_TOPUP');
|
|
my $profile_underrun = _create_billing_profile('UNDERRUN3_UNDERRUN');
|
|
|
|
my $package = _create_profile_package('topup','month',1,
|
|
carry_over_mode => 'carry_over', underrun_lock_threshold => 1000, underrun_lock_level => 4, underrun_profile_threshold => 1000,
|
|
topup_lock_level => 0,
|
|
initial_profiles => [ { profile_id => $profile_initial->{id}, }, ],
|
|
topup_profiles => [ { profile_id => $profile_topup->{id}, }, ],
|
|
underrun_profiles => [ { profile_id => $profile_underrun->{id}, }, ],
|
|
);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-07-20 13:00:00'));
|
|
|
|
my $customer = _create_customer($package,'2');
|
|
my $subscriber = _create_subscriber($customer,'of customer 2');
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-07-20 13:00:00', stop => $infinite_future, cash => 0, profile => $profile_underrun->{id} },
|
|
]);
|
|
is(_get_subscriber_lock_level($subscriber),4,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-07-20 13:00:10'));
|
|
|
|
_perform_topup_cash($subscriber,5);
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-07-20 13:00:00', stop => '~2015-07-20 13:00:10', cash => 0, profile => $profile_underrun->{id} },
|
|
{ start => '~2015-07-20 13:00:10', stop => $infinite_future, cash => 5, profile => $profile_underrun->{id} },
|
|
]);
|
|
is(_get_subscriber_lock_level($subscriber),undef,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-07-20 13:00:20'));
|
|
_perform_topup_cash($subscriber,5);
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-07-20 13:00:00', stop => '~2015-07-20 13:00:10', cash => 0, profile => $profile_underrun->{id} },
|
|
{ start => '~2015-07-20 13:00:10', stop => '~2015-07-20 13:00:20', cash => 5, profile => $profile_underrun->{id} },
|
|
{ start => '~2015-07-20 13:00:20', stop => $infinite_future, cash => 10, profile => $profile_topup->{id} },
|
|
]);
|
|
is(_get_subscriber_lock_level($subscriber),undef,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time();
|
|
}
|
|
|
|
{
|
|
#_start_recording();
|
|
my $network_x = _create_billing_network_x();
|
|
my $network_y = _create_billing_network_y();
|
|
|
|
my $profile_base_any = _create_billing_profile('BASE_ANY_NETWORK');
|
|
my $profile_base_x = _create_billing_profile('BASE_NETWORK_X');
|
|
my $profile_base_y = _create_billing_profile('BASE_NETWORK_Y');
|
|
|
|
my $profile_silver_x = _create_billing_profile('SILVER_NETWORK_X');
|
|
my $profile_silver_y = _create_billing_profile('SILVER_NETWORK_Y');
|
|
|
|
my $profile_gold_x = _create_billing_profile('GOLD_NETWORK_X');
|
|
my $profile_gold_y = _create_billing_profile('GOLD_NETWORK_Y');
|
|
|
|
my $base_package = _create_base_profile_package($profile_base_any,$profile_base_x,$profile_base_y,$network_x,$network_y);
|
|
my $silver_package = _create_silver_profile_package($base_package,$profile_silver_x,$profile_silver_y,$network_x,$network_y);
|
|
my $extension_package = _create_extension_profile_package($base_package,$profile_silver_x,$profile_silver_y,$network_x,$network_y);
|
|
my $gold_package = _create_gold_profile_package($base_package,$profile_gold_x,$profile_gold_y,$network_x,$network_y);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-05 13:00:00'));
|
|
my $customer_A = _create_customer($base_package,'A');
|
|
my $subscriber_A = _create_subscriber($customer_A,'of customer A');
|
|
#_start_recording();
|
|
my $v_silver_1 = _create_voucher(10,'SILVER_1_'.$t,undef,$silver_package);
|
|
#print _stop_recording();
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-21 13:00:00'));
|
|
|
|
_perform_topup_voucher($subscriber_A,$v_silver_1);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-10-01 13:00:00'));
|
|
|
|
_check_interval_history($customer_A,[
|
|
{ start => '~2015-06-05 13:00:00', stop => '~2015-06-21 13:00:00', cash => 0, profile => $profile_base_y->{id} },
|
|
{ start => '~2015-06-21 13:00:00', stop => '~2015-07-21 13:00:00', cash => 8, profile => $profile_silver_y->{id} },
|
|
{ start => '~2015-07-21 13:00:00', stop => '~2015-08-21 13:00:00', cash => 0, profile => $profile_silver_y->{id} },
|
|
{ start => '~2015-08-21 13:00:00', stop => '~2015-09-21 13:00:00', cash => 0, profile => $profile_silver_y->{id} },
|
|
{ start => '~2015-09-21 13:00:00', stop => '~2015-10-21 13:00:00', cash => 0, profile => $profile_silver_y->{id} },
|
|
]);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-05 13:00:00'));
|
|
my $customer_B = _create_customer($base_package,'B');
|
|
my $subscriber_B = _create_subscriber($customer_B,'of customer B');
|
|
my $v_silver_2 = _create_voucher(10,'SILVER_2_'.$t,undef,$silver_package);
|
|
my $v_extension_1 = _create_voucher(2,'EXTENSION_1_'.$t,undef,$extension_package);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-27 13:00:00'));
|
|
|
|
_perform_topup_voucher($subscriber_B,$v_silver_2);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-07-27 12:00:00'));
|
|
|
|
_perform_topup_voucher($subscriber_B,$v_extension_1);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-10-01 13:00:00'));
|
|
|
|
_check_interval_history($customer_B,[
|
|
{ start => '~2015-06-05 13:00:00', stop => '~2015-06-27 13:00:00', cash => 0, profile => $profile_base_y->{id} },
|
|
{ start => '~2015-06-27 13:00:00', stop => '~2015-07-27 13:00:00', cash => 8, profile => $profile_silver_y->{id} },
|
|
{ start => '~2015-07-27 13:00:00', stop => '~2015-08-27 13:00:00', cash => 8, profile => $profile_silver_y->{id} },
|
|
{ start => '~2015-08-27 13:00:00', stop => '~2015-09-27 13:00:00', cash => 0, profile => $profile_silver_y->{id} },
|
|
{ start => '~2015-09-27 13:00:00', stop => '~2015-10-27 13:00:00', cash => 0, profile => $profile_silver_y->{id} },
|
|
]);
|
|
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-05 13:00:00'));
|
|
my $customer_C = _create_customer($base_package,'C');
|
|
my $subscriber_C = _create_subscriber($customer_C,'of customer C');
|
|
my $v_gold_1 = _create_voucher(20,'GOLD_1_'.$t,undef,$gold_package);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-07-02 13:00:00'));
|
|
|
|
_perform_topup_voucher($subscriber_C,$v_gold_1);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-10-01 13:00:00'));
|
|
|
|
_perform_topup_cash($subscriber_C,10,$silver_package);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-11-01 13:00:00'));
|
|
|
|
_check_interval_history($customer_C,[
|
|
{ start => '~2015-06-05 13:00:00', stop => '~2015-07-02 13:00:00', cash => 0, profile => $profile_base_y->{id} },
|
|
{ start => '~2015-07-02 13:00:00', stop => '~2015-08-02 13:00:00', cash => 15, profile => $profile_gold_y->{id} },
|
|
{ start => '~2015-08-02 13:00:00', stop => '~2015-09-02 13:00:00', cash => 15, profile => $profile_gold_y->{id} },
|
|
{ start => '~2015-09-02 13:00:00', stop => '~2015-10-02 13:00:00', cash => 23, profile => $profile_gold_y->{id} },
|
|
{ start => '~2015-10-02 13:00:00', stop => '~2015-11-02 13:00:00', cash => 0, profile => $profile_silver_y->{id} },
|
|
]);
|
|
|
|
_set_time();
|
|
#print _stop_recording();
|
|
}
|
|
|
|
my $prof_package_create30d = _create_profile_package('create','day',30);
|
|
my $prof_package_1st30d = _create_profile_package('1st','day',30);
|
|
|
|
my $prof_package_create1m = _create_profile_package('create','month',1);
|
|
my $prof_package_1st1m = _create_profile_package('1st','month',1);
|
|
|
|
my $prof_package_create2w = _create_profile_package('create','week',2);
|
|
my $prof_package_1st2w = _create_profile_package('1st','week',2);
|
|
|
|
my $prof_package_topup = _create_profile_package('topup',"month",1);
|
|
|
|
my $prof_package_topup_interval = _create_profile_package('topup_interval',"month",1);
|
|
|
|
{
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2014-12-30 13:00:00'));
|
|
|
|
my $customer_topup = _create_customer($prof_package_topup); #create closest to now
|
|
my $customer_wo = _create_customer();
|
|
my $customer_create1m = _create_customer($prof_package_create1m);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-04-02 02:00:00'));
|
|
|
|
_check_interval_history($customer_topup,[
|
|
{ start => '~2014-12-30 13:00:00', stop => $infinite_future},
|
|
]);
|
|
|
|
_check_interval_history($customer_wo,[
|
|
{ start => '2014-12-01 00:00:00', stop => '2014-12-31 23:59:59'},
|
|
{ start => '2015-01-01 00:00:00', stop => '2015-01-31 23:59:59'},
|
|
{ start => '2015-02-01 00:00:00', stop => '2015-02-28 23:59:59'},
|
|
{ start => '2015-03-01 00:00:00', stop => '2015-03-31 23:59:59'},
|
|
{ start => '2015-04-01 00:00:00', stop => '2015-04-30 23:59:59'},
|
|
]); #,NGCP::Panel::Utils::DateTime::from_string('2014-11-29 13:00:00'));
|
|
|
|
_check_interval_history($customer_create1m,[
|
|
{ start => '2014-12-30 00:00:00', stop => '2015-01-29 23:59:59'},
|
|
{ start => '2015-01-30 00:00:00', stop => '2015-02-27 23:59:59'},
|
|
{ start => '2015-02-28 00:00:00', stop => '2015-03-29 23:59:59'},
|
|
{ start => '2015-03-30 00:00:00', stop => '2015-04-29 23:59:59'},
|
|
]);
|
|
|
|
_set_time();
|
|
}
|
|
|
|
{
|
|
my $ts = '2014-01-07 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$gantt_events = [];
|
|
|
|
my $cnt = 1;
|
|
$req_identifier = $cnt . '. create customer'; diag($req_identifier); $cnt++;
|
|
my $customer = _create_customer();
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef },
|
|
]);
|
|
|
|
$ts = '2014-03-01 13:00:00'; $gantt_events = [];
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef },
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef },
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-31 23:59:59', package_id => undef },
|
|
]);
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_create30d->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_create30d);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef },
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef },
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-06 23:59:59', package_id => [ undef , $prof_package_create30d->{id} ] },
|
|
]);
|
|
|
|
$ts = '2014-04-01 13:00:00';
|
|
$gantt_events = [];
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef },
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef },
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-06 23:59:59', package_id => [ undef , $prof_package_create30d->{id} ] },
|
|
{ start => '2014-03-07 00:00:00', stop => '2014-04-05 23:59:59', package_id => $prof_package_create30d->{id} },
|
|
]);
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_1st30d->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_1st30d);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef},
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef},
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-06 23:59:59', package_id => [ undef , $prof_package_create30d->{id} ] },
|
|
{ start => '2014-03-07 00:00:00', stop => '2014-04-30 23:59:59', package_id => [ $prof_package_create30d->{id}, $prof_package_1st30d->{id} ] },
|
|
]);
|
|
|
|
$ts = '2014-05-13 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef},
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef},
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-06 23:59:59', package_id => [ undef , $prof_package_create30d->{id} ]},
|
|
{ start => '2014-03-07 00:00:00', stop => '2014-04-30 23:59:59', package_id => [ $prof_package_create30d->{id}, $prof_package_1st30d->{id} ]},
|
|
{ start => '2014-05-01 00:00:00', stop => '2014-05-30 23:59:59', package_id => $prof_package_1st30d->{id} },
|
|
]);
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_create1m->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_create1m);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef},
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef},
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-06 23:59:59', package_id => [ undef , $prof_package_create30d->{id} ]},
|
|
{ start => '2014-03-07 00:00:00', stop => '2014-04-30 23:59:59', package_id => [ $prof_package_create30d->{id}, $prof_package_1st30d->{id} ]},
|
|
{ start => '2014-05-01 00:00:00', stop => '2014-06-06 23:59:59', package_id => [ $prof_package_1st30d->{id}, $prof_package_create1m->{id} ]},
|
|
]);
|
|
|
|
$ts = '2014-05-27 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef},
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef},
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-06 23:59:59', package_id => [ undef , $prof_package_create30d->{id} ]},
|
|
{ start => '2014-03-07 00:00:00', stop => '2014-04-30 23:59:59', package_id => [ $prof_package_create30d->{id}, $prof_package_1st30d->{id} ]},
|
|
{ start => '2014-05-01 00:00:00', stop => '2014-06-06 23:59:59', package_id => [ $prof_package_1st30d->{id}, $prof_package_create1m->{id} ]},
|
|
]);
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_1st1m->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_1st1m);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-01-01 00:00:00', stop => '2014-01-31 23:59:59', package_id => undef},
|
|
{ start => '2014-02-01 00:00:00', stop => '2014-02-28 23:59:59', package_id => undef},
|
|
{ start => '2014-03-01 00:00:00', stop => '2014-03-06 23:59:59', package_id => [ undef , $prof_package_create30d->{id} ]},
|
|
{ start => '2014-03-07 00:00:00', stop => '2014-04-30 23:59:59', package_id => [ $prof_package_create30d->{id}, $prof_package_1st30d->{id} ]},
|
|
{ start => '2014-05-01 00:00:00', stop => '2014-05-31 23:59:59', package_id => [ $prof_package_create30d->{id}, $prof_package_1st30d->{id}, $prof_package_1st1m->{id} ]},
|
|
]);
|
|
|
|
my $t1 = $ts;
|
|
$gantt_events = [];
|
|
$ts = '2014-08-03 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_create2w->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_create2w);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-06-01 00:00:00', stop => '2014-06-30 23:59:59', package_id => $prof_package_1st1m->{id}},
|
|
{ start => '2014-07-01 00:00:00', stop => '2014-07-31 23:59:59', package_id => $prof_package_1st1m->{id}},
|
|
{ start => '2014-08-01 00:00:00', stop => '2014-08-06 23:59:59', package_id => [ $prof_package_1st1m->{id}, $prof_package_create2w->{id} ]},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$t1 = $ts;
|
|
$gantt_events = [];
|
|
$ts = '2014-09-03 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_1st2w->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_1st2w);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-08-07 00:00:00', stop => '2014-08-20 23:59:59', package_id => $prof_package_create2w->{id}},
|
|
{ start => '2014-08-21 00:00:00', stop => '2014-09-30 23:59:59', package_id => [ $prof_package_create2w->{id}, $prof_package_1st2w->{id} ]},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
#$t1 = $ts;
|
|
#$ts = '2014-09-03 13:00:00';
|
|
#_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to no package'; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-08-07 00:00:00', stop => '2014-08-20 23:59:59', package_id => $prof_package_create2w->{id}},
|
|
{ start => '2014-08-21 00:00:00', stop => '2014-09-30 23:59:59', package_id => [ $prof_package_create2w->{id}, $prof_package_1st2w->{id}, undef ]},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$t1 = $ts;
|
|
$gantt_events = [];
|
|
#my $t1 = '2014-09-03 13:00:00';
|
|
$ts = '2014-10-04 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_topup->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_topup);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
#diag("wait a second here");
|
|
#sleep(1); #sigh
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-10-01 00:00:00', stop => '~2014-10-04 13:00:00', package_id => undef },
|
|
{ start => '~2014-10-04 13:00:00', stop => $infinite_future, package_id => $prof_package_topup->{id}},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$req_identifier = $cnt . '. create topup_start_mode_test1 voucher'; diag($req_identifier); $cnt++;
|
|
my $voucher1 = _create_voucher(10,'topup_start_mode_test1'.$t,$customer);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
$req_identifier = $cnt . '. create topup_start_mode_test2 voucher'; diag($req_identifier); $cnt++;
|
|
my $voucher2 = _create_voucher(10,'topup_start_mode_test2'.$t,$customer,$prof_package_create1m);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
$req_identifier = $cnt . '. create subscriber for customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
my $subscriber = _create_subscriber($customer);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$t1 = $ts;
|
|
$ts = '2014-10-23 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '~2014-10-04 13:00:00', stop => $infinite_future, package_id => $prof_package_topup->{id}},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$req_identifier = $cnt . '. perform topup with voucher ' . $voucher1->{code}; diag($req_identifier); $cnt++;
|
|
_perform_topup_voucher($subscriber,$voucher1);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '~2014-10-04 13:00:00', stop => '~2014-10-23 13:00:00', package_id => $prof_package_topup->{id}},
|
|
{ start => '~2014-10-23 13:00:00', stop => $infinite_future, package_id => $voucher1->{package_id}},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$t1 = $ts;
|
|
$gantt_events = [];
|
|
$ts = '2014-11-29 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '~2014-10-23 13:00:00', stop => $infinite_future, package_id => $voucher1->{package_id}},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$req_identifier = $cnt . '. perform topup with voucher ' . $voucher2->{code}; diag($req_identifier); $cnt++;
|
|
_perform_topup_voucher($subscriber,$voucher2);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '~2014-10-23 13:00:00', stop => '2014-12-06 23:59:59', package_id => [$voucher1->{package_id}, $voucher2->{package_id}]},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to no package'; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '~2014-10-23 13:00:00', stop => '2014-11-30 23:59:59', cash => 20, package_id => [$voucher1->{package_id}, $voucher2->{package_id}, undef]},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$t1 = $ts;
|
|
$gantt_events = [];
|
|
$ts = '2015-01-19 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-12-01 00:00:00', stop => '2014-12-31 23:59:59', package_id => undef},
|
|
{ start => '2015-01-01 00:00:00', stop => '2015-01-31 23:59:59', package_id => undef},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$req_identifier = $cnt . '. switch customer ' . $customer->{id} . ' to package ' . $prof_package_topup_interval->{description}; diag($req_identifier); $cnt++;
|
|
$customer = _switch_package($customer,$prof_package_topup_interval);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-12-01 00:00:00', stop => '2014-12-31 23:59:59', package_id => undef},
|
|
{ start => '2015-01-01 00:00:00', stop => $infinite_future, package_id => [ undef, $prof_package_topup_interval->{id}]},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$req_identifier = $cnt . '. create topup_interval_start_mode_test voucher'; diag($req_identifier); $cnt++;
|
|
my $voucher3 = _create_voucher(15,'topup_interval_start_mode_test'.$t,$customer,$prof_package_topup_interval);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$ts = '2015-03-11 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
$req_identifier = $cnt . '. perform topup with voucher ' . $voucher3->{code}; diag($req_identifier); $cnt++;
|
|
_perform_topup_voucher($subscriber,$voucher3);
|
|
push(@$gantt_events,{ name => $req_identifier, t => $ts });
|
|
|
|
$req_identifier = $cnt . '. get balance history of customer ' . $customer->{id}; diag($req_identifier); $cnt++;
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-12-01 00:00:00', stop => '2014-12-31 23:59:59', package_id => undef},
|
|
{ start => '2015-01-01 00:00:00', stop => '~2015-03-11 13:00:00', package_id => [ undef, $prof_package_topup_interval->{id}]},
|
|
{ start => '~2015-03-11 13:00:00', stop => '~2015-04-11 13:00:00', package_id => $prof_package_topup_interval->{id}},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
$ts = '2015-05-17 13:00:00';
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string($ts));
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2014-12-01 00:00:00', stop => '2014-12-31 23:59:59', package_id => undef},
|
|
{ start => '2015-01-01 00:00:00', stop => '~2015-03-11 13:00:00', package_id => [ undef, $prof_package_topup_interval->{id}]},
|
|
{ start => '~2015-03-11 13:00:00', stop => '~2015-04-11 13:00:00', package_id => $prof_package_topup_interval->{id}},
|
|
{ start => '~2015-04-11 13:00:00', stop => '~2015-05-11 13:00:00', package_id => $prof_package_topup_interval->{id}},
|
|
{ start => '~2015-05-11 13:00:00', stop => '~2015-06-11 13:00:00', cash => 35, package_id => $prof_package_topup_interval->{id}},
|
|
],NGCP::Panel::Utils::DateTime::from_string($t1));
|
|
|
|
_set_time();
|
|
undef $req_identifier;
|
|
undef $gantt_events;
|
|
}
|
|
|
|
#SKIP:
|
|
{
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-01-30 13:00:00'));
|
|
|
|
my $profile_underrun = _create_billing_profile('UNDERRUN_NOTOPUP');
|
|
my $profile_topup = _create_billing_profile('TOPUP_NOTOPUP');
|
|
my $package = _create_profile_package('create','month',1, notopup_discard_intervals => 2,
|
|
initial_balance => 0, carry_over_mode => 'carry_over',
|
|
topup_profiles => [{ profile_id => $profile_topup->{id}, }, ],
|
|
underrun_profile_threshold => 1, underrun_profiles => [{ profile_id => $profile_underrun->{id}, }, ],);
|
|
my $customer = _create_customer($package);
|
|
my $subscriber = _create_subscriber($customer);
|
|
my $v_notopup = _create_voucher(10,'notopup'.$t);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-02-17 13:00:00'));
|
|
|
|
_perform_topup_voucher($subscriber,$v_notopup);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-01 13:00:00'));
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '2015-01-30 00:00:00', stop => '2015-02-27 23:59:59', cash => 10, topups => 1, profile => $profile_underrun->{id} }, #topup
|
|
{ start => '2015-02-28 00:00:00', stop => '2015-03-29 23:59:59', cash => 10, topups => 0, profile => $profile_topup->{id} },
|
|
{ start => '2015-03-30 00:00:00', stop => '2015-04-29 23:59:59', cash => 10, topups => 0, profile => $profile_topup->{id} },
|
|
{ start => '2015-04-30 00:00:00', stop => '2015-05-29 23:59:59', cash => 0, topups => 0, profile => $profile_underrun->{id} }, #'notopup_discard_expiry' => '2015-04-30 00:00:00'
|
|
{ start => '2015-05-30 00:00:00', stop => '2015-06-29 23:59:59', cash => 0, topups => 0, profile => $profile_underrun->{id} },
|
|
#{ start => '2015-06-30 00:00:00', stop => '2015-07-29 23:59:59', cash => 0, topups => 0 },
|
|
]);
|
|
|
|
_set_time();
|
|
}
|
|
|
|
{
|
|
|
|
my $profile_underrun = _create_billing_profile('UNDERRUN_NOTOPUP_INF');
|
|
my $profile_initial = _create_billing_profile('INITIAL_NOTOPUP_INF');
|
|
my $package = _create_profile_package('topup_interval','month',1, notopup_discard_intervals => 3,
|
|
initial_balance => 1, carry_over_mode => 'carry_over',
|
|
initial_profiles => [{ profile_id => $profile_initial->{id}, }, ],
|
|
underrun_lock_threshold => 1,
|
|
underrun_lock_level => 4,
|
|
underrun_profile_threshold => 1, underrun_profiles => [{ profile_id => $profile_underrun->{id}, }, ],);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-01-30 13:00:00'));
|
|
my $customer = _create_customer($package);
|
|
my $subscriber = _create_subscriber($customer);
|
|
#my $v_notopup = _create_voucher(10,'notopup'.$t);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-02-17 13:00:00'));
|
|
|
|
#_perform_topup_voucher($subscriber,$v_notopup);
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-01-30 13:00:00', stop => $infinite_future, cash => 0.01, profile => $profile_initial->{id} },
|
|
]);
|
|
is(_get_customer($customer)->{billing_profile_id},$profile_initial->{id},'check customer actual billing profile id');
|
|
is(_get_subscriber_lock_level($subscriber),undef,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-01 13:00:00'));
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-01-30 13:00:00', stop => $infinite_future, cash => 0.00, profile => $profile_initial->{id} },
|
|
]);
|
|
is(_get_customer($customer)->{billing_profile_id},$profile_underrun->{id},'check customer actual billing profile id');
|
|
is(_get_subscriber_lock_level($subscriber),4,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time();
|
|
}
|
|
|
|
#SKIP:
|
|
{
|
|
|
|
my $profile_underrun = _create_billing_profile('UNDERRUN_NOTOPUP_TIM');
|
|
my $profile_initial = _create_billing_profile('INITIAL_NOTOPUP_TIM');
|
|
my $package = _create_profile_package('topup_interval','month',1,
|
|
initial_balance => 1, carry_over_mode => 'carry_over_timely',
|
|
initial_profiles => [{ profile_id => $profile_initial->{id}, }, ],
|
|
timely_duration_unit => 'month',
|
|
timely_duration_value => 1,
|
|
underrun_lock_threshold => 1,
|
|
underrun_lock_level => 4,
|
|
underrun_profile_threshold => 1, underrun_profiles => [{ profile_id => $profile_underrun->{id}, }, ],);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-01-30 13:00:00'));
|
|
my $customer = _create_customer($package);
|
|
my $subscriber = _create_subscriber($customer);
|
|
#my $v_notopup = _create_voucher(10,'notopup'.$t);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-02-17 13:00:00'));
|
|
|
|
#_perform_topup_voucher($subscriber,$v_notopup);
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-01-30 13:00:00', stop => $infinite_future, cash => 0.01, profile => $profile_initial->{id} },
|
|
]);
|
|
is(_get_customer($customer)->{billing_profile_id},$profile_initial->{id},'check customer actual billing profile id');
|
|
is(_get_subscriber_lock_level($subscriber),undef,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-03-01 13:00:00'));
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-01-30 13:00:00', stop => $infinite_future, cash => 0.00, profile => $profile_initial->{id} },
|
|
]);
|
|
is(_get_customer($customer)->{billing_profile_id},$profile_underrun->{id},'check customer actual billing profile id');
|
|
is(_get_subscriber_lock_level($subscriber),4,"check subscriber id " . $subscriber->{id} . " lock level");
|
|
|
|
_set_time();
|
|
}
|
|
|
|
THREADED:
|
|
{
|
|
my $package = _create_profile_package('topup','month',1,
|
|
carry_over_mode => 'carry_over',
|
|
);
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-08-21 13:00:00'));
|
|
|
|
my $customer = _create_customer($package,'multi_topup');
|
|
my $subscriber_1 = _create_subscriber($customer,'of customer multi_topup');
|
|
my $subscriber_2 = _create_subscriber($customer,'of customer multi_topup');
|
|
my $subscriber_3 = _create_subscriber($customer,'of customer multi_topup');
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-08-22 13:00:00'));
|
|
my $delay = 5; #try 0 to provoke the concurrent action error
|
|
my $t_a = threads->create(sub { _perform_topup_cash($subscriber_1,2); });
|
|
sleep($delay);
|
|
my $t_b = threads->create(sub { _perform_topup_cash($subscriber_2,2); });
|
|
sleep($delay);
|
|
my $t_c = threads->create(sub { _perform_topup_cash($subscriber_3,2); });
|
|
$t_a->join();
|
|
$t_b->join();
|
|
$t_c->join();
|
|
|
|
|
|
_check_interval_history($customer,[
|
|
{ start => '~2015-08-21 13:00:00', stop => '~2015-08-22 13:00:00', cash => 0, topups => 1 },
|
|
{ start => '~2015-08-22 13:00:01', stop => '~2015-08-22 13:00:01', cash => 2, topups => 1 },
|
|
{ start => '~2015-08-22 13:00:02', stop => '~2015-08-22 13:00:02', cash => 4, topups => 1 },
|
|
{ start => '~2015-08-22 13:00:03', stop => $infinite_future, cash => 6, topups => 0 },
|
|
]);
|
|
|
|
_set_time();
|
|
}
|
|
|
|
if (_get_allow_delay_commit()) {
|
|
my $custcontact1 = _create_customer_contact();
|
|
my $custcontact2 = _create_customer_contact();
|
|
_set_time(NGCP::Panel::Utils::DateTime::current_local->subtract(months => 3));
|
|
_create_customers_threaded(3,undef,undef,$custcontact1);
|
|
_create_customers_threaded(3,undef,undef,$custcontact2);
|
|
_set_time();
|
|
|
|
my $t1 = time;
|
|
my $delay = 5; #15;
|
|
|
|
my $t_a = threads->create(\&_fetch_customerbalances_worker,$delay,'id','asc',$custcontact2);
|
|
my $t_b = threads->create(\&_fetch_customerbalances_worker,$delay,'id','desc',$custcontact2);
|
|
#my $t_c = threads->create(\&_fetch_customerbalances_worker,$delay,'id','asc',$custcontact9);
|
|
my $intervals_a = $t_a->join();
|
|
my $intervals_b = $t_b->join();
|
|
#my $intervals_c = $t_c->join();
|
|
my $t2 = time;
|
|
#my $got_a = [ sort { $a->{id} <=> $b->{id} } @{ $intervals_b->{_embedded}->{'ngcp:balanceintervals'} } ]; #$a->{contract_id}
|
|
is($intervals_a->{total_count},3,"check total count of thread a results");
|
|
is($intervals_b->{total_count},3,"check total count of thread b results");
|
|
#is($intervals_c->{total_count},scalar (grep { $_->{contact_id} == $custcontact9->{id} } values %customer_map),"check total count of thread c results");
|
|
my $got_asc = $intervals_a->{_embedded}->{'ngcp:customerbalances'};
|
|
my $got_desc = $intervals_b->{_embedded}->{'ngcp:customerbalances'};
|
|
if (!is_deeply($got_desc,[ reverse @{ $got_asc } ],'compare customerbalances collection results of threaded requests deeply')) {
|
|
diag(Dumper({asc => $got_asc, desc => $got_desc}));
|
|
}
|
|
my $delta_serialized = $t2 - $t1;
|
|
ok($delta_serialized >= 2*$delay,'expected delay to assume customerbalances requests were processed after another');
|
|
#ok($t2 - $t1 < 3*$delay,'expected delay to assume only required contracts were locked');
|
|
|
|
$t1 = time;
|
|
$t_a = threads->create(\&_fetch_customerbalances_worker,$delay,'id','asc',$custcontact1);
|
|
$t_b = threads->create(\&_fetch_customerbalances_worker,$delay,'id','desc',$custcontact2);
|
|
#$t_c = threads->create(\&_fetch_customerbalances_worker,$delay,'id','asc',$custcontact2);
|
|
$intervals_a = $t_a->join();
|
|
$intervals_b = $t_b->join();
|
|
#$intervals_c = $t_c->join();
|
|
$t2 = time;
|
|
|
|
is($intervals_a->{total_count},3,"check total count of thread a results");
|
|
is($intervals_b->{total_count},3,"check total count of thread b results");
|
|
#is($intervals_b->{total_count},scalar (grep { $_->{contact_id} == $custcontact9->{id} } values %customer_map),"check total count of thread b results");
|
|
#is($intervals_c->{total_count},3,"check total count of thread c results");
|
|
|
|
ok($t2 - $t1 < $delta_serialized,'expected delay to assume only required contracts were locked and requests were performed in parallel') if !$disable_parallel_catchup;
|
|
|
|
} else {
|
|
diag('allow_delay_commit not set, skipping ...');
|
|
}
|
|
|
|
if (_get_allow_delay_commit()) {
|
|
my $custcontact1 = _create_customer_contact();
|
|
my $custcontact2 = _create_customer_contact();
|
|
_set_time(NGCP::Panel::Utils::DateTime::current_local->subtract(months => 3));
|
|
_create_customers_threaded(3,undef,undef,$custcontact1);
|
|
_create_customers_threaded(3,undef,undef,$custcontact2);
|
|
_set_time();
|
|
|
|
my $t1 = time;
|
|
my $delay = 5; #15;
|
|
|
|
my $t_a = threads->create(\&_fetch_intervals_worker,$delay,'id','asc',$custcontact2);
|
|
my $t_b = threads->create(\&_fetch_intervals_worker,$delay,'id','desc',$custcontact2);
|
|
#my $t_c = threads->create(\&_fetch_intervals_worker,$delay,'id','desc',$custcontact9);
|
|
my $intervals_a = $t_a->join();
|
|
my $intervals_b = $t_b->join();
|
|
#my $intervals_c = $t_c->join();
|
|
my $t2 = time;
|
|
is($intervals_a->{total_count},3,"check total count of thread a results");
|
|
is($intervals_b->{total_count},3,"check total count of thread b results");
|
|
#is($intervals_c->{total_count},scalar (grep { $_->{contact_id} == $custcontact9->{id} } values %customer_map),"check total count of thread c results");
|
|
#my $got_a = [ sort { $a->{id} <=> $b->{id} } @{ $intervals_b->{_embedded}->{'ngcp:balanceintervals'} } ]; #$a->{contract_id}
|
|
my $got_asc = $intervals_a->{_embedded}->{'ngcp:balanceintervals'};
|
|
my $got_desc = $intervals_b->{_embedded}->{'ngcp:balanceintervals'};
|
|
if (!is_deeply($got_desc,[ reverse @{ $got_asc } ],'compare interval collection results of threaded requests deeply')) {
|
|
diag(Dumper({asc => $got_asc, desc => $got_desc}));
|
|
}
|
|
my $delta_serialized = $t2 - $t1;
|
|
ok($delta_serialized >= 2*$delay,'expected delay to assume balanceintervals requests were processed after another');
|
|
#ok($t2 - $t1 < 3*$delay,'expected delay to assume only required contracts were locked');
|
|
|
|
$t1 = time;
|
|
$t_a = threads->create(\&_fetch_intervals_worker,$delay,'id','asc',$custcontact1);
|
|
$t_b = threads->create(\&_fetch_intervals_worker,$delay,'id','desc',$custcontact2);
|
|
#$t_c = threads->create(\&_fetch_intervals_worker,$delay,'id','desc',$custcontact3);
|
|
$intervals_a = $t_a->join();
|
|
$intervals_b = $t_b->join();
|
|
#$intervals_c = $t_c->join();
|
|
$t2 = time;
|
|
|
|
is($intervals_a->{total_count},3,"check total count of thread a results");
|
|
is($intervals_b->{total_count},3,"check total count of thread b results");
|
|
#is($intervals_b->{total_count},scalar (grep { $_->{contact_id} == $custcontact9->{id} } values %customer_map),"check total count of thread b results");
|
|
#is($intervals_c->{total_count},3,"check total count of thread c results");
|
|
|
|
ok($t2 - $t1 < $delta_serialized,'expected delay to assume only required contracts were locked and requests were perfomed in parallel') if !$disable_parallel_catchup;
|
|
|
|
|
|
} else {
|
|
diag('allow_delay_commit not set, skipping ...');
|
|
}
|
|
|
|
if (_get_allow_delay_commit()) {
|
|
my $custcontact1 = _create_customer_contact();
|
|
my $custcontact2 = _create_customer_contact();
|
|
my $package = _create_profile_package('create','month',1,initial_balance => 1, carry_over_mode => 'discard', underrun_lock_threshold => 1, underrun_lock_level => 4);
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-05-17 13:00:00'));
|
|
_create_customers_threaded(3,2,$package,$custcontact1);
|
|
_create_customers_threaded(3,2,$package,$custcontact2);
|
|
|
|
my $t1 = time;
|
|
my $delay = 5.0; #15.0; #10.0; #2.0;
|
|
my $t_a = threads->create(\&_fetch_preferences_worker,$delay,'id','asc',$custcontact2);
|
|
my $t_b = threads->create(\&_fetch_preferences_worker,$delay,'id','desc',$custcontact2);
|
|
#my $t_c = threads->create(\&_fetch_preferences_worker,$delay,'id','desc',$custcontact9);
|
|
my $prefs_a = $t_a->join();
|
|
my $prefs_b = $t_b->join();
|
|
#my $prefs_c = $t_c->join();
|
|
my $t2 = time;
|
|
is($prefs_a->{total_count},2*3,"check total count of thread a results");
|
|
is($prefs_b->{total_count},2*3,"check total count of thread b results");
|
|
#is($prefs_c->{total_count},scalar (grep { $customer_map{$_->{customer_id}}->{contact_id} == $custcontact9->{id} } values %subscriber_map),"check total count of thread c results");
|
|
my $got_asc = $prefs_a->{_embedded}->{'ngcp:subscriberpreferences'};
|
|
my $got_desc = $prefs_b->{_embedded}->{'ngcp:subscriberpreferences'};
|
|
if (!is_deeply($got_desc,[ reverse @{ $got_asc } ],'compare subscriber preference collection results of threaded requests deeply')) {
|
|
diag(Dumper({asc => $got_asc, desc => $got_desc}));
|
|
}
|
|
my $delta_serialized = $t2 - $t1;
|
|
ok($delta_serialized >= 2*$delay,'expected delay to assume subscriberpreferences requests were processed after another');
|
|
#ok($t2 - $t1 < 3*$delay,'expected delay to assume only required contracts were locked');
|
|
for (my $i = 0; $i < 2*3; $i++) {
|
|
is($got_desc->[$i]->{lock},undef,"check if subscriber is unlocked initially");
|
|
}
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-18 13:00:00'));
|
|
|
|
#$t1 = time;
|
|
|
|
#$t_a = threads->create(\&_fetch_preferences_worker,$delay,'id','asc',$custcontact4);
|
|
#$t_b = threads->create(\&_fetch_preferences_worker,$delay,'id','desc',$custcontact9);
|
|
##$t_c = threads->create(\&_fetch_preferences_worker,$delay,'id','desc',$custcontact9);
|
|
#$prefs_a = $t_a->join();
|
|
#$prefs_b = $t_b->join();
|
|
##$prefs_c = $t_c->join();
|
|
#$t2 = time;
|
|
#is($prefs_a->{total_count},2*3,"check total count of thread a results");
|
|
##is($prefs_b->{total_count},2*3,"check total count of thread b results");
|
|
#is($prefs_b->{total_count},scalar (grep { $customer_map{$_->{customer_id}}->{contact_id} == $custcontact9->{id} } values %subscriber_map),"check total count of thread b results");
|
|
#$got_asc = $prefs_a->{_embedded}->{'ngcp:subscriberpreferences'};
|
|
#$got_desc = $prefs_b->{_embedded}->{'ngcp:subscriberpreferences'};
|
|
#if (!is_deeply($got_desc,[ reverse @{ $got_asc } ],'compare subscriber preference collection results of threaded requests deeply')) {
|
|
# diag(Dumper({asc => $got_asc, desc => $got_desc}));
|
|
#}
|
|
#ok($t2 - $t1 > 2*$delay,'expected delay to assume subscriberpreferences requests were processed after another');
|
|
#ok($t2 - $t1 < 3*$delay,'expected delay to assume only required contracts were locked');
|
|
#for (my $i = 0; $i < 2*3; $i++) {
|
|
# is($got_desc->[$i]->{lock},4,"check if subscriber is locked now");
|
|
#}
|
|
|
|
$t1 = time;
|
|
$t_a = threads->create(\&_fetch_preferences_worker,$delay,'id','asc',$custcontact1);
|
|
$t_b = threads->create(\&_fetch_preferences_worker,$delay,'id','desc',$custcontact2);
|
|
#$t_c = threads->create(\&_fetch_preferences_worker,$delay,'id','desc',$custcontact4);
|
|
$prefs_a = $t_a->join();
|
|
$prefs_b = $t_b->join();
|
|
#$prefs_c = $t_c->join();
|
|
$t2 = time;
|
|
|
|
is($prefs_a->{total_count},2*3,"check total count of thread a results");
|
|
is($prefs_b->{total_count},2*3,"check total count of thread b results");
|
|
#is($prefs_b->{total_count},scalar (grep { $customer_map{$_->{customer_id}}->{contact_id} == $custcontact9->{id} } values %subscriber_map),"check total count of thread b results");
|
|
#is($prefs_c->{total_count},2*3,"check total count of thread c results");
|
|
$got_asc = $prefs_a->{_embedded}->{'ngcp:subscriberpreferences'};
|
|
for (my $i = 0; $i < 2*3; $i++) {
|
|
is($got_asc->[$i]->{lock},4,"check if subscriber is locked now");
|
|
}
|
|
|
|
ok($t2 - $t1 < $delta_serialized,'expected delay to assume only required contracts were locked and requests were performed in parallel') if !$disable_parallel_catchup;
|
|
|
|
$t1 = time;
|
|
$t_a = threads->create(\&_fetch_preferences_worker,$delay,'id','asc',$custcontact2);
|
|
sleep($delay/2.0);
|
|
my $last_customer_id = shift(@{[sort {$b <=> $a} keys %customer_map]});
|
|
_check_interval_history($customer_map{$last_customer_id},[
|
|
{ start => '2015-05-17 00:00:00', stop => '2015-06-16 23:59:59', cash => 0.01, package_id => $package->{id}, profile => $billingprofile->{id} },
|
|
{ start => '2015-06-17 00:00:00', stop => '2015-07-16 23:59:59', cash => 0, package_id => $package->{id}, profile => $billingprofile->{id} },
|
|
]);
|
|
$t2 = time;
|
|
$t_a->join();
|
|
|
|
ok($t2 - $t1 >= $delay,'expected delay to assume subscriberpreferences request locks contracts and an simultaneous access to contract id ' . $last_customer_id . ' is serialized');
|
|
|
|
_set_time();
|
|
|
|
} else {
|
|
diag('allow_delay_commit not set, skipping ...');
|
|
}
|
|
|
|
if (_get_allow_delay_commit()) {
|
|
my $custcontact1 = _create_customer_contact();
|
|
my $custcontact2 = _create_customer_contact();
|
|
my $package = _create_profile_package('create','month',1,initial_balance => 1, carry_over_mode => 'discard', underrun_lock_threshold => 1, underrun_lock_level => 4);
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-05-17 13:00:00'));
|
|
_create_customers_threaded(3,2,$package,$custcontact1);
|
|
_create_customers_threaded(3,2,$package,$custcontact2);
|
|
|
|
my $t1 = time;
|
|
my $delay = 5.0; #15.0; #10.0; #2.0;
|
|
my $t_a = threads->create(\&_fetch_subscribers_worker,$delay,'id','asc',$custcontact2);
|
|
my $t_b = threads->create(\&_fetch_subscribers_worker,$delay,'id','desc',$custcontact2);
|
|
#my $t_c = threads->create(\&_fetch_subscribers_worker,$delay,'id','desc',$custcontact9);
|
|
my $subs_a = $t_a->join();
|
|
my $subs_b = $t_b->join();
|
|
#my $subs_c = $t_c->join();
|
|
my $t2 = time;
|
|
is($subs_a->{total_count},2*3,"check total count of thread a results");
|
|
is($subs_b->{total_count},2*3,"check total count of thread b results");
|
|
#is($subs_c->{total_count},scalar (grep { $customer_map{$_->{customer_id}}->{contact_id} == $custcontact9->{id} } values %subscriber_map),"check total count of thread c results");
|
|
my $got_asc = $subs_a->{_embedded}->{'ngcp:subscribers'};
|
|
my $got_desc = $subs_b->{_embedded}->{'ngcp:subscribers'};
|
|
if (!is_deeply($got_desc,[ reverse @{ $got_asc } ],'compare subscriber collection results of threaded requests deeply')) {
|
|
diag(Dumper({asc => $got_asc, desc => $got_desc}));
|
|
}
|
|
my $delta_serialized = $t2 - $t1;
|
|
ok($delta_serialized >= 2*$delay,'expected delay to assume subscribers requests were processed after another');
|
|
#ok($t2 - $t1 < 3*$delay,'expected delay to assume only required contracts were locked');
|
|
for (my $i = 0; $i < 2*3; $i++) {
|
|
is($got_desc->[$i]->{lock},undef,"check if subscriber is unlocked initially");
|
|
}
|
|
|
|
_set_time(NGCP::Panel::Utils::DateTime::from_string('2015-06-18 13:00:00'));
|
|
|
|
#$t1 = time;
|
|
#
|
|
#$t_a = threads->create(\&_fetch_subscribers_worker,$delay,'id','asc',$custcontact5);
|
|
#$t_b = threads->create(\&_fetch_subscribers_worker,$delay,'id','desc',$custcontact9);
|
|
##$t_c = threads->create(\&_fetch_subscribers_worker,$delay,'id','desc',$custcontact9);
|
|
#$subs_a = $t_a->join();
|
|
#$subs_b = $t_b->join();
|
|
##$subs_c = $t_c->join();
|
|
#$t2 = time;
|
|
#is($subs_a->{total_count},2*3,"check total count of thread a results");
|
|
#is($subs_b->{total_count},2*3,"check total count of thread b results");
|
|
#is($subs_c->{total_count},scalar (grep { $customer_map{$_->{customer_id}}->{contact_id} == $custcontact9->{id} } values %subscriber_map),"check total count of thread c results");
|
|
#$got_asc = $subs_a->{_embedded}->{'ngcp:subscribers'};
|
|
#$got_desc = $subs_b->{_embedded}->{'ngcp:subscribers'};
|
|
#if (!is_deeply($got_desc,[ reverse @{ $got_asc } ],'compare subscriber collection results of threaded requests deeply')) {
|
|
# diag(Dumper({asc => $got_asc, desc => $got_desc}));
|
|
#}
|
|
#ok($t2 - $t1 > 2*$delay,'expected delay to assume subscribers requests were processed after another');
|
|
#ok($t2 - $t1 < 3*$delay,'expected delay to assume only required contracts were locked');
|
|
#for (my $i = 0; $i < 2*3; $i++) {
|
|
# is($got_desc->[$i]->{lock},4,"check if subscriber is locked now");
|
|
#}
|
|
|
|
$t1 = time;
|
|
$t_a = threads->create(\&_fetch_subscribers_worker,$delay,'id','asc',$custcontact1);
|
|
$t_b = threads->create(\&_fetch_subscribers_worker,$delay,'id','desc',$custcontact2);
|
|
#$t_c = threads->create(\&_fetch_subscribers_worker,$delay,'id','desc',$custcontact5);
|
|
$subs_a = $t_a->join();
|
|
$subs_b = $t_b->join();
|
|
#$subs_c = $t_c->join();
|
|
$t2 = time;
|
|
|
|
is($subs_a->{total_count},2*3,"check total count of thread a results");
|
|
is($subs_b->{total_count},2*3,"check total count of thread b results");
|
|
#is($subs_b->{total_count},scalar (grep { $customer_map{$_->{customer_id}}->{contact_id} == $custcontact9->{id} } values %subscriber_map),"check total count of thread b results");
|
|
#is($subs_c->{total_count},2*3,"check total count of thread c results");
|
|
$got_asc = $subs_a->{_embedded}->{'ngcp:subscribers'};
|
|
for (my $i = 0; $i < 2*3; $i++) {
|
|
is($got_asc->[$i]->{lock},4,"check if subscriber is locked now");
|
|
}
|
|
ok($t2 - $t1 < $delta_serialized,'expected delay to assume only required contracts were locked and requests were performed in parallel') if !$disable_parallel_catchup;
|
|
|
|
$t1 = time;
|
|
$t_a = threads->create(\&_fetch_subscribers_worker,$delay,'id','asc',$custcontact2);
|
|
sleep($delay/2.0);
|
|
my $last_customer_id = shift(@{[sort {$b <=> $a} keys %customer_map]});
|
|
_check_interval_history($customer_map{$last_customer_id},[
|
|
{ start => '2015-05-17 00:00:00', stop => '2015-06-16 23:59:59', cash => 0.01, package_id => $package->{id}, profile => $billingprofile->{id} },
|
|
{ start => '2015-06-17 00:00:00', stop => '2015-07-16 23:59:59', cash => 0, package_id => $package->{id}, profile => $billingprofile->{id} },
|
|
]);
|
|
$t2 = time;
|
|
$t_a->join();
|
|
|
|
ok($t2 - $t1 >= $delay,'expected delay to assume subscribers request locks contracts and an simultaneous access to contract id ' . $last_customer_id . ' is serialized');
|
|
|
|
_set_time();
|
|
|
|
} else {
|
|
diag('allow_delay_commit not set, skipping ...');
|
|
}
|
|
|
|
} else {
|
|
diag('allow_fake_client_time not set, skipping ...');
|
|
}
|
|
|
|
for my $custcontact (values %$customer_contact_map) { #$default_custcontact,$custcontact2,$custcontact3,$custcontact4,$custcontact9) {
|
|
{ #test balanceintervals root collection and item
|
|
_create_customers_threaded(3,undef,undef,$custcontact); # unless _get_allow_fake_client_time() && $enable_profile_packages;
|
|
|
|
my $total_count = scalar grep { $_->{contact_id} == $custcontact->{id} } values %customer_map; #(scalar keys %customer_map);
|
|
my $nexturi = $uri.'/api/balanceintervals/?page=1&rows=' . ((not defined $total_count or $total_count <= 2) ? 2 : $total_count - 1) . '&contact_id='.$custcontact->{id};
|
|
do {
|
|
$req = HTTP::Request->new('GET',$nexturi);
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
#$res = $ua->get($nexturi);
|
|
is($res->code, 200, "balanceintervals root collection: fetch balance intervals collection page");
|
|
my $collection = JSON::from_json($res->decoded_content);
|
|
my $selfuri = $uri . $collection->{_links}->{self}->{href};
|
|
is($selfuri, $nexturi, "balanceintervals root collection: check _links.self.href of collection");
|
|
my $colluri = URI->new($selfuri);
|
|
|
|
ok(defined $total_count ? ($collection->{total_count} == $total_count) : ($collection->{total_count} > 0), "balanceintervals root collection: check 'total_count' of collection");
|
|
|
|
my %q = $colluri->query_form;
|
|
ok(exists $q{page} && exists $q{rows}, "balanceintervals root collection: 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}, "balanceintervals root collection: check absence of 'prev' on first page");
|
|
} else {
|
|
ok(exists $collection->{_links}->{prev}->{href}, "balanceintervals root collection: check existence of 'prev'");
|
|
}
|
|
if(($collection->{total_count} / $rows) <= $page) {
|
|
ok(!exists $collection->{_links}->{next}->{href}, "balanceintervals root collection: check absence of 'next' on last page");
|
|
} else {
|
|
ok(exists $collection->{_links}->{next}->{href}, "balanceintervals root collection: 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:balanceintervals'} eq "ARRAY", "balanceintervals root collection: check if 'ngcp:balanceintervals' is array");
|
|
|
|
my $page_items = {};
|
|
|
|
foreach my $interval_link (@{ $collection->{_links}->{'ngcp:balanceintervals'} }) {
|
|
#delete $customers{$c->{href}};
|
|
#ok(exists $journals->{$journal->{href}},"check page journal item link");
|
|
|
|
$req = HTTP::Request->new('GET',$uri . $interval_link->{href});
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "balanceintervals root collection: fetch page balance interval item");
|
|
my $interval = JSON::from_json($res->decoded_content);
|
|
|
|
$page_items->{$interval->{id}} = $interval;
|
|
}
|
|
foreach my $interval (@{ $collection->{_embedded}->{'ngcp:balanceintervals'} }) {
|
|
ok(exists $page_items->{$interval->{id}},"balanceintervals root collection: check existence of linked item among embedded");
|
|
my $fetched = delete $page_items->{$interval->{id}};
|
|
delete $fetched->{content};
|
|
is_deeply($interval,$fetched,"balanceintervals root collection: compare fetched and embedded item deeply");
|
|
}
|
|
ok((scalar keys %{ $page_items }) == 0,"balanceintervals root collection: check if all embedded items are linked");
|
|
|
|
} while($nexturi);
|
|
|
|
}
|
|
}
|
|
|
|
done_testing;
|
|
|
|
sub _check_interval_history {
|
|
|
|
my ($customer,$expected_interval_history,$limit_dt,$record_label) = @_;
|
|
my $total_count = (scalar @$expected_interval_history);
|
|
#my @got_interval_history = ();
|
|
my $i = 0;
|
|
my $limit = '';
|
|
my $ok = 1;
|
|
my @intervals;
|
|
$limit = '&start=' . DateTime::Format::ISO8601->parse_datetime($limit_dt) if defined $limit_dt;
|
|
my @requests = ();
|
|
my $last_request;
|
|
$last_request = _req_to_debug($req) if $req;
|
|
my $label = 'interval history of contract with ' . ($customer->{profile_package_id} ? 'package ' . $package_map->{$customer->{profile_package_id}}->{name} : 'no package') . ': ';
|
|
my $nexturi = $uri.'/api/balanceintervals/'.$customer->{id}.'/?page=1&rows=10&order_by_direction=asc&order_by=start'.$limit;
|
|
do {
|
|
$req = HTTP::Request->new('GET',$nexturi);
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
#$res = $ua->get($nexturi);
|
|
is($res->code, 200, $label . "fetch balance intervals collection page");
|
|
push(@requests,_req_to_debug($req));
|
|
my $collection = JSON::from_json($res->decoded_content);
|
|
my $selfuri = $uri . $collection->{_links}->{self}->{href};
|
|
#is($selfuri, $nexturi, $label . "check _links.self.href of collection");
|
|
my $colluri = URI->new($selfuri);
|
|
|
|
$ok = ok($collection->{total_count} == $total_count, $label . "check 'total_count' of collection") && $ok;
|
|
|
|
my %q = $colluri->query_form;
|
|
ok(exists $q{page} && exists $q{rows}, $label . "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}, $label . "check absence of 'prev' on first page");
|
|
} else {
|
|
ok(exists $collection->{_links}->{prev}->{href}, $label . "check existence of 'prev'");
|
|
}
|
|
if(($collection->{total_count} / $rows) <= $page) {
|
|
ok(!exists $collection->{_links}->{next}->{href}, $label . "check absence of 'next' on last page");
|
|
} else {
|
|
ok(exists $collection->{_links}->{next}->{href}, $label . "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:balanceintervals'} eq "ARRAY", $label . "check if 'ngcp:balanceintervals' is array");
|
|
|
|
my $page_items = {};
|
|
|
|
#foreach my $interval_link (@{ $collection->{_links}->{'ngcp:balanceintervals'} }) {
|
|
# #delete $customers{$c->{href}};
|
|
# #ok(exists $journals->{$journal->{href}},"check page journal item link");
|
|
#
|
|
# $req = HTTP::Request->new('GET',$uri . $interval_link->{href});
|
|
# $req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
# $req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
# $res = $ua->request($req);
|
|
# is($res->code, 200, $label . "fetch page balance interval item");
|
|
# my $interval = JSON::from_json($res->decoded_content);
|
|
#
|
|
# $page_items->{$interval->{id}} = $interval;
|
|
#}
|
|
foreach my $interval (@{ $collection->{_embedded}->{'ngcp:balanceintervals'} }) {
|
|
#ok(exists $page_items->{$interval->{id}},$label . "check existence of linked item among embedded");
|
|
#my $fetched = delete $page_items->{$interval->{id}};
|
|
#delete $fetched->{content};
|
|
#is_deeply($interval,$fetched,$label . "compare fetched and embedded item deeply");
|
|
$ok = _compare_interval($interval,$expected_interval_history->[$i],$label) && $ok;
|
|
delete $interval->{'_links'};
|
|
push(@intervals,$interval);
|
|
$i++
|
|
}
|
|
#ok((scalar keys $page_items) == 0,$label . "check if all embedded items are linked");
|
|
|
|
_record_request("view contract balances" . ($record_label ? ' of ' . $record_label : ''),$req,undef,$collection);
|
|
|
|
} while($nexturi);
|
|
|
|
ok($i == $total_count,$label . "check if all expected items are listed");
|
|
_create_gantt($customer,$expected_interval_history);
|
|
diag(Dumper({last_request => $last_request, collection_requests => \@requests, result_intervals => \@intervals})) if !$ok;
|
|
|
|
}
|
|
|
|
sub _compare_interval {
|
|
my ($got,$expected,$label) = @_;
|
|
|
|
my $ok = 1;
|
|
if ($expected->{start}) {
|
|
#is(NGCP::Panel::Utils::DateTime::from_string($got->{start}),NGCP::Panel::Utils::DateTime::from_string($expected->{start}),$label . "check interval " . $got->{id} . " start timestmp");
|
|
if (substr($expected->{start},0,1) eq '~') {
|
|
$ok = _is_ts_approx($got->{start},$expected->{start},$label . "check interval " . $got->{id} . " start timestamp") && $ok;
|
|
} else {
|
|
$ok = is($got->{start},$expected->{start},$label . "check interval " . $got->{id} . " start timestmp") && $ok;
|
|
}
|
|
}
|
|
if ($expected->{stop}) {
|
|
#is(NGCP::Panel::Utils::DateTime::from_string($got->{stop}),NGCP::Panel::Utils::DateTime::from_string($expected->{stop}),$label . "check interval " . $got->{id} . " stop timestmp");
|
|
if (substr($expected->{stop},0,1) eq '~') {
|
|
$ok = _is_ts_approx($got->{stop},$expected->{stop},$label . "check interval " . $got->{id} . " stop timestamp") && $ok;
|
|
} else {
|
|
$ok = is($got->{stop},$expected->{stop},$label . "check interval " . $got->{id} . " stop timestmp") && $ok;
|
|
}
|
|
}
|
|
|
|
if ($expected->{cash}) {
|
|
$ok = is($got->{cash_balance},$expected->{cash},$label . "check interval " . $got->{id} . " cash balance") && $ok;
|
|
}
|
|
|
|
if ($expected->{profile}) {
|
|
$ok = is($got->{billing_profile_id},$expected->{profile},$label . "check interval " . $got->{id} . " billing profile") && $ok;
|
|
}
|
|
|
|
if ($expected->{topups}) {
|
|
$ok = is($got->{topup_count},$expected->{topups},$label . "check interval " . $got->{id} . " topup count") && $ok;
|
|
}
|
|
|
|
if ($expected->{timely_topups}) {
|
|
$ok = is($got->{timely_topup_count},$expected->{timely_topups},$label . "check interval " . $got->{id} . " timely topup count") && $ok;
|
|
}
|
|
|
|
return $ok;
|
|
|
|
}
|
|
|
|
sub _is_ts_approx {
|
|
my ($got,$expected,$label) = @_;
|
|
$got = NGCP::Panel::Utils::DateTime::from_string($got);
|
|
$expected = NGCP::Panel::Utils::DateTime::from_string(substr($expected,1));
|
|
my $epsilon = 10;
|
|
my $lower = $expected->clone->subtract(seconds => $epsilon);
|
|
my $upper = $expected->clone->add(seconds => $epsilon);
|
|
return ok($got >= $lower && $got <= $upper,$label . ' approximately (' . $got . ')');
|
|
}
|
|
|
|
sub _fetch_intervals_worker {
|
|
my ($delay,$sort_column,$dir,$custcontact) = @_;
|
|
diag("starting thread " . threads->tid() . " ...");
|
|
$req = HTTP::Request->new('GET', $uri.'/api/balanceintervals/?order_by='.$sort_column.'&order_by_direction='.$dir.'&contact_id='.$custcontact->{id}.'&rows='.(scalar keys %customer_map));
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$req->header('X-Delay-Commit' => $delay);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "thread " . threads->tid() . ": concurrent fetch balanceintervals of contracts of contact id ".$custcontact->{id} . " in " . $dir . " order");
|
|
my $result = JSON::from_json($res->decoded_content);
|
|
#is($result->{total_count},(scalar keys %customer_map),"check total count");
|
|
diag("finishing thread " . threads->tid() . " ...");
|
|
return $result;
|
|
}
|
|
|
|
sub _fetch_customerbalances_worker {
|
|
my ($delay,$sort_column,$dir,$custcontact) = @_;
|
|
diag("starting thread " . threads->tid() . " ...");
|
|
$req = HTTP::Request->new('GET', $uri.'/api/customerbalances/?order_by='.$sort_column.'&order_by_direction='.$dir.'&contact_id='.$custcontact->{id}.'&rows='.(scalar keys %customer_map));
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$req->header('X-Delay-Commit' => $delay);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "thread " . threads->tid() . ": concurrent fetch customerbalances of contracts of contact id ".$custcontact->{id} . " in " . $dir . " order");
|
|
my $result = JSON::from_json($res->decoded_content);
|
|
#is($result->{total_count},(scalar keys %customer_map),"check total count");
|
|
diag("finishing thread " . threads->tid() . " ...");
|
|
return $result;
|
|
}
|
|
|
|
sub _create_customers_threaded {
|
|
my ($number_of_customers,$subscribers_per_customer,$package,$custcontact) = @_;
|
|
my $t0 = time;
|
|
my @t_cs = ();
|
|
#my $number_of_customers = 3;
|
|
for (1..$number_of_customers) {
|
|
my $t_c;
|
|
$t_c = threads->create(sub {
|
|
my $customer = _create_customer($package,undef,$custcontact);
|
|
if (defined $subscribers_per_customer && $subscribers_per_customer > 0) {
|
|
for (1..$subscribers_per_customer) {
|
|
_create_subscriber($customer);
|
|
}
|
|
}
|
|
});
|
|
push(@t_cs,$t_c);
|
|
}
|
|
foreach my $t_c (@t_cs) {
|
|
$t_c->join();
|
|
}
|
|
my $t1 = time;
|
|
diag('average time to create a customer: ' . ($t1 - $t0)/$number_of_customers);
|
|
}
|
|
|
|
sub _create_customer_contact {
|
|
|
|
my $n = (scalar keys %$customer_contact_map);
|
|
$req = HTTP::Request->new('POST', $uri.'/api/customercontacts/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$req->content(JSON::to_json({
|
|
firstname => "cust_contact_".$n."_first",
|
|
lastname => "cust_contact_".$n."_last",
|
|
email => "cust_contact".$n."\@custcontact.invalid",
|
|
reseller_id => $default_reseller_id,
|
|
}));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "create customer contact $n");
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch customer contact $n");
|
|
my $custcontact = JSON::from_json($res->decoded_content);
|
|
$customer_contact_map->{$custcontact->{id}} = $custcontact;
|
|
return $custcontact;
|
|
|
|
}
|
|
|
|
sub _create_customer {
|
|
|
|
my ($package,$record_label,$custcontact) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/customers/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
my $req_data = {
|
|
status => "active",
|
|
contact_id => (defined $custcontact ? $custcontact->{id} : $default_custcontact->{id}),
|
|
type => "sipaccount",
|
|
($package ? (billing_profile_definition => 'package',
|
|
profile_package_id => $package->{id}) :
|
|
(billing_profile_id => $billingprofile->{id})),
|
|
max_subscribers => undef,
|
|
external_id => undef,
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
my $label = 'test customer ' . ($package ? 'with package ' . $package->{name} : 'w/o profile package');
|
|
is($res->code, 201, "create " . $label);
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch " . $label);
|
|
my $customer = JSON::from_json($res->decoded_content);
|
|
$customer_map{$customer->{id}} = threads::shared::shared_clone($customer);
|
|
_record_request("create customer" . ($record_label ? ' ' . $record_label : ''),$request,$req_data,$customer);
|
|
return $customer;
|
|
|
|
}
|
|
|
|
sub _get_customer {
|
|
my $customer = shift;
|
|
$req = HTTP::Request->new('GET', $uri.'/api/customers/'.$customer->{id});
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch customer id " . $customer->{id});
|
|
$customer = JSON::from_json($res->decoded_content);
|
|
$customer_map{$customer->{id}} = threads::shared::shared_clone($customer);
|
|
return $customer;
|
|
}
|
|
|
|
sub _switch_package {
|
|
|
|
my ($customer,$package) = @_;
|
|
$req = HTTP::Request->new('PATCH', $uri.'/api/customers/'.$customer->{id});
|
|
$req->header('Prefer' => 'return=representation');
|
|
$req->header('Content-Type' => 'application/json-patch+json');
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
|
|
$req->content(JSON::to_json(
|
|
[ { op => 'replace', path => '/profile_package_id', value => ($package ? $package->{id} : undef) } ]
|
|
));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "patch customer from " . ($customer->{profile_package_id} ? 'package ' . $package_map->{$customer->{profile_package_id}}->{name} : 'no package') . " to " .
|
|
($package ? $package->{name} : 'no package'));
|
|
$customer = JSON::from_json($res->decoded_content);
|
|
$customer_map{$customer->{id}} = threads::shared::shared_clone($customer);
|
|
return $customer;
|
|
|
|
}
|
|
|
|
sub _set_time {
|
|
my ($o) = @_;
|
|
my $dtf = DateTime::Format::Strptime->new(
|
|
pattern => '%F %T',
|
|
);
|
|
if (defined $o) {
|
|
NGCP::Panel::Utils::DateTime::set_fake_time($o);
|
|
my $now = NGCP::Panel::Utils::DateTime::current_local;
|
|
diag("applying fake time offset '$o' - current time: " . $dtf->format_datetime($now));
|
|
} else {
|
|
NGCP::Panel::Utils::DateTime::set_fake_time();
|
|
my $now = NGCP::Panel::Utils::DateTime::current_local;
|
|
diag("resetting fake time - current time: " . $dtf->format_datetime($now));
|
|
}
|
|
}
|
|
|
|
sub _get_fake_clienttime_now {
|
|
#return NGCP::Panel::Utils::DateTime::to_rfc1123_string(NGCP::Panel::Utils::DateTime::current_local);
|
|
#with rfc1123 there could be a problem if jenkins runner and test host will not have the same (language) locale
|
|
return NGCP::Panel::Utils::DateTime::to_string(NGCP::Panel::Utils::DateTime::current_local);
|
|
}
|
|
|
|
sub _create_profile_package {
|
|
|
|
my ($start_mode,$interval_unit,$interval_value,@further_opts) = @_; #$notopup_discard_intervals
|
|
$req = HTTP::Request->new('POST', $uri.'/api/profilepackages/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
my $name = $start_mode . ($interval_unit ? '/' . $interval_value . ' ' . $interval_unit : '');
|
|
$req->content(JSON::to_json({
|
|
name => "test '" . $name . "' profile package " . (scalar keys %$package_map) . '_' . $t,
|
|
#description => "test prof package descr " . (scalar keys %$package_map) . '_' . $t,
|
|
description => $start_mode . "/" . $interval_value . " " . $interval_unit . "s",
|
|
reseller_id => $default_reseller_id,
|
|
initial_profiles => [{ profile_id => $billingprofile->{id}, }, ],
|
|
balance_interval_start_mode => $start_mode,
|
|
($interval_unit ? (balance_interval_value => $interval_value,
|
|
balance_interval_unit => $interval_unit,) : ()),
|
|
#notopup_discard_intervals => $notopup_discard_intervals,
|
|
@further_opts,
|
|
}));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test profilepackage - '" . $name . "'");
|
|
my $profilepackage_uri = $uri.'/'.$res->header('Location');
|
|
$req = HTTP::Request->new('GET', $profilepackage_uri);
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed profilepackage - '" . $name . "'");
|
|
my $package = JSON::from_json($res->decoded_content);
|
|
$package_map->{$package->{id}} = $package;
|
|
return $package;
|
|
|
|
}
|
|
|
|
sub _create_billing_network_x {
|
|
|
|
$req = HTTP::Request->new('POST', $uri.'/api/billingnetworks/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
my $req_data = {
|
|
name => "test billing network X ".$t,
|
|
description => "billing network X descr ".$t,
|
|
reseller_id => $default_reseller_id,
|
|
blocks => [{ip=>'fdfe::5a55:caff:fefa:9089',mask=>128},
|
|
{ip=>'fdfe::5a55:caff:fefa:908a'},
|
|
{ip=>'fdfe::5a55:caff:fefa:908b',mask=>128},],
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test billingnetwork X");
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed billingnetwork X");
|
|
my $network = JSON::from_json($res->decoded_content);
|
|
_record_request("create billing network X",$request,$req_data,$network);
|
|
return $network;
|
|
}
|
|
|
|
sub _create_billing_network_y {
|
|
|
|
$req = HTTP::Request->new('POST', $uri.'/api/billingnetworks/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
my $req_data = {
|
|
name => "test billing network Y ".$t,
|
|
description => "billing network Y descr ".$t,
|
|
reseller_id => $default_reseller_id,
|
|
blocks => [{ip=>'10.0.4.7',mask=>26}, #0..63
|
|
{ip=>'10.0.4.99',mask=>26}, #64..127
|
|
{ip=>'10.0.5.9',mask=>24},
|
|
{ip=>'10.0.6.9',mask=>24},],
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test billingnetwork Y");
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed billingnetwork Y");
|
|
my $network = JSON::from_json($res->decoded_content);
|
|
_record_request("create billing network Y",$request,$req_data,$network);
|
|
return $network;
|
|
}
|
|
|
|
sub _create_base_profile_package {
|
|
|
|
my ($profile_base_any,$profile_base_x,$profile_base_b,$network_x,$network_b) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/profilepackages/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
my $req_data = {
|
|
name => "base profile package " . $t,
|
|
description => "base prof package descr " . $t,
|
|
reseller_id => $default_reseller_id,
|
|
initial_profiles => [{ profile_id => $profile_base_any->{id}, },
|
|
{ profile_id => $profile_base_x->{id}, network_id => $network_x->{id} },
|
|
{ profile_id => $profile_base_b->{id}, network_id => $network_b->{id} }],
|
|
balance_interval_start_mode => 'topup_interval',
|
|
balance_interval_value => 1,
|
|
balance_interval_unit => 'month',
|
|
carry_over_mode => 'carry_over_timely',
|
|
timely_duration_value => 1,
|
|
timely_duration_unit => 'month',
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test base profilepackage");
|
|
my $profilepackage_uri = $uri.'/'.$res->header('Location');
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $profilepackage_uri);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed base profilepackage");
|
|
my $package = JSON::from_json($res->decoded_content);
|
|
$package_map->{$package->{id}} = $package;
|
|
_record_request("create BASE profile package",$request,$req_data,$package);
|
|
return $package;
|
|
|
|
}
|
|
|
|
sub _create_silver_profile_package {
|
|
|
|
my ($base_package,$profile_silver_x,$profile_silver_y,$network_x,$network_y) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/profilepackages/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
my $req_data = {
|
|
name => "silver profile package " . $t,
|
|
description => "silver prof package descr " . $t,
|
|
reseller_id => $default_reseller_id,
|
|
initial_profiles => $base_package->{initial_profiles},
|
|
balance_interval_start_mode => 'topup_interval',
|
|
balance_interval_value => 1,
|
|
balance_interval_unit => 'month',
|
|
carry_over_mode => 'carry_over_timely',
|
|
timely_duration_value => 1,
|
|
timely_duration_unit => 'month',
|
|
|
|
service_charge => 200,
|
|
topup_profiles => [ #{ profile_id => $profile_silver_any->{id}, },
|
|
{ profile_id => $profile_silver_x->{id}, network_id => $network_x->{id} } ,
|
|
{ profile_id => $profile_silver_y->{id}, network_id => $network_y->{id} } ],
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test silver profilepackage");
|
|
my $profilepackage_uri = $uri.'/'.$res->header('Location');
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $profilepackage_uri);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed silver profilepackage");
|
|
my $package = JSON::from_json($res->decoded_content);
|
|
$package_map->{$package->{id}} = $package;
|
|
_record_request("create SILVER profile package",$request,$req_data,$package);
|
|
return $package;
|
|
|
|
}
|
|
|
|
sub _create_extension_profile_package {
|
|
|
|
my ($base_package,$profile_silver_x,$profile_silver_y,$network_x,$network_y) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/profilepackages/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
my $req_data = {
|
|
name => "extension profile package " . $t,
|
|
description => "extension prof package descr " . $t,
|
|
reseller_id => $default_reseller_id,
|
|
initial_profiles => $base_package->{initial_profiles},
|
|
balance_interval_start_mode => 'topup_interval',
|
|
balance_interval_value => 1,
|
|
balance_interval_unit => 'month',
|
|
carry_over_mode => 'carry_over_timely',
|
|
timely_duration_value => 1,
|
|
timely_duration_unit => 'month',
|
|
|
|
service_charge => 200,
|
|
topup_profiles => [ #{ profile_id => $profile_silver_any->{id}, },
|
|
{ profile_id => $profile_silver_x->{id}, network_id => $network_x->{id} } ,
|
|
{ profile_id => $profile_silver_y->{id}, network_id => $network_y->{id} } ],
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test extension profilepackage");
|
|
my $profilepackage_uri = $uri.'/'.$res->header('Location');
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $profilepackage_uri);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed extension profilepackage");
|
|
my $package = JSON::from_json($res->decoded_content);
|
|
$package_map->{$package->{id}} = $package;
|
|
_record_request("create EXTENSION profile package",$request,$req_data,$package);
|
|
return $package;
|
|
|
|
}
|
|
|
|
sub _create_gold_profile_package {
|
|
|
|
my ($base_package,$profile_gold_x,$profile_gold_y,$network_x,$network_y) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/profilepackages/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
my $req_data = {
|
|
name => "gold profile package " . $t,
|
|
description => "gold prof package descr " . $t,
|
|
reseller_id => $default_reseller_id,
|
|
initial_profiles => $base_package->{initial_profiles},
|
|
balance_interval_start_mode => 'topup_interval',
|
|
balance_interval_value => 1,
|
|
balance_interval_unit => 'month',
|
|
carry_over_mode => 'carry_over',
|
|
#timely_duration_value => 1,
|
|
#timely_duration_unit => 'month',
|
|
|
|
service_charge => 500,
|
|
topup_profiles => [ #{ profile_id => $profile_gold_any->{id}, },
|
|
{ profile_id => $profile_gold_x->{id}, network_id => $network_x->{id} } ,
|
|
{ profile_id => $profile_gold_y->{id}, network_id => $network_y->{id} } ],
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test gold profilepackage");
|
|
my $profilepackage_uri = $uri.'/'.$res->header('Location');
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $profilepackage_uri);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed gold profilepackage");
|
|
my $package = JSON::from_json($res->decoded_content);
|
|
$package_map->{$package->{id}} = $package;
|
|
_record_request("create GOLD profile package",$request,$req_data,$package);
|
|
return $package;
|
|
|
|
}
|
|
|
|
sub _create_voucher {
|
|
|
|
my ($amount,$code,$customer,$package,$valid_until_dt) = @_;
|
|
my $dtf = DateTime::Format::Strptime->new(
|
|
pattern => '%F %T',
|
|
);
|
|
$req = HTTP::Request->new('POST', $uri.'/api/vouchers/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
my $req_data = {
|
|
amount => $amount * 100.0,
|
|
code => $code,
|
|
customer_id => ($customer ? $customer->{id} : undef),
|
|
package_id => ($package ? $package->{id} : undef),
|
|
reseller_id => $default_reseller_id,
|
|
valid_until => $dtf->format_datetime($valid_until_dt ? $valid_until_dt : NGCP::Panel::Utils::DateTime::current_local->add(years => 1)),
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
my $label = 'test voucher (' . ($customer ? 'for customer ' . $customer->{id} : 'no customer') . ', ' . ($package ? 'for package ' . $package->{id} : 'no package') . ')';
|
|
is($res->code, 201, "create " . $label);
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch " . $label);
|
|
my $voucher = JSON::from_json($res->decoded_content);
|
|
$voucher_map->{$voucher->{id}} = $voucher;
|
|
_record_request("create $amount € voucher (code $code)",$request,$req_data,$voucher);
|
|
return $voucher;
|
|
|
|
}
|
|
|
|
sub _create_subscriber {
|
|
my ($customer,$record_label) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/subscribers/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
{
|
|
lock %subscriber_map;
|
|
my $req_data = {
|
|
domain_id => $domain->{id},
|
|
username => 'cust_subscriber_' . (scalar keys %subscriber_map) . '_'.$t,
|
|
password => 'cust_subscriber_password',
|
|
customer_id => $customer->{id},
|
|
#status => "active",
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test subscriber");
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed test subscriber");
|
|
my $subscriber = JSON::from_json($res->decoded_content);
|
|
$subscriber->{_label} = 'subscriber' . ($record_label ? ' ' . $record_label : '');
|
|
$subscriber_map{$subscriber->{id}} = threads::shared::shared_clone($subscriber);
|
|
_record_request("create " . $subscriber->{_label},$request,$req_data,$subscriber);
|
|
return $subscriber;
|
|
}
|
|
}
|
|
|
|
sub _perform_topup_voucher {
|
|
|
|
my ($subscriber,$voucher) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/topupvouchers/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
my $req_data = {
|
|
code => $voucher->{code},
|
|
subscriber_id => $subscriber->{id},
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 204, "perform topup with voucher " . $voucher->{code});
|
|
_record_request("topup by " . $subscriber_map{$subscriber->{id}}->{_label} . " using " . $voucher->{amount} / 100.0 . " € voucher (code $voucher->{code})",$req,$req_data,undef);
|
|
|
|
}
|
|
|
|
sub _perform_topup_cash {
|
|
|
|
my ($subscriber,$amount,$package) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/topupcash/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
my $req_data = {
|
|
amount => $amount * 100.0,
|
|
package_id => ($package ? $package->{id} : undef),
|
|
subscriber_id => $subscriber->{id},
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 204, "perform topup with amount " . $amount * 100.0 . " cents, " . ($package ? 'package id ' . $package->{id} : 'no package'));
|
|
_record_request("topup by " . $subscriber_map{$subscriber->{id}}->{_label} . " with " . $amount / 100.0 . " €, " . ($package ? 'package id ' . $package->{id} : 'no package'),$req,$req_data,undef);
|
|
|
|
}
|
|
|
|
sub _create_billing_profile {
|
|
my ($name,@further_opts) = @_;
|
|
$req = HTTP::Request->new('POST', $uri.'/api/billingprofiles/');
|
|
$req->header('Content-Type' => 'application/json');
|
|
$req->header('Prefer' => 'return=representation');
|
|
my $req_data = {
|
|
name => $name." $t",
|
|
handle => $name."_$t",
|
|
reseller_id => $default_reseller_id,
|
|
@further_opts,
|
|
};
|
|
$req->content(JSON::to_json($req_data));
|
|
$res = $ua->request($req);
|
|
is($res->code, 201, "POST test billing profile " . $name);
|
|
my $request = $req;
|
|
$req = HTTP::Request->new('GET', $uri.'/'.$res->header('Location'));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch POSTed billing profile " . $name);
|
|
my $billingprofile = JSON::from_json($res->decoded_content);
|
|
$profile_map->{$billingprofile->{id}} = $billingprofile;
|
|
_record_request("create billing profile '$name'",$request,$req_data,$billingprofile);
|
|
return $billingprofile;
|
|
}
|
|
|
|
sub _get_subscriber_lock_level {
|
|
my ($subscriber) = @_;
|
|
$req = HTTP::Request->new('GET', $uri.'/api/subscriberpreferences/'.$subscriber->{id});
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch subscriber id " . $subscriber->{id} . " preferences");
|
|
my $preferences = JSON::from_json($res->decoded_content);
|
|
return $preferences->{lock};
|
|
}
|
|
|
|
sub _get_actual_billing_profile_id {
|
|
my ($customer) = @_;
|
|
$req = HTTP::Request->new('GET', $uri.'/api/customers/'.$customer->{id});
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "fetch customer id " . $customer->{id});
|
|
my $contract = JSON::from_json($res->decoded_content);
|
|
return $contract->{billing_profile_id};
|
|
}
|
|
|
|
sub _fetch_preferences_worker {
|
|
my ($delay,$sort_column,$dir,$custcontact) = @_;
|
|
diag("starting thread " . threads->tid() . " ...");
|
|
$req = HTTP::Request->new('GET', $uri.'/api/subscriberpreferences/?order_by='.$sort_column.'&order_by_direction='.$dir.'&contact_id='.$custcontact->{id}.'&rows='.(scalar keys %subscriber_map));
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$req->header('X-Delay-Commit' => $delay);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "thread " . threads->tid() . ": concurrent fetch subscriber preferences of contracts of contact id ".$custcontact->{id} . " in " . $dir . " order");
|
|
my $result = JSON::from_json($res->decoded_content);
|
|
#is($result->{total_count},(scalar keys %subscriber_map),"check total count");
|
|
diag("finishing thread " . threads->tid() . " ...");
|
|
return $result;
|
|
}
|
|
|
|
sub _fetch_subscribers_worker {
|
|
my ($delay,$sort_column,$dir,$custcontact) = @_;
|
|
diag("starting thread " . threads->tid() . " ...");
|
|
$req = HTTP::Request->new('GET', $uri.'/api/subscribers/?order_by='.$sort_column.'&order_by_direction='.$dir.'&contact_id='.$custcontact->{id}.'&rows='.(scalar keys %subscriber_map));
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
$req->header('X-Delay-Commit' => $delay);
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "thread " . threads->tid() . ": concurrent fetch subscribers of contracts of contact id ".$custcontact->{id} . " in " . $dir . " order");
|
|
my $result = JSON::from_json($res->decoded_content);
|
|
#is($result->{total_count},(scalar keys %subscriber_map),"check total count");
|
|
diag("finishing thread " . threads->tid() . " ...");
|
|
return $result;
|
|
}
|
|
|
|
sub _record_request {
|
|
my ($label,$request,$req_data,$res_data) = @_;
|
|
if ($tb) {
|
|
my $dtf = DateTime::Format::Strptime->new(
|
|
pattern => '%F %T',
|
|
);
|
|
$tb->add(wrap('',"\t",$tb_cnt . ".\t" . $label . ":"),'');
|
|
my $http_cmd = $request->method . " " . $request->uri;
|
|
$http_cmd =~ s/\?/?\n/;
|
|
$tb->add($http_cmd,' ... at ' . $dtf->format_datetime(NGCP::Panel::Utils::DateTime::current_local));
|
|
$tb->add("Request","Response");
|
|
if ($res_data) {
|
|
$res_data = Storable::dclone($res_data);
|
|
delete $res_data->{"_links"};
|
|
$tb->add($req_data ? to_pretty_json($req_data) : '', to_pretty_json($res_data));
|
|
} else {
|
|
$tb->add($req_data ? to_pretty_json($req_data) : '', '');
|
|
}
|
|
$tb_cnt++;
|
|
};
|
|
}
|
|
|
|
sub _set_cash_balance {
|
|
|
|
my ($customer,$new_cash_balance) = @_;
|
|
$req = HTTP::Request->new('PATCH', $uri.'/api/customerbalances/' . $customer->{id});
|
|
$req->header('Prefer' => 'return=representation');
|
|
$req->header('Content-Type' => 'application/json-patch+json');
|
|
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
|
|
$req->header('X-Request-Identifier' => $req_identifier) if $req_identifier;
|
|
|
|
$req->content(JSON::to_json(
|
|
[ { op => 'replace', path => '/cash_balance', value => $new_cash_balance } ]
|
|
));
|
|
$res = $ua->request($req);
|
|
is($res->code, 200, "setting customer id " . $customer->{id} . " cash_balance to " . $new_cash_balance * 100.0 . ' cents');
|
|
|
|
}
|
|
|
|
sub _start_recording {
|
|
$tb = Text::Table->new("request", "response");
|
|
$tb_cnt = 1;
|
|
}
|
|
|
|
sub _stop_recording {
|
|
my $output = '';
|
|
if ($tb) {
|
|
$output = $tb->stringify;
|
|
}
|
|
undef $tb;
|
|
undef $tb_cnt;
|
|
return $output;
|
|
}
|
|
|
|
sub to_pretty_json {
|
|
return JSON::to_json(shift, {pretty => 1}); # =~ s/(^\s*{\s*)|(\s*}\s*$)//rg =~ s/\n /\n/rg;
|
|
}
|
|
|
|
sub _req_to_debug {
|
|
my $request = shift;
|
|
return { request => $request->method . " " . $request->uri,
|
|
headers => $request->headers };
|
|
}
|
|
|
|
sub _get_allow_delay_commit {
|
|
my $allow_delay_commit = 0;
|
|
my $cfg = $config{api_debug_opts};
|
|
$allow_delay_commit = ((defined $cfg->{allow_delay_commit}) && $cfg->{allow_delay_commit} ? 1 : 0) if defined $cfg;
|
|
return $allow_delay_commit;
|
|
}
|
|
|
|
sub _get_allow_fake_client_time {
|
|
my $allow_fake_client_time = 0;
|
|
my $cfg = $config{api_debug_opts};
|
|
$allow_fake_client_time = ((defined $cfg->{allow_fake_client_time}) && $cfg->{allow_fake_client_time} ? 1 : 0) if defined $cfg;
|
|
return $allow_fake_client_time;
|
|
}
|
|
|
|
#sub _create_gantt_old {
|
|
# my ($customer,$expected_interval_history) = @_;
|
|
#
|
|
# if (defined $gantt_events && (scalar @$gantt_events > 0)) {
|
|
#
|
|
# use Project::Gantt;
|
|
# use Project::Gantt::Skin;
|
|
#
|
|
# my $skin= new Project::Gantt::Skin(
|
|
# doTitle => 0);
|
|
#
|
|
# my $filename = $req_identifier;
|
|
# $filename =~ s/[^a-z0-9_\-]/_/i;
|
|
# $filename = '/home/rkrenn/test/gantt/' . $filename . '.png';
|
|
# my $gantt = new Project::Gantt(
|
|
# file => $filename,
|
|
# skin => $skin,
|
|
# mode => 'months',
|
|
# description => $req_identifier);
|
|
#
|
|
# my $dtf = DateTime::Format::Strptime->new(
|
|
# pattern => '%F %T',
|
|
# );
|
|
# foreach my $balance_interval (@$expected_interval_history) {
|
|
# my $start = $balance_interval->{start};
|
|
# $start =~ s/~//;
|
|
# my $end = $balance_interval->{stop};
|
|
# if ('9999-12-31 23:59:59' eq $end) {
|
|
# $end = $dtf->format_datetime(NGCP::Panel::Utils::DateTime::from_string($start)->add(years => 1));
|
|
# } else {
|
|
# $end =~ s/~//;
|
|
# }
|
|
# my @packages = ();
|
|
# if ('ARRAY' eq ref $balance_interval->{package_id}) {
|
|
# foreach my $package_id (@{$balance_interval->{package_id}}) {
|
|
# if (defined $package_id) {
|
|
# push(@packages,$package_map->{$package_id}->{description});
|
|
# } else {
|
|
# push(@packages,"no package");
|
|
# }
|
|
# }
|
|
# } else {
|
|
# if (defined $balance_interval->{package_id}) {
|
|
# push(@packages,$package_map->{$balance_interval->{package_id}}->{description});
|
|
# } else {
|
|
# push(@packages,"no package");
|
|
# }
|
|
# }
|
|
# my $resource = $gantt->addResource(name => $packages[$#packages]);
|
|
# $gantt->addTask(
|
|
# #description => $package->{name},
|
|
# description => join(', ',@packages),
|
|
# resource => $resource,
|
|
# start => $start,
|
|
# end => $end);
|
|
# }
|
|
# my $event_count = 1;
|
|
# foreach my $event (@$gantt_events) {
|
|
# my $resource = $gantt->addResource(name => 'event ' . $event_count);
|
|
# $gantt->addTask(
|
|
# #description => $package->{name},
|
|
# description => $event->{name},
|
|
# resource => $resource,
|
|
# start => $event->{t},
|
|
# end => $dtf->format_datetime(NGCP::Panel::Utils::DateTime::from_string($event->{t})->add(seconds => 1)),
|
|
# );
|
|
# $event_count++;
|
|
# }
|
|
# $gantt->display();
|
|
# return 1;
|
|
# }
|
|
# return 0;
|
|
#
|
|
#}
|
|
|
|
sub _create_gantt {
|
|
|
|
my ($customer,$expected_interval_history) = @_;
|
|
|
|
#uncomment and adjust this, if you want to create gantt charts of
|
|
#contract_balances resulting from a test case. this is a only a
|
|
#proof-of-concept and requires to have ChartDirector library installed.
|
|
|
|
#use lib "/opt/ChartDirector/lib/";
|
|
#use perlchartdir;
|
|
#
|
|
#if (defined $gantt_events && (scalar @$gantt_events > 0)) {
|
|
#
|
|
# my $filename = $req_identifier;
|
|
# $filename =~ s/[^a-z0-9_\-]/_/i;
|
|
# $filename = '/home/rkrenn/test/gantt/' . $filename . '.png';
|
|
#
|
|
# my @startDate = ();
|
|
# my @endDate = ();
|
|
# my @labels = ();
|
|
# my @colors = ();
|
|
# my @taskNo = ();
|
|
#
|
|
# my $firstDate = undef;
|
|
# my $lastDate = undef;
|
|
#
|
|
# my $dtf = DateTime::Format::Strptime->new(
|
|
# pattern => '%F %T',
|
|
# );
|
|
#
|
|
# my $inf_end = 0;
|
|
# foreach my $balance_interval (@$expected_interval_history) {
|
|
# my $start = $balance_interval->{start};
|
|
# $start =~ s/~//;
|
|
# my $end = $balance_interval->{stop};
|
|
# if ('9999-12-31 23:59:59' eq $end) {
|
|
# $end = $dtf->format_datetime(NGCP::Panel::Utils::DateTime::from_string($start)->add(months => 1));
|
|
# $inf_end = 1;
|
|
# } else {
|
|
# $end =~ s/~//;
|
|
# }
|
|
# my @packages = ();
|
|
# if ('ARRAY' eq ref $balance_interval->{package_id}) {
|
|
# foreach my $package_id (@{$balance_interval->{package_id}}) {
|
|
# if (defined $package_id) {
|
|
# push(@packages,$package_map->{$package_id}->{description});
|
|
# } else {
|
|
# push(@packages,"no package");
|
|
# }
|
|
# }
|
|
# } else {
|
|
# if (defined $balance_interval->{package_id}) {
|
|
# push(@packages,$package_map->{$balance_interval->{package_id}}->{description});
|
|
# } else {
|
|
# push(@packages,"no package");
|
|
# }
|
|
# }
|
|
# push(@startDate,perlchartdir::chartTime(split(/[^0-9]+/, $start)));
|
|
# $firstDate = $start unless $firstDate;
|
|
# push(@endDate,perlchartdir::chartTime(split(/[^0-9]+/, $end)));
|
|
# $lastDate = $end;
|
|
# push(@labels,join(', ',@packages));
|
|
# push(@colors,0xa0a0a0);
|
|
# push(@taskNo,scalar @taskNo);
|
|
# }
|
|
#
|
|
# $firstDate = perlchartdir::chartTime(split(/[^0-9]+/,$dtf->format_datetime(NGCP::Panel::Utils::DateTime::from_string($firstDate)->subtract(days => 3)->truncate(to => 'day'))));
|
|
# $lastDate = perlchartdir::chartTime(split(/[^0-9]+/,($inf_end ? $lastDate : $dtf->format_datetime(NGCP::Panel::Utils::DateTime::from_string($lastDate)->add(days => 4)->truncate(to => 'day')))));
|
|
#
|
|
# # Create a XYChart object of size 620 x 280 pixels. Set background color to light blue (ccccff),
|
|
# # with 1 pixel 3D border effect.
|
|
# #my $c = new XYChart(700, 365, 0xccccff, 0x000000, 1);
|
|
# my $c = new XYChart(1300, 700, 0xccccff, 0x000000, 1);
|
|
#
|
|
# # Set the plotarea at (140, 55) and of size 460 x 200 pixels. Use alternative white/grey background.
|
|
# # Enable both horizontal and vertical grids by setting their colors to grey (c0c0c0). Set vertical
|
|
# # major grid (represents month boundaries) 2 pixels in width
|
|
# #$c->setPlotArea(180, 55, 500, 200, 0xffffff, 0xeeeeee, $perlchartdir::LineColor, 0xc0c0c0, 0xc0c0c0
|
|
# $c->setPlotArea(180, 55, 1000, 400, 0xffffff, 0xeeeeee, $perlchartdir::LineColor, 0xc0c0c0, 0xc0c0c0
|
|
# )->setGridWidth(2, 1, 1, 1);
|
|
#
|
|
# # swap the x and y axes to create a horziontal box-whisker chart
|
|
# $c->swapXY();
|
|
#
|
|
# # Set the y-axis scale to be date scale from Aug 16, 2004 to Nov 22, 2004, with ticks every 7 days
|
|
# # (1 week)
|
|
# $c->yAxis()->setDateScale($firstDate, $lastDate, 86400 * 7, 86400 * 1);
|
|
#
|
|
# # Set multi-style axis label formatting. Month labels are in Arial Bold font in "mmm d" format.
|
|
# # Weekly labels just show the day of month and use minor tick (by using '-' as first character of
|
|
# # format string).
|
|
# $c->yAxis()->setMultiFormat(perlchartdir::StartOfMonthFilter(), "<*font=arialbd.ttf*>{value|mmm d}",
|
|
# perlchartdir::StartOfDayFilter(), "-{value|d}");
|
|
#
|
|
# # Set the y-axis to shown on the top (right + swapXY = top)
|
|
# $c->setYAxisOnRight();
|
|
#
|
|
# # Set the labels on the x axis
|
|
# $c->xAxis()->setLabels(\@labels);
|
|
#
|
|
# # Reverse the x-axis scale so that it points downwards.
|
|
# $c->xAxis()->setReverse();
|
|
#
|
|
# # Set the horizontal ticks and grid lines to be between the bars
|
|
# $c->xAxis()->setTickOffset(0.5);
|
|
#
|
|
# # Add some symbols to the chart to represent milestones. The symbols are added using scatter layers.
|
|
# # We need to specify the task index, date, name, symbol shape, size and color.
|
|
# #$c->addScatterLayer([1], [perlchartdir::chartTime(2004, 9, 13)], "Milestone 1",
|
|
# # perlchartdir::Cross2Shape(), 13, 0xffff00);
|
|
# #$c->addScatterLayer([3], [perlchartdir::chartTime(2004, 10, 4)], "Milestone 2",
|
|
# # perlchartdir::StarShape(5), 15, 0xff00ff);
|
|
# #$c->addScatterLayer([5], [perlchartdir::chartTime(2004, 11, 8)], "Milestone 3",
|
|
# # $perlchartdir::TriangleSymbol, 13, 0xff9933);
|
|
# my $event_count = 0;
|
|
# my $title = '';
|
|
# foreach my $event (@$gantt_events) {
|
|
# $title = $event->{name};
|
|
# $title =~ s/customer \d+/customer/i;
|
|
# $c->addScatterLayer([$#taskNo], [perlchartdir::chartTime(split(/[^0-9]+/, $event->{t}))], $title,
|
|
# perlchartdir::Cross2Shape(), 13, 0xffff00) if $event_count % 3 == 0;
|
|
# $c->addScatterLayer([$#taskNo], [perlchartdir::chartTime(split(/[^0-9]+/, $event->{t}))], $title,
|
|
# perlchartdir::StarShape(5), 15, 0xff00ff) if $event_count % 3 == 1;
|
|
# $c->addScatterLayer([$#taskNo], [perlchartdir::chartTime(split(/[^0-9]+/, $event->{t}))], $title,
|
|
# $perlchartdir::TriangleSymbol, 13, 0xff9933) if $event_count % 3 == 2;
|
|
# $event_count++;
|
|
# }
|
|
#
|
|
# # Add a title to the chart using 15 points Times Bold Itatic font, with white (ffffff) text on a
|
|
# # deep blue (000080) background
|
|
# $c->addTitle($title, "timesbi.ttf", 15, 0xffffff)->setBackground(0x000080);
|
|
#
|
|
# # Add a multi-color box-whisker layer to represent the gantt bars
|
|
# my $layer = $c->addBoxWhiskerLayer2(\@startDate, \@endDate, undef, undef, undef, \@colors);
|
|
# $layer->setXData(\@taskNo);
|
|
# $layer->setBorderColor($perlchartdir::SameAsMainColor);
|
|
#
|
|
# # Divide the plot area height ( = 200 in this chart) by the number of tasks to get the height of
|
|
# # each slot. Use 80% of that as the bar height.
|
|
# #$layer->setDataWidth(int(200 * 4 / 5 / scalar(@labels)));
|
|
# $layer->setDataWidth(int(400 * 4 / 5 / scalar(@labels)));
|
|
#
|
|
# # Add a legend box at (140, 265) - bottom of the plot area. Use 8pt Arial Bold as the font with
|
|
# # auto-grid layout. Set the width to the same width as the plot area. Set the backgorund to grey
|
|
# # (dddddd).
|
|
# #my $legendBox = $c->addLegend2(180, 265, $perlchartdir::AutoGrid, "arialbd.ttf", 8);
|
|
# #my $legendBox = $c->addLegend2(180, 265, $perlchartdir::AutoGrid, "arialbd.ttf", 8);
|
|
# my $legendBox = $c->addLegend2(180, 465, $perlchartdir::AutoGrid, "arialbd.ttf", 8);
|
|
# $legendBox->setWidth(1001);
|
|
# $legendBox->setBackground(0xdddddd);
|
|
#
|
|
# # The keys for the scatter layers (milestone symbols) will automatically be added to the legend box.
|
|
# # We just need to add keys to show the meanings of the bar colors.
|
|
# $legendBox->addKey("Balance Intervals", 0xa0a0a0);
|
|
# #$legendBox->addKey("Planning Team", 0x0000cc);
|
|
# #$legendBox->addKey("Development Team", 0xcc0000);
|
|
#
|
|
# # Output the chart
|
|
# $c->makeChart($filename);
|
|
# return 1;
|
|
#}
|
|
return 0;
|
|
|
|
}
|