open a server tunnel

host-cache/src/main/groovy/com/muwire/hostcache/HostCache.groovy

@@ -1,7 +1,11 @@
 package com.muwire.hostcache
 
 import net.i2p.client.I2PClientFactory
+import net.i2p.client.I2PSession
+import net.i2p.client.I2PSessionMuxedListener
+import net.i2p.client.datagram.I2PDatagramDissector
 import net.i2p.util.SystemVersion
+import net.i2p.data.*
 
 public class HostCache {
 
@@ -38,8 +42,47 @@ public class HostCache {
             println myDest.toBase64()
         } 
         
-        session = i2pClient.createSession(new FileInputStream(keyfile), System.getProperties())
+        def props = System.getProperties().clone()
+        props.putAt("inbound.nickname", "MuWire HostCache")
+        session = i2pClient.createSession(new FileInputStream(keyfile), props)
         myDest = session.getMyDestination()
+        
+        session.addMuxedSessionListener(new Listener(), 
+            I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY)
+        session.connect()
+        println "INFO: connected, going to sleep"
+        Thread.sleep(Integer.MAX_VALUE)
+        
+    }
+    
+    static class Listener implements I2PSessionMuxedListener {
+        void reportAbuse(I2PSession sesison, int severity) {}
+        void disconnected(I2PSession session) {
+            println "ERROR: session disconnected, exiting"
+            System.exit(1)
+        }
+        void errorOccurred(I2PSession session, String message, Throwable error) {
+            println "ERROR: ${message} ${error}"
+        }
+        void messageAvailable(I2PSession session, int msgId, long size, int proto,
+            int fromport, int toport) {
+            if (proto != I2PSession.PROTO_DATAGRAM) {
+                println "WARN: received unexpected protocol ${proto}"
+                return
+            }
+            
+            def payload = session.receiveMessage(msgId)
+            def dissector = new I2PDatagramDissector()
+            try {
+                dissector.loadI2PDatagram(payload)
+                def sender = dissector.getSender()
+                def query = dissector.getPayload()
+                println "INFO: from ${sender.toBase64()} received query ${query}"
+            } catch (DataFormatException dfe) {
+                println "WARN: invalid datagram ${dfe}"
+            }
+        }
+        void messageAvailable(I2PSession session, int msgId, long size) {
+        }
     }
-
 }