working on bug fix (only first era is routed). Problem identified. Working on a stable solution - no workaround.

Author: thsc42

src/main/java/net/sharksystem/asap/ASAPStorage.java

@@ -26,6 +26,24 @@ public interface ASAPStorage {
      */
     ASAPStorage getExistingIncomingStorage(CharSequence sender) throws IOException, ASAPException;
 
+    /**
+     * Get storage - parameter decides if to create a non-existing storage
+     * @param sender
+     * @param create
+     * @return
+     * @throws IOException
+     * @throws ASAPException
+     */
+    ASAPStorage getIncomingStorage(CharSequence sender, boolean create) throws IOException, ASAPException;
+
+    /**
+     * Get storage - create of required
+     * @param sender
+     * @return
+     * @throws IOException
+     * @throws ASAPException
+     */
+    ASAPStorage getIncomingStorage(CharSequence sender) throws IOException, ASAPException;
     /**
      *
      * @return storage format / app

src/main/java/net/sharksystem/asap/engine/ASAPEngine.java

@@ -394,11 +394,9 @@ public void handleASAPAssimilate(ASAP_AssimilationPDU_1_0 asapAssimilationPDU, A
         //>>>>>>>>>>>>>>>>>>>debug
 
         // get received storage
-        /*
-        ASAPStorage incomingStorage = this.getExistingIncomingStorage(senderE2E);
+        ASAPStorage incomingStorage = this.getIncomingStorage(senderE2E, true);
         ASAPChunkStorage incomingChunkStorage = incomingStorage.getChunkStorage();
-         */
-        ASAPChunkStorage incomingChunkStorage = this.getReceivedChunksStorage(senderE2E);
+        //ASAPChunkStorage incomingChunkStorage = this.getReceivedChunksStorage(senderE2E);
         Log.writeLog(this, this.toString(), "got incoming chunk storage for senderE2E: " + senderE2E);
 
         boolean changed = false;

src/main/java/net/sharksystem/asap/engine/ASAPEngineFS.java

@@ -105,22 +105,31 @@ private void saveMemento() throws IOException {
         this.getMemento(this.rootDirectory).save(this);
     }
 
-    /**
-     *
-     * @param owner can be null - restored
-     * @param rootDirectory must not be null
-     * @param format can be null - restored
-     * @return
-     * @throws IOException
-     * @throws ASAPException
-     */
     static ASAPEngineFS getASAPEngineFS(String owner, String rootDirectory, CharSequence format)
             throws IOException, ASAPException {
+        return ASAPEngineFS.getASAPEngineFS(owner, rootDirectory, format, false);
+    }
+
+        /**
+         *
+         * @param owner can be null - restored
+         * @param rootDirectory must not be null
+         * @param format can be null - restored
+         * @return
+         * @throws IOException
+         * @throws ASAPException
+         */
+    static ASAPEngineFS getASAPEngineFS(String owner, String rootDirectory, CharSequence format, boolean createFolder)
+            throws IOException, ASAPException {
 
         // root directory must exist when setting up an engine
         File root = new File(rootDirectory);
         if(!root.exists() || !root.isDirectory()) {
-            throw new ASAPException("chunk root directory must exist when creating an ASAPEngine: " + rootDirectory);
+            if(!createFolder) {
+                throw new ASAPException("chunk root directory must exist when creating an ASAPEngine: " + rootDirectory);
+            } else {
+                root.mkdirs();
+            }
         }
 
         if(format == null || format.toString().equalsIgnoreCase(ASAP_1_0.ANY_FORMAT)) {
@@ -221,11 +230,16 @@ public ASAPChunkStorage getReceivedChunksStorage(CharSequence sender) {
         return new ASAPChunkStorageFS(dir, this.format, this.era);
     }
 
-    public ASAPInternalStorage getExistingIncomingStorage(CharSequence sender) throws IOException, ASAPException {
+    public ASAPInternalStorage getIncomingStorage(CharSequence sender, boolean create) throws IOException, ASAPException {
         return ASAPEngineFS.getASAPEngineFS(
                 sender.toString(), // becomes owner
                 this.rootDirectory + "/" + sender, // folder
-                this.getFormat()); // format taken from superior storage
+                this.getFormat(), // format taken from superior storage
+                create);
+    }
+
+    public ASAPInternalStorage getExistingIncomingStorage(CharSequence sender) throws IOException, ASAPException {
+        return this.getIncomingStorage(sender, true);
     }
 
     /**
@@ -236,6 +250,8 @@ public ASAPInternalStorage getExistingIncomingStorage(CharSequence sender) throw
      * @throws ASAPException
      */
     public ASAPInternalStorage getIncomingStorage(CharSequence sender) throws IOException, ASAPException {
+        return this.getIncomingStorage(sender, true);
+        /*
         String folderName = this.rootDirectory + "/" + sender;
         File folder = new File(folderName);
         if(!folder.exists()) {
@@ -246,6 +262,7 @@ public ASAPInternalStorage getIncomingStorage(CharSequence sender) throws IOExce
                 sender.toString(), // becomes owner
                 folderName, // folder
                 this.getFormat()); // format taken from superior storage
+         */
     }
 
     @Override