added output

Author: wachterjohannes

src/Command/ScheduleSystemTasksCommand.php

@@ -99,8 +99,10 @@ protected function execute(InputInterface $input, OutputInterface $output)
         }
 
         foreach ($this->taskRepository->findSystemTasks() as $task) {
-            if (!in_array($task->getSystemKey(), array_keys($this->systemTasks))) {
-                $this->disableTask($task);
+            if (!in_array($task->getSystemKey(), array_keys($this->systemTasks)) && ($this->disableTask($task))) {
+                $output->writeln(
+                    sprintf(' * System-task "%s" was <comment>disabled</comment>', $task->getSystemKey())
+                );
             }
         }
 
@@ -118,17 +120,17 @@ protected function execute(InputInterface $input, OutputInterface $output)
     private function processSystemTask($systemKey, array $systemTask, OutputInterface $output)
     {
         if (!$systemTask['enabled']) {
-            $this->disableSystemTask($systemKey);
-
-            $output->writeln(sprintf(' * System-task "%s" was <info>disabled</info>.', $systemKey));
+            if ($this->disableSystemTask($systemKey)) {
+                $output->writeln(sprintf(' * System-task "%s" was <comment>disabled</comment>', $systemKey));
+            }
 
             return;
         }
 
         if ($task = $this->taskRepository->findBySystemKey($systemKey)) {
             $this->updateTask($systemKey, $systemTask, $task);
 
-            $output->writeln(sprintf(' * System-task "%s" was <info>updated</info>.', $systemKey));
+            $output->writeln(sprintf(' * System-task "%s" was <info>updated</info>', $systemKey));
 
             return;
         }
@@ -142,32 +144,39 @@ private function processSystemTask($systemKey, array $systemTask, OutputInterfac
 
         $builder->schedule();
 
-        $output->writeln(sprintf(' * System-task "%s" was <info>created</info>.', $systemKey));
+        $output->writeln(sprintf(' * System-task "%s" was <info>created</info>', $systemKey));
     }
 
     /**
      * Disable task identified by system-key.
      *
      * @param string $systemKey
+     *
+     * @return bool
      */
     private function disableSystemTask($systemKey)
     {
         if (!$task = $this->taskRepository->findBySystemKey($systemKey)) {
-            return;
+            return false;
         }
 
         $this->disableTask($task);
+
+        return true;
     }
 
     /**
      * Disable given task identified.
      *
      * @param TaskInterface $task
+     *
+     * @return bool
      */
     public function disableTask(TaskInterface $task)
     {
         $task->setInterval($task->getInterval(), $task->getFirstExecution(), new \DateTime());
-        $this->abortPending($task);
+
+        return $this->abortPending($task);
     }
 
     /**
@@ -201,14 +210,18 @@ private function updateTask($systemKey, array $systemTask, TaskInterface $task)
      * Abort pending execution for given task.
      *
      * @param TaskInterface $task
+     *
+     * @return bool
      */
     private function abortPending(TaskInterface $task)
     {
         if (!$execution = $this->taskExecutionRepository->findPending($task)) {
-            return;
+            return false;
         }
 
         $execution->setStatus(TaskStatus::ABORTED);
         $this->taskExecutionRepository->save($execution);
+
+        return true;
     }
 }