'use strict' /* eslint-disable */

require('dd-trace/init') // Only works with commonjs
const { Database, PlcServer } = require('..')

const main = async () => {
  const version = process.env.PLC_VERSION
  const dbCreds = JSON.parse(process.env.DB_CREDS_JSON)
  const dbSchema = process.env.DB_SCHEMA || undefined
  const enableMigrations = process.env.ENABLE_MIGRATIONS === 'true'
  if (enableMigrations) {
    const dbMigrateCreds = JSON.parse(process.env.DB_MIGRATE_CREDS_JSON)
    // Migrate using credentialed user
    const migrateDb = Database.postgres({
      url: pgUrl(dbMigrateCreds),
      schema: dbSchema,
    })
    await migrateDb.migrateToLatestOrThrow()
    await migrateDb.close()
  }
  const dbPoolSize = parseMaybeInt(process.env.DB_POOL_SIZE)
  const dbPoolMaxUses = parseMaybeInt(process.env.DB_POOL_MAX_USES)
  const dbPoolIdleTimeoutMs = parseMaybeInt(process.env.DB_POOL_IDLE_TIMEOUT_MS)
  // Use lower-credentialed user to run the app
  const db = Database.postgres({
    url: pgUrl(dbCreds),
    schema: dbSchema,
    poolSize: dbPoolSize,
    poolMaxUses: dbPoolMaxUses,
    poolIdleTimeoutMs: dbPoolIdleTimeoutMs,
  })
  const port = parseMaybeInt(process.env.PORT)
  const plc = PlcServer.create({ db, port, version })
  const server = await plc.start()
  server.keepAliveTimeout = 90000
  // Graceful shutdown (see also https://aws.amazon.com/blogs/containers/graceful-shutdowns-with-ecs/)
  process.on('SIGTERM', async () => {
    await plc.destroy()
  })
}

const pgUrl = ({ username = "postgres", password = "postgres", host = "localhost", port = "5432", database = "postgres", sslmode }) => {
  const enc = encodeURIComponent
  return `postgresql://${username}:${enc(password)}@${host}:${port}/${database}${sslmode ? `?sslmode=${enc(sslmode)}` : ''}`
}

const parseMaybeInt = (str) => {
  return str ? parseInt(str, 10) : undefined
}

main()