File Coverage

blib/lib/Database/Async/Engine.pm

Criterion	Covered	Total	%
statement	19	27	70.3
branch	1	6	16.6
condition			n/a
subroutine	6	9	66.6
pod	2	4	50.0
total	28	46	60.8

package Database::Async::Engine;

use strict;
use warnings;

our $VERSION = '0.016'; # VERSION

use parent qw(IO::Async::Notifier);

=head1 NAME

Database::Async::Engine - base class for database implementation support in L

=head1 DESCRIPTION

=cut

use URI;
use Scalar::Util;

our %ENGINE_MAP;

UNITCHECK { require Database::Async::Engine::Empty }

=head2 register_class

Class method which will register a package name for a given engine type.

=cut

sub register_class {
    my ($self, $name, $engine_class) = @_;
    die 'already have handler for ' . $name if exists $ENGINE_MAP{$name};
    $ENGINE_MAP{$name} = $engine_class;
    return;
}

sub uri { shift->{uri} }
sub db { shift->{db} }

sub configure {
    my ($self, %args) = @_;
    for (qw(uri)) {
        $self->{$_} = URI->new('' . delete($args{$_})) if exists $args{$_};
    }
    for (qw(db)) {
        Scalar::Util::weaken($self->{$_} = delete $args{$_}) if exists $args{$_};
    }
    $self->next::method(%args);
}

1;

=head1 AUTHOR

Tom Molesworth C<<  >>

=head1 LICENSE

Copyright Tom Molesworth 2011-2021. Licensed under the same terms as Perl itself.