added options to skip public schema and survey schema db migrations (#172)

* added options to skip public schema and survey schema db migrations

* added log info

Author: SteRiccio

src/server/arenaServer/index.ts

@@ -1,21 +1,24 @@
 import { ServiceRegistry } from '@openforis/arena-core'
 
 import { DBMigrator } from '../../db'
+import { Logger } from '../../log'
 import { ProcessEnv } from '../../processEnv'
 import { ArenaApp } from '../arenaApp'
 import { InitAppOptions, initApp } from './initApp'
 import { registerServices } from './registerServices'
 import { start } from './start'
 import { stop } from './stop'
 
+const logger: Logger = new Logger('Arena server')
+
 const initServices = (): ServiceRegistry => {
   return registerServices()
 }
 
 const init = async (options?: InitAppOptions): Promise<ArenaApp> => {
   initServices()
   if (!ProcessEnv.disableDbMigrations) {
-    await DBMigrator.migrateAll()
+    await performDatabaseMigrations(options)
   }
   return initApp(options)
 }
@@ -28,3 +31,26 @@ export const ArenaServer = {
   start,
   stop,
 }
+const performDatabaseMigrations = async (options: InitAppOptions | undefined) => {
+  const skipPublic = options?.skipPublicSchemaDbMigrations === true
+  const skipSurvey = options?.skipSurveySchemaDbMigrations === true
+
+  // Preserve migration-level logging/error handling for the default path.
+  if (!skipPublic && !skipSurvey) {
+    await DBMigrator.migrateAll()
+  } else {
+    try {
+      logger.info(`running database migrations (skip public schema: ${skipPublic}, skip survey schemas: ${skipSurvey})`)
+      if (!skipPublic) {
+        await DBMigrator.migrateSchema()
+      }
+      if (!skipSurvey) {
+        await DBMigrator.migrateSurveySchemas()
+      }
+      logger.info('database migrations completed')
+    } catch (error) {
+      logger.error(`error running database migrations: ${String(error)}`)
+      throw error
+    }
+  }
+}

src/server/arenaServer/initApp.ts

@@ -19,6 +19,8 @@ import { Api } from '../../api'
 export interface InitAppOptions {
   fileSizeLimit?: number
   bodyParseLimit?: string
+  skipPublicSchemaDbMigrations?: boolean
+  skipSurveySchemaDbMigrations?: boolean
 }
 
 const defaultOptions: InitAppOptions = {

src/server/arenaServer/start.ts

@@ -10,8 +10,8 @@ import { onShutdown } from './stop'
 
 const logger: Logger = new Logger('Arena server')
 
-export const start = (app: ArenaApp): Promise<Server> => {
-  return new Promise<Server>((resolve, reject) => {
+export const start = (app: ArenaApp): Promise<Server> =>
+  new Promise<Server>((resolve, reject) => {
     logger.info(`server starting`)
     const port = ProcessEnv.arenaPort
 
@@ -52,4 +52,3 @@ export const start = (app: ArenaApp): Promise<Server> => {
 
     server.once('listening', onListening)
   })
-}