PEIP_Object_Map_Dispatcher.php

Go to the documentation of this file.

<?php

/*
 * This file is part of the PEIP package.
 * (c) 2010 Timo Michna <timomichna/yahoo.de>
 * 
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

class PEIP_Object_Map_Dispatcher
    implements PEIP_INF_Object_Map_Dispatcher {

    protected 
        $listeners = NULL;

         
    public function connect($name, $object, PEIP_INF_Handler $listener){
            $listners = $this->doGetListeners();
            if (!isset($listners[$object])){
                $listners[$object] = new ArrayObject;
            }
            if (!array_key_exists($name, $listners[$object])){ 
                $listners[$object][$name] = array();
            } 
            $this->listeners[$object][$name][spl_object_hash($listener)] = $listener; 
            return true; 
        }

    public function disconnect($name, $object, PEIP_INF_Handler $listener){
            $listners = $this->doGetListeners();
            if (!isset($listners[$object]) || !isset($listners[$object][$name])){
                return false;
            }
            $eventListeners = $listners[$object][$name];
            $hash = spl_object_hash($listener);
            if(isset($eventListeners[$hash])){
                unset($eventListeners[$hash]);
                $listners[$object][$name] = $eventListeners;
                return true;
            }
            return false;
        }
  
    public function hasListeners($name, $object){
        $listners = $this->doGetListeners();
        if (!$this->hadListeners($name, $object)){
                $res = false;
        }else{
                $res = (boolean) count($this->getListeners($name, $object));
        }
        return $res;
        }

    public function hadListeners($name, $object){
        $listners = $this->doGetListeners();
        return (isset($listners[$object]) && isset($listners[$object][$name])) ? true : false;  
        }

    public function getEventNames($object){
        $listeners = $this->doGetListeners();
        if (!isset($listeners[$object])){
                return array();
        }
        return array_keys($listeners[$object]->getArrayCopy());
        }
    
    public function notify($name, $object){
        if($this->hasListeners($name, $object)){
            self::doNotify($this->getListeners($name, $object), $object);   
        }
        return true;         
    }

    public function notifyUntil($name, $subject){
        if($this->hasListeners($name, $subject)){               
            $res = self::doNotifyUntil($this->getListeners($name, $subject), $subject);   
        }
        return $res;
        }

    public function getListeners($name, $object){
            if (!$this->hadListeners($name, $object)){
                return array();
            }
        return array_values($this->listeners[$object][$name]);
        }
    
    protected function doGetListeners(){
        return isset($this->listeners) ? $this->listeners : $this->listeners = new SplObjectStorage();
    }

    protected static function doNotify(array $listeners, $subject){
        foreach($listeners as $listener){ 
            $listener->handle($subject);    
        }   
    }  

    protected static function doNotifyUntil(array $listeners, $subject){  
        $res = NULL;
        foreach ($listeners as $listener){
                $res = $listener->handle($subject);
                if ($res){
                return $listener;  
                }
        }
        return $res;
    } 
}

---