- missing GNS classes

8 files changed, 471 insertions, 0 deletions

diff --git a/src/main/java/org/gnunet/gns/Gns.java b/src/main/java/org/gnunet/gns/Gns.java
new file mode 100644
index 0000000..3175be0
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/Gns.java
@@ -0,0 +1,137 @@
+/*
+ This file is part of GNUnet.
+  (C) 2012, 2013 Christian Grothoff (and other contributing authors)
+
+  GNUnet is free software; you can redistribute it and/or modify
+  it under the terms of the GNU General Public License as published
+  by the Free Software Foundation; either version 3, or (at your
+  option) any later version.
+
+  GNUnet is distributed in the hope that it will be useful, but
+  WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+  General Public License for more details.
+
+  You should have received a copy of the GNU General Public License
+  along with GNUnet; see the file COPYING.  If not, write to the
+  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+  Boston, MA 02111-1307, USA.
+ */
+
+package org.gnunet.gns;
+
+import org.gnunet.gns.callbacks.LookupResultProcessor;
+import org.gnunet.gns.messages.ClientLookupMessage;
+import org.gnunet.gns.messages.ClientLookupResultMessage;
+import org.gnunet.requests.MatchingRequestContainer;
+import org.gnunet.requests.SimpleRequest;
+import org.gnunet.util.*;
+import org.gnunet.util.crypto.EcdsaPrivateKey;
+import org.gnunet.util.crypto.EcdsaPublicKey;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * API to the GNUnet name system.
+ */
+public class Gns {
+    private static final Logger logger = LoggerFactory
+            .getLogger(Gns.class);
+    /**
+     * All pending and active lookup requests.
+     */
+    private MatchingRequestContainer<Long, SimpleRequest<LookupResultProcessor>> lookupRequests;
+
+    /**
+     * Request ID for lookup requests.
+     */
+    private long nextUID = 1;
+
+    /**
+     * Client connected to the GNS service.
+     */
+    private Client client;
+
+    private RelativeTime reconnectBackoff = RelativeTime.STD_BACKOFF;
+
+
+    public class GNSMessageReceiver extends RunaboutMessageReceiver {
+        public void visit(ClientLookupResultMessage m) {
+            SimpleRequest<LookupResultProcessor> r = lookupRequests.pollRequest(m.id);
+            if (null == r) {
+                logger.warn("no matching request for lookup result");
+                return;
+            }
+            r.getContext().process(m.records);
+        }
+
+        @Override
+        public void handleError() {
+            logger.warn("Error receiving from GNS service, reconnecting.");
+            Scheduler.addDelayed(reconnectBackoff, new Scheduler.Task() {
+                @Override
+                public void run(Scheduler.RunContext ctx) {
+                    client.reconnect();
+                    // re-send active requests
+                    lookupRequests.restart();
+                }
+            });
+            reconnectBackoff = reconnectBackoff.backoff();
+        }
+    }
+
+    /**
+     * Connect to the GNS service
+     *
+     * @param cfg configuration to use
+     */
+    public Gns(Configuration cfg) {
+        client = new Client("gns", cfg);
+        lookupRequests = new MatchingRequestContainer<Long, SimpleRequest<LookupResultProcessor>>(client);
+        client.installReceiver(new GNSMessageReceiver());
+    }
+
+    /**
+     * Perform an asynchronous lookup operation on the GNS.
+     *
+     * @param name the name to look up
+     * @param zone zone to look in
+     * @param type the GNS record type to look for
+     * @param onlyCached true to only check locally (not in the DHT)
+     * @param shortenZoneKey the private key of the shorten zone (can be NULL);
+     *                    specify to enable automatic shortening (given a PSEU
+     *                    record, if a given pseudonym is not yet used in the
+     *                    shorten zone, we automatically add the respective zone
+     *                    under that name)
+     * @param proc function to call on result
+     * @return handle to the queued request
+     */
+    public Cancelable lookup(String name,
+                             EcdsaPublicKey zone,
+                             long type, boolean onlyCached,
+                             EcdsaPrivateKey shortenZoneKey,
+                             LookupResultProcessor proc) {
+        ClientLookupMessage m = new ClientLookupMessage();
+
+        if (null != shortenZoneKey) {
+            m.haveKey = 1;
+            m.shortenKey = shortenZoneKey;
+        } else {
+            m.haveKey = 0;
+            m.shortenKey = EcdsaPrivateKey.zeroKey();
+        }
+        m.id = nextUID++;
+        m.name = name;
+        m.onlyCached = onlyCached ? 1 : 0;
+        m.type = type;
+        m.zone = zone;
+
+        return lookupRequests.addRequest(m.id, new SimpleRequest<LookupResultProcessor>(m, proc));
+    }
+
+
+    public void disconnect() {
+        client.disconnect();
+        client = null;
+    }
+}
diff --git a/src/main/java/org/gnunet/gns/GnsTool.java b/src/main/java/org/gnunet/gns/GnsTool.java
new file mode 100644
index 0000000..81cd6d3
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/GnsTool.java
@@ -0,0 +1,81 @@
+package org.gnunet.gns;
+
+
+import org.gnunet.gns.callbacks.LookupResultProcessor;
+import org.gnunet.identity.Identity;
+import org.gnunet.identity.IdentityCallback;
+import org.gnunet.util.Program;
+import org.gnunet.util.getopt.Argument;
+import org.gnunet.util.getopt.ArgumentAction;
+
+public class GnsTool {
+    public static void main(String[] args) {
+        int ret = new Program(args) {
+            @Argument(
+                    shortname = "u",
+                    longname = "lookup",
+                    action = ArgumentAction.STORE_STRING,
+                    description = "Lookup a record for the given name")
+            String name;
+
+            @Argument(
+                    shortname = "z",
+                    longname = "zone",
+                    action = ArgumentAction.STORE_STRING,
+                    description = "Lookup a record in the given zone")
+            String zone = "master-zone";
+
+            @Argument(
+                    shortname = "t",
+                    longname = "type",
+                    action = ArgumentAction.STORE_STRING,
+                    description = "Lookup a record of the given type (defaut: A)")
+            String type = "A";
+
+            @Override
+            protected void run() {
+                if (null == name) {
+                    System.err.println("no name given");
+                    setReturnValue(1);
+                    return;
+                }
+
+                final long typeId = GnsRecord.getIdFromString(type);
+                if (typeId < 0) {
+                    System.err.println(String.format("type '%s' not known", type));
+                    setReturnValue(1);
+                    return;
+                }
+
+                System.out.println("looking for records of type id " + typeId);
+
+                Identity.lookup(getConfiguration(), zone, new IdentityCallback() {
+                    @Override
+                    public void onEgo(Identity.Ego ego) {
+                        System.out.println("looking in zone " + ego.getPublicKey());
+                        final Gns gns = new Gns(getConfiguration());
+                        gns.lookup(name, ego.getPublicKey(), typeId, false, null, new LookupResultProcessor() {
+                            @Override
+                            public void process(GnsRecord[] records) {
+                                System.out.println("got " + records.length + " records");
+                                gns.disconnect();
+                                for (GnsRecord record : records) {
+                                    String s = record.getRecordData().asRecordString();
+                                    System.out.println(
+                                            String.format("Type: %s, Value: %s", record.recordType, s));
+                                }
+                            }
+                        });
+                    }
+
+                    @Override
+                    public void onError(String errorMessage) {
+                        System.err.println("could not look up zone ego '" + name + "': " + errorMessage);
+                    }
+                });
+
+            }
+        }.start();
+        System.exit(ret);
+    }
+}
diff --git a/src/main/java/org/gnunet/gns/RecordFlags.java b/src/main/java/org/gnunet/gns/RecordFlags.java
new file mode 100644
index 0000000..58a9141
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/RecordFlags.java
@@ -0,0 +1,48 @@
+/*
+ This file is part of GNUnet.
+  (C) 2014 Christian Grothoff (and other contributing authors)
+
+  GNUnet is free software; you can redistribute it and/or modify
+  it under the terms of the GNU General Public License as published
+  by the Free Software Foundation; either version 3, or (at your
+  option) any later version.
+
+  GNUnet is distributed in the hope that it will be useful, but
+  WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+  General Public License for more details.
+
+  You should have received a copy of the GNU General Public License
+  along with GNUnet; see the file COPYING.  If not, write to the
+  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+  Boston, MA 02111-1307, USA.
+ */
+
+package org.gnunet.gns;
+
+
+public interface RecordFlags {
+    /**
+     * No special options.
+     */
+    public static final int NONE = 0;
+    /**
+     * No special options.
+     */
+    public static final int PRIVATE = 2;
+    /**
+     * This record was added automatically by the system
+     * and is pending user confimation.
+     */
+    public static final int PENDING = 4;
+    /**
+     * This expiration time of the record is a relative
+     * time (not an absolute time).
+     */
+    public static final int EXPIRATION = 8;
+    /**
+     * This record should not be used unless all (other) records with an absolute
+     * expiration time have expired.
+     */
+    public static final int SHADOW_RECORD = 16;
+}
diff --git a/src/main/java/org/gnunet/gns/callbacks/LookupResultProcessor.java b/src/main/java/org/gnunet/gns/callbacks/LookupResultProcessor.java
new file mode 100644
index 0000000..daa6d3e
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/callbacks/LookupResultProcessor.java
@@ -0,0 +1,35 @@
+/*
+ This file is part of GNUnet.
+  (C) 2012, 2013 Christian Grothoff (and other contributing authors)
+
+  GNUnet is free software; you can redistribute it and/or modify
+  it under the terms of the GNU General Public License as published
+  by the Free Software Foundation; either version 3, or (at your
+  option) any later version.
+
+  GNUnet is distributed in the hope that it will be useful, but
+  WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+  General Public License for more details.
+
+  You should have received a copy of the GNU General Public License
+  along with GNUnet; see the file COPYING.  If not, write to the
+  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+  Boston, MA 02111-1307, USA.
+ */
+
+package org.gnunet.gns.callbacks;
+
+import org.gnunet.gns.GnsRecord;
+
+/**
+ * Processor for GNS request results.
+ */
+public interface LookupResultProcessor {
+    /**
+     * Process an array of records.
+     *
+     * @param records Records to process.
+     */
+    void process(GnsRecord[] records);
+}
diff --git a/src/main/java/org/gnunet/gns/records/ARecordData.java b/src/main/java/org/gnunet/gns/records/ARecordData.java
new file mode 100644
index 0000000..1154a44
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/records/ARecordData.java
@@ -0,0 +1,68 @@
+/*
+ This file is part of GNUnet.
+  (C) 2012, 2013 Christian Grothoff (and other contributing authors)
+
+  GNUnet is free software; you can redistribute it and/or modify
+  it under the terms of the GNU General Public License as published
+  by the Free Software Foundation; either version 3, or (at your
+  option) any later version.
+
+  GNUnet is distributed in the hope that it will be useful, but
+  WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+  General Public License for more details.
+
+  You should have received a copy of the GNU General Public License
+  along with GNUnet; see the file COPYING.  If not, write to the
+  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+  Boston, MA 02111-1307, USA.
+ */
+
+package org.gnunet.gns.records;
+
+
+import com.google.common.net.InetAddresses;
+import org.gnunet.construct.FixedSizeIntegerArray;
+import org.gnunet.construct.UnionCase;
+
+import java.net.Inet4Address;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+/**
+ * A DNS A Record.
+ */
+@UnionCase(1)
+public class ARecordData implements RecordData {
+
+    @FixedSizeIntegerArray(length = 4, bitSize = 8, signed = false)
+    public byte[] addr;
+
+    @SuppressWarnings("UnusedDeclaration")
+    public static String recordTypeString = "A";
+
+    public static ARecordData fromString(String s) {
+        InetAddress addr = InetAddresses.forString(s);
+        byte[] addrBytes = addr.getAddress();
+        if (addrBytes.length != 4) {
+            return null;
+        }
+        ARecordData recordData = new ARecordData();
+        recordData.addr = addrBytes;
+        return recordData;
+    }
+
+    @Override
+    public String asRecordString() {
+        if (addr.length != 4) {
+            return null;
+        }
+        InetAddress inetAddress;
+        try {
+            inetAddress = Inet4Address.getByAddress(addr);
+        } catch (UnknownHostException e) {
+            return null;
+        }
+        return inetAddress.getHostAddress();
+    }
+}
diff --git a/src/main/java/org/gnunet/gns/records/PkeyRecordData.java b/src/main/java/org/gnunet/gns/records/PkeyRecordData.java
new file mode 100644
index 0000000..bdbe06e
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/records/PkeyRecordData.java
@@ -0,0 +1,33 @@
+package org.gnunet.gns.records;
+
+import org.gnunet.construct.NestedMessage;
+import org.gnunet.construct.UnionCase;
+import org.gnunet.util.crypto.EcdsaPublicKey;
+
+/**
+ * A GNS PKEY record.
+ */
+@UnionCase(65536)
+public class PkeyRecordData implements RecordData {
+
+    @NestedMessage
+    public EcdsaPublicKey publicKey;
+
+    @SuppressWarnings("UnusedDeclaration")
+    public static String recordTypeString = "PKEY";
+
+    public static PkeyRecordData fromString(String s) {
+        EcdsaPublicKey publicKey = EcdsaPublicKey.fromString(s);
+        if (null == publicKey) {
+            return null;
+        }
+        PkeyRecordData recordData = new PkeyRecordData();
+        recordData.publicKey = publicKey;
+        return recordData;
+    }
+
+    @Override
+    public String asRecordString() {
+        return publicKey.toString();
+    }
+}
diff --git a/src/main/java/org/gnunet/gns/records/RecordData.java b/src/main/java/org/gnunet/gns/records/RecordData.java
new file mode 100644
index 0000000..f8f317b
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/records/RecordData.java
@@ -0,0 +1,30 @@
+/*
+ This file is part of GNUnet.
+  (C) 2012, 2013 Christian Grothoff (and other contributing authors)
+
+  GNUnet is free software; you can redistribute it and/or modify
+  it under the terms of the GNU General Public License as published
+  by the Free Software Foundation; either version 3, or (at your
+  option) any later version.
+
+  GNUnet is distributed in the hope that it will be useful, but
+  WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+  General Public License for more details.
+
+  You should have received a copy of the GNU General Public License
+  along with GNUnet; see the file COPYING.  If not, write to the
+  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+  Boston, MA 02111-1307, USA.
+ */
+
+package org.gnunet.gns.records;
+
+import org.gnunet.construct.MessageUnion;
+
+/**
+ * Tag interface for message for GNS record data union members.
+ */
+public interface RecordData extends MessageUnion {
+    public String asRecordString();
+}
diff --git a/src/main/java/org/gnunet/gns/records/UnknownRecordData.java b/src/main/java/org/gnunet/gns/records/UnknownRecordData.java
new file mode 100644
index 0000000..c885458
--- /dev/null
+++ b/src/main/java/org/gnunet/gns/records/UnknownRecordData.java
@@ -0,0 +1,39 @@
+/*
+ This file is part of GNUnet.
+  (C) 2012, 2013 Christian Grothoff (and other contributing authors)
+
+  GNUnet is free software; you can redistribute it and/or modify
+  it under the terms of the GNU General Public License as published
+  by the Free Software Foundation; either version 3, or (at your
+  option) any later version.
+
+  GNUnet is distributed in the hope that it will be useful, but
+  WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+  General Public License for more details.
+
+  You should have received a copy of the GNU General Public License
+  along with GNUnet; see the file COPYING.  If not, write to the
+  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+  Boston, MA 02111-1307, USA.
+ */
+
+package org.gnunet.gns.records;
+
+
+import org.gnunet.construct.IntegerFill;
+
+public class UnknownRecordData implements RecordData {
+
+    @IntegerFill(signed = true, bitSize = 8)
+    public byte[] data;
+
+    public String toString() {
+        return "(unknown record)";
+    }
+
+    @Override
+    public String asRecordString() {
+        return "(unknown)";
+    }
+}