Phraseanet/lib/Alchemy/Phrasea/SearchEngine/Phrasea/PhraseaEngineSubscriber.php

<?php

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

namespace Alchemy\Phrasea\SearchEngine\Phrasea;

use Alchemy\Phrasea\Application;
use Alchemy\Phrasea\Core\Event\CollectionCreateEvent;
use Alchemy\Phrasea\Core\Event\PostAuthenticate;
use Alchemy\Phrasea\Core\PhraseaEvents;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class PhraseaEngineSubscriber implements EventSubscriberInterface
{
    private $app;

    public function __construct(Application $app)
    {
        $this->app = $app;
    }

    public function onAuthenticate(PostAuthenticate $event)
    {
        $event->getUser()->ACL()->inject_rights();
    }

    public function onCollectionCreate(CollectionCreateEvent $event)
    {
        $sql = 'SELECT u.usr_id, c.session_id
                FROM (usr u, Sessions s, basusr b)
                LEFT JOIN cache c ON (c.usr_id = u.usr_id)
                WHERE u.model_of = 0 AND u.usr_login NOT LIKE "(#deleted%"
                  AND b.base_id = :base_id AND b.usr_id = u.usr_id AND b.actif=1
                  AND s.usr_id = u.usr_id';

        $stmt = $this->app['phraseanet.appbox']->get_connection()->prepare($sql);
        $stmt->execute(array(':base_id' => $event->getCollection()->get_base_id()));
        $rows = $stmt->fetchAll(\PDO::FETCH_ASSOC);
        $stmt->closeCursor();

        $initialized = false;

        foreach ($rows as $row) {
            $user = \User_Adapter::getInstance($row['usr_id'], $this->app);
            $user->ACL()->inject_rights();
            if (null !== $row['session_id']) {
                if (!$initialized) {
                    $this->app['phraseanet.SE']->initialize();
                    $initialized = true;
                }
                phrasea_clear_cache($row['session_id']);
                phrasea_close_session($row['session_id']);
            }
        }
    }

    public static function getSubscribedEvents()
    {
        return array(
            PhraseaEvents::POST_AUTHENTICATE => array('onAuthenticate', 0),
            PhraseaEvents::COLLECTION_CREATE => array('onCollectionCreate', 0),
        );
    }
}