PronounsPage/server/express/inclusive.ts

import { Router } from 'express';
import type { Request } from 'express';
import SQL from 'sql-template-strings';
import { ulid } from 'ulid';

import { handleErrorAsync, sortClearedLinkedText } from '../../src/helpers.ts';
import type { User } from '../../src/user.ts';
import { auditLog } from '../audit.ts';
import type { Database } from '../db.ts';

interface InclusiveRow {
    id: string;
    insteadOf: string;
    say: string | null;
    because: string | null;
    locale: string;
    approved: number | null;
    base_id: string | null;
    author_id: string | null;
    categories: string | null;
    links: string | null;
    deleted: number | null;
    clarification: string | null;
}

type InclusiveRowWithAuthor = InclusiveRow & { author: User['username'] };

const approve = async (db: Database, id: string) => {
    const { base_id } = await db.get(SQL`SELECT base_id FROM inclusive WHERE id=${id}`) as Pick<InclusiveRow, 'base_id'>;
    if (base_id) {
        await db.get(SQL`
            UPDATE inclusive
            SET deleted=1
            WHERE id = ${base_id}
        `);
    }
    await db.get(SQL`
        UPDATE inclusive
        SET approved = 1, base_id = NULL
        WHERE id = ${id}
    `);
    await invalidateCache('inclusive');
    await invalidateCache('search', 'inclusive');
};

const router = Router();

export const getInclusiveEntries = defineCachedFunction(async (db: Database, isGranted: Request['isGranted']) => {
    return sortClearedLinkedText(await db.all<InclusiveRowWithAuthor>(SQL`
            SELECT i.*, u.username AS author FROM inclusive i
            LEFT JOIN users u ON i.author_id = u.id
            WHERE i.locale = ${global.config.locale}
            AND i.approved >= ${isGranted('inclusive') ? 0 : 1}
            AND i.deleted = 0
        `), 'insteadOf');
}, {
    name: 'inclusive',
    getKey: () => 'default',
    shouldBypassCache: (db, isGranted) => isGranted('inclusive'),
    maxAge: 24 * 60 * 60,
});

router.get('/inclusive', handleErrorAsync(async (req, res) => {
    return res.json(await getInclusiveEntries(req.db, req.isGranted));
}));

router.get('/inclusive/search/:term', handleErrorAsync(async (req, res) => {
    const term = `%${req.params.term}%`;
    return res.json(sortClearedLinkedText(await req.db.all<InclusiveRowWithAuthor>(SQL`
        SELECT i.*, u.username AS author FROM inclusive i
        LEFT JOIN users u ON i.author_id = u.id
        WHERE i.locale = ${global.config.locale}
        AND i.approved >= ${req.isGranted('inclusive') ? 0 : 1}
        AND i.deleted = 0
        AND (i.insteadOf like ${term} OR i.say like ${term})
        ORDER BY i.approved, i.insteadOf
    `), 'insteadOf'));
}));

router.post('/inclusive/submit', handleErrorAsync(async (req, res) => {
    if (!req.user || !await req.isUserAllowedToPost()) {
        return res.status(401).json({ error: 'Unauthorised' });
    }

    const id = ulid();
    await req.db.get(SQL`
        INSERT INTO inclusive (id, insteadOf, say, because, approved, base_id, locale, author_id, categories, links, clarification)
        VALUES (
            ${id},
            ${req.body.insteadOf.join('|')}, ${req.body.say.join('|')}, ${req.body.because},
            0, ${req.body.base}, ${global.config.locale}, ${req.user ? req.user.id : null},
            ${req.body.categories.join(',')}, ${JSON.stringify(req.body.links)}, ${req.body.clarification || null}
        )
    `);
    await auditLog(req, 'inclusive/submitted', { ...req.body });

    if (req.isGranted('inclusive')) {
        await approve(req.db, id);
        await auditLog(req, 'inclusive/approved', { id });
    }

    return res.json('ok');
}));

router.post('/inclusive/hide/:id', handleErrorAsync(async (req, res) => {
    if (!req.isGranted('inclusive')) {
        return res.status(401).json({ error: 'Unauthorised' });
    }

    await req.db.get(SQL`
        UPDATE inclusive
        SET approved = 0
        WHERE id = ${req.params.id}
    `);

    await auditLog(req, 'inclusive/hidden', { id: req.params.id });

    await invalidateCache('inclusive');
    await invalidateCache('search', 'inclusive');

    return res.json('ok');
}));

router.post('/inclusive/approve/:id', handleErrorAsync(async (req, res) => {
    if (!req.isGranted('inclusive')) {
        return res.status(401).json({ error: 'Unauthorised' });
    }

    await approve(req.db, req.params.id);

    await auditLog(req, 'inclusive/approved', { id: req.params.id });

    return res.json('ok');
}));

router.post('/inclusive/remove/:id', handleErrorAsync(async (req, res) => {
    if (!req.isGranted('inclusive')) {
        return res.status(401).json({ error: 'Unauthorised' });
    }

    await req.db.get(SQL`
        UPDATE inclusive
        SET deleted=1
        WHERE id = ${req.params.id}
    `);

    await invalidateCache('inclusive');
    await invalidateCache('search', 'inclusive');

    await auditLog(req, 'inclusive/removed', { id: req.params.id });

    return res.json('ok');
}));

export default router;