| line |
l |
!l |
condition |
|
494
|
0 |
0 |
$args{'required_pull_request_reviews'} //= undef |
|
495
|
0 |
0 |
$args{'restrictions'} //= undef |
|
496
|
0 |
0 |
$args{'restrictions'}{'users'} ||= [] |
|
497
|
0 |
0 |
$args{'restrictions'}{'teams'} ||= [] |
|
511
|
0 |
0 |
$args{'branch'} // die("need a branch") |
|
531
|
0 |
0 |
$args{'branch'} // die("need a branch") |
|
558
|
0 |
0 |
$args{'path'} // die("need a path") |
|
621
|
0 |
0 |
$args{'visibility'} // "all" |
|
629
|
0 |
0 |
$args{'visibility'} // "all" |
|
651
|
0 |
0 |
$args{'visibility'} // "all" |
|
948
|
0 |
0 |
+(shift())->{'timeout'} //= 60 |
|
982
|
0 |
0 |
+(shift())->{'mime_type'} //= "application/vnd.github.v3+json" |
|
1071
|
0 |
0 |
$src //= "" |
|
1075
|
0 |
0 |
$src // "unknown" |
|
1131
|
0 |
0 |
$src //= "" |
|
1135
|
0 |
0 |
$src // "unknown" |
|
1144
|
0 |
0 |
delete $args{'method'} || 'PUT' |
|
1194
|
0 |
0 |
$src //= "" |
|
1198
|
0 |
0 |
$src // "unknown" |
|
1260
|
0 |
0 |
$src //= "" |
|
1264
|
0 |
0 |
$src // "unknown" |
|
1297
|
0 |
0 |
delete $args{'per_page'} || 100 |
|
1450
|
0 |
0 |
+(shift())->{'page_cache_size'} //= 1000 |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
575
|
0 |
0 |
0 |
$args{'owner'} // $self->owner |
|
|
0 |
0 |
0 |
$args{'repo'} // $self->repo |
|
|
0 |
0 |
0 |
$args{'id'} // $self->number |
|
605
|
0 |
0 |
0 |
$args{'owner'} // $self->{'head'}{'repo'}{'owner'}{'login'} |
|
|
0 |
0 |
0 |
$args{'repo'} // $self->{'head'}{'repo'}{'name'} |
|
|
0 |
0 |
0 |
$args{'ref'} // $self->branch_name |
|
792
|
0 |
0 |
0 |
$self->{'core_rate_limit'} //= do {
my $rl = "Net::Async::Github::RateLimit::Core"->new("limit", "Ryu::Observable"->new(undef), "remaining", "Ryu::Observable"->new(undef), "reset", "Ryu::Observable"->new(undef));
retain_future($self->http_get("uri", $self->endpoint("rate_limit"))->on_done(sub {
my $data = shift();
$Net::Async::Github::log->tracef("Github rate limit response was %s", $data);
$rl->reset->set_numeric($data->{'resources'}{'core'}{'reset'});
$rl->limit->set_numeric($data->{'resources'}{'core'}{'limit'});
$rl->remaining->set_numeric($data->{'resources'}{'core'}{'remaining'});
}
));
$rl
} |
|
858
|
0 |
0 |
0 |
$self->{'endpoints'} ||= do {
my $path = Path::Tiny::path(&__DIR__())->parent(3)->child("share/endpoints.json");
$path = Path::Tiny::path(File::ShareDir::dist_file("Net-Async-Github", "endpoints.json")) unless $path->exists;
decode_json_text($path->slurp_utf8)
} |
|
897
|
0 |
0 |
0 |
$self->{'http'} ||= do {
require Net::Async::HTTP;
$self->add_child(my $ua = "Net::Async::HTTP"->new("fail_on_error", 1, "max_connections_per_host", $self->connections_per_host, "pipeline", 1, "max_in_flight", 4, "decode_content", 1, "user_agent", "Mozilla/4.0 (perl; Net::Async::Github; TEAM\@cpan.org)", $self->timeout ? ("timeout", $self->timeout) : ()));
$ua
} |
|
992
|
0 |
0 |
0 |
+(shift())->{'base_uri'} //= "URI"->new("https://api.github.com") |
|
1007
|
0 |
0 |
0 |
$args{'headers'}{$_} //= $hdr->{$_} |
|
1009
|
0 |
0 |
0 |
$args{$_} //= $auth{$_} |
|
1086
|
0 |
0 |
0 |
$args{'headers'}{$_} //= $hdr->{$_} |
|
1088
|
0 |
0 |
0 |
$args{$_} //= $auth{$_} |
|
1147
|
0 |
0 |
0 |
$args{'headers'}{$_} //= $hdr->{$_} |
|
1149
|
0 |
0 |
0 |
$args{$_} //= $auth{$_} |
|
1214
|
0 |
0 |
0 |
$args{'headers'}{$_} //= $hdr->{$_} |
|
1216
|
0 |
0 |
0 |
$args{$_} //= $auth{$_} |
|
1365
|
0 |
0 |
0 |
+(shift())->{'pending_requests'} //= do {
require Adapter::Async::OrderedList::Array;
"Adapter::Async::OrderedList::Array"->new
} |
|
1458
|
0 |
0 |
0 |
$_[0]{'page_cache'} //= do {
"Cache::LRU"->new("size", $_[0]->page_cache_size)
} |
|
1485
|
0 |
0 |
0 |
$self->{'ws'} // do {
require Net::Async::WebSocket::Client;
$self->add_child(my $ws = "Net::Async::WebSocket::Client"->new("on_frame", $self->curry::weak::on_frame));
builtin::weaken($self->{'ws'} = $ws);
$ws
} |