delboy1978uk / bone-user

src/Http/Middleware/SessionAuth.php

<?php

namespace Bone\User\Http\Middleware;

use Bone\Http\Response;
use Bone\Paseto\PasetoService;
use Bone\Server\SessionAwareInterface;
use Bone\Server\Traits\HasSessionTrait;
use Del\Exception\UserException;
use Del\Service\UserService;
use Del\SessionManager;
use Exception;
use Laminas\Diactoros\Response\RedirectResponse;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

class SessionAuth implements MiddlewareInterface, SessionAwareInterface
{
    use HasSessionTrait;

    /** @var UserService $userService */
    private $userService;

    /** @var PasetoService $pasetoService */
    private $pasetoService;

    /** @var string $redirectUrl */
    private $redirectUrl;

    public function __construct(SessionManager $sessionManager, UserService $userService, PasetoService $pasetoService, $redirectUrl = '/user/home')
    {
        $this->setSession($sessionManager);
        $this->userService = $userService;
        $this->pasetoService = $pasetoService;
        $this->redirectUrl = $redirectUrl;
    }

    /**
     * @param ServerRequestInterface $request
     * @param RequestHandlerInterface $handler
     * @return ResponseInterface
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $cookies = $request->getCookieParams();
        $id = $this->getSession()->get('user');

        if (!$id && isset($cookies['resu'])) {
            $string = $cookies['resu'];

            try {
                $token = $this->pasetoService->decryptToken($string);
                $id = $token->getClaims()['user'];
                $this->getSession()->set('user', $id);
            } catch (Exception $e) {
                return new RedirectResponse($this->redirectUrl);
            }
        }

        if ($id) {
            $user = $this->userService->findUserById($id);
            $request = $request->withAttribute('user', $user);
            $response = $handler->handle($request);

            if ($response instanceof Response) {
                $response->setAttribute('user', $user);
            }

            $person = $user->getPerson();
            $person = $this->userService->getPersonSvc()->toArray($person);

The function Del\Service\UserService::getPersonSvc() has been deprecated: use getPersonService() instead

            $userArray = $this->userService->toArray($user);

It seems like $user can also be of type null; however, parameter $user of Del\Service\UserService::toArray() does only seem to accept Del\Entity\UserInterface, maybe add an additional type check?

            $userArray['person'] = $person;

            return $response->withHeader('user', json_encode($userArray));

The expression return $response->withHeader('user', json_encode($userArray)) returns the type Psr\Http\Message\MessageInterface which includes types incompatible with the type-hinted return Psr\Http\Message\ResponseInterface.

        }

        throw new UserException(UserException::UNAUTHORISED, 401);
    }
}