<?php
// $Id: file.php,v 1.1.6.18 2010-02-06 12:01:55 andypost Exp $

/**
 * @file
 *   Engine file for file based.
 */

class fileCacheRouterEngine extends CacheRouterEngine {
  var $content = array();
  var $fspath = '/tmp/filecache';

  function page_fast_cache() {
    return TRUE;
  }

  function __construct($bin, $options, $default_options) {
    // Assign the path on the following order: bin specific -> default specific -> /tmp/filepath
    if (isset($options['path'])) {
      $this->fspath = $options['path'];
    }
    elseif (isset($default_options['path'])) {
      $this->fspath = $default_options['path'];
    }
    parent::__construct($bin, $options, $default_options);
  }

  function get($key) {
    global $user, $conf;

    if (isset($this->content[$key])) {
      return $this->content[$key];
    }

    $cache_lifetime = variable_get('cache_lifetime', 0);

    //make sure fast cache is enabled (see CacheRouter function page_fast_cache)
    if ($this->page_fast_cache()) {
      $cache = NULL;
      $cache_file = $this->key($key);
      if (file_exists($cache_file)) {
        if ($fp = fopen($cache_file, 'r')) {
          if (flock($fp, LOCK_SH)) {
            $data = @fread($fp, filesize($cache_file));
            flock($fp, LOCK_UN);
            $cache = unserialize($data);
          }
          fclose($fp);
        }
      }
      return $cache;

    }
    else {
      // garbage collection necessary when enforcing a minimum cache lifetime
      $cache_flush = variable_get('cache_flush_'. $this->name, 0);
      if ($cache_flush && ($cache_flush + $cache_lifetime <= time())) {
        variable_set('cache_flush_'. $this->name, 0);
      }
    }

    if (isset($cache->data)) {
      // If enforcing a minimum cache lifetime, validate that the data is
      // currently valid for this user before we return it by making sure the
      // cache entry was created before the timestamp in the current session's
      // cache timer. The cache variable is loaded into the $user object by
      // sess_read() in session.inc.
      if ($user->cache > $cache->created) {
        // This cache data is too old and thus not valid for us, ignore it.
        return FALSE;
      }
      return $cache;
    }
    return FALSE;
  }

  function set($key, $value, $expire = CACHE_PERMANENT, $headers = NULL) {
    static $subdirectories;
    //make sure fast cache is enabled (see CacheRouter function page_fast_cache)
    if ($this->page_fast_cache()) {
      // prepare the cache before grabbing the file lock
      $cache = new stdClass;
      $cache->cid = $key;
      $cache->table = $this->name;
      $cache->created = time();
      $cache->expire = $expire;
      $cache->headers = $headers;
      $cache->data = $value;

      $data = serialize($cache);

      $file = $this->key($key);
      if ($fp = @fopen($file, 'w')) {
        // only write to the cache file if we can obtain an exclusive lock
        if (flock($fp, LOCK_EX)) {
          fwrite($fp, $data);
          flock($fp, LOCK_UN);
        }
        fclose($fp);
        @chmod($file, 0664); // Necessary for non-webserver users.
      }
      else {
        // t() may not be loaded
        if (function_exists('watchdog')) {
          watchdog('cache', strtr('Cache write error, failed to open file "%file"', array('%file' => $file)), WATCHDOG_ERROR);
        }
      }
    } else {
      if (function_exists('watchdog')) {
        watchdog('cache', 'Cache write error, failed to verify page_cache_fastpath');
      }
    }
  }

