class.ilUserSearchCache.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilUserSearchCache
{
    public const int DEFAULT_SEARCH = 0;
    public const int LUCENE_DEFAULT = 5;

    public const int LAST_QUERY = 7;

    public const int LUCENE_USER_SEARCH = 8;

    private static ?ilUserSearchCache $instance = null;
    protected ilDBInterface $db;

    private int $usr_id;
    private int $search_type = self::DEFAULT_SEARCH;

    private array $search_result = array();
    private array $checked = array();
    private array $failed = array();
    private int $page_number = 1;

    private $query;
    private int $root;
    private array $item_filter = array();
    private bool $isAnonymous = false;
    private array $mime_filter = array();
    private array $creation_filter = array();



    private function __construct(int $a_usr_id)
    {
        global $DIC;

        $this->db = $DIC->database();

        if ($a_usr_id == ANONYMOUS_USER_ID) {
            $this->isAnonymous = true;
        }

        $this->root = ROOT_FOLDER_ID;
        $this->usr_id = $a_usr_id;
        $this->search_type = self::DEFAULT_SEARCH;
        $this->read();
    }

    public static function _getInstance(int $a_usr_id): ilUserSearchCache
    {
        if (self::$instance instanceof ilUserSearchCache) {
            return self::$instance;
        }
        return self::$instance = new ilUserSearchCache($a_usr_id);
    }

    public function isAnonymous(): bool
    {
        return $this->isAnonymous;
    }

    public function switchSearchType(int $a_type): bool
    {
        $this->search_type = $a_type;
        $this->read();
        return true;
    }

    public function getResults(): array
    {
        return $this->search_result ?: array();
    }

    public function setResults(array $a_results): void
    {
        $this->search_result = $a_results;
    }

    public function addResult(array $a_result_item): bool
    {
        $this->search_result[$a_result_item['ref_id']]['ref_id'] = $a_result_item['ref_id'];
        $this->search_result[$a_result_item['ref_id']]['obj_id'] = $a_result_item['obj_id'];
        $this->search_result[$a_result_item['ref_id']]['type'] = $a_result_item['type'];
        return true;
    }

    public function appendToFailed(int $a_ref_id): void
    {
        $this->failed[$a_ref_id] = $a_ref_id;
    }

    public function isFailed(int $a_ref_id): bool
    {
        return in_array($a_ref_id, $this->failed);
    }

    public function appendToChecked(int $a_ref_id, int $a_obj_id): void
    {
        $this->checked[$a_ref_id] = $a_obj_id;
    }

    public function isChecked(int $a_ref_id): bool
    {
        return array_key_exists($a_ref_id, $this->checked) and $this->checked[$a_ref_id];
    }

    public function getCheckedItems(): array
    {
        return $this->checked ?: array();
    }

    public function setResultPageNumber(int $a_number): void
    {
        if ($a_number) {
            $this->page_number = $a_number;
        }
    }

    public function getResultPageNumber(): int
    {
        return $this->page_number ?: 1;
    }

    public function setQuery(string $a_query): void
    {
        $this->query = $a_query;
    }

    public function getQuery(): string
    {
        return $this->query ?? '';
    }

    public function getUrlEncodedQuery(): string
    {
        return urlencode(str_replace('"', '.', $this->getQuery()));
    }

    public function setRoot(int $a_root): void
    {
        $this->root = $a_root;
    }

    public function getRoot(): int
    {
        return $this->root ?: ROOT_FOLDER_ID;
    }

    public function setItemFilter(array $a_filter): void
    {
        $this->item_filter = $a_filter;
    }

    public function getItemFilter(): array
    {
        return $this->item_filter;
    }

    public function setMimeFilter(array $a_filter): void
    {
        $this->mime_filter = $a_filter;
    }

    public function getMimeFilter(): array
    {
        return $this->mime_filter;
    }

    public function setCreationFilter(array $a_filter): void
    {
        $this->creation_filter = $a_filter;
    }

    public function getCreationFilter(): array
    {
        return $this->creation_filter;
    }

    public function deleteCachedEntries(): void
    {
        if ($this->isAnonymous()) {
            $this->deleteCachedEntriesAnonymous();
            return;
        }
        $query = "SELECT COUNT(*) num FROM usr_search " .
            "WHERE usr_id = " . $this->db->quote($this->usr_id, 'integer') . " " .
            "AND search_type = " . $this->db->quote($this->search_type, 'integer');
        $res = $this->db->query($query);
        $row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT);

        if ($row->num > 0) {
            $this->db->update(
                'usr_search',
                array(
                    'search_result' => array('clob',serialize(array(0))),
                    'checked' => array('clob',serialize(array(0))),
                    'failed' => array('clob',serialize(array(0))),
                    'page' => array('integer',0)),
                array(
                    'usr_id' => array('integer', $this->usr_id),
                    'search_type' => array('integer', $this->search_type)
            )
            );
        } else {
            $this->db->insert(
                'usr_search',
                array(
                    'search_result' => array('clob',serialize(array(0))),
                    'checked' => array('clob',serialize(array(0))),
                    'failed' => array('clob',serialize(array(0))),
                    'page' => array('integer',0),
                    'usr_id' => array('integer', $this->usr_id),
                    'search_type' => array('integer', $this->search_type),
                    'query' => array('clob',serialize(''))
            )
            );
        }

