feat: adjust to sib00-db_vbn

This commit is contained in:
dancingCycle 2023-07-07 13:29:19 +02:00
parent 27d5ba69dd
commit fb8722dfda
52 changed files with 684 additions and 158 deletions

View File

@ -16,17 +16,28 @@ const tableCount = require('./route/table-count');
//get overall number of entries per table in public schema as array[0]['count'] object
const tableAgencyCount = require('./route/table-agency-count');
const tableAreasCount = require('./route/table-areas-count');
const tableAttributionsCount = require('./route/table-attributions-count');
const tableCalendarCount = require('./route/table-calendar-count');
const tableCalendarDatesCount = require('./route/table-calendar-dates-count');
const tableFareAttributesCount = require('./route/table-fare-attributes-count');
const tableFareLegRulesCount = require('./route/table-fare-leg-rules-count');
const tableFareMediaCount = require('./route/table-fare-media-count');
const tableFareProductsCount = require('./route/table-fare-products-count');
const tableFareRulesCount = require('./route/table-fare-rules-count');
const tableFareTransferRulesCount = require('./route/table-fare-transfer-rules-count');
const tableFeedInfoCount = require('./route/table-feed-info-count');
const tableFrequenciesCount = require('./route/table-frequencies-count');
const tableLevelsCount = require('./route/table-levels-count');
const tablePathwaysCount = require('./route/table-pathways-count');
const tableRoutesCount = require('./route/table-routes-count');
const tableShapesCount = require('./route/table-shapes-count');
const tableTransfersCount = require('./route/table-transfers-count');
const tableTripsCount = require('./route/table-trips-count');
const tableStopAreasCount = require('./route/table-stop-areas-count');
const tableStopsCount = require('./route/table-stops-count');
const tableStopTimesCount = require('./route/table-stop-times-count');
const tableTransfersCount = require('./route/table-transfers-count');
const tableTranslationsCount = require('./route/table-translations-count');
const tableTripsCount = require('./route/table-trips-count');
//get all table names in public schema as array[i]['table_name'] object
const tableNames = require('./route/table-names');
@ -129,6 +140,7 @@ const TRIPCOUNT = require('./route/trip-count');
//TODO make this list available via config
//limit access to this origin list
let whitelist = [
'http://localhost:8080',
'http(s)://foo.bar'
];
@ -212,18 +224,29 @@ APP.use('/service-availability',serviceAvailability);
APP.use('/service-ability-by-route-id',serviceAbilityByRouteId);
APP.use('/services-by-route-id', servicesByRouteId);
//entry count
APP.use('/table-areas-count', tableAreasCount);
APP.use('/table-agency-count', tableAgencyCount);
APP.use('/table-attributions-count', tableAttributionsCount);
APP.use('/table-calendar-count', tableCalendarCount);
APP.use('/table-calendar_dates-count', tableCalendarDatesCount);
APP.use('/table-fare_attributes-count', tableFareAttributesCount);
APP.use('/table-fare_leg-rules-count', tableFareLegRulesCount);
APP.use('/table-fare_media-count', tableFareMediaCount);
APP.use('/table-fare_products-count', tableFareProductsCount);
APP.use('/table-fare_rules-count', tableFareRulesCount);
APP.use('/table-fare_transfer-rules-count', tableFareTransferRulesCount);
APP.use('/table-feed_info-count', tableFeedInfoCount);
APP.use('/table-frequencies-count', tableFrequenciesCount);
APP.use('/table-levels-count', tableLevelsCount);
APP.use('/table-pathways-count', tablePathwaysCount);
APP.use('/table-routes-count', tableRoutesCount);
APP.use('/table-shapes-count', tableShapesCount);
APP.use('/table-transfers-count', tableTransfersCount);
APP.use('/table-trips-count', tableTripsCount);
APP.use('/table-stop_areas-count', tableStopAreasCount);
APP.use('/table-stops-count', tableStopsCount);
APP.use('/table-stop_times-count', tableStopTimesCount);
APP.use('/table-transfers-count', tableTransfersCount);
APP.use('/table-translations-count', tableTranslationsCount);
APP.use('/table-trips-count', tableTripsCount);
//number of tables
APP.use('/table-count', tableCount);
//array with name of all tables

