-
Notifications
You must be signed in to change notification settings - Fork 27
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
0fe6b47
commit 9e33f7c
Showing
5 changed files
with
418 additions
and
366 deletions.
There are no files selected for viewing
4 changes: 4 additions & 0 deletions
4
shared/common/src/main/java/cz/incad/kramerius/fedora/ObjectAccess.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,4 @@ | ||
| package cz.incad.kramerius.fedora; | ||
|
|
||
| public interface ObjectAccess { | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
112 changes: 112 additions & 0 deletions
112
shared/common/src/main/java/cz/incad/kramerius/fedora/impl/ObjectAccessImpl.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,112 @@ | ||
| package cz.incad.kramerius.fedora.impl; | ||
|
|
||
| import com.qbizm.kramerius.imp.jaxb.DigitalObject; | ||
| import cz.incad.kramerius.fedora.ObjectAccess; | ||
| import cz.incad.kramerius.fedora.om.repository.RepositoryException; | ||
| import cz.incad.kramerius.fedora.utils.AkubraUtils; | ||
| import cz.incad.kramerius.utils.Dom4jUtils; | ||
| import org.apache.solr.client.solrj.SolrServerException; | ||
|
|
||
| import java.io.IOException; | ||
| import java.time.LocalDateTime; | ||
| import java.time.format.DateTimeParseException; | ||
| import java.util.Date; | ||
| import java.util.Map; | ||
|
|
||
| public class ObjectAccessImpl implements ObjectAccess { | ||
|
|
||
| //-------- get object property | ||
| @Override | ||
| public String getProperty(String pid, String propertyName) throws IOException, RepositoryException { | ||
| org.dom4j.Document objectFoxml = getFoxml(pid); | ||
| return objectFoxml == null ? null : extractProperty(objectFoxml, propertyName); | ||
| } | ||
| private String extractProperty(org.dom4j.Document foxmlDoc, String name) { | ||
| org.dom4j.Node node = Dom4jUtils.buildXpath(String.format("/foxml:digitalObject/foxml:objectProperties/foxml:property[@NAME='%s']/@VALUE", name)).selectSingleNode(foxmlDoc); | ||
| return node == null ? null : Dom4jUtils.toStringOrNull(node); | ||
| } | ||
| @Override | ||
| public String getPropertyLabel(String pid) throws IOException, RepositoryException { | ||
| return getProperty(pid, "info:fedora/fedora-system:def/model#label"); | ||
| } | ||
| @Override | ||
| public LocalDateTime getPropertyCreated(String pid) throws IOException, RepositoryException { | ||
| String propertyValue = getProperty(pid, "info:fedora/fedora-system:def/model#createdDate"); | ||
| if (propertyValue != null) { | ||
| try { | ||
| return LocalDateTime.parse(propertyValue, RepositoryApi.TIMESTAMP_FORMATTER); | ||
| } catch (DateTimeParseException e) { | ||
| System.out.println(String.format("cannot parse createdDate %s from object %s", propertyValue, pid)); | ||
| } | ||
| } | ||
| return null; | ||
| } | ||
| @Override | ||
| public LocalDateTime getPropertyLastModified(String pid) throws IOException, RepositoryException { | ||
| String propertyValue = getProperty(pid, "info:fedora/fedora-system:def/view#lastModifiedDate"); | ||
| if (propertyValue != null) { | ||
| try { | ||
| return LocalDateTime.parse(propertyValue, RepositoryApi.TIMESTAMP_FORMATTER); | ||
| } catch (DateTimeParseException e) { | ||
| System.out.println(String.format("cannot parse lastModifiedDate %s from object %s", propertyValue, pid)); | ||
| } | ||
| } | ||
| return null; | ||
| } | ||
| @Override | ||
| public Date getObjectLastmodifiedFlag(String pid) throws IOException { | ||
| DigitalObject object = manager.readObjectFromStorage(pid); | ||
| if (object != null) { | ||
| return AkubraUtils.getLastModified(object); | ||
| } | ||
| throw new IOException("Object not found: " + pid); | ||
| } | ||
| @Override | ||
| public String getModel(String objectPid) throws RepositoryException, IOException, SolrServerException { | ||
| Map<String, String> description = repositoryApi.getDescription(objectPid); | ||
| String model = description.get("model"); | ||
| return model == null ? null : model.substring("model:".length()); | ||
| } | ||
| /* | ||
| @Override | ||
| public InputStream getFoxml(String pid, boolean archive) throws IOException { | ||
| try { | ||
| if (archive){ | ||
| DigitalObject obj = manager.readObjectCloneFromStorage(pid); | ||
| manager.resolveArchivedDatastreams(obj); | ||
| return this.manager.marshallObject(obj); | ||
| }else { | ||
| return this.manager.retrieveObject(pid); | ||
| } | ||
| } catch (Exception e) { | ||
| throw new IOException(e); | ||
| } | ||
| } | ||
| @Override | ||
| public org.dom4j.Document getFoxml(String pid) throws RepositoryException, IOException { | ||
| Lock readLock = AkubraDOManager.getReadLock(pid); | ||
| try { | ||
| RepositoryObject object = akubraRepositoryImpl.getObject(pid); | ||
| return Utils.inputstreamToDocument(object.getFoxml(), true); | ||
| } finally { | ||
| readLock.unlock(); | ||
| } | ||
| } | ||
| @Override | ||
| public boolean objectExists(String pid) throws RepositoryException { | ||
| Lock readLock = AkubraDOManager.getReadLock(pid); | ||
| try { | ||
| return akubraRepositoryImpl.objectExists(pid); | ||
| } finally { | ||
| readLock.unlock(); | ||
| } | ||
| } | ||
| @Override | ||
| public boolean isPidAvailable(String pid) throws IOException, RepositoryException { | ||
| boolean exists = this.repositoryApi.objectExists(pid); | ||
| return exists; | ||
| } | ||
| */ | ||
|
|
||
| } |
Oops, something went wrong.