Balloon\App\Office\Api\v2\Sessions

Complexity

Total Complexity

6

Size/Duplication

Total Lines	169
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	post()	0	18	1
A	postJoin()	0	15	1
A	delete()	0	8	1
A	parseId()	0	8	2

<?php

declare(strict_types=1);

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

namespace Balloon\App\Office\Api\v2;

use Balloon\App\Api\Controller;
use Balloon\App\Office\Constructor\Http as App;
use Balloon\App\Office\Document;
use Balloon\App\Office\Session as WopiSession;
use Balloon\App\Office\Session\Member;
use Balloon\Exception;
use Balloon\Filesystem;
use Balloon\Filesystem\Node\File;
use Balloon\Server;
use Micro\Http\Response;
use MongoDB\BSON\ObjectId;

class Sessions extends Controller
{
    /**
     * App.
     *
     * @var App
     */
    protected $app;

    /**
     * Filesystem.
     *
     * @var Filesystem
     */
    protected $fs;

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

    /**
     * Constructor.
     *
     * @param App    $app
     * @param Server $server
     */
    public function __construct(App $app, Server $server)
    {
        $this->server = $server;
        $this->fs = $server->getFilesystem();
        $this->app = $app;
    }

    /**
     * @api {post} /api/v2/office/sessions Create session
     * @apiName post
     * @apiVersion 2.0.0
     * @apiGroup App\Office
     * @apiPermission none
     * @apiUse _getNode
     * @apiDescription Create new session for a document
     *
     * @apiExample (cURL) example:
     * curl -XPOST "https://SERVER/api/v2/office/session?id=58a18a4ca271f962af6fdbc4"
     *
     * @apiSuccessExample {json} Success-Response:
     * HTTP/1.1 201 Created
     * {
     *      "id": "544627ed3c58891f058bbbaa",
     *      "wopi_url": "https://localhost",
     *      "access_token": "544627ed3c58891f058b4622",
     *      "access_token_ttl": "1486989000"
     * }
     *
     * @param string $id
     * @param string $p
     *
     * @return Response
     */
    public function post(?string $id = null, ?string $p = null): Response
    {
        $node = $this->fs->getNode($id, $p, File::class);
        $document = new Document($this->fs->getDatabase(), $node);

$node of type object<Balloon\Filesystem\Node\NodeInterface> is not a sub-type of object<Balloon\Filesystem\Node\File>. It seems like you assume a concrete implementation of the interface Balloon\Filesystem\Node\NodeInterface to be always present.

        $ttl = $this->app->getTokenTtl();

        $session = new WopiSession($this->fs, $document, $ttl);
        $member = new Member($this->fs->getUser(), $ttl);
        $session->join($member)
                ->store();

        return (new Response())->setCode(201)->setBody([
            'id' => (string) $session->getId(),
            'wopi_url' => $this->app->getWopiUrl(),
            'access_token' => $member->getAccessToken(),
            'access_token_ttl' => ($member->getTTL()->toDateTime()->format('U') * 1000),
        ]);
    }

    /**
     * @api {post} /api/v2/office/sessions/:id/join Join session
     * @apiName postJoin
     * @apiVersion 2.0.0
     * @apiGroup App\Office
     * @apiPermission none
     * @apiDescription Join running session
     * @apiParam (GET Parameter) {string} session_id The session id to join to
     *
     * @apiExample (cURL) example:
     * curl -XPOST "https://SERVER/api/v2/office/session/join?session_id=58a18a4ca271f962af6fdbc4"
     *
     * @apiSuccessExample {json} Success-Response:
     * HTTP/1.1 200 OK
     * {
     *      "id": "544627ed3c58891f058bbbaa",
     *      "wopi_url": "https://localhost",
     *      "access_token": "544627ed3c58891f058b4622",
     *      "access_token_ttl": "1486989000"
     * }
     *
     * @param string $id
     *
     * @return Response
     */
    public function postJoin(string $id): Response
    {
        $session = WopiSession::getSessionById($this->fs, $this->parseId($id));
        $ttl = $this->app->getTokenTtl();
        $member = new Member($this->fs->getUser(), $ttl);
        $session->join($member)
                ->store();

        return (new Response())->setCode(200)->setBody([
            'id' => (string) $session->getId(),
            'wopi_url' => $this->app->getWopiUrl(),
            'access_token' => $member->getAccessToken(),
            'access_token_ttl' => ($member->getTTL()->toDateTime()->format('U') * 1000),
        ]);
    }

    /**
     * @api {delete} /api/v2/office/session/:id Delete session
     * @apiName delete
     * @apiVersion 2.0.0
     * @apiGroup App\Office
     * @apiPermission none
     * @apiDescription Delete a running session. If more members are active in the requested session than only the membership gets removed.
     * The session gets completely removed if only one member exists.
     * @apiParam (GET Parameter) {string} session_id The session id to delete
     * @apiParam (GET Parameter) {string} access_token Access token
     *
     * @apiExample (cURL) example:
     * curl -XDELETE "https://SERVER/api/v2/office/session?session_id=58a18a4ca271f962af6fdbc4&access_token=97223329239823bj223232323"
     *
     * @apiSuccessExample {json} Success-Response:
     * HTTP/1.1 204 OK
     *
     * @param string $id
     * @param string $access_token
     *
     * @return Response
     */
    public function delete(string $id, string $access_token): Response
    {
        $session = WopiSession::getByAccessToken($this->server, $this->parseId($id), $access_token);
        $session->leave($this->fs->getUser())
                ->store();

        return (new Response())->setCode(204);
    }

    /**
     * Parse id.
     *
     * @param string $id
     *
     * @return ObjectId
     */
    protected function parseId(string $id): ObjectId
    {
        try {
            return new ObjectId($id);
        } catch (\Exception $e) {
            throw new Exception\InvalidArgument('bad session id given');
        }
    }
}