File Coverage

blib/lib/CPAN/MirrorMerger.pm

Criterion	Covered	Total	%
statement	46	46	100.0
branch			n/a
condition	1	3	33.3
subroutine	17	17	100.0
pod	0	3	0.0
total	64	69	92.7

package CPAN::MirrorMerger;
use strict;
use warnings;

our $VERSION = "0.08";

use Class::Accessor::Lite ro => [qw/mirrors/];

use File::Spec;
use Path::Tiny ();

use CPAN::MirrorMerger::Agent;
use CPAN::MirrorMerger::Mirror;
use CPAN::MirrorMerger::MirrorCache;
use CPAN::MirrorMerger::RetryPolicy;
use CPAN::MirrorMerger::Logger::Null;
use CPAN::MirrorMerger::Algorithm::PreferLatestVersion;

our $DEFAULT_LOGGER = CPAN::MirrorMerger::Logger::Null->instance();
our $DEFAULT_RETRY_POLICY = CPAN::MirrorMerger::RetryPolicy->new(
    max_retries   => 5,
    interval      => 1,
    jitter_factor => 0.05,
);
our $DEFAULT_REQUEST_TIMEOUT = 30;
our $DEFAULT_MIRROR_CACHE_DIR = File::Spec->catdir(File::Spec->tmpdir(), 'CPAN-MirrorMerger');
our $DEFAULT_MIRROR_INDEX_CACHE_TIMEOUT = 300;

sub new {
    my ($class, %args) = @_;
    bless {
        mirrors => [],
    } => $class;
}

sub add_mirror {
    my ($self, $mirror_url) = @_;
    my $mirror = CPAN::MirrorMerger::Mirror->new($mirror_url);
    push @{ $self->{mirrors} } => $mirror;
}

sub merge {
    my ($self, $algorithm) = @_;
    $algorithm ||= _get_default_algorithm();

    return $algorithm->merge(@{ $self->mirrors });
}

sub _get_default_algorithm {
    return CPAN::MirrorMerger::Algorithm::PreferLatestVersion->new(
        mirror_cache => _get_default_mirror_cache(),
        logger       => $DEFAULT_LOGGER,
    );
}

sub _get_default_mirror_cache {
    return CPAN::MirrorMerger::MirrorCache->new(
        cache_dir           => $DEFAULT_MIRROR_CACHE_DIR,
        index_cache_timeout => $DEFAULT_MIRROR_INDEX_CACHE_TIMEOUT,
        agent               => _get_default_agent(),
        logger              => $DEFAULT_LOGGER,
    );
}

sub _get_default_agent {
    return CPAN::MirrorMerger::Agent->new(
        agent        => __PACKAGE__."/$VERSION",
        timeout      => $DEFAULT_REQUEST_TIMEOUT,
        logger       => $DEFAULT_LOGGER,
        retry_policy => $DEFAULT_RETRY_POLICY,
    );
}

1;
__END__