CPAN::Groonga

use 5.12.0;
use warnings;

use Data::Dumper;
use File::Slurp;
use Getopt::Long;
use IO::Wrap;
use JSON;
use LWP::UserAgent;
use Pod::Usage;
use Text::CSV_XS;
use Text::Table;
use Try::Tiny;

my $url =

ocalhost:8080';
my $username;
my $password;
my $help = 0;
my $config_file = '/etc/disbatch/config.json';
my $ssl_ca_file;
my $disable_ssl_verification = 0;

GetOptions(
    'url|u=s'       => \$url,
 

ication,
);

pod2usage(-verbose => 2, -exitval => 0) if $help;
pod2usage(1) unless @ARGV;

my $json = JSON->new;

my $options = {};
if (defined $ssl_ca_file) {
    $options->{ssl_opts}{SSL_ca_file} = 

= '4.103';
use 5.12.0;
use warnings;

use Cpanel::JSON::XS;
use Disbatch::Web;	# exports: parse_params send_json_options template
use Limper::SendJSON;
use Limper;
use MongoDB::OID 1.0.4;
use Safe::Is

##########

get '/scheduler-json' => sub {
    undef $disbatch->{mongo};
    send_json $disbatch->scheduler_report_old_api, send_json_options;
};

post '/set-queue-attr-json' => sub {
    undef $disba

;
        return send_json { success => 0, error => 'Invalid attr'}, send_json_options;
    }
    unless (defined $params->{value}) {
        status 400;
        return send_json {success => 0, error 

e qw/clone/;
use Cpanel::JSON::XS;
use Data::Dumper;
use Disbatch;
use Exporter qw/ import /;
use File::Slurp;
use Limper::SendFile;	# needed for public()
use Limper::SendJSON;
use Limper 0.015;
use M

arams_mixed/;

our @EXPORT = qw/ parse_params send_json_options template /;

my $oid_keys = [ qw/ queue / ];	# NOTE: in addition to _id

sub send_json_options { allow_blessed => 1, canonical => 1, con

atch->new(class => 'Disbatch::Web', config_file => ($args->{config_file} // '/etc/disbatch/config.json'));
    $disbatch->load_config;
    public ($disbatch->{config}{web_root} // '/etc/disbatch/htdoc

3';
use 5.12.0;
use warnings;

use Disbatch::Web;	# exports: parse_params send_json_options template
use Limper::SendJSON;
use Limper;
use MongoDB::OID 1.0.4;
use Safe::Isa;
use Time::Moment;
use Try:

options} eq 'HASH') {
        status 400;
        return send_json { error => 'filter and options must be name/value objects' }, send_json_options;
    }
    $params->{options}{limit} //= $LIMIT;
    

s->{options}{limit} > $LIMIT) {
        status 400;
        return send_json { error => "limit cannot exceed $LIMIT" }, send_json_options;
    }

    $params->{filter}{queue} = { '$oid' => $params->{f

 Disbatch;
$Disbatch::VERSION = '4.103';
use 5.12.0;
use warnings;

use boolean 0.25;
use Cpanel::JSON::XS;
use Data::Dumper;
use Encode;
use File::Slurp;
use Log::Log4perl;
use MongoDB 1.0.4;
use POS

lf) = @_;
    if (!defined $self->{config}) {
        $self->{config} = try {
            Cpanel::JSON::XS->new->utf8->relaxed->decode(scalar read_file($self->{config_file}));
        } catch {