#!/usr/bin/env perl
use warnings;
use strict;
use POE::Kernel { loop => 'POE::XS::Loop::EPoll' };
use POE qw(Component::Server::TCP);

POE::Component::Server::TCP->new(
	Alias              => "chat_server",
	Port               => 32080,
	InlineStates       => {send => \&handle_send},
	ClientConnected    => \&client_connected,
	ClientError        => \&client_error,
	ClientDisconnected => \&client_disconnected,
	ClientInput        => \&client_input,
);
$poe_kernel->run();
exit 0;

my %users;

sub broadcast {
	my ($sender, $message) = @_;
	foreach my $user (keys %users) {
		if ($user == $sender) {
			$poe_kernel->post($user => send => "You $message");
		}
		else {
			$poe_kernel->post($user => send => "$sender $message");
		}
	}
}

sub handle_send {
	my ($heap, $message) = @_[HEAP, ARG0];
	$heap->{client}->put($message);
}

sub client_connected {
	my $session_id = $_[SESSION]->ID;
	$users{$session_id} = 1;
	broadcast($session_id, "connected.");
}

sub client_disconnected {
	my $session_id = $_[SESSION]->ID;
	delete $users{$session_id};
	broadcast($session_id, "disconnected.");
}

sub client_error {
	my $session_id = $_[SESSION]->ID;
	delete $users{$session_id};
	broadcast($session_id, "disconnected.");
	$_[KERNEL]->yield("shutdown");
}

sub client_input {
	my ($kernel, $session, $input) = @_[KERNEL, SESSION, ARG0];
	my $session_id = $session->ID;
	if ($input eq "/quit") {			# user entered /quit
		$poe_kernel->post($session_id => send => "goodbye");
		$kernel->yield("shutdown");
		return;
	}
	elsif ($input eq "/shutdown") {		# user entered /shutdown
		$poe_kernel->post($session_id => send => "don't do that!");
		### how to do this, shutdown the server
		$kernel->call('chat_server', 'shutdown');
		#########################################
		return;
	}
	broadcast($session_id, "said: $input");
}