File Coverage

blib/lib/XAS/Lib/POE/PubSub.pm

Criterion	Covered	Total	%
statement	6	24	25.0
branch			n/a
condition			n/a
subroutine	2	6	33.3
pod	4	4	100.0
total	12	34	35.2

package XAS::Lib::POE::PubSub;

our $VERSION = '0.01';

use POE;

use XAS::Class
  debug   => 0,
  version => $VERSION,
  base    => 'XAS::Singleton',
  utils   => ':validation',
;

#use Data::Dumper;

# ----------------------------------------------------------------------
# Public Methods
# ----------------------------------------------------------------------

sub subscribe {
    my $self = shift;
    my ($session, $channel) = validate_params(\@_, [
        1,
        { optional => 1, default => 'default' }
    ]);

    $self->{'registry'}->{$channel}->{$session} = $session;

}

sub unsubscribe {
    my $self = shift;
    my ($session, $channel) = validate_params(\@_, [
        1,
        { optional => 1, default => 'default' }
    ]);

    delete $self->{'registry'}->{$channel}->{$session};

}

sub publish {
    my $self = shift;
    my $p = validate_params(\@_, {
       -event   => 1,
       -args    => { optional => 1, default => undef },
       -channel => { optional => 1, default => 'default' },
    });

    my $event   = $p->{'event'};
    my $channel = $p->{'channel'};
    my $args    = $p->{'args'};

    foreach my $session (keys %{$self->{'registry'}->{$channel}}) {

        $poe_kernel->post($session, $event, $args);

    }

}

# ----------------------------------------------------------------------
# Private Methods
# ----------------------------------------------------------------------

sub init {
    my $class = shift;

    my $self = $class->SUPER::init(@_);

    $self->{'registry'} = {};

    return $self;

}

1;

__END__