classes/security/AuthSourceDAO.inc.php

<?php

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


import('security.AuthSource');

class AuthSourceDAO extends DAO {
   var $plugins;

   function AuthSourceDAO() {
      parent::DAO();
      $this->plugins = &PluginRegistry::loadCategory(AUTH_PLUGIN_CATEGORY);
   }

   function &getPlugin($authId) {
      $plugin = null;
      $auth = &$this->getSource($authId);
      if ($auth != null) {
         $plugin =& $auth->getPluginClass();
         if ($plugin != null) {
            $plugin = &$plugin->getInstance($auth->getSettings(), $auth->getAuthId());
         }
      }
      return $plugin;
   }

   function &getDefaultPlugin() {
      $plugin = null;
      $auth = &$this->getDefaultSource();
      if ($auth != null) {
         $plugin =& $auth->getPluginClass();
         if ($plugin != null) {
            $plugin = &$plugin->getInstance($auth->getSettings(), $auth->getAuthId());
         }
      }
      return $plugin;
   }

   function &getSource($authId) {
      $result = &$this->retrieve(
         'SELECT * FROM auth_sources WHERE auth_id = ?', $authId
      );

      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = &$this->_returnAuthSourceFromRow($result->GetRowAssoc(false));
      }

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

      return $returner;
   }

   function &getDefaultSource() {
      $result = &$this->retrieve(
         'SELECT * FROM auth_sources WHERE auth_default = 1'
      );

      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = &$this->_returnAuthSourceFromRow($result->GetRowAssoc(false));
      }

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

      return $returner;
   }

   function &_returnAuthSourceFromRow(&$row) {
      $auth = &new AuthSource();
      $auth->setAuthId($row['auth_id']);
      $auth->setTitle($row['title']);
      $auth->setPlugin($row['plugin']);
      $auth->setPluginClass(@$this->plugins[$row['plugin']]);
      $auth->setDefault($row['auth_default']);
      $auth->setSettings(unserialize($row['settings']));
      return $auth;
   }

   function insertSource(&$auth) {
      if (!isset($this->plugins[$auth->getPlugin()])) return false;
      if (!$auth->getTitle()) $auth->setTitle($this->plugins[$auth->getPlugin()]->getDisplayName());
      $this->update(
         'INSERT INTO auth_sources
            (title, plugin, settings)
            VALUES
            (?, ?, ?)',
         array(
            $auth->getTitle(),
            $auth->getPlugin(),
            serialize($auth->getSettings() ? $auth->getSettings() : array())
         )
      );

      $auth->setAuthId($this->getInsertId('auth_sources', 'auth_id'));
      return $auth->getAuthId();
   }

   function updateSource(&$auth) {
      return $this->update(
         'UPDATE auth_sources SET
            title = ?,
            settings = ?
         WHERE auth_id = ?',
         array(
            $auth->getTitle(),
            serialize($auth->getSettings() ? $auth->getSettings() : array()),
            $auth->getAuthId()
         )
      );
   }

   function deleteSource($authId) {
      return $this->update(
         'DELETE FROM auth_sources WHERE auth_id = ?', $authId
      );
   }

   function setDefault($authId) {
      $this->update(
         'UPDATE auth_sources SET auth_default = 0'
      );
      $this->update(
         'UPDATE auth_sources SET auth_default = 1 WHERE auth_id = ?', $authId
      );
   }

   function &getSources($rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM auth_sources ORDER BY auth_id',
         false, $rangeInfo
      );

      $returner = &new DAOResultFactory($result, $this, '_returnAuthSourceFromRow');
      return $returner;
   }
}

?>

---