@godaddy/terminus - npm Package Compare versions

example/cassandra/package-lock.json

example/mongo/package-lock.json

example/mysql/package-lock.json

example/postgres/package-lock.json

example/redis/package-lock.json

2

example/cassandra/package.json

2

example/mysql/package.json

2

example/postgres/package.json

41

lib/terminus.js

		@@ -65,23 +65,34 @@ 'use strict'

		server.listeners('request').forEach((listener) => {
		server.removeListener('request', listener)
		server.on('request', async (req, res) => {
		let hasSetHandler = false
		const createHandler = (listener) => {
		const check = hasSetHandler ? () => {} : async (healthCheck, res) => {
		if (state.isShuttingDown) {
		return sendFailure(res, { onSendFailureDuringShutdown })
		}
		let info
		try {
		info = await healthCheck()
		} catch (error) {
		logger('healthcheck failed', error)
		return sendFailure(res, { error: error.causes })
		}
		return sendSuccess(res, { info, verbatim: healthChecks.verbatim })
		}

		hasSetHandler = true

		return async (req, res) => {
		const url = caseInsensitive ? req.url.toLowerCase() : req.url
		const healthCheck = healthChecks[url]
		if (healthCheck) {
		if (state.isShuttingDown) {
		return sendFailure(res, { onSendFailureDuringShutdown })
		}
		let info
		try {
		info = await healthCheck()
		} catch (error) {
		logger('healthcheck failed', error)
		return sendFailure(res, { error: error.causes })
		}
		return sendSuccess(res, { info, verbatim: healthChecks.verbatim })
		return check(healthCheck, res)
		} else {
		listener(req, res)
		}
		})
		}
		}

		server.listeners('request').forEach((listener) => {
		server.removeListener('request', listener)
		server.on('request', createHandler(listener))
		})
		@@ -88,0 +99,0 @@ }

29

lib/terminus.spec.js

		@@ -105,2 +105,31 @@ 'use strict'

		it('do not send multiple responses for the same request', async () => {
		let healthCheckRanTimes = 0
		let hasHandlerCalled = false
		let hasUnhandledRejection = false

		process.once('unhandledRejection', () => {
		hasUnhandledRejection = true;
		})

		server.on('request', () => {
		hasHandlerCalled = true
		})

		createTerminus(server, {
		healthChecks: {
		'/healthCheck': () => {
		healthCheckRanTimes++
		return Promise.resolve()
		}
		},
		})
		server.listen(8000)

		await fetch('http://localhost:8000/healthCheck')
		expect(hasUnhandledRejection).to.eql(false)
		expect(healthCheckRanTimes).to.eql(1)
		expect(hasHandlerCalled).to.eql(false)
		})

		it('includes info on resolve', async () => {
		@@ -107,0 +136,0 @@ let onHealthCheckRan = false

12

package.json

4

README.md

		@@ -72,3 +72,3 @@
		// both
		logger // [optional] logger function to be called with errors
		logger // [optional] logger function to be called with errors. Example logger call: ('error happened during shutdown', error). See terminus.js for more details.
		};
		@@ -99,3 +99,3 @@
		if (errors.length) {
		throw new HealthCheckError('healtcheck failed', errors)
		throw new HealthCheckError('healthcheck failed', errors)
		}
		@@ -102,0 +102,0 @@ })

5

typings/index.d.ts

		@@ -10,4 +10,5 @@ declare module "@godaddy/terminus" {

		export interface HealthCheckMap {
		[key: string]: HealthCheck;
		export type HealthCheckMap = {
		verbatim?: boolean;
		[key: string]: HealthCheck \| boolean;
		}
		@@ -14,0 +15,0 @@

3

typings/index.test.ts

.travis.yml

Sorry, the diff of this file is not supported yet

New alerts