modules/dns/include/dnsinclude.php (0a43c60) - webinterface.git

dnsinclude.php

<?php
/*
This file belongs to the Webinterface of schokokeks.org Hosting

Written 2008-2018 by schokokeks.org Hosting, namely
  Bernd Wurst <bernd@schokokeks.org>
  Hanno Böck <hanno@schokokeks.org>

To the extent possible under law, the author(s) have dedicated all copyright and related and neighboring rights to this software to the public domain worldwide. This software is distributed without any warranty.

You should have received a copy of the CC0 Public Domain Dedication along with this software. If not, see
http://creativecommons.org/publicdomain/zero/1.0/

Nevertheless, in case you use a significant part of this code, we ask (but not require, see the license) that you keep the authors' names in place and return your changes to the public. We would be especially happy if you tell us what you're going to do with this code.
*/

require_once('inc/debug.php');
require_once('inc/base.php');
require_once('inc/security.php');
require_once('inc/error.php');

require_once('class/domain.php');

$caa_properties= array( 0 => "issue", 1 => "issuewild", 2 => "iodef" );

function get_dyndns_accounts()
{
    $uid = (int) $_SESSION['userinfo']['uid'];
    $result = db_query("SELECT * FROM dns.dyndns WHERE uid=?", array($uid));
    $list = array();
    while ($item = $result->fetch()) {
        array_push($list, $item);
    }
    DEBUG($list);
    return $list;
}

function create_dyndns_account($handle, $password_http, $sshkey)
{
    $uid = (int) $_SESSION['userinfo']['uid'];

if ($password_http == '' && $sshkey == '') {
        system_failure('Sie müssen entweder einen SSH-Key oder ein Passwort zum Web-Update eingeben.');
    }

$handle = verify_input_identifier($handle);

if (strlen(trim($sshkey)) == 0) {
        $sshkey = null;
    } else {
        $sshkey = filter_ssh_key($sshkey);
    }

$pwhash = null;
    if ($password_http) {
        $pwhash = "{SHA}".base64_encode(sha1($password_http, true));
    }

db_query(
        "INSERT INTO dns.dyndns (uid, handle, password, sshkey) VALUES ".
           "(:uid, :handle, :pwhash, :sshkey)",
        array(":uid" => $uid, ":handle" => $handle, ":pwhash" => $pwhash, ":sshkey" => $sshkey)
    );
    $dyndns_id = db_insert_id();
    //$masterdomain = new Domain(config('masterdomain'));
    //db_query("INSERT INTO dns.custom_records (type, domain, hostname, dyndns, ttl) VALUES ".
    //         "('a', :dom, :hostname, :dyndns, 120)",
    //         array(":dom" => $masterdomain->id, ":hostname" => filter_input_hostname($handle).'.'.$_SESSION['userinfo']['username'], ":dyndns" => $dyndns_id));
    logger(LOG_INFO, "modules/dns/include/dnsinclude", "dyndns", "inserted account {$dyndns_id}");
    return $dyndns_id;
}

function edit_dyndns_account($id, $handle, $password_http, $sshkey)
{
    $id = (int) $id;
    $oldaccount = get_dyndns_account($id);
    $handle = verify_input_identifier($handle);
    $sshkey = verify_input_ascii($sshkey);
    if (trim($sshkey) == '') {
        $sshkey = null;
    }

if ($oldaccount['handle'] != $handle) {
        $masterdomain = new Domain(config('masterdomain'));
        db_query(
            "UPDATE dns.custom_records SET hostname=:newhostname WHERE ".
             "hostname=:oldhostname AND domain=:dom AND dyndns=:dyndns AND ip IS NULL",
            array(":dom" => $masterdomain->id, ":newhostname" => filter_input_hostname($handle).'.'.$_SESSION['userinfo']['username'],
                   ":oldhostname" => $oldaccount['handle'].'.'.$_SESSION['userinfo']['username'],  ":dyndns" => $id)
        );
    }

$args = array(":handle" => $handle, ":sshkey" => $sshkey, ":id" => $id);
    $pwhash = null;
    if ($password_http && $password_http != '************') {
        $args[":pwhash"] = "{SHA}".base64_encode(sha1($password_http, true));
        db_query("UPDATE dns.dyndns SET handle=:handle, password=:pwhash, sshkey=:sshkey WHERE id=:id", $args);
    } else {
        db_query("UPDATE dns.dyndns SET handle=:handle, sshkey=:sshkey WHERE id=:id", $args);
    }
    logger(LOG_INFO, "modules/dns/include/dnsinclude", "dyndns", "edited account »{$id}«");
}

