classes/oai/ojs/JournalOAI.inc.php

<?php

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


import('oai.OAI');
import('oai.ojs.OAIDAO');

class JournalOAI extends OAI {
   var $site;

   var $journal;

   var $journalId;

   var $dao;


   function JournalOAI($config) {
      parent::OAI($config);

      $this->site = &Request::getSite();
      $this->journal = &Request::getJournal();
      $this->journalId = isset($this->journal) ? $this->journal->getJournalId() : null;
      $this->dao = &DAORegistry::getDAO('OAIDAO');
      $this->dao->setOAI($this);
   }

   function articleIdToIdentifier($articleId) {
      return 'oai:' . $this->config->repositoryId . ':' . 'article/' . $articleId;
   }

   function identifierToArticleId($identifier) {
      $prefix = 'oai:' . $this->config->repositoryId . ':' . 'article/';
      if (strstr($identifier, $prefix)) {
         return (int) str_replace($prefix, '', $identifier);
      } else {
         return false;
      }
   }

   function setSpecToSectionId($setSpec, $journalId = null) {
      $tmpArray = split(':', $setSpec);
      if (count($tmpArray) == 1) {
         list($journalSpec) = $tmpArray;
         $sectionSpec = null;
      } else if (count($tmpArray) == 2) {
         list($journalSpec, $sectionSpec) = $tmpArray;
      } else {
         return array(0, 0);
      }
      return $this->dao->getSetJournalSectionId($journalSpec, $sectionSpec, $this->journalId);
   }


   //
   // OAI interface functions
   //

   function &repositoryInfo() {
      $info = &new OAIRepository();

      if (isset($this->journal)) {
         $info->repositoryName = $this->journal->getJournalTitle();
         $info->adminEmail = $this->journal->getSetting('contactEmail');

      } else {
         $info->repositoryName = $this->site->getSiteTitle();
         $info->adminEmail = $this->site->getSiteContactEmail();
      }

      $info->sampleIdentifier = $this->articleIdToIdentifier(1);
      $info->earliestDatestamp = $this->dao->getEarliestDatestamp($this->journalId);

      return $info;
   }

   function validIdentifier($identifier) {
      return $this->identifierToArticleId($identifier) !== false;
   }

   function identifierExists($identifier) {
      $recordExists = false;
      $articleId = $this->identifierToArticleId($identifier);
      if ($articleId) {
         $recordExists = $this->dao->recordExists($articleId, $this->journalId);
      }
      return $recordExists;
   }

   function &record($identifier) {
      $articleId = $this->identifierToArticleId($identifier);
      if ($articleId) {
         $record = &$this->dao->getRecord($articleId, $this->journalId);
      }
      if (!isset($record)) {
         $record = false;
      }
      return $record;      
   }

   function &records($metadataPrefix, $from, $until, $set, $offset, $limit, &$total) {
      $sectionId = null;
      if (isset($set)) {
         list($journalId, $sectionId) = $this->setSpecToSectionId($set);
      } else {
         $journalId = $this->journalId;
      }
      $records = &$this->dao->getRecords($journalId, $sectionId, $from, $until, $offset, $limit, $total);
      return $records;
   }

   function &identifiers($metadataPrefix, $from, $until, $set, $offset, $limit, &$total) {
      $sectionId = null;
      if (isset($set)) {
         list($journalId, $sectionId) = $this->setSpecToSectionId($set);
      } else {
         $journalId = $this->journalId;
      }
      $records = &$this->dao->getIdentifiers($journalId, $sectionId, $from, $until, $offset, $limit, $total);
      return $records;
   }

   function &sets($offset, &$total) {
      $sets = &$this->dao->getJournalSets($this->journalId, $offset, $total);
      return $sets;
   }

   function &resumptionToken($tokenId) {
      $this->dao->clearTokens();
      $token = $this->dao->getToken($tokenId);
      if (!isset($token)) {
         $token = false;
      }
      return $token;
   }

   function &saveResumptionToken($offset, $params) {
      $token = &new OAIResumptionToken(null, $offset, $params, time() + $this->config->tokenLifetime);
      $this->dao->insertToken($token);
      return $token;
   }
}

?>

---