Fixed UI exceptions caused by modifications to the UI outside the event thread.

src/main/java/com/rarchives/ripme/ripper/AbstractRipper.java

@@ -1,5 +1,7 @@
 package com.rarchives.ripme.ripper;
 
+import com.rarchives.ripme.ui.MainWindow;
+import com.rarchives.ripme.ui.RipStatusHandler;
 import java.io.File;
 import java.io.IOException;
 import java.lang.reflect.Constructor;
@@ -17,6 +19,7 @@ import org.apache.log4j.Logger;
 import com.rarchives.ripme.ui.RipStatusMessage;
 import com.rarchives.ripme.ui.RipStatusMessage.STATUS;
 import com.rarchives.ripme.utils.Utils;
+import java.util.Collections;
 
 public abstract class AbstractRipper 
                 extends Observable
@@ -30,11 +33,11 @@ public abstract class AbstractRipper
     protected URL url;
     protected File workingDir;
     protected DownloadThreadPool threadPool;
-    protected Observer observer = null;
+    protected RipStatusHandler observer = null;
 
-    protected Map<URL, File> itemsPending = new HashMap<URL, File>();
+    protected Map<URL, File> itemsPending = Collections.synchronizedMap(new HashMap<URL, File>());
-    protected Map<URL, File> itemsCompleted = new HashMap<URL, File>();
+    protected Map<URL, File> itemsCompleted = Collections.synchronizedMap(new HashMap<URL, File>());
-    protected Map<URL, String> itemsErrored = new HashMap<URL, String>();
+    protected Map<URL, String> itemsErrored = Collections.synchronizedMap(new HashMap<URL, String>());
     protected boolean completed = true;
 
     public abstract void rip() throws IOException;
@@ -59,7 +62,7 @@ public abstract class AbstractRipper
         this.threadPool = new DownloadThreadPool();
     }
 
