Blob Blame History Raw
#! @PERL@
# Copyright (c) 2013-2016 Carbonite, Inc.  All Rights Reserved.
#
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License
# as published by the Free Software Foundation; either version 2
# of the License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful, but
# WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
# or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
# for more details.
#
# You should have received a copy of the GNU General Public License along
# with this program; if not, write to the Free Software Foundation, Inc.,
# 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
#
# Contact information: Carbonite Inc., 756 N Pastoria Ave
# Sunnyvale, CA 94086, USA, or: http://www.zmanda.com

use lib '@amperldir@';
use strict;
use warnings;

use Getopt::Long;
use POSIX qw(WIFEXITED WEXITSTATUS strftime);
use File::Glob qw( :glob );

use Amanda::Config qw( :init :getconf );
use Amanda::Util qw( :constants );
use Amanda::Logfile qw( :logtype_t log_add );
use Amanda::Debug qw( debug );
use Amanda::Paths;
use Amanda::Amdump;

##
# Main

sub usage {
    my ($msg) = @_;
    print STDERR <<EOF;
Usage: amanda-rest-server [--version] [--help] [--development] [ start | stop ]
EOF
    print STDERR "$msg\n" if $msg;
    exit 1;
}

Amanda::Util::setup_application("amanda-rest-server", "server", $CONTEXT_DAEMON, "amanda", "amanda");

my $config_overrides = new_config_overrides($#ARGV+1);
my @config_overrides_opts;

my $opt_dancer = 0;
my $opt_dancer2 = 0;
my $opt_development = 0;

debug("Arguments: " . join(' ', @ARGV));
Getopt::Long::Configure(qw(bundling));
GetOptions(
    'version' => \&Amanda::Util::version_opt,
    'development' => \$opt_development,
    'dancer' => \$opt_dancer,
    'dancer2' => \$opt_dancer2,
    'help|usage|?' => sub { usage(); },
) or usage();

usage("'start' or 'stop' must be specified.") if (@ARGV < 1);

config_init($CONFIG_INIT_GLOBAL, undef);
Amanda::Util::finish_setup($RUNNING_AS_DUMPUSER);

my $dbgdir = $Amanda::Paths::AMANDA_DBGDIR;
my $pid_file = $dbgdir . '/rest-api-pid';
my $pid;
if (-f $pid_file) {
    $pid = Amanda::Util::slurp($pid_file);
    chomp $pid;
}
my $command = shift @ARGV;
if ($command eq 'start') {
    if (defined $pid) {
	my $Amanda_process = Amanda::Process->new(1);
	$Amanda_process->load_ps_table();
	if ($Amanda_process->process_alive($pid, undef)) {
	    print "The Amanda Rest Server is already running\n";
	    exit 0;
	}
    }

    my $port = getconf($CNF_REST_API_PORT);
    if ($port == 0) {
	debug("The REST-API-PORT must be defined in the global amanda.conf (" . $Amanda::Paths::CONFIG_DIR . "/amanda.conf) and be larger than 1024");
	print "The REST-API-PORT must be defined in the global amanda.conf (" . $Amanda::Paths::CONFIG_DIR . "/amanda.conf) and be larger than 1024\n";
	exit 1;
    } elsif ($port < 1024) {
	debug("The REST-API-PORT must be larger than 1024");
	print "The REST-API-PORT must be larger than 1024\n";
	exit 1;
    }

    my $ssl_cert = getconf($CNF_REST_SSL_CERT);
    my $ssl_key = getconf($CNF_REST_SSL_KEY);
    my @ssl;
    if ($ssl_cert && $ssl_key) {
	@ssl = ('--enable-ssl', '--ssl-cert', $ssl_cert, '--ssl-key', $ssl_key);
    }

    my $dance_name;
    eval "use Dancer2;";
    if ((!$@ || $opt_dancer2) && !$opt_dancer) {
	$dance_name = '@amlibexecdir@' . '/rest-server/bin/app-dancer2.pl';
    } else {
	$dance_name = '@amlibexecdir@' . '/rest-server/bin/app.pl';
    }
    my @command = ('starman',
		   $dance_name,
		   '--listen', '127.0.0.1:' . $port,
		   '--preload-app',
		   $opt_development ? '--env' : '',
		   $opt_development ? 'development' : '',
		   '--max-requests', '1',
		   $opt_development ? '' : '--daemonize',
		   @ssl,
		   '--pid', $pid_file);
    debug("running: " . join(' ', @command));
    system(@command);
    if ($? != 0) {
        debug("Unable to start Amanda REST server");
        print "Unable to start Amanda REST server\n";
        exit 1;
    }
    print "Started the Amanda Rest Server\n";
} elsif ($command eq 'stop') {
    if (defined $pid) {
	kill 'SIGTERM', $pid;
	print "Stopped the Amanda Rest Server\n";
    } else {
	print "The Amanda Rest Server is not running\n";
    }
    unlink($pid_file);
} else {
    usage("unknown '$command' command.");
}