lib/Sack/REPL.pm

#!/usr/bin/perl

package Sack::REPL;

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