start work on sharing of trust lists

core/src/main/groovy/com/muwire/core/Core.groovy

@@ -42,6 +42,8 @@ import com.muwire.core.search.SearchManager
 import com.muwire.core.search.UIResultBatchEvent
 import com.muwire.core.trust.TrustEvent
 import com.muwire.core.trust.TrustService
+import com.muwire.core.trust.TrustSubscriber
+import com.muwire.core.trust.TrustSubscriptionEvent
 import com.muwire.core.update.UpdateClient
 import com.muwire.core.upload.UploadManager
 import com.muwire.core.util.MuWireLogManager
@@ -74,6 +76,7 @@ public class Core {
     final MuWireSettings muOptions
     
     private final TrustService trustService
+    private final TrustSubscriber trustSubscriber
     private final PersisterService persisterService
     private final HostCache hostCache
     private final ConnectionManager connectionManager
@@ -280,6 +283,11 @@ public class Core {
         log.info("initializing hasher service")
         hasherService = new HasherService(new FileHasher(), eventBus, fileManager)
         eventBus.register(FileSharedEvent.class, hasherService)
+        
+        log.info("initializing trust subscriber")
+        trustSubscriber = new TrustSubscriber(eventBus, i2pConnector, props)
+        eventBus.register(UILoadedEvent.class, trustSubscriber)
+        eventBus.register(TrustSubscriptionEvent.class, trustSubscriber)
 	}
     
     public void startServices() {
@@ -300,6 +308,8 @@ public class Core {
             log.info("already shutting down")
             return
         }
+        log.info("shutting down trust subscriber")
+        trustSubscriber.stop()
         log.info("shutting down download manageer")
         downloadManager.shutdown()
         log.info("shutting down connection acceeptor")

core/src/main/groovy/com/muwire/core/trust/TrustSubscriber.groovy

@@ -1,14 +1,21 @@
 package com.muwire.core.trust
 
+import java.nio.charset.StandardCharsets
 import java.util.concurrent.ConcurrentHashMap
+import java.util.logging.Level
 
 import com.muwire.core.EventBus
 import com.muwire.core.MuWireSettings
+import com.muwire.core.Persona
 import com.muwire.core.UILoadedEvent
+import com.muwire.core.connection.Endpoint
 import com.muwire.core.connection.I2PConnector
+import com.muwire.core.util.DataUtil
 
+import groovy.util.logging.Log
 import net.i2p.data.Destination
 
+@Log
 class TrustSubscriber {
     private final EventBus eventBus
     private final I2PConnector i2pConnector
@@ -62,6 +69,7 @@ class TrustSubscriber {
                     if (now - trustList.timestamp < settings.trustListInterval * 60 * 60 * 1000)
                         return
                     check(trustList, now)
+                    eventBus.publish(new TrustSubscriptionUpdatedEvent(trustList : trustList))
                 }
             }
         } catch (InterruptedException e) {
@@ -71,6 +79,53 @@ class TrustSubscriber {
     }
     
     private void check(RemoteTrustList trustList, long now) {
-        // TODO: fetch trustlist and update timestamp
+        log.info("fetching trust list from ${trustList.persona.getHumanReadableName()}")
+        Endpoint endpoint = null
+        try {
+            endpoint = i2pConnector.connect(trustList.persona.destination)
+            OutputStream os = endpoint.getOutputStream()
+            InputStream is = endpoint.getInputStream()
+            os.write("TRUST\r\n\r\n".getBytes(StandardCharsets.US_ASCII))
+            os.flush()
+            
+            String codeString = DataUtil.readTillRN(is)
+            int space = codeString.indexOf(' ')
+            if (space > 0)
+                codeString = codeString.substring(0,space)
+            int code = Integer.parseInt(codeString.trim())
+            
+            if (code != 200) {
+                log.info("couldn't fetch trust list, code $code")
+                return
+            }
+            
+            DataInputStream dis = new DataInputStream(is)
+            
+            Set<Persona> good = new HashSet<>()
+            int nGood = dis.readUnsignedShort()
+            for (int i = 0; i < nGood; i++) {
+                Persona p = new Persona(dis)
+                good.add(p)
+            }
+            
+            Set<Persona> bad = new HashSet<>()
+            int nBad = dis.readUnsignedShort()
+            for (int i = 0; i < nBad; i++) {
+                Persona p = new Persona(dis)
+                bad.add(p)
+            }
+            
+            trustList.timestamp = now
+            trustList.good.clear()
+            trustList.good.addAll(good)
+            trustList.bad.clear()
+            trustList.bad.addAll(bad)
+            
+        } catch (Exception e) {
+            log.log(Level.WARNING,"exception fetching trust list from ${trustList.persona.getHumanReadableName()}",e)
+        } finally {
+            endpoint?.close()
+        }
+        
     }
 }

core/src/main/groovy/com/muwire/core/trust/TrustSubscriptionUpdatedEvent.groovy

@@ -3,4 +3,5 @@ package com.muwire.core.trust
 import com.muwire.core.Event
 
 class TrustSubscriptionUpdatedEvent extends Event {
+    RemoteTrustList trustList
 }