equal
deleted
inserted
replaced
14 # along with this program. If not, see <http://www.gnu.org/licenses/>. |
14 # along with this program. If not, see <http://www.gnu.org/licenses/>. |
15 |
15 |
16 use Mojo::Base -strict; |
16 use Mojo::Base -strict; |
17 use lib 'lib'; |
17 use lib 'lib'; |
18 |
18 |
19 use Mojo::JSON; |
19 use Mojo::JSON qw/decode_json/; |
20 use Mojo::Util qw(decode slurp); |
20 use Mojo::Util qw/decode slurp/; |
21 use Mojo::Loader; |
21 use Mojo::Loader; |
22 use File::Temp; |
22 use File::Temp; |
23 use Gearman::Worker; |
23 use Gearman::Worker; |
24 use Mojolicious; |
24 use Mojolicious; |
25 use Mojo::Home; |
25 use Mojo::Home; |
45 my $worker = Gearman::Worker->new(job_servers => $config->{DecodeQueue}->{GearmanServers}); |
45 my $worker = Gearman::Worker->new(job_servers => $config->{DecodeQueue}->{GearmanServers}); |
46 |
46 |
47 $worker->register_function("dump_decode", 60, sub { |
47 $worker->register_function("dump_decode", 60, sub { |
48 my $args = $_[0]->arg; |
48 my $args = $_[0]->arg; |
49 |
49 |
50 my $json = Mojo::JSON->new(); |
50 my $jsonin = decode_json($args); |
51 my $jsonin = $json->decode($args); |
|
52 |
51 |
53 my $file = File::Temp->new(); |
52 my $file = File::Temp->new(); |
54 binmode($file); |
53 binmode($file); |
55 print $file $jsonin->{file}; |
54 print $file $jsonin->{file}; |
56 |
55 |