lib/Tak/MetaService.pm

   1 package Tak::MetaService;
   2
   3 use Tak::WeakClient;
   4 use Moo;
   5
   6 with 'Tak::Role::Service';
   7
   8 has router => (is => 'ro', required => 1, weak_ref => 1);
   9
  10 sub handle_pid {
  11   return $$;
  12 }
  13
  14 sub handle_register {
  15   my ($self, $name, $class, %args) = @_;
  16   (my $file = $class) =~ s/::/\//g;
  17   require "${file}.pm";
  18   if (my $expose = delete $args{expose}) {
  19     my $client = Tak::WeakClient->new(service => $self->router);
  20     foreach my $name (%$expose) {
  21       $args{$name} = $client->curry(@{$expose->{$name}});
  22     }
  23   }
  24   my $new = $class->new(\%args);
  25   $self->router->register($name => $new);
  26   return "Registered ${name}";
  27 }
  28
  29 1;