4 use Tak::ServiceManager;
8 has channel => (is => 'ro', required => 1);
10 has local_request_handlers => (is => 'ro', default => sub { {} });
12 has requests_received => (is => 'ro', default => sub { {} });
14 has last_serial => (is => 'ro',default => sub { 'A0000' });
16 sub next_serial { ++($_[0]->{last_serial}) }
18 has requests_sent => (is => 'ro', default => sub { {} });
22 $self->register(meta => Tak::MetaService->new(router => $self));
25 sub run { shift->run_until }
28 my ($self, $done) = @_;
29 while (!$_[1] and my $message = $self->channel->receive) {
30 $self->receive(@$message);
35 my ($self, $type, @payload) = @_;
37 $self->channel->send(MISTAKE => message_format => "No message type");
41 $self->channel->send(MISTAKE => message_format => "Tag missing");
44 unless (@payload > 1) {
45 $self->channel->send(MISTAKE => message_format => "No payload");
47 if ($type eq 'REQUEST') {
48 $self->receive_request(@payload);
51 if ($type eq 'RESPONSE') {
52 $self->receive_response(@payload);
58 my ($self, $tag, $handler_name, @payload) = @_;
59 if ($self->requests_received->{$tag}) {
61 MISTAKE => request_tag => "Request for ${tag} in process"
65 my $handler = $self->local_request_handlers->{$handler_name};
68 $tag => MISTAKE => handler_name => "No such handler ${handler_name}"
73 = $self->requests_received->{$tag}
75 tag => $tag, respond_to => $self, respond_with => 'send_response',
77 $handler->start_request($request => @payload);
81 my ($self, $tag, @result) = @_;
82 delete $self->requests_received->{$tag};
83 $self->channel->send(RESPONSE => $tag => @result);
87 my ($self, $respond_to, $respond_with, @payload) = @_;
88 my $tag = $self->next_serial;
90 = $self->requests_sent->{$tag}
93 respond_to => $respond_to,
94 respond_with => $respond_with,
96 $self->channel->send(REQUEST => $tag => @payload);
100 sub receive_response {
101 my ($self, $tag, @result) = @_;
102 my $request = delete $self->requests_sent->{$tag};
103 $request->respond(@result);
107 my ($self, $name, $service) = @_;
108 $self->local_request_handlers->{$name} = Tak::ServiceManager->new(