function delete_dyndns_account($id)
{
    $id = (int) $id;

db_query("DELETE FROM dns.dyndns WHERE id=?", array($id));
    logger(LOG_INFO, "modules/dns/include/dnsinclude", "dyndns", "deleted account »{$id}«");
}

$valid_record_types = array('a', 'aaaa', 'mx', 'ns', 'spf', 'txt', 'cname', 'ptr', 'srv', 'raw', 'sshfp', 'caa', 'srv');

function get_dns_record($id)
{
    $id = (int) $id;
    $result = db_query("SELECT hostname, domain, type, ip, dyndns, spec, data, ttl FROM dns.custom_records WHERE id=?", array($id));
    if ($result->rowCount() != 1) {
        system_failure('illegal ID');
    }
    $data = $result->fetch();
    $dom = new Domain((int) $data['domain']);
    $dom->ensure_userdomain();
    DEBUG($data);
    return $data;
}

function get_domain_auto_records($domainname)
{
    $result = db_query("SELECT hostname, domain, CONCAT_WS('.', hostname, domain) AS fqdn, type, ip, spec, data, ttl FROM dns.tmp_autorecords WHERE domain=?", array($domainname));
    $data = array();
    while ($entry = $result->fetch()) {
        array_push($data, $entry);
    }
    DEBUG($data);
    return $data;
}

$implemented_record_types = array('a', 'aaaa', 'mx', 'spf', 'txt', 'cname', 'ptr', 'srv', 'ns', 'sshfp', 'caa');

case 'spf':
    case 'txt':
      $record['dyndns'] = null;
      $record['spec'] = null;
      $record['ip'] = null;
      if (! $record['data']) {
          system_failure('text entry missing');
      }
      break;

case 'sshfp':
      $record['dyndns'] = null;
      $record['spec'] = max((int) $record['spec'], 1);
      $record['ip'] = null;
      if (! $record['data']) {
          system_failure('text entry missing');
      }
      break;

case 'caa':
      $record['dyndns'] = null;
      $record['ip'] = null;
      if (! $record['data']) {
          system_failure('text entry missing');
      }
      break;

case 'srv':
      $record['dyndns'] = null;
      $record['spec'] = (int) $record['spec'];
      if ($record['spec'] < 0) {
          system_failure("invalid priority");
      }
      if (! $record['data']) {
          system_failure('SRV target missing');
      }
      $data = explode(':', $record['data']);
      if (count($data) != 2) {
          system_failure('Das eingegebene Ziel war nicht im Format hostname:port');
      }
      list($hostname, $port) = $data;
      verify_input_hostname($hostname);
      if ($port !== (string)(int) $port || (int)$port < 1 || (int)$port > 65535) {
          system_failure('Ungültige Portnummer');
      }
      $record['ip'] = null;
      break;
    default:
      system_failure('Not implemented');
  }
    $id = (int) $id;
    $args = array(":domain" => $dom->id,
                ":hostname" => $record['hostname'],
                ":type" => $record['type'],
                ":ttl" => ($record['ttl'] == 0 ? null : (int) $record['ttl']),
                ":ip" => $record['ip'],
                ":dyndns" => $record['dyndns'],
                ":data" => $record['data'],
                ":spec" => $record['spec']);
    if ($id) {
        $args[":id"] = $id;
        db_query("UPDATE dns.custom_records SET hostname=:hostname, domain=:domain, type=:type, ttl=:ttl, ip=:ip, dyndns=:dyndns, data=:data, spec=:spec WHERE id=:id", $args);
    } else {
        db_query("INSERT INTO dns.custom_records (hostname, domain, type, ttl, ip, dyndns, data, spec) VALUES (:hostname, :domain, :type, :ttl, :ip, :dyndns, :data, :spec)", $args);
    }
}

