mirror of
https://github.com/jambonz/jambonz-api-server.git
synced 2026-02-09 02:29:59 +00:00
88 lines
3.5 KiB
JavaScript
88 lines
3.5 KiB
JavaScript
const router = require('express').Router();
|
|
const {DbErrorBadRequest} = require('../../utils/errors');
|
|
const PredefinedCarrier = require('../../models/predefined-carrier');
|
|
const VoipCarrier = require('../../models/voip-carrier');
|
|
const SipGateway = require('../../models/sip-gateway');
|
|
const SmppGateway = require('../../models/smpp-gateway');
|
|
const {parseServiceProviderSid} = require('./utils');
|
|
const {promisePool} = require('../../db');
|
|
const sysError = require('../error');
|
|
|
|
const sqlSelectCarrierByName = `SELECT * FROM voip_carriers
|
|
WHERE account_sid = ?
|
|
AND name = ?`;
|
|
const sqlSelectCarrierByNameForSP = `SELECT * FROM voip_carriers
|
|
WHERE service_provider_sid = ?
|
|
AND name = ?`;
|
|
const sqlSelectTemplateSipGateways = `SELECT * FROM predefined_sip_gateways
|
|
WHERE predefined_carrier_sid = ?`;
|
|
const sqlSelectTemplateSmppGateways = `SELECT * FROM predefined_smpp_gateways
|
|
WHERE predefined_carrier_sid = ?`;
|
|
|
|
|
|
router.post('/:sid', async(req, res) => {
|
|
const logger = req.app.locals.logger;
|
|
const {sid } = req.params;
|
|
let service_provider_sid;
|
|
const {account_sid} = req.user;
|
|
if (!account_sid) {
|
|
if (!req.user.hasScope('service_provider')) {
|
|
logger.error({user: req.user}, 'invalid creds');
|
|
return res.sendStatus(403);
|
|
}
|
|
service_provider_sid = parseServiceProviderSid(req);
|
|
}
|
|
try {
|
|
const [template] = await PredefinedCarrier.retrieve(sid);
|
|
logger.debug({template}, `Retrieved template carrier for sid ${sid}`);
|
|
if (!template) return res.sendStatus(404);
|
|
|
|
/* make sure not to add the same carrier twice */
|
|
const [r2] = account_sid ?
|
|
await promisePool.query(sqlSelectCarrierByName, [account_sid, template.name]) :
|
|
await promisePool.query(sqlSelectCarrierByNameForSP, [service_provider_sid, template.name]);
|
|
|
|
if (r2.length > 0) {
|
|
logger.info({account_sid}, `Failed to add carrier with name ${template.name}, carrier of that name exists`);
|
|
throw new DbErrorBadRequest(`A carrier with name ${template.name} already exists`);
|
|
}
|
|
|
|
/* retrieve all the sip gateways */
|
|
const [r3] = await promisePool.query(sqlSelectTemplateSipGateways, template.predefined_carrier_sid);
|
|
logger.debug({r3}, `retrieved template sip gateways for ${template.name}`);
|
|
|
|
/* retrieve all the smpp gateways */
|
|
const [r4] = await promisePool.query(sqlSelectTemplateSmppGateways, template.predefined_carrier_sid);
|
|
logger.debug({r4}, `retrieved template smpp gateways for ${template.name}`);
|
|
|
|
/* add a voip_carrier */
|
|
// eslint-disable-next-line no-unused-vars
|
|
const {requires_static_ip, predefined_carrier_sid, ...obj} = template;
|
|
const uuid = await VoipCarrier.make({...obj, account_sid, service_provider_sid});
|
|
|
|
/* add all the sipp gateways */
|
|
for (const gw of r3) {
|
|
// eslint-disable-next-line no-unused-vars
|
|
const {predefined_carrier_sid, predefined_sip_gateway_sid, ...obj} = gw;
|
|
logger.debug({obj}, 'adding sip gateway');
|
|
await SipGateway.make({...obj, voip_carrier_sid: uuid});
|
|
}
|
|
|
|
/* add all the smpp gateways */
|
|
for (const gw of r4) {
|
|
// eslint-disable-next-line no-unused-vars
|
|
const {predefined_carrier_sid, predefined_smpp_gateway_sid, ...obj} = gw;
|
|
logger.debug({obj}, 'adding smpp gateway');
|
|
await SmppGateway.make({...obj, voip_carrier_sid: uuid});
|
|
}
|
|
|
|
logger.debug({sid: uuid}, 'Successfully added carrier from predefined list');
|
|
res.status(201).json({sid: uuid});
|
|
} catch (err) {
|
|
logger.error({err}, 'Error adding voip_carrier from template');
|
|
sysError(logger, res, err);
|
|
}
|
|
});
|
|
|
|
module.exports = router;
|