@@ -80,13 +80,14 @@ async function colCount(collection) {
|
||||
await client.connect();
|
||||
let col = db.collection(collection);
|
||||
let count = col.countDocuments();
|
||||
log.out(`dbAccess.colCount: Collection: ${collection} contains ${count} documents`);
|
||||
log.out(`dbAccess.colCount: Collection: ${collection} contains ${count}` +
|
||||
' documents');
|
||||
return await count;
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
query,
|
||||
increment, // Probqbly doesn't need exporting? - It does, ldbServices needs to increment when the API is hit!
|
||||
increment,
|
||||
addUser,
|
||||
userAtime,
|
||||
addRegReq,
|
||||
|
||||
@@ -5,7 +5,8 @@ const log = require('../utils/log.utils');
|
||||
const clean = require('../utils/sanitizer.utils');
|
||||
|
||||
async function findPisByOrigDest(start,end) {
|
||||
log.out(`pisServices.findPisByOrigDest: Searching for PIS for Orig: ${start}, Dest: ${end}`, 'dbug');
|
||||
log.out('pisServices.findPisByOrigDest: Searching for PIS for Orig: ' +
|
||||
`${start}, Dest: ${end}`, 'dbug');
|
||||
const firstCrs = clean.cleanApiEndpointTxt(start.toLowerCase());
|
||||
const lastCrs = clean.cleanApiEndpointTxt(end.toLowerCase());
|
||||
const query = {
|
||||
@@ -22,7 +23,6 @@ async function findPisByOrigDest(start,end) {
|
||||
]
|
||||
}
|
||||
};
|
||||
//const oldQuery = {$and:[{$expr:{$eq:[{$first:"$stops"},firstCrs]}},{$expr:{$eq:[{$last:"$stops"},lastCrs]}}]}
|
||||
const search = db.query('pis', query);
|
||||
return await search;
|
||||
}
|
||||
@@ -45,8 +45,6 @@ async function findByTiplocArray(tiplocArray) {
|
||||
return await res;
|
||||
}
|
||||
|
||||
// Hopefully at some point, I will also be able to implement a find PIS code by headcode option.
|
||||
|
||||
module.exports = {
|
||||
findPisByOrigDest,
|
||||
findPisByCode,
|
||||
|
||||
Reference in New Issue
Block a user