const MODULE_NAME = 'CORE-CALLBACK.DUMPER.SENDER';

const fs = require('fs');
const fsPromise = require('fs').promises;
const path = require('path');
const config = require('komodo-sdk/config');
const logger = require('komodo-sdk/logger');
const moment = require('moment');

const baseDumpDir = 'dump';
const subBaseDumpDir = path.join(baseDumpDir, 'core-callback');
const lastSymbolicLinkName = path.join(subBaseDumpDir, 'last-sent');

if (!fs.existsSync(baseDumpDir)) {
    logger.verbose(`${MODULE_NAME} CE7EA06A: Creating base dump dir`);
    fs.mkdirSync(baseDumpDir);
}

if (!fs.existsSync(subBaseDumpDir)) {
    logger.verbose(`${MODULE_NAME} A9807434: Creating dump dir`);
    fs.mkdirSync(subBaseDumpDir);
}

module.exports = async (xid, httpMethod, endpointUrl, params, axiosResponse, axiosError) => {
    if (
        !config
        || !config.listener
        || !config.listener.core
        || !config.listener.core.dump
    ) {
        return;
    }

    const data = `--------
XID: ${xid}
PID: ${process.pid}
DATE: ${moment().format('YYYY-MM-DD HH:mm:ss.SSS')}

HTTP METHOD: ${httpMethod}
ENDPOINT URL: ${endpointUrl}

REQ PARAMS:
${JSON.stringify(params, null, 2)}

ERROR CODE: ${(axiosError && axiosError.code) || ''}
ERROR MESSAGE: ${(axiosError && axiosError.message) || ''}

RES HTTP STATUS: ${axiosResponse && axiosResponse.status}
RES BODY:
${
    axiosResponse && axiosResponse.data && (
        ((typeof axiosResponse.data === 'string') && axiosResponse.data)
        || JSON.stringify(axiosResponse.data, null, 2)
    )
}
`;

    const dumpDir = path.join(
        subBaseDumpDir,
        moment().format('YYYY-MM-DD'),
    );

    try {
        await fsPromise.stat(dumpDir);
    } catch (e) {
        await fsPromise.mkdir(dumpDir, { recursive: true });
    }

    const dumpFileName = path.join(
        dumpDir,
        [
            'sent',
            moment().format('YYMMDD_HHmmss_SSS'),
            xid,
        ].join('_'),
    );

    await fsPromise.writeFile(dumpFileName, data);

    try {
        await fsPromise.unlink(lastSymbolicLinkName);
    } catch (e) {
        //
    }

    await fs.symlink(dumpFileName, lastSymbolicLinkName);
};