worker.js

process.title = 'Jetsam Queue Worker'

const { config, boot } = require('bootstrap')
const debug = require('debug')('server:worker:boot')
const Sentry = require('@sentry/node')
const bindQueue = require('core/utils/queue')
const pkg = require('./package.json')

let close = null
let done = false

async function main() {
	await boot()
	bindSentry()

	const { queue } = require('services')
	if (queue._initialise) {
		await queue._initialise()
	}

	bindQueue()

	close = await queue.listen()
	await new Promise(async r => {
		debug('Starting worker spin loop')
		while (!done) { await new Promise(rr => setTimeout(rr, 10)) }
		debug('Ending worker spin loop')
		r(true)
	})
}

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

	debug('Binding sentry to process level errors')

	process.on("error", (err) => {
		Sentry.captureException(err);
	});
}

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


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

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