package LinuxRulz::Bot::Plugin::TCPDPlugin;

use Moses::Plugin;
use namespace::autoclean;
use Data::Dumper;

use POE::Wheel::SocketFactory;
use POE::Wheel::ReadWrite;
use Socket;


with "LinuxRulz::Bot::Role::Plugin";

has _socketfactory => (
    isa        => 'Any',
    accessor   => 'socketfactory',
	builder    => '_build__socketfactory',
    lazy_build => 1,
);

has _clients  => (
    isa        => 'HashRef',

);

sub _build__socketfactory {
	my $self = shift;
	unlink "/home/linuxrulz/bots/linuxrulz/var/bot.socket" if -e "/home/linuxrulz/bots/linuxrulz/var/bot.socket";
	my $socketfactory;

	POE::Session->create(
    	inline_states => {
      		_start     => sub {
				$socketfactory = POE::Wheel::SocketFactory->new(
       				SocketDomain => PF_UNIX,
			        BindAddress  => '/home/linuxrulz/bots/linuxrulz/var/bot.socket',
        			SuccessEvent => 'got_client',
        			FailureEvent => 'got_error',
    			);
			},
      		got_client => sub { $self->got_client(@_); },
      		got_error  => sub { $self->got_error(@_); },
			on_client_input  => sub { $self->got_client_input(@_); },
            on_client_error  => sub { $self->got_client_error(@_); },
    	},
    	heap => {self => $self},
  	);
	
	return $socketfactory;
}

sub got_client {
	my ( $self, $client_socket ) = @_;
	die 1;
    my $io_wheel = POE::Wheel::ReadWrite->new(
    	Handle => $client_socket,
        InputEvent => "on_client_input",
        ErrorEvent => "on_client_error",
	);

	$self->_clients->{ $io_wheel->ID() } = $io_wheel;
}

sub got_error {
	my ($self, $syscall, $errno, $error) = @_;
	$error = "Normal disconnection." unless $errno;
	warn "Server socket encountered $syscall error $errno: $error\n";
	delete $self->socketfactory;
}

sub on_client_error  {
	my ( $self, $wheel_id ) = @_;
    delete $self->_clients->{$wheel_id};
}

sub on_client_input {
	my ($self, $input, $wheel_id) = @_;
	$input =~ tr[a-zA-Z][n-za-mN-ZA-M]; # ASCII rot13
    $self->_clients->{$wheel_id}->put($input);
}

after "PCI_register" => sub  {
	my ( $self, $irc ) = @_;

	$self->socketfactory();
	
	return 1;
};

after "PCI_unregister" => sub  {
    my ( $self, $irc ) = @_;

	delete $self->_clients;
	delete $self->socketfactory;

    return 1;
};

sub S_msg {
    my ( $self, $irc, $nickstr, $target, $msg ) = @_;

	return $self->handle_message($irc, $$nickstr, $$target, "priv", $$msg);

    return PCI_EAT_NONE;
}

sub S_bot_addressed {
    my ( $self, $irc, $nickstr, $channel, $msg ) = @_;
	
	return $self->handle_message($irc, $$nickstr, $$channel, "chan", $$msg);
	
    return PCI_EAT_NONE;
}

sub handle_message {
	my ( $self, $irc, $nickstr, $where, $source, $message ) = @_;

    my ($nick) = split /!/, $nickstr;

	if($message =~ /^!testhttpd$/)
	{
		$self->send_msg($irc, $nickstr, $where, $source, "Test");
	}

	return PCI_EAT_NONE;
}

__PACKAGE__->meta->add_method( S_public => \&S_bot_addressed );

1;