From 080b349bd5821a48c18355a50cace1e9a276856f Mon Sep 17 00:00:00 2001 From: Gerhard Jungwirth Date: Fri, 2 Jun 2017 13:28:43 +0200 Subject: [PATCH] TT#13784 add stopper flag to peering rules Change-Id: I90cf08d06c1170605b8942ca89b5d826f945735b --- db_scripts/diff/15341.down | 63 ++++++++++++++++++++++++++++++++++++ db_scripts/diff/15341.up | 66 ++++++++++++++++++++++++++++++++++++++ 2 files changed, 129 insertions(+) create mode 100644 db_scripts/diff/15341.down create mode 100644 db_scripts/diff/15341.up diff --git a/db_scripts/diff/15341.down b/db_scripts/diff/15341.down new file mode 100644 index 00000000..58dbe46b --- /dev/null +++ b/db_scripts/diff/15341.down @@ -0,0 +1,63 @@ +USE provisioning; + +ALTER TABLE `provisioning`.`voip_peer_rules` +DROP COLUMN `stopper`; + + +DROP TRIGGER IF EXISTS provisioning.voip_prul_crepl_trig; +DELIMITER ;; +/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER provisioning.voip_prul_crepl_trig AFTER INSERT ON voip_peer_rules + FOR EACH ROW BEGIN + + IF NEW.enabled = 1 THEN + INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id) + VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, 0, 1, NEW.group_id); + + INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight) + SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight + FROM kamailio.lcr_gw gw + INNER JOIN provisioning.voip_peer_hosts vph ON vph.ip = gw.ip_addr + AND gw.lcr_id = 1 + AND vph.group_id = gw.group_id + INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id + WHERE vph.group_id <=> NEW.group_id; + END IF; + + END */;; +DELIMITER ; + +DROP TRIGGER IF EXISTS provisioning.voip_prul_urepl_trig; +DELIMITER ;; +/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER provisioning.voip_prul_urepl_trig AFTER UPDATE ON voip_peer_rules + FOR EACH ROW BEGIN + + IF OLD.enabled = 1 AND NEW.enabled = 1 THEN + UPDATE kamailio.lcr_rule + SET prefix = NEW.callee_prefix, request_uri = NEW.callee_pattern, + from_uri = NEW.caller_pattern + WHERE prefix <=> OLD.callee_prefix + AND request_uri <=> OLD.callee_pattern + AND from_uri <=> OLD.caller_pattern + AND group_id <=> OLD.group_id; + ELSEIF OLD.enabled = 0 AND NEW.enabled = 1 THEN + INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id) + VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, 0, 1, NEW.group_id); + + INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight) + SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight + FROM kamailio.lcr_gw gw + INNER JOIN provisioning.voip_peer_hosts vph ON vph.ip = gw.ip_addr + AND gw.lcr_id = 1 + AND vph.group_id = gw.group_id + INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id + WHERE vph.group_id <=> NEW.group_id; + ELSEIF OLD.enabled = 1 AND NEW.enabled = 0 THEN + DELETE FROM kamailio.lcr_rule + WHERE prefix <=> OLD.callee_prefix + AND request_uri <=> OLD.callee_pattern + AND from_uri <=> OLD.caller_pattern + AND group_id <=> OLD.group_id; + END IF; + + END */;; +DELIMITER ; diff --git a/db_scripts/diff/15341.up b/db_scripts/diff/15341.up new file mode 100644 index 00000000..3e975658 --- /dev/null +++ b/db_scripts/diff/15341.up @@ -0,0 +1,66 @@ +USE provisioning; + +ALTER TABLE `provisioning`.`voip_peer_rules` +ADD COLUMN `stopper` TINYINT(1) NOT NULL DEFAULT '0' AFTER `enabled`; + + +DROP TRIGGER IF EXISTS provisioning.voip_prul_crepl_trig; +DELIMITER ;; +/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER provisioning.voip_prul_crepl_trig AFTER INSERT ON voip_peer_rules + FOR EACH ROW BEGIN + + IF NEW.enabled = 1 THEN + INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id) + VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, NEW.stopper, 1, NEW.group_id); + + INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight) + SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight + FROM kamailio.lcr_gw gw + INNER JOIN provisioning.voip_peer_hosts vph ON vph.ip = gw.ip_addr + AND gw.lcr_id = 1 + AND vph.group_id = gw.group_id + INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id + WHERE vph.group_id <=> NEW.group_id; + END IF; + + END */;; +DELIMITER ; + +DROP TRIGGER IF EXISTS provisioning.voip_prul_urepl_trig; +DELIMITER ;; +/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER provisioning.voip_prul_urepl_trig AFTER UPDATE ON voip_peer_rules + FOR EACH ROW BEGIN + + IF OLD.enabled = 1 AND NEW.enabled = 1 THEN + UPDATE kamailio.lcr_rule + SET prefix = NEW.callee_prefix, request_uri = NEW.callee_pattern, + from_uri = NEW.caller_pattern, stopper = NEW.stopper + WHERE prefix <=> OLD.callee_prefix + AND request_uri <=> OLD.callee_pattern + AND from_uri <=> OLD.caller_pattern + AND group_id <=> OLD.group_id + AND stopper <=> OLD.stopper; + ELSEIF OLD.enabled = 0 AND NEW.enabled = 1 THEN + INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id) + VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, NEW.stopper, 1, NEW.group_id); + + INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight) + SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight + FROM kamailio.lcr_gw gw + INNER JOIN provisioning.voip_peer_hosts vph ON vph.ip = gw.ip_addr + AND gw.lcr_id = 1 + AND vph.group_id = gw.group_id + INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id + WHERE vph.group_id <=> NEW.group_id; + ELSEIF OLD.enabled = 1 AND NEW.enabled = 0 THEN + DELETE FROM kamailio.lcr_rule + WHERE prefix <=> OLD.callee_prefix + AND request_uri <=> OLD.callee_pattern + AND from_uri <=> OLD.caller_pattern + AND group_id <=> OLD.group_id + AND stopper <=> OLD.stopper + LIMIT 1; + END IF; + + END */;; +DELIMITER ;