src/Pumukit/WebTVBundle/Controller/DefaultController.php line 325

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Pumukit\WebTVBundle\Controller;
  7. use Detection\MobileDetect;
  8. use Doctrine\ODM\MongoDB\DocumentManager;
  9. use MongoDB\BSON\ObjectId;
  10. use Psr\Log\LoggerInterface;
  11. use Pumukit\SchemaBundle\Document\EmbeddedBroadcast;
  12. use Pumukit\SchemaBundle\Document\Live;
  13. use Pumukit\SchemaBundle\Document\MultimediaObject;
  14. use Pumukit\SchemaBundle\Services\EmbeddedEventSessionService;
  15. use Pumukit\WebTVBundle\Form\Type\ContactType;
  16. use Pumukit\WebTVBundle\PumukitWebTVBundle;
  17. use Pumukit\WebTVBundle\Services\BreadcrumbsService;
  18. use Sensio\Bundle\FrameworkExtraBundle\Configuration\ParamConverter;
  19. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  20. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  21. use Symfony\Component\HttpFoundation\JsonResponse;
  22. use Symfony\Component\HttpFoundation\Request;
  23. use Symfony\Component\HttpFoundation\Response;
  24. use Symfony\Component\Routing\Annotation\Route;
  25. use Symfony\Contracts\Translation\TranslatorInterface;
  27. class DefaultController extends AbstractController
  28. {
  29.     protected $documentManager;
  30.     protected $breadcrumbService;
  31.     protected $embeddedEventSessionService;
  32.     protected $translator;
  33.     protected $logger;
  34.     protected $mailer;
  35.     protected $captchaPublicKey;
  36.     protected $captchaPrivateKey;
  37.     protected $pumukitLiveEventContactAndShare;
  38.     protected $pumukitIntro;
  39.     protected $pumukitNotificationSenderEmail;
  40.     protected $pumukitInfo;
  41.     protected $mobileDetector;
  43.     public function __construct(
  44.         DocumentManager $documentManager,
  45.         BreadcrumbsService $breadcrumbService,
  46.         EmbeddedEventSessionService $embeddedEventSessionService,
  47.         TranslatorInterface $translator,
  48.         LoggerInterface $logger,
  49.         \Swift_Mailer $mailer,
  50.         $captchaPublicKey,
  51.         $captchaPrivateKey,
  52.         $pumukitLiveEventContactAndShare,
  53.         $pumukitIntro,
  54.         $pumukitNotificationSenderEmail,
  55.         $pumukitInfo
  56.     ) {
  57.         $this->documentManager = $documentManager;
  58.         $this->breadcrumbService = $breadcrumbService;
  59.         $this->embeddedEventSessionService = $embeddedEventSessionService;
  60.         $this->translator = $translator;
  61.         $this->logger = $logger;
  62.         $this->mailer = $mailer;
  63.         $this->captchaPublicKey = $captchaPublicKey;
  64.         $this->captchaPrivateKey = $captchaPrivateKey;
  65.         $this->pumukitLiveEventContactAndShare = $pumukitLiveEventContactAndShare;
  66.         $this->pumukitIntro = $pumukitIntro;
  67.         $this->pumukitNotificationSenderEmail = $pumukitNotificationSenderEmail;
  68.         $this->pumukitInfo = $pumukitInfo;
  70.         $this->mobileDetector = new MobileDetect();
  71.     }
  73.     /**
  74.      * @Route("/live/{id}", name="pumukit_live_id")
  75.      *
  76.      * @Template("@PumukitWebTV/Live/Basic/template.html.twig")
  77.      */
  78.     public function indexAction(Live $live, Request $request)
  79.     {
  80.         $this->updateBreadcrumbs($live->getName(), 'pumukit_live_id', ['id' => $live->getId()]);
  82.         return $this->doLive($live, $request);
  83.     }
  85.     /**
  86.      * @Route("/live/iframe/{id}", name="pumukit_live_iframe_id")
  87.      *
  88.      * @Template("@PumukitWebTV/Live/Basic/template_iframe.html.twig")
  89.      */
  90.     public function iframeAction(Live $live, Request $request)
  91.     {
  92.         return $this->doLive($live, $request);
  93.     }
  95.     /**
  96.      * @Route("/live/event/{id}", name="pumukit_live_event_id")
  97.      *
  98.      * @ParamConverter("multimediaObject", options={"mapping": {"id": "id"}})
  99.      *
  100.      * @Template("@PumukitWebTV/Live/Advance/template.html.twig")
  101.      */
  102.     public function indexEventAction(MultimediaObject $multimediaObject, Request $request)
  103.     {
  104.         $criteria = [
  105.             '_id' => new ObjectId($multimediaObject->getId()),
  106.         ];
  108.         $nowSessions = $this->embeddedEventSessionService->findCurrentSessions($criteria, 0, true);
  109.         $nextSession = $this->embeddedEventSessionService->findNextSessions($criteria, 0, true);
  111.         if ((is_countable($nextSession) ? count($nextSession) : 0) > 0 || (is_countable($nowSessions) ? count($nowSessions) : 0) > 0) {
  112.             $this->updateBreadcrumbs($this->translator->trans('Live events'), 'pumukit_webtv_events');
  114.             return $this->iframeEventAction($multimediaObject, $request, false);
  115.         }
  117.         $series = $multimediaObject->getSeries();
  119.         $qb = $this->getMultimediaObjects($series->getId());
  120.         $multimediaObjects = $qb->getQuery()->execute()->toArray();
  122.         if (1 === (is_countable($multimediaObjects) ? count($multimediaObjects) : 0) && $multimediaObjects[0]->getDisplayTrack()) {
  123.             return $this->redirectToRoute('pumukit_webtv_multimediaobject_index', ['id' => $multimediaObjects[0]->getId()]);
  124.         }
  125.         if ((is_countable($multimediaObjects) ? count($multimediaObjects) : 0) > 1 && !$series->isHide()) {
  126.             return $this->redirectToRoute('pumukit_webtv_series_index', ['id' => $series->getId()]);
  127.         }
  129.         return $this->iframeEventAction($multimediaObject, $request, false);
  130.     }
  132.     /**
  133.      * @Route("/live/event/iframe/{id}", name="pumukit_live_event_iframe_id")
  134.      *
  135.      * @ParamConverter("multimediaObject", options={"mapping": {"id": "id"}})
  136.      *
  137.      * @Template("@PumukitWebTV/Live/Advance/iframe.html.twig")
  138.      */
  139.     public function iframeEventAction(MultimediaObject $multimediaObject, Request $request, bool $iframe = true)
  140.     {
  141.         if (EmbeddedBroadcast::TYPE_PASSWORD === $multimediaObject->getEmbeddedBroadcast()->getType() && $multimediaObject->getEmbeddedBroadcast()->getPassword() !== $request->get('broadcast_password')) {
  142.             return $this->render($iframe ? '@PumukitWebTV/Live/Basic/template_iframe_password.html.twig' : '@PumukitWebTV/Live/Basic/template_password.html.twig', [
  143.                 'live' => $multimediaObject->getEmbeddedEvent(),
  144.                 'invalid_password' => (bool) $request->get('broadcast_password'),
  145.             ]);
  146.         }
  148.         if (!$this->isGranted('IS_AUTHENTICATED_FULLY') && EmbeddedBroadcast::TYPE_LOGIN === $multimediaObject->getEmbeddedBroadcast()->getType()) {
  149.             $this->denyAccessUnlessGranted('IS_AUTHENTICATED_FULLY');
  150.         }
  152.         $userAgent = $request->headers->get('user-agent');
  154.         $mobileDevice = ($this->mobileDetector->isMobile($userAgent) || $this->mobileDetector->isTablet($userAgent));
  155.         $isIE = $this->mobileDetector->version('IE');
  156.         $versionIE = $isIE ? (float) $isIE : 11.0;
  158.         $locale = $request->getLocale();
  160.         $form = $this->createForm(ContactType::class, null, ['translator' => $this->translator, 'locale' => $locale]);
  162.         $activeContact = false;
  163.         $captchaPublicKey = '';
  164.         if ($this->pumukitLiveEventContactAndShare) {
  165.             $captchaPublicKey = $this->captchaPublicKey;
  166.             $activeContact = true;
  167.         }
  169.         $criteria = [
  170.             '_id' => new ObjectId($multimediaObject->getId()),
  171.         ];
  173.         $nowSessions = $this->embeddedEventSessionService->findCurrentSessions($criteria, 0, true);
  174.         $now = new \DateTime();
  175.         $firstNowSessionEnds = new \DateTime();
  176.         $firstNowSessionEnds = $firstNowSessionEnds->getTimestamp();
  177.         $firstNowSessionRemainingDuration = 0;
  178.         foreach ($nowSessions as $session) {
  179.             $firstNowSessionEnds = ($session['data'][0]['session']['start']->toDateTime()->format('U') + $session['data'][0]['session']['duration']) * 1000;
  180.             $firstNowSessionRemainingDuration = $firstNowSessionEnds - ($now->getTimeStamp() * 1000);
  182.             break;
  183.         }
  185.         $nextSessions = $this->embeddedEventSessionService->findNextSessions($criteria, 0, true);
  186.         $date = new \DateTime();
  187.         $firstNextSession = '';
  188.         foreach ($multimediaObject->getEmbeddedEvent()->getEmbeddedEventSession() as $session) {
  189.             if ($session->getStart() < $date && $session->getEnds() > $date) {
  190.                 $firstNextSession = $session->getStart()->getTimestamp() * 1000;
  192.                 break;
  193.             }
  194.             if ($session->getStart() > $date) {
  195.                 $firstNextSession = $session->getStart()->getTimestamp() * 1000;
  197.                 break;
  198.             }
  199.         }
  201.         $secondsToEvent = null;
  202.         if (!empty($firstNextSession)) {
  203.             $secondsToEvent = $firstNextSession - ($now->getTimeStamp() * 1000);
  204.         }
  206.         if ($iframe && 0 === (is_countable($nowSessions) ? count($nowSessions) : 0) && 0 === (is_countable($nextSessions) ? count($nextSessions) : 0)) {
  207.             $qb = $this->getMultimediaObjects($multimediaObject->getSeries()->getId());
  208.             $qb->field('embeddedBroadcast.type')->equals(EmbeddedBroadcast::TYPE_PUBLIC);
  209.             $multimediaObjectPlaylist = $qb->getQuery()->getSingleResult();
  211.             if ($multimediaObjectPlaylist) {
  212.                 $autostart = $request->query->get('autostart', 'true');
  214.                 return $this->redirectToRoute(
  215.                     'pumukit_playlistplayer_index',
  216.                     ['id' => $multimediaObjectPlaylist->getSeries()->getId(), 'autostart' => $autostart]
  217.                 );
  218.             }
  219.         }
  221.         return [
  222.             'multimediaObject' => $multimediaObject,
  223.             'firstNextSession' => $firstNextSession,
  224.             'secondsToEvent' => $secondsToEvent,
  225.             'firstNowSessionEnds' => $firstNowSessionEnds,
  226.             'firstNowSessionDuration' => $firstNowSessionRemainingDuration,
  227.             'nowSessions' => $nowSessions,
  228.             'nextSessions' => $nextSessions,
  229.             'captcha_public_key' => $captchaPublicKey,
  230.             'live' => $multimediaObject->getEmbeddedEvent()->getLive(),
  231.             'contact' => $form->createView(),
  232.             'activeContact' => $activeContact,
  233.             'success' => -1,
  234.             'mobile_device' => $mobileDevice,
  235.             'isIE' => $isIE,
  236.             'versionIE' => $versionIE,
  237.             'showDownloads' => true,
  238.         ];
  239.     }
  241.     /**
  242.      * @Route("/live", name="pumukit_live")
  243.      *
  244.      * @Template("@PumukitWebTV/Live/Basic/template.html.twig")
  245.      */
  246.     public function defaultAction(Request $request)
  247.     {
  248.         $live = $this->documentManager->getRepository(Live::class)->findOneBy([]);
  250.         if (!$live) {
  251.             throw $this->createNotFoundException('The live channel does not exist');
  252.         }
  254.         $this->updateBreadcrumbs($live->getName(), 'pumukit_live', ['id' => $live->getId()]);
  256.         return $this->doLive($live, $request);
  257.     }
  259.     /**
  260.      * @Route("/live/playlist/{id}", name="pumukit_live_playlist_id", defaults={"_format": "xml"})
  261.      */
  262.     public function playlistAction(Live $live): Response
  263.     {
  264.         $intro = $this->pumukitIntro ?? null;
  265.         $mmobjsPlaylist = $this->documentManager->getRepository(MultimediaObject::class)->findBy([
  266.             'properties.is_live_playlist' => true,
  267.         ]);
  269.         $response = ['live' => $live];
  270.         if ($mmobjsPlaylist) {
  271.             $response['items'] = $mmobjsPlaylist;
  272.         } elseif ($intro) {
  273.             $response['items'] = $intro;
  274.         } else {
  275.             $response['items'] = '/bundles/pumukitwebtv/live/video/default.mp4';
  276.         }
  278.         return $this->render('@PumukitWebTV/Live/Basic/playlist.xml.twig', $response);
  279.     }
  281.     /**
  282.      * @Route("/event/contact/{id}", name="pumukit_webtv_contact_event")
  283.      *
  284.      * @ParamConverter("multimediaObject", options={"mapping": {"id": "id"}})
  285.      */
  286.     public function contactAction(MultimediaObject $multimediaObject, Request $request): JsonResponse
  287.     {
  288.         if ('POST' === $request->getMethod() && $this->checkCaptcha($request->request->get('g-recaptcha-response'), $request->getClientIp())) {
  289.             $mail = $this->pumukitNotificationSenderEmail ?? 'noreplay@yourplatform.es';
  290.             $to = $multimediaObject->getEmbeddedSocial()->getEmail();
  292.             $data = $request->request->get('pumukit_multimedia_object_contact');
  293.             $bodyMail = sprintf(" * URL: %s\n * ".$this->translator->trans('Email').": %s\n * ".$this->translator->trans('Name').": %s\n * ".$this->translator->trans('Content').": %s\n ", $request->headers->get('referer', 'No referer'), $data['email'], $data['name'], $data['content']);
  295.             $subject = sprintf(
  296.                 '%s - %s: %s',
  297.                 $this->pumukitInfo['title'],
  298.                 $this->translator->trans('New contact from live event'),
  299.                 $multimediaObject->getEmbeddedEvent()->getName()
  300.             );
  302.             $message = new \Swift_Message();
  303.             $message->setSubject($subject)->setSender($mail)->setFrom($mail)->setTo($to)->setBody($bodyMail, 'text/plain');
  304.             $sent = $this->mailer->send($message);
  306.             if (0 === $sent) {
  307.                 $this->logger->error('Event contact: Error sending message from - '.$request->request->get('email'));
  308.             }
  310.             return new JsonResponse([
  311.                 'success' => true,
  312.                 'message' => $this->translator->trans('email send'),
  313.             ]);
  314.         }
  316.         return new JsonResponse([
  317.             'success' => false,
  318.             'message' => $this->translator->trans('please verify form data'),
  319.         ]);
  320.     }
  322.     /**
  323.      * @Route("/sitemap", name="pumukit_sitemap")
  324.      */
  325.     public function siteMapAction(): Response
  326.     {
  327.         $this->updateBreadcrumbs($this->translator->trans('Sitemap'), 'pumukit_sitemap');
  329.         return $this->render('@PumukitWebTV/Misc/map.html.twig');
  330.     }
  332.     protected function doLive(Live $live, Request $request, bool $iframe = true)
  333.     {
  334.         if ($live->getPasswd() && $live->getPasswd() !== $request->get('broadcast_password')) {
  335.             return $this->render($iframe ? '@PumukitWebTV/Live/Basic/template_iframe_password.html.twig' : '@PumukitWebTV/Live/Basic/template_password.html.twig', [
  336.                 'live' => $live,
  337.                 'invalid_password' => (bool) $request->get('broadcast_password'),
  338.             ]);
  339.         }
  340.         $userAgent = $request->headers->get('user-agent');
  341.         $mobileDevice = ($this->mobileDetector->isMobile($userAgent) || $this->mobileDetector->isTablet($userAgent));
  342.         $isIE = $this->mobileDetector->version('IE');
  343.         $versionIE = $isIE ? (float) $isIE : 11.0;
  345.         return [
  346.             'live' => $live,
  347.             'mobile_device' => $mobileDevice,
  348.             'isIE' => $isIE,
  349.             'versionIE' => $versionIE,
  350.         ];
  351.     }
  353.     protected function updateBreadcrumbs(string $title, string $routeName, array $routeParameters = []): void
  354.     {
  355.         $this->breadcrumbService->addList($title, $routeName, $routeParameters);
  356.     }
  358.     private function getMultimediaObjects($seriesId)
  359.     {
  360.         $qb = $this->documentManager->getRepository(MultimediaObject::class)->createStandardQueryBuilder()
  361.             ->field('status')->equals(MultimediaObject::STATUS_PUBLISHED)
  362.             ->field('tags.cod')->equals(PumukitWebTVBundle::WEB_TV_TAG)
  363.             ->field('series')->equals(new ObjectId($seriesId))
  364.         ;
  365.         $qb->field('tracks')->elemMatch($qb->expr()->field('tags')->equals('display')->field('hide')->equals(false));
  367.         return $qb;
  368.     }
  370.     private function checkCaptcha($response, string $remoteip = '')
  371.     {
  372.         if (null === $response || 0 === strlen($response)) {
  373.             return false;
  374.         }
  376.         $response = $this->recaptchaHttpPost([
  377.             'secret' => $this->captchaPrivateKey,
  378.             'remoteip' => $remoteip,
  379.             'response' => $response,
  380.         ]);
  382.         return json_decode($response, true, 512, JSON_THROW_ON_ERROR)['success'];
  383.     }
  385.     /**
  386.      * Submits an HTTP POST to a reCAPTCHA server.
  387.      */
  388.     private function recaptchaHttpPost(array $data)
  389.     {
  390.         $verify = curl_init();
  391.         curl_setopt($verify, CURLOPT_URL, 'https://www.google.com/recaptcha/api/siteverify');
  392.         curl_setopt($verify, CURLOPT_POST, true);
  393.         curl_setopt($verify, CURLOPT_POSTFIELDS, http_build_query($data));
  394.         curl_setopt($verify, CURLOPT_SSL_VERIFYPEER, false);
  395.         curl_setopt($verify, CURLOPT_RETURNTRANSFER, true);
  397.         return curl_exec($verify);
  398.     }
  399. }