grigori-gru/jira-to-matrix

import express from 'express';
import * as bodyParser from 'body-parser';
import { getAllSettingData, setSettingsData, delSettingsData } from './bot/settings';
import { getLogger } from './modules/log';
import { HookParser } from './hook-parser';

const logger = getLogger(module);
const app = express();

export const httpStatus = {
    OK: 200,
    BAD_REQUEST: 404,
};

export type getServerType = (handleFunc: Function, hookParser: HookParser) => express.Application;

export const getServer: getServerType = (handleFunc, hookParser): express.Application => {
    app.use(
        bodyParser.json({
            strict: false,
            limit: '20mb',
        }),
    )
        .post('/', async (req, res, next) => {
            logger.info('Webhook received! Start getting ignore status');
            logger.silly('Jira body', req.body);

            const parser = hookParser.init();
            const saveStatus = await parser.getParsedAndSaveToRedis(req.body);

            if (saveStatus) {
                await handleFunc();
            }

            next();
        })
        .get('/', (req, res) => {
            res.end(`Version ${process.env.npm_package_version}`);
        })
        .post('/run', async (req, res, next) => {
            logger.info('Run handling queue');

            await handleFunc();

            next();
        })
        .get('/ignore', async (req, res) => {
            try {
                const result = (await getAllSettingData('ignore')) || 'Ignore list is empty.';
                res.json(result).end();
            } catch (err) {
                logger.error(err);
                res.status(httpStatus.BAD_REQUEST).end();
            }
        })
        .post('/ignore', async (req, res) => {
            const [ignoreData] = Object.entries(req.body);
            try {
                const [key, data] = ignoreData;
                await setSettingsData(key, data, 'ignore');
                res.end();
            } catch (err) {
                logger.error(err);
                res.status(httpStatus.BAD_REQUEST).end();
            }
        })
        .put('/ignore/:key', async (req, res) => {
            const { key } = req.params;
            const data = req.body;
            try {
                await setSettingsData(key, data, 'ignore');
                res.end();
            } catch (err) {
                logger.error(err);
                res.status(httpStatus.BAD_REQUEST).end();
            }
        })
        .delete('/ignore/:key', async (req, res) => {
            const { key } = req.params;
            try {
                await delSettingsData(key, 'ignore');
                res.end();
            } catch (err) {
                logger.error(err);
                res.status(httpStatus.BAD_REQUEST).end();
            }
        })
        .use((req, res) => {
            res.end();
        })
        // eslint-disable-next-line @typescript-eslint/no-unused-vars
        .use((err, req, res, next) => {
            if (err) {
                logger.error(err);
            }
            res.end();
        });

    return app;
};