UploaderTask.java

package ProdDatabase;
import java.util.regex.*;
import java.io.*;
public class UploaderTask {
    private int lengthOfTask;
    private int current = 0;
    private boolean done = false;
    private boolean cancelled = false;
    private String statMessage;
    private String command;
    private boolean quitOnFinish;
    Pattern aPattern = Pattern.compile(".*\\d{14}\\.jassm.*");
    private boolean isAssemblyUpload;

    public UploaderTask(int noOfModules, String cmd, boolean quitOnFinish) {
        lengthOfTask = noOfModules;
        command = cmd;
        this.quitOnFinish = quitOnFinish;
        isAssemblyUpload = aPattern.matcher(cmd).matches();
    }

    public void go() {
        final guiUtilities.SwingWorker worker = new guiUtilities.SwingWorker() {
            public Object construct() {
                current = 0;
                done = false;
                cancelled = false;
                statMessage = null;
                return new ActualTask();
            }
        };
        worker.start();
    }

    public int getLengthOfTask() {
        return lengthOfTask;
    }

    public int getCurrent() {
        return current;
    }

    public void stop() {
        cancelled = true;
        statMessage = null;
    }

    public boolean isDone() {
        return done;
    }

    public String getMessage() {
        return statMessage;
    }

    class ActualTask {
        Pattern d14Pattern = Pattern.compile(".*(\\d{14}).*");
        Pattern assemblyPattern = Pattern.compile("^Item assembled.*");
        ActualTask() {
          Process p = null;
           try {

                String OS = System.getProperty("os.name").toLowerCase();
                if (OS.indexOf("linux") >= 0) {
                    String [] cmds = {"/bin/sh","-c",command};
                   p = Runtime.getRuntime().exec( cmds );
                } else {
                   p = Runtime.getRuntime().exec( command );
                }

//              p.waitFor();

                BufferedReader in = new BufferedReader( new InputStreamReader( p.getInputStream() ) );

                String t = in.readLine();
                if(t!=null) System.out.println(t);

                while( !cancelled && t!=null && current<lengthOfTask )
                   {
                        t = in.readLine();
                        if(t!=null) {
                          System.out.println(t);
                          Matcher matcher = d14Pattern.matcher(t);
                          if(matcher.matches()) statMessage = t.substring(matcher.start(1),matcher.end(1));
                          matcher = assemblyPattern.matcher(t);
                          if(t.indexOf("DB transaction commited.")!=-1 || matcher.matches()) current++;
                          }
                    }
                in.close();
                if(cancelled && p!=null) p.destroy();
                done=true;

                } catch(Exception rcException) {System.out.println("SctGUI::UploaderTask error "+rcException.toString()); done=true;}
       int total = isAssemblyUpload ? lengthOfTask-1 : lengthOfTask;
       int ncurrent = current;
       if(isAssemblyUpload) {
         if(ncurrent==lengthOfTask) ncurrent--;
         }
       String info = isAssemblyUpload ? Integer.toString(ncurrent)+" items out of "+Integer.toString(total) : Integer.toString(ncurrent)+" tests out of "+Integer.toString(total);
       if(cancelled) {
           String msg = "Uploader Task Cancelled!\nYou had uploaded "+info;
           javax.swing.JOptionPane.showMessageDialog(null,msg);
           }
       else {
           String msg = "Uploader Task Completed.\nYou had uploaded "+info;
           if(current<lengthOfTask) msg+="\nOne or more uploads FAILED. Please check the log files in your upload directory.";
           javax.swing.JOptionPane.showMessageDialog(null,msg);
           }
       if(quitOnFinish) System.exit(0);
       }
    }
}

---