Refactor build configuration and improve error handling

src/main/java/org/quetoo/installer/Console.java

@@ -88,8 +88,8 @@ private void onSync(final File file) {
    * @param throwable The error.
    */
   private void onError(final Throwable throwable) {
+    System.err.println("Error: " + throwable.getMessage());
     throwable.printStackTrace(System.err);
-    System.exit(1);
   }
 
   /**

src/main/java/org/quetoo/installer/Main.java

@@ -1,10 +1,13 @@
 package org.quetoo.installer;
 
+import io.reactivex.exceptions.UndeliverableException;
+import io.reactivex.plugins.RxJavaPlugins;
 import org.apache.commons.cli.*;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.SystemUtils;
 
 import java.io.IOException;
+import java.net.SocketException;
 import java.nio.file.Files;
 import java.util.Properties;
 
@@ -24,6 +27,19 @@ public class Main {
    */
   public static void main(String[] args) {
 
+    RxJavaPlugins.setErrorHandler(e -> {
+      if (e instanceof UndeliverableException) {
+        e = e.getCause();
+      }
+      if (e instanceof InterruptedException
+          || e instanceof IOException
+          || e instanceof SocketException) {
+        return;
+      }
+      Thread.currentThread().getUncaughtExceptionHandler()
+          .uncaughtException(Thread.currentThread(), e);
+    });
+
     final var build = Option.builder("b")
         .longOpt("build")
         .hasArg()

src/main/java/org/quetoo/installer/Manager.java

@@ -70,7 +70,7 @@ public Observable<Delta> delta(final Observable<Index> indices) {
    * @return An Observable yielding the synchronized files.
    */
   public Observable<File> sync(final Observable<Delta> deltas) {
-    return deltas.flatMap(delta -> delta.getIndex().getSync().sync(delta))
+    return deltas.concatMap(delta -> delta.getIndex().getSync().sync(delta))
         .doOnNext(file -> {
           if (file.getParentFile().equals(config.getBin())) {
             file.setExecutable(true);

src/main/java/org/quetoo/installer/aws/S3Sync.java

@@ -65,15 +65,15 @@ private <T> T executeHttpRequest(final String path, final Map<String, String> pa
         .append("https://")
         .append(bucketName)
         .append(".s3.amazonaws.com/")
-        .append(path.replace("+", "%2B"));
+        .append(path.replace("+", "%2B").replace(" ", "%20"));
 
     if (!params.isEmpty()) {
       url.append("?");
       params.forEach((k, v) -> {
         if (url.charAt(url.length() - 1) != '?') {
           url.append("&");
         }
-        url.append(k).append("=").append(v.replace("+", "%2B"));
+        url.append(k).append("=").append(v.replace("+", "%2B").replace(" ", "%20"));
       });
     }
 
@@ -200,7 +200,11 @@ public Observable<File> sync(final Delta delta) {
     return Observable.fromIterable(delta)
         .map(asset -> (S3Object) asset)
         .flatMap(obj -> Observable.fromCallable(() -> sync(obj))
-            .subscribeOn(Schedulers.io()), 8);
+            .subscribeOn(Schedulers.io())
+            .onErrorResumeNext(e -> {
+              System.err.println("Failed to sync " + obj.getKey() + ": " + e.getMessage());
+              return Observable.empty();
+            }), 8);
   }
 
   @Override