89 lines
2.7 KiB
JavaScript
89 lines
2.7 KiB
JavaScript
const express = require('express');
|
|
const router = express.Router();
|
|
const jwt = require('jsonwebtoken');
|
|
const AvtocodProvider = require('../data_providers/avtocod');
|
|
const Vin01Provider = require('../data_providers/vin01');
|
|
|
|
const makeError = error => ({ success: false, error });
|
|
|
|
router.post('/check', async (req, res) => {
|
|
const number = req.body.number.replace(/ /g, '').toUpperCase();
|
|
const googleIdToken = req.body.googleIdToken;
|
|
const forceUpdate = req.body.forceUpdate.toLowerCase() == 'true';
|
|
const { login } = req.user;
|
|
|
|
let collection = req.db.collection('vehicles');
|
|
let vehicles = await collection.find({ number }).toArray();
|
|
if(vehicles.length > 0 && !forceUpdate) {
|
|
res.send({ success: true, data: vehicles[0] });
|
|
} else {
|
|
try {
|
|
let autocodPromise = AvtocodProvider.getReport(number);
|
|
let all = [autocodPromise];
|
|
|
|
if(googleIdToken) {
|
|
let vin01Promise = Vin01Provider.getReport(number, googleIdToken);
|
|
all.push(vin01Promise);
|
|
}
|
|
let [autocod, vin01] = await Promise.allSettled(all);
|
|
if(autocod.status == 'fulfilled') {
|
|
let vehicle = autocod.value;
|
|
vehicle.addedBy = login;
|
|
if(vin01?.status == 'fulfilled' && vin01.value?.brand?.name?.original == vehicle?.brand?.name?.original) {
|
|
vehicle.vin1 = vin01.value.vin1;
|
|
vehicle.vin2 = vin01.value.vin2;
|
|
vehicle.color = vin01.value.color;
|
|
vehicle.ownershipPeriods = vin01.value.ownershipPeriods;
|
|
}
|
|
await collection.replaceOne({ number }, vehicle, { upsert: true });
|
|
res.status(201).send({ success: true, data: vehicle });
|
|
} else {
|
|
throw Error(autocod.reason);
|
|
}
|
|
} catch(ex) {
|
|
res.send(makeError(ex.message));
|
|
console.error(ex);
|
|
}
|
|
}
|
|
});
|
|
|
|
router.get('/', async (req, res) => {
|
|
const { limit, query } = req.query;
|
|
|
|
console.log('limit:', limit);
|
|
console.log('query:', query);
|
|
|
|
let findQuery = {};
|
|
|
|
if(query) {
|
|
findQuery.number = RegExp(query);
|
|
}
|
|
|
|
try {
|
|
let collection = req.db.collection('vehicles');
|
|
let vehicles = await collection.find(findQuery).sort({ addedDate: -1 }).limit(parseInt(limit)).toArray();
|
|
res.send({ success: true, data: vehicles });
|
|
} catch(ex) {
|
|
res.send(makeError('Error reading vehicles from DB'));
|
|
console.error(ex);
|
|
}
|
|
});
|
|
|
|
router.get('/shared_report', async (req, res) => {
|
|
try {
|
|
let { plate_number } = jwt.verify(req.query.token, '#TheTruthIsOutThere');
|
|
let collection = req.db.collection('vehicles');
|
|
let vehicles = await collection.find({ plate_number }).toArray();
|
|
if(vehicles.length > 0) {
|
|
res.send({ success: true, data: vehicles[0] });
|
|
} else {
|
|
res.send(makeError('Vehicle not found'));
|
|
}
|
|
} catch(ex) {
|
|
res.send(makeError(ex.message));
|
|
console.error(ex);
|
|
}
|
|
});
|
|
|
|
module.exports = router;
|