fix(src/routes/service.js): fix error handler for async

Author: Goodluckhf

src/index.js

@@ -44,12 +44,6 @@ app.use(morgan('dev'));
 app.use(bodyParser.json({ limit: '5mb' }));
 const router = express.Router();
 
-//eslint-disable-next-line
-router.use((error, req, res, next) => {
-	logger.error({ error });
-	res.status(500).send('Internal server error');
-});
-
 router.get('/v1/catalog/services', makeServicesRoute(config));
 router.get('/v1/catalog/service/:service', makeServiceRoute(config, serviceDiscovery));
 
@@ -65,8 +59,12 @@ router.get('/v1/agent/self', (req, res) => {
 	});
 });
 
-
 app.use('/', router);
+//eslint-disable-next-line
+app.use((error, req, res, next) => {
+	logger.error({ error });
+	res.status(500).send('Internal server error');
+});
 app.get('*', (req, res) => {
 	res.status(404).send('Not Found');
 });

src/routes/service.js

@@ -1,52 +1,56 @@
 export default (config, serviceDiscovery) => {
 	let oldConfig = null;
 
-	return async (req, res) => {
-		const actualConfig = serviceDiscovery.getActualConfig();
-		
-		// Если модуль только стартанул,
-		// надо сразу сгенерировать и отдать конфиг
-		if (!actualConfig) {
-			const generatedConfig = await serviceDiscovery.generateConfig();
-			res.json(generatedConfig.getRawObject());
-			return;
-		}
-		
-		// Если индекса нет
-		// Значит запроси пришел либо в ручную
-		// Либо это первый запрос
-		const { index } = req.query;
-		if (!index) {
-			res.json(actualConfig.getRawObject());
-			return;
-		}
-		
-		// Сам long polling
-		// По таймауту, если конфиг не изменился
-		// Отдаем текущий актуальный
-		let responseSent = false;
-		let interval     = null;
-		const timeout = setTimeout(() => {
-			clearInterval(interval);
-			if (responseSent) {
+	return async (req, res, next) => {
+		try {
+			const actualConfig = serviceDiscovery.getActualConfig();
+			
+			// Если модуль только стартанул,
+			// надо сразу сгенерировать и отдать конфиг
+			if (!actualConfig) {
+				const generatedConfig = await serviceDiscovery.generateConfig();
+				res.json(generatedConfig.getRawObject());
 				return;
 			}
 
-			responseSent = true;
-			res.json(actualConfig.getRawObject());
-		}, config.polling_interval);
-		
-		interval = setInterval(() => {
-			const actualConfigForIteration = serviceDiscovery.getActualConfig();
-			if (actualConfigForIteration.equals(oldConfig)) {
+			// Если индекса нет
+			// Значит запроси пришел либо в ручную
+			// Либо это первый запрос
+			const { index } = req.query;
+			if (!index) {
+				res.json(actualConfig.getRawObject());
 				return;
 			}
 
-			clearTimeout(timeout);
-			clearInterval(interval);
-			oldConfig = actualConfigForIteration;
-			const newConfig = serviceDiscovery.getActualConfig();
-			res.json(newConfig.getRawObject());
-		}, 1000);
+			// Сам long polling
+			// По таймауту, если конфиг не изменился
+			// Отдаем текущий актуальный
+			let responseSent = false;
+			let interval     = null;
+			const timeout = setTimeout(() => {
+				clearInterval(interval);
+				if (responseSent) {
+					return;
+				}
+				
+				responseSent = true;
+				res.json(actualConfig.getRawObject());
+			}, config.polling_interval);
+			
+			interval = setInterval(() => {
+				const actualConfigForIteration = serviceDiscovery.getActualConfig();
+				if (actualConfigForIteration.equals(oldConfig)) {
+					return;
+				}
+				
+				clearTimeout(timeout);
+				clearInterval(interval);
+				oldConfig = actualConfigForIteration;
+				const newConfig = serviceDiscovery.getActualConfig();
+				res.json(newConfig.getRawObject());
+			}, 1000);
+		} catch (error) {
+			next(error);
+		}
 	};
 };