add a way for modules to inject triples into the describe responses f…

…or a resource (to add e.g. HATEOS responsess)
fcrepo · May 29, 2013 · 070d7c4 · cbeer · May 29, 2013 · awoods
1 parent e308b39
commit 070d7c4
Show file tree

Hide file tree

Showing 13 changed files with 264 additions and 15 deletions.
diff --git a/fcrepo-http-api/pom.xml b/fcrepo-http-api/pom.xml
@@ -26,6 +26,12 @@
       <version>${project.version}</version>
     </dependency>
 
+    <dependency>
+      <groupId>org.fcrepo</groupId>
+      <artifactId>fcrepo-kernel</artifactId>
+      <version>${project.version}</version>
+    </dependency>
+
    	<!-- Apache Velocity -->
     <dependency>
       <groupId>org.apache.velocity</groupId>

diff --git a/fcrepo-http-api/src/main/java/org/fcrepo/api/FedoraNodes.java b/fcrepo-http-api/src/main/java/org/fcrepo/api/FedoraNodes.java
@@ -95,7 +95,11 @@ public Dataset describe(@PathParam("path")
                 throw new WebApplicationException(builder.cacheControl(cc)
                         .lastModified(date).build());
             }
-            return resource.getPropertiesDataset(new HttpGraphSubjects(FedoraNodes.class, uriInfo));
+            final HttpGraphSubjects subjects = new HttpGraphSubjects(FedoraNodes.class, uriInfo);
+            final Dataset propertiesDataset = resource.getPropertiesDataset(subjects);
+            addResponseInformationToDataset(resource, propertiesDataset, uriInfo, subjects);
+
+            return propertiesDataset;
 
         } finally {
             session.logout();

diff --git a/fcrepo-http-api/src/main/java/org/fcrepo/url/HttpApiResources.java b/fcrepo-http-api/src/main/java/org/fcrepo/url/HttpApiResources.java
@@ -0,0 +1,61 @@
+package org.fcrepo.url;
+
+import com.google.common.collect.ImmutableBiMap;
+import com.hp.hpl.jena.rdf.model.Model;
+import com.hp.hpl.jena.rdf.model.Resource;
+import org.fcrepo.FedoraResource;
+import org.fcrepo.api.FedoraExport;
+import org.fcrepo.api.FedoraFieldSearch;
+import org.fcrepo.api.FedoraFixity;
+import org.fcrepo.api.FedoraNodes;
+import org.fcrepo.api.FedoraSitemap;
+import org.fcrepo.api.FedoraTransactions;
+import org.fcrepo.api.FedoraVersions;
+import org.fcrepo.api.rdf.HttpComponentAppender;
+import org.fcrepo.api.repository.FedoraRepositoryNamespaces;
+import org.fcrepo.rdf.GraphSubjects;
+import org.fcrepo.serialization.FedoraObjectSerializer;
+import org.springframework.stereotype.Component;
+
+import javax.jcr.RepositoryException;
+import javax.ws.rs.core.UriInfo;
+
+import java.util.Map;
+
+@Component
+public class HttpApiResources implements HttpComponentAppender {
+
+    @javax.annotation.Resource
+    protected Map<String, FedoraObjectSerializer> serializers;
+
+    @Override
+    public void addResponseInformationToDataset(FedoraResource resource, Model model, UriInfo uriInfo, GraphSubjects graphSubjects) throws RepositoryException {
+
+        final Resource s = graphSubjects.getGraphSubject(resource.getNode());
+
+        if (resource.getNode().getPrimaryNodeType().isNodeType("mode:root")) {
+            model.add(s, model.createProperty("http://www.whatwg.org/specs/web-apps/current-work/multipage/links.html#link-type-search"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraFieldSearch.class).build().toASCIIString()));
+            model.add(s, model.createProperty("http://microformats.org/wiki/rel-sitemap"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraSitemap.class).build().toASCIIString()));
+            model.add(s, model.createProperty("info:fedora/hasTransactionProvider"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraTransactions.class).build().toASCIIString()));
+            model.add(s, model.createProperty("info:fedora/hasNamespaces"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraRepositoryNamespaces.class).build().toASCIIString()));
+
+        } else {
+
+            for (String key : serializers.keySet()) {
+                final Map<String, String> pathMap = ImmutableBiMap.of("path", resource.getPath().substring(1), "format", key);
+                model.add(s, model.createProperty("info:fedora/exportsAs"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraExport.class).buildFromMap(pathMap).toASCIIString()));
+            }
+
+            final Map<String, String> pathMap = ImmutableBiMap.of("path", resource.getPath().substring(1));
+            model.add(s, model.createProperty("info:fedora/hasVersions"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraVersions.class).buildFromMap(pathMap).toASCIIString()));
+
+        }
+
+        if (resource.hasContent()) {
+            final Map<String, String> pathMap = ImmutableBiMap.of("path", resource.getPath().substring(1));
+            model.add(s, model.createProperty("info:fedora/runFixityCheck"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraFixity.class).buildFromMap(pathMap).toASCIIString()));
+        }
+
+
+    }
+}
diff --git a/fcrepo-http-api/src/test/resources/spring-test/rest.xml b/fcrepo-http-api/src/test/resources/spring-test/rest.xml
@@ -14,7 +14,7 @@
   <context:annotation-config/>
 
   <context:component-scan
