League\OAuth2\Server\Middleware\DeviceGrantMiddleware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	process()	0	14	2

<?php

namespace League\OAuth2\Server\Middleware;

use League\OAuth2\Server\Exception\OAuthServerException;
use League\OAuth2\Server\Repositories\DeviceAuthorizationRequestRepository;
use Psr\Http\Message\ResponseFactoryInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;

The type Psr\Http\Server\MiddlewareInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Http\Server\RequestHandlerInterface;

The type Psr\Http\Server\RequestHandlerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

class DeviceGrantMiddleware implements MiddlewareInterface
{
    private $deviceAuthorizationRequestRepository;
    private $responseFactory;

    public function __construct(
        DeviceAuthorizationRequestRepository $deviceAuthorizationRequestRepository,
        ResponseFactoryInterface $responseFactory
    ) {
        $this->deviceAuthorizationRequestRepository = $deviceAuthorizationRequestRepository;
        $this->responseFactory = $responseFactory;
    }

    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $queryParameters = $request->getQueryParams();
        $deviceCode = $queryParameters['device_code'];

        // Get the last timestamp this client requested an access code
        $lastRequestTimeStamp = $this->deviceAuthorizationRequestRepository->getLast($deviceCode);

        // If the request is within the last 5 seconds, issue a slowdown notification
        if ($lastRequestTimeStamp + 5 > \time()) {
            return OAuthServerException::slowDown()->generateHttpResponse($this->responseFactory->createResponse());
        }

        return $handler->handle($request);
    }
}