collectionObject = new ObjectHelper($pid); $this->pid = $pid; } } static function get_collection_query($pid) { if ($query = self::_get_collection_query_from_stream($pid)) { return $query; } else { return self::_get_default_collection_query($pid); } } static function _get_collection_query_from_stream($pid) { module_load_include('inc', 'fedora_repository', 'api/fedora_item'); $item = new Fedora_Item($pid); if ($item->exists() && array_key_exists('QUERY', $item->datastreams)) { return $item->get_datastream_dissemination('QUERY'); } else { return FALSE; } } static function _get_default_collection_query($pid) { return 'select $object $title $content from <#ri> where ($object $title and $object $content and ($object or $object ) and $object ) minus $content order by $title'; } /** * Gets objects related to this object. Must include offset and limit! * * Calls self::getRelatedItems() but requires limit and offset. * * @param $pid string * A string containing a Fedora PID. * @param $limit * An integer * @param type $offset * @param type $itqlquery * @return type */ static function getRelatedObjects($pid, $limit, $offset, $itqlquery=NULL) { return self::getRelatedItems($pid, $itqlquery, $limit, $offset); } /** * Gets objects related to this item. * * Query the resource index using the provided iTQL query. If no query is * provided, one should be obtained via self::get_collection_query() which * grabs the child objects. * * @param $pid string * A string containing a PID which may be substituted into the query, * in place of the %parent_collection% placeholder. * @param $itqlquery string * An optional iTQL query. * @param $limit int * An optional integer to limit the number of results returned. * @param int $offset * An optional integer used to offset the results returned. (Query should * involve a sort to maintain consistency. * @return string * Sparql XML results from the resource index. */ static function getRelatedItems($pid, $query_string = NULL, $limit = NULL, $offset = NULL) { module_load_include('inc', 'fedora_repository', 'ObjectHelper'); module_load_include('inc', 'fedora_repository', 'api/fedora_utils'); if (!fedora_repository_access(OBJECTHELPER :: $OBJECT_HELPER_VIEW_FEDORA, $pid)) { drupal_set_message(t("You do not have access to Fedora objects within the attempted namespace or access to Fedora denied."), 'error'); return ' '; } $objectHelper = new ObjectHelper(); if ($query_string === NULL) { $query_string = self::get_collection_query($pid); } // Replace %parent_collection% with the actual collection PID $query_string = preg_replace("/\%parent_collection\%/", "", $query_string); $url = variable_get('fedora_repository_url', 'http://localhost:8080/fedora/risearch'); $settings = array( 'type' => 'tuples', 'flush' => TRUE, 'format' => 'Sparql', 'lang' => 'itql', 'stream' => 'on', 'query' => $query_string ); if ($limit > 0) { $settings['limit'] = $limit; } if ($offset > 0) { $settings['offset'] = $offset; } $url .= '?' . http_build_query($settings, NULL, '&'); $content = do_curl($url); return $content; } /** * get Collection Policy Stream ? * @param type $collection_pid * @return type */ function getCollectionPolicyStream($collection_pid) { if ($this->collectionPolicyStream != NULL) { return $this->collectionPolicyStream; } $this->collectionPolicyStream = $this->getStream($collection_pid, CollectionClass :: $COLLECTION_CLASS_COLLECTION_POLICY_STREAM, 0); return $this->collectionPolicyStream; } /** * get Relationship element ? * @param type $collection_pid * @return type */ function getRelationshipElement($collection_pid) { $stream = $this->getCollectionPolicyStream($collection_pid); try { $xml = new SimpleXMLElement($stream); } catch (Exception $e) { drupal_set_message(t('Error getting relationship element from policy stream @e', array('@e' => check_plain($e->getMessage()))), 'error'); return; } $relationship = $xml->relationship[0]; return $relationship; } /** * get Collection View Stream ? * @param type $collection_pid * @return type */ function getCollectionViewStream($collection_pid) { $this->collectionViewStream = $this->getStream($collection_pid, CollectionClass :: $COLLECTION_CLASS_COLLECTION_VIEW_STREAM, 0); return $this->collectionViewStream; } /** * get Stream ? * @param type $pid * @param type $dsid * @param type $showError * @return type */ function getStream($pid, $dsid, $showError = 1) { module_load_include('inc', 'fedora_repository', 'api/fedora_item'); $item = new fedora_item($pid); return isset($item->datastreams[$dsid]) ? $item->get_datastream_dissemination($dsid) : NULL; } /** * get Pid name space ? * @param type $pid * @param type $dsid * @return type */ function getPidNameSpace($pid, $dsid) { $stream = $this->getCollectionPolicyStream($pid); try { $xml = new SimpleXMLElement($stream); } catch (Exception $e) { drupal_set_message(t('Error getting PID namespace @e', array('@e' => check_plain($e->getMessage()))), 'error'); return; } foreach ($xml->contentmodels->contentmodel as $contentModel) { // $contentModelName=strip_tags($contentModel['name']); $contentdsid = strip_tags($contentModel->dsid); if (strtolower($contentdsid) == strtolower($dsid)) { return strip_tags($contentModel->pid_namespace->asXML()); } } drupal_set_message(t('Error getting PID namespace! using collection pid of !pid and content model of !dsid', array('!pid' => $pid, '!dsid' => $dsid)), 'error'); return NULL; } /** * gets a list of content models from a collection policy * @param type $collection_pid * @param type $showError * @return ContentModel */ function getContentModels($collection_pid, $showError = TRUE) { module_load_include('inc', 'Fedora_Repository', 'ContentModel'); $collection_stream = $this->getCollectionPolicyStream($collection_pid); try { $xml = new SimpleXMLElement($collection_stream); } catch (Exception $e) { if ($showError) { drupal_set_message(t('@e', array('@e' => check_plain($e->getMessage()))), 'error'); } return NULL; } foreach ($xml->contentmodels->contentmodel as $content_model) { $contentModel = new ContentModel(); $contentModel->contentModelDsid = $content_model->dsid; $contentModel->contentModelPid = $content_model->pid; $contentModel->pidNamespace = $content_model->pidNamespace; $contentModel->contentModelName = $content_model['name']; $models[] = $contentModel; } return $models; } /** * using the collection policies pid namespace get a new pid by calling fedora' get next pid and appending it to the namespace * $pid is the $pid of the content model * $dsid is the datastream id of the content model. */ function getNextPid($pid, $dsid) { module_load_include('inc', 'Fedora_Repository', 'ConnectionHelper'); $pidNameSpace = $this->getPidNameSpace($pid, $dsid); $pname = substr($pidNameSpace, 0, strpos($pidNameSpace, ":")); module_load_include('inc', 'fedora_repository', 'api/fedora_item'); return Fedora_Item::get_next_pid_in_namespace($pname); } /** * gets the form handler file, class and method and returns them in an array * * @param string $pid The content model PID * @param string $dsid The content model DSID * @return array The file, class and method name to handle the ingest form. */ function getFormHandler($pid, $dsid) { $stream = $this->getContentModelStream($pid, $dsid); try { $xml = new SimpleXMLElement($stream); } catch (Exception $e) { drupal_set_message(t('Error Getting FormHandler: @e', array('@e' => check_plain($e->getMessage()))), 'error'); return NULL; } $formHandler = $xml->ingest_form; if ($formHandler != NULL) { $handlerDsid = strip_tags($formHandler['dsid']); $handlerMethod = strip_tags($formHandler->form_builder_method->form_handler->asXML()); $handlerFile = strip_tags($formHandler->form_builder_method->file->asXML()); $handlerClass = strip_tags($formHandler->form_builder_method->class_name->asXML()); $handlerModule = strip_tags($formHandler->form_builder_method->module->asXML()); $returnArray = array(); $returnArray['module'] = $handlerModule; $returnArray['method'] = $handlerMethod; $returnArray['class'] = $handlerClass; $returnArray['file'] = $handlerFile; return $returnArray; } drupal_set_message(t("Error getting form handler. No handler found for !pid - !dsid", array('!pid' => $pid, '!dsid' => $dsid)), 'error'); return NULL; } /** * get Allowed Mime Types * @param type $contentModelPid * @param type $contentModel_dsid * @return type */ function getAllowedMimeTypes($contentModelPid, $contentModel_dsid) { $stream = $this->getContentModelStream($contentModelPid, $contentModel_dsid); try { $xml = new SimpleXMLElement($stream); } catch (Exception $e) { drupal_set_message(t('Error getting content model stream for mime types @e', array('@e' => check_plain($e->getMessage()))), 'error'); return; } foreach ($xml->mimetypes->type as $type) { $types[] = $type; } return $types; } /** * Grabs the rules from the content model stream * file the file that has been uploaded * * @param type $file * @param type $mimetype * @param type $pid * @param type $dsid * @return type */ function getAndDoRules($file, $mimetype, $pid, $dsid) { if (!user_access('ingest new fedora objects')) { drupal_set_message(t('You do not have permission to ingest objects.')); return FALSE; } $stream = $this->getContentModelStream($pid, $dsid); try { $xml = new SimpleXMLElement($stream); } catch (Exception $e) { drupal_set_message(t('Error getting content model stream @e', array('@e' => check_plain($e->getMessage()))), 'error'); return FALSE; } foreach ($xml->ingest_rules->rule as $rule) { foreach ($rule->applies_to as $type) { if (!strcmp(trim($type), trim($mimetype))) { $methods = $rule->methods->method; return $this->callMethods($file, $methods); } } } } /** * calls the methods defined in the content model rules .xml file stored in a Fedora object * * @param type $file * @param type $methods * @return type */ function callMethods($file, $methods) { foreach ($methods as $method) { $phpFile = strip_tags($method->file->asXML()); $phpClass = strip_tags($method->class_name->asXML()); $phpMethod = strip_tags($method->method_name->asXML()); $file_ext = strip_tags($method->modified_files_ext->asXML()); $parameters = $method->parameters->parameter; $dsid = strip_tags($method->datastream_id); $parametersArray = array(); if (isset($parameters)) { foreach ($parameters as $parameter) { $name = strip_tags($parameter['name']); $value = strip_tags($parameter->asXML()); $parametersArray["$name"] = $value; } } // module_load_include( $phpFile, 'Fedora_Repository', ' '); require_once(drupal_get_path('module', 'fedora_repository') . '/' . $phpFile); $thisClass = new $phpClass (); $returnValue = $thisClass->$phpMethod($parametersArray, $dsid, $file, $file_ext); if (!$returnValue) { drupal_set_message(t('Error! Failed running content model method !m !rv', array('!m' => $phpMethod, '!rv' => $returnValue))); return FALSE; } } return TRUE; } /** * grabs a xml form definition from a content model and builds * the form using drupals forms api * * @param type $form * @param type $form_state * @param type $contentModelPid * @param type $contentModelDsid * @return type */ function build_ingest_form(&$form, &$form_state, $contentModelPid, $contentModelDsid) { $stream = $this->getContentModelStream($contentModelPid, $contentModelDsid); try { $xml = new SimpleXMLElement($stream); } catch (Exception $e) { drupal_set_message(t('Error getting ingest form stream @e', array('@e' => check_plain($e->getMessage()))), 'error'); return FALSE; } $docRoot = $_SERVER['DOCUMENT_ROOT']; $file = (isset($form_state['values']['ingest-file-location']) ? $form_state['values']['ingest-file-location'] : ''); // $fullPath = $docRoot . '' . $file; $fullpath = $file; // $form = array(); $form['step'] = array( '#type' => 'hidden', '#value' => (isset($form_state['values']['step']) ? $form_state['values']['step'] : 0) + 1, ); $form['ingest-file-location'] = array( '#type' => 'hidden', '#value' => $file, ); $form['content_model_name'] = array( '#type' => 'hidden', '#value' => $contentModelDsid ); $form['models'] = array(//content models available '#type' => 'hidden', '#value' => $form_state['values']['models'], ); $form['fullpath'] = array( '#type' => 'hidden', '#value' => $fullpath, ); $form['#attributes']['enctype'] = 'multipart/form-data'; $form['indicator']['ingest-file-location'] = array( '#type' => 'file', '#title' => t('Upload Document'), '#size' => 48, '#description' => t('Full text'), ); if ($xml->ingest_form->hide_file_chooser == 'TRUE') { $form['indicator']['ingest-file-location']['#type'] = 'hidden'; } $ingest_form = $xml->ingest_form; //should only be one $drupal_module = strip_tags($ingest_form->form_builder_method->module->asXML()); if (empty($drupal_module)) { $drupal_module = 'fedora_repository'; } $phpFile = strip_tags($ingest_form->form_builder_method->file->asXML()); $phpClass = strip_tags($ingest_form->form_builder_method->class_name->asXML()); $phpMethod = strip_tags($ingest_form->form_builder_method->method_name->asXML()); $dsid = strip_tags($ingest_form['dsid']); // module_load_include('php', 'Fedora_Repository', $phpFile); require_once(drupal_get_path('module', $drupal_module) . '/' . $phpFile); $thisClass = new $phpClass (); return $thisClass->$phpMethod($form, $ingest_form, $form_state['values'], $form_state); } /** * this will also create a personal collection for an existing user if they don't have one * not using this function currently * * @param type $user * @return type */ function createUserCollection(& $user) { if (isset($user->fedora_personal_pid)) { return; } $username = array( 'name' => variable_get('fedora_admin_user', 'fedoraAdmin') ); $admin_user = user_load($username); module_load_include('inc', 'fedora_repository', 'ConnectionHelper'); $connectionHelper = new ConnectionHelper(); try { $soapClient = $connectionHelper->getSoapClient(variable_get('fedora_soap_manage_url', 'http://localhost:8080/fedora/wsdl?api=API-M')); $pidNameSpace = variable_get('fedora_repository_pid', 'vre:'); $pidNameSpace = substr($pidNameSpace, 0, strpos($pidNameSpace, ":")); $params = array( 'numPIDs' => '', 'pidNamespace' => $pidNameSpace ); $object = $soapClient->__soapCall('getNextPID', array( $params )); } catch (exception $e) { drupal_set_message(t('Error getting Next PID: @e', array('@e' => check_plain($e->getMessage()))), 'error'); return FALSE; } $pid = implode(get_object_vars($object)); $pidNumber = strstr($pid, ":"); $pid = $pidNameSpace . ':' . 'USER-' . $user->name . '-' . substr($pidNumber, 1); $personal_collection_pid = array( 'fedora_personal_pid' => $pid ); module_load_include('inc', 'fedora_repository', 'plugins/PersonalCollectionClass'); $personalCollectionClass = new PersonalCollectionClass(); if (!$personalCollectionClass->createCollection($user, $pid, $soapClient)) { drupal_set_message(t("Did not create a personal collection object for !u", array('!u' => $user->name))); return FALSE; //creation failed don't save the collection pid in drupal db } user_save($user, $personal_collection_pid); return TRUE; } /** * Queries a collection object for an xslt to format how the * collection of objects is displayed. * * @param type $pid * @param type $path * @param type $canUseDefault * @return type */ function getXslContent($pid, $path, $canUseDefault = TRUE) { module_load_include('inc', 'fedora_repository', 'CollectionClass'); $collectionClass = new CollectionClass(); $xslContent = $collectionClass->getCollectionViewStream($pid); //If there's no XSLT from the object, then check if the one which used to exist, does... if (!$xslContent && $canUseDefault && file_exists($path . '/xsl/sparql_to_html.xsl')) { $xslContent = file_get_contents($path . '/xsl/sparql_to_html.xsl'); } return $xslContent; } /** * show field sets ? * @global type $base_url * @global type $user * @param type $page_number * @return string */ function showFieldSets($page_number) { module_load_include('inc', 'fedora_repository', 'api/fedora_item'); module_load_include('inc', 'fedora_repository', 'CollectionPolicy'); //module_load_include('inc', 'fedora_repository', 'BatchIngest'); //Legacy code? global $base_url; global $user; $tabset = array(); $query = NULL; $item = new Fedora_Item($this->pid); if ($item->exists() && array_key_exists('QUERY', $item->datastreams)) { $query = $item->get_datastream_dissemination('QUERY'); } $results = $this->getRelatedItems($this->pid, $query); $collection_items = $this->renderCollection($results, $this->pid, NULL, NULL, $page_number); $show_batch_tab = FALSE; $policy = CollectionPolicy::loadFromCollection($this->pid, TRUE); if (!empty($policy)) { $content_models = $policy->getContentModels(); } if (count($content_models) == 1 && $content_models[0]->pid == "islandora:collectionCModel") { $show_batch_tab = FALSE; } // Check the form post to see if we are in the middle of an ingest operation. $add_selected = ((!empty($_POST['form_id']) && $_POST['form_id'] == 'fedora_repository_ingest_form') || !$collection_items); $view_selected = !$add_selected; $tabset['view_tab'] = array( '#type' => 'tabpage', '#title' => t('View'), '#selected' => $view_selected, '#content' => $collection_items, '#tab_name' => 'view-tab', ); $add_to_collection = $this->getIngestInterface(); if (!empty($add_to_collection)) { $tabset['add_tab'] = array( '#type' => 'tabpage', '#title' => t('Add'), '#selected' => $add_selected, // This will be the content of the tab. '#content' => $add_to_collection, '#tab_name' => 'add-tab', ); } return $tabset; } /** * get Ingest Interface ?? * @global type $base_url * @return string */ function getIngestInterface() { global $base_url; $objectHelper = new ObjectHelper(); module_load_include('inc', 'Fedora_Repository', 'CollectionPolicy'); $collectionPolicyExists = $objectHelper->getMimeType($this->pid, CollectionPolicy::getDefaultDSID()); if (user_access(ObjectHelper :: $INGEST_FEDORA_OBJECTS) && $collectionPolicyExists) { if (!empty($collectionPolicyExists)) { $allow = TRUE; if (module_exists('fedora_fesl')) { $allow = fedora_fesl_check_roles($this->pid, 'write'); } if ($allow) { $ingestObject = drupal_get_form('fedora_repository_ingest_form', $this->pid); } } } else { $ingestObject = ''; } return $ingestObject; } /** * Unfortunate function, I know... * * Does just what it says: Hacks the default Drupal pager such that it might * be rendered. */ protected static function _hack_pager($pager_name, $per_page, $total_items) { global $pager_total, $pager_page_array; $pager_total[$pager_name] = ceil($total_items / $per_page); $page_info = explode(',', isset($_GET['page']) ? $_GET['page'] : ''); $page = $page_info[$pager_name]; if ($page < 0) { $page = 0; } if (!isset($pager_page_array)) { $pager_page_array = pager_load_array($page, $pager_name, $page_info); } else { $pager_page_array = pager_load_array($page, $pager_name, $pager_page_array); } $page = $pager_page_array[$pager_name]; return $page; } /** * render collection * @global type $base_url * @param type $content * @param type $pid * @param type $dsId * @param type $collection * @param int $pageNumber * @return type */ function renderCollection($content, $pid, $dsId, $collectionName, $pageNumber = NULL) { $path = drupal_get_path('module', 'fedora_repository'); global $base_url; $collection_pid = $pid; //we will be changing the pid later maybe $objectHelper = new ObjectHelper(); $parsedContent = NULL; $contentModels = $objectHelper->get_content_models_list($pid); $isCollection = FALSE; //if this is a collection object store the $pid in the session as it will come in handy //after a purge or ingest to return to the correct collection. $fedoraItem = NULL; if (empty($collectionName)) { $collectionName = menu_get_active_title(); } $xslContent = $this->getXslContent($pid, $path); $objectList = ''; if (isset($content) && $content != FALSE) { if (!$xslContent) { //Didn't find an XSLT. module_load_include('inc', 'fedora_repository', 'ObjectHelper'); $intermediate_results = ObjectHelper::parse_sparql_results($content); unset($content); $per_page = 20; //XXX: Make this configurable. $pager_name = 0; $total = count($intermediate_results); $pager_page = self::_hack_pager($pager_name, $per_page, $total); $results = array(); foreach (array_slice($intermediate_results, $per_page * $pager_page, $per_page) as $result) { $title = $result['title']; $obj_path = "fedora/repository/{$result['object']}"; $thumbnail = theme('image', "$obj_path/TN", $title, $title, array(), FALSE); $results[] = array( array( 'data' => l($thumbnail, $obj_path, array( 'html' => TRUE, )), ), array( 'data' => l($title, $obj_path), ), ); } if (!$results) { drupal_set_message(t("No objects in this collection (or bad query).")); } else { $first = $per_page * $pager_page; $last = (($total - $first) > $per_page)? ($first + $per_page): $total; $objectList = '

' . t('Results @first to @last of @total', array( '@first' => $first + 1, '@last' => $last, '@total' => $total, )) . '

'; $objectList .= theme('pager', array(), $per_page, $pager_name); $objectList .= theme('table', NULL, $results); $objectList .= theme('pager', array(), $per_page, $pager_name); } } else { if (!$pageNumber) { $pageNumber = 1; } //get collection list and display using xslt------------------------------------------- $input = new DomDocument(); $input->loadXML(trim($content)); $results = $input->getElementsByTagName('result'); if ($results->length > 0) { try { $proc = new XsltProcessor(); $options = array( //Could make this the return of a hook? 'collectionPid' => $collection_pid, 'collectionTitle' => $collectionName, 'baseUrl' => $base_url, 'path' => "$base_url/$path", 'hitPage' => $pageNumber, ); if (defined('PHP_VERSION_ID') && PHP_VERSION_ID >= 50100) { $proc->setParameter('', $options); } else { foreach ($options as $name => $value) { $proc->setParameter('', $name, $value); } } $proc->registerPHPFunctions(); $xsl = new DomDocument(); $xsl->loadXML($xslContent); // php xsl does not seem to work with namespaces so removing it below // I may have just been being stupid here // $content = str_ireplace('xmlns="http://www.w3.org/2001/sw/DataAccess/rf1/result"', '', $content); $xsl = $proc->importStylesheet($xsl); $newdom = $proc->transformToDoc($input); $objectList = $newdom->saveHTML(); //is the xml transformed to html as defined in the xslt associated with the collection object if (!$objectList) { throw new Exception("Invalid XML."); } } catch (Exception $e) { drupal_set_message(check_plain($e->getMessage()), 'error'); return ''; } } } } else { drupal_set_message(t("No objects in this collection (or bad query).")); } return $objectList; } }