test connections

Author: dplewis

integration/test/ParseServerTest.js

@@ -15,9 +15,14 @@ describe('ParseServer', () => {
     parseServer.server.on('close', () => {
       close += 1;
     });
-    const object = new TestObject({ foo: 'bar' });
+    const object = new TestObject();
+    // Open a connection to the server
+    const query = new Parse.Query(TestObject);
+    await query.subscribe();
+    expect(openConnections.size > 0).toBeTruthy();
     await shutdownServer(parseServer);
     expect(close).toBe(1);
+    expect(openConnections.size).toBe(0);
     await expectAsync(object.save()).toBeRejectedWithError(
       'XMLHttpRequest failed: "Unable to connect to the Parse API"'
     );

integration/test/helper.js

@@ -93,7 +93,7 @@ const defaultConfiguration = {
   }),
 };
 
-const openConnections = {};
+const openConnections = new Set();
 let parseServer;
 
 const shutdownServer = async _parseServer => {
@@ -138,10 +138,9 @@ const reconfigureServer = async (changedConfiguration = {}) => {
     });
   }
   parseServer.server.on('connection', connection => {
-    const key = `${connection.remoteAddress}:${connection.remotePort}`;
-    openConnections[key] = connection;
+    openConnections.add(connection);
     connection.on('close', () => {
-      delete openConnections[key];
+      openConnections.delete(connection);
     });
   });
   return parseServer;
@@ -155,6 +154,7 @@ global.TestPoint = Parse.Object.extend('TestPoint');
 global.TestObject = Parse.Object.extend('TestObject');
 global.reconfigureServer = reconfigureServer;
 global.shutdownServer = shutdownServer;
+global.openConnections = openConnections;
 
 beforeAll(async () => {
   const promise = ['parse.js', 'parse.min.js'].map(fileName => {
@@ -179,11 +179,4 @@ afterEach(async () => {
   }
 });
 
-afterAll(() => {
-  // Jasmine process counts as one open connection
-  if (Object.keys(openConnections).length > 1) {
-    console.warn('There were open connections to the server left after the test finished');
-  }
-});
-
 module.exports = { twitterAuthData };