sipwise
/
rate-o-mat
mirror of https://github.com/sipwise/rate-o-mat.git
1
0
Fork 0
Code Issues Releases Wiki Activity

MT#12061 negative call fees for callee testcase

Browse Source 
Change-Id: I532ce6d336d409853e3d235fda96deabc4b2a1fa
changes/06/3506/2
Rene Krenn 11 years ago
parent f9e2211f50
commit f65c54b5f6
2 changed files with 163 additions and 16 deletions
Show Stats Download Patch File Download Diff File

60
t/Utils/Api.pm
Unescape View File

@ -46,6 +46,7 @@ our @EXPORT_OK = qw(
setup_provider
setup_subscriber
setup_package
to_pretty_json
);
my ($netloc) = ($uri =~ m!^https?://(.*)/?.*$!);
@ -178,6 +179,17 @@ sub _get_entity_map {
return $entity_maps{$resource};
}
sub _ua_request {
my $req = shift;
my $res = $ua->request($req);
log_request($req,$res);
return $res;
}
sub log_request {
my ($req,$res) = @_;
}
sub _create_item {
my ($resource,@params) = @_;
my $map = _get_entity_map($resource);
@ -189,11 +201,11 @@ sub _create_item {
$req->content(JSON::to_json({
@params
}));
$res = $ua->request($req);
$res = _ua_request($req);
if (is($res->code, 201, "create $resource $n")) {
$req = HTTP::Request->new('GET', $uri.$res->header('Location'));
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
$res = $ua->request($req);
$res = _ua_request($req);
my $entity = JSON::from_json($res->decoded_content);
$map->{$entity->{id}} = $entity;
$resource_map{$entity->{_links}->{self}->{href}} = $resource;
@ -219,7 +231,7 @@ sub update_item {
$req->content(JSON::to_json(
[ map { { op => 'replace', path => '/'.$_ , value => $params{$_} }; } keys %params ]
));
$res = $ua->request($req);
$res = _ua_request($req);
if (is($res->code, 200, "patch $resource id ".$entity->{id})) {
$entity = JSON::from_json($res->decoded_content);
$map->{$entity->{id}} = $entity;
@ -349,7 +361,7 @@ sub set_cash_balance {
$req->content(JSON::to_json(
[ { op => 'replace', path => '/cash_balance', value => $new_cash_balance } ]
));
$res = $ua->request($req);
$res = _ua_request($req);
if (!is($res->code, 200, "setting customer id " . $customer->{id} . " cash_balance to " . $new_cash_balance * 100.0 . ' cents')) {
eval {
diag(JSON::from_json($res->decoded_content)->{message});
@ -362,7 +374,7 @@ sub get_subscriber_preferences {
my ($subscriber) = @_;
$req = HTTP::Request->new('GET', $uri.'/api/subscriberpreferences/'.$subscriber->{id});
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
$res = $ua->request($req);
$res = _ua_request($req);
if (is($res->code, 200, "fetch subscriber id " . $subscriber->{id} . " preferences")) {
return JSON::from_json($res->decoded_content);
} else {
@ -394,7 +406,7 @@ sub check_interval_history {
do {
$req = HTTP::Request->new('GET',$nexturi);
$req->header('X-Fake-Clienttime' => _get_fake_clienttime_now());
$res = $ua->request($req);
$res = _ua_request($req);
is($res->code, 200, $label . "fetch customer id " . $customer_id . " balance intervals collection page");
my $collection = JSON::from_json($res->decoded_content);
@ -490,7 +502,7 @@ sub perform_topup {
subscriber_id => $subscriber->{id},
};
$req->content(JSON::to_json($req_data));
$res = $ua->request($req);
$res = _ua_request($req);
if (!is($res->code, 204, "perform topup with amount " . $amount * 100.0 . " cents, " . ($package ? 'package id ' . $package->{id} : 'no package'))) {
eval {
diag(JSON::from_json($res->decoded_content)->{message});
@ -682,7 +694,8 @@ sub setup_provider {
my $profile_fee = {};
($profile_fee->{profile},
$profile_fee->{zone},
$profile_fee->{fee}) = _setup_customer_fees($provider->{reseller},
$profile_fee->{fee},
$profile_fee->{fees}) = _setup_customer_fees($provider->{reseller},
%$rate
);
push(@{$provider->{profiles}},$profile_fee);
@ -708,14 +721,29 @@ sub _setup_customer_fees {
my $zone = create_billing_zone(
billing_profile_id => $profile->{id},
);
my $fee = create_billing_fee(
billing_profile_id => $profile->{id},
billing_zone_id => $zone->{id},
direction => "out",
destination => ".",
%params,
);
return ($profile,$zone,$fee);
my @fees = ();
if (exists $params{fees}) {
foreach my $fee (@{ $params{fees} }) {
push(@fees,create_billing_fee(
billing_profile_id => $profile->{id},
billing_zone_id => $zone->{id},
%$fee,
));
}
} else {
push(@fees,create_billing_fee(
billing_profile_id => $profile->{id},
billing_zone_id => $zone->{id},
direction => "out",
destination => ".",
%params,
));
}
return ($profile,$zone,$fees[0],\@fees);
}
sub to_pretty_json {
return JSON::to_json(shift, {pretty => 1}); # =~ s/(^\s*{\s*)|(\s*}\s*$)//rg =~ s/\n /\n/rg;
}
1;

119
t/rateomat-negative-fees.t
Unescape View File

@ -0,0 +1,119 @@
use strict;
use Utils::Api qw();
use Utils::Rateomat qw();
use Test::More;
use Text::Table;
use Text::Wrap;
use Storable;
use DateTime::Format::Strptime;
my $tb = Text::Table->new("request", "response");
*Utils::Api::log_request = sub {
my ($req,$res) = @_;
if ($tb) {
my $dtf = DateTime::Format::Strptime->new(
pattern => '%F %T',
);
#$tb->add(wrap('',"\t",$tb_cnt . ".\t" . $label . ":"),'');
my $http_cmd = $req->method . " " . $req->uri;
$http_cmd =~ s/\?/?\n/;
$tb->add($http_cmd,' ... at ' . $dtf->format_datetime(Utils::Api::get_now()));
$tb->add("Request","Response");
my $req_data;
eval {
$req_data = JSON::from_json($req->decoded_content);
};
my $res_data;
eval {
$res_data = JSON::from_json($res->decoded_content);
};
if ($res_data) {
$res_data = Storable::dclone($res_data);
delete $res_data->{"_links"};
$tb->add($req_data ? Utils::Api::to_pretty_json($req_data) : '', Utils::Api::to_pretty_json($res_data));
} else {
$tb->add($req_data ? Utils::Api::to_pretty_json($req_data) : '', '');
}
#$tb_cnt++;
};
};
{
my $provider = create_provider();
my $profile = $provider->{profiles}->[0]->{profile};
my $balance = 5;
my $caller = Utils::Api::setup_subscriber($provider,$profile,$balance,{ cc => 888, ac => '1<n>', sn => '<t>' });
my $callee = Utils::Api::setup_subscriber($provider,$profile,$balance,{ cc => 888, ac => '2<n>', sn => '<t>' });
my $caller_costs = ($provider->{profiles}->[0]->{fees}->[0]->{onpeak_init_rate} *
$provider->{profiles}->[0]->{fees}->[0]->{onpeak_init_interval} +
$provider->{profiles}->[0]->{fees}->[0]->{onpeak_follow_rate} *
$provider->{profiles}->[0]->{fees}->[0]->{onpeak_follow_interval})/100.0;
my $callee_costs = ($provider->{profiles}->[0]->{fees}->[1]->{onpeak_init_rate} *
$provider->{profiles}->[0]->{fees}->[1]->{onpeak_init_interval} +
$provider->{profiles}->[0]->{fees}->[1]->{onpeak_follow_rate} *
$provider->{profiles}->[0]->{fees}->[1]->{onpeak_follow_interval})/100.0; #negative!
my $now = Utils::Api::get_now();
my @cdr_ids = map { $_->{id}; } @{ Utils::Rateomat::create_cdrs([
Utils::Rateomat::prepare_cdr($caller->{subscriber},undef,$caller->{reseller},
$callee->{subscriber},undef,$callee->{reseller},
'192.168.0.1',$now->epoch,61),
]) };
if (ok((scalar @cdr_ids) > 0 && Utils::Rateomat::run_rateomat(),'rate-o-mat executed')) {
ok(Utils::Rateomat::check_cdrs('',
map { $_ => { id => $_, rating_status => 'ok', }; } @cdr_ids
),'cdrs were all processed');
Utils::Api::check_interval_history('negative fees - caller',$caller->{customer}->{id},[
{ cash => $balance - $caller_costs,
profile => $provider->{profiles}->[0]->{profile}->{id} },
]);
Utils::Api::check_interval_history('negative fees - callee',$callee->{customer}->{id},[
{ cash => $balance - $callee_costs,
profile => $provider->{profiles}->[0]->{profile}->{id} },
]);
}
}
print $tb->stringify;
done_testing();
exit;
sub create_provider {
return Utils::Api::setup_provider('test<n>.com',
[ #rates:
{ fees => [
{ #regular:
direction => 'out',
destination => '.',
onpeak_init_rate => 2,
onpeak_init_interval => 60,
onpeak_follow_rate => 1,
onpeak_follow_interval => 30,
offpeak_init_rate => 2,
offpeak_init_interval => 60,
offpeak_follow_rate => 1,
offpeak_follow_interval => 30,
},
{ #negative:
direction => 'in',
destination => '.',
onpeak_init_rate => -1*2,
onpeak_init_interval => 60,
onpeak_follow_rate => -1*1,
onpeak_follow_interval => 30,
offpeak_init_rate => -1*2,
offpeak_init_interval => 60,
offpeak_follow_rate => -1*1,
offpeak_follow_interval => 30,
},
]},
],
[ #billing networks:
]
);
}
Write Preview
Loading…
Cancel
Save