my $sub = AnyEvent::Redis->new( host => $ENV{REDIS_HOST}, port => $ENV{REDIS_PORT}, on_error => sub { confess @_ } );
my $sub = AnyEvent::Redis->new( host => $ENV{REDIS_HOST}, port => $ENV{REDIS_PORT}, on_error => sub { confess @_ } );
warn "#Q<< ",dump( $from, $message );
my ( undef, $channel, $user ) = split(/ /,$from,3);
$con->send_msg( 'PRIVMSG', $room => join(' ',$channel, $user, $message) );
warn "#Q<< ",dump( $from, $message );
my ( undef, $channel, $user ) = split(/ /,$from,3);
$con->send_msg( 'PRIVMSG', $room => join(' ',$channel, $user, $message) );
- my $channel = join(' ', 'channel', $msg->{params}->[0], $msg->{prefix});
+ my ( $to, $body ) = @{ $msg->{params} };
+ my $channel = join(' ', 'MSG', "$nick/$to", $msg->{prefix});
+ warn "#Q>> $channel | $body\n";
my $pub = AnyEvent::Redis->new( host => $ENV{REDIS_HOST}, port => $ENV{REDIS_PORT}, on_error => sub { confess @_ } );
my $pub = AnyEvent::Redis->new( host => $ENV{REDIS_HOST}, port => $ENV{REDIS_PORT}, on_error => sub { confess @_ } );