feat(api): add api routes gtfs-stops-last-vacuum and stops-count-gtfs-lt-0

api/src/api.js

@@ -16,6 +16,8 @@ const STOPS_GTFS_DE_ROUTER = require('./route/gtfs-stops-de');
 const STOPS_GTFS_DE_NO_GI_ROUTER = require('./route/gtfs-stops-de-not-dhid');
 const STOPS_GTFS_DE_NO_GI_REFINE_ROUTER = require('./route/gtfs-stops-de-not-dhid-refine');
 
+const STOPS_COUNT_GTFS_LT_0 = require('./route/stops-count-gtfs-lt-0');
+
 const STOPS_COUNT_GTFS = require('./route/stops-count-gtfs');
 
 const STOPS_COUNT_GTFS_DE = require('./route/stops-count-gtfs-de');
@@ -56,6 +58,8 @@ const STOPS_COUNT_GTFS_DE_SL_NO_GI = require('./route/stops-count-gtfs-de-sl-not
 const STOPS_COUNT_GTFS_DE_BY_NO_GI = require('./route/stops-count-gtfs-de-by-not-dhid');
 const STOPS_COUNT_GTFS_DE_BW_NO_GI = require('./route/stops-count-gtfs-de-bw-not-dhid');
 
+const GTFS_STOPS_LAST_VACUUM = require('./route/gtfs-stops-last-vacuum');
+
 const STOPS_COUNT_ZHV = require('./route/stops-count-zhv');
 
 //TODO make this list available via config
@@ -95,6 +99,8 @@ APP.use('/gtfs-stops-de',STOPS_GTFS_DE_ROUTER);
 APP.use('/gtfs-stops-de-not-dhid',STOPS_GTFS_DE_NO_GI_ROUTER);
 APP.use('/gtfs-stops-de-not-dhid-refine',STOPS_GTFS_DE_NO_GI_REFINE_ROUTER);
 
+APP.use('/stops-count-gtfs-lt-0',STOPS_COUNT_GTFS_LT_0);
+
 APP.use('/stops-count-gtfs',STOPS_COUNT_GTFS);
 
 APP.use('/stops-count-gtfs-de',STOPS_COUNT_GTFS_DE);
@@ -134,6 +140,7 @@ APP.use('/stops-count-gtfs-de-sl-not-dhid',STOPS_COUNT_GTFS_DE_SL_NO_GI);
 APP.use('/stops-count-gtfs-de-by-not-dhid',STOPS_COUNT_GTFS_DE_BY_NO_GI);
 APP.use('/stops-count-gtfs-de-bw-not-dhid',STOPS_COUNT_GTFS_DE_BW_NO_GI);
 
+APP.use('/gtfs-stops-last-vacuum',GTFS_STOPS_LAST_VACUUM);
 APP.use('/stops-count-zhv',STOPS_COUNT_ZHV);
 
 module.exports=APP;

api/src/route/gtfs-stops-last-vacuum.js

@@ -0,0 +1,16 @@
+const express = require('express');
+const router = express.Router();
+const lastVacuum = require('../service/gtfs-stops-last-vacuum');
+const UTILS=require('../utils');
+
+//GET listing
+router.get('/', async function(req, res, next) {
+    try {
+	res.json(await lastVacuum.get());
+    } catch (err) {
+	console.error(`Error while getting data: `, err.message);
+	res.status(err.statusCode || 500).json(UTILS.MSGS.error);
+    }
+});
+
+module.exports = router;

api/src/route/stops-count-gtfs-lt-0.js

@@ -0,0 +1,16 @@
+const express = require('express');
+const router = express.Router();
+const stopsCount = require('../service/stops-count-gtfs-lt-0');
+const UTILS=require('../utils');
+
+//GET listing
+router.get('/', async function(req, res, next) {
+    try {
+	res.json(await stopsCount.get());
+    } catch (err) {
+	console.error(`Error while getting data: `, err.message);
+	res.status(err.statusCode || 500).json(UTILS.MSGS.error);
+    }
+});
+
+module.exports = router;

api/src/route/stops-count-gtfs.js

@@ -1,16 +1,16 @@
-const EXPRESS = require('express');
-const ROUTER = EXPRESS.Router();
-const STOPS_COUNT_GTFS = require('../service/stops-count-gtfs');
+const express = require('express');
+const router = express.Router();
+const stopsCount = require('../service/stops-count-gtfs');
 const UTILS=require('../utils');
 
 //GET listing
-ROUTER.get('/', async function(req, res, next) {
+router.get('/', async function(req, res, next) {
     try {
-	res.json(await STOPS_COUNT_GTFS.get());
+	res.json(await stopsCount.get());
     } catch (err) {
 	console.error(`Error while getting data: `, err.message);
 	res.status(err.statusCode || 500).json(UTILS.MSGS.error);
     }
 });
 
-module.exports = ROUTER;
+module.exports = router;

api/src/service/gtfs-stops-last-vacuum.js

@@ -0,0 +1,12 @@
+const db = require('./db');
+
+async function get(){
+    const query = 'SELECT last_vacuum FROM pg_stat_all_tables WHERE schemaname=' + '\'gtfs\'' + ' AND relname=' + '\'stops\'' + ';';
+    //console.log('gtfs-stops-last-vacuum.get() query: ' + query);
+    return await db.query(
+	query
+    );
+};
+module.exports = {
+  get
+};

api/src/service/stops-count-gtfs-lt-0.js

@@ -0,0 +1,10 @@
+const db = require('./db');
+
+async function get(){
+    return await db.query(
+	'SELECT count(DISTINCT stop_id) FROM analysis.tbl_gtfs_stops_lt_0;'
+    );
+};
+module.exports = {
+  get
+};