test: liveQueryPublisher should disconnect from Redis on shutdown

spec/ParseServer.spec.js

@@ -4,6 +4,9 @@ const express = require('express');
 const MongoStorageAdapter = require('../lib/Adapters/Storage/Mongo/MongoStorageAdapter').default;
 const PostgresStorageAdapter = require('../lib/Adapters/Storage/Postgres/PostgresStorageAdapter')
   .default;
+const GridFSBucketAdapter = require('../lib/Adapters/Files/GridFSBucketAdapter')
+  .GridFSBucketAdapter;
+const FSAdapter = require('@parse/fs-files-adapter');
 const ParseServer = require('../lib/ParseServer').default;
 const path = require('path');
 const { spawn } = require('child_process');
@@ -114,3 +117,53 @@ describe('Server Url Checks', () => {
     });
   });
 });
+
+describe('Server Shutdown', () => {
+  let quitSpy;
+  let databaseAdapter;
+  let filesAdapter;
+
+  beforeEach(() => {
+    // Mock redis
+    quitSpy = jasmine.createSpy('quit'); // Called when connection is closed
+    const createClient = jasmine.createSpy('createClient').and.returnValue({
+      quit: quitSpy,
+    });
+    jasmine.mockLibrary('redis', 'createClient', createClient);
+
+    const mongoURI = 'mongodb://localhost:27017/parseServerMongoAdapterTestDatabase';
+    const postgresURI = 'postgres://localhost:5432/parse_server_postgres_adapter_test_database';
+
+    const isPostgres = process.env.PARSE_SERVER_TEST_DB === 'postgres';
+    databaseAdapter = isPostgres
+      ? new PostgresStorageAdapter({
+        uri: process.env.PARSE_SERVER_TEST_DATABASE_URI || postgresURI,
+        collectionPrefix: 'shutdown_',
+      })
+      : new MongoStorageAdapter({
+        uri: mongoURI,
+        collectionPrefix: 'shutdown_',
+      });
+    filesAdapter = isPostgres ? new FSAdapter() : new GridFSBucketAdapter(mongoURI);
+  });
+
+  it('should disconnect from Redis', async () => {
+    const server = new ParseServer({
+      appId: 'test',
+      masterKey: 'test',
+      databaseAdapter,
+      filesAdapter,
+      liveQuery: {
+        redisURL: 'redis://127.0.0.1:6379', // Fake connection. URL is irrelevant
+      },
+    });
+
+    await server.handleShutdown();
+
+    expect(quitSpy).toHaveBeenCalled();
+  });
+
+  afterEach(function () {
+    jasmine.restoreLibrary('redis', 'createClient');
+  });
+});