1 package Tak::MetaService;
4 use Log::Contextual qw(:log);
7 with 'Tak::Role::Service';
9 has router => (is => 'ro', required => 1, weak_ref => 1);
18 return "Already have ${name}" if $self->router->services->{$name};
19 $self->handle_register(@_);
23 my ($self, $name, $class, %args) = @_;
24 (my $file = $class) =~ s/::/\//g;
26 if (my $expose = delete $args{expose}) {
27 %args = (%args, %{$self->_construct_exposed_clients($expose)});
29 my $new = $class->new(\%args);
30 $self->router->register($name => $new);
31 return "Registered ${name}";
34 sub _construct_exposed_clients {
35 my ($self, $expose) = @_;
36 my $router = $self->router;
38 foreach my $name (keys %$expose) {
39 local $_ = $expose->{$name};
41 $client{$name} = Tak::Client->new(
42 service => Tak::Router->new(
43 services => $self->_construct_exposed_clients($_)
46 } elsif (ref eq 'ARRAY') {
47 if (my ($svc, @rest) = @$_) {
48 die "router has no service ${svc}"
49 unless my $service = $router->services->{$svc};
51 Scalar::Util::isweak($router->services->{$svc})
55 $client{$name} = $client_class->new(service => $service)
58 $client{$name} = Tak::WeakClient->new(service => $router);
61 die "expose key ${name} was ".ref;