AuthSourceDAO.inc.php

<?php
 
import('lib.pkp.classes.security.AuthSource');
 
class AuthSourceDAO extends DAO {
   var $plugins;
 
   function __construct() {
      parent::__construct();
      $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 = ?',
         array((int) $authId)
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function getDefaultSource() {
      $result = $this->retrieve(
         'SELECT * FROM auth_sources WHERE auth_default = 1'
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function newDataObject() {
      return new AuthSource();
   }
 
   function _fromRow($row) {
      $auth = $this->newDataObject();
      $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 insertObject($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 updateObject($auth) {
      return $this->update(
         'UPDATE auth_sources SET
            title = ?,
            settings = ?
         WHERE auth_id = ?',
         array(
            $auth->getTitle(),
            serialize($auth->getSettings() ? $auth->getSettings() : array()),
            (int) $auth->getAuthId()
         )
      );
   }
 
   function deleteObject($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 = ?',
         array((int) $authId)
      );
   }
 
   function getSources($rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM auth_sources ORDER BY auth_id',
         false,
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
}