function delete_dns_record($id)
{
    $id = (int) $id;
    // Diese Funktion prüft, ob der Eintrag einer eigenen Domain gehört
    $record = get_dns_record($id);
    db_query("DELETE FROM dns.custom_records WHERE id=?", array($id));
}

function convert_from_autorecords($domainid)
{
    $dom = new Domain((int) $domainid);
    $dom->ensure_userdomain();
    $dom = $dom->id;

db_query("INSERT IGNORE INTO dns.custom_records SELECT r.id, r.lastchange, type, d.id, hostname, ip, NULL AS dyndns, data, spec, ttl FROM dns.v_tmptable_allrecords AS r INNER JOIN dns.v_domains AS d ON (d.name=r.domain) WHERE d.id=?", array($dom));
    disable_autorecords($dom);
    db_query("UPDATE dns.dnsstatus SET status='outdated'");
    warning("Die automatischen Einträge werden in Kürze abgeschaltet, bitte haben Sie einen Moment Geduld.");
}

function enable_autorecords($domainid)
{
    $dom = new Domain((int) $domainid);
    $dom->ensure_userdomain();
    $dom = $dom->id;

db_query("UPDATE kundendaten.domains SET autodns=1 WHERE id=?", array($dom));
    db_query("DELETE FROM dns.custom_records WHERE type='ns' AND domain=? AND hostname IS NULL", array($dom));
    warning("Die automatischen Einträge werden in Kürze aktiviert, bitte haben Sie einen Moment Geduld.");
}

function disable_autorecords($domainid)
{
    $dom = new Domain((int) $domainid);
    $dom->ensure_userdomain();
    $dom = $dom->id;

db_query("UPDATE kundendaten.domains SET autodns=0 WHERE id=?", array($dom));
}

function domain_is_maildomain($domain)
{
    $domain = (int) $domain;
    $result = db_query("SELECT mail FROM kundendaten.domains WHERE id=?", array($domain));
    $dom = $result->fetch();
    return ($dom['mail'] != 'none');
}

$own_ns = array();

function own_ns()
{
    global $own_ns;

if (count($own_ns) < 1) {
        $auth = dns_get_record(config('masterdomain'), DNS_NS);
        foreach ($auth as $ns) {
            $own_ns[] = $ns['target'];
        }
    }

return $own_ns;
}

$tld_ns = array();

function check_dns($domainname, $tld)
{
    global $tld_ns;
    $domain=idn_to_ascii($domainname.".".$tld, 0, INTL_IDNA_VARIANT_UTS46);

if (! isset($tld_ns[$tld])) {
        $resp = shell_exec('dig @a.root-servers.net. +noall +authority -t ns '.$tld.'.');
        $line = explode("\n", $resp, 2)[0];
        $NS = preg_replace("/^.*\\sIN\\s+NS\\s+(\\S+)$/", '\1', $line);
        $tld_ns[$tld] = $NS;
    }

$resp = shell_exec('dig @'.$tld_ns[$tld].' +noall +authority -t ns '.$domain.'.');
    $line = explode("\n", $resp, 2)[0];
    if (preg_match('/^.*\\sIN\\s+NS\\s+/', $line) === 0) {
        return "NXDOMAIN";
    }
    $NS = preg_replace("/^.*\\sIN\\s+NS\\s+(\\S+).$/", '\1', $line);

$own_ns = own_ns();

if (in_array($NS, $own_ns)) {
        return true;
    }
    return $NS;
}

webinterface.git

more robust SRV record filter, disallow multiple :, negative and too high port numbers