Phraseanet/lib/Alchemy/Phrasea/Application/Overview.php

<?php

/*
 * This file is part of Phraseanet
 *
 * (c) 2005-2012 Alchemy
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Alchemy\Phrasea\Application;

use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpFoundation\Request;

/**
 *
 * @license     http://opensource.org/licenses/gpl-3.0 GPLv3
 * @link        www.phraseanet.com
 */
return call_user_func(
        function() {

            $app = new \Silex\Application();

            $app['Core'] = \bootstrap::getCore();

            $appbox = \appbox::get_instance($app['Core']);
            $session = $appbox->get_session();

            $deliver_content = function(Request $request, \Session_Handler $session, \record_adapter $record, $subdef, $watermark, $stamp, $app) {

                    $file = $record->get_subdef($subdef);

                    $pathIn = $pathOut = $file->get_pathfile();

                    if ($watermark === true && $file->get_type() === \media_subdef::TYPE_IMAGE) {
                        $pathOut = \recordutils_image::watermark($record->get_base_id(), $record->get_record_id());
                    } elseif ($stamp === true && $file->get_type() === \media_subdef::TYPE_IMAGE) {
                        $pathOut = \recordutils_image::stamp($record->get_base_id(), $record->get_record_id());
                    }


                    $log_id = null;
                    try {
                        $registry = \registry::get_instance();
                        $logger = $session->get_logger($record->get_databox());
                        $log_id = $logger->get_id();

                        $referrer = 'NO REFERRER';

                        if (isset($_SERVER['HTTP_REFERER']))
                            $referrer = $_SERVER['HTTP_REFERER'];

                        $record->log_view($log_id, $referrer, $registry->get('GV_sit'));
                    } catch (\Exception $e) {
                        
                    }

                    $response = \set_export::stream_file($pathOut, $file->get_file(), $file->get_mime(), 'attachment');
                    $response->setPrivate();

                    /* @var $response \Symfony\Component\HttpFoundation\Response */
                    if ($file->getEtag()) {
                        $response->setEtag($file->getEtag());
                        $response->setLastModified($file->get_modification_date());
                    }

                    $response->headers->addCacheControlDirective('must-revalidate', true);
                    $response->isNotModified($request);

                    return $response;
                };

            $app->get('/datafiles/{sbas_id}/{record_id}/{subdef}/', function($sbas_id, $record_id, $subdef) use ($app, $session, $deliver_content) {

                    $databox = \databox::get_instance((int) $sbas_id);
                    $record = new \record_adapter($sbas_id, $record_id);

                    $record->get_type();

                    if ( ! $session->is_authenticated())
                        throw new \Exception_Session_NotAuthenticated();

                    $user = \User_Adapter::getInstance($session->get_usr_id(), \appbox::get_instance($app['Core']));

                    if ( ! $user->ACL()->has_access_to_subdef($record, $subdef))
                        throw new \Exception_UnauthorizedAction();

                    $stamp = false;
                    $watermark = ! $user->ACL()->has_right_on_base($record->get_base_id(), 'nowatermark');

                    if ($watermark) {
                        $subdef_class = $databox
                            ->get_subdef_structure()
                            ->get_subdef($record->get_type(), $subdef)
                            ->get_class();

                        if ($subdef_class == \databox_subdef::CLASS_PREVIEW && $user->ACL()->has_preview_grant($record)) {
                            $watermark = false;
                        } elseif ($subdef_class == \databox_subdef::CLASS_DOCUMENT && $user->ACL()->has_hd_grant($record)) {
                            $watermark = false;
                        }
                    }

                    if ($watermark) {

                        $em = $app['Core']->getEntityManager();

                        $repository = $em->getRepository('\Entities\BasketElement');

                        /* @var $repository \Repositories\BasketElementRepository */

                        $ValidationByRecord = $repository->findReceivedValidationElementsByRecord($record, $user);
                        $ReceptionByRecord = $repository->findReceivedElementsByRecord($record, $user);

                        if ($ValidationByRecord && $ValidationByRecord->count() > 0) {
                            $watermark = false;
                        } elseif ($ReceptionByRecord && $ReceptionByRecord->count() > 0) {
                            $watermark = false;
                        }
                    }

                    return $deliver_content($app['request'], $session, $record, $subdef, $watermark, $stamp, $app);
                })->assert('sbas_id', '\d+')->assert('record_id', '\d+');


            $app->get('/permalink/v1/{label}/{sbas_id}/{record_id}/{key}/{subdef}/view/'
                , function($label, $sbas_id, $record_id, $key, $subdef) use($app) {

                    $databox = \databox::get_instance((int) $sbas_id);

                    $record = \media_Permalink_Adapter::challenge_token($databox, $key, $record_id, $subdef);

                    if ( ! ($record instanceof \record_adapter))
                        throw new \Exception('bad luck');

                    /* @var $twig \Twig_Environment */
                    $twig = $app['Core']->getTwig();

                    $params = array(
                        'subdef_name' => $subdef
                        , 'module_name' => 'overview'
                        , 'module'      => 'overview'
                        , 'view'        => 'overview'
                        , 'record'      => $record
                    );

                    return $twig->render('overview.twig', $params);
                })->assert('sbas_id', '\d+')->assert('record_id', '\d+');


            $app->get('/permalink/v1/{label}/{sbas_id}/{record_id}/{key}/{subdef}/'
                    , function($label, $sbas_id, $record_id, $key, $subdef) use ($app, $session, $deliver_content) {
                        $databox = \databox::get_instance((int) $sbas_id);
                        $record = \media_Permalink_Adapter::challenge_token($databox, $key, $record_id, $subdef);
                        if ( ! ($record instanceof \record_adapter))
                            throw new \Exception('bad luck');

                        $watermark = $stamp = false;

                        if ($session->is_authenticated()) {
                            $user = \User_Adapter::getInstance($session->get_usr_id(), \appbox::get_instance($app['Core']));

                            $watermark = ! $user->ACL()->has_right_on_base($record->get_base_id(), 'nowatermark');

                            if ($watermark) {

                                $em = $app['Core']->getEntityManager();

                                $repository = $em->getRepository('\Entities\BasketElement');

                                if ($repository->findReceivedValidationElementsByRecord($record, $user)->count() > 0) {
                                    $watermark = false;
                                } elseif ($repository->findReceivedElementsByRecord($record, $user)->count() > 0) {
                                    $watermark = false;
                                }
                            }

                            return $deliver_content($app['request'], $session, $record, $subdef, $watermark, $stamp, $app);
                        } else {
                            $collection = \collection::get_from_base_id($record->get_base_id());
                            switch ($collection->get_pub_wm()) {
                                default:
                                case 'none':
                                    $watermark = false;
                                    break;
                                case 'stamp':
                                    $stamp = true;
                                    break;
                                case 'wm':
                                    $watermark = false;
                                    break;
                            }
                        }

                        return $deliver_content($app['request'], $session, $record, $subdef, $watermark, $stamp, $app);
                    }
                )
                ->assert('sbas_id', '\d+')->assert('record_id', '\d+');


            $app->error(function (\Exception $e) {
                var_dump($e->getMessage());
                    if ($e instanceof \Exception_Session_NotAuthenticated) {
                        $code = 403;
                        $message = 'Forbidden';
                    } elseif ($e instanceof \Exception_NotAllowed) {
                        $code = 403;
                        $message = 'Forbidden';
                    } elseif ($e instanceof \Exception_NotFound) {
                        $code = 404;
                        $message = 'Not Found';
                    } else {
                        $code = 404;
                        $message = 'Not Found';
                    }

                    return new Response($message, $code);
                });




            return $app;
        }
);