handlequeued.php 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. #!/usr/bin/env php
  2. <?php
  3. /*
  4. * StatusNet - the distributed open-source microblogging tool
  5. * Copyright (C) 2008, 2009, StatusNet, Inc.
  6. *
  7. * This program is free software: you can redistribute it and/or modify
  8. * it under the terms of the GNU Affero General Public License as published by
  9. * the Free Software Foundation, either version 3 of the License, or
  10. * (at your option) any later version.
  11. *
  12. * This program is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU Affero General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU Affero General Public License
  18. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  19. */
  20. define('INSTALLDIR', realpath(dirname(__FILE__) . '/..'));
  21. $helptext = <<<END_OF_QUEUE_HELP
  22. USAGE: handlequeued.php <queue> <notice id>
  23. Run a single queued notice through background processing
  24. as if it were being run through the queue.
  25. END_OF_QUEUE_HELP;
  26. require_once INSTALLDIR.'/scripts/commandline.inc';
  27. if (count($args) != 2) {
  28. show_help();
  29. }
  30. $queue = trim($args[0]);
  31. $noticeId = intval($args[1]);
  32. $qm = QueueManager::get();
  33. $handler = $qm->getHandler($queue);
  34. if (!$handler) {
  35. print "No handler for queue '$queue'.\n";
  36. exit(1);
  37. }
  38. $notice = Notice::getKV('id', $noticeId);
  39. if (empty($notice)) {
  40. print "Invalid notice id $noticeId\n";
  41. exit(1);
  42. }
  43. if (!$handler->handle($notice)) {
  44. print "Failed to handle notice id $noticeId on queue '$queue'.\n";
  45. exit(1);
  46. }