0a08088893
Numeric conversions for all ids coming in as route req params. Infrastructure for proper error message when dependencies prevent entity deletion.
59 lines
No EOL
2.4 KiB
JavaScript
59 lines
No EOL
2.4 KiB
JavaScript
'use strict';
|
|
|
|
const passport = require('../../lib/passport');
|
|
const imports = require('../../models/imports');
|
|
|
|
const router = require('../../lib/router-async').create();
|
|
const {castToInteger} = require('../../lib/helpers');
|
|
|
|
|
|
const path = require('path');
|
|
const files = require('../../models/files');
|
|
const uploadedFilesDir = path.join(files.filesDir, 'uploaded');
|
|
|
|
const multer = require('multer')({
|
|
dest: uploadedFilesDir
|
|
});
|
|
|
|
router.postAsync('/imports-table/:listId', passport.loggedIn, async (req, res) => {
|
|
return res.json(await imports.listDTAjax(req.context, castToInteger(req.params.listId), req.body));
|
|
});
|
|
|
|
router.getAsync('/imports/:listId/:importId', passport.loggedIn, async (req, res) => {
|
|
const entity = await imports.getById(req.context, castToInteger(req.params.listId), castToInteger(req.params.importId), true);
|
|
entity.hash = imports.hash(entity);
|
|
return res.json(entity);
|
|
});
|
|
|
|
const fileFields = [
|
|
{name: 'csvFile', maxCount: 1}
|
|
];
|
|
|
|
router.postAsync('/imports/:listId', passport.loggedIn, passport.csrfProtection, multer.fields(fileFields), async (req, res) => {
|
|
const entity = JSON.parse(req.body.entity);
|
|
|
|
return res.json(await imports.create(req.context, castToInteger(req.params.listId), entity, req.files));
|
|
});
|
|
|
|
router.putAsync('/imports/:listId/:importId', passport.loggedIn, passport.csrfProtection, multer.fields(fileFields), async (req, res) => {
|
|
const entity = JSON.parse(req.body.entity);
|
|
entity.id = castToInteger(req.params.importId);
|
|
|
|
await imports.updateWithConsistencyCheck(req.context, castToInteger(req.params.listId), entity, req.files);
|
|
return res.json();
|
|
});
|
|
|
|
router.deleteAsync('/imports/:listId/:importId', passport.loggedIn, passport.csrfProtection, async (req, res) => {
|
|
await imports.remove(req.context, castToInteger(req.params.listId), castToInteger(req.params.importId));
|
|
return res.json();
|
|
});
|
|
|
|
router.postAsync('/import-start/:listId/:importId', passport.loggedIn, passport.csrfProtection, async (req, res) => {
|
|
return res.json(await imports.start(req.context, castToInteger(req.params.listId), castToInteger(req.params.importId)));
|
|
});
|
|
|
|
router.postAsync('/import-stop/:listId/:importId', passport.loggedIn, passport.csrfProtection, async (req, res) => {
|
|
return res.json(await imports.stop(req.context, castToInteger(req.params.listId), castToInteger(req.params.importId)));
|
|
});
|
|
|
|
module.exports = router; |