#!/usr/bin/env perl
use warnings;
use strict;
use Mojo::Util qw/dumper/;
use Mojo::IOLoop;
use Mojo::IOLoop::Stream::Role::LineBuffer;

Mojo::IOLoop->server(
	{ address => '127.0.0.1', port => 3000, reuse => 1 } => sub {
		my ($loop, $stream) = @_;
		my $peer = $stream->handle->peerhost.":".$stream->handle->peerport;
		print "$peer: Connect\n";
		$stream->timeout(30);
		$stream = $stream->with_roles('+LineBuffer')->watch_lines;
		$stream->on(read_line => sub {
			my ($strm, $line, $sep) = @_;
			print "$peer: Got line ".dumper($line);
		});
		$stream->on(timeout => sub { print "$peer: Timeout\n" });
		$stream->on(close => sub { print "$peer: Closed\n" });
		$stream->on(error => sub { warn "$peer: Error: $_[1]" });
		$stream->write("Hello, client from $peer.\n");
	});
print "Starting server...\n";
Mojo::IOLoop->start unless Mojo::IOLoop->is_running;