Move server.ts to CLI

2026-03-16 21:34:50 +00:00 · 2023-12-24 06:17:45 -08:00
parent 2f1577e1c6
commit b5eca8f442
2 changed files with 2 additions and 2 deletions
--- a/src/cli/server.ts
+++ b/src/cli/server.ts
@@ -0,0 +1,126 @@
+import {
+  DATA_ROOT,
+  DEBUG,
+  DISCORD_POCKETSTREAM_URL,
+  DefaultSettingsService,
+  MOTHERSHIP_ADMIN_PASSWORD,
+  MOTHERSHIP_ADMIN_USERNAME,
+  MOTHERSHIP_HOOKS_DIR,
+  MOTHERSHIP_MIGRATIONS_DIR,
+  MOTHERSHIP_NAME,
+  MOTHERSHIP_SEMVER,
+  PH_BIN_CACHE,
+  SETTINGS,
+  mkContainerHomePath,
+} from '$constants'
+import {
+  MothershipAdmimClientService,
+  PocketbaseReleaseVersionService,
+  PocketbaseService,
+  PortService,
+  SqliteService,
+  centralDbService,
+  ftpService,
+  instanceService,
+  ipWhitelistService,
+  proxyService,
+  realtimeLog,
+} from '$services'
+import { LogLevelName, LoggerService } from '$shared'
+import EventSource from 'eventsource'
+// gen:import
+
+const [major, minor, patch] = process.versions.node.split('.').map(Number)
+
+if ((major || 0) < 18) {
+  throw new Error(`Node 18 or higher required.`)
+}
+
+DefaultSettingsService(SETTINGS)
+
+LoggerService({
+  level: DEBUG() ? LogLevelName.Debug : LogLevelName.Info,
+})
+
+// npm install eventsource --save
+// @ts-ignore
+global.EventSource = EventSource
+;(async () => {
+  const logger = LoggerService().create(`server.ts`)
+  const { dbg, error, info, warn } = logger
+  info(`Starting`)
+
+  const udService = await PocketbaseReleaseVersionService({
+    cachePath: PH_BIN_CACHE(),
+    checkIntervalMs: 1000 * 5 * 60,
+  })
+
+  await PortService({})
+  const pbService = await PocketbaseService({})
+
+  /**
+   * Launch central database
+   */
+
+  info(`Serving`)
+  const [port] = await PortService().alloc()
+  const url = await new Promise<string>((resolve) => {
+    const mothership = async () => {
+      try {
+        const { url, exitCode } = await pbService.spawn({
+          version: MOTHERSHIP_SEMVER(),
+          name: MOTHERSHIP_NAME(),
+          slug: MOTHERSHIP_NAME(),
+          port,
+          env: {
+            DATA_ROOT: mkContainerHomePath(`data`),
+            DISCORD_POCKETSTREAM_URL: DISCORD_POCKETSTREAM_URL(),
+          },
+          extraBinds: [
+            `${DATA_ROOT()}:${mkContainerHomePath(`data`)}`,
+            `${MOTHERSHIP_HOOKS_DIR()}:${mkContainerHomePath(`pb_hooks`)}`,
+            `${MOTHERSHIP_MIGRATIONS_DIR()}:${mkContainerHomePath(
+              `pb_migrations`,
+            )}`,
+          ],
+        })
+        resolve(url)
+        await exitCode
+        console.log(`got exit code on mothership`, { exitCode })
+      } catch (e) {
+        error(e)
+      } finally {
+        console.log(`finally executing`)
+        setTimeout(mothership, 10000)
+      }
+    }
+    mothership()
+  })
+  info(`Mothership URL for this session is ${url}`)
+
+  /**
+   * Launch services
+   */
+  await MothershipAdmimClientService({
+    url,
+    username: MOTHERSHIP_ADMIN_USERNAME(),
+    password: MOTHERSHIP_ADMIN_PASSWORD(),
+  })
+  await ftpService({
+    mothershipUrl: url,
+  })
+  await proxyService({
+    coreInternalUrl: url,
+  })
+  await ipWhitelistService({})
+  await SqliteService({})
+  await realtimeLog({})
+  await instanceService({
+    instanceApiCheckIntervalMs: 50,
+    instanceApiTimeoutMs: 5000,
+  })
+  await centralDbService({})
+  // gen:service
+
+  info(`Hooking into process exit event`)
+})()