chore: Catch server health checker errors

ParabolInc · Dec 10, 2024 · 6e11a7a · 6e11a7a
1 parent 2741491
commit 6e11a7a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/packages/server/listenHandler.ts b/packages/server/listenHandler.ts
@@ -2,6 +2,7 @@ import {us_listen_socket} from 'uWebSockets.js'
 import getGraphQLExecutor from './utils/getGraphQLExecutor'
 import {Logger} from './utils/Logger'
 import serverHealthChecker from './utils/serverHealthChecker'
+import sendToSentry from './utils/sendToSentry'
 
 const listenHandler = (listenSocket: us_listen_socket) => {
   const PORT = Number(__PRODUCTION__ ? process.env.PORT : process.env.SOCKET_PORT)
@@ -10,7 +11,7 @@ const listenHandler = (listenSocket: us_listen_socket) => {
     Logger.log(`\n🔥🔥🔥 Server ID: ${SERVER_ID}. Ready for Sockets: Port ${PORT} 🔥🔥🔥`)
     getGraphQLExecutor().subscribe()
     // Cleaning on startup because shutdowns may be abrupt
-    serverHealthChecker.cleanUserPresence()
+    serverHealthChecker.cleanUserPresence().catch(sendToSentry)
   } else {
     Logger.log(`❌❌❌    Port ${PORT} is in use!    ❌❌❌`)
   }

diff --git a/packages/server/utils/serverHealthChecker.ts b/packages/server/utils/serverHealthChecker.ts
@@ -5,7 +5,6 @@ import {disconnectQuery} from '../socketHandlers/handleDisconnect'
 import {Logger} from './Logger'
 import RedisInstance from './RedisInstance'
 import publishInternalGQL from './publishInternalGQL'
-import sendToSentry from './sendToSentry'
 
 const SERVER_ID = process.env.SERVER_ID!
 const INSTANCE_ID = `${SERVER_ID}:${process.pid}`
@@ -84,7 +83,6 @@ class ServerHealthChecker {
     await new Promise((resolve, reject) => {
       userPresenceStream.on('end', resolve)
       userPresenceStream.on('error', (e) => {
-        sendToSentry(e)
         reject(e)
       })
     })