<?php

//
// Open Web Analytics - An Open Source Web Analytics Framework
//
// Copyright 2006 Peter Adams. All rights reserved.
//
// Licensed under GPL v2.0 http://www.gnu.org/copyleft/gpl.html
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
// $Id$
//

/**
 * Abstract Cache Class
 * 
 * @author      Peter Adams <peter@openwebanalytics.com>
 * @copyright   Copyright &copy; 2006 Peter Adams <peter@openwebanalytics.com>
 * @license     http://www.gnu.org/copyleft/gpl.html GPL v2.0
 * @category    owa
 * @package     owa
 * @version		$Revision$	      
 * @since		owa 1.0.0
 */


class owa_cache {

	var $cache;
	var $statistics = array('warm' => 0, 'cold' => 0, 'miss' => 0, 'replaced' => 0, 'added' => 0, 'removed' => 0, 'dirty' => 0);
	var $cache_id = 1; // default cache id
	var $collections;
	var $dirty_collections;
	var $dirty_objs = array();
	var $global_collections = array();
	var $collection_expiration_periods = array();
	var $e;

	/**
	 * Constructor
	 * 
	 * Takes cache directory as param
	 *
	 * @param $cache_dir string
	 */
	function __construct($cache_dir = '') {
		
		$this->e = &owa_coreAPI::errorSingleton();
	}
		
	function set($collection, $key, $value, $expires = '') {
	
		$hkey = $this->hash($key);
		//owa_coreAPI::debug('set key: '.$key);
		//owa_coreAPI::debug('set hkey: '.$hkey);
		$this->cache[$collection][$hkey] = $value;
		$this->debug(sprintf('Added Object to Cache - Collection: %s, id: %s', $collection, $hkey));
		$this->statistics['added']++;		
		$this->dirty_objs[$collection][$hkey] = $hkey;
		$this->dirty_collections[$collection] = true; 
		$this->debug(sprintf('Added Object to Dirty List - Collection: %s, id: %s', $collection, $hkey));
		$this->statistics['dirty']++;
			
	}
	
	function replace($collection, $key, $value) {
	
		$hkey = $this->hash($key);
		$this->cache[$collection][$hkey] = $value;
		$this->debug(sprintf('Replacing Object in Cache - Collection: %s, id: %s', $collection, $hkey));
		$this->statistics['replaced']++;
		
		// check to make sure the dirty collection exists and object is not already in there.
		if (!empty($this->dirty_objs[$collection])) {
			if(!in_array($hkey, $this->dirty_objs[$collection])) {
				$this->dirty_objs[$collection][] = $hkey;
				$this->dirty_collections[$collection] = true; 
				$this->debug(sprintf('Added Object to Dirty List - Collection: %s, id: %s', $collection, $hkey));
				$this->statistics['dirty']++;
			}
		} else {
			$this->dirty_objs[$collection][] = $hkey;
			$this->dirty_collections[$collection] = true; 
			$this->debug(sprintf('Added Object to Dirty List - Collection: %s, id: %s', $collection, $hkey));
			$this->statistics['dirty']++;
		}
			
		
	}
	
	function get($collection, $key) {
		
		$id = $this->hash($key);
		// check warm cache and return
		if (isset($this->cache[$collection][$id])) {
			$this->debug(sprintf('CACHE HIT (Warm) - Retrieved Object from Cache - Collection: %s, id: %s', $collection, $id));	
			$this->statistics['warm']++;
		//load from cache file	
		} else {
		
			$item = $this->getItemFromCacheStore($collection, $id);
			if ($item) {
				$this->cache[$collection][$id] = $item;
				$this->debug(sprintf('CACHE HIT (Cold) - Retrieved Object from Cache File - Collection: %s, id: %s', $collection, $id));
				$this->statistics['cold']++;
			} else {
				$this->debug( sprintf( 'CACHE MISS - object not found for Collection: %s, id: %s', $collection, $id ) );
				$this->statistics['miss']++;
			}
		}
		
		if (isset($this->cache[$collection][$id])) {
			return $this->cache[$collection][$id];	
		} else {
			return false;
		}
		
	}
	
	function remove($collection, $key) {
	
		$id = $this->hash($key);
		unset($this->cache[$collection][$id]);
		
		return $this->removeItemFromCacheStore($collection, $id);
		
	}
	
	function persistCache() {
		
		$this->debug("starting to persist cache...");
		
		// check for dirty objects
		if (!empty($this->dirty_objs)) {
			
			$this->debug('Dirty Objects: '.print_r($this->dirty_objs, true));
			$this->debug("starting to persist cache...");
			
			// persist dirty objects
			foreach ($this->dirty_objs as $collection => $ids) {
				
				foreach ($ids as $id) {
					$this->putItemToCacheStore($collection, $id);
				}	
			}
			
		} else {
			$this->debug("There seem to be no dirty objects in the cache to persist.");
		}
	}
	
	/**
	 * Store specific implementation of getting an object from the cold cache store
	 */
	function getItemFromCacheStore($collection, $id) {
		return false;
	}
	/**
	 * Store specific implementation of putting an object to the cold cache store
	 */
	function putItemToCacheStore($collection, $id) {
		return false;
	}
	
	/**
	 * Store specific implementation of removing an object to the cold cache store
	 */
	function removeItemFromCacheStore($collection, $id) {
		return false;
	}
	
	/**
	 * Store specific implementation of flushing the cold cache store
	 */
	function flush() {
	
		return false;	
	}
	
	function getStats() {
	
		return sprintf("Cache Statistics: 
						  Total Hits: %s (Warm/Cold: %s/%s)
						  Total Miss: %s
						  Total Added to Cache: %s
						  Total Replaced: %s
						  Total Persisted: %s
						  Total Removed: %s",
						  $this->statistics['warm'] + $this->statistics['cold'],
						  $this->statistics['warm'],
						  $this->statistics['cold'],
						  $this->statistics['miss'],
						  $this->statistics['added'],
						  $this->statistics['replaced'],
						  $this->statistics['dirty'],
						  $this->statistics['removed']);
	}
	
	function prepare($obj) {
	
		return $obj;
	}
	
	function __destruct() {
		
		$this->persistCache();
		$this->debug($this->getStats());
		$this->persistStats();
	}
	
	function persistStats() {
	
		return false;
	}
	
	function hash($id) {
	
		return md5($id);
	}
	
	function debug($msg) {
		
		return owa_coreAPI::debug($msg);
	}
	
	function error($msg) {
	
		return false;
	}
		
	function setCollectionExpirationPeriod($collection_name, $seconds) {
	
		$this->collection_expiration_periods[$collection_name] = $seconds;
	}
	
	function getCollectionExpirationPeriod($collection_name) {
		
		// for some reason an 'array_key_exists' check does not work here. using isset instead.
		if (isset($this->collection_expiration_periods[$collection_name])) {
			return $this->collection_expiration_periods[$collection_name];
		} else {
			return false;
		}
	}
	
	function setGlobalCollection($collection) {
	
		return $this->global_collections[] = $collection;
	
	}
}

?>