File Coverage

blib/lib/Plugins/Factory.pm

Criterion	Covered	Total	%
statement	21	40	52.5
branch	0	12	0.0
condition	0	6	0.0
subroutine	7	10	70.0
pod			n/a
total	28	68	41.1

package Plugins::Factory;

use strict;
use warnings;

our $VERSION = '0.01';

use Module::Load;
require Module::Pluggable;

# save all plugin and package
$Plugins::Factory::job_name = {};

# save all code ref
$Plugins::Factory::ref_code = {};

sub import {
    my ($class,%opts) = @_;
    my ($call_pkg) = caller;
    map {
        my $pl_name = $_;
        my $namespace = $opts{$pl_name}->{'plugin_namespace'} if exists $opts{$pl_name}->{'plugin_namespace'};
        next unless (ref $opts{$pl_name} eq 'HASH' and $namespace);
        my $method = $opts{$pl_name}->{'init_method'};

        Module::Pluggable->import(search_path => [$namespace]);
        foreach my $pkg (__PACKAGE__->plugins) {
            load $pkg;
            (my $short_name = $pkg) =~ s/^${namespace}:://;
            push @{$Plugins::Factory::job_name->{$call_pkg}->{$pl_name}},$pkg;
            $Plugins::Factory::ref_code->{$call_pkg}->{$pl_name}->{$short_name} =
            $Plugins::Factory::ref_code->{$call_pkg}->{$pl_name}->{$pkg} =
            ($method and $pkg->can($method)) ? sub {$pkg->$method(@_)} : sub {$pkg};
        }

        no strict 'refs';
        no warnings qw(redefine prototype);
        # add function in traget package
        *{"$call_pkg\::$pl_name"} = sub {
                                             my ($class,$name,@init) = @_;
                                             return $Plugins::Factory::job_name->{$call_pkg}->{$pl_name} unless $name;
                                             return $Plugins::Factory::ref_code->{$call_pkg}->{$pl_name}->{$name}->(@init) if exists $Plugins::Factory::ref_code->{$call_pkg}->{$pl_name}->{$name};
        } if exists $Plugins::Factory::ref_code->{$call_pkg}->{$pl_name};
        use strict 'refs';
        1;
    } keys %opts;

}


1;
__END__