File Coverage

blib/lib/Mercury/Controller/Bus.pm

Criterion	Covered	Total	%
statement	26	26	100.0
branch	4	4	100.0
condition			n/a
subroutine	6	6	100.0
pod	2	2	100.0
total	38	38	100.0

package Mercury::Controller::Bus;
our $VERSION = '0.015';
# ABSTRACT: A messaging pattern where all subscribers share messages

#pod =head1 SYNOPSIS
#pod
#pod =head1 DESCRIPTION
#pod
#pod =head1 SEE ALSO
#pod
#pod =cut

use Mojo::Base 'Mojolicious::Controller';
use Mercury::Pattern::Bus;

#pod =method connect
#pod
#pod Establish a WebSocket message bus to send/receive messages on the given
#pod C. All clients connected to the topic will receive all messages
#pod published on the topic.
#pod
#pod This is a shorter way of doing both C and C,
#pod without the hierarchical message passing.
#pod
#pod One difference is that by default a sender will not receive a message
#pod that they sent. To enable this behavior, pass a true value as the C
#pod query parameter when establishing the websocket.
#pod
#pod   $ua->websocket('/bus/foo?echo=1' => sub { ... });
#pod
#pod =cut

sub connect {
    my ( $c ) = @_;

    my $topic = $c->stash( 'topic' );
    my $pattern = $c->_pattern( $topic );
    $pattern->add_peer( $c->tx );
    if ( $c->param( 'echo' ) ) {
        $c->tx->on( message => sub {
            my ( $tx, $msg ) = @_;
            $tx->send( $msg );
        } );
    }

    $c->rendered( 101 );
};

#pod =method post
#pod
#pod Post a new message to the given topic without subscribing or
#pod establishing a WebSocket connection. This allows new messages to be
#pod pushed by any HTTP client.
#pod
#pod =cut

sub post {
    my ( $c ) = @_;
    my $topic = $c->stash( 'topic' );
    my $pattern = $c->_pattern( $topic );
    $pattern->send_message( $c->req->body );
    $c->render(
        status => 200,
        text => '',
    );
}

#=method _pattern
#
#   my $pattern = $c->_pattern( $topic );
#
# Get or create the L object for the given
# topic.
#
#=cut

sub _pattern {
    my ( $c, $topic ) = @_;
    my $pattern = $c->mercury->pattern( Bus => $topic );
    if ( !$pattern ) {
        $pattern = Mercury::Pattern::Bus->new;
        $c->mercury->pattern( Bus => $topic => $pattern );
    }
    return $pattern;
}

1;

__END__