'use strict'

const fs = require('node:fs');

const { fetch, Agent } = require('undici');


exports.register = function () {
    this.load_config();
    this.register_hook('queue', 'hook_queue');
};


exports.load_config = function () {
    this.cfg = this.config.get('webhook_forward.ini', {
        booleans: [
            '-allow_self_signed',
        ],
    },
    () => {
        this.load_config();
    });
};


exports.hook_queue = async function (next, connection) {
    const transaction = connection?.transaction;

    if (!transaction) {
        return next();
    }

    const writeToFile = (code, message) => {
        const file   = `${this.cfg.main.failed_requests_dir}/mail_${transaction.uuid}.eml`;
        const stream = fs.createWriteStream(file);

        stream.once('close', () => next(code, message));
        transaction.message_stream.pipe(stream);
    };


    try {
        this.lognotice(`Sending to ${this.cfg.main.url}`);

        const response = await fetch(this.cfg.main.url, {
            method:  'POST',
            duplex:  'half',
            body:    transaction.message_stream,
            agent:   new Agent({
                rejectUnauthorized: this.cfg.main.allow_self_signed,
            }),
            headers: {
                'Content-Type':  'message/rfc822',
                'User-Agent':    'haraka',
                'Authorization': `Bearer ${this.cfg.main.secret}`,
                'Message-Type':  'queue',
                'Message-ID':    transaction.uuid,
                'Message-From':  transaction.mail_from.toString(),
            },
        });

        if (!response.ok || response.status !== 202) {
            this.logerror(`Invalid response status ${response.status}`);

            return next(DENYSOFT, 'Processing failed');
        }

        // consume body to be sure the request is done in the app
        await response.text();

        return next(OK);

    } catch (e) {
        this.logerror(`Webhook processing failed with: ${e.message}`);

        writeToFile(DENYSOFT, 'Unexpected internal error');
    }
};