File Coverage

blib/lib/Dancer2/Plugin/WebSocket/Group.pm

Criterion	Covered	Total	%
statement	12	22	54.5
branch	0	2	0.0
condition	0	3	0.0
subroutine	4	7	57.1
pod	2	3	66.6
total	18	37	48.6

package Dancer2::Plugin::WebSocket::Group;
our $AUTHORITY = 'cpan:YANICK';
# ABSTACT: Grouping of connections to send messages to
$Dancer2::Plugin::WebSocket::Group::VERSION = '0.2.0';

use strict;
use warnings;

use Moo;


has source => (
    is => 'ro',
    required => 1,
);

has channels => (
    is => 'ro',
    required => 1,
);

use Set::Tiny;

sub targets {
    my ( $self, $omit_self ) = @_;

    my $channels = Set::Tiny->new( @{$self->channels} );

    return grep {
        $_->in_channel($channels) and
        ( !$omit_self or $self->source->id != $_->id )
    } values %{ $self->source->manager->connections };
}


sub send {
    my ( $self, @args ) = @_;

    $_->send(@args) for $self->targets;
}


sub broadcast {
    my ( $self, @args ) = @_;

    $_->send(@args) for $self->targets(1);
}

1;

__END__