Set.pm

packageElasticSearchX::Model::Document::Set;
use strict;
use warnings;

use MetaCPAN::Model::Hacks;

no warnings 'redefine';

our%query_override;
my $_build_query = \&_build_query;
*_build_query = sub {
my$query = $_build_query->(@_);
%$query = ( %$query, %query_override );
return$query;
};

our%qs_override;
my $_build_qs = \&_build_qs;
*_build_qs = sub {
my$qs = $_build_qs->(@_);
%$qs = ( %$qs, %qs_override );
return$qs;
};

# ESXM normally tries to use search_type => scan, which is deprecated or
# removed in newer Elasticsearch versions. Sorting on _doc gives the same
# optimization.
my$delete = \&delete;
*delete = sub {
local%qs_override = ( search_type=>'query_then_fetch' );
local%query_override = ( sort=>'_doc' );
return$delete->(@_);
};

my$get = \&get;
*get = sub {
my ( $self, $args, $qs ) = @_;
if ( $self->es->api_version eq'2_0' ) {
goto &$get;
 }
my%qs = %{ $qs || {} };
if ( my$fields = $self->fields ) {
$qs{_source} = $fields;
local$self->{fields};
return$get->( $self, $args, \%qs );
 }
goto &$get;
};

# ESXM will try to inflate based on the index/type stored in the result. We
# are using aliases, and ESXM doesn't know about the actual index that the
# docs are stored in. Instead, allow it to use the configured index/type for
# this doc set.
my$inflate_result = \&inflate_result;
*inflate_result = sub {
my ( $self, $res ) = @_;
my$new_res = {%$res};
delete$new_res->{_index};
delete$new_res->{_type};
$self->$inflate_result($new_res);
};

1;