Libcast\AssetDistributor\Vimeo\VimeoAdapter

Complexity

Total Complexity

20

Size/Duplication

Total Lines	146
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes	5
Bugs	1	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getVendor()	0	4	1
B	getClient()	0	24	4
B	authenticate()	0	54	8
A	support()	0	8	2
A	upload()	0	15	3
A	update()	0	4	1
A	remove()	0	4	1

<?php

namespace Libcast\AssetDistributor\Vimeo;

use Libcast\AssetDistributor\Adapter\AbstractAdapter;
use Libcast\AssetDistributor\Adapter\Adapter;
use Libcast\AssetDistributor\Asset\Asset;
use Libcast\AssetDistributor\Asset\Video;
use Libcast\AssetDistributor\Request;
use Symfony\Component\HttpFoundation\Session\Session;
use Vimeo\Vimeo;

class VimeoAdapter extends AbstractAdapter implements Adapter
{
    /**
     *
     * @return string
     * @throws \Exception
     */
    public function getVendor()
    {
        return 'Vimeo';
    }

    /**
     *
     * @return Vimeo
     */
    public function getClient()
    {
        if ($this->client) {
            return $this->client;
        }

        $client = new Vimeo(
            $this->getConfiguration('id'),
            $this->getConfiguration('secret')
        );

        if ($token = $this->getCredentials()) {
            $client->setToken($token);
            $this->isAuthenticated = true;
        }

        $this->client = $client; // Now getClient() returns \Vimeo\Vimeo

        if (!$this->isAuthenticated()) {
            $this->authenticate();
        }

        return $this->client;
    }

    /**
     * {@inheritdoc}
     */
    public function authenticate()
    {
        $client = $this->getClient();
        $request = Request::get();
        $session = new Session;

        if ($code = $request->query->get('code')) {
            if (!$requestState = $request->query->get('state')) {
                throw new \Exception('Missing state from Vimeo request');
            }

            if (!$sessionState = $session->get('vimeo_state')) {
                throw new \Exception('Missing state from Vimeo session');
            }

            if (strval($requestState) !== strval($sessionState)) {
                throw new \Exception('Vimeo session state and request state don\'t match');
            }

            $this->debug('Found Vimeo oAuth code', ['code' => $code]);
            $response = $client->accessToken($code, $this->getConfiguration('redirectUri'));

            if (200 === $response['status'] and $token = $response['body']['access_token']) {
                $this->debug('Found Vimeo oAuth token', ['token' => $token]);
                $client->setToken($token);
                $this->setCredentials($token);
            } else {
                $this->error('Vimeo authentication failed', $response);
                throw new \Exception('Vimeo authentication failed');
            }
        }

        if (!$client->getToken()) {
            $this->debug('Missing Vimeo token, try to authenticate...');

            $state = mt_rand();
            $session->set('vimeo_state', $state);

            $this->redirect($client->buildAuthorizationEndpoint(
                $this->getConfiguration('redirectUri'),
                $this->getConfiguration('scopes'),
                $state
            ));
        }

        // Clean query parameters as they may cause error
        // on other Adapter's authentication process
        $request->query->set('code', null);
        $request->query->set('state', null);

        $this->debug('Vimeo account is authenticated');

        $this->isAuthenticated = true;
    }

    /**
     * {@inheritdoc}
     */
    public static function support(Asset $asset)
    {
        if (!$asset instanceof Video) {
            return false;
        }

        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function upload(Asset $asset)
    {
        if (!self::support($asset)) {
            throw new \Exception('Vimeo adapter only handles video assets');
        }

        if (!is_null($this->retrieve($asset))) {
            $this->update($asset);
            return;
        }

        $uri = $this->getClient()->upload($asset->getPath());

        $this->remember($asset, $uri);
    }

    /**
     * {@inheritdoc}
     */
    public function update(Asset $asset)
    {
        /** @todo implement update */
    }

    /**
     * {@inheritdoc}
     */
    public function remove(Asset $asset)
    {
        /** @todo implement remove */
    }
}