File Coverage

blib/lib/Net/Async/MCP/Server/Transport/Stdio.pm

Criterion	Covered	Total	%
statement	15	41	36.5
branch	0	10	0.0
condition	0	3	0.0
subroutine	5	10	50.0
pod	4	4	100.0
total	24	68	35.2

package Net::Async::MCP::Server::Transport::Stdio;
# ABSTRACT: Stdio transport for Net::Async::MCP::Server

use strict;
use warnings;

use parent 'IO::Async::Notifier';

use Future::AsyncAwait;
use JSON::MaybeXS qw( encode_json decode_json );

our $VERSION = '0.001';


sub new {
    my ( $class, %params ) = @_;
    my $server = delete $params{server};
    my $self = $class->SUPER::new(%params);
    $self->{server} = $server if defined $server;
    return $self;
}

sub configure {
    my ( $self, %params ) = @_;
    if ( exists $params{server} ) {
        $self->{server} = delete $params{server};
    }
    $self->SUPER::configure(%params);
}


sub server {
    my ( $self ) = @_;
    return $self->{server};
}


sub handle_requests {
    my ( $self ) = @_;

    my $loop = $self->loop // IO::Async::Loop->new;

    while ( my $line =  ) {
        chomp $line;
        next unless length $line;

        my $request = eval { decode_json($line) };
        if ($@) {
            $self->_send_response({
                jsonrpc => '2.0',
                id      => undef,
                error   => { code => -32700, message => 'Parse error' },
            });
            next;
        }

        my $response = $self->server->handle($request);
        if ($response) {
            $self->_send_response($response);
        }
    }
}

sub _send_response {
    my ( $self, $response ) = @_;
    print STDOUT encode_json($response) . "\n";
}

1;

__END__