Balloon\App\Wopi\SessionManager

Complexity

Total Complexity

10

Size/Duplication

Total Lines	125
Duplicated Lines	12 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	setOptions()	15	15	3
A	authenticate()	0	15	2
A	getByToken()	0	18	2
A	create()	0	14	1
A	createToken()	0	4	1

<?php

declare(strict_types=1);

/**
 * balloon
 *
 * @copyright   Copryright (c) 2012-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\App\Wopi;

use Balloon\App\Wopi\Session\Session;
use Balloon\App\Wopi\Session\SessionInterface;
use Balloon\Filesystem\Exception;
use Balloon\Filesystem\Node\File;
use Balloon\Server;
use Balloon\Server\User;
use InvalidArgumentException;
use MongoDB\BSON\UTCDateTime;
use MongoDB\Database;

class SessionManager
{
    /**
     * Valid until.
     *
     * @var int
     */
    protected $access_token_ttl = 3600;

    /**
     * Database.
     *
     * @var Database
     */
    protected $db;

    /**
     * Host manager.
     *
     * @var HostManager
     */
    protected $host_manager;

    /**
     * Server.
     */
    protected $server;

    /**
     * Session.
     */
    public function __construct(Database $db, Server $server, HostManager $host_manager, array $config = [])
    {
        $this->db = $db;
        $this->server = $server;
        $this->host_manager = $host_manager;
        $this->setOptions($config);
    }

    /**
     * Set options.
     */
    public function setOptions(array $config = []): SessionManager

This method seems to be duplicated in your project.

    {
        foreach ($config as $option => $value) {
            switch ($option) {
                case 'access_token_ttl':
                    $this->access_token_ttl = (int) $value;

                    break;
                default:
                    throw new InvalidArgumentException('invalid option '.$option.' given');
            }
        }

        return $this;
    }

    /**
     * Authenticate.
     */
    public function authenticate(string $token): User
    {
        $result = $this->db->wopi->findOne([
            'token' => $token,
            'ttl' => [
                '$gte' => new UTCDateTime(),
            ],
        ]);

        if (null === $result) {
            throw new Exception\Forbidden('token is not valid for the requested node');
        }

        return $this->server->getUserById($result['user']);
    }

    /**
     * Get session by id.
     */
    public function getByToken(File $file, string $token): SessionInterface
    {
        $result = $this->db->wopi->findOne([
            'token' => $token,
            'ttl' => [
                '$gte' => new UTCDateTime(),
            ],
        ]);

        if (null === $result) {
            throw new Exception\Forbidden('session does not exists');
        }

        $result['client'] = $this->host_manager->getClientUrl();
        $user = $this->server->getUserById($result['user']);

        return new Session($file, $user, $result);
    }

    /**
     * Create session.
     */
    public function create(File $file, User $user): SessionInterface
    {
        $data = [
            'token' => $this->createToken(),
            'ttl' => new UTCDateTime((time() + $this->access_token_ttl) * 1000),
            'user' => $user->getId(),
            'node' => $file->getId(),
        ];

        $this->db->wopi->insertOne($data);
        $data['client'] = $this->host_manager->getClientUrl();

        return new Session($file, $user, $data);
    }

    /**
     * Create token.
     */
    protected function createToken(): string
    {
        return bin2hex(random_bytes(32));
    }
}