mirror of
https://github.com/phpbb/phpbb.git
synced 2025-07-31 22:10:45 +02:00
[ticket/14542] Move cron to controller
PHPBB3-14542
This commit is contained in:
committed by
Marc Alexander
parent
41956a8b90
commit
7a173877b7
38
phpBB/phpbb/cron/controller/cron.php
Normal file
38
phpBB/phpbb/cron/controller/cron.php
Normal file
@@ -0,0 +1,38 @@
|
||||
<?php
|
||||
/**
|
||||
*
|
||||
* This file is part of the phpBB Forum Software package.
|
||||
*
|
||||
* @copyright (c) phpBB Limited <https://www.phpbb.com>
|
||||
* @license GNU General Public License, version 2 (GPL-2.0)
|
||||
*
|
||||
* For full copyright and license information, please see
|
||||
* the docs/CREDITS.txt file.
|
||||
*
|
||||
*/
|
||||
|
||||
namespace phpbb\cron\controller;
|
||||
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
|
||||
/**
|
||||
* Controller for running cron jobs
|
||||
*/
|
||||
class cron
|
||||
{
|
||||
/**
|
||||
* Handles CRON requests
|
||||
*
|
||||
* @return Response
|
||||
*/
|
||||
public function handle($cron_type)
|
||||
{
|
||||
$response = new Response();
|
||||
$response->headers->set('Cache-Control', 'no-cache');
|
||||
$response->headers->set('Content-type', 'image/gif');
|
||||
$response->headers->set('Content-length', '43');
|
||||
$response->setContent(base64_decode('R0lGODlhAQABAIAAAP///wAAACH5BAEAAAAALAAAAAABAAEAAAICRAEAOw=='));
|
||||
|
||||
return $response;
|
||||
}
|
||||
}
|
101
phpBB/phpbb/cron/event/cron_runner_listener.php
Normal file
101
phpBB/phpbb/cron/event/cron_runner_listener.php
Normal file
@@ -0,0 +1,101 @@
|
||||
<?php
|
||||
/**
|
||||
*
|
||||
* This file is part of the phpBB Forum Software package.
|
||||
*
|
||||
* @copyright (c) phpBB Limited <https://www.phpbb.com>
|
||||
* @license GNU General Public License, version 2 (GPL-2.0)
|
||||
*
|
||||
* For full copyright and license information, please see
|
||||
* the docs/CREDITS.txt file.
|
||||
*
|
||||
*/
|
||||
|
||||
namespace phpbb\cron\event;
|
||||
|
||||
use phpbb\cron\manager;
|
||||
use phpbb\lock\db;
|
||||
use phpbb\request\request_interface;
|
||||
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
|
||||
use Symfony\Component\HttpKernel\KernelEvents;
|
||||
use Symfony\Component\HttpKernel\Event\PostResponseEvent;
|
||||
|
||||
/**
|
||||
* Event listener that executes cron tasks, after the response was served
|
||||
*/
|
||||
class cron_runner_listener implements EventSubscriberInterface
|
||||
{
|
||||
/**
|
||||
* @var \phpbb\lock\db
|
||||
*/
|
||||
private $cron_lock;
|
||||
|
||||
/**
|
||||
* @var \phpbb\cron\manager
|
||||
*/
|
||||
private $cron_manager;
|
||||
|
||||
/**
|
||||
* @var \phpbb\request\request_interface
|
||||
*/
|
||||
private $request;
|
||||
|
||||
/**
|
||||
* Constructor
|
||||
*
|
||||
* @param db $lock
|
||||
* @param manager $manager
|
||||
* @param request_interface $request
|
||||
*/
|
||||
public function __construct(db $lock, manager $manager, request_interface $request)
|
||||
{
|
||||
$this->cron_lock = $lock;
|
||||
$this->cron_manager = $manager;
|
||||
$this->request = $request;
|
||||
}
|
||||
|
||||
/**
|
||||
* Runs the cron job after the response was sent
|
||||
*/
|
||||
public function on_kernel_terminate(PostResponseEvent $event)
|
||||
{
|
||||
$request = $event->getRequest();
|
||||
$controller_name = $request->get('_route');
|
||||
|
||||
if ($controller_name !== 'phpbb_cron_run')
|
||||
{
|
||||
return;
|
||||
}
|
||||
|
||||
$cron_type = $request->get('cron_type');
|
||||
|
||||
if ($this->cron_lock->acquire())
|
||||
{
|
||||
$task = $this->cron_manager->find_task($cron_type);
|
||||
if ($task)
|
||||
{
|
||||
if ($task->is_parametrized())
|
||||
{
|
||||
$task->parse_parameters($this->request);
|
||||
}
|
||||
|
||||
if ($task->is_ready())
|
||||
{
|
||||
$task->run();
|
||||
}
|
||||
|
||||
$this->cron_lock->release();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
static public function getSubscribedEvents()
|
||||
{
|
||||
return array(
|
||||
KernelEvents::TERMINATE => 'on_kernel_terminate',
|
||||
);
|
||||
}
|
||||
}
|
@@ -13,6 +13,9 @@
|
||||
|
||||
namespace phpbb\cron;
|
||||
|
||||
use phpbb\cron\task\wrapper;
|
||||
use phpbb\routing\helper;
|
||||
|
||||
/**
|
||||
* Cron manager class.
|
||||
*
|
||||
@@ -20,6 +23,11 @@ namespace phpbb\cron;
|
||||
*/
|
||||
class manager
|
||||
{
|
||||
/**
|
||||
* @var helper
|
||||
*/
|
||||
protected $routing_helper;
|
||||
|
||||
/**
|
||||
* Set of \phpbb\cron\task\wrapper objects.
|
||||
* Array holding all tasks that have been found.
|
||||
@@ -28,18 +36,27 @@ class manager
|
||||
*/
|
||||
protected $tasks = array();
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
protected $phpbb_root_path;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
protected $php_ext;
|
||||
|
||||
/**
|
||||
* Constructor. Loads all available tasks.
|
||||
*
|
||||
* @param array|\Traversable $tasks Provides an iterable set of task names
|
||||
* @param helper $routing_helper Routing helper
|
||||
* @param string $phpbb_root_path Relative path to phpBB root
|
||||
* @param string $php_ext PHP file extension
|
||||
*/
|
||||
public function __construct($tasks, $phpbb_root_path, $php_ext)
|
||||
public function __construct($tasks, helper $routing_helper, $phpbb_root_path, $php_ext)
|
||||
{
|
||||
$this->routing_helper = $routing_helper;
|
||||
$this->phpbb_root_path = $phpbb_root_path;
|
||||
$this->php_ext = $php_ext;
|
||||
|
||||
@@ -142,6 +159,6 @@ class manager
|
||||
*/
|
||||
public function wrap_task(\phpbb\cron\task\task $task)
|
||||
{
|
||||
return new \phpbb\cron\task\wrapper($task, $this->phpbb_root_path, $this->php_ext);
|
||||
return new wrapper($task, $this->routing_helper, $this->phpbb_root_path, $this->php_ext);
|
||||
}
|
||||
}
|
||||
|
@@ -13,14 +13,32 @@
|
||||
|
||||
namespace phpbb\cron\task;
|
||||
|
||||
use phpbb\routing\helper;
|
||||
|
||||
/**
|
||||
* Cron task wrapper class.
|
||||
* Enhances cron tasks with convenience methods that work identically for all tasks.
|
||||
*/
|
||||
class wrapper
|
||||
{
|
||||
/**
|
||||
* @var helper
|
||||
*/
|
||||
protected $routing_helper;
|
||||
|
||||
/**
|
||||
* @var task
|
||||
*/
|
||||
protected $task;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
protected $phpbb_root_path;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
protected $php_ext;
|
||||
|
||||
/**
|
||||
@@ -28,13 +46,15 @@ class wrapper
|
||||
*
|
||||
* Wraps a task $task, which must implement cron_task interface.
|
||||
*
|
||||
* @param \phpbb\cron\task\task $task The cron task to wrap.
|
||||
* @param string $phpbb_root_path Relative path to phpBB root
|
||||
* @param string $php_ext PHP file extension
|
||||
* @param task $task The cron task to wrap.
|
||||
* @param helper $routing_helper Routing helper for route generation
|
||||
* @param string $phpbb_root_path Relative path to phpBB root
|
||||
* @param string $php_ext PHP file extension
|
||||
*/
|
||||
public function __construct(\phpbb\cron\task\task $task, $phpbb_root_path, $php_ext)
|
||||
public function __construct(task $task, helper $routing_helper, $phpbb_root_path, $php_ext)
|
||||
{
|
||||
$this->task = $task;
|
||||
$this->routing_helper = $routing_helper;
|
||||
$this->phpbb_root_path = $phpbb_root_path;
|
||||
$this->php_ext = $php_ext;
|
||||
}
|
||||
@@ -49,7 +69,7 @@ class wrapper
|
||||
*/
|
||||
public function is_parametrized()
|
||||
{
|
||||
return $this->task instanceof \phpbb\cron\task\parametrized;
|
||||
return $this->task instanceof parametrized;
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -76,22 +96,13 @@ class wrapper
|
||||
*/
|
||||
public function get_url()
|
||||
{
|
||||
$name = $this->get_name();
|
||||
$params['cron_type'] = $this->get_name();
|
||||
if ($this->is_parametrized())
|
||||
{
|
||||
$params = $this->task->get_parameters();
|
||||
$extra = '';
|
||||
foreach ($params as $key => $value)
|
||||
{
|
||||
$extra .= '&' . $key . '=' . urlencode($value);
|
||||
}
|
||||
$params = array_merge($params, $this->task->get_parameters());
|
||||
}
|
||||
else
|
||||
{
|
||||
$extra = '';
|
||||
}
|
||||
$url = append_sid($this->phpbb_root_path . 'cron.' . $this->php_ext, 'cron_type=' . $name . $extra);
|
||||
return $url;
|
||||
|
||||
return $this->routing_helper->route('phpbb_cron_run', $params);
|
||||
}
|
||||
|
||||
/**
|
||||
|
Reference in New Issue
Block a user