feat(server): Add resolver to flag Brain Initiative datasets

packages/openneuro-search/src/mappings/datasets-mapping.json

@@ -3,6 +3,7 @@
     "id": { "type": "keyword" },
     "created": { "type": "date" },
     "public": { "type": "boolean" },
+    "brainInitiative": { "type": "boolean" },
     "metadata": {
       "properties": {
         "datasetName": { "type": "keyword" },

packages/openneuro-search/src/query.ts

@@ -9,6 +9,7 @@ export const INDEX_DATASET_FRAGMENT = gql`
     id
     created
     public
+    brainInitiative
     metadata {
       datasetName
       datasetUrl

packages/openneuro-server/src/cache/types.ts

@@ -13,4 +13,5 @@ export enum CacheType {
   participantCount = "participantCount",
   snapshotDownload = "download",
   draftRevision = "revision",
+  brainInitiative = "brainInitiative"
 }

packages/openneuro-server/src/graphql/resolvers/brainInitiative.ts

@@ -0,0 +1,41 @@
+import { redis } from '../../libs/redis'
+import type { DatasetOrSnapshot } from '../../utils/datasetOrSnapshot'
+import { latestSnapshot } from './snapshots'
+import { description } from '../../datalad/description'
+import Metadata from '../../models/metadata'
+import CacheItem, { CacheType } from '../../cache/item'
+import * as Sentry from "@sentry/node"
+
+const brainInitiativeMatch = new RegExp('brain.initiative', 'i')
+
+/**
+ * Check for any Brain Initiative metadata
+ */
+export const brainInitiative = async (
+  dataset: DatasetOrSnapshot,
+  _,
+  context
+): Promise<boolean> => {
+  const cache = new CacheItem(redis, CacheType.brainInitiative, [dataset.id], 7200)
+  return await cache.get(async () => {
+    try {
+      const metadata = await Metadata.findOne({ datasetId: dataset.id })
+      if (metadata.grantFunderName.match(brainInitiativeMatch)) {
+        return true
+      } else {
+        // Fetch snapshot if metadata didn't match
+        const snapshot = await latestSnapshot(dataset, null, context)
+        const snapshotDescription = await description(snapshot)
+        for (const funding of snapshotDescription.Funding) {
+          if (funding.match(brainInitiativeMatch)) {
+            return true
+          }
+        }
+      }
+      return false
+    } catch (_err) {
+      Sentry.captureException(_err)
+      return false
+    }
+  })
+}

packages/openneuro-server/src/graphql/resolvers/dataset.ts

@@ -19,6 +19,7 @@ import { reviewers } from "./reviewer"
 import { getDatasetWorker } from "../../libs/datalad-service"
 import { getFileName } from "../../datalad/files"
 import { onBrainlife } from "./brainlife"
+import { brainInitiative } from "./brainInitiative"
 import { derivatives } from "./derivatives"
 import { promiseTimeout } from "../../utils/promiseTimeout"
 import semver from "semver"
@@ -301,6 +302,7 @@ const Dataset = {
   history,
   worker,
   reviewers,
+  brainInitiative,
 }
 
 export default Dataset

packages/openneuro-server/src/graphql/schema.ts

@@ -410,6 +410,8 @@
     worker: String
     # Anonymous reviewers for this dataset
     reviewers: [DatasetReviewer]
+    # Dataset belongs to Brain Initiative
+    brainInitiative: Boolean
   }
 
   type DatasetDerivatives {