Digia\Lumen\SnsMiddleware\Http\Middleware\AbstractMessageHandlerMiddleware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	handle()	0	12	2

<?php

namespace Digia\Lumen\SnsMiddleware\Http\Middleware;

use Closure;
use Digia\Lumen\SnsMiddleware\Http\Client\HttpClientInterface;
use Digia\Lumen\SnsMiddleware\MessageFactory;
use Illuminate\Http\Request;
use Illuminate\Http\Response;
use Jalle19\Laravel\LostInterfaces\Http\Middleware\Middleware;

/**
 * Class AbstractMessageHandlerMiddleware
 * @package Digia\Lumen\SnsMiddleware\Http\Middleware
 */
abstract class AbstractMessageHandlerMiddleware implements Middleware
{

    /**
     * @var HttpClientInterface
     */
    protected $httpClient;

    /**
     * @return string
     */
    abstract protected function getMessageType(): string;

    /**
     * HandleSubscriptionConfirmationMiddleware constructor.
     *
     * @param HttpClientInterface $httpClient
     */
    public function __construct(HttpClientInterface $httpClient)
    {
        $this->httpClient = $httpClient;
    }

    /**
     * @inheritdoc
     *
     * @throws \InvalidArgumentException
     * @throws \RuntimeException
     */
    public function handle(Request $request, Closure $next)
    {
        $message = MessageFactory::createFromRequest($request);

        if ($message['Type'] === $this->getMessageType()) {
            $this->httpClient->get((string)$message['SubscribeURL']);

            // Terminate the chain, return a response directly
            return new Response();
        }

        return $next($request);
    }
}