Merge pull request #342 from stac-utils/backport/thumbnail-endpoint

v.0.4.2 backport: add support for thumbnail endpoint

Author: Phil Varner

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## [0.4.2] - 2022-12-20
+
+### Added
+
+- (Experimental) Adds Item 'thumbnail' link to presign an s3 protocol thumbnail asset ARN
+
 ## [0.4.1] - 2022-07-11
 
 ### Added
@@ -151,6 +157,7 @@ Initial release, forked from [sat-api](https://github.com/sat-utils/sat-api/tree
 
 Compliant with STAC 0.9.0
 
+[0.4.2]: https://github.com/stac-utils/stac-api/compare/v0.4.2...v0.4.2
 [0.4.1]: https://github.com/stac-utils/stac-api/compare/v0.4.0...v0.4.1
 [0.4.0]: https://github.com/stac-utils/stac-api/compare/v0.3.1...v0.4.0
 [0.3.1]: https://github.com/stac-utils/stac-api/compare/v0.3.0...v0.3.1

src/lambdas/api/app.js

@@ -268,6 +268,31 @@ app.delete('/collections/:collectionId/items/:itemId', async (req, res, next) =>
   }
 })
 
+app.get('/collections/:collectionId/items/:itemId/thumbnail', async (req, res, next) => {
+  try {
+    const { itemId, collectionId } = req.params
+
+    const response = await api.getItemThumbnail(
+      collectionId,
+      itemId,
+      es,
+    )
+
+    if (response instanceof Error) {
+      if (response.message === 'Item not found'
+          || response.message === 'Thumbnail not found') {
+        next(createError(404))
+      } else {
+        next(createError(500))
+      }
+    } else {
+      res.redirect(response.location)
+    }
+  } catch (error) {
+    next(error)
+  }
+})
+
 // catch 404 and forward to error handler
 app.use((_req, _res, next) => {
   next(createError(404))

src/lib/api.js

@@ -1,6 +1,7 @@
 const { pickBy, assign, get: getNested } = require('lodash')
 const extent = require('@mapbox/extent')
 const { DateTime } = require('luxon')
+const AWS = require('aws-sdk')
 const { isIndexNotFoundError } = require('./es')
 const logger = console
 
@@ -357,6 +358,10 @@ const addItemLinks = function (results, endpoint) {
       rel: 'root',
       href: `${endpoint}/`
     })
+    links.push({
+      rel: 'thumbnail',
+      href: `${endpoint}/collections/${collection}/items/${id}/thumbnail`
+    })
     result.type = 'Feature'
     return result
   })
@@ -689,6 +694,41 @@ const deleteItem = async function (collectionId, itemId, backend) {
   return new Error(`Error deleting item ${collectionId}/${itemId}`)
 }
 
+const getItemThumbnail = async function (collectionId, itemId, backend) {
+  const itemQuery = { collections: [collectionId], id: itemId }
+  const { results } = await backend.search(itemQuery)
+  const [item] = results
+  if (!item) {
+    return new Error('Item not found')
+  }
+
+  const thumbnailAsset = Object.values(item.assets || []).find(
+    (x) => x.roles && x.roles.includes('thumbnail')
+  )
+  if (!thumbnailAsset) {
+    return new Error('Thumbnail not found')
+  }
+
+  let location
+  if (thumbnailAsset.href && thumbnailAsset.href.startsWith('http')) {
+    location = thumbnailAsset.href
+  } else if (thumbnailAsset.href && thumbnailAsset.href.startsWith('s3')) {
+    const withoutProtocol = thumbnailAsset.href.substring(5) // chop off s3://
+    const [bucket, ...keyArray] = withoutProtocol.split('/')
+    const key = keyArray.join('/')
+    location = new AWS.S3().getSignedUrl('getObject', {
+      Bucket: bucket,
+      Key: key,
+      Expires: 60 * 5, // expiry in seconds
+      RequestPayer: 'requester'
+    })
+  } else {
+    return new Error('Thumbnail not found')
+  }
+
+  return { location }
+}
+
 module.exports = {
   getConformance,
   getCatalog,
@@ -705,5 +745,6 @@ module.exports = {
   partialUpdateItem,
   ValidationError,
   extractLimit,
-  extractDatetime
+  extractDatetime,
+  getItemThumbnail,
 }