QueryHandlerMiddleware::handle()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 14
Code Lines 6

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 14
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 6
nc 1
nop 2
1
<?php
2
/**
3
 * This file is part of the Cubiche package.
4
 *
5
 * Copyright (c) Cubiche
6
 *
7
 * For the full copyright and license information, please view the LICENSE
8
 * file that was distributed with this source code.
9
 */
10
namespace Cubiche\Core\Cqrs\Middlewares\Handler;
11
12
use Cubiche\Core\Bus\Middlewares\Handler\MessageHandlerMiddleware;
13
use Cubiche\Core\Cqrs\Query\QueryInterface;
14
15
/**
16
 * QueryHandlerMiddleware class.
17
 *
18
 * @author Ivannis Suárez Jerez <[email protected]>
19
 */
20
class QueryHandlerMiddleware extends MessageHandlerMiddleware
21
{
22
    /**
23
     * {@inheritdoc}
24
     */
25
    public function handle($query, callable $next)
26
    {
27
        $this->ensureTypeOfMessage($query);
28
        $handler = $this->handlerClassResolver->resolve($query);
29
30
        // get the query result
31
        $returnValue = $handler($query);
32
33
        // and pass the query result to the next middleware
34
        $returnValue = $next($returnValue);
35
36
        // return the last value
37
        return $returnValue;
38
    }
39
40
    /**
41
     * {@inheritdoc}
42
     */
43
    protected function ensureTypeOfMessage($message)
44
    {
45
        if (!$message instanceof QueryInterface) {
46
            throw new \InvalidArgumentException(
47
                sprintf(
48
                    'The object must be an instance of %s. Instance of %s given',
49
                    QueryInterface::class,
50
                    get_class($message)
51
                )
52
            );
53
        }
54
    }
55
}
56