get_datastreams_list_as_SimpleXML($pid)) { $log[] = log_line(t("Failed to get datastream %dsid for pid %pid", array('%dsid' => $ds->ID, '%pid' => $pid)), 'error'); return FALSE; } // Datastreams added as a result of the ingest process $ignore_dsids = array('QUERY'); $paths = array(); foreach ($object->datastreamDef as $ds) { if (!in_array($ds->ID, $ignore_dsids)) { $file = $dir . '/' . $ds->label . '.' . get_file_extension($ds->MIMEType); $paths[$ds->ID] = $file; //$content = $ob_helper->getDatastreamDissemination($pid, $ds->ID); if ($content = $ob_helper->getStream($pid, $ds->ID, FALSE)) { if (!$fp = @fopen($file, 'w')) { $log[] = log_line(t("Failed to open file %file to write datastream %dsid for pid %pid", array('%file' => $file, '%dsid' => $ds->ID, '%pid' => $pid)), 'error'); return FALSE; } fwrite($fp, $content); fclose($fp); } else { $log[] = log_line(t("Failed to get datastream %dsid for pid %pid", array('%dsid' => $ds->ID, '%pid' => $pid)), 'error'); } } } return $paths; } /** * Export foxml for pid * @param type $pid * @param type $dir * @param type $paths * @param type $log * @param type $format * @param type $remove_islandora * @return type */ function export_foxml_for_pid($pid, $dir, $paths, &$log, $format = FOXML_11, $remove_islandora = FALSE) { module_load_include('inc', 'islandora_repository', 'ObjectHelper'); $ob_helper = new ObjectHelper(); if (!$object_xml = $ob_helper->getObject($pid, 'migrate', $format)) { $log[] = log_line(t("Failed to get foxml for %pid", array('%pid' => $pid)), 'error'); return FALSE; } $foxml = new DOMDocument(); $foxml->loadXML($object_xml); $xpath = new DOMXpath($foxml); // Remove rdf elements added during ingest (if present) if ($remove_islandora) { $xpath->registerNamespace('rdf', 'http://www.w3.org/1999/02/22-rdf-syntax-ns#'); $desc_node = $xpath->query("//rdf:RDF/rdf:Description")->item(0); if ($model = $desc_node->getElementsByTagName('hasModel')->item(0)) { $desc_node->removeChild($model); } if ($member = $desc_node->getElementsByTagName('rel:isMemberOfCollection')->item(0)) { $desc_node->removeChild($member); } } if ($remove_islandora) { // Update object paths in the foxml for this pid switch ($format) { case FOXML_10: case FOXML_11: $disallowed_groups = array('E', 'R'); // Update datastream uris $xpath->registerNamespace('foxml', 'info:fedora/fedora-system:def/foxml#'); foreach ($xpath->query("//foxml:datastream[@ID]") as $ds_node) { // Don't update datastreams having external uris if (in_array($ds_node->getAttribute('CONTROL_GROUP'), $disallowed_groups)) { continue; } $ds_id = $ds_node->getAttribute('ID'); // Remove QUERY datastream if ($ds_id == "QUERY") { $parent_node = $xpath->query('/foxml:digitalObject')->item(0); $parent_node->removeChild($ds_node); } foreach ($ds_node->getElementsByTagName('*') as $content_node) { if ($str = $content_node->getAttribute('REF')) { $content_node->setAttribute('REF', url($paths[$ds_id], array('absolute' => TRUE))); } } } break; case METS_10: case METS_11: // Update datastream uris $xpath->registerNamespace('METS', 'http://www.loc.gov/METS/'); foreach ($xpath->query('//METS:fileGrp[@ID="DATASTREAMS"]/METS:fileGrp') as $ds_node) { $ds_id = $ds_node->getAttribute('ID'); // Remove QUERY datastream if ($ds_id == "QUERY") { $parent_node = $xpath->query('//METS:fileGrp[@ID="DATASTREAMS"]')->item(0); $parent_node->removeChild($ds_node); } $xpath->registerNamespace('xlink', 'http://www.loc.gov/METS/'); foreach ($xpath->query('METS:file[@OWNERID!="E"][@OWNERID!="R"]/METS:FLocat[@xlink:href]', $ds_node) as $floc) { $floc->setAttribute('xlink:href', url($paths[$ds_id], array('absolute' => TRUE))); } /* foreach ($ds_node->getElementsByTagName('METS:file') as $content_node) { // Don't update datastreams having external uris if (in_array($ds_node->getAttribute('OWNERID'), $disallowed_groups)) { continue; } foreach ($xpath->('METS:FLocat[@xlink:href]', $content_node) as $floc) { $floc->setAttribute('xlink:href', url($paths[$ds_id], array('absolute' => true))); } `} */ } break; default: $log[] = log_line(t("Unknown or invalid format: " . $format), 'error'); return FALSE; } } //if $remove_islandora $file = $dir . '/' . $pid . '.xml'; if (!$foxml->save($file)) { $log[] = log_line(t("Failed to write datastream %dsid for pid %pid to %file", array('%dsid' => $ds->ID, '%pid' => $pid, '%file' => $file)), 'error'); return FALSE; } else { $log[] = log_line(t("Exported %pid to %file", array('%pid' => $pid, '%file' => $file)), 'info'); } return TRUE; } /** * Get file extension * @param type $mimeType * @return type */ function get_file_extension($mime_type) { return substr(strstr($mime_type, '/'), 1); } /** * Log line * @param type $msg * @param type $severity * @param type $sep * @return type */ function log_line($msg, $severity = 'info', $sep = "\t") { return date("Y-m-d H:i:s") . $sep . ucfirst($severity) . $sep . $msg; }