]> granicus.if.org Git - pdns/commitdiff
remove priority in remote backend
authorKees Monshouwer <mind04@monshouwer.org>
Sun, 17 Aug 2014 19:11:29 +0000 (21:11 +0200)
committermind04 <mind04@monshouwer.org>
Mon, 13 Oct 2014 22:08:57 +0000 (00:08 +0200)
modules/remotebackend/example.rb
modules/remotebackend/regression-tests/backend.rb
modules/remotebackend/regression-tests/basic-aaaa-resolution/tmp.rb
modules/remotebackend/regression-tests/long-txt-resolution/tmp.rb
modules/remotebackend/remotebackend.cc
modules/remotebackend/unittest.rb

index 777d31dc9ec815ecc9ecad023d125d7dec9ed0b5..f93e86c6ae921fbc6115a770ed2469a589924d33 100644 (file)
@@ -110,7 +110,7 @@ Coefficient: 5lP9IFknvFgaXKCs8MproehHSFhFTWac4557HIn03KrnlGOKDcY6DC/vgu1e42bEZ4J
        return [ 
           record("SOA","example.com", "sns.dns.icann.org noc.dns.icann.org 2013012485 7200 3600 1209600 3600"),
           record("NS","example.com","sns.dns.icann.org"),
-          record_prio("MX","example.com","test.example.com",10)
+          record("MX","example.com","10 test.example.com")
               ]
      elsif args["qname"] == "test.example.com" and args["qtype"].downcase == "any"
        return [
@@ -137,7 +137,7 @@ Coefficient: 5lP9IFknvFgaXKCs8MproehHSFhFTWac4557HIn03KrnlGOKDcY6DC/vgu1e42bEZ4J
        return [
           record("SOA","example.com", "sns.dns.icann.org noc.dns.icann.org 2013012485 7200 3600 1209600 3600"),
           record("NS","example.com","sns.dns.icann.org"),
-          record_prio("MX","example.com","test.example.com",10),
+          record("MX","example.com","10 test.example.com"),
           record("A","test.example.com","127.0.0.1")
        ]
      end
@@ -149,16 +149,12 @@ Coefficient: 5lP9IFknvFgaXKCs8MproehHSFhFTWac4557HIn03KrnlGOKDcY6DC/vgu1e42bEZ4J
 
   ## Some helpers after this 
 
-  def record_prio_ttl(qtype,qname,content,prio,ttl)
-    {:qtype => qtype, :qname => qname, :content => content, :priority => prio, :ttl => ttl, :auth => 1}
-  end
-
-  def record_prio(qtype,qname,content,prio)
-    record_prio_ttl(qtype,qname,content,prio,@default_ttl)
+  def record_ttl(qtype,qname,content,ttl)
+    {:qtype => qtype, :qname => qname, :content => content, :ttl => ttl, :auth => 1}
   end
 
   def record(qtype,qname,content)
-    record_prio_ttl(qtype,qname,content,0,@default_ttl)
+    record_ttl(qtype,qname,content,@default_ttl,)
   end
 
   def log(message)
index c81e2609ff8ad59a928a6fa707fb566fee055e23..d221a7edb65ca9eefa342775b90e6aa85c93b566 100755 (executable)
@@ -4,8 +4,8 @@ require 'rubygems'
 require 'json'
 require 'sqlite3'
 
-def rr(qname, qtype, content, ttl, priority = 0, auth = 1, domain_id = -1)
-   {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl.to_i, :priority => priority.to_i, :auth => auth.to_i, :domain_id => domain_id.to_i}
+def rr(qname, qtype, content, ttl, auth = 1, domain_id = -1)
+   {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl.to_i, :auth => auth.to_i, :domain_id => domain_id.to_i}
 end
 
 class Handler
@@ -95,7 +95,11 @@ class Handler
              end  
           end
           db.execute(sql, sargs) do |row|
-            ret << rr(row[1], row[2], row[3], row[4], row[5], row[6], row[0])
+            if (row[2] == "MX" || row[2] == "SRV")
+              ret << rr(row[1], row[2], row[5]+" "+row[3], row[4], row[6], row[0])
+            else
+              ret << rr(row[1], row[2], row[3], row[4], row[6], row[0])
+            end
           end
         rescue Exception => e
           e.backtrace
@@ -126,7 +130,11 @@ class Handler
           d_id = db.get_first_value("SELECT id FROM domains WHERE name = ?", target)
           return false if d_id.nil?
           db.execute("SELECT domain_id,name,type,content,ttl,prio,auth FROM records WHERE domain_id = ?", d_id) do |row|
-            ret << rr(row[1], row[2], row[3], row[4], row[5], row[6], row[0])
+            if (row[2] == "MX" || row[2] == "SRV")
+              ret << rr(row[1], row[2], row[5]+" "+row[3], row[4], row[6], row[0])
+            else
+              ret << rr(row[1], row[2], row[3], row[4], row[6], row[0])
+            end
           end
         rescue Exception => e
           e.backtrace
index 3cbe477357c41c40512ec55874724e108f2571c8..bec7f929f2553eaede4e33f25747f6cc0a1dbb99 100644 (file)
@@ -8,8 +8,8 @@ def from32(str)
    str.tr("ybndrfg8ejkmcpqxot1uwisza345h769", "0123456789abcdefghijklmnopqrstuv").to_i(32)
 end
 
-def rr(qname, qtype, content, ttl, priority = 0, auth = 1)
-   {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl, :priority => priority, :auth => auth}
+def rr(qname, qtype, content, ttl, auth = 1)
+   {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl, :auth => auth}
 end
 
 def send_result(*params)
index 3cbe477357c41c40512ec55874724e108f2571c8..bec7f929f2553eaede4e33f25747f6cc0a1dbb99 100644 (file)
@@ -8,8 +8,8 @@ def from32(str)
    str.tr("ybndrfg8ejkmcpqxot1uwisza345h769", "0123456789abcdefghijklmnopqrstuv").to_i(32)
 end
 
-def rr(qname, qtype, content, ttl, priority = 0, auth = 1)
-   {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl, :priority => priority, :auth => auth}
+def rr(qname, qtype, content, ttl, auth = 1)
+   {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl, :auth => auth}
 end
 
 def send_result(*params)
index 75a61d8d5ea9cb41ffdc08124f59ba7a3ffeec94..ba1ecab6230198c9315b7fdf087d0695fe26d986 100644 (file)
@@ -244,7 +244,6 @@ bool RemoteBackend::get(DNSResourceRecord &rr) {
    value = -1;
    rr.ttl = getInt(JSON_GET((*d_result)["result"][d_index], "ttl",value));
    rr.domain_id = getInt(JSON_GET((*d_result)["result"][d_index],"domain_id",value));
-   rr.priority = getInt(JSON_GET((*d_result)["result"][d_index],"priority",value));
    value = 1;
    if (d_dnssec) 
      rr.auth = getInt(JSON_GET((*d_result)["result"][d_index],"auth", value));
@@ -699,7 +698,6 @@ bool RemoteBackend::superMasterBackend(const string &ip, const string &domain, c
       JSON_ADD_MEMBER(rr, "qclass", QClass::IN, query.GetAllocator());
       JSON_ADD_MEMBER(rr, "content", nsset[i].content.c_str(), query.GetAllocator());
       JSON_ADD_MEMBER(rr, "ttl", nsset[i].ttl, query.GetAllocator());
-      JSON_ADD_MEMBER(rr, "priority", nsset[i].priority, query.GetAllocator());
       JSON_ADD_MEMBER(rr, "auth", nsset[i].auth, query.GetAllocator());
       rrset.PushBack(rr, query.GetAllocator());
    }
@@ -760,7 +758,6 @@ bool RemoteBackend::replaceRRSet(uint32_t domain_id, const string& qname, const
       JSON_ADD_MEMBER(rr, "qclass", QClass::IN, query.GetAllocator());
       JSON_ADD_MEMBER(rr, "content", rrset[i].content.c_str(), query.GetAllocator());
       JSON_ADD_MEMBER(rr, "ttl", rrset[i].ttl, query.GetAllocator());
-      JSON_ADD_MEMBER(rr, "priority", rrset[i].priority, query.GetAllocator());
       JSON_ADD_MEMBER(rr, "auth", rrset[i].auth, query.GetAllocator());
       rj_rrset.PushBack(rr, query.GetAllocator());
    }
@@ -785,7 +782,6 @@ bool RemoteBackend::feedRecord(const DNSResourceRecord &rr, string *ordername) {
    JSON_ADD_MEMBER(rj_rr, "qclass", QClass::IN, query.GetAllocator());
    JSON_ADD_MEMBER(rj_rr, "content", rr.content.c_str(), query.GetAllocator());
    JSON_ADD_MEMBER(rj_rr, "ttl", rr.ttl, query.GetAllocator());
-   JSON_ADD_MEMBER(rj_rr, "priority", rr.priority, query.GetAllocator());
    JSON_ADD_MEMBER(rj_rr, "auth", rr.auth, query.GetAllocator());
    parameters.AddMember("rr", rj_rr, query.GetAllocator());
 
index a5aac4425919bf359bbb526322b79b75e729f8e5..9bc29dd976c490c6a9191e5dc89124c248ceda37 100644 (file)
@@ -33,8 +33,8 @@ class Handler
    def initialize
    end
 
-   def rr(qname, qtype, content, ttl, priority = 0, auth = 1, domain_id = -1)
-      {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl.to_i, :priority => priority.to_i, :auth => auth.to_i, :domain_id => domain_id.to_i}
+   def rr(qname, qtype, content, ttl, auth = 1, domain_id = -1)
+      {:qname => qname, :qtype => qtype, :content => content, :ttl => ttl.to_i, :auth => auth.to_i, :domain_id => domain_id.to_i}
    end
 
    def do_initialize(*args)