134 lines
4.1 KiB
JavaScript
134 lines
4.1 KiB
JavaScript
import { Router } from 'express';
|
|
import SQL from "sql-template-strings";
|
|
import {ulid} from "ulid";
|
|
import {handleErrorAsync} from "../../src/helpers";
|
|
|
|
const approve = async (db, id) => {
|
|
const { base_id } = await db.get(SQL`SELECT base_id FROM sources WHERE id=${id}`);
|
|
if (base_id) {
|
|
await db.get(SQL`
|
|
UPDATE sources
|
|
SET deleted=1
|
|
WHERE id = ${base_id}
|
|
`);
|
|
}
|
|
await db.get(SQL`
|
|
UPDATE sources
|
|
SET approved = 1, base_id = NULL
|
|
WHERE id = ${id}
|
|
`);
|
|
}
|
|
|
|
const linkOtherVersions = async (req, sources) => {
|
|
const keys = new Set(sources.filter(s => !!s && s.key).map(s => `'` + s.key + `'`));
|
|
|
|
const otherVersions = await req.db.all(SQL`
|
|
SELECT s.*, u.username AS submitter FROM sources s
|
|
LEFT JOIN users u ON s.submitter_id = u.id
|
|
WHERE s.locale != ${req.config.locale}
|
|
AND s.deleted = 0
|
|
AND s.approved >= ${req.isGranted('sources') ? 0 : 1}
|
|
AND s.key IN (`.append([...keys].join(',')).append(SQL`)
|
|
`));
|
|
|
|
const otherVersionsMap = {};
|
|
otherVersions.forEach(version => {
|
|
if (otherVersionsMap[version.key] === undefined) {
|
|
otherVersionsMap[version.key] = [];
|
|
}
|
|
otherVersionsMap[version.key].push(version);
|
|
});
|
|
|
|
return sources.map(s => {
|
|
s.versions = s.key ? otherVersionsMap[s.key] || [] : [];
|
|
return s;
|
|
});
|
|
};
|
|
|
|
const router = Router();
|
|
|
|
router.get('/sources', handleErrorAsync(async (req, res) => {
|
|
let sql = SQL`
|
|
SELECT s.*, u.username AS submitter FROM sources s
|
|
LEFT JOIN users u ON s.submitter_id = u.id
|
|
WHERE s.locale = ${req.config.locale}
|
|
AND s.deleted = 0
|
|
AND s.approved >= ${req.isGranted('sources') ? 0 : 1}
|
|
`;
|
|
if (req.query.pronoun) {
|
|
sql.append(SQL`AND s.pronouns LIKE ${'%' + req.query.pronoun + '%'}`)
|
|
}
|
|
return res.json(await linkOtherVersions(req, await req.db.all(sql)));
|
|
}));
|
|
|
|
router.get('/sources/:id', handleErrorAsync(async (req, res) => {
|
|
return res.json(await linkOtherVersions(req, await req.db.all(SQL`
|
|
SELECT s.*, u.username AS submitter FROM sources s
|
|
LEFT JOIN users u ON s.submitter_id = u.id
|
|
WHERE s.locale = ${req.config.locale}
|
|
AND s.deleted = 0
|
|
AND s.approved >= ${req.isGranted('sources') ? 0 : 1}
|
|
AND s.id = ${req.params.id}
|
|
`)));
|
|
}));
|
|
|
|
router.post('/sources/submit', handleErrorAsync(async (req, res) => {
|
|
const id = ulid();
|
|
await req.db.get(SQL`
|
|
INSERT INTO sources (id, locale, pronouns, type, author, title, extra, year, fragments, comment, link, key, images, submitter_id, base_id)
|
|
VALUES (
|
|
${id}, ${req.config.locale}, ${req.body.pronouns.join(';')},
|
|
${req.body.type}, ${req.body.author}, ${req.body.title}, ${req.body.extra}, ${req.body.year},
|
|
${req.body.fragments.join('@').replace(/\n/g, '|')}, ${req.body.comment}, ${req.body.link},
|
|
${req.body.key || null}, ${req.body.images || null},
|
|
${req.user ? req.user.id : null}, ${req.body.base}
|
|
)
|
|
`);
|
|
|
|
if (req.isGranted('sources')) {
|
|
await approve(req.db, id);
|
|
}
|
|
|
|
return res.json('ok');
|
|
}));
|
|
|
|
router.post('/sources/hide/:id', handleErrorAsync(async (req, res) => {
|
|
if (!req.isGranted('sources')) {
|
|
res.status(401).json({error: 'Unauthorised'});
|
|
}
|
|
|
|
await req.db.get(SQL`
|
|
UPDATE sources
|
|
SET approved = 0
|
|
WHERE id = ${req.params.id}
|
|
`);
|
|
|
|
return res.json('ok');
|
|
}));
|
|
|
|
router.post('/sources/approve/:id', handleErrorAsync(async (req, res) => {
|
|
if (!req.isGranted('sources')) {
|
|
res.status(401).json({error: 'Unauthorised'});
|
|
}
|
|
|
|
await approve(req.db, req.params.id);
|
|
|
|
return res.json('ok');
|
|
}));
|
|
|
|
router.post('/sources/remove/:id', handleErrorAsync(async (req, res) => {
|
|
if (!req.isGranted('sources')) {
|
|
res.status(401).json({error: 'Unauthorised'});
|
|
}
|
|
|
|
await req.db.get(SQL`
|
|
UPDATE sources
|
|
SET deleted=1
|
|
WHERE id = ${req.params.id}
|
|
`);
|
|
|
|
return res.json('ok');
|
|
}));
|
|
|
|
export default router;
|