Snippets

Brian Medley 69aEg: Untitled snippet

Created by Brian Medley
work.pl
Raw 
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
use Mojolicious::Lite;
use 5.20.0;
use experimental 'signatures';

use Mojo::Util qw(steady_time);

plugin Minion => {Pg => "postgresql://$ENV{DBI_USER}:$ENV{DBI_PASS}\@127.0.0.1/jobs"};

app->minion->add_task(email_photo => sub ($job, $photo) {
    $job->app->log->debug(qq{Received message $photo : } . steady_time);
    select(undef, undef, undef, rand);
    $job->app->log->debug(qq{Processd message $photo : } . steady_time);
});

app->minion->add_task(convert_photo => sub ($job, $photo) {
    $job->app->log->debug(qq{Received message $photo : } . steady_time);
    select(undef, undef, undef, rand);
    $job->app->log->debug(qq{Processd message $photo : } . steady_time);
});

app->minion->add_task(resize_photo => sub ($job, $photo) {
    $job->app->log->debug(qq{Received message $photo : } . steady_time);
    select(undef, undef, undef, rand);
    $job->app->log->debug(qq{Processd message $photo : } . steady_time);
});

app->minion->add_task(crop_photo => sub ($job, $photo) {
    $job->app->log->debug(qq{Received message $photo : } . steady_time);
    select(undef, undef, undef, rand);
    $job->app->log->debug(qq{Processd message $photo : } . steady_time);
});

app->minion->add_task(independent => sub ($job, $time) {
    $job->app->log->debug(qq{Received message $time : } . steady_time);
    select(undef, undef, undef, rand);
    $job->app->log->debug(qq{Processd message $time : } . steady_time);
});

get '/' => sub {
    my $c = shift;

    $c->render(json => {number => 4});
};

get '/photo' => sub ($c) {
    my $time = steady_time;

    my @chain = (
        [ convert_photo => "yippie.png: $time", [] ],
        [ resize_photo => "yippie.png: $time", [] ],
        [ crop_photo => "yippie.png: $time", [] ],
        [ email_photo => "yippie.png: $time", [] ],
    );

    foreach my $chain (@chain) {
        state $deps = [];

        my $task = shift(@{ $chain });
        my $ops = pop(@{ $chain });

        push(@{ $deps }, $c->minion->enqueue($task, $chain, {@{$ops}, depends_on => $deps}));

        $c->minion->enqueue("independent", [$time], {priority => 3}) if int(rand(2));
    }

    $c->minion->enqueue("independent", [$time]);
    
    $c->render(text => 'Your photo will be done soon.');
};

app->start;

Comments (0)

HTTPS SSH

You can clone a snippet to your computer for local editing. Learn more.