Yoshi2889 / tasks

src/TaskInterface.php

Indentation +13 added lines, -13 removed lines

@@ -12,19 +12,19 @@
 
 interface TaskInterface
 {
-	/**
-	 * @return int
-	 */
-	public function getExpiryTime(): int;
+    /**
+     * @return int
+     */
+    public function getExpiryTime(): int;
 
-	/**
-	 * Pass back a new instance of TaskInterface to run a new task.
-	 * @return null|TaskInterface
-	 */
-	public function run(): ?TaskInterface;
+    /**
+     * Pass back a new instance of TaskInterface to run a new task.
+     * @return null|TaskInterface
+     */
+    public function run(): ?TaskInterface;
 
-	/**
-	 * @return void
-	 */
-	public function cancel(): void;
+    /**
+     * @return void
+     */
+    public function cancel(): void;
 }
\ No newline at end of file

src/TaskController.php

Braces +12 added lines, -8 removed lines

@@ -40,8 +40,9 @@ 
 	 */
 	public function add(TaskInterface $task): bool
 	{
-		if ($this->exists($task))
-			return false;
+		if ($this->exists($task)) {
+					return false;
+		}
 
 		$this->tasks[] = $task;
 
@@ -55,8 +56,9 @@ 
 	 */
 	public function remove(TaskInterface $task): bool
 	{
-		if (!$this->exists($task))
-			return false;
+		if (!$this->exists($task)) {
+					return false;
+		}
 
 		unset($this->tasks[array_search($task, $this->tasks)]);
 
@@ -77,16 +79,18 @@ 
 	{
 		foreach ($this->tasks as $task)
 		{
-			if (time() < $task->getExpiryTime())
-				continue;
+			if (time() < $task->getExpiryTime()) {
+							continue;
+			}
 
 			$result = $task->run();
 
 			// It is removed first.
 			$this->remove($task);
 
-			if ($result instanceof TaskInterface)
-				$this->add($result);
+			if ($result instanceof TaskInterface) {
+							$this->add($result);
+			}
 		}
 	}
 }
\ No newline at end of file

Indentation +77 added lines, -77 removed lines

@@ -13,55 +13,55 @@ 
 
 class TaskController
 {
-	/**
-	 * @var int
-	 */
-	protected $loopInterval = 1;
-
-	/**
-	 * @var TaskInterface[]
-	 */
-	protected $tasks = [];
-
-	/**
-	 * TaskController constructor.
-	 *
-	 * @param LoopInterface $loop
-	 */
-	public function __construct(LoopInterface $loop)
-	{
-		$loop->addPeriodicTimer($this->loopInterval, [$this, 'runTasks']);
-	}
-
-	/**
-	 * @param TaskInterface $task
-	 *
-	 * @return bool
-	 */
-	public function add(TaskInterface $task): bool
-	{
-		if ($this->exists($task))
-			return false;
-
-		$this->tasks[] = $task;
-
-		return true;
-	}
-
-	/**
-	 * @param TaskInterface $task
-	 *
-	 * @return bool
-	 */
-	public function remove(TaskInterface $task): bool
-	{
-		if (!$this->exists($task))
-			return false;
-
-		unset($this->tasks[array_search($task, $this->tasks)]);
-
-		return true;
-	}
+    /**
+     * @var int
+     */
+    protected $loopInterval = 1;
+
+    /**
+     * @var TaskInterface[]
+     */
+    protected $tasks = [];
+
+    /**
+     * TaskController constructor.
+     *
+     * @param LoopInterface $loop
+     */
+    public function __construct(LoopInterface $loop)
+    {
+        $loop->addPeriodicTimer($this->loopInterval, [$this, 'runTasks']);
+    }
+
+    /**
+     * @param TaskInterface $task
+     *
+     * @return bool
+     */
+    public function add(TaskInterface $task): bool
+    {
+        if ($this->exists($task))
+            return false;
+
+        $this->tasks[] = $task;
+
+        return true;
+    }
+
+    /**
+     * @param TaskInterface $task
+     *
+     * @return bool
+     */
+    public function remove(TaskInterface $task): bool
+    {
+        if (!$this->exists($task))
+            return false;
+
+        unset($this->tasks[array_search($task, $this->tasks)]);
+
+        return true;
+    }
 
     public function removeAll()
     {
@@ -70,32 +70,32 @@ 
             $task->cancel();
             $this->remove($task);
         }
-	}
-
-	/**
-	 * @param TaskInterface $task
-	 *
-	 * @return bool
-	 */
-	public function exists(TaskInterface $task): bool
-	{
-		return in_array($task, $this->tasks);
-	}
-
-	public function runTasks()
-	{
-		foreach ($this->tasks as $task)
-		{
-			if (time() < $task->getExpiryTime())
-				continue;
-
-			$result = $task->run();
-
-			// It is removed first.
-			$this->remove($task);
-
-			if ($result instanceof TaskInterface)
-				$this->add($result);
-		}
-	}
+    }
+
+    /**
+     * @param TaskInterface $task
+     *
+     * @return bool
+     */
+    public function exists(TaskInterface $task): bool
+    {
+        return in_array($task, $this->tasks);
+    }
+
+    public function runTasks()
+    {
+        foreach ($this->tasks as $task)
+        {
+            if (time() < $task->getExpiryTime())
+                continue;
+
+            $result = $task->run();
+
+            // It is removed first.
+            $this->remove($task);
+
+            if ($result instanceof TaskInterface)
+                $this->add($result);
+        }
+    }
 }
