Minion::Notifier

Controller.pm

sub websocket {
    my $c = shift;
    
    $c->minion->backend->pg->pubsub->json('foo')->listen(foo => sub {
        my ($pubsub, $payload) = @_;
        my $job = $c->minion->job($payload->{id});

        $c->send({ json => $job->info });
    });
}

Plugin.pm

sub register {
  my ($self, $app, $args) = @_;
  my $pg = Mojo::Pg->new('postgresql://<user>:<pw>@/test');

    $app->minion->on(enqueue => sub {
        my ($minion, $id) = @_;
        $pg->pubsub->json('foo')->notify('foo' => { id => $id, message => 'enqueue' });
    });

    $app->minion->on(worker => sub {
        my ($minion, $worker) = @_;
        $worker->on(dequeue => sub {
            my ($w, $job) = @_;
            my $id = $job->id;
            $pg->pubsub->json('foo')->notify('foo' => { id => $id, message => 'dequeue' });
            $job->on(finished => sub {
                $pg->pubsub->json('foo')->notify('foo' => { id => $id, message => 'finished' });
            });
            $job->on(failed => sub {
                $pg->pubsub->json('foo')->notify('foo' => { id => $id, message => 'failed' });
            });
        });
    });
}