AbstractMessageHandlerMiddleware::handle()   A
last analyzed

Complexity

Conditions 2
Paths 2

Size

Total Lines 12
Code Lines 5

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
eloc 5
c 1
b 0
f 0
dl 0
loc 12
rs 10
cc 2
nc 2
nop 2
1
<?php
2
3
namespace Digia\Lumen\SnsMiddleware\Http\Middleware;
4
5
use Closure;
6
use Digia\Lumen\SnsMiddleware\Http\Client\HttpClientInterface;
7
use Digia\Lumen\SnsMiddleware\MessageFactory;
8
use Illuminate\Http\Request;
9
use Illuminate\Http\Response;
10
use Jalle19\Laravel\LostInterfaces\Http\Middleware\Middleware;
11
12
/**
13
 * Class AbstractMessageHandlerMiddleware
14
 * @package Digia\Lumen\SnsMiddleware\Http\Middleware
15
 */
16
abstract class AbstractMessageHandlerMiddleware implements Middleware
17
{
18
19
    /**
20
     * @var HttpClientInterface
21
     */
22
    protected $httpClient;
23
24
    /**
25
     * @return string
26
     */
27
    abstract protected function getMessageType(): string;
28
29
    /**
30
     * HandleSubscriptionConfirmationMiddleware constructor.
31
     *
32
     * @param HttpClientInterface $httpClient
33
     */
34
    public function __construct(HttpClientInterface $httpClient)
35
    {
36
        $this->httpClient = $httpClient;
37
    }
38
39
    /**
40
     * @inheritdoc
41
     *
42
     * @throws \InvalidArgumentException
43
     * @throws \RuntimeException
44
     */
45
    public function handle(Request $request, Closure $next)
46
    {
47
        $message = MessageFactory::createFromRequest($request);
48
49
        if ($message['Type'] === $this->getMessageType()) {
50
            $this->httpClient->get((string)$message['SubscribeURL']);
51
52
            // Terminate the chain, return a response directly
53
            return new Response();
54
        }
55
56
        return $next($request);
57
    }
58
}
59