Comodojo\Cache\Drivers\FilesystemGhost

Complexity

Total Complexity

18

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Test Coverage

Coverage

97.37%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	11	3
A	set()	0	20	5
A	has()	0	23	6
A	clear()	0	19	4

<?php namespace Comodojo\Cache\Drivers;

use \Exception;

/**
 * @package     Comodojo Cache
 * @author      Marco Giovinazzi <marco.giovinazzi@comodojo.org>
 * @license     MIT
 *
 * LICENSE:
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

class FilesystemGhost extends FilesystemXattr {

    const DRIVER_NAME = "filesystem-ghost";

    /**
     * {@inheritdoc}
     */
    public function set($key, $namespace, $value, $ttl = null) {

        $cacheFile = $this->cache_folder."$key-$namespace.cache";
        $cacheGhost = $this->cache_folder."$key-$namespace.expire";

        if ( $ttl == null || $ttl == 0 ) {
            $ttl = 0;
        } else {
            $ttl = time() + intval($ttl);
        }

        $cached = @file_put_contents($cacheFile, $value, LOCK_EX);

        if ( $cached === false ) throw new Exception("Error writing cache object $cacheFile");

        $tagged = @file_put_contents($cacheGhost, $ttl, LOCK_EX);

        if ( $tagged === false ) throw new Exception("Error writing cache ttl $cacheFile");

        return true;

    }

    /**
     * {@inheritdoc}
     */
    public function delete($key, $namespace) {

        $result = [];

        $file_list = glob($this->cache_folder."$key-$namespace.{cache,expire}", GLOB_BRACE);

        if ( empty($file_list) ) return false;

        foreach ( $file_list as $file ) $result[] = unlink($file);

        return !in_array(false, $result);

    }

    /**
     * {@inheritdoc}
     */
    public function clear($namespace = null) {

        $result = [];

        if ( $namespace === null ) {

            $file_list = glob($this->cache_folder."*.{cache,expire}", GLOB_BRACE);

        } else {

            $file_list = glob($this->cache_folder."*-$namespace.{cache,expire}", GLOB_BRACE);

        }

        if ( empty($file_list) ) return true;

        foreach ( $file_list as $file ) $result[] = unlink($file);

        return !in_array(false, $result);

    }

    // public function getMultiple(array $keys, $namespace) {
    //
    //     $result = [];
    //
    //     foreach ($keys as $key) {
    //         $result[$key] = $this->get($key, $namespace);
    //     }
    //
    //     return $result;
    //
    // }
    //
    // public function setMultiple(array $key_values, $namespace, $ttl = null) {
    //
    //     $result = [];
    //
    //     foreach ($keys as $key => $value) {
    //         $result[] = $this->set($key, $namespace, $value, $ttl);
    //     }
    //
    //     return !in_array(false, $result);
    //
    // }
    //
    // public function deleteMultiple(array $keys, $namespace) {
    //
    //     $result = [];
    //
    //     foreach ($keys as $key) {
    //         $result[] = $this->delete($key, $namespace);
    //     }
    //
    //     return !in_array(false, $result);
    //
    // }

    /**
     * {@inheritdoc}
     */
    public function has($key, $namespace) {

        $time = time();

        $cacheFile = $this->cache_folder."$key-$namespace.cache";
        $cacheGhost = $this->cache_folder."$key-$namespace.expire";

        if ( file_exists($cacheFile) && file_exists($cacheGhost) ) {

            $expire = @file_get_contents($cacheGhost);

            if ( $expire === false ) {
                throw new Exception("Error reading cache ttl for $cacheFile");
            } else if ( intval($expire) < $time && intval($expire) !== 0 ) {
                $this->delete($key, $namespace);
                return false;
            } else {
                return true;
            }

        }

        return false;

    }

    // public function stats() {
    //
    //     return ['objects' => count(glob($this->cache_folder."*.cache"))];
    //
    // }

}