File Coverage

blib/lib/Minion/Notifier/Transport/WebSocket.pm

Criterion	Covered	Total	%
statement	19	19	100.0
branch			n/a
condition			n/a
subroutine	7	7	100.0
pod	0	2	0.0
total	26	28	92.8

package Minion::Notifier::Transport::WebSocket;

use Mojo::Base 'Minion::Notifier::Transport';

use Mojo::URL;
use Mojo::UserAgent;

has ua => sub { Mojo::UserAgent->new };
has url => sub { die 'url is required' };

sub listen {
  my $self = shift;
  $self->ua->websocket($self->url => sub {
    my ($ua, $tx) = @_;
    $tx->on(json => sub {
      my ($tx, $data) = @_;
      $self->emit(notified => @$data);
    });
  });
}

sub send {
  my ($self, $id, $message) = @_;
  $self->ua->websocket($self->url => sub {
    my ($ua, $tx) = @_;
    $tx->send({json => [$id, $message]}); #TODO finish after send?
  });
}


1;