File Coverage

blib/lib/Mojo/Events/Listeners.pm

Criterion	Covered	Total	%
statement	9	26	34.6
branch	0	8	0.0
condition	0	3	0.0
subroutine	3	6	50.0
pod	1	1	100.0
total	13	44	29.5

package Mojo::Events::Listeners;
use Mojo::Base -base;

use Mojo::Loader qw(find_modules load_class);
use Mojo::Server;

has app => sub { Mojo::Server->new->build_app('Mojo::HelloWorld') }, weak => 1;
has namespaces => sub { [] };

=head2 startup

Start listeners

=cut

sub startup {
    my ($self, $dispatcher) = @_;

    my @namespaces = @{ $self->namespaces };
    push(@namespaces, 'Mojo::Events::Listeners');

    for my $namespace (@namespaces) {
        for my $module (find_modules($namespace)) {
            my $loaded = _listener($module, 1);

            if (!$loaded) {
                warn "Could not load $module";

                next;
            }

            # Initialize listener
            my $listener = $loaded->new(app => $self->app);

            $dispatcher->on($listener->event => sub {
                my $self = shift;

                return $listener->handle(@_);
            });
        }
    }
}

=head2 _listener

Load listener

=cut

sub _listener {
    my ($module, $fatal) = @_;

    return $module->isa('Mojo::Events::Listener') ? $module : undef
        unless my $e = load_class $module;
    $fatal && ref $e ? die $e : return undef;
}

1;