fix: rely on lazy tenant initialisation instead of bulk initialisation after startup (#138)

Author: thebengeu

package-lock.json

@@ -39,7 +39,6 @@
     "fs-xattr": "^0.3.1",
     "jsonwebtoken": "^8.5.1",
     "knex": "^1.0.3",
-    "p-limit": "^3.1.0",
     "pg": "^8.7.3",
     "pg-listen": "^1.7.0",
     "pino": "^7.8.0",

package.json

@@ -6,7 +6,7 @@ import build from './app'
 import buildAdmin from './admin-app'
 import { getConfig } from './utils/config'
 import { runMultitenantMigrations, runMigrations } from './utils/migrate'
-import { cacheTenantConfigsFromDbAndRunMigrations, listenForTenantUpdate } from './utils/tenant'
+import { listenForTenantUpdate } from './utils/tenant'
 
 const logger = pino({
   formatters: {
@@ -51,8 +51,4 @@ const exposeDocs = true
     }
     console.log(`Server listening at ${address}`)
   })
-
-  if (isMultitenant) {
-    await cacheTenantConfigsFromDbAndRunMigrations()
-  }
 })()

src/server.ts

@@ -1,4 +1,3 @@
-import pLimit from 'p-limit'
 import createSubscriber from 'pg-listen'
 import { getConfig } from './config'
 import { decrypt } from './crypto'
@@ -48,28 +47,6 @@ export function deleteTenantConfig(tenantId: string): void {
   tenantConfigCache.delete(tenantId)
 }
 
-export async function cacheTenantConfigsFromDbAndRunMigrations(): Promise<void> {
-  const tenants = await knex('tenants').select()
-  const limit = pLimit(100)
-  await Promise.all(
-    tenants.map(({ id, anon_key, database_url, file_size_limit, jwt_secret, service_key }) =>
-      limit(() =>
-        cacheTenantConfigAndRunMigrations(
-          id,
-          {
-            anonKey: decrypt(anon_key),
-            databaseUrl: decrypt(database_url),
-            fileSizeLimit: Number(file_size_limit),
-            jwtSecret: decrypt(jwt_secret),
-            serviceKey: decrypt(service_key),
-          },
-          true
-        )
-      )
-    )
-  )
-}
-
 async function getTenantConfig(tenantId: string): Promise<TenantConfig> {
   if (tenantConfigCache.has(tenantId)) {
     return tenantConfigCache.get(tenantId) as TenantConfig