online credential exchange worked in a very first test

Author: thsc42

src/net/sharksystem/asap/ASAPChunkFS.java

@@ -60,8 +60,8 @@ public List<CharSequence> getDeliveredTo() {
         return this.deliveredTo;
     }
 
-    ASAPChunkFS(ASAPChunkStorageFS storage, String targetUri, int era) throws IOException {
-        this(storage, targetUri, era, null);
+    ASAPChunkFS(ASAPChunkStorageFS storage, String uri, int era) throws IOException {
+        this(storage, uri, era, null);
     }
 
     ASAPChunkFS(ASAPChunkStorageFS storage, String targetUri, int era, String sender) throws IOException {

src/net/sharksystem/asap/ASAPChunkStorage.java

@@ -34,4 +34,6 @@ public interface ASAPChunkStorage {
      * @throws IOException 
      */
     public ASAPMessages getASAPChunkCache(CharSequence uri, int toEra) throws IOException;
+
+    public ASAPMessages getASAPChunkCache(CharSequence uri, int fromEra, int toEra) throws IOException;
 }

src/net/sharksystem/asap/ASAPChunkStorageFS.java

@@ -134,9 +134,15 @@ public ASAPMessages getASAPChunkCache(CharSequence uri, int toEra) throws IOExce
             fromEra = ASAPEngine.previousEra(fromEra);
         }
 
+        return this.getASAPChunkCache(uri, fromEra, toEra);
+    }
+
+    @Override
+    public ASAPMessages getASAPChunkCache(CharSequence uri, int fromEra, int toEra) throws IOException {
         Log.writeLog(this, "create ASAPInMemoMessages");
 
-        return new ASAPInMemoMessages(this,
+        return new ASAPInMemoMessages(
+                this,
                 this.getFormat(),
                 uri,
                 fromEra, // set starting era

src/net/sharksystem/asap/ASAPEngineFS.java

@@ -1,6 +1,8 @@
 package net.sharksystem.asap;
 
+import net.sharksystem.Utils;
 import net.sharksystem.asap.protocol.ASAP_1_0;
+import net.sharksystem.asap.util.Log;
 
 import java.io.File;
 import java.io.IOException;

src/net/sharksystem/asap/ASAPInMemoMessages.java

@@ -41,9 +41,9 @@ public ASAPInMemoMessages(ASAPChunkStorageFS chunkStorage,
         this.toEra = toEra;
         this.maxCacheLen = maxCacheLen;
 
-        Log.writeLog(this, "format: " + format + "uri: " + uri
-                + "rootDir: " + chunkStorage.getRootDirectory()
-                + "fromEra: " + fromEra+ "toEra: " + toEra+ "maxCacheLen: " + maxCacheLen);
+        Log.writeLog(this, "format: " + format + " | uri: " + uri
+                + " | rootDir: " + chunkStorage.getRootDirectory()
+                + " | fromEra: " + fromEra+ " | toEra: " + toEra);
     }
 
     public ASAPInMemoMessages(ASAPChunkStorageFS chunkStorage,

src/net/sharksystem/asap/util/Log.java

@@ -2,8 +2,12 @@
 
 public class Log {
     public static StringBuilder startLog(Object o) {
+        return Log.startLog(o.getClass());
+    }
+
+    public static StringBuilder startLog(Class c) {
         StringBuilder sb = new StringBuilder();
-        sb.append(o.getClass().getSimpleName());
+        sb.append(c.getSimpleName());
         sb.append(": ");
         return sb;
     }
@@ -12,7 +16,15 @@ public static void writeLog(Object o, String message) {
         System.out.println(Log.startLog(o) +": " + message);
     }
 
+    public static void writeLog(Class c, String message) {
+        System.out.println(Log.startLog(c) +": " + message);
+    }
+
     public static void writeLogErr(Object o, String message) {
         System.err.println(Log.startLog(o) +": " + message);
     }
+
+    public static void writeLogErr(Class c, String message) {
+        System.err.println(Log.startLog(c) +": " + message);
+    }
 }