SCC-5490: Update item location filter

data/buildingLocations.json

@@ -1 +1 @@
-[{ "value": "ma", "label": "Stephen A. Schwarzman Building (SASB)","nickname": "SASB" }, { "value": "pa", "label": "The New York Public Library for the Performing Arts (LPA)","nickname": "LPA" },{ "value": "sc", "label": "Schomburg Center for Research in Black Culture","nickname": "Schomburg" },{ "value": "rc", "label": "Offsite - request in advance"},{ "value": "bu", "label": "Stavros Niarchos Foundation Library (SNFL)", "nickname": "SNFL" }]
+[{ "value": "ma", "label": "Stephen A. Schwarzman Building (SASB)", "shortLabel": "Stephen A. Schwarzman Building", "nickname": "SASB" }, { "value": "pa", "shortLabel": "The New York Public Library for the Performing Arts", "label": "The New York Public Library for the Performing Arts (LPA)","nickname": "LPA" },{ "value": "sc", "label": "Schomburg Center for Research in Black Culture", "shortLabel": "Schomburg Center for Research in Black Culture", "nickname": "Schomburg" },{ "value": "rc", "label": "Offsite - request in advance", "shortLabel": "Offsite"},{ "value": "bu", "label": "Stavros Niarchos Foundation Library (SNFL)", "shortLabel": "Stavros Niarchos Foundation Library", "nickname": "SNFL" }]

lib/jsonld_serializers.js

@@ -339,6 +339,12 @@ ResourceSerializer.formatItemFilterAggregations = function (aggregations) {
       // If it's a packed value, parse out the value and label:
       if (value.split('||').length === 2) {
         ;[value, label] = value.split('||')
+      // For item location, add the buildingLocation label
+      } else if (field === 'location') {
+        const loc = buildingLocations.find(l => l.value === value)
+        if (loc) {
+          label = loc.shortLabel
+        }
       }
       return {
         value,
@@ -380,6 +386,11 @@ class ItemResourceSerializer extends JsonLdItemSerializer {
       stmts.holdingLocation = ItemResourceSerializer.getFormattedHoldingLocation(this.body.holdingLocation)
     }
 
+    const buildingLocation = ItemResourceSerializer.getBuildingLocation(this.body.holdingLocation)
+    if (buildingLocation) {
+      stmts.buildingLocation = buildingLocation
+    }
+
     if (this.body.collectionId) {
       stmts.collection = ResourceSerializer.getFormattedCollections(this.body.collectionId)
       delete stmts.collectionId
@@ -411,6 +422,21 @@ class ItemResourceSerializer extends JsonLdItemSerializer {
     }]
   }
 
+  static getBuildingLocation (location) {
+    const loc = Array.isArray(location) ? location[0] : location
+    const parentLoc = loc?.['@id']?.split(':')[1]?.substring(0, 2)
+    if (parentLoc) {
+      const building = buildingLocations.find(l => l.value === parentLoc)
+      if (building) {
+        return [{
+          '@id': building.value,
+          prefLabel: building.shortLabel
+        }]
+      }
+    }
+    return null
+  }
+
   // Given an item, returns item with an added `identifier`
   // of form 'urn:[sourceIdentifierPrefix]:[sourceIdentifier]'
   // e.g.

lib/resources.js

@@ -28,7 +28,19 @@ const Item = require('./models/Item.js')
 const RESOURCES_INDEX = process.env.RESOURCES_INDEX
 
 const ITEM_FILTER_AGGREGATIONS = {
-  item_location: { nested: { path: 'items' }, aggs: { _nested: { terms: { size: 100, field: 'items.holdingLocation_packed' } } } },
+  item_location: {
+    nested: { path: 'items' },
+    aggs: {
+      _nested: {
+        terms: {
+          size: 100,
+          script: {
+            source: "def locs = doc['items.holdingLocation.id']; if (locs.size() == 0) return null; def loc = locs.value; int colonIdx = loc.indexOf(':'); if (colonIdx == -1) return null; def locId = loc.substring(colonIdx + 1); if (locId.length() < 2) return null; def parentLoc = locId.substring(0, 2); if (['ma', 'pa', 'sc', 'rc', 'bu'].contains(parentLoc)) { return parentLoc; } return null;"
+          }
+        }
+      }
+    }
+  },
   item_status: { nested: { path: 'items' }, aggs: { _nested: { terms: { size: 100, field: 'items.status_packed' } } } },
   item_format: { nested: { path: 'items' }, aggs: { _nested: { terms: { size: 100, field: 'items.formatLiteral' } } } }
 }
@@ -212,6 +224,7 @@ module.exports = function (app, _private = null) {
           }).then((resp) => {
             const hitsAndItemAggregations = resp.hits.hits[0]._source
             hitsAndItemAggregations.itemAggregations = resp.aggregations
+
             return ResourceSerializer.serialize(hitsAndItemAggregations, Object.assign(opts, { root: true }))
           })
       })
@@ -488,8 +501,13 @@ module.exports = function (app, _private = null) {
       },
       location: (locations) => {
         return {
-          terms: {
-            'items.holdingLocation.id': locations
+          script: {
+            script: {
+              source: "def locs = doc['items.holdingLocation.id']; if (locs.size() == 0) return false; def loc = locs.value; int colonIdx = loc.indexOf(':'); if (colonIdx == -1) return false; def locId = loc.substring(colonIdx + 1); if (locId.length() < 2) return false; def parentLoc = locId.substring(0, 2); return ['ma', 'pa', 'sc', 'rc', 'bu'].contains(parentLoc) && params.locations.contains(parentLoc);",
+              params: {
+                locations
+              }
+            }
           }
         }
       },