classes/plugins/PluginSettingsDAO.inc.php

<?php

// $Id: PluginSettingsDAO.inc.php,v 1.12 2008/07/01 01:16:10 asmecher Exp $


class PluginSettingsDAO extends DAO {
   function &_getCache($journalId, $pluginName) {
      static $settingCache;
      if (!isset($settingCache)) {
         $settingCache = array();
      }
      if (!isset($this->settingCache[$journalId])) {
         $this->settingCache[$journalId] = array();
      }
      if (!isset($this->settingCache[$journalId][$pluginName])) {
         import('cache.CacheManager');
         $cacheManager =& CacheManager::getManager();
         $this->settingCache[$journalId][$pluginName] = $cacheManager->getCache(
            'pluginSettings-' . $journalId, $pluginName,
            array($this, '_cacheMiss')
         );
      }
      return $this->settingCache[$journalId][$pluginName];
   }

   function getSetting($journalId, $pluginName, $name) {
      $cache =& $this->_getCache($journalId, $pluginName);
      return $cache->get($name);
   }

   function _cacheMiss(&$cache, $id) {
      $contextParts = explode('-', $cache->getContext());
      $journalId = array_pop($contextParts);
      $settings =& $this->getPluginSettings($journalId, $cache->getCacheId());
      if (!isset($settings[$id])) {
         // Make sure that even null values are cached
         $cache->setCache($id, null);
         return null;
      }
      return $settings[$id];
   }

   function &getPluginSettings($journalId, $pluginName) {
      $pluginSettings[$pluginName] = array();

      $result = &$this->retrieve(
         'SELECT setting_name, setting_value, setting_type FROM plugin_settings WHERE plugin_name = ? AND journal_id = ?', array($pluginName, $journalId)
      );

      if ($result->RecordCount() == 0) {
         $returner = null;
         $result->Close();
         return $returner;

      } else {
         while (!$result->EOF) {
            $row = &$result->getRowAssoc(false);
            $value = $this->convertFromDB($row['setting_value'], $row['setting_type']);
            $pluginSettings[$pluginName][$row['setting_name']] = $value;
            $result->MoveNext();
         }
         $result->close();
         unset($result);

         $cache =& $this->_getCache($journalId, $pluginName);
         $cache->setEntireCache($pluginSettings[$pluginName]);

         return $pluginSettings[$pluginName];
      }
   }

   function updateSetting($journalId, $pluginName, $name, $value, $type = null) {
      $cache =& $this->_getCache($journalId, $pluginName);
      $cache->setCache($name, $value);

      $result = $this->retrieve(
         'SELECT COUNT(*) FROM plugin_settings WHERE plugin_name = ? AND setting_name = ? AND journal_id = ?',
         array($pluginName, $name, $journalId)
      );

      $value = $this->convertToDB($value, $type);
      if ($result->fields[0] == 0) {
         $returner = $this->update(
            'INSERT INTO plugin_settings
               (plugin_name, journal_id, setting_name, setting_value, setting_type)
               VALUES
               (?, ?, ?, ?, ?)',
            array($pluginName, $journalId, $name, $value, $type)
         );
      } else {
         $returner = $this->update(
            'UPDATE plugin_settings SET
               setting_value = ?,
               setting_type = ?
               WHERE plugin_name = ? AND setting_name = ? AND journal_id = ?',
            array($value, $type, $pluginName, $name, $journalId)
         );
      }

      $result->Close();
      unset($result);

      return $returner;
   }

   function deleteSetting($journalId, $pluginName, $name) {
      $cache =& $this->_getCache($pluginName);
      $cache->setCache($name, null);

      return $this->update(
         'DELETE FROM plugin_settings WHERE plugin_name = ? AND setting_name = ? AND journal_id = ?',
         array($pluginName, $name, $journalId)
      );
   }

   function deleteSettingsByPlugin($pluginName) {
      $cache =& $this->_getCache($pluginName);
      $cache->flush();

      return $this->update(
            'DELETE FROM plugin_settings WHERE plugin_name = ?', $pluginName
      );
   }

   function deleteSettingsByJournalId($journalId) {
      return $this->update(
            'DELETE FROM plugin_settings WHERE journal_id = ?', $journalId
      );
   }

   function _performReplacement($rawInput, $paramArray = array()) {
      $value = preg_replace_callback('{{translate key="([^"]+)"}}', '_installer_plugin_regexp_callback', $rawInput);
      foreach ($paramArray as $pKey => $pValue) {
         $value = str_replace('{$' . $pKey . '}', $pValue, $value);
      }
      return $value;
   }

   function &_buildObject (&$node, $paramArray = array()) {
      $value = array();
      foreach ($node->getChildren() as $element) {
         $key = $element->getAttribute('key');
         $childArray = &$element->getChildByName('array');
         if (isset($childArray)) {
            $content = $this->_buildObject($childArray, $paramArray);
         } else {
            $content = $this->_performReplacement($element->getValue(), $paramArray);
         }
         if (!empty($key)) {
            $key = $this->_performReplacement($key, $paramArray);
            $value[$key] = $content;
         } else $value[] = $content;
      }
      return $value;
   }

   function installSettings($journalId, $pluginName, $filename, $paramArray = array()) {
      $xmlParser = &new XMLParser();
      $tree = $xmlParser->parse($filename);

      if (!$tree) {
         $xmlParser->destroy();
         return false;
      }

      foreach ($tree->getChildren() as $setting) {
         $nameNode = &$setting->getChildByName('name');
         $valueNode = &$setting->getChildByName('value');

         if (isset($nameNode) && isset($valueNode)) {
            $type = $setting->getAttribute('type');
            $name = &$nameNode->getValue();

            if ($type == 'object') {
               $arrayNode = &$valueNode->getChildByName('array');
               $value = $this->_buildObject($arrayNode, $paramArray);
            } else {
               $value = $this->_performReplacement($valueNode->getValue(), $paramArray);
            }

            // Replace translate calls with translated content
            $this->updateSetting($journalId, $pluginName, $name, $value, $type);
         }
      }

      $xmlParser->destroy();

   }
}

function _installer_plugin_regexp_callback($matches) {
   return Locale::translate($matches[1]);
}

?>

---