X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fde%2Ftodesbaum%2Fjsite%2Fapplication%2FProjectInserter.java;h=e52587da411bb201069cfb8f1b9b831c99d3050f;hb=75d17b6fd76177a09cb2cc02b2cbdaa119e97514;hp=756e121c67273cb84bac35ecbb4c710ab7091f85;hpb=ed54585ba9537da09379df378e51216e9ae528c1;p=jSite.git diff --git a/src/de/todesbaum/jsite/application/ProjectInserter.java b/src/de/todesbaum/jsite/application/ProjectInserter.java index 756e121..e52587d 100644 --- a/src/de/todesbaum/jsite/application/ProjectInserter.java +++ b/src/de/todesbaum/jsite/application/ProjectInserter.java @@ -53,6 +53,7 @@ import de.todesbaum.util.freenet.fcp2.Verbosity; import de.todesbaum.util.io.Closer; import de.todesbaum.util.io.ReplacingOutputStream; import de.todesbaum.util.io.StreamCopier; +import de.todesbaum.util.io.StreamCopier.ProgressListener; /** * Manages project inserts. @@ -94,6 +95,9 @@ public class ProjectInserter implements FileScannerListener, Runnable { /** Whether the insert is cancelled. */ private volatile boolean cancelled = false; + /** Progress listener for payload transfers. */ + private ProgressListener progressListener; + /** * Adds a listener to the list of registered listeners. * @@ -221,9 +225,13 @@ public class ProjectInserter implements FileScannerListener, Runnable { /** * Starts the insert. + * + * @param progressListener + * Listener to notify on progress events */ - public void start() { + public void start(ProgressListener progressListener) { cancelled = false; + this.progressListener = progressListener; fileScanner = new FileScanner(project); fileScanner.addFileScannerListener(this); new Thread(fileScanner).start(); @@ -429,7 +437,7 @@ public class ProjectInserter implements FileScannerListener, Runnable { } } String indexFile = project.getIndexFile(); - boolean hasIndexFile = (indexFile != null); + boolean hasIndexFile = (indexFile != null) && (indexFile.length() > 0); if (hasIndexFile && !project.getFileOption(indexFile).getContainer().equals("")) { checkReport.addIssue("warning.container-index", false); } @@ -439,7 +447,7 @@ public class ProjectInserter implements FileScannerListener, Runnable { } Map fileOptions = project.getFileOptions(); Set> fileOptionEntries = fileOptions.entrySet(); - boolean insert = false; + boolean insert = fileOptionEntries.isEmpty(); for (Entry fileOptionEntry : fileOptionEntries) { String fileName = fileOptionEntry.getKey(); FileOption fileOption = fileOptionEntry.getValue(); @@ -529,7 +537,8 @@ public class ProjectInserter implements FileScannerListener, Runnable { /* start request */ try { - client.execute(putDir); + client.execute(putDir, progressListener); + fireProjectUploadFinished(); } catch (IOException ioe1) { fireProjectInsertFinished(false, ioe1); return; @@ -537,17 +546,12 @@ public class ProjectInserter implements FileScannerListener, Runnable { /* parse progress and success messages */ String finalURI = null; - boolean firstMessage = true; boolean success = false; boolean finished = false; boolean disconnected = false; while (!finished && !cancelled) { Message message = client.readMessage(); finished = (message == null) || (disconnected = client.isDisconnected()); - if (firstMessage) { - fireProjectUploadFinished(); - firstMessage = false; - } logger.log(Level.FINE, "Received message: " + message); if (!finished) { @SuppressWarnings("null")