const soap = require('soap'); const xmlParser = require('xml2js').parseString; const UserError = require('vn-loopback/util/user-error'); module.exports = Self => { Self.remoteMethod('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 { if (process.env.NODE_ENV !== 'production') { status = { codigo: [200], descripcion: ['Fake response'] }; } else { [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; }; };