File Coverage

blib/lib/Mercury.pm

Criterion	Covered	Total	%
statement	52	55	94.5
branch	8	12	66.6
condition	3	3	100.0
subroutine	8	9	88.8
pod	1	1	100.0
total	72	80	90.0

package Mercury;
our $VERSION = '0.015';
# ABSTRACT: Main broker application class

#pod =head1 SYNOPSIS
#pod
#pod     # Start the broker
#pod     $ mercury broker
#pod
#pod     # To get help
#pod     $ mercury help broker
#pod
#pod =head1 DESCRIPTION
#pod
#pod This is the main broker application class. This is the standard broker
#pod application that is started when you use C.
#pod
#pod To learn how to use this application to broker messages, see L
#pod Mercury documentation|mercury>. For how to start the broker application,
#pod see L
#pod or run C.
#pod
#pod To learn how to create a custom message broker to integrate authentication,
#pod logging, and other customizations, see L.
#pod
#pod =cut

use Mojo::Base 'Mojolicious';
use Scalar::Util qw( weaken refaddr );
use File::Basename qw( dirname );
use File::Spec::Functions qw( catdir );
use Mojo::WebSocket 'WS_PING';

sub startup {
    my ( $app ) = @_;
    $app->log( Mojo::Log->new ); # Log only to STDERR
    $app->plugin( 'Config', { default => { broker => { } } } );
    $app->commands->namespaces( [ 'Mercury::Command::mercury' ] );

    my $r = $app->routes;
    if ( my $origin = $app->config->{broker}{allow_origin} ) {
        # Allow only '*' for wildcards
        my @origin = map { quotemeta } ref $origin eq 'ARRAY' ? @$origin : $origin;
        s/\\\*/.*/g for @origin;

        $r = $r->under( '/' => sub {
            #say "Got origin: " . $_[0]->req->headers->origin;
            #say "Checking against: @origin";
            my $origin = $_[0]->req->headers->origin;
            if ( !$origin || !grep { $origin =~ /$_/ } @origin ) {
                $_[0]->render(
                    status => '401',
                    text => 'Origin check failed',
                );
                return;
            }
            return 1;
        } );
    }

    $app->hook( before_dispatch => sub {
        my ( $c ) = @_;
        if ( $c->tx->is_websocket ) {
            weaken $c;
            my $id = Mojo::IOLoop->recurring( 300, sub {
                return unless $c;
                $c->tx->send([1, 0, 0, 0, WS_PING, 'Still alive!']);
            } );
            $c->tx->once( finish => sub { Mojo::IOLoop->remove( $id ) } );
        }
    } );

    $app->plugin( 'Mercury' );
    $r->websocket( '/push/*topic' )
      ->to( controller => 'PushPull', action => 'push' )
      ->name( 'push' );
    $r->post( '/push/*topic' )
      ->to( controller => 'PushPull', action => 'post' )
      ->name( 'push_post' );
    $r->websocket( '/pull/*topic' )
      ->to( controller => 'PushPull', action => 'pull' )
      ->name( 'pull' );

    $r->websocket( '/pub/*topic' )
      ->to( controller => 'PubSub::Cascade', action => 'publish' )
      ->name( 'pub' );
    $r->post( '/pub/*topic' )
      ->to( controller => 'PubSub::Cascade', action => 'post' )
      ->name( 'pub_post' );
    $r->websocket( '/sub/*topic' )
      ->to( controller => 'PubSub::Cascade', action => 'subscribe' )
      ->name( 'sub' );

    $r->websocket( '/bus/*topic' )
      ->to( controller => 'Bus', action => 'connect' )
      ->name( 'bus' );
    $r->post( '/bus/*topic' )
      ->to( controller => 'Bus', action => 'post' )
      ->name( 'bus_post' );

    if ( $app->mode eq 'development' ) {
        # Enable the example app
        my $root = catdir( dirname( __FILE__ ), 'Mercury' );
        $app->static->paths->[0] = catdir( $root, 'public' );
        $app->renderer->paths->[0] = catdir( $root, 'templates' );
        $app->routes->any( '/' )->to( cb => sub { shift->render( 'index' ) } );
    }
}

1;

__END__