Convert app.js to ES modules

GitOrigin-RevId: 7819cc8c8235b93b985c1c07c7dec778c93d9134
2024-10-14 11:04:23 +00:00
parent 209a3670ce
commit e128e8ea32
16 changed files with 130 additions and 137 deletions
@@ -0,0 +1,90 @@
+// Metrics must be initialized before importing anything else
+import '@overleaf/metrics/initialize.js'
+
+import Modules from './app/src/infrastructure/Modules.js'
+import metrics from '@overleaf/metrics'
+import Settings from '@overleaf/settings'
+import logger from '@overleaf/logger'
+import PlansLocator from './app/src/Features/Subscription/PlansLocator.js'
+import SiteAdminHandler from './app/src/infrastructure/SiteAdminHandler.js'
+
+import http from 'node:http'
+import https from 'node:https'
+
+import * as Serializers from './app/src/infrastructure/LoggerSerializers.js'
+
+import Server from './app/src/infrastructure/Server.js'
+import QueueWorkers from './app/src/infrastructure/QueueWorkers.js'
+import mongodb from './app/src/infrastructure/mongodb.js'
+import mongoose from './app/src/infrastructure/Mongoose.js'
+import { triggerGracefulShutdown } from './app/src/infrastructure/GracefulShutdown.js'
+import FileWriter from './app/src/infrastructure/FileWriter.js'
+import { fileURLToPath } from 'url'
+
+logger.initialize(process.env.METRICS_APP_NAME || 'web')
+logger.logger.serializers.user = Serializers.user
+logger.logger.serializers.docs = Serializers.docs
+logger.logger.serializers.files = Serializers.files
+logger.logger.serializers.project = Serializers.project
+if (Settings.sentry?.dsn != null) {
+  logger.initializeErrorReporting(Settings.sentry.dsn)
+}
+http.globalAgent.maxSockets = Settings.limits.httpGlobalAgentMaxSockets
+https.globalAgent.maxSockets = Settings.limits.httpsGlobalAgentMaxSockets
+
+metrics.memory.monitor(logger)
+metrics.leaked_sockets.monitor(logger)
+metrics.open_sockets.monitor()
+
+if (Settings.catchErrors) {
+  process.removeAllListeners('uncaughtException')
+  process.on('uncaughtException', error =>
+    logger.error({ err: error }, 'uncaughtException')
+  )
+}
+
+// Create ./data/dumpFolder if needed
+FileWriter.ensureDumpFolderExists()
+
+const port = Settings.port || Settings.internal.web.port || 3000
+const host = Settings.internal.web.host || '127.0.0.1'
+if (process.argv[1] === fileURLToPath(import.meta.url)) {
+  // Called directly
+  // We want to make sure that we provided a password through the environment.
+  if (!process.env.WEB_API_USER || !process.env.WEB_API_PASSWORD) {
+    throw new Error('No API user and password provided')
+  }
+
+  PlansLocator.ensurePlansAreSetupCorrectly()
+
+  Promise.all([mongodb.waitForDb(), mongoose.connectionPromise])
+    .then(async () => {
+      Server.server.listen(port, host, function () {
+        logger.debug(`web starting up, listening on ${host}:${port}`)
+        logger.debug(`${http.globalAgent.maxSockets} sockets enabled`)
+        // wait until the process is ready before monitoring the event loop
+        metrics.event_loop.monitor(logger)
+      })
+      QueueWorkers.start()
+      await Modules.start()
+    })
+    .catch(err => {
+      logger.fatal({ err }, 'Cannot connect to mongo. Exiting.')
+      process.exit(1)
+    })
+}
+
+// initialise site admin tasks
+Promise.all([mongodb.waitForDb(), mongoose.connectionPromise])
+  .then(() => SiteAdminHandler.initialise())
+  .catch(err => {
+    logger.fatal({ err }, 'Cannot connect to mongo. Exiting.')
+    process.exit(1)
+  })
+
+// handle SIGTERM for graceful shutdown in kubernetes
+process.on('SIGTERM', function (signal) {
+  triggerGracefulShutdown(Server.server, signal)
+})
+
+export default Server.server