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	dpavlin	164	#!/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	dpavlin	171	my $retries = 0;
12			my $sock;
13	dpavlin	164
14	dpavlin	171	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	dpavlin	164	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			}