Austin McKinley
90 lines
2.2 KiB
TypeScript
90 lines
2.2 KiB
TypeScript
import {
|
|
Database,
|
|
envToCfg,
|
|
FORCE_SHUTDOWN_TIMEOUT_MS,
|
|
httpLogger,
|
|
LinkService,
|
|
readEnv,
|
|
} from './index.js'
|
|
|
|
async function main() {
|
|
try {
|
|
httpLogger.info('Starting blink service')
|
|
|
|
const env = readEnv()
|
|
const cfg = envToCfg(env)
|
|
|
|
httpLogger.info(
|
|
{
|
|
port: cfg.service.port,
|
|
metricsPort: cfg.service.metricsPort,
|
|
safelinkEnabled: cfg.service.safelinkEnabled,
|
|
hasDbUrl: !!cfg.db.url,
|
|
hasDbMigrationUrl: !!cfg.db.migrationUrl,
|
|
},
|
|
'Configuration loaded',
|
|
)
|
|
|
|
if (cfg.db.migrationUrl) {
|
|
httpLogger.info('Running database migrations')
|
|
const migrateDb = Database.postgres({
|
|
url: cfg.db.migrationUrl,
|
|
schema: cfg.db.schema,
|
|
})
|
|
await migrateDb.migrateToLatestOrThrow()
|
|
await migrateDb.close()
|
|
httpLogger.info('Database migrations completed')
|
|
}
|
|
|
|
httpLogger.info('Creating LinkService')
|
|
const link = await LinkService.create(cfg)
|
|
|
|
if (link.ctx.cfg.service.safelinkEnabled) {
|
|
httpLogger.info('Starting Safelink client')
|
|
void link.ctx.safelinkClient.runFetchEvents()
|
|
}
|
|
|
|
await link.start()
|
|
httpLogger.info('Link service is running')
|
|
|
|
const shutdown = (signal: NodeJS.Signals) => {
|
|
const forceExitTimer = setTimeout(() => {
|
|
httpLogger.error(
|
|
{signal},
|
|
'Link service exceeded its shutdown deadline; forcing exit',
|
|
)
|
|
process.exit(1)
|
|
}, FORCE_SHUTDOWN_TIMEOUT_MS)
|
|
forceExitTimer.unref()
|
|
|
|
void (async () => {
|
|
httpLogger.info({signal}, 'Link service is stopping')
|
|
try {
|
|
await link.destroy()
|
|
httpLogger.info({signal}, 'Link service is stopped')
|
|
} catch (err) {
|
|
process.exitCode = 1
|
|
httpLogger.error({err, signal}, 'Failed to stop link service cleanly')
|
|
}
|
|
})()
|
|
}
|
|
|
|
process.once('SIGTERM', shutdown)
|
|
process.once('SIGINT', shutdown)
|
|
} catch (error) {
|
|
httpLogger.error(
|
|
{
|
|
error: String(error),
|
|
stack: error instanceof Error ? error.stack : undefined,
|
|
},
|
|
'Failed to start blink service',
|
|
)
|
|
process.exit(1)
|
|
}
|
|
}
|
|
|
|
main().catch(error => {
|
|
console.error('Unhandled startup error:', error)
|
|
process.exit(1)
|
|
})
|