Completed
Push — master ( 334094...51b7bf )
by yuuki
01:48
created

RetryOnFailureInterceptor   A

Complexity

Total Complexity 7

Size/Duplication

Total Lines 58
Duplicated Lines 0 %

Coupling/Cohesion

Components 1
Dependencies 4

Importance

Changes 0
Metric Value
wmc 7
lcom 1
cbo 4
dl 0
loc 58
rs 10
c 0
b 0
f 0

2 Methods

Rating   Name   Duplication   Size   Complexity  
A keyName() 0 4 1
B invoke() 0 34 6
1
<?php
2
3
/**
4
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
5
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
6
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
7
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
8
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
9
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
10
 * THE SOFTWARE.
11
 *
12
 * This software consists of voluntary contributions made by many individuals
13
 * and is licensed under the MIT license.
14
 *
15
 * Copyright (c) 2015-2016 Yuuki Takezawa
16
 *
17
 */
18
namespace Ytake\LaravelAspect\Interceptor;
19
20
use Ray\Aop\MethodInvocation;
21
use Ray\Aop\MethodInterceptor;
22
use Ytake\LaravelAspect\Annotation\RetryOnFailure;
23
use Ytake\LaravelAspect\Annotation\AnnotationReaderTrait;
24
25
/**
26
 * Class RetryOnFailureInterceptor
27
 */
28
class RetryOnFailureInterceptor implements MethodInterceptor
29
{
30
    use AnnotationReaderTrait;
31
32
    /** @var array|null */
33
    private static $attempt = null;
34
35
    /**
36
     * @param MethodInvocation $invocation
37
     *
38
     * @return object
39
     * @throws \Exception
40
     */
41
    public function invoke(MethodInvocation $invocation)
42
    {
43
        /** @var RetryOnFailure $annotation */
44
        $annotation = $invocation->getMethod()->getAnnotation($this->annotation);
45
        $key = $this->keyName($invocation);
46
47
        if (isset(self::$attempt[$key]) === false) {
48
            self::$attempt[$key] = $annotation->attempts;
49
        }
50
51
        try {
52
            self::$attempt[$key]--;
53
54
            return $invocation->proceed();
55
        } catch (\Exception $e) {
56
            if (ltrim($annotation->ignore, '\\') === get_class($e)) {
57
                self::$attempt[$key] = null;
58
                throw $e;
59
            }
60
61
            $pass = array_filter($annotation->types, function ($values) use ($e) {
62
                return ltrim($values, '\\') === get_class($e);
63
            });
64
            if ($pass !== false) {
65
                if (self::$attempt[$key] > 0) {
66
                    sleep($annotation->delay);
67
68
                    return $invocation->proceed();
69
                }
70
            }
71
            self::$attempt[$key] = null;
72
            throw $e;
73
        }
74
    }
75
76
    /**
77
     * @param MethodInvocation $invocation
78
     *
79
     * @return string
80
     */
81
    protected function keyName(MethodInvocation $invocation)
82
    {
83
        return $invocation->getMethod()->class . "$" . $invocation->getMethod()->getName();
0 ignored issues
show
Bug introduced by
Consider using $invocation->getMethod()->name. There is an issue with getName() and APC-enabled PHP versions.
Loading history...
84
    }
85
}
86