        $this->setResultPageNumber(1);
        $this->search_result = array();
        $this->checked = array();
        $this->failed = array();
    }

    public function deleteCachedEntriesAnonymous(): bool
    {
        $this->setResultPageNumber(1);
        $this->search_result = array();
        $this->checked = array();
        $this->failed = array();

        return true;
    }

    public function delete(): bool
    {
        $query = "DELETE FROM usr_search " .
            "WHERE usr_id = " . $this->db->quote($this->usr_id, 'integer') . " " .
            "AND search_type = " . $this->db->quote($this->search_type, 'integer');
        $res = $this->db->manipulate($query);

        $this->read();
        return true;
    }

    public function save(): void
    {
        if ($this->isAnonymous()) {
            $this->saveForAnonymous();
            return;
        }

        $query = "DELETE FROM usr_search " .
            "WHERE usr_id = " . $this->db->quote($this->usr_id, 'integer') . " " .
            "AND ( search_type = " . $this->db->quote($this->search_type, 'integer') . ' ' .
            "OR search_type = " . $this->db->quote(self::LAST_QUERY, 'integer') . ')';
        $res = $this->db->manipulate($query);

        $this->db->insert('usr_search', array(
            'usr_id' => array('integer', $this->usr_id),
            'search_result' => array('clob',serialize($this->search_result)),
            'checked' => array('clob',serialize($this->checked)),
            'failed' => array('clob',serialize($this->failed)),
            'page' => array('integer', $this->page_number),
            'search_type' => array('integer', $this->search_type),
            'query' => array('clob',serialize($this->getQuery())),
            'root' => array('integer',$this->getRoot()),
            'item_filter' => array('text',serialize($this->getItemFilter())),
            'mime_filter' => array('text',  serialize($this->getMimeFilter())),
            'creation_filter' => array('text', serialize($this->getCreationFilter()))
        ));


        // Write last query information
        $this->db->insert(
            'usr_search',
            array(
                'usr_id' => array('integer',$this->usr_id),
                'search_type' => array('integer',self::LAST_QUERY),
                'query' => array('text',serialize($this->getQuery()))
            )
        );
    }

    public function saveForAnonymous(): void
    {
        ilSession::clear('usr_search_cache');
        $session_usr_search = [];
        $session_usr_search[$this->search_type]['search_result'] = $this->search_result;
        $session_usr_search[$this->search_type]['checked'] = $this->checked;
        $session_usr_search[$this->search_type]['failed'] = $this->failed;
        $session_usr_search[$this->search_type]['page'] = $this->page_number;
        $session_usr_search[$this->search_type]['query'] = $this->getQuery();
        $session_usr_search[$this->search_type]['root'] = $this->getRoot();
        $session_usr_search[$this->search_type]['item_filter'] = $this->getItemFilter();
        $session_usr_search[$this->search_type]['mime_filter'] = $this->getMimeFilter();
        $session_usr_search[$this->search_type]['creation_filter'] = $this->getCreationFilter();
        $session_usr_search[self::LAST_QUERY]['query'] = $this->getQuery();
        ilSession::set('usr_search_cache', $session_usr_search);
    }

    private function read(): void
    {
        $this->failed = array();
        $this->checked = array();
        $this->search_result = array();
        $this->page_number = 0;

        if ($this->isAnonymous()) {
            $this->readAnonymous();
            return;
        }

        $query = "SELECT * FROM usr_search " .
            "WHERE usr_id = " . $this->db->quote($this->usr_id, 'integer') . " " .
            "AND search_type = " . $this->db->quote($this->search_type, 'integer');

        $res = $this->db->query($query);
        while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $this->search_result = (array) unserialize((string) $row->search_result);
            if (strlen((string) $row->checked)) {
                $this->checked = (array) unserialize((string) $row->checked);
            }
            if (strlen((string) $row->failed)) {
                $this->failed = (array) unserialize((string) $row->failed);
            }
            $this->page_number = (int) $row->page;
            $this->setQuery(unserialize((string) $row->query));
            $this->setRoot((int) $row->root);
            $this->setItemFilter((array) unserialize((string) $row->item_filter));
            $this->setCreationFilter((array) unserialize((string) $row->creation_filter));
        }
    }

    private function readAnonymous(): void
    {
        $usr_search_cache = ilSession::get('usr_search_cache') ?? [];

        $this->search_result = (array) ($usr_search_cache[$this->search_type]['search_result'] ?? []);
        $this->checked = (array) ($usr_search_cache[$this->search_type]['checked'] ?? []);
        $this->failed = (array) ($usr_search_cache[$this->search_type]['failed'] ?? []);
        $this->page_number = (int) ($usr_search_cache[$this->search_type]['page_number'] ?? 1);
        $this->setQuery((string) ($usr_search_cache[$this->search_type]['query'] ?? ''));
        $this->setRoot((int) ($usr_search_cache[$this->search_type]['root'] ?? ROOT_FOLDER_ID));
        $this->setItemFilter((array) ($usr_search_cache[$this->search_type]['item_filter'] ?? []));
        $this->setMimeFilter((array) ($usr_search_cache[$this->search_type]['mime_filter'] ?? []));
        $this->setCreationFilter((array) ($usr_search_cache[$this->search_type]['creation_filter'] ?? []));
    }
}