const soap = require('soap');
const xmlParser = require('xml2js').parseString;
const UserError = require('vn-loopback/util/user-error');

module.exports = Self => {
    Self.remoteMethodCtx('send', {
        description: 'Sends SMS to a destination phone',
        accessType: 'WRITE',
        accepts: [{
            arg: 'destinationFk',
            type: 'Integer'
        },
        {
            arg: 'destination',
            type: 'String',
            required: true,
        },
        {
            arg: 'message',
            type: 'String',
            required: true,
        }],
        returns: {
            type: 'Object',
            root: true
        },
        http: {
            path: `/send`,
            verb: 'POST'
        }
    });

    Self.send = async(ctx, destinationFk, destination, message) => {
        const userId = ctx.req.accessToken.userId;
        const smsConfig = await Self.app.models.SmsConfig.findOne();
        const soapClient = await soap.createClientAsync(smsConfig.uri);
        const params = {
            user: smsConfig.user,
            pass: smsConfig.password,
            src: smsConfig.title,
            dst: destination,
            msg: message
        };

        let xmlResponse;
        let xmlResult;
        let xmlParsed;
        let status;

        try {
            [xmlResponse] = await soapClient.sendSMSAsync(params);
            xmlResult = xmlResponse.result.$value;
            xmlParsed = await new Promise((resolve, reject) => {
                xmlParser(xmlResult, (err, result) => {
                    if (err)
                        reject(err);
                    resolve(result);
                });
            });
            [status] = xmlParsed['xtratelecom-sms-response'].sms;
        } catch (e) {
            console.error(e);
        }

        const statusCode = status.codigo[0];
        const statusDescription = status.descripcion[0];

        const newSms = {
            senderFk: userId,
            destinationFk: destinationFk || null,
            destination: destination,
            message: message,
            statusCode: statusCode,
            status: statusDescription
        };

        const sms = await Self.create(newSms);

        if (statusCode != 200)
            throw new UserError(`We weren't able to send this SMS`);

        return sms;
    };
};