experiments/protocol-v3/repl.pl

#!/usr/bin/perl

use warnings;
use strict;

use Term::ReadLine;
use IO::Socket::INET;
use Storable qw();
use Data::Dump qw(dump);

my $retries = 0;
my $sock;

print STDERR "wait for server";

while ( $retries < 10 && ! $sock ) {
        $sock = IO::Socket::INET->new(
                PeerAddr => '127.0.0.1',
                PeerPort => 4444,
                Proto => 'tcp',
        );
        if ( ! $sock ) {
                $retries++;
                print STDERR ".";
                sleep 1
        }
}

die $! unless $sock;

print STDERR "connected after $retries retries\n";

Storable::fd_retrieve( $sock )->{ping} or die "no ping";

my $term = Term::ReadLine->new('Sack');
my $prompt = "sack> ";
my $OUT = $term->OUT || \*STDOUT;
while ( defined ($_ = $term->readline($prompt)) ) {
        if ( /\S/ ) {
                warn "# $_\n";
                Storable::store_fd( { repl => $_ }, $sock );
                warn "## ", dump( Storable::fd_retrieve( $sock ) );
                $term->addhistory($_);
        }
}
1	#!/usr/bin/perl
2
3	use warnings;
4	use strict;
5
6	use Term::ReadLine;
7	use IO::Socket::INET;
8	use Storable qw();
9	use Data::Dump qw(dump);
10
11	my $retries = 0;
12	my $sock;
13
14	print STDERR "wait for server";
15
16	while ( $retries < 10 && ! $sock ) {
17	$sock = IO::Socket::INET->new(
18	PeerAddr => '127.0.0.1',
19	PeerPort => 4444,
20	Proto => 'tcp',
21	);
22	if ( ! $sock ) {
23	$retries++;
24	print STDERR ".";
25	sleep 1
26	}
27	}
28
29	die $! unless $sock;
30
31	print STDERR "connected after $retries retries\n";
32
33	Storable::fd_retrieve( $sock )->{ping} or die "no ping";
34
35	my $term = Term::ReadLine->new('Sack');
36	my $prompt = "sack> ";
37	my $OUT = $term->OUT \|\| \*STDOUT;
38	while ( defined ($_ = $term->readline($prompt)) ) {
39	if ( /\S/ ) {
40	warn "# $_\n";
41	Storable::store_fd( { repl => $_ }, $sock );
42	warn "## ", dump( Storable::fd_retrieve( $sock ) );
43	$term->addhistory($_);
44	}
45	}