-    base-package="org.fcrepo.api, org.fcrepo.serialization, org.fcrepo.responses, org.fcrepo.exceptionhandlers"/>
+    base-package="org.fcrepo.api, org.fcrepo.serialization, org.fcrepo.responses, org.fcrepo.exceptionhandlers, org.fcrepo.url"/>
 
   <util:map id="serializers" key-type="java.lang.String" map-class="java.util.HashMap"
     value-type="org.fcrepo.serialization.FedoraObjectSerializer">

diff --git a/fcrepo-http-commons/src/main/java/org/fcrepo/AbstractResource.java b/fcrepo-http-commons/src/main/java/org/fcrepo/AbstractResource.java
@@ -2,7 +2,6 @@
 package org.fcrepo;
 
 import static javax.ws.rs.core.MediaType.APPLICATION_OCTET_STREAM_TYPE;
-import static javax.ws.rs.core.Response.noContent;
 import static org.slf4j.LoggerFactory.getLogger;
 
 import java.io.IOException;
@@ -17,15 +16,17 @@
 import javax.ws.rs.core.Context;
 import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.PathSegment;
-import javax.ws.rs.core.Response;
 import javax.ws.rs.core.SecurityContext;
 import javax.ws.rs.core.UriInfo;
 
+import com.hp.hpl.jena.query.Dataset;
 import org.apache.commons.io.IOUtils;
 import org.apache.jena.riot.WebContent;
+import org.fcrepo.api.rdf.HttpComponentInjector;
 import org.fcrepo.api.rdf.HttpGraphSubjects;
 import org.fcrepo.exception.InvalidChecksumException;
 import org.fcrepo.identifiers.PidMinter;
+import org.fcrepo.rdf.GraphSubjects;
 import org.fcrepo.services.DatastreamService;
 import org.fcrepo.services.NodeService;
 import org.fcrepo.services.ObjectService;
