File Coverage

blib/lib/Tak/Router.pm

Criterion	Covered	Total	%
statement	12	34	35.2
branch	0	8	0.0
condition			n/a
subroutine	4	13	30.7
pod	0	7	0.0
total	16	62	25.8

package Tak::Router;

use Tak::MetaService;
use Scalar::Util qw(weaken);
use Log::Contextual qw(:log);
use Moo;

has services => (is => 'ro', default => sub { {} });

sub BUILD {
  my ($self) = @_;
  $self->register(meta => Tak::MetaService->new(router => $self));
}

sub start_request {
  my ($self, $req, $target, @payload) = @_;
  return $req->mistake("Reached router with no target")
    unless $target;
  return $req->failure("Reached router with invalid target ${target}")
    unless my $next = $self->services->{$target};
  $next->start_request($req, @payload);
}

sub receive {
  my ($self, $target, @payload) = @_;
  return unless $target;
  log_debug { "Message received for ${target}" };
  return log_info { "Discarded message to ${target}" }
    unless my $next = $self->services->{$target};
  $next->receive(@payload);
}

sub register {
  my ($self, $name, $service) = @_;
  $self->services->{$name} = $service;
}

sub register_weak {
  my ($self, $name, $service) = @_;
  weaken($self->services->{$name} = $service);
}

sub deregister {
  my ($self, $name) = @_;
  delete $self->services->{$name}
}

sub clone_or_self {
  my ($self) = @_;
  (ref $self)->new(services => { %{$self->services} });
}

1;