chore(server): Cleanup unused GraphQL subscriptions

packages/openneuro-server/package.json

@@ -36,8 +36,6 @@
     "graphql-bigint": "^1.0.0",
     "graphql-compose": "9.0.10",
     "graphql-iso-date": "^3.6.1",
-    "graphql-redis-subscriptions": "2.1.0",
-    "graphql-subscriptions": "^1.1.0",
     "graphql-tools": "9.0.0",
     "immutable": "^3.8.2",
     "ioredis": "4.17.3",

packages/openneuro-server/src/datalad/snapshots.js

@@ -6,7 +6,6 @@ import { reindexDataset } from '../elasticsearch/reindex-dataset'
 import { redis, redlock } from '../libs/redis'
 import CacheItem, { CacheType } from '../cache/item'
 import config from '../config.js'
-import pubsub from '../graphql/pubsub.js'
 import {
   updateDatasetName,
   snapshotCreationComparison,
@@ -109,14 +108,6 @@ const announceNewSnapshot = async (snapshot, datasetId, user) => {
   if (snapshot.files) {
     notifications.snapshotCreated(datasetId, snapshot, user) // send snapshot notification to subscribers
   }
-  pubsub.publish('snapshotsUpdated', {
-    datasetId,
-    snapshotsUpdated: {
-      id: datasetId,
-      snapshots: await getSnapshots(datasetId),
-      latestSnapshot: snapshot,
-    },
-  })
 }
 
 /**
@@ -193,13 +184,6 @@ export const deleteSnapshot = (datasetId, tag) => {
       tag,
     ])
     await snapshotCache.drop()
-    pubsub.publish('snapshotsUpdated', {
-      datasetId,
-      snapshotsUpdated: {
-        id: datasetId,
-        snapshots: await getSnapshots(datasetId),
-      },
-    })
     return body
   })
 }

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

@@ -1,5 +1,4 @@
 import * as datalad from '../../datalad/dataset.js'
-import pubsub from '../pubsub.js'
 import { removeDatasetSearchDocument } from '../../graphql/resolvers/dataset-search.js'
 import { snapshots, latestSnapshot } from './snapshots.js'
 import { description } from './description.js'
@@ -134,10 +133,6 @@ export const deleteDataset = async (
     redirect,
     user: { _id: user },
   }).save()
-  await pubsub.publish('datasetDeleted', {
-    datasetId: id,
-    datasetDeleted: id,
-  })
   return deleted
 }
 
@@ -152,14 +147,6 @@ export const deleteFiles = async (
   try {
     await checkDatasetWrite(datasetId, user, userInfo)
     const deletedFiles = await datalad.deleteFiles(datasetId, files, userInfo)
-    pubsub.publish('filesUpdated', {
-      datasetId,
-      filesUpdated: {
-        action: 'DELETE',
-        payload: deletedFiles,
-      },
-    })
-
     return true
   } catch (err) {
     return false

packages/openneuro-server/src/graphql/resolvers/description.js

@@ -4,7 +4,6 @@
 import { setDescription } from '../../datalad/description.js'
 import { checkDatasetWrite } from '../permissions.js'
 export { description } from '../../datalad/description.js'
-import pubsub from '../pubsub.js'
 
 export const updateDescription = (
   obj,
@@ -13,17 +12,7 @@ export const updateDescription = (
 ) => {
   return checkDatasetWrite(datasetId, user, userInfo)
     .then(() => setDescription(datasetId, userInfo, { [field]: value }))
-    .then(description => {
-      pubsub.publish('draftUpdated', {
-        datasetId: description.id,
-        draftUpdated: {
-          draft: {
-            description,
-          },
-        },
-      })
-      return description
-    })
+    .then(description => description)
 }
 
 export const updateDescriptionList = updateDescription

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

@@ -2,7 +2,6 @@ import User, { UserDocument } from '../../models/user'
 import Permission, { PermissionDocument } from '../../models/permission'
 import { checkDatasetAdmin } from '../permissions'
 import { user } from './user'
-import pubsub from '../pubsub.js'
 
 interface DatasetPermission {
   id: string
@@ -40,10 +39,6 @@ const publishPermissions = async datasetId => {
       ),
     },
   }
-  pubsub.publish('permissionsUpdated', {
-    datasetId,
-    permissionsUpdated,
-  })
 }
 
 /**

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

@@ -1,7 +1,6 @@
 // @ts-nocheck
 import { schemaComposer } from 'graphql-compose'
 import resolvers from './resolvers'
-import Subscription from './resolvers/subscriptions.js'
 import {
   datasetSearch,
   advancedDatasetSearch,
@@ -818,7 +817,6 @@ export const typeDefs = `
 
 schemaComposer.addTypeDefs(typeDefs)
 schemaComposer.addResolveMethods(resolvers)
-schemaComposer.Subscription.addFields(Subscription)
 schemaComposer.Query.addFields(datasetSearch)
 schemaComposer.Query.addFields(advancedDatasetSearch)