One Hat Cyber Team

View File Name : Cache.php

<?php
/**
 * A cache for Kolab storage.
 *
 * PHP version 5
 *
 * @category Kolab
 * @package  Kolab_Storage
 * @author   Gunnar Wrobel <wrobel@pardus.de>
 * @license  http://www.horde.org/licenses/lgpl21 LGPL 2.1
 */

/**
 * The Kolab_Cache class provides a cache for Kolab groupware objects.
 *
 * The Horde_Kolab_Storage_Cache singleton instance provides caching for all
 * storage folders. So before operating on the cache data it is necessary to
 * load the desired folder data. Before switching the folder the cache data
 * should be saved.
 *
 * This class does not offer a lot of safeties and is primarily intended to be
 * used within the Horde_Kolab_Storage_Data class.
 *
 * Copyright 2007-2017 Horde LLC (http://www.horde.org/)
 *
 * See the enclosed file COPYING for license information (LGPL). If you
 * did not receive this file, see http://www.horde.org/licenses/lgpl21.
 *
 * @category Kolab
 * @package  Kolab_Storage
 * @author   Gunnar Wrobel <wrobel@pardus.de>
 * @license  http://www.horde.org/licenses/lgpl21 LGPL 2.1
 */
class Horde_Kolab_Storage_Cache
{
    /**
     * The link to the horde cache.
     *
     * @var Horde_Cache
     */
    protected $_horde_cache;

    /**
     * Data cache instances.
     *
     * @var array
     */
    protected $_data_caches;

    /**
     * Constructor.
     *
     * @param Horde_Cache $cache The global cache for temporary data storage.
     */
    public function __construct($cache)
    {
        $this->_horde_cache = $cache;
    }

    /**
     * Return a data cache.
     *
     * @param array $data_params Return the data cache for a data set
     *                           with these parameters.
     *
     * @return Horde_Kolab_Storage_Cache_Data The data cache.
     */
    public function getDataCache($data_params)
    {
        $data_id = $this->_getDataId($data_params);
        if (!isset($this->_data_caches[$data_id])) {
            $this->_data_caches[$data_id] = new Horde_Kolab_Storage_Cache_Data(
                $this, $data_params
            );
            $this->_data_caches[$data_id]->setDataId($data_id);
        }
        return $this->_data_caches[$data_id];
    }

    /**
     * Retrieve data set.
     *
     * @param string $data_id  ID of the data set.
     *
     * @return string The cached data set.
     */
    public function loadData($data_id)
    {
        return $this->_horde_cache->get($data_id, 0);
    }

    /**
     * Cache data set.
     *
     * @param string $data_id  ID of the data set.
     * @param string $data     The data to be cached.
     */
    public function storeData($data_id, $data)
    {
        $this->_horde_cache->set($data_id, $data, 0);
    }

    /**
     * Retrieve an attachment.
     *
     * @param string $data_id       ID of the data set.
     * @param string $obid          Object backend id.
     * @param string $attachment_id Attachment ID.
     *
     * @return resource A stream opened to the attachment data.
     */
    public function loadAttachment($data_id, $obid, $attachment_id)
    {
        $data = $this->_horde_cache->get(
            $this->_getAttachmentId($data_id, $obid, $attachment_id),
            0
        );
        return $data === false
            ? $data
            : Horde_Stream_Wrapper_String::getStream($data);
    }

    /**
     * Store an attachment.
     *
     * @param string   $data_id        ID of the data set.
     * @param string   $obid           Object backend id.
     * @param string   $attachment_id  Attachment ID.
     * @param resource $data           A stream opened to the attachment data.
     */
    public function storeAttachment($data_id, $obid, $attachment_id, $data)
    {
        $this->_horde_cache->set(
            $this->_getAttachmentId($data_id, $obid, $attachment_id),
            (string)new Horde_Stream_Existing(array('stream' => $data)),
            0
        );
    }

    /**
     * Delete a cached attachment.
     *
     * @param string $data_id       ID of the data set.
     * @param string $obid          Object backend id.
     * @param string $attachment_id Attachment ID.
     */
    public function deleteAttachment($data_id, $obid, $attachment_id)
    {
        return $this->_horde_cache->expire(
            $this->_getAttachmentId($data_id, $obid, $attachment_id)
        );
    }

    /**
     * Retrieve list data.
     *
     * @param string $list_id ID of the connection matching the list.
     *
     * @return string The data of the object.
     */
    public function loadList($list_id)
    {
        return $this->_horde_cache->get($list_id, 0);
    }

    /**
     * Cache list data.
     *
     * @param string $list_id ID of the connection matching the list.
     * @param string $data          The data to be cached.
     */
    public function storeList($list_id, $data)
    {
        $this->_horde_cache->set($list_id, $data, 0);
    }

    /**
     * Compose the data key.
     *
     * @param array $data_params Return the data ID for a data set with these
     *                           parameters.
     *
     * @return string The data cache ID.
     */
    private function _getDataId($data_params)
    {
        foreach (array('host', 'port', 'prefix', 'folder', 'type', 'owner') as $key) {
            $this->requireParameter($data_params, 'data', $key);
        }
        ksort($data_params);
        return md5(serialize($data_params));
    }

    /**
     * Compose the attachment key.
     *
     * @param string $data_id        ID of the data set.
     * @param string $obid           Object backend id.
     * @param string $attachment_id  Attachment ID.
     *
     * @return string The attachment cache ID.
     */
    private function _getAttachmentId($data_id, $obid, $attachment_id)
    {
        return md5(
            serialize(array('d' => $data_id, 'o' => (string)$obid, 'p' => (string)$attachment_id))
        );
    }

    /**
     * Determine if a necessary parameter is set.
     *
     * @throws Horde_Kolab_Storage_Exception In case the parameter is missing.
     */
    public function requireParameter($parameters, $type, $key)
    {
        if (!isset($parameters[$key])) {
            throw new Horde_Kolab_Storage_Exception(
                sprintf(
                    'Unable to determine the %s cache key: The "%s" parameter is missing!',
                    $type,
                    $key
                )
            );
        }

    }
}