\ No newline at end of file

src/RepeatableTask.php

Doc Comments +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
 	}
 
 	/**
-	 * @return null|TaskInterface
+	 * @return RepeatableTask|null
 	 */
 	public function run(): ?TaskInterface
 	{

Indentation +65 added lines, -65 removed lines

@@ -12,79 +12,79 @@
 
 class RepeatableTask implements TaskInterface
 {
-	/**
-	 * @var int
-	 */
-	protected $repeatInterval = 0;
+    /**
+     * @var int
+     */
+    protected $repeatInterval = 0;
 
-	/**
-	 * @var int
-	 */
-	protected $expiryTime = 0;
+    /**
+     * @var int
+     */
+    protected $expiryTime = 0;
 
-	/**
-	 * @var TaskInterface
-	 */
-	protected $childTask;
+    /**
+     * @var TaskInterface
+     */
+    protected $childTask;
 
-	/**
-	 * RepeatableTask constructor.
-	 *
-	 * @param TaskInterface $childTask
-	 * @param int $repeatInterval
-	 */
-	public function __construct(TaskInterface $childTask, int $repeatInterval)
-	{
-		$this->expiryTime = time() + $repeatInterval;
-		$this->repeatInterval = $repeatInterval;
-		$this->childTask = $childTask;
-	}
+    /**
+     * RepeatableTask constructor.
+     *
+     * @param TaskInterface $childTask
+     * @param int $repeatInterval
+     */
+    public function __construct(TaskInterface $childTask, int $repeatInterval)
+    {
+        $this->expiryTime = time() + $repeatInterval;
+        $this->repeatInterval = $repeatInterval;
+        $this->childTask = $childTask;
+    }
 
-	/**
-	 * @return null|TaskInterface
-	 */
-	public function run(): ?TaskInterface
-	{
-		if (time() >= $this->childTask->getExpiryTime())
-		{
-			$result = $this->childTask->run();
+    /**
+     * @return null|TaskInterface
+     */
+    public function run(): ?TaskInterface
+    {
+        if (time() >= $this->childTask->getExpiryTime())
+        {
+            $result = $this->childTask->run();
 
-			if ($result instanceof TaskInterface)
-				$this->childTask = $result;
-		}
+            if ($result instanceof TaskInterface)
+                $this->childTask = $result;
+        }
 
-		$this->expiryTime = $this->getExpiryTime() + $this->getRepeatInterval();
-		return $this->expiryTime > 0 ? $this : null;
-	}
+        $this->expiryTime = $this->getExpiryTime() + $this->getRepeatInterval();
+        return $this->expiryTime > 0 ? $this : null;
+    }
 
-	public function cancel(): void
-	{
-		$this->childTask->cancel();
-		$this->repeatInterval = 0;
-		$this->expiryTime = 0;
-	}
+    public function cancel(): void
+    {
+        $this->childTask->cancel();
+        $this->repeatInterval = 0;
+        $this->expiryTime = 0;
+    }
 
-	/**
-	 * @return int
-	 */
-	public function getRepeatInterval(): int
-	{
-		return $this->repeatInterval;
-	}
+    /**
+     * @return int
+     */
+    public function getRepeatInterval(): int
+    {
+        return $this->repeatInterval;
+    }
 
-	/**
-	 * @param int $repeatInterval
-	 */
-	public function setRepeatInterval(int $repeatInterval)
-	{
-		$this->repeatInterval = $repeatInterval;
-	}
+    /**
+     * @param int $repeatInterval
+     */
+    public function setRepeatInterval(int $repeatInterval)
+    {
+        $this->repeatInterval = $repeatInterval;
+    }
 
-	/**
-	 * @return int
-	 */
-	public function getExpiryTime(): int
-	{
-		return $this->expiryTime;
-	}
+    /**
+     * @return int
+     */
+    public function getExpiryTime(): int
+    {
+        return $this->expiryTime;
+    }
 }
\ No newline at end of file

Braces +4 added lines, -4 removed lines

@@ -45,12 +45,12 @@
 	 */
 	public function run(): ?TaskInterface
 	{
-		if (time() >= $this->childTask->getExpiryTime())
-		{
+		if (time() >= $this->childTask->getExpiryTime()) {
 			$result = $this->childTask->run();
 
-			if ($result instanceof TaskInterface)
-				$this->childTask = $result;
+			if ($result instanceof TaskInterface) {
+							$this->childTask = $result;
+			}
 		}
 
 		$this->expiryTime = $this->getExpiryTime() + $this->getRepeatInterval();

src/CallbackTask.php

Indentation +84 added lines, -84 removed lines

@@ -11,90 +11,90 @@
 
 class CallbackTask implements TaskInterface
 {
-	/**
-	 * @var callable
-	 */
-	protected $callback = null;
-
-	/**
-	 * @var int
-	 */
-	protected $expiryTime = 0;
-
-	/**
-	 * @var array
-	 */
-	protected $storedArguments = [];
-
-	/**
-	 * CallbackTask constructor.
-	 *
-	 * @param callable $callback
-	 * @param int $time
-	 * @param array $args
-	 */
-	public function __construct(callable $callback, int $time, array $args = [])
-	{
-		$this->callback = $callback;
-		$this->setExpiryTime(time() + $time);
-		$this->setStoredArguments($args);
-	}
-
-	public function run(): ?TaskInterface
-	{
-		$result = call_user_func_array($this->getCallback(), $this->getStoredArguments());
-
-		if (!($result instanceof TaskInterface))
-			return null;
-
-		return $result;
-	}
-
-	public function cancel(): void
-	{
-		$this->callback = function () {};
-		$this->setExpiryTime(0);
-	}
-
-	/**
-	 * @return callable
-	 */
-	public function getCallback(): callable
-	{
-		return $this->callback;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getExpiryTime(): int
-	{
-		return $this->expiryTime;
-	}
-
-	/**
-	 * @param int $expiryTime
-	 */
-	public function setExpiryTime(int $expiryTime)
-	{
-		$this->expiryTime = $expiryTime;
-	}
-
-	/**
-	 * @return array
-	 */
-	public function getStoredArguments(): array
-	{
-		return $this->storedArguments;
-	}
-
-	/**
-	 * @param array $storedArguments
-	 */
-	public function setStoredArguments(array $storedArguments)
-	{
-		$this->storedArguments = $storedArguments;
-	}
+    /**
+     * @var callable
+     */
+    protected $callback = null;
+
+    /**
+     * @var int
+     */
+    protected $expiryTime = 0;
+
+    /**
+     * @var array
+     */
+    protected $storedArguments = [];
+
+    /**
+     * CallbackTask constructor.
+     *
+     * @param callable $callback
+     * @param int $time
+     * @param array $args
+     */
+    public function __construct(callable $callback, int $time, array $args = [])
+    {
+        $this->callback = $callback;
+        $this->setExpiryTime(time() + $time);
+        $this->setStoredArguments($args);
+    }
+
+    public function run(): ?TaskInterface
+    {
+        $result = call_user_func_array($this->getCallback(), $this->getStoredArguments());
+
+        if (!($result instanceof TaskInterface))
+            return null;
+
+        return $result;
+    }
+
+    public function cancel(): void
+    {
+        $this->callback = function () {};
+        $this->setExpiryTime(0);
+    }
+
+    /**
+     * @return callable
+     */
+    public function getCallback(): callable
+    {
+        return $this->callback;
+    }
+
+    /**
+     * @return int
+     */
+    public function getExpiryTime(): int
+    {
+        return $this->expiryTime;
+    }
+
+    /**
+     * @param int $expiryTime
+     */
+    public function setExpiryTime(int $expiryTime)
+    {
+        $this->expiryTime = $expiryTime;
+    }
+
+    /**
+     * @return array
+     */
+    public function getStoredArguments(): array
+    {
+        return $this->storedArguments;
+    }
+
+    /**
+     * @param array $storedArguments
+     */
+    public function setStoredArguments(array $storedArguments)
+    {
+        $this->storedArguments = $storedArguments;
+    }
 
 
 }
\ No newline at end of file

Braces +6 added lines, -3 removed lines

@@ -44,15 +44,18 @@
 	{
 		$result = call_user_func_array($this->getCallback(), $this->getStoredArguments());
 
-		if (!($result instanceof TaskInterface))
-			return null;
+		if (!($result instanceof TaskInterface)) {
+					return null;
+		}
 
 		return $result;
 	}
 
 	public function cancel(): void
 	{
-		$this->callback = function () {};
+		$this->callback = function ()
+		{
+};
 		$this->setExpiryTime(0);
 	}