source: branches/1.2/workflow/inc/engine/src/common/Observable.php @ 1349

<?php
/**
 * Implements the Observer design pattern defining Observable
 * objects, when a class extends Observable Observers can be attached to
 * the class listening for some event. When an event is detected in any
 * method of the derived class the method can call notifyAll($event,$msg)
 * to notify all the observers listening for event $event.
 * The Observer objects must extend the Observer class and define the
 * notify($event,$msg) method
 * 
 * @abstract
 * @package Galaxia
 * @license http://www.gnu.org/copyleft/gpl.html GPL 
 */
class Observable {
  /**
   * @var array $_observers Observed subclasses
   * @access private
   */
  var $_observers=Array();
  
  /**
   * Empty constructor
   * 
   * @access public
   * @return object Observable instance
   */
  function Observable() {
  
  }
  
  /**
   * This method can be used to attach an object to the class listening for
   * some specific event. The object will be notified when the specified
   * event is triggered by the derived class
   * 
   * @param string $event
   * @param object &$obj
   * @access public
   * @return mixed 
   */
  function attach($event, &$obj)
  {
    if (!is_object($obj)) {
        return false;
    }
    $obj->_observerId = uniqid(rand());
    $this->_observers[$event][$obj->_observerId] = &$obj;
  }
  
  /**
   * Attaches an object to the class listening for any event,
   * The object will be notified when any event occurs in the derived class
   * 
   * @param object &$obj
   * @return mixed 
   * @access public
   */
  function attach_all(&$obj)
  {
    if (!is_object($obj)) {
        return false;
    }
    $obj->_observerId = uniqid(rand());
    $this->_observers['all'][$obj->_observerId] = &$obj;
  }
  
  /**
   * Detaches an observer from the class
   * 
   * @param object &$obj
   * @return void 
   * @access public
   */
  function dettach(&$obj)
  {
        if (isset($this->_observers[$obj->_observerId])) {
        unset($this->_observers[$obj->_observerId]);
    }
  }
  
  /**
   * Notifies objects of an event. This is called in the methods of the derived class that want to notify some event
   *
   * @access protected
   * @param string $event
   * @param string $msg 
   * @return void  
   */
  function notify_all($event, $msg)
  {
        //reset($this->_observers[$event]);
        if(isset($this->_observers[$event])) {
        foreach ($this->_observers[$event] as $observer) {
                $observer->notify($event,$msg);
        }
    }
        if(isset($this->_observers['all'])) {
        foreach ($this->_observers['all'] as $observer) {
                $observer->notify($event,$msg);
        }
    }
    
  } 

}
?>