New file |
| | |
| | | <?php |
| | | |
| | | /* |
| | | Copyright (c) 2009, Falko Timme, Till Brehm, projektfarm Gmbh |
| | | All rights reserved. |
| | | |
| | | Redistribution and use in source and binary forms, with or without modification, |
| | | are permitted provided that the following conditions are met: |
| | | |
| | | * Redistributions of source code must retain the above copyright notice, |
| | | this list of conditions and the following disclaimer. |
| | | * Redistributions in binary form must reproduce the above copyright notice, |
| | | this list of conditions and the following disclaimer in the documentation |
| | | and/or other materials provided with the distribution. |
| | | * Neither the name of ISPConfig nor the names of its contributors |
| | | may be used to endorse or promote products derived from this software without |
| | | specific prior written permission. |
| | | |
| | | THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND |
| | | ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
| | | WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| | | IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, |
| | | INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, |
| | | BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| | | DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY |
| | | OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING |
| | | NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, |
| | | EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| | | */ |
| | | |
| | | /* |
| | | The powerdns database name has to be "powerdns" and it must be accessible |
| | | by the "ispconfig" database user |
| | | |
| | | TABLE STRUCTURE of the "powerdns" database: |
| | | |
| | | CREATE TABLE `domains` ( |
| | | `id` int(11) NOT NULL auto_increment, |
| | | `name` varchar(255) NOT NULL, |
| | | `master` varchar(128) default NULL, |
| | | `last_check` int(11) default NULL, |
| | | `type` varchar(6) NOT NULL, |
| | | `notified_serial` int(11) default NULL, |
| | | `account` varchar(40) default NULL, |
| | | `ispconfig_id` int(11) NOT NULL, |
| | | PRIMARY KEY (`id`), |
| | | UNIQUE KEY `name_index` (`name`) |
| | | ) ENGINE=MyISAM DEFAULT CHARSET=latin1; |
| | | |
| | | CREATE TABLE `records` ( |
| | | `id` int(11) NOT NULL auto_increment, |
| | | `domain_id` int(11) default NULL, |
| | | `name` varchar(255) default NULL, |
| | | `type` varchar(6) default NULL, |
| | | `content` varchar(255) default NULL, |
| | | `ttl` int(11) default NULL, |
| | | `prio` int(11) default NULL, |
| | | `change_date` int(11) default NULL, |
| | | `ispconfig_id` int(11) NOT NULL, |
| | | PRIMARY KEY (`id`), |
| | | KEY `rec_name_index` (`name`), |
| | | KEY `nametype_index` (`name`,`type`), |
| | | KEY `domain_id` (`domain_id`) |
| | | ) ENGINE=MyISAM DEFAULT CHARSET=latin1; |
| | | |
| | | CREATE TABLE `supermasters` ( |
| | | `ip` varchar(25) NOT NULL, |
| | | `nameserver` varchar(255) NOT NULL, |
| | | `account` varchar(40) default NULL |
| | | ) ENGINE=MyISAM DEFAULT CHARSET=latin1; |
| | | |
| | | |
| | | IMPORTANT: |
| | | - This plugin does not support ALIAS records (supported only by MyDNS). |
| | | |
| | | TODO: |
| | | - introduce a variable for the PowerDNS database |
| | | */ |
| | | |
| | | class powerdns_plugin { |
| | | |
| | | var $plugin_name = 'powerdns_plugin'; |
| | | var $class_name = 'powerdns_plugin'; |
| | | |
| | | //* This function is called during ispconfig installation to determine |
| | | // if a symlink shall be created for this plugin. |
| | | function onInstall() { |
| | | global $conf; |
| | | |
| | | if(isset($conf['powerdns']['installed']) && $conf['powerdns']['installed'] == true) { |
| | | return true; |
| | | } else { |
| | | return false; |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | /* |
| | | This function is called when the plugin is loaded |
| | | */ |
| | | |
| | | function onLoad() { |
| | | global $app; |
| | | |
| | | /* |
| | | Register for the events |
| | | */ |
| | | |
| | | //* SOA |
| | | $app->plugins->registerEvent('dns_soa_insert',$this->plugin_name,'soa_insert'); |
| | | $app->plugins->registerEvent('dns_soa_update',$this->plugin_name,'soa_update'); |
| | | $app->plugins->registerEvent('dns_soa_delete',$this->plugin_name,'soa_delete'); |
| | | |
| | | //* RR |
| | | $app->plugins->registerEvent('dns_rr_insert',$this->plugin_name,'rr_insert'); |
| | | $app->plugins->registerEvent('dns_rr_update',$this->plugin_name,'rr_update'); |
| | | $app->plugins->registerEvent('dns_rr_delete',$this->plugin_name,'rr_delete'); |
| | | |
| | | } |
| | | |
| | | |
| | | function soa_insert($event_name,$data) { |
| | | global $app, $conf; |
| | | |
| | | if($data["new"]["active"] != 'Y') return; |
| | | |
| | | $origin = substr($data["new"]["origin"], 0, -1); |
| | | $ispconfig_id = $data["new"]["id"]; |
| | | $app->db->query("INSERT INTO powerdns.domains (name, type, ispconfig_id) VALUES ('$origin', 'NATIVE', $ispconfig_id)"); |
| | | $zone_id = mysql_insert_id(); |
| | | if(substr($data["new"]["ns"], -1) == '.'){ |
| | | $ns = substr($data["new"]["ns"], 0, -1); |
| | | } else { |
| | | $ns = $data["new"]["ns"].'.'.$origin; |
| | | } |
| | | if($ns == '') $ns = $origin; |
| | | |
| | | $hostmaster = substr($data["new"]["mbox"], 0, -1); |
| | | $content = $ns.' '.$hostmaster.' 0'; |
| | | $ttl = $data["new"]["ttl"]; |
| | | |
| | | $app->db->query("INSERT INTO powerdns.records (domain_id, name, type, content, ttl, prio, change_date, ispconfig_id) VALUES ($zone_id, '$origin', 'SOA', '$content', $ttl, 0, ".time().", $ispconfig_id)"); |
| | | |
| | | } |
| | | |
| | | function soa_update($event_name,$data) { |
| | | global $app, $conf; |
| | | |
| | | if($data["new"]["active"] != 'Y'){ |
| | | if($data["old"]["active"] != 'Y') return; |
| | | $this->soa_delete($event_name,$data); |
| | | } else { |
| | | if($data["old"]["active"] == 'Y'){ |
| | | $origin = substr($data["new"]["origin"], 0, -1); |
| | | $ispconfig_id = $data["new"]["id"]; |
| | | $app->db->query("UPDATE powerdns.domains SET name = '$origin' WHERE ispconfig_id = $ispconfig_id"); |
| | | |
| | | if(substr($data["new"]["ns"], -1) == '.'){ |
| | | $ns = substr($data["new"]["ns"], 0, -1); |
| | | } else { |
| | | $ns = $data["new"]["ns"].'.'.$origin; |
| | | } |
| | | if($ns == '') $ns = $origin; |
| | | |
| | | $hostmaster = substr($data["new"]["mbox"], 0, -1); |
| | | $content = $ns.' '.$hostmaster.' 0'; |
| | | $ttl = $data["new"]["ttl"]; |
| | | $app->db->query("UPDATE powerdns.records SET name = '$origin', content = '$content', ttl = $ttl, change_date = ".time()." WHERE ispconfig_id = ".$data["new"]["id"]." AND type = 'SOA'"); |
| | | } else { |
| | | $this->soa_insert($event_name,$data); |
| | | $ispconfig_id = $data["new"]["id"]; |
| | | if($records = $app->db->queryAllRecords("SELECT * FROM dns_rr WHERE zone = $ispconfig_id AND active = 'Y'")){ |
| | | foreach($records as $record){ |
| | | foreach($record as $key => $val){ |
| | | $data["new"][$key] = $val; |
| | | } |
| | | $this->rr_insert("dns_rr_insert", $data); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | function soa_delete($event_name,$data) { |
| | | global $app, $conf; |
| | | |
| | | $zone = $app->db->queryOneRecord("SELECT * FROM powerdns.domains WHERE ispconfig_id = ".$data["old"]["id"]); |
| | | $zone_id = $zone["id"]; |
| | | $app->db->query("DELETE FROM powerdns.records WHERE domain_id = $zone_id"); |
| | | $app->db->query("DELETE FROM powerdns.domains WHERE id = $zone_id"); |
| | | |
| | | } |
| | | |
| | | function rr_insert($event_name,$data) { |
| | | global $app, $conf; |
| | | if($data["new"]["active"] != 'Y') return; |
| | | |
| | | $zone = $app->db->queryOneRecord("SELECT * FROM dns_soa WHERE id = ".$data["new"]["zone"]); |
| | | $origin = substr($zone["origin"], 0, -1); |
| | | $powerdns_zone = $app->db->queryOneRecord("SELECT * FROM powerdns.domains WHERE ispconfig_id = ".$data["new"]["zone"]); |
| | | $zone_id = $powerdns_zone["id"]; |
| | | |
| | | $type = $data["new"]["type"]; |
| | | |
| | | switch ($type) { |
| | | case "PTR": |
| | | $name = $data["new"]["name"]; |
| | | break; |
| | | default: |
| | | if(substr($data["new"]["name"], -1) == '.'){ |
| | | $name = substr($data["new"]["name"], 0, -1); |
| | | } else { |
| | | if($data["new"]["name"] == ""){ |
| | | $name = $origin; |
| | | } else { |
| | | $name = $data["new"]["name"].'.'.$origin; |
| | | } |
| | | } |
| | | if($name == '') $name = $origin; |
| | | } |
| | | |
| | | switch ($type) { |
| | | case "CNAME": |
| | | case "MX": |
| | | case "NS": |
| | | case "ALIAS": |
| | | case "PTR": |
| | | case "SRV": |
| | | if(substr($data["new"]["data"], -1) == '.'){ |
| | | $content = substr($data["new"]["data"], 0, -1); |
| | | } else { |
| | | $content = $data["new"]["data"].'.'.$origin; |
| | | } |
| | | break; |
| | | case "HINFO": |
| | | $content = $data["new"]["data"]; |
| | | $quote1 = strpos($content, '"'); |
| | | if($quote1 !== FALSE){ |
| | | $quote2 = strpos(substr($content, ($quote1 + 1)), '"'); |
| | | } |
| | | if($quote1 !== FALSE && $quote2 !== FALSE){ |
| | | $text_between_quotes = str_replace(' ', '_', substr($content, ($quote1 + 1), (($quote2 - $quote1)))); |
| | | $content = $text_between_quotes.substr($content, ($quote2 + 2)); |
| | | } |
| | | break; |
| | | default: |
| | | $content = $data["new"]["data"]; |
| | | } |
| | | |
| | | $ttl = $data["new"]["ttl"]; |
| | | $prio = $data["new"]["aux"]; |
| | | $change_date = time(); |
| | | $ispconfig_id = $data["new"]["id"]; |
| | | |
| | | $app->db->query("INSERT INTO powerdns.records (domain_id, name, type, content, ttl, prio, change_date, ispconfig_id) VALUES ($zone_id, '$name', '$type', '$content', $ttl, $prio, $change_date, $ispconfig_id)"); |
| | | |
| | | } |
| | | |
| | | function rr_update($event_name,$data) { |
| | | global $app, $conf; |
| | | |
| | | if($data["new"]["active"] != 'Y'){ |
| | | if($data["old"]["active"] != 'Y') return; |
| | | $this->rr_delete($event_name,$data); |
| | | } else { |
| | | if($data["old"]["active"] == 'Y'){ |
| | | $zone = $app->db->queryOneRecord("SELECT * FROM dns_soa WHERE id = ".$data["new"]["zone"]); |
| | | $origin = substr($zone["origin"], 0, -1); |
| | | $powerdns_zone = $app->db->queryOneRecord("SELECT * FROM powerdns.domains WHERE ispconfig_id = ".$data["new"]["zone"]); |
| | | $zone_id = $powerdns_zone["id"]; |
| | | |
| | | $type = $data["new"]["type"]; |
| | | |
| | | switch ($type) { |
| | | case "PTR": |
| | | $name = $data["new"]["name"]; |
| | | break; |
| | | default: |
| | | if(substr($data["new"]["name"], -1) == '.'){ |
| | | $name = substr($data["new"]["name"], 0, -1); |
| | | } else { |
| | | if($data["new"]["name"] == ""){ |
| | | $name = $origin; |
| | | } else { |
| | | $name = $data["new"]["name"].'.'.$origin; |
| | | } |
| | | } |
| | | if($name == '') $name = $origin; |
| | | } |
| | | |
| | | switch ($type) { |
| | | case "CNAME": |
| | | case "MX": |
| | | case "NS": |
| | | case "ALIAS": |
| | | case "PTR": |
| | | case "SRV": |
| | | if(substr($data["new"]["data"], -1) == '.'){ |
| | | $content = substr($data["new"]["data"], 0, -1); |
| | | } else { |
| | | $content = $data["new"]["data"].'.'.$origin; |
| | | } |
| | | break; |
| | | case "HINFO": |
| | | $content = $data["new"]["data"]; |
| | | $quote1 = strpos($content, '"'); |
| | | if($quote1 !== FALSE){ |
| | | $quote2 = strpos(substr($content, ($quote1 + 1)), '"'); |
| | | } |
| | | if($quote1 !== FALSE && $quote2 !== FALSE){ |
| | | $text_between_quotes = str_replace(' ', '_', substr($content, ($quote1 + 1), (($quote2 - $quote1)))); |
| | | $content = $text_between_quotes.substr($content, ($quote2 + 2)); |
| | | } |
| | | break; |
| | | default: |
| | | $content = $data["new"]["data"]; |
| | | } |
| | | |
| | | $ttl = $data["new"]["ttl"]; |
| | | $prio = $data["new"]["aux"]; |
| | | $change_date = time(); |
| | | $ispconfig_id = $data["new"]["id"]; |
| | | //echo "UPDATE powerdns.records SET name = '$name', type = '$type', content = '$content', ttl = $ttl, prio = $prio, change_date = ".time()." WHERE id = $record_id"; |
| | | $app->db->query("UPDATE powerdns.records SET name = '$name', type = '$type', content = '$content', ttl = $ttl, prio = $prio, change_date = ".time()." WHERE ispconfig_id = $ispconfig_id AND type != 'SOA'"); |
| | | |
| | | } else { |
| | | $this->rr_insert($event_name,$data); |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | function rr_delete($event_name,$data) { |
| | | global $app, $conf; |
| | | |
| | | $ispconfig_id = $data["old"]["id"]; |
| | | $app->db->query("DELETE FROM powerdns.records WHERE ispconfig_id = $ispconfig_id AND type != 'SOA'"); |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | } // end class |
| | | |
| | | ?> |