Changeset 706 for trunk

Timestamp:

08/30/12 13:29:50 (12 years ago)

Author:

sherbold

Message:

• removed class ReplayGenerator? and moved its functionality to the command generateReplayfile.
• removed command generateRandomReplay. It was redundant with the combination of of generateReplayfile and generateRandomSequences

Location:

trunk

Files:

• quest-plugin-mfc-test/src/test/java/de/ugoe/cs/quest/plugin/mfc/MFCLogParserTest.java (modified) (2 diffs)
• quest-ui-core/src/main/java/de/ugoe/cs/quest/ReplayGenerator.java (deleted)
• quest-ui-core/src/main/java/de/ugoe/cs/quest/ui/commands/CMDgenerateRandomReplay.java (deleted)
• quest-ui-core/src/main/java/de/ugoe/cs/quest/ui/commands/CMDgenerateReplayfile.java (modified) (3 diffs)

trunk/quest-plugin-mfc-test/src/test/java/de/ugoe/cs/quest/plugin/mfc/MFCLogParserTest.java

@@ -18 +18 @@
 import org.junit.Test;
 
-import de.ugoe.cs.quest.ReplayGenerator;
 import de.ugoe.cs.quest.eventcore.Event;
 import de.ugoe.cs.quest.eventcore.guimodel.GUIModel;
+import de.ugoe.cs.util.console.CommandExecuter;
 import de.ugoe.cs.util.console.Console;
+import de.ugoe.cs.util.console.GlobalDataContainer;
 import de.ugoe.cs.util.console.listener.IOutputListener;
 
@@ -137 +138 @@
         guiModel.dump(System.err);
 
-        ReplayGenerator generator = new ReplayGenerator();
-        generator.createLogfileMultipleSessions(parser.getSequences(), tmpFile.getAbsolutePath());
+        
+        GlobalDataContainer.getInstance().addData("seqs",  parser.getSequences());
+        
+        CommandExecuter.getInstance().exec("generateReplayfile " + tmpFile.getAbsolutePath() + " seqs");
         
         InputStreamReader reader1 = 

trunk/quest-ui-core/src/main/java/de/ugoe/cs/quest/ui/commands/CMDgenerateReplayfile.java

@@ -1 +1 @@
 package de.ugoe.cs.quest.ui.commands;
 
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStreamWriter;
 import java.security.InvalidParameterException;
 import java.util.Collection;
 import java.util.List;
+import java.util.logging.Level;
 
 import de.ugoe.cs.quest.CommandHelpers;
-import de.ugoe.cs.quest.ReplayGenerator;
+import de.ugoe.cs.quest.IReplayDecorator;
 import de.ugoe.cs.quest.SequenceInstanceOf;
 import de.ugoe.cs.quest.eventcore.Event;
+import de.ugoe.cs.quest.eventcore.IReplayable;
+import de.ugoe.cs.util.StringTools;
 import de.ugoe.cs.util.console.Command;
+import de.ugoe.cs.util.console.Console;
 import de.ugoe.cs.util.console.GlobalDataContainer;
 
@@ -16 +24 @@
  * Command to create a replay file from stored sessions.
  * </p>
+ * 
+ * TODO: Add appropriate checks if Events are replayable
  * 
  * @author Steffen Herbold
@@ -63 +73 @@
 
                 sequences = (Collection<List<Event>>) dataObject;
-                ReplayGenerator generator = new ReplayGenerator();
-                generator.createLogfileMultipleSessions(sequences, filename);
+                createLogfileMultipleSessions(sequences, filename);
         }
+        
+            /**
+             * <p>
+             * {@link IReplayDecorator} to be used. If this field is {@code null}, no decorator is used.
+             * Default: {@code null}
+             * </p>
+             */
+            private IReplayDecorator decorator = null;
 
+            /**
+             * <p>
+             * Id of the current session. The starting id is 1.
+             * </p>
+             */
+            int sessionId = 1;
+
+            /**
+             * <p>
+             * Creates a replay file that contains multiple event sequences.
+             * </p>
+             * 
+             * @param sequences
+             *            collection of event sequences from which the sessions are generated
+             * @param filename
+             *            name and path of the replay file
+             */
+            private void createLogfileMultipleSessions(Collection<List<Event>> sequences, String filename) {
+                OutputStreamWriter writer = openReplayFile(filename);
+                if (writer != null) {
+                    try {
+                        try {
+                            decorator =
+                                sequences.iterator().next().get(0).getReplayables().get(0).getDecorator();
+                        }
+                        catch (Exception e) {
+                            // in the above line, many things can go wrong: emtpy sequences, null
+                            // references, etc. However, all failures just indicate that no replay decorator
+                            // should be used, hence, we ignore the exception
+                        }
+                        if (decorator != null) {
+                            writer.write(decorator.getHeader());
+                        }
+                        for (List<Event> actions : sequences) {
+                            writeSession(actions, writer);
+                        }
+                        if (decorator != null) {
+                            writer.write(decorator.getFooter());
+                        }
+                        decorator = null;
+                        writer.close();
+                    }
+                    catch (IOException e) {
+                        Console.printerrln("Unable to write replay file " + filename);
+                    }
+                }
+            }
+
+            /**
+             * <p>
+             * Helper function that opens the replay file for writing.
+             * </p>
+             * 
+             * @param filename
+             *            name and path of the replay file
+             * @return {@link OutputStreamWriter} that writes to the replay file
+             */
+            private OutputStreamWriter openReplayFile(String filename) {
+                File file = new File(filename);
+                boolean fileCreated;
+                try {
+                    fileCreated = file.createNewFile();
+                    if (!fileCreated) {
+                        Console.traceln(Level.INFO, "Created logfile " + filename);
+                    }
+                    else {
+                        Console.traceln(Level.INFO, "Overwrote existing logfile " + filename);
+                    }
+                }
+                catch (IOException e) {
+                    Console.printerrln("Unable to create file " + filename);
+                    Console.logException(e);
+                }
+                OutputStreamWriter writer = null;
+                try {
+                    writer = new OutputStreamWriter(new FileOutputStream(file), "UTF-16");
+                }
+                catch (IOException e) {
+                    Console.printerrln("Unable to open file for writing (read-only file):" + filename);
+                    Console.logException(e);
+                }
+                return writer;
+            }
+
+            /**
+             * <p>
+             * Helper function that adds an event sequence to the replay.
+             * </p>
+             * 
+             * @param actions
+             *            event sequences to be added
+             * @param writer
+             *            {@link OutputStreamWriter} to which the replay is added
+             * @throws IOException
+             *             thrown if there is a problem writing to writer
+             */
+            private void writeSession(List<Event> actions, OutputStreamWriter writer) throws IOException {
+                if (decorator != null) {
+                    writer.write(decorator.getSessionHeader(sessionId));
+                }
+                for (Event currentAction : actions) {
+
+                    List<? extends IReplayable> replayables = currentAction.getReplayables();
+                    for (IReplayable replayble : replayables) {
+                        writer.write(replayble.getReplay() + StringTools.ENDLINE);
+                        writer.flush();
+                    }
+                }
+                if (decorator != null) {
+                    writer.write(decorator.getSessionFooter(sessionId));
+                }
+                sessionId++;
+            }
 }