server.js

process.title = 'Jetsam API Server'

const redbird = require('redbird')
const Koa = require('koa')
const app = require('app')
const http = require('http')
const { config, env, fs, boot } = require('bootstrap')
const debug = require('debug')('server:boot')
const pkg = require('./package.json')

const Sentry = require('@sentry/node')
const Tracing = require('@sentry/tracing')

let server = null
let worker = null

function bindSentry(app) {
	const sentryUtil = require('vendor/sentry')
	sentryUtil.configure()

	debug('Binding sentry to app level errors')

	app.on('error', (err, ctx) => {
		console.error(err)
		Sentry.withScope(function (scope) {
			scope.addEventProcessor(function (event) {
				return Sentry.Handlers.parseRequest(event, ctx.request)
			})
			Sentry.captureException(err)
		})
	})
}

async function launch(
	port = 0,
	host = config('app.host.web', `http://localhost:${port}`),
) {
	const koa = new Koa()
	const appserver = await app(koa)

	if (config('sentry.enabled')) {
		bindSentry(koa)
	}

	const httpServer = http.createServer(appserver.callback())
	httpServer.listen(port)
	debug(`Listening on ${host}`)

	server = httpServer

	maybeSpawnWorker()

	return httpServer
}

async function runProxy() {
	const port = config('app.port')
	const proxy = redbird({ port, bunyan: false })
	const hosts = config('services.proxy.hosts')

	await launch()

	const address = server.address()
	if (!address) {
		throw new Error('Failed to start')
	}

	debug(`Binding hosts [${hosts.join(', ')}] to server port ${address.port}`)
	for (const host of hosts) {
		proxy.register(host, `http://127.0.0.1:${address.port}`)
	}
}

function maybeSpawnWorker() {
	if (config('queue.driver') === 'async') {
		debug('Spawning async worker')
		const bindQueue = require('core/utils/queue')
		const { queue } = require('services')

		bindQueue()
		worker = queue.listen()
	}
}

async function main() {
	await boot()

	if (config('services.proxy.enabled')) {
		return await runProxy()
	} else {
		return await launch(config('app.port'))
	}
}

main().catch(e => {
	console.error(e)
	process.exit(1)
})

const cleanupsigs = ['SIGINT', 'SIGTERM', 'SIGUSR2']

cleanupsigs.forEach(signal => {
	process.on(signal, () => {
		if (worker) {
			worker()
		}
		if (server) {
			server.close()
		}
		Sentry.close(2000).then(() => {
			process.exit(0)
		})
	})
})