MonographSearchIndex.inc.php

<?php
 
import('lib.pkp.classes.search.SubmissionSearchIndex');
 
class MonographSearchIndex extends SubmissionSearchIndex {
 
   public function indexObjectKeywords($objectId, $text, &$position) {
      $searchDao = DAORegistry::getDAO('MonographSearchDAO'); /* @var $searchDao MonographSearchDAO */
      $keywords = $this->filterKeywords($text);
      for ($i = 0, $count = count($keywords); $i < $count; $i++) {
         if ($searchDao->insertObjectKeyword($objectId, $keywords[$i], $position) !== null) {
            $position += 1;
         }
      }
   }
 
   public function updateTextIndex($monographId, $type, $text, $assocId = null) {
      $searchDao = DAORegistry::getDAO('MonographSearchDAO'); /* @var $searchDao MonographSearchDAO */
      $objectId = $searchDao->insertObject($monographId, $type, $assocId);
      $position = 0;
      $this->indexObjectKeywords($objectId, $text, $position);
   }
 
   public function updateFileIndex($monographId, $type, $fileId) {
      $submissionFileDao = DAORegistry::getDAO('SubmissionFileDAO'); /* @var $submissionFileDao SubmissionFileDAO */
      $file = $submissionFileDao->getLatestRevision($fileId);
 
      if (isset($file)) {
         $parser = SearchFileParser::fromFile($file);
      }
 
      if (isset($parser)) {
         if ($parser->open()) {
            $searchDao = DAORegistry::getDAO('MonographSearchDAO'); /* @var $searchDao MonographSearchDAO */
            $objectId = $searchDao->insertObject($monographId, $type, $fileId);
 
            $position = 0;
            while(($text = $parser->read()) !== false) {
               $this->indexObjectKeywords($objectId, $text, $position);
            }
            $parser->close();
         } else {
            // cannot open parser; unsupported format?
         }
      }
   }
 
   public function deleteTextIndex($monographId, $type = null, $assocId = null) {
      $searchDao = DAORegistry::getDAO('MonographSearchDAO'); /* @var $searchDao MonographSearchDAO */
      return $searchDao->deleteSubmissionKeywords($monographId, $type, $assocId);
   }
 
   public function submissionMetadataChanged($submission) {
      $publication = $submission->getCurrentPublication();
 
      // Build author keywords
      $authorText = [];
      foreach ($publication->getData('authors') as $author) {
         $authorText = array_merge(
            $authorText,
            array_values((array) $author->getData('givenName')),
            array_values((array) $author->getData('familyName')),
            array_values(array_map('strip_tags', (array) $author->getData('affiliation'))),
            array_values(array_map('strip_tags', (array) $author->getData('biography')))
         );
      }
 
      // Update search index
      import('classes.search.MonographSearch');
      $submissionId = $submission->getId();
      $this->updateTextIndex($submissionId, SUBMISSION_SEARCH_AUTHOR, $authorText);
      $this->updateTextIndex($submissionId, SUBMISSION_SEARCH_TITLE, $publication->getData('title'));
      $this->updateTextIndex($submissionId, SUBMISSION_SEARCH_ABSTRACT, $publication->getData('abstract'));
 
      $this->updateTextIndex($submissionId, SUBMISSION_SEARCH_DISCIPLINE, (array) $publication->getData('disciplines'));
      $this->updateTextIndex($submissionId, SUBMISSION_SEARCH_TYPE, (array) $publication->getData('type'));
      $this->updateTextIndex($submissionId, SUBMISSION_SEARCH_COVERAGE, (array) $publication->getData('coverage'));
      // FIXME Index sponsors too?
   }
 
   public function submissionFilesChanged($monograph) {
      // Index galley files
      $submissionFileDao = DAORegistry::getDAO('SubmissionFileDAO'); /* @var $submissionFileDao SubmissionFileDAO */
      import('lib.pkp.classes.submission.SubmissionFile'); // Constants
      import('classes.search.MonographSearch'); // Constants
      $files = $submissionFileDao->getLatestRevisions($monograph->getId(), SUBMISSION_FILE_PROOF);
 
      foreach ($files as $file) {
         if ($file->getFileId()) {
            $this->updateFileIndex($monograph->getId(), SUBMISSION_SEARCH_GALLEY_FILE, $file->getFileId());
         }
      }
   }
 
   public function clearSubmissionFiles($submission) {
      $searchDao = DAORegistry::getDAO('MonographSearchDAO'); /* @var $searchDao MonographSearchDAO */
      $searchDao->deleteSubmissionKeywords($submission->getId(), SUBMISSION_SEARCH_GALLEY_FILE);
   }
 
   public function submissionChangesFinished() {
      // Trigger a hook to let the indexing back-end know that
      // the index may be updated.
      HookRegistry::call(
         'MonographSearchIndex::monographChangesFinished'
      );
 
      // The default indexing back-end works completely synchronously
      // and will therefore not do anything here.
   }
 
   public function monographChangesFinished() {
      if (Config::getVar('debug', 'deprecation_warnings')) trigger_error('Deprecated call to monographChangesFinished. Use submissionChangesFinished instead.');
      $this->submissionChangesFinished();
   }
 
 
   public function rebuildIndex($log = false) {
      // Clear index
      if ($log) echo 'Clearing index ... ';
      $searchDao = DAORegistry::getDAO('MonographSearchDAO'); /* @var $searchDao MonographSearchDAO */
      // FIXME Abstract into MonographSearchDAO?
      $searchDao->update('DELETE FROM submission_search_object_keywords');
      $searchDao->update('DELETE FROM submission_search_objects');
      $searchDao->update('DELETE FROM submission_search_keyword_list');
      $searchDao->setCacheDir(Config::getVar('files', 'files_dir') . '/_db');
      $searchDao->_dataSource->CacheFlush();
      if ($log) echo "done\n";
 
      // Build index
      $pressDao = DAORegistry::getDAO('PressDAO'); /* @var $pressDao PressDAO */
      $submissionDao = DAORegistry::getDAO('SubmissionDAO'); /* @var $submissionDao SubmissionDAO */
 
      $presses = $pressDao->getAll();
      while ($press = $presses->next()) {
         $numIndexed = 0;
 
         if ($log) echo "Indexing \"", $press->getLocalizedName(), "\" ... ";
 
         $monographs = $submissionDao->getByContextId($press->getId());
         while (!$monographs->eof()) {
            $monograph = $monographs->next();
            if ($monograph->getDatePublished()) {
               $this->submissionMetadataChanged($monograph);
               $this->submissionFilesChanged($monograph);
               $numIndexed++;
            }
         }
         $this->submissionChangesFinished();
 
         if ($log) echo $numIndexed, " monographs indexed\n";
      }
   }
}