Marius Cramer
2013-11-14 b1a6a5a3991cec5cd08873b01376e45d0b247f18
server/lib/classes/plugins.inc.php
@@ -29,96 +29,96 @@
*/
class plugins {
   var $available_events = array();
   var $subscribed_events = array();
   var $subscribed_actions = array();
   var $debug = false;
   /*
    This function is called to load the plugins from the plugins-enabled or the plugins-core folder
   */
   function loadPlugins($type) {
      global $app,$conf;
      global $app, $conf;
      $subPath = 'plugins-enabled';
      //if ($type == 'core') $subPath = 'plugins-core';
      $plugins_dir = $conf['rootpath'].$conf['fs_div'].$subPath.$conf['fs_div'];
      $tmp_plugins = array();
      if (is_dir($plugins_dir)) {
         if ($dh = opendir($plugins_dir)) {
            //** Go trough all files in the plugin dir
            while (($file = readdir($dh)) !== false) {
               if($file != '.' && $file != '..' && substr($file,-8,8) == '.inc.php') {
                  $plugin_name = substr($file,0,-8);
               if($file != '.' && $file != '..' && substr($file, -8, 8) == '.inc.php') {
                  $plugin_name = substr($file, 0, -8);
                  $tmp_plugins[$plugin_name] = $file;
               }
            }
            //** sort the plugins by name
            ksort($tmp_plugins);
            //** load the plugins
            foreach($tmp_plugins as $plugin_name => $file) {
               include_once($plugins_dir.$file);
               if($this->debug) $app->log('Loading plugin: '.$plugin_name,LOGLEVEL_DEBUG);
               include_once $plugins_dir.$file;
               if($this->debug) $app->log('Loading plugin: '.$plugin_name, LOGLEVEL_DEBUG);
               $app->loaded_plugins[$plugin_name] = new $plugin_name;
               $app->loaded_plugins[$plugin_name]->onLoad();
            }
         } else {
            $app->log('Unable to open the plugins directory: '.$plugins_dir,LOGLEVEL_ERROR);
            $app->log('Unable to open the plugins directory: '.$plugins_dir, LOGLEVEL_ERROR);
         }
      } else {
         $app->log('Plugins directory missing: '.$plugins_dir,LOGLEVEL_ERROR);
         $app->log('Plugins directory missing: '.$plugins_dir, LOGLEVEL_ERROR);
      }
   }
   /*
      This function is used by the modules to announce which events they provide
   */
   function announceEvents($module_name,$events) {
   function announceEvents($module_name, $events) {
      global $app;
      foreach($events as $event_name) {
         $this->available_events[$event_name] = $module_name;
         if($this->debug) $app->log('Announced event: '.$event_name,LOGLEVEL_DEBUG);
         if($this->debug) $app->log('Announced event: '.$event_name, LOGLEVEL_DEBUG);
      }
   }
   /*
    This function is called by the plugin to register for an event
   */
   function registerEvent($event_name,$plugin_name,$function_name) {
   function registerEvent($event_name, $plugin_name, $function_name) {
      global $app;
      if(!isset($this->available_events[$event_name])) {
         $app->log("Unable to register function '$function_name' from plugin '$plugin_name' for event '$event_name'",LOGLEVEL_DEBUG);
         $app->log("Unable to register function '$function_name' from plugin '$plugin_name' for event '$event_name'", LOGLEVEL_DEBUG);
      } else {
         $this->subscribed_events[$event_name][] = array('plugin' => $plugin_name, 'function' => $function_name);
         if($this->debug)  $app->log("Registered function '$function_name' from plugin '$plugin_name' for event '$event_name'.",LOGLEVEL_DEBUG);
         if($this->debug)  $app->log("Registered function '$function_name' from plugin '$plugin_name' for event '$event_name'.", LOGLEVEL_DEBUG);
      }
   }
   function raiseEvent($event_name,$data) {
   function raiseEvent($event_name, $data) {
      global $app;
      // Get the subscriptions for this event
      $events = (isset($this->subscribed_events[$event_name]))?$this->subscribed_events[$event_name]:'';
      if($this->debug) $app->log('Raised event: '.$event_name,LOGLEVEL_DEBUG);
      if($this->debug) $app->log('Raised event: '.$event_name, LOGLEVEL_DEBUG);
      if(is_array($events)) {
         foreach($events as $event) {
            $plugin_name = $event['plugin'];
            $function_name = $event['function'];
            // Call the processing function of the plugin
            $app->log("Calling function '$function_name' from plugin '$plugin_name' raised by event '$event_name'.",LOGLEVEL_DEBUG);
            $app->log("Calling function '$function_name' from plugin '$plugin_name' raised by event '$event_name'.", LOGLEVEL_DEBUG);
            // call_user_method($function_name,$app->loaded_plugins[$plugin_name],$event_name,$data);
            call_user_func(array($app->loaded_plugins[$plugin_name],$function_name),$event_name,$data);
            call_user_func(array($app->loaded_plugins[$plugin_name], $function_name), $event_name, $data);
            unset($plugin_name);
            unset($function_name);
         }
@@ -126,33 +126,33 @@
      unset($event);
      unset($events);
   }
   /*
    This function is called by the plugin to register for an action
   */
   function registerAction($action_name,$plugin_name,$function_name) {
   function registerAction($action_name, $plugin_name, $function_name) {
      global $app;
      $this->subscribed_actions[$action_name][] = array('plugin' => $plugin_name, 'function' => $function_name);
      if($this->debug)  $app->log("Registered function '$function_name' from plugin '$plugin_name' for action '$event_name'.",LOGLEVEL_DEBUG);
      if($this->debug)  $app->log("Registered function '$function_name' from plugin '$plugin_name' for action '$event_name'.", LOGLEVEL_DEBUG);
   }
   function raiseAction($action_name,$data) {
   function raiseAction($action_name, $data) {
      global $app;
      //* Get the subscriptions for this action
      $actions = (isset($this->subscribed_actions[$action_name]))?$this->subscribed_actions[$action_name]:'';
      if($this->debug) $app->log('Raised action: '.$action_name,LOGLEVEL_DEBUG);
      if($this->debug) $app->log('Raised action: '.$action_name, LOGLEVEL_DEBUG);
      if(is_array($actions)) {
         foreach($actions as $action) {
            $plugin_name = $action['plugin'];
            $function_name = $action['function'];
            $state_out = 'ok';
            //* Call the processing function of the plugin
            $app->log("Calling function '$function_name' from plugin '$plugin_name' raised by action '$action_name'.",LOGLEVEL_DEBUG);
            $state = call_user_func(array($app->loaded_plugins[$plugin_name],$function_name),$action_name,$data);
            $app->log("Calling function '$function_name' from plugin '$plugin_name' raised by action '$action_name'.", LOGLEVEL_DEBUG);
            $state = call_user_func(array($app->loaded_plugins[$plugin_name], $function_name), $action_name, $data);
            //* ensure that we return the highest warning / error level if a error occured in one of the functions
            if($state == 'warning' && $state_out != 'error') $state_out = 'warning';
            if($state == 'error') $state_out = 'error';
@@ -162,10 +162,10 @@
      }
      unset($action);
      unset($actions);
      return $state_out;
   }
}
?>