allow multiengine to setup new asapEngines

Author: thsc42

src/net/sharksystem/asap/MultiASAPEngineFS.java

@@ -20,18 +20,34 @@
  * That interface hides those different engines.
  */
 public interface MultiASAPEngineFS {
-    public static final long DEFAULT_MAX_PROCESSING_TIME = Long.MAX_VALUE;
+    long DEFAULT_MAX_PROCESSING_TIME = Long.MAX_VALUE;
 
-    public ASAPEngine getEngineByFormat(CharSequence format) throws ASAPException, IOException;
+    /**
+     * get an existing engine
+     * @param format
+     * @return
+     * @throws ASAPException engine does not exist
+     * @throws IOException
+     */
+    ASAPEngine getEngineByFormat(CharSequence format) throws ASAPException, IOException;
+
+    /**
+     * create an engine for a given format / application name
+     * @param format
+     * @return
+     * @throws ASAPException
+     * @throws IOException
+     */
+    ASAPEngine createEngineByFormat(CharSequence format) throws ASAPException, IOException;
 
     ASAPChunkReceivedListener getListenerByFormat(CharSequence format) throws ASAPException;
 
     /**
      * get or create engine for a given application - mainly means: setup folder
-     * @param appName
+     * @param format
      * @return
      */
-    ASAPEngine getASAPEngine(CharSequence appName, CharSequence format) throws IOException, ASAPException;
+    ASAPEngine getASAPEngine(CharSequence format) throws IOException, ASAPException;
 
     /**
      * handle that newly established connection to another ASAP peer

src/net/sharksystem/asap/MultiASAPEngineFS_Impl.java

@@ -140,6 +140,22 @@ public ASAPEngine getEngineByFormat(CharSequence format) throws ASAPException, I
         return asapEngine;
     }
 
+    @Override
+    public ASAPEngine createEngineByFormat(CharSequence format) throws ASAPException, IOException {
+        try {
+            return this.getEngineByFormat(format);
+        }
+        catch(ASAPException e) {
+            // does not exist yet
+        }
+
+        String folderName = this.getEngineFolderByAppName(format);
+        ASAPEngine asapEngine = this.getASAPEngine(format);
+        this.folderMap.put(format, new EngineSetting(folderName, listener));
+
+        return asapEngine;
+    }
+
     @Override
     public ASAPChunkReceivedListener getListenerByFormat(CharSequence format) throws ASAPException {
         EngineSetting engineSetting = this.folderMap.get(format);
@@ -148,11 +164,15 @@ public ASAPChunkReceivedListener getListenerByFormat(CharSequence format) throws
         return engineSetting.listener;
     }
 
+    private String getEngineFolderByAppName(CharSequence appName) {
+        return this.rootFolderName.toString() + "/" + appName;
+    }
+
     @Override
-    public ASAPEngine getASAPEngine(CharSequence appName, CharSequence format)
+    public ASAPEngine getASAPEngine(CharSequence format)
             throws IOException, ASAPException {
 
-        String foldername = this.rootFolderName.toString() + "/" + appName.toString();
+        String foldername = this.getEngineFolderByAppName(format);
         // already exists?
         try {
             ASAPEngine existingASAPEngineFS = ASAPEngineFS.getExistingASAPEngineFS(foldername);