From 32e4a932c801dfa6c52f6e8211a96bdb7849579d Mon Sep 17 00:00:00 2001 From: Frederic Guillot Date: Wed, 27 Jan 2016 21:45:37 -0500 Subject: Added automatic actions based on a daily event --- app/Console/TaskTrigger.php | 52 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 52 insertions(+) create mode 100644 app/Console/TaskTrigger.php (limited to 'app/Console/TaskTrigger.php') diff --git a/app/Console/TaskTrigger.php b/app/Console/TaskTrigger.php new file mode 100644 index 00000000..000d215a --- /dev/null +++ b/app/Console/TaskTrigger.php @@ -0,0 +1,52 @@ +setName('trigger:tasks') + ->setDescription('Trigger scheduler event for all tasks'); + } + + protected function execute(InputInterface $input, OutputInterface $output) + { + foreach ($this->getProjectIds() as $project_id) { + $tasks = $this->taskFinder->getAll($project_id); + $nb_tasks = count($tasks); + + if ($nb_tasks > 0) { + $output->writeln('Trigger task event: project_id='.$project_id.', nb_tasks='.$nb_tasks); + $this->sendEvent($tasks, $project_id); + } + } + } + + private function getProjectIds() + { + $listeners = $this->dispatcher->getListeners(Task::EVENT_DAILY_CRONJOB); + $project_ids = array(); + + foreach ($listeners as $listener) { + $project_ids[] = $listener[0]->getProjectId(); + } + + return array_unique($project_ids); + } + + private function sendEvent(array &$tasks, $project_id) + { + $event = new TaskListEvent(array('project_id' => $project_id)); + $event->setTasks($tasks); + + $this->dispatcher->dispatch(Task::EVENT_DAILY_CRONJOB, $event); + } +} -- cgit v1.2.3 From 3fd8c5387124cba9a5a2a554f3f707a4c7525b64 Mon Sep 17 00:00:00 2001 From: Frederic Guillot Date: Thu, 28 Jan 2016 20:34:15 -0500 Subject: Remove unused use statement --- app/Console/Cronjob.php | 1 - app/Console/TaskTrigger.php | 1 - 2 files changed, 2 deletions(-) (limited to 'app/Console/TaskTrigger.php') diff --git a/app/Console/Cronjob.php b/app/Console/Cronjob.php index 2b12d93d..3a5c5596 100644 --- a/app/Console/Cronjob.php +++ b/app/Console/Cronjob.php @@ -3,7 +3,6 @@ namespace Kanboard\Console; use Symfony\Component\Console\Input\ArrayInput; -use Symfony\Component\Console\Input\InputArgument; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Output\OutputInterface; use Symfony\Component\Console\Output\NullOutput; diff --git a/app/Console/TaskTrigger.php b/app/Console/TaskTrigger.php index 000d215a..8d707211 100644 --- a/app/Console/TaskTrigger.php +++ b/app/Console/TaskTrigger.php @@ -2,7 +2,6 @@ namespace Kanboard\Console; -use Symfony\Component\Console\Input\InputArgument; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Output\OutputInterface; use Kanboard\Model\Task; -- cgit v1.2.3