source code refactoring

Author: jkyberneees

demos/circuitbreaker.js

@@ -1,12 +1,9 @@
 const gateway = require('../index')
-const PORT = process.env.PORT || 8080
 const onEnd = require('on-http-end')
 const CircuitBreaker = require('opossum')
 
-const REQUEST_TIMEOUT = 1.5 * 1000
-
 const options = {
-  timeout: REQUEST_TIMEOUT - 200, // If our function takes longer than "timeout", trigger a failure
+  timeout: 1500, // If our function takes longer than "timeout", trigger a failure
   errorThresholdPercentage: 50, // When 50% of requests fail, trip the circuit
   resetTimeout: 30 * 1000 // After 30 seconds, try again.
 }
@@ -23,14 +20,13 @@ const breaker = new CircuitBreaker(([req, res, url, proxy, proxyOpts]) => {
 breaker.fallback(([req, res], err) => {
   if (err.code === 'EOPENBREAKER') {
     res.send({
-      message: 'Upps, looks like "public" service is down. Please try again in 30 seconds!'
+      message: 'Upps, looks like we are under heavy load. Please try again in 30 seconds!'
     }, 503)
   }
 })
 
 gateway({
   routes: [{
-    timeout: REQUEST_TIMEOUT,
     proxyHandler: (...params) => breaker.fire(params),
     prefix: '/public',
     target: 'http://localhost:3000',
@@ -40,20 +36,10 @@ gateway({
       type: 'swagger'
     }
   }]
-}).start(PORT).then(() => {
-  console.log(`API Gateway listening on ${PORT} port!`)
-})
+}).start(8080).then(() => console.log('API Gateway listening on 8080 port!'))
 
 const service = require('restana')({})
-service.get('/longop', (req, res) => {
-  setTimeout(() => {
-    res.send('This operation will trigger the breaker failure counter...')
-  }, 2000)
-})
-service.get('/hi', (req, res) => {
-  res.send('Hello World!')
-})
-
-service.start(3000).then(() => {
-  console.log('Public service listening on 3000 port!')
-})
+service
+  .get('/longop', (req, res) => setTimeout(() => res.send('This operation will trigger the breaker failure counter...'), 2000))
+  .get('/hi', (req, res) => res.send('Hello World!'))
+  .start(3000).then(() => console.log('Public service listening on 3000 port!'))