File Coverage

blib/lib/Aion/Emitter.pm

Criterion	Covered	Total	%
statement	24	24	100.0
branch	3	4	75.0
condition	1	3	33.3
subroutine	6	6	100.0
pod	1	1	100.0
total	35	38	92.1

package Aion::Emitter;
# Диспетчер

use common::sense;

our $VERSION = "0.1.1";

use Aion::Pleroma;

use Aion;

my $event_isa = HashRef[ArrayRef[Dict[act => StrMatch[qr/^[\w:]+#\w+$/a], line => Option[Nat], nice => Option[Num], remark => Option[Str]]]];

use Aion::Env::Etc INI => (isa => Str, default => 'etc/annotation/listen.ann', key => 'aion.emitter.ini');
use Aion::Env::Etc EVENT => (isa => $event_isa, default => {}, key => 'aion.emitter.event');

# Путь к собранным из аннотаций методам
has ini => (is => 'ro', isa => Str, default => INI);

# Список слушателей
has event => (is => 'ro', isa => $event_isa, default => sub {
	my ($self) = @_;
	my %event = %{EVENT()};

	if(defined $self->ini and -e $self->ini) {
		open my $f, "<:encoding(UTF-8)", $self->ini or die "Not open ${\$self->ini}";
		while(<$f>) {
			do { close $f; die "${\$self->ini}:$. corrupt!" } unless /^([\w:]+)#(\w*),(\d+)=(?:(-?\d+(?:\.\d+)?)\s+)?([a-z][\w:]*(?:#[\w.:-]+)?)(?:\s+(.*?))??\s*$/ia;
			my ($pkg, $sub, $line, $nice, $evt, $remark) = ($1, $2, $3, $4, $5, $6);
			$sub //= 'listen';
			push @{$event{$evt}}, {
				act => "$pkg#$sub",
				line => $line,
				$nice? (nice => $nice): (),
				$remark ne ''? (remark => $remark): (),
			};
		}
		close $f;
	}

	for my $listens (values %event) {
		@$listens = sort { $a->{nice} <=> $b->{nice} or $a->{act} cmp $b->{act} } @$listens;
	}

	\%event
});

# Плерома
has pleroma => (is => 'ro', isa => 'Aion::Pleroma', eon => 1);

# Излучить
sub emit {
	my ($self, $event, $key) = @_;

	my $listeners = $self->event->{defined($key)? "${\ref $event}#$key": ref $event};
	return $self unless $listeners;

	for my $listener_bag (@$listeners) {
		my ($pkg, $sub) = split /#/, $listener_bag->{act}, 2;
		my $listener = $self->pleroma->get($pkg) // $self->pleroma->autoware($pkg)->resolve($pkg);
		$listener->$sub($event);
	}

	$self
}

1;

__END__