salix/back/methods/mrw-config/createShipment.js

const axios = require('axios');
const {DOMParser} = require('xmldom');
const fs = require('fs');
const ejs = require('ejs');
const UserError = require('vn-loopback/util/user-error');

module.exports = Self => {
    Self.remoteMethodCtx('createShipment', {
        description: 'Create an expedition and return a base64Binary label',
        accessType: 'WRITE',
        accepts: [{
            arg: 'expeditionFk',
            type: 'number',
            required: true
        }],
        returns: {
            type: ['object'],
            root: true
        },
        http: {
            path: `/createShipment`,
            verb: 'POST'
        }
    });

    Self.createShipment = async(ctx, expeditionFk, options) => {
        const myOptions = {};

        if (typeof options == 'object')
            Object.assign(myOptions, options);

        const models = Self.app.models;
        const mrw = await models.MrwConfig.findOne(null, myOptions);
        console.log('mrw: ', mrw);

        if (!mrw)
            throw new UserError(`Some mrwConfig parameters are not set`);

        const [expeditionData] = await Self.rawSql(
            fs.readFileSync(__dirname + '/expeditionData.sql', 'utf-8'),
            null,
            myOptions
        );
        console.log('sigue');
        if (!expeditionData)
            throw new UserError(`This expedition is not a MRW shipment`);

        if (expeditionData?.created < Date.vnNew())
            throw new UserError(`This ticket has a shipped date earlier than today`); po;

        const shipmentResponse = await sendXmlDoc('createShipment', {mrw, expeditionData});

        const parser = new DOMParser();
        const shipmentXmlDoc = parser.parseFromString(shipmentResponse, 'text/xml');
        const shipmentId = getTextByTag(shipmentXmlDoc, 'NumeroEnvio');

        if (!shipmentId)
            throw new UserError(getTextByTag(shipmentXmlDoc, 'Mensaje'));

        const getLabelResponse = await sendXmlDoc('getLabel', {mrw, shipmentId});

        const getLabelXmlDoc = parser.parseFromString(getLabelResponse, 'text/xml');
        const file = getTextByTag(getLabelXmlDoc, 'EtiquetaFile');
        console.log('file: ', file);
        if (!file) {
            const message = getTextByTag(getLabelXmlDoc, 'Mensaje') ??
                `The MRW web service is not returning the expected response`;
            throw new UserError(message);
        }
        await models.Expedition.updateAll({id: expeditionFk}, {externalId: shipmentId}, options);

        return file;
    };

    function getTextByTag(xmlDoc, tag) {
        const parser = new DOMParser();
        const doc = parser.parseFromString(xmlDoc?.data, 'text/xml');
        return doc?.getElementsByTagName(tag)[0]?.textContent;
    }

    async function sendXmlDoc(xmlDock, params) {
        const xmlTemplate = fs.readFileSync(__dirname + `/${xmlDock}.ejs`, 'utf-8');
        const renderedTemplate = ejs.render(xmlTemplate, params);
        const {data} = await axios.post(params.mrw.url, renderedTemplate, {
            headers: {
                'Content-Type': 'application/soap+xml; charset=utf-8'
            }
        });

        console.log('data: ', data);
        return data;
    }
};