xabbuh / PandaBundle

Controller/Controller.php

<?php

/*
 * This file is part of the XabbuhPandaBundle package.
 *
 * (c) Christian Flothmann <christian.flothmann@xabbuh.de>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Xabbuh\PandaBundle\Controller;

use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface as ConstractsEventDispatcherInterface;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Xabbuh\PandaBundle\Event\EventFactory;
use Xabbuh\PandaClient\Api\CloudManagerInterface;
use Xabbuh\PandaClient\Signer\PandaSigner;

/**
 * XabbuhPandaBundle controllers.
 *
 * @author Christian Flothmann <christian.flothmann@xabbuh.de>
 */
class Controller
{
    /**
     * @var CloudManagerInterface
     */
    private $cloudManager;

    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

    /**
     * @param CloudManagerInterface    $cloudManager
     * @param EventDispatcherInterface $eventDispatcher
     */
    public function __construct(CloudManagerInterface $cloudManager, EventDispatcherInterface $eventDispatcher)
    {
        $this->cloudManager = $cloudManager;
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * Sign a set of given url parameters and return them as a JSON object.
     *
     * Specials keys are <em>method</em> and <em>path</em>. <em>method</em> is
     * the http method and <em>path</em> the url part of the api request for
     * which the signature is generated. The default <em>method</em> if not
     * given is <em>GET</em>, the default <em>path</em> is <em>/videos.json</em>.
     * All remaining url parameters are treated as parameters for the api
     * request.
     *
     * @param string  $cloud   Cloud to use for performing API requests
     * @param Request $request The current request
     *
     * @return JsonResponse The response
     */
    public function signAction($cloud, Request $request)
    {
        $params = $request->query->all();

        if (isset($params['method'])) {
            $method = $params['method'];
            unset($params['method']);
        } else {
            $method = 'GET';
        }

        if (isset($params['path'])) {
            $path = $params['path'];
            unset($params['path']);
        } else {
            $path = '/videos.json';
        }

        $httpClient = $this->cloudManager->getCloud($cloud)->getHttpClient();
        $cloudId = $httpClient->getCloudId();
        $account = $httpClient->getAccount();
        $signer = PandaSigner::getInstance($cloudId, $account);

        return new JsonResponse($signer->signParams($method, $path, $params));
    }

    /**
     * Authorize a file upload.
     *
     * The name of the file to upload and its size are passed as POST parameters.
     * The response contains a JSON encoded object. It includes a property
     * upload_url to which the caller should send its video file.
     *
     * @param string  $cloud   Cloud to use for performing API requests
     * @param Request $request The current request
     *
     * @return JsonResponse The response
     */
    public function authoriseUploadAction($cloud, Request $request)
    {
        $payload = json_decode($request->request->get('payload'));
        $upload = $this->cloudManager
            ->getCloud($cloud)
            ->registerUpload(
                $payload->filename,
                $payload->filesize,
                null,
                true
            );

        return new JsonResponse(array('upload_url' => $upload->location));
    }

    /**
     * Endpoint for notification requests.
     *
     * @param Request $request The current request
     *
     * @return Response An empty response with status code 200
     */
    public function notifyAction(Request $request)
    {
        try {
            $event = EventFactory::createEventFromRequest($request);

            if ($this->eventDispatcher instanceof ConstractsEventDispatcherInterface) {
                $this->eventDispatcher->dispatch($event, constant(get_class($event).'::NAME'));

$event is of type object<Xabbuh\PandaBundle\Event\VideoCreatedEvent>|object<Xabbuh\PandaBundle\Event\VideoEncodedEvent>|object<Xabbuh\PandaBundle\Event\EncodingProgressEvent>|object<Xabbuh\PandaBundle\Event\EncodingCompleteEvent>, but the function expects a object<Symfony\Contracts\EventDispatcher\object>.

            } else {
                $this->eventDispatcher->dispatch(constant(get_class($event).'::NAME'), $event);
            }

            return new Response('');
        } catch (\InvalidArgumentException $e) {
            return new Response($e->getMessage(), 400);
        }
    }
}