const router = require('express').Router();
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 short = require('short-uuid');
const {promisePool} = require('../../db');
const sysError = require('../error');


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;

  try {
    if (!account_sid) {
      service_provider_sid = parseServiceProviderSid(req);
    } else {
      service_provider_sid = req.user.service_provider_sid;
    }

    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] = await promisePool.query(sqlSelectCarrierByNameForSP, [service_provider_sid, template.name]);

    if (r2.length > 0) {
      template.name =  `${template.name}-${short.generate()}`;
    }

    /* 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;