#!/usr/bin/env php
<?php
/*
 * StatusNet - the distributed open-source microblogging tool
 * Copyright (C) 2010, StatusNet, Inc.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 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 Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

/**
 * Sends control signals to running queue daemons.
 *
 * @author Brion Vibber <brion@status.net>
 * @package QueueHandler
 */

define('INSTALLDIR', realpath(dirname(__FILE__) . '/..'));

$shortoptions = 'ur';
$longoptions = array('update', 'restart', 'stop');

$helptext = <<<END_OF_QUEUECTL_HELP
Send broadcast events to control any running queue handlers.
(Currently for Stomp queues only.)

Events relating to current site (as selected with -s etc)
    -u --update       Announce new site or updated configuration. Running
                      daemons will start subscribing to any new queues needed
                      for this site.

Global events:
    -r --restart      Graceful restart of all threads
       --stop         Graceful shutdown of all threads

END_OF_QUEUECTL_HELP;

require_once INSTALLDIR.'/scripts/commandline.inc.php';

function doSendControl($message, $event, $param='')
{
    print $message;
    $qm = QueueManager::get();
    if ($qm->sendControlSignal($event, $param)) {
        print " sent.\n";
    } else {
        print " FAILED.\n";
    }
}

$actions = 0;

if (have_option('u') || have_option('--update')) {
    $nickname = common_config('site', 'nickname');
    doSendControl("Sending site update signal to queue daemons for $nickname",
                  "update", $nickname);
    $actions++;
}

if (have_option('r') || have_option('--restart')) {
    doSendControl("Sending graceful restart signal to queue daemons...",
                  "restart");
    $actions++;
}

if (have_option('--stop')) {
    doSendControl("Sending graceful shutdown signal to queue daemons...",
                  "shutdown");
    $actions++;
}

if (!$actions) {
    show_help();
}