AccessKeyDAO.inc.php

<?php
 
import('lib.pkp.classes.security.AccessKey');
 
class AccessKeyDAO extends DAO {
 
   function &getAccessKey($accessKeyId) {
      $result = $this->retrieve(
         sprintf(
            'SELECT * FROM access_keys WHERE access_key_id = ? AND expiry_date > %s',
            $this->datetimeToDB(Core::getCurrentDate())
         ),
         array((int) $accessKeyId)
      );
 
      $accessKey = null;
      if ($result->RecordCount() != 0) {
         $accessKey =& $this->_returnAccessKeyFromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $accessKey;
   }
 
   function &getAccessKeyByUserId($context, $userId) {
      $result = $this->retrieve(
         sprintf(
            'SELECT * FROM access_keys WHERE context = ? AND user_id = ? AND expiry_date > %s',
            $this->datetimeToDB(Core::getCurrentDate())
         ),
         array($context, $userId)
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner =& $this->_returnAccessKeyFromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function &getAccessKeyByKeyHash($context, $userId, $keyHash, $assocId = null) {
      $paramArray = array($context, $keyHash, (int) $userId);
      if (isset($assocId)) $paramArray[] = (int) $assocId;
      $result = $this->retrieve(
         sprintf(
            'SELECT * FROM access_keys WHERE context = ? AND key_hash = ? AND user_id = ? AND expiry_date > %s' . (isset($assocId)?' AND assoc_id = ?':''),
            $this->datetimeToDB(Core::getCurrentDate())
         ),
         $paramArray
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner =& $this->_returnAccessKeyFromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function newDataObject() {
      return new AccessKey();
   }
 
   function &_returnAccessKeyFromRow($row) {
      $accessKey = $this->newDataObject();
      $accessKey->setId($row['access_key_id']);
      $accessKey->setKeyHash($row['key_hash']);
      $accessKey->setExpiryDate($this->datetimeFromDB($row['expiry_date']));
      $accessKey->setContext($row['context']);
      $accessKey->setAssocId($row['assoc_id']);
      $accessKey->setUserId($row['user_id']);
 
      HookRegistry::call('AccessKeyDAO::_returnAccessKeyFromRow', array(&$accessKey, &$row));
 
      return $accessKey;
   }
 
   function insertObject($accessKey) {
      $this->update(
         sprintf('INSERT INTO access_keys
            (key_hash, expiry_date, context, assoc_id, user_id)
            VALUES
            (?, %s, ?, ?, ?)',
            $this->datetimeToDB($accessKey->getExpiryDate())),
         array(
            $accessKey->getKeyHash(),
            $accessKey->getContext(),
            $accessKey->getAssocId()==''?null:(int) $accessKey->getAssocId(),
            (int) $accessKey->getUserId()
         )
      );
 
      $accessKey->setId($this->getInsertId());
      return $accessKey->getId();
   }
 
   function updateObject(&$accessKey) {
      return $this->update(
         sprintf('UPDATE access_keys
            SET
               key_hash = ?,
               expiry_date = %s,
               context = ?,
               assoc_id = ?,
               user_id = ?
            WHERE access_key_id = ?',
            $this->datetimeToDB($accessKey->getExpiryDate())),
         array(
            $accessKey->getKeyHash(),
            $accessKey->getContext(),
            $accessKey->getAssocId()==''?null:(int) $accessKey->getAssocId(),
            (int) $accessKey->getUserId(),
            (int) $accessKey->getId()
         )
      );
   }
 
   function deleteObject(&$accessKey) {
      return $this->deleteAccessKeyById($accessKey->getId());
   }
 
   function deleteAccessKeyById($accessKeyId) {
      return $this->update(
         'DELETE FROM access_keys WHERE access_key_id = ?',
         array((int) $accessKeyId)
      );
   }
 
   function transferAccessKeys($oldUserId, $newUserId) {
      return $this->update(
         'UPDATE access_keys SET user_id = ? WHERE user_id = ?',
         array((int) $newUserId, (int) $oldUserId)
      );
   }
 
   function deleteExpiredKeys() {
      return $this->update(
         sprintf(
            'DELETE FROM access_keys WHERE expiry_date <= %s',
            $this->datetimeToDB(Core::getCurrentDate())
         )
      );
   }
 
   function getInsertId() {
      return $this->_getInsertId('access_keys', 'access_key_id');
   }
}