  function delete($key) {
    // when using wildcard: $key is part-of-key + '*'

    $filename = $this->key($key);
    if (is_dir($filename)) {
      $fspath = $filename;
      // Filename: abcdef12345verylongmd5code--content:123456:987654
      $files = file_scan_directory($fspath, ".--.", array('.', '..', 'CVS'), 0, FALSE);
      foreach ($files as $file) {
       if(is_file($file->filename)){
         if ($fp = fopen($file->filename, 'w')) {
          // only delete the cache file once we obtain an exclusive lock to prevent
          // deleting a cache file that is currently being read.
           if (flock($fp, LOCK_EX)) {
             unlink($file->filename);
           }
         }
       }
      }
    } else if (strrpos($key, '*') !== FALSE) {
      $look_for = explode('*', $key);
      $fspath = $this->fspath;
      // Filename: abcdef12345verylongmd5code--content:123456:987654
      $files = file_scan_directory($fspath, ".--{$look_for[0]}.*", array('.', '..', 'CVS'), 0, TRUE);
      foreach ($files as $file) {
       if(is_file($file->filename)){
         if ($fp = @fopen($file->filename, 'w')) {
          // only delete the cache file once we obtain an exclusive lock to prevent
          // deleting a cache file that is currently being read.
           if (flock($fp, LOCK_EX)) {
             unlink($file->filename);
           }
         }
       }
      }
    } else {
      //generate the proper filename
        if ($fp = @fopen($filename, 'w')) {
          // only delete the cache file once we obtain an exclusive lock to prevent
          // deleting a cache file that is currently being read.
          if (flock($fp, LOCK_EX)) {
            unlink($filename);
          }
        }
      }
  }


  function flush() {
    global $user;

    $table = $this->name;
    $cache_lifetime = variable_get('cache_lifetime', 0);
    $fspath = $this->fspath;

    $ivalfrom = ord("a");
    $ivalto = ord("f");

    for ($i = $ivalfrom; $i <= $ivalto; $i++) {
      $this->purge("$fspath/$table/". chr($i));
    }

    for ($i = 0; $i<10; $i++) {
      $this->purge("$fspath/$table/". $i);
    }
  }

  function key($key) {
    $table = $this->name;
    $fspath = $this->fspath;
    if($key != '*'){
      $hash = md5($key);
      // TODO make sure we always get valid filenames in the appendix
      $appendix = str_replace(array('/'), array('-'), $key);
      $this->create_directory($fspath, $hash{0});
      return  "$fspath/$table/". $hash{0}. '/'. $hash. '--'. $appendix;
    } else {
      // TODO make sure we always get valid filenames in the appendix
      return  "$fspath/$table/";
    }

  }

  /**
   * Create the necessary $table directory and/or letter/number subdirectory if
   * it doesn't exist.  We store the directories we've created in a static
   * so we don't bother doing an fstat on that more than one time per page load.
   */
  function create_directory($fspath, $hash) {
    static $dirs = array();
    $table = $this->name;

    $create = array($fspath, "$fspath/$table", "$fspath/$table/$hash");

    foreach ($create as $dir) {
      $dir = rtrim($dir, '/\\');
      // Check the static $dirs to avoid excessive fstats
      if (!isset($dirs[$dir])) {
        $dirs[$dir] = 1;
        if (!is_dir($dir)) {
          if (!mkdir($dir)) {
            // t() is not available.
            if (function_exists('watchdog')) {
              watchdog('cache', strtr('Failed to create directory %dir.', array('%dir' => "<em>$dir</em>")), WATCHDOG_ERROR);
            }
          }
          else {
            @chmod($dir, 0775); // Necessary for non-webserver users.
          }
        }
      }
    }
  }

  function purge($dir) {
    $cache_lifetime = variable_get('cache_lifetime', 0);
    $files = file_scan_directory($dir, '.', array('.', '..', 'CVS'), 0, FALSE);
    foreach ($files as $file) {
      if (filemtime($file->filename) < (time() - $cache_lifetime)) {
        if ($fp = fopen($file->filename, 'r')) {
          // We need an exclusive lock, but don't block if we can't get it as
          // we can simply try again next time cron is run.
          if (flock($fp, LOCK_EX|LOCK_NB)) {
            unlink($file->filename);
          }
        }
      }
    }
  }

  function stats() {
    $stats = array(
      'uptime' => time(),
      'bytes_used' => disk_total_space($this->fspath) - disk_free_space($this->fspath),
      'bytes_total' => disk_total_space($this->fspath),
      'gets' => 0,
      'sets' => 0,
      'hits' => 0,
      'misses' => 0,
      'req_rate' => 0,
      'hit_rate' => 0,
      'miss_rate' => 0,
      'set_rate' => 0,
    );
    return $stats;
  }
}