-    public void setObserver(Observer obs) {
+    public void setObserver(RipStatusHandler obs) {
         this.observer = obs;
     }
 
@@ -162,7 +165,6 @@ public abstract class AbstractRipper
     public void retrievingSource(URL url) {
         RipStatusMessage msg = new RipStatusMessage(STATUS.LOADING_RESOURCE, url);
         observer.update(this,  msg);
-        observer.notifyAll();
     }
 
     /**
@@ -179,13 +181,11 @@ public abstract class AbstractRipper
         try {
             String path = Utils.removeCWD(saveAs);
             RipStatusMessage msg = new RipStatusMessage(STATUS.DOWNLOAD_COMPLETE, path);
-            synchronized(observer) {
             itemsPending.remove(url);
             itemsCompleted.put(url, saveAs);
             observer.update(this, msg);
-                observer.notifyAll();
+
             checkIfComplete();
-            }
         } catch (Exception e) {
             logger.error("Exception while updating observer: ", e);
         }
@@ -200,14 +200,12 @@ public abstract class AbstractRipper
         if (observer == null) {
             return;
         }
-        synchronized(observer) {
         itemsPending.remove(url);
         itemsErrored.put(url, reason);
         observer.update(this, new RipStatusMessage(STATUS.DOWNLOAD_ERRORED, url + " : " + reason));
-            observer.notifyAll();
+
         checkIfComplete();
     }
-    }
 
     /**
      * Notify observers that a download could not be completed,
@@ -219,12 +217,12 @@ public abstract class AbstractRipper
         if (observer == null) {
             return;
         }
-        synchronized(observer) {
+        
         itemsPending.remove(url);
         itemsErrored.put(url, message);
         observer.update(this, new RipStatusMessage(STATUS.DOWNLOAD_WARN, url + " : " + message));
-            observer.notifyAll();
+            
-        }
+        
         checkIfComplete();
     }
 
@@ -235,16 +233,13 @@ public abstract class AbstractRipper
         if (observer == null) {
             return;
         }
-        synchronized (observer) {
+        
-            if (!completed && itemsPending.size() == 0) {
+        if (!completed && itemsPending.isEmpty()) {
             completed = true;
             logger.info("   Rip completed!");
-                observer.update(this,
+            
-                        new RipStatusMessage(
+            RipStatusMessage msg = new RipStatusMessage(STATUS.RIP_COMPLETE, workingDir);
-                                STATUS.RIP_COMPLETE,
+            observer.update(this, msg);
-                                workingDir));
-                observer.notifyAll();
-            }
         }
     }
 
@@ -325,10 +320,7 @@ public abstract class AbstractRipper
         if (observer == null) {
             return;
         }
-        synchronized (observer) {
         observer.update(this, new RipStatusMessage(status, message));
-            observer.notifyAll();
-        }
     }
     
     /**

src/main/java/com/rarchives/ripme/ui/MainWindow.java

@@ -46,7 +46,7 @@ import com.rarchives.ripme.utils.Utils;
 /**
  * Everything UI-related starts and ends here.
  */
-public class MainWindow implements Runnable {
+public class MainWindow implements Runnable, RipStatusHandler {
 
     private static final Logger logger = Logger.getLogger(MainWindow.class);
     
@@ -101,7 +101,7 @@ public class MainWindow implements Runnable {
         mainFrame.setVisible(true);
     }
 
-    public static void status(String text) {
+    public synchronized static void status(String text) {
         statusLabel.setText(text);
         mainFrame.pack();
     }
@@ -276,24 +276,14 @@ public class MainWindow implements Runnable {
     }
     
     private void appendLog(final String text, final Color color) {
-            try {
-                SwingUtilities.invokeAndWait(new Runnable() {
-                    @Override
-                    public void run() {
         SimpleAttributeSet sas = new SimpleAttributeSet();
         StyleConstants.setForeground(sas, color);
         StyledDocument sd = logText.getStyledDocument();
         try {
             sd.insertString(sd.getLength(), text + "\n", sas);
         } catch (BadLocationException e) { }
-                        logText.setCaretPosition(logText.getText().length());
+
-                    }
+        logText.setCaretPosition(sd.getLength());
-                });
-            } catch (InterruptedException e) {
-                e.printStackTrace();
-            } catch (InvocationTargetException e) {
-                e.printStackTrace();
-            }
     }
     
     private void loadHistory() {
@@ -359,7 +349,7 @@ public class MainWindow implements Runnable {
         try {
             AbstractRipper ripper = AbstractRipper.getRipper(url);
             ripTextfield.setText(ripper.getURL().toExternalForm());
-            ripper.setObserver(new RipStatusHandler());
+            ripper.setObserver((RipStatusHandler) this);
             Thread t = new Thread(ripper);
             t.start();
             return t;
@@ -376,13 +366,26 @@ public class MainWindow implements Runnable {
         }
     }
     
-    class RipStatusHandler implements Observer {
+    private class StatusEvent implements Runnable {
-        public void update(Observable observable, Object object) {
+        private final AbstractRipper ripper;
-            RipStatusMessage msg = (RipStatusMessage) object;
+        private final RipStatusMessage msg;
 
-            int completedPercent = ((AbstractRipper) observable).getCompletionPercentage();
+        public StatusEvent(AbstractRipper ripper, RipStatusMessage msg) {
+            this.ripper = ripper;
+            this.msg = msg;
+        }
+
+        public void run() {
+            handleEvent(this);
+        }
+    }
+    
+    private void handleEvent(StatusEvent evt) {
+        RipStatusMessage msg = evt.msg;
+
+        int completedPercent = evt.ripper.getCompletionPercentage();
         statusProgress.setValue(completedPercent);
-            status( ((AbstractRipper)observable).getStatusText() );
+        status( evt.ripper.getStatusText() );
 
         switch(msg.getStatus()) {
         case LOADING_RESOURCE:
@@ -428,11 +431,17 @@ public class MainWindow implements Runnable {
             mainFrame.pack();
         }
     }
+
+    public void update(AbstractRipper ripper, RipStatusMessage message) {
+        StatusEvent event = new StatusEvent(ripper, message);
+        SwingUtilities.invokeLater(event);
     }
     
     /** Simple TextPane that allows horizontal scrolling. */
     class JTextPaneNoWrap extends JTextPane {
         private static final long serialVersionUID = 1L;
+        
+        @Override
         public boolean getScrollableTracksViewportWidth() {
             return false;
         }

src/main/java/com/rarchives/ripme/ui/RipStatusHandler.java

@@ -0,0 +1,14 @@
+
+package com.rarchives.ripme.ui;
+
+import com.rarchives.ripme.ripper.AbstractRipper;
+
+/**
+ *
+ * @author Mads
+ */
+public interface RipStatusHandler {
+
+    public void update(AbstractRipper ripper, RipStatusMessage message);
+
+}