@@ -79,6 +80,9 @@ public abstract class AbstractResource {
     @Autowired
     protected DatastreamService datastreamService;
 
+    @Autowired(required=false)
+    private HttpComponentInjector httpComponentInjector;
+
     /**
      * A resource that can mint new Fedora PIDs.
      */
@@ -183,6 +187,12 @@ protected FedoraResource createObjectOrDatastreamFromRequestContent(
         return result;
     }
 
+    protected void addResponseInformationToDataset(final FedoraResource resource, final Dataset dataset, final UriInfo uriInfo, GraphSubjects subjects) throws RepositoryException {
+        if (httpComponentInjector != null) {
+            httpComponentInjector.addResponseInformationToDataset(resource, dataset, uriInfo, subjects);
+        }
+    }
+
     /**
      * A testing convenience setter for otherwise injected resources
      * @param repo

diff --git a/fcrepo-http-commons/src/main/java/org/fcrepo/api/rdf/HttpComponentAppender.java b/fcrepo-http-commons/src/main/java/org/fcrepo/api/rdf/HttpComponentAppender.java
@@ -0,0 +1,12 @@
+package org.fcrepo.api.rdf;
+
+import com.hp.hpl.jena.rdf.model.Model;
+import org.fcrepo.FedoraResource;
+import org.fcrepo.rdf.GraphSubjects;
+
+import javax.jcr.RepositoryException;
+import javax.ws.rs.core.UriInfo;
+
+public interface HttpComponentAppender {
+    void addResponseInformationToDataset(final FedoraResource resource, final Model model, final UriInfo uriInfo, GraphSubjects graphSubjects) throws RepositoryException;
+}
diff --git a/fcrepo-http-commons/src/main/java/org/fcrepo/api/rdf/HttpComponentInjector.java b/fcrepo-http-commons/src/main/java/org/fcrepo/api/rdf/HttpComponentInjector.java
@@ -0,0 +1,47 @@
+package org.fcrepo.api.rdf;
+
+import com.hp.hpl.jena.query.Dataset;
+import com.hp.hpl.jena.rdf.model.Model;
+import com.hp.hpl.jena.rdf.model.ModelFactory;
+import org.fcrepo.FedoraResource;
+import org.fcrepo.rdf.GraphSubjects;
+import org.slf4j.Logger;
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+import javax.jcr.RepositoryException;
+import javax.ws.rs.core.UriInfo;
+import java.util.Collection;
+
+import static org.slf4j.LoggerFactory.getLogger;
+
+@Component
+public class HttpComponentInjector implements ApplicationContextAware {
+    private static final Logger LOGGER = getLogger(HttpComponentInjector.class);
+    private ApplicationContext applicationContext;
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        this.applicationContext = applicationContext;
+    }
+
+    public void addResponseInformationToDataset(FedoraResource resource, Dataset dataset, UriInfo uriInfo, GraphSubjects graphSubjects) throws RepositoryException {
+
+        final Model model = ModelFactory.createDefaultModel();
+        LOGGER.debug("Adding additional HTTP context triples to dataset");
+        for (HttpComponentAppender httpComponentAppender : getAppenders()) {
+            LOGGER.debug("Adding response information using {}", httpComponentAppender.getClass().toString());
+
+            httpComponentAppender.addResponseInformationToDataset(resource, model, uriInfo, graphSubjects);
+        }
+
+        dataset.addNamedModel("info:fedora/http-uris", model);
+    }
+
+    private Collection<HttpComponentAppender> getAppenders() {
+        return applicationContext.getBeansOfType(HttpComponentAppender.class).values();
+
+    }
+}
diff --git a/fcrepo-http-commons/src/main/java/org/fcrepo/responses/GraphStoreStreamingOutput.java b/fcrepo-http-commons/src/main/java/org/fcrepo/responses/GraphStoreStreamingOutput.java
@@ -6,6 +6,7 @@
 
 import java.io.IOException;
 import java.io.OutputStream;
+import java.util.Iterator;
 
 import javax.ws.rs.WebApplicationException;
 import javax.ws.rs.core.MediaType;
@@ -21,7 +22,7 @@ public class GraphStoreStreamingOutput implements StreamingOutput {
     private static final Logger LOGGER =
             getLogger(GraphStoreStreamingOutput.class);
 
-    private final Model model;
+    private final Dataset dataset;
 
     private final String format;
 
@@ -33,14 +34,7 @@ public GraphStoreStreamingOutput(final GraphStore graphStore,
 
     public GraphStoreStreamingOutput(final Dataset dataset,
             final MediaType mediaType) {
-        this.model = dataset.getDefaultModel();
-        format =
-                contentTypeToLang(mediaType.toString()).getName().toUpperCase();
-    }
-
-    public GraphStoreStreamingOutput(final Model model,
-                                     final MediaType mediaType) {
-        this.model = model;
+        this.dataset = dataset;
         format =
                 contentTypeToLang(mediaType.toString()).getName().toUpperCase();
     }
@@ -49,7 +43,14 @@ public GraphStoreStreamingOutput(final Model model,
     public void write(final OutputStream out) throws IOException,
             WebApplicationException {
         LOGGER.debug("Serializing graph model as {}", format);
-        model.write(out, format);
+        final Iterator<String> iterator = dataset.listNames();
+
+        while (iterator.hasNext()) {
+            final Model model = dataset.getNamedModel(iterator.next());
+            model.write(out, format);
+        }
+
+        dataset.getDefaultModel().write(out, format);
 
     }
 

diff --git a/fcrepo-http-commons/src/test/java/org/fcrepo/api/rdf/HttpComponentInjectorTest.java b/fcrepo-http-commons/src/test/java/org/fcrepo/api/rdf/HttpComponentInjectorTest.java
@@ -0,0 +1,58 @@
+package org.fcrepo.api.rdf;
+
+import com.google.common.collect.ImmutableBiMap;
+import com.hp.hpl.jena.query.Dataset;
+import com.hp.hpl.jena.query.DatasetFactory;
+import com.hp.hpl.jena.rdf.model.Model;
+import com.hp.hpl.jena.rdf.model.ModelFactory;
+import org.fcrepo.FedoraResource;
+import org.fcrepo.rdf.GraphSubjects;
+import org.junit.Before;
+import org.junit.Test;
+import org.springframework.context.ApplicationContext;
+
+import javax.jcr.RepositoryException;
+import javax.ws.rs.core.UriInfo;
+
+import java.util.Map;
+
+import static org.mockito.Matchers.any;
+import static org.mockito.Matchers.eq;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+public class HttpComponentInjectorTest {
+
+    private HttpComponentInjector testObj;
+    private Dataset dataset;
+    private UriInfo mockUriInfo;
+    private GraphSubjects mockSubjects;
+    private ApplicationContext mockContext;
+
+    @Before
+    public void setUp() {
+        mockContext = mock(ApplicationContext.class);
+        testObj = new HttpComponentInjector();
+        testObj.setApplicationContext(mockContext);
+
+        dataset = DatasetFactory.create(ModelFactory.createDefaultModel());
+        mockUriInfo = mock(UriInfo.class);
+        mockSubjects = mock(GraphSubjects.class);
+
+
+    }
+
+    @Test
+    public void shouldAddTriplesFromRegisteredBeans() throws RepositoryException {
+        final FedoraResource mockResource = mock(FedoraResource.class);
+
+        HttpComponentAppender mockBean1 = mock(HttpComponentAppender.class);
+        HttpComponentAppender mockBean2 = mock(HttpComponentAppender.class);
+        Map<String, HttpComponentAppender> mockBeans = ImmutableBiMap.of("doesnt", mockBean1, "matter", mockBean2);
+        when(mockContext.getBeansOfType(HttpComponentAppender.class)).thenReturn(mockBeans);
+        testObj.addResponseInformationToDataset(mockResource, dataset, mockUriInfo, mockSubjects);
+        verify(mockBean1).addResponseInformationToDataset(eq(mockResource), any(Model.class), eq(mockUriInfo), eq(mockSubjects));
+        verify(mockBean2).addResponseInformationToDataset(eq(mockResource), any(Model.class), eq(mockUriInfo), eq(mockSubjects));
+    }
+}
diff --git a/fcrepo-jcr/pom.xml b/fcrepo-jcr/pom.xml
@@ -17,6 +17,12 @@
       <artifactId>modeshape-jcr</artifactId>
     </dependency>
 
+
+    <dependency>
+      <groupId>org.modeshape</groupId>
+      <artifactId>modeshape-common</artifactId>
+    </dependency>
+
     <dependency>
       <groupId>org.jboss.jbossts</groupId>
       <artifactId>jbossjta</artifactId>

diff --git a/fcrepo-rss/src/main/java/org/fcrepo/syndication/RssResources.java b/fcrepo-rss/src/main/java/org/fcrepo/syndication/RssResources.java
@@ -0,0 +1,22 @@
+package org.fcrepo.syndication;
+
+import com.hp.hpl.jena.rdf.model.Model;
+import com.hp.hpl.jena.rdf.model.Resource;
+import org.fcrepo.FedoraResource;
+import org.fcrepo.api.rdf.HttpComponentAppender;
+import org.fcrepo.rdf.GraphSubjects;
+
+import javax.jcr.RepositoryException;
+import javax.ws.rs.core.UriInfo;
+
+public class RssResources implements HttpComponentAppender {
+    @Override
+    public void addResponseInformationToDataset(FedoraResource resource, Model model, UriInfo uriInfo, GraphSubjects graphSubjects) throws RepositoryException {
+
+        final Resource s = graphSubjects.getGraphSubject(resource.getNode());
+
+        if (resource.getNode().getPrimaryNodeType().isNodeType("mode:root")) {
+            model.add(s, model.createProperty("http://www.whatwg.org/specs/web-apps/current-work/multipage/history.html#link-type-feed"), model.createResource(uriInfo.getBaseUriBuilder().path(RSSPublisher.class).build().toASCIIString()));
+        }
+    }
+}
diff --git a/fcrepo-webapp/src/main/resources/spring/rest.xml b/fcrepo-webapp/src/main/resources/spring/rest.xml
@@ -17,7 +17,7 @@
     <bean class="org.fcrepo.identifiers.UUIDPidMinter"/>
     <bean class="org.fcrepo.session.SessionFactory"/>
 
-    <context:component-scan base-package="org.modeshape.web.jcr.rest, org.fcrepo.api, org.fcrepo.serialization, org.fcrepo.responses, org.fcrepo.exceptionhandlers, org.fcrepo.audit"/>
+    <context:component-scan base-package="org.modeshape.web.jcr.rest, org.fcrepo.api, org.fcrepo.serialization, org.fcrepo.responses, org.fcrepo.exceptionhandlers, org.fcrepo.audit, org.fcrepo.url"/>
 
   <util:map id="serializers" key-type="java.lang.String" map-class="java.util.HashMap"
             value-type="org.fcrepo.serialization.FedoraObjectSerializer">

diff --git a/fcrepo-webhooks/src/main/java/org/fcrepo/webhooks/WebhooksResources.java b/fcrepo-webhooks/src/main/java/org/fcrepo/webhooks/WebhooksResources.java
@@ -0,0 +1,22 @@
+package org.fcrepo.webhooks;
+
+import com.hp.hpl.jena.rdf.model.Model;
+import com.hp.hpl.jena.rdf.model.Resource;
+import org.fcrepo.FedoraResource;
+import org.fcrepo.api.rdf.HttpComponentAppender;
+import org.fcrepo.rdf.GraphSubjects;
+
+import javax.jcr.RepositoryException;
+import javax.ws.rs.core.UriInfo;
+
+public class WebhooksResources implements HttpComponentAppender {
+    @Override
+    public void addResponseInformationToDataset(FedoraResource resource, Model model, UriInfo uriInfo, GraphSubjects graphSubjects) throws RepositoryException {
+
+        final Resource s = graphSubjects.getGraphSubject(resource.getNode());
+
+        if (resource.getNode().getPrimaryNodeType().isNodeType("mode:root")) {
+            model.add(s, model.createProperty("http://microformats.org/wiki/rel-subscription"), model.createResource(uriInfo.getBaseUriBuilder().path(FedoraWebhooks.class).build().toASCIIString()));
+        }
+    }
+}