698 ldp patch import resource one by one

src/middleware/packages/ldp/service.js

@@ -11,11 +11,12 @@ module.exports = {
     containers: [],
     podProvider: false,
     mirrorGraphName: 'http://semapps.org/mirror',
-    defaultContainerOptions: {}
+    defaultContainerOptions: {},
+    preferredViewForResource: null,
   },
   dependencies: ['ldp.container', 'ldp.resource', 'ldp.registry'],
   async created() {
-    const { baseUrl, containers, ontologies, podProvider, defaultContainerOptions, mirrorGraphName } = this.settings;
+    const { baseUrl, containers, ontologies, podProvider, defaultContainerOptions, mirrorGraphName, preferredViewForResource } = this.settings;
 
     await this.broker.createService(LdpContainerService, {
       settings: {
@@ -32,7 +33,8 @@ module.exports = {
         baseUrl,
         ontologies,
         podProvider,
-        mirrorGraphName
+        mirrorGraphName,
+        preferredViewForResource
       },
       hooks: this.schema.hooksResource || {}
     });

src/middleware/packages/ldp/services/resource/actions/get.js

@@ -16,16 +16,35 @@ module.exports = {
   api: async function api(ctx) {
     const { id, containerUri } = ctx.params;
     const resourceUri = urlJoin(containerUri, id);
-    const { accept, controlledActions } = {
+    const { accept, controlledActions, preferredView } = {
       ...(await ctx.call('ldp.registry.getByUri', { resourceUri })),
       ...ctx.meta.headers
     };
     try {
-      ctx.meta.$responseType = ctx.meta.$responseType || accept;
-      return await ctx.call(controlledActions.get || 'ldp.resource.get', {
+
+      if (ctx.meta.accepts && ctx.meta.accepts.includes('text/html') && this.settings.preferredViewForResource) {
+        const webId = ctx.meta.webId || 'anon';
+        const resourceExist = await ctx.call('ldp.resource.exist', { resourceUri, webId });
+        if (resourceExist) {
+          const redirect = await this.settings.preferredViewForResource(resourceUri, preferredView);
+          if (redirect && redirect !== resourceUri) {
+            ctx.meta.$statusCode = 302
+            ctx.meta.$location = redirect
+            ctx.meta.$responseHeaders = {
+              'Content-Length': 0
+            };
+            return;
+          }
+        }
+      }
+
+      const res = await ctx.call(controlledActions.get || 'ldp.resource.get', {
         resourceUri,
         accept
       });
+      ctx.meta.$responseType = ctx.meta.$responseType || accept;
+      return res;
+
     } catch (e) {
       console.error(e);
       ctx.meta.$statusCode = e.code || 500;
@@ -65,14 +84,15 @@ module.exports = {
         ...ctx.params
       };
 
-      const mirror = isMirror(resourceUri, this.settings.baseUrl);
-
       const resourceExist = await ctx.call('ldp.resource.exist', { resourceUri, webId });
 
       if (resourceExist) {
+
         const blandNodeQuery = buildBlankNodesQuery(queryDepth);
         const dereferenceQuery = buildDereferenceQuery(dereference);
 
+        const mirror = isMirror(resourceUri, this.settings.baseUrl);
+
         let result = await ctx.call('triplestore.query', {
           query: `
             ${getPrefixRdf(this.settings.ontologies)}

src/middleware/packages/ldp/services/resource/index.js

@@ -18,7 +18,8 @@ module.exports = {
     baseUrl: null,
     ontologies: [],
     podProvider: false,
-    mirrorGraphName: null
+    mirrorGraphName: null,
+    preferredViewForResource: null
   },
   dependencies: ['triplestore', 'jsonld'],
   actions: {

src/middleware/packages/middlewares/index.js

@@ -39,6 +39,8 @@ const throw500 = msg => {
 
 const negotiateAccept = (req, res, next) => {
   if (!req.$ctx.meta.headers) req.$ctx.meta.headers = {};
+  // we keep the full list for further use
+  req.$ctx.meta.accepts = req.headers.accept;
   if (req.headers.accept === '*/*') req.headers.accept = undefined;
   if (req.headers.accept !== undefined) {
     try {

src/middleware/packages/mime-types/index.js

@@ -13,7 +13,6 @@ const negotiateType = function(incomingType) {
       accept: negotiatorType
     }
   });
-
   const rawNegotiatedAccept = negotiator.mediaType(availableMediaTypes);
   if (rawNegotiatedAccept !== undefined) {
     return TYPES_REPO.filter(tr => tr.mimeFull.includes(rawNegotiatedAccept))[0];