Remote: try to send the stories image-per-image

[fanfix.git] / src / be / nikiroo / fanfix / library / RemoteLibraryServer.java

diff --git a/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java b/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java
index 55c50c1b44e13fc7c682211529ac83d00098f018..2799a65a1923975f4695dd8d13bb1c33c0a91f1d 100644 (file)
--- a/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java
+++ b/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java
@@ -2,12 +2,16 @@ package be.nikiroo.fanfix.library;
 
 import java.io.IOException;
 import java.security.InvalidParameterException;
+import java.util.ArrayList;
 import java.util.List;
 
 import be.nikiroo.fanfix.Instance;
+import be.nikiroo.fanfix.data.Chapter;
 import be.nikiroo.fanfix.data.MetaData;
+import be.nikiroo.fanfix.data.Paragraph;
 import be.nikiroo.fanfix.data.Story;
 import be.nikiroo.utils.Version;
+import be.nikiroo.utils.serial.server.ConnectActionClientObject;
 import be.nikiroo.utils.serial.server.ConnectActionServerObject;
 import be.nikiroo.utils.serial.server.ServerObject;
 
@@ -24,7 +28,8 @@ import be.nikiroo.utils.serial.server.ServerObject;
  * library</li>
  * <li>[key] GET_STORY [luid]: will return the given story if it exists (or NULL
  * if not)</li>
- * <li>[key] SAVE_STORY [story] [luid]: save the story with the given LUID</li>
+ * <li>[key] SAVE_STORY [luid]: save the story (that must be sent just after the
+ * command) with the given LUID</li>
  * <li>[key] DELETE_STORY [luid]: delete the story of LUID luid</li>
  * <li>[key] GET_COVER [luid]: return the cover of the story</li>
  * <li>[key] GET_SOURCE_COVER [source]: return the cover for this source</li>
@@ -95,9 +100,11 @@ public class RemoteLibraryServer extends ServerObject {
                        throw new InvalidParameterException(
                                        "only * is valid here, but you passed: " + args[0]);
                } else if ("GET_STORY".equals(command)) {
-                       return Instance.getLibrary().getStory("" + args[0], null);
+                       Story story = Instance.getLibrary().getStory("" + args[0], null);
+                       sendStory(story, action);
                } else if ("SAVE_STORY".equals(command)) {
-                       Instance.getLibrary().save((Story) args[0], "" + args[1], null);
+                       Story story = recStory(action);
+                       Instance.getLibrary().save(story, "" + args[1], null);
                } else if ("DELETE_STORY".equals(command)) {
                        Instance.getLibrary().delete("" + args[0]);
                } else if ("GET_COVER".equals(command)) {
@@ -112,4 +119,84 @@ public class RemoteLibraryServer extends ServerObject {
 
                return null;
        }
+
+       public static void sendStory(Story story, Object sender)
+                       throws NoSuchFieldException, NoSuchMethodException,
+                       ClassNotFoundException, IOException {
+
+               if (!story.getMeta().isImageDocument()) {
+                       sendNextObject(sender, story);
+                       return;
+               }
+
+               story = story.clone();
+
+               List<Chapter> chaps = story.getChapters();
+               story.setChapters(new ArrayList<Chapter>());
+               sendNextObject(sender, story);
+
+               for (Chapter chap : chaps) {
+                       List<Paragraph> paras = chap.getParagraphs();
+                       chap.setParagraphs(new ArrayList<Paragraph>());
+                       sendNextObject(sender, chap);
+
+                       for (Paragraph para : paras) {
+                               sendNextObject(sender, para);
+                       }
+               }
+       }
+
+       public static Story recStory(Object source) throws NoSuchFieldException,
+                       NoSuchMethodException, ClassNotFoundException, IOException {
+
+               Story story = null;
+
+               Object obj = getNextObject(source);
+               if (obj instanceof Story) {
+                       story = (Story) obj;
+
+                       Chapter current = null;
+                       for (obj = getNextObject(source); obj != null; obj = getNextObject(source)) {
+                               if (obj instanceof Chapter) {
+                                       current = (Chapter) obj;
+                                       story.getChapters().add(current);
+                               } else if (obj instanceof Paragraph) {
+                                       current.getParagraphs().add((Paragraph) obj);
+                               }
+                       }
+               }
+
+               return story;
+       }
+
+       private static Object getNextObject(Object clientOrServer)
+                       throws NoSuchFieldException, NoSuchMethodException,
+                       ClassNotFoundException, IOException {
+               if (clientOrServer instanceof ConnectActionClientObject) {
+                       ConnectActionClientObject client = (ConnectActionClientObject) clientOrServer;
+                       return client.send(null);
+               } else if (clientOrServer instanceof ConnectActionServerObject) {
+                       ConnectActionServerObject server = (ConnectActionServerObject) clientOrServer;
+                       Object obj = server.rec();
+                       server.send(null);
+                       return obj;
+               } else {
+                       throw new ClassNotFoundException();
+               }
+       }
+
+       private static void sendNextObject(Object clientOrServer, Object obj)
+                       throws NoSuchFieldException, NoSuchMethodException,
+                       ClassNotFoundException, IOException {
+               if (clientOrServer instanceof ConnectActionClientObject) {
+                       ConnectActionClientObject client = (ConnectActionClientObject) clientOrServer;
+                       client.send(obj);
+               } else if (clientOrServer instanceof ConnectActionServerObject) {
+                       ConnectActionServerObject server = (ConnectActionServerObject) clientOrServer;
+                       server.send(obj);
+                       server.rec();
+               } else {
+                       throw new ClassNotFoundException();
+               }
+       }
 }