src/Module/Admin/Queue.php

   1 <?php\r
   2 \r
   3 namespace Friendica\Module\Admin;\r
   4 \r
   5 use Friendica\Core\L10n;\r
   6 use Friendica\Core\Renderer;\r
   7 use Friendica\Database\DBA;\r
   8 use Friendica\Module\BaseAdminModule;\r
   9 use Friendica\Util\Arrays;\r
  10 use Friendica\Util\DateTimeFormat;\r
  11 \r
  12 /**\r
  13  * @brief Admin Inspect Queue Page\r
  14  *\r
  15  * Generates a page for the admin to have a look into the current queue of\r
  16  * worker jobs. Shown are the parameters for the job and its priority.\r
  17  *\r
  18  * @return string\r
  19  */\r
  20 class Queue extends BaseAdminModule\r
  21 {\r
  22         public static function content()\r
  23         {\r
  24                 parent::content();\r
  25 \r
  26                 $a = self::getApp();\r
  27 \r
  28                 // @TODO: Replace with parameter from router\r
  29                 $deferred = $a->argc > 2 && $a->argv[2] == 'deferred';\r
  30 \r
  31                 // get jobs from the workerqueue table\r
  32                 if ($deferred) {\r
  33                         $condition = ["NOT `done` AND `next_try` > ?", DateTimeFormat::utcNow()];\r
  34                         $sub_title = L10n::t('Inspect Deferred Worker Queue');\r
  35                         $info = L10n::t("This page lists the deferred worker jobs. This are jobs that couldn't be executed at the first time.");\r
  36                 } else {\r
  37                         $condition = ["NOT `done` AND `next_try` < ?", DateTimeFormat::utcNow()];\r
  38                         $sub_title = L10n::t('Inspect Worker Queue');\r
  39                         $info = L10n::t('This page lists the currently queued worker jobs. These jobs are handled by the worker cronjob you\'ve set up during install.');\r
  40                 }\r
  41 \r
  42                 $entries = DBA::select('workerqueue', ['id', 'parameter', 'created', 'priority'], $condition, ['order' => ['priority']]);\r
  43 \r
  44                 $r = [];\r
  45                 while ($entry = DBA::fetch($entries)) {\r
  46                         // fix GH-5469. ref: src/Core/Worker.php:217\r
  47                         $entry['parameter'] = Arrays::recursiveImplode(json_decode($entry['parameter'], true), ': ');\r
  48                         $entry['created'] = DateTimeFormat::local($entry['created']);\r
  49                         $r[] = $entry;\r
  50                 }\r
  51                 DBA::close($entries);\r
  52 \r
  53                 $t = Renderer::getMarkupTemplate('admin/queue.tpl');\r
  54                 return Renderer::replaceMacros($t, [\r
  55                         '$title' => L10n::t('Administration'),\r
  56                         '$page' => $sub_title,\r
  57                         '$count' => count($r),\r
  58                         '$id_header' => L10n::t('ID'),\r
  59                         '$param_header' => L10n::t('Job Parameters'),\r
  60                         '$created_header' => L10n::t('Created'),\r
  61                         '$prio_header' => L10n::t('Priority'),\r
  62                         '$info' => $info,\r
  63                         '$entries' => $r,\r
  64                 ]);\r
  65         }\r
  66 }\r