X-Git-Url: https://code.wpia.club/?p=gigi.git;a=blobdiff_plain;f=src%2Forg%2Fcacert%2Fgigi%2Fping%2FDNSPinger.java;h=eb6327b3f9a2968cd98332091b01bdbdf3a49d56;hp=3dc9ac60a8b51d23e915f28997cf02c1a416e2e7;hb=d7be034f96e06985f57d86d2779c434276b5bd4d;hpb=50c8c66dc1d3245e8eaedf17e273f8c0522f1435

diff --git a/src/org/cacert/gigi/ping/DNSPinger.java b/src/org/cacert/gigi/ping/DNSPinger.java
index 3dc9ac60..eb6327b3 100644
--- a/src/org/cacert/gigi/ping/DNSPinger.java
+++ b/src/org/cacert/gigi/ping/DNSPinger.java
@@ -1,69 +1,58 @@
 package org.cacert.gigi.ping;
 
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
 import java.util.Arrays;
-import java.util.LinkedList;
+import java.util.List;
+
+import javax.naming.NamingException;
+
+import org.cacert.gigi.dbObjects.CertificateOwner;
+import org.cacert.gigi.dbObjects.Domain;
+import org.cacert.gigi.util.DNSUtil;
 
 public class DNSPinger extends DomainPinger {
 
     @Override
-    public String ping(String domain, String expToken) {
+    public void ping(Domain domain, String expToken, CertificateOwner u, int confId) {
+        String[] tokenParts = expToken.split(":", 2);
+        List<String> nameservers;
         try {
-            String[] tokenParts = expToken.split(":", 2);
-
-            Process p = Runtime.getRuntime().exec(new String[] {
-                    "dig", "+short", "NS", domain
-            });
-            BufferedReader br = new BufferedReader(new InputStreamReader(p.getInputStream()));
-            String line;
-            LinkedList<String> nameservers = new LinkedList<String>();
-            while ((line = br.readLine()) != null) {
-                nameservers.add(line);
-            }
-            p.destroy();
-            StringBuffer result = new StringBuffer();
-            result.append("failed: ");
-            boolean failed = nameservers.isEmpty();
-            nameservers:
-            for (String NS : nameservers) {
-                String[] call = new String[] {
-                        "dig", "@" + NS, "+short", "TXT", "cacert-" + tokenParts[0] + "." + domain
-                };
-                System.out.println(Arrays.toString(call));
-                p = Runtime.getRuntime().exec(call);
-                br = new BufferedReader(new InputStreamReader(p.getInputStream()));
-                String token = null;
-                boolean found = false;
-                while ((line = br.readLine()) != null) {
-                    if (line.isEmpty()) {
+            nameservers = Arrays.asList(DNSUtil.getNSNames(domain.getSuffix()));
+        } catch (NamingException e) {
+            enterPingResult(confId, "error", "No authorative nameserver found.", null);
+            return;
+        }
+        StringBuffer result = new StringBuffer();
+        result.append("failed: ");
+        boolean failed = nameservers.isEmpty();
+        nameservers:
+        for (String NS : nameservers) {
+            boolean found = false;
+            try {
+                for (String token : DNSUtil.getTXTEntries(tokenParts[0] + "._cacert._auth." + domain.getSuffix(), NS)) {
+                    if (token.isEmpty()) {
                         continue;
                     }
                     found = true;
-                    token = line.substring(1, line.length() - 1);
                     if (token.equals(tokenParts[1])) {
                         continue nameservers;
                     }
                 }
-                p.destroy();
-                result.append(NS);
-                if (found) {
-                    result.append(" DIFFER;");
-                } else {
-                    result.append(" EMPTY;");
-                }
-                failed = true;
-
+            } catch (NamingException e) {
+                found = false;
             }
-            if ( !failed) {
-                return PING_SUCCEDED;
+            result.append(NS);
+            if (found) {
+                result.append(" DIFFER;");
+            } else {
+                result.append(" EMPTY;");
             }
-            return result.toString();
-        } catch (IOException e) {
-            e.printStackTrace();
-            return "Connection closed";
+            failed = true;
+
+        }
+        if ( !failed) {
+            enterPingResult(confId, PING_SUCCEDED, "", null);
+        } else {
+            enterPingResult(confId, "error", result.toString(), null);
         }
     }
-
 }