ProcessCallbacks::catch() - Code Metrics - spatie/async - Measure and Improve Code Quality continuously with Scrutinizer

ProcessCallbacks::catch() A
last analyzed 2020-10-12 09:06 UTC

↳ Parent: ProcessCallbacks

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
nc	1
nop	1
dl	0
loc	6
rs	10
c	0
b	0
f	0

<?php

namespace Spatie\Async\Process;

use ReflectionFunction;
use Throwable;

trait ProcessCallbacks
{
    protected $successCallbacks = [];
    protected $errorCallbacks = [];
    protected $timeoutCallbacks = [];

    public function then(callable $callback): self
    {
        $this->successCallbacks[] = $callback;

        return $this;
    }

    public function catch(callable $callback): self
    {
        $this->errorCallbacks[] = $callback;

        return $this;
    }

    public function timeout(callable $callback): self
    {
        $this->timeoutCallbacks[] = $callback;

        return $this;
    }

    public function triggerSuccess()
    {
        if ($this->getErrorOutput()) {
trait Idable {
    public function equalIds(Idable $other) {
        return $this->getId() === $other->getId();
    }
}
            $this->triggerError();

            return;
        }

        $output = $this->getOutput();
trait Idable {
    public function equalIds(Idable $other) {
        return $this->getId() === $other->getId();
    }
}

        foreach ($this->successCallbacks as $callback) {
            call_user_func_array($callback, [$output]);
        }

        return $output;
    }

    public function triggerError()
    {
        $exception = $this->resolveErrorOutput();

        if (! $this->errorCallbacks) {
            throw $exception;
        }

        foreach ($this->errorCallbacks as $callback) {
            if (! $this->isAllowedThrowableType($exception, $callback)) {
                continue;
            }

            call_user_func_array($callback, [$exception]);

            break;
        }
    }

    abstract protected function resolveErrorOutput(): Throwable;

    public function triggerTimeout()
    {
        foreach ($this->timeoutCallbacks as $callback) {
            call_user_func_array($callback, []);
        }
    }

    protected function isAllowedThrowableType(Throwable $throwable, callable $callable): bool
    {
        $reflection = new ReflectionFunction($callable);

        $parameters = $reflection->getParameters();

        if (! isset($parameters[0])) {
            return true;
        }

        $firstParameter = $parameters[0];

        if (! $firstParameter) {
            return true;
        }

        $type = $firstParameter->getType();

        if (! $type) {
            return true;
        }

        if (is_a($throwable, $type->getName())) {
            return true;
        }

        return false;
    }
}


1			<?php
2
3			namespace Spatie\Async\Process;
4
5			use ReflectionFunction;
6			use Throwable;
7
8			trait ProcessCallbacks
9			{
10			protected $successCallbacks = [];
11			protected $errorCallbacks = [];
12			protected $timeoutCallbacks = [];
13
14			public function then(callable $callback): self
15			{
16			$this->successCallbacks[] = $callback;
17
18			return $this;
19			}
20
21			public function catch(callable $callback): self
22			{
23			$this->errorCallbacks[] = $callback;
24
25			return $this;
26			}
27
28			public function timeout(callable $callback): self
29			{
30			$this->timeoutCallbacks[] = $callback;
31
32			return $this;
33			}
34
35			public function triggerSuccess()
36			{
37			if ($this->getErrorOutput()) {
			0 ignored issues – show Bug introduced 2018-01-16 07:43 UTC by Report Bug Copy Issue Report It seems like `getErrorOutput()` must be provided by classes using this trait. How about adding it as abstract method to this trait? This check looks for methods that are used by a trait but not required by it. To illustrate, let’s look at the following code example trait Idable { public function equalIds(Idable $other) { return $this->getId() === $other->getId(); } } The trait `Idable` provides a method `equalsId` that in turn relies on the method `getId()`. If this method does not exist on a class mixing in this trait, the method will fail. Adding the `getId()` as an abstract method to the trait will make sure it is available. Loading history...
38			$this->triggerError();
39
40			return;
41			}
42
43			$output = $this->getOutput();
			0 ignored issues – show Bug introduced 2018-01-16 07:43 UTC by Report Bug Copy Issue Report It seems like `getOutput()` must be provided by classes using this trait. How about adding it as abstract method to this trait? This check looks for methods that are used by a trait but not required by it. To illustrate, let’s look at the following code example trait Idable { public function equalIds(Idable $other) { return $this->getId() === $other->getId(); } } The trait `Idable` provides a method `equalsId` that in turn relies on the method `getId()`. If this method does not exist on a class mixing in this trait, the method will fail. Adding the `getId()` as an abstract method to the trait will make sure it is available. Loading history...
44
45			foreach ($this->successCallbacks as $callback) {
46			call_user_func_array($callback, [$output]);
47			}
48
49			return $output;
50			}
51
52			public function triggerError()
53			{
54			$exception = $this->resolveErrorOutput();
55
56			if (! $this->errorCallbacks) {
57			throw $exception;
58			}
59
60			foreach ($this->errorCallbacks as $callback) {
61			if (! $this->isAllowedThrowableType($exception, $callback)) {
62			continue;
63			}
64
65			call_user_func_array($callback, [$exception]);
66
67			break;
68			}
69			}
70
71			abstract protected function resolveErrorOutput(): Throwable;
72
73			public function triggerTimeout()
74			{
75			foreach ($this->timeoutCallbacks as $callback) {
76			call_user_func_array($callback, []);
77			}
78			}
79
80			protected function isAllowedThrowableType(Throwable $throwable, callable $callable): bool
81			{
82			$reflection = new ReflectionFunction($callable);
83
84			$parameters = $reflection->getParameters();
85
86			if (! isset($parameters[0])) {
87			return true;
88			}
89
90			$firstParameter = $parameters[0];
91
92			if (! $firstParameter) {
93			return true;
94			}
95
96			$type = $firstParameter->getType();
97
98			if (! $type) {
99			return true;
100			}
101
102			if (is_a($throwable, $type->getName())) {
103			return true;
104			}
105
106			return false;
107			}
108			}
109

spatie / async

GitHub Access Token became invalid

ProcessCallbacks::catch() A last analyzed 2020-10-12 09:06 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

ProcessCallbacks::catch() A
last analyzed 2020-10-12 09:06 UTC