File Coverage

blib/lib/OpenSearch/Client.pm

Criterion	Covered	Total	%
statement	21	23	91.3
branch	1	2	50.0
condition	6	7	85.7
subroutine	4	4	100.0
pod	0	1	0.0
total	32	37	86.4

# OpenSearch::Client is an unofficial client for OpenSearch.
# It is derived from Search::Elasticsearch version 7.714
# License details from that work are contained in the NOTICE
# file distributed with this work.
#-----------------------------------------------------------------------
# OpenSearch::Client
#-----------------------------------------------------------------------
# Copyright 2026 Mark Dootson
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

package OpenSearch::Client;

use Moo 2.001000 ();

use OpenSearch::Client::Util qw(parse_params load_plugin);
use namespace::clean;

our $VERSION = '3.007002';

my %Default_Plugins = (
    client      => [ 'OpenSearch::Client::Core',         '3_0::Direct' ],
    cxn_factory => [ 'OpenSearch::Client::Cxn::Factory', '' ],
    cxn_pool    => [ 'OpenSearch::Client::CxnPool',      'Static' ],
    logger      => [ 'OpenSearch::Client::Logger',       'LogAny' ],
    serializer  => [ 'OpenSearch::Client::Serializer',   'JSON' ],
    transport   => [ 'OpenSearch::Client::Transport',    '' ],
);

my @Load_Order = qw(
    serializer
    logger
    cxn_factory
    cxn_pool
    transport
    client
);

#===================================
sub new {
#===================================
    my ( $class, $params ) = parse_params(@_);

    $params->{cxn} ||= 'HTTPTiny';
    my $plugins = delete $params->{plugins} || [];
    $plugins = [$plugins] unless ref $plugins eq 'ARRAY';

    for my $name (@Load_Order) {
        my ( $base, $default ) = @{ $Default_Plugins{$name} };
        my $sub_class = $params->{$name} || $default;
        my $plugin_class = load_plugin( $base, $sub_class );
        $params->{$name} = $plugin_class->new($params);
    }

    for my $name (@$plugins) {
        my $plugin_class
            = load_plugin( 'OpenSearch::Client::Plugin', $name );
        $plugin_class->_init_plugin($params);
    }

    return $params->{client};
}

1;

__END__