| line |
true |
false |
branch |
|
184
|
0 |
0 |
if ($$params{'index'}) { } |
|
185
|
0 |
0 |
if (my $ids = delete $$params{'ids'}) |
|
186
|
0 |
0 |
if $$params{'docs'} |
|
193
|
0 |
0 |
if $$params{'type'} |
|
196
|
0 |
0 |
if $$params{'ids'} |
|
212
|
0 |
0 |
unless @{$_[1]{'data'}{'docs'};} |
|
218
|
0 |
0 |
$filter ? : |
|
273
|
0 |
0 |
$_[2]{'id'} ? : |
|
382
|
0 |
0 |
if $$params{'type'} and not $$params{'index'} |
|
386
|
0 |
0 |
unless ${$_[1]{'data'};} |
|
421
|
0 |
0 |
unless ref $_[0] |
|
423
|
0 |
0 |
ref $_[0] eq 'ARRAY' ? : |
|
|
0 |
0 |
unless @_ > 1 |
|
429
|
0 |
0 |
if (ref $_[0] eq 'ARRAY') |
|
431
|
0 |
0 |
ref $_[0] ? : |
|
476
|
0 |
0 |
unless eval {
do {
foreach my $data (@$actions) {
die q['actions' must be an ARRAY ref of HASH refs] unless ref $data eq 'HASH';
my($action, $params) = %$data;
$action ||= '';
my $defn = $Bulk_Actions{$action} || die("Unknown action '${action}'");
my %metadata;
$params = {%$params};
delete @{$params;}{'_score', 'sort'};
$$params{'data'} ||= delete $$params{'_source'} if $$params{'_source'};
foreach my $key (keys %$defn) {
my $val = delete $$params{$key};
$val = delete $$params{"_$key"} unless defined $val;
unless (defined $val) {
next if $$defn{$key} == 2;
die "Missing required param '${key}' for action '${action}'";
} ;
$metadata{"_$key"} = $val;
} ;
die "Unknown params for bulk action '${action}': " . join(', ', keys %$params) if keys %$params;
my $data = delete $metadata{'_data'};
my $request = $json->encode({$action, \%metadata}) . "\n";
if ($data) {
$data = $json->encode($data) if ref $data eq 'HASH';
$request .= $data . "\n";
} ;
$json_docs .= $request;
} ;
1
}
} |
|
479
|
0 |
0 |
unless ref $data eq 'HASH' |
|
490
|
0 |
0 |
if $$params{'_source'} |
|
495
|
0 |
0 |
unless defined $val |
|
496
|
0 |
0 |
unless (defined $val) |
|
497
|
0 |
0 |
if $$defn{$key} == 2 |
|
502
|
0 |
0 |
if keys %$params |
|
508
|
0 |
0 |
if ($data) |
|
509
|
0 |
0 |
if ref $data eq 'HASH' |
|
518
|
0 |
0 |
if $error |
|
540
|
0 |
0 |
if (my $match = $$item{'matches'}) |
|
544
|
0 |
0 |
unless my $error = $$items[$i]{$action}{'error'} |
|
545
|
0 |
0 |
if ($on_conflict and $error =~ /
VersionConflictEngineException
| DocumentAlreadyExistsException
/x) { } |
|
|
0 |
0 |
elsif ($on_error) { } |
|
563
|
0 |
0 |
@errors ? : |
|
583
|
0 |
0 |
unless my $src = delete $$clause{$old} |
|
584
|
0 |
0 |
if $$clause{$new} |
|
587
|
0 |
0 |
$new eq 'query' ? : |
|
588
|
0 |
0 |
unless my $sub_clause = $builder->$method($src) |
|
601
|
0 |
0 |
unless my $facets = $$data{'facets'} |
|
602
|
0 |
0 |
unless ref $facets eq 'HASH' |
|
605
|
0 |
0 |
unless ref $_ eq 'HASH' |
|
623
|
0 |
0 |
if (my $query = delete $$args{'data'}{'query'}) |
|
633
|
0 |
0 |
unless my $warmers = $$args{'data'}{'warmers'} |
|
637
|
0 |
0 |
unless my $source = $$_{'source'} |
|
768
|
0 |
0 |
if (ref $queries eq 'HASH') |
|
789
|
0 |
0 |
$order ? : |
|
|
0 |
0 |
unless ${$$args{'data'};} |
|
793
|
0 |
0 |
unless $order |
|
822
|
0 |
0 |
unless eval {
do {
foreach my $query (@$queries) {
die "'queries' must contain HASH refs\n" unless ref $query eq 'HASH';
my(%request) = ('h', {}, 'b', {});
foreach $_ (keys %$query) {
die "Unknown param for msearch: $_\n" unless my $dest = $MSearch{$_};
$request{$dest}{$_} = $$query{$_};
} ;
foreach $_ ('index', 'type', 'stats', 'routing') {
$request{'h'}{$_} = join(',', @{$request{'h'}{$_};}) if ref $request{'h'}{$_} eq 'ARRAY';
} ;
$self->_data_fixup($request{'b'});
$json_docs .= $json->encode($request{'h'}) . "\n" . $json->encode($request{'b'}) . "\n";
} ;
1
}
} |
|
825
|
0 |
0 |
unless ref $query eq 'HASH' |
|
830
|
0 |
0 |
unless my $dest = $MSearch{$_} |
|
837
|
0 |
0 |
if ref $request{'h'}{$_} eq 'ARRAY' |
|
848
|
0 |
0 |
if $error |
|
871
|
0 |
0 |
if (defined $$args{'qs'}{'q'}) { } |
|
873
|
0 |
0 |
if %{$$args{'data'};} |
|
877
|
0 |
0 |
unless (eval {
do {
_query_fixup(@_);
1
}
}) |
|
878
|
0 |
0 |
if $@ =~ /Cannot specify queryb and query/ |
|
912
|
0 |
0 |
if (defined $$args{'qs'}{'q'}) { } |
|
914
|
0 |
0 |
if %{$$args{'data'};} |
|
967
|
0 |
0 |
unless %{$_[1]{'data'};} |
|
988
|
0 |
0 |
unless %{$_[1]{'data'};} |
|
1063
|
0 |
0 |
unless $$args{'data'}{'query'} |
|
1065
|
0 |
0 |
if $$args{'data'}{'data'}{'query'} |
|
1102
|
0 |
0 |
unless ref $result eq 'HASH' |
|
1270
|
0 |
0 |
if (defined $actions and ref $actions ne 'ARRAY') |
|
1342
|
0 |
0 |
unless defined $$params{'warmer'} and length $$params{'warmer'} |
|
1533
|
0 |
0 |
if not $$params{'mapping'} and grep {exists $$params{$_};} keys %{$defn{'deprecated'};} |
|
1658
|
0 |
0 |
unless my $type = $$params{'type'} |
|
1891
|
0 |
0 |
if $$params{'commands'} and ref $$params{'commands'} ne 'ARRAY' |
|
1914
|
0 |
0 |
if (@_) |
|
1915
|
0 |
0 |
if (shift()) { } |
|
1922
|
0 |
0 |
$$self{'_base_qs'}{'case'} ? : |
|
1929
|
0 |
0 |
if (@_) |
|
1930
|
0 |
0 |
if (shift()) { } |
|
1937
|
0 |
0 |
$$self{'_base_qs'}{'error_trace'} ? : |
|
1958
|
0 |
0 |
unless eval {
do {
$args{'cmd'} = $self->_build_cmd($params, @{$defn;}{'prefix', 'cmd', 'postfix'});
$args{'qs'} = $self->_build_qs($params, $$defn{'qs'});
$args{'data'} = $self->_build_data($params, @{$defn;}{'data', 'deprecated'});
if (my $fixup = $$defn{'fixup'}) {
&$fixup($self, \%args);
} ;
die 'Unknown parameters: ' . join(', ', keys %$params) . "\n" if keys %$params;
1
}
} |
|
1964
|
0 |
0 |
if (my $fixup = $$defn{'fixup'}) |
|
1967
|
0 |
0 |
if keys %$params |
|
1973
|
0 |
0 |
if ($error) |
|
1974
|
0 |
0 |
if ref $error |
|
1981
|
0 |
0 |
if (my $skip = $args{'skip'}) |
|
1995
|
0 |
0 |
unless $$defn{'cmd'} |
|
1998
|
0 |
0 |
$type == 2 ? : |
|
|
0 |
0 |
$type == 1 ? : |
|
2003
|
0 |
0 |
$type == 1 || $type == 6 ? : |
|
2011
|
0 |
0 |
if (my $data = $$defn{'data'}) |
|
2012
|
0 |
0 |
ref $_ ? : |
|
2025
|
0 |
0 |
if (my $qs = $$defn{'qs'}) |
|
2029
|
0 |
0 |
if ref $arg_format |
|
2031
|
0 |
0 |
if (length $arg_format > 45) |
|
2051
|
0 |
0 |
unless $$defn{$key} |
|
2054
|
0 |
0 |
unless exists $$params{$key} |
|
2056
|
0 |
0 |
unless my $formatter = $QS_Formatter{$format_name} |
|
2059
|
0 |
0 |
unless my $val = &$formatter($key, delete $$params{$key}, @args) |
|
2071
|
0 |
0 |
unless my $defn = shift() |
|
2073
|
0 |
0 |
if (my $deprecated = shift()) |
|
2079
|
0 |
0 |
unless defined $source |
|
2080
|
0 |
0 |
if (ref $source eq 'ARRAY') { } |
|
2083
|
0 |
0 |
unless defined $val |
|
2089
|
0 |
0 |
unless $data{$key} = delete $$params{$source} |
|
2103
|
0 |
0 |
unless $defn |
|
2109
|
0 |
0 |
exists $$params{$key} ? : |
|
2114
|
0 |
0 |
unless defined $val |
|
2116
|
0 |
0 |
if (ref $val eq 'ARRAY') |
|
2117
|
0 |
0 |
if $type <= 3 |
|
2121
|
0 |
0 |
unless (length $val) |
|
2122
|
0 |
0 |
if $type == 2 or $type == 5 |
|
2123
|
0 |
0 |
if $type == 1 or $type == 6 |