View File

@ -1,20 +1,18 @@
const DEBUG=require('debug')('table-agency-count');
DEBUG('table-agency-count start...');
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-agency-count');
const utils=require('../utils');
const EXPRESS = require('express');
const ROUTER = EXPRESS.Router();
const tableCount = require('../service/table-agency-count');
const UTILS=require('../utils');
//GET listing
ROUTER.get('/', async function(req, res, next) {
router.get('/', async function(req, res, next) {
//debug('table-agency-count start...');
try {
res.json(await tableCount.get());
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(UTILS.MSGS.error);
}
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-agency-count done.');
});
module.exports = ROUTER;
DEBUG('table-agency-count done.');
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-areas-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-areas-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-areas-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-attributions-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-attributions-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-attributions-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-fare-attributes-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-fare-attributes-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-fare-attributes-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-fare-leg-rules-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
debug('table-fare-leg-rules-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
debug('table-fare-leg-rules-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-fare-media-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-fare-media-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-fare-media-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-fare-products-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-fare-products-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-fare-products-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-fare-rules-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-fare-rules-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-fare-rules-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-fare-transfer-rules-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
debug('table-fare-transfer-rules-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
debug('table-fare-transfer-rules-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-feed-info-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-feed-info-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-feed-info-count done.');
});
module.exports = router;

View File

@ -1,5 +1,5 @@
const DEBUG=require('debug')('table-levels-count');
DEBUG('table-levels-count start...');
//DEBUG('table-levels-count start...');
const EXPRESS = require('express');
const ROUTER = EXPRESS.Router();
@ -17,4 +17,4 @@ ROUTER.get('/', async function(req, res, next) {
});
module.exports = ROUTER;
DEBUG('table-levels-count done.');
//DEBUG('table-levels-count done.');

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-stop-areas-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-stop-areas-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-stop-areas-count done.');
});
module.exports = router;

View File

@ -0,0 +1,18 @@
const debug=require('debug')('debug');
const express = require('express');
const router = express.Router();
const service = require('../service/table-translations-count');
const utils=require('../utils');
router.get('/', async function(req, res, next) {
//debug('table-translations-count start...');
try {
res.json(await service.get());
} catch (err) {
console.error(`Error while getting table count `, err.message);
res.status(err.statusCode || 500).json(utils.MSGS.error);
}
//debug('table-translations-count done.');
});
module.exports = router;

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('agencyOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('agency-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.agency OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM agency OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('agency-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('agencyOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('calendarDatesOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('calendar_dates-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.calendar_dates OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM calendar_dates OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('calendar_dates-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('calendarDatesOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('calendarOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('calendar-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.calendar OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM calendar OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('calendar-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('calendarOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('frequenciesOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('frequencies-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.frequencies OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM frequencies OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('frequencies-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('frequenciesOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('levelsOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('levels-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.levels OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM levels OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('levels-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('levelsOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('pathwaysOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('pathways-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.pathways OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM pathways OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('pathways-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('pathwaysOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('routesOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('routes-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.routes OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM routes OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('routes-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('routesOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('shapesOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('shapes-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.shapes OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM shapes OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('shapes-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('shapesOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('stopTimesOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('stop_times-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.stop_times OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM stop_times OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('stop_times-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('stopTimesOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('stopsOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('stops-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.stops OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM stops OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('stops-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('stopsOsetLimit done.');

View File

@ -1,19 +1,20 @@
const DEBUG=require('debug')('table-agency-count');
DEBUG('table-agency-count start...');
const debug=require('debug')('table-agency-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM agency`);
DEBUG('DATA length: '+DATA.length);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-agency-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(agency_id) FROM ' + schema + '.agency;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}
DEBUG('table-agency-count done.');

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_media_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(area_id) FROM ' + schema + '.areas;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-attributions_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(attribution_id) FROM ' + schema + '.attributions;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -1,19 +1,20 @@
const DEBUG=require('debug')('table-calendar-count');
DEBUG('table-calendar-count start...');
const debug=require('debug')('table-calendar-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM calendar`);
DEBUG('DATA length: '+DATA.length);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-calendar-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(service_id) FROM ' + schema + '.calendar;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}
DEBUG('table-calendar-count done.');

View File

@ -1,19 +1,20 @@
const DEBUG=require('debug')('table-calendar-dates-count');
DEBUG('table-calendar-dates-count start...');
const debug=require('debug')('table-calendar_dates-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM calendar_dates`);
DEBUG('DATA length: '+DATA.length);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-calendar_dates_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.calendar_dates;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}
DEBUG('table-calendar-dates-count done.');

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_attributes_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(fare_id) FROM ' + schema + '.fare_attributes;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_media_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.fare_leg_rules;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_media_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(fare_media_id) FROM ' + schema + '.fare_media;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_media_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(fare_product_id) FROM ' + schema + '.fare_products;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_rules_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.fare_rules;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_media_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.fare_transfer_rules;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-feed_info_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.feed_info;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -1,19 +1,20 @@
const DEBUG=require('debug')('table-frequencies-count');
DEBUG('table-frequencies-count start...');
const debug=require('debug')('table-frequencies-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM frequencies`);
DEBUG('DATA length: '+DATA.length);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-frequencies_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.frequencies;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}
DEBUG('table-frequencies-count done.');

View File

@ -1,19 +1,20 @@
const DEBUG=require('debug')('table-levels-count');
DEBUG('table-levels-count start...');
const debug=require('debug')('table-levels-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM levels`);
DEBUG('DATA length: '+DATA.length);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-levels_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(level_id) FROM ' + schema + '.levels;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}
DEBUG('table-levels-count done.');

View File

@ -1,19 +1,20 @@
const debug=require('debug')('debug');
debug('table-names start...');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT table_name FROM information_schema.tables WHERE table_schema = 'public'`);
debug('DATA length: '+DATA.length);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
const schema = process.env.DB_SCHEMA || 'schema';
//debug('stops-de-oset-limit schema: ' + schema);
const query = `SELECT table_name FROM information_schema.tables WHERE table_schema = '` + schema + `';`;
//debug('stops-de-oset-limit query: ' + query);
const data = await db.query(query);
return data;
}
module.exports = {
get
}
debug('table-names done.');

View File

@ -1,12 +1,18 @@
const debug=require('debug')('table-pathways-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM pathways`);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-pathways_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(pathway_id) FROM ' + schema + '.pathways;';
const data = await db.query(query);
return data;
}
module.exports = {

View File

@ -1,12 +1,18 @@
const debug=require('debug')('table-routes-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM routes`);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-routes_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(route_id) FROM ' + schema + '.routes;';
const data = await db.query(query);
return data;
}
module.exports = {

View File

@ -1,19 +1,20 @@
const DEBUG=require('debug')('table-shapes-count');
DEBUG('table-shapes-count start...');
const debug=require('debug')('table-shapes-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM shapes`);
DEBUG('DATA length: '+DATA.length);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-shapes_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.shapes;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}
DEBUG('table-shapes-count done.');

View File

@ -0,0 +1,20 @@
const debug=require('debug')('debug');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-fare_media_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.stop_areas;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -1,12 +1,18 @@
const debug=require('debug')('table-stop_times-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM stop_times`);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-stop_times_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.stop_times;';
const data = await db.query(query);
return data;
}
module.exports = {

View File

@ -6,10 +6,8 @@ require('dotenv').config();
async function get() {
const schema = process.env.DB_SCHEMA || 'schema';
//debug('stops-de-oset-limit schema: ' + schema);
const query = 'SELECT count(stop_id) FROM ' + schema + '.stops;';
//debug('stops-de-oset-limit query: ' + query);
const data = await db.query(query);
return data;

View File

@ -1,12 +1,18 @@
const debug=require('debug')('table-transfers-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM transfers`);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-transfers_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.transfers;';
const data = await db.query(query);
return data;
}
module.exports = {

View File

@ -0,0 +1,20 @@
const debug=require('debug')('table-translations-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
//debug('table-translations_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(*) FROM ' + schema + '.translations;';
const data = await db.query(query);
return data;
}
module.exports = {
get
}

View File

@ -1,12 +1,18 @@
const debug=require('debug')('table-trips-count');
const db = require('./db');
const helper = require('../helper');
const config = require('../config');
require('dotenv').config();
async function get() {
const DATA = await db.query(
`SELECT count(*) FROM trips`);
//TODO if DATA {message "getaddrinfo ENOTFOUND <HOST like acer>"} then handle
return DATA;
//debug('table-trips_dates-count start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT count(trip_id) FROM ' + schema + '.trips;';
const data = await db.query(query);
return data;
}
module.exports = {

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('transfersOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('transfers-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.transfers OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM transfers OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('transfers-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('transfersOsetLimit done.');

View File

@ -1,18 +1,23 @@
const debug=require('debug')('debug');
debug('tripsOsetLimit start...');
const db = require('./db');
const helper = require('../helper');
require('dotenv').config();
async function get(oset = 1,limit = 100) {
debug('trips-oset-limit start...');
const schema = process.env.DB_SCHEMA || 'schema';
const query = 'SELECT * FROM ' + schema + '.trips OFFSET $1 LIMIT $2'
const offset = helper.getOffset(oset, limit);
const rows = await db.query(
'SELECT * FROM trips OFFSET $1 LIMIT $2',
query,
[offset, limit]
);
const data = helper.emptyOrRows(rows);
debug('trips-oset-limit done.');
return data;
};
module.exports = {
get
};
debug('tripsOsetLimit done.');

4
package-lock.json generated
View File

@ -1,12 +1,12 @@
{
"name": "postgres-gtfs-rest-api",
"version": "0.8.0",
"version": "0.9.0",
"lockfileVersion": 2,
"requires": true,
"packages": {
"": {
"name": "postgres-gtfs-rest-api",
"version": "0.8.0",
"version": "0.9.0",
"license": "GPL-3.0-or-later",
"dependencies": {
"compression": "1.7.4",

View File

@ -1,22 +1,14 @@
{
"private": true,
"name": "postgres-gtfs-rest-api",
"description": "REST API to request GTFS data from postgres database",
"version": "0.8.0",
"description": "REST API to interact with postgres database",
"version": "0.9.0",
"main": "index.js",
"keywords": [
"public",
"transport",
"mobility",
"postgresql",
"gtfs",
"rest",
"api"
],
"keywords": ["public", "transport", "mobility", "postgresql", "rest", "api"],
"author": "Software Ingenieur Begerad <dialog@SwIngBe.de>",
"homepage": "https://github.com/Software-Ingenieur-Begerad/postgres-gtfs-rest-api/tree/main",
"repository": "https://github.com/Software-Ingenieur-Begerad/postgres-gtfs-rest-api",
"bugs": "https://github.com/Software-Ingenieur-Begerad/postgres-gtfs-rest-api/issues",
"homepage": "https://git.wtf-eg.de/dancesWithCycles/gtfs-display",
"repository": "https://git.wtf-eg.de/dancesWithCycles/gtfs-display",
"bugs": "https://git.wtf-eg.de/dancesWithCycles/gtfs-display/issues",
"license": "GPL-3.0-or-later",
"engines": {
"node": ">=10"