/*
    *  Copyright 2006 the GLXDesktop Project Team, all rights reserved.
    *  
    *  This file is part of GLXDesktop Project.
    *  GLXDesktop Project is free software; you can redistribute it and/or modify
    *  it under the terms of the GNU General Public License as published by
    *  the Free Software Foundation; either version 2 of the License.
    *  3ddesktop-configurator is distributed in the hope that it will be useful,
    *  but WITHOUT ANY WARRANTY; without even the implied warranty of
   *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   *  GNU General Public License for more details.
   *  You should have received a copy of the GNU General Public License
   *  along with GLXDesktop Project; if not, write to the Free Software
   *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
   */
  
  package net.sf.glxdesktop.gui.runcmd;
  
  import java.io.BufferedReader;
  import java.io.IOException;
  import java.io.InputStream;
  import java.io.InputStreamReader;
  
  import net.sf.glxdesktop.gui.Messages;
  import net.sf.glxdesktop.gui.glade.LoadGladeException;
  
  import org.gnu.glib.CustomEvents;
  import org.gnu.glib.Fireable;
  import org.gnu.glib.Timer;
  import org.gnu.gtk.TextBuffer;
  import org.gnu.gtk.event.ButtonEvent;
  import org.gnu.gtk.event.ButtonListener;
  import org.gnu.gtk.event.LifeCycleEvent;
  import org.gnu.gtk.event.LifeCycleListener;
  
  /***
   * This class open a progress Gtk window and execute a system command, 
   * The window retrive informations like command inputStream and errorInputStream.
   *  
   * @author Alphonse Van Assche
   * 
   */
  public abstract class RunCmdProgressImpl extends RunCmdProgress implements
  		Fireable {
  
  	private Timer timer = null;
  
  	private static final String DEFAULT_TITLE = Messages
  			.getString("RunCmdProgressImpl.default_title"); //$NON-NLS-1$
  
  	private static final String DEFAULT_MESSAGE = Messages
  			.getString("RunCmdProgressImpl.default_message"); //$NON-NLS-1$
  
  	private boolean canClose = false;
  
  	private String inputLines;
  
  	private String errorLines;
  
  	final String command;
  
  	public abstract void process();
  
  	public RunCmdProgressImpl(String commandToRun, String title, String message) {
  		command = commandToRun;
  		try {
  			initialize();
  		} catch (LoadGladeException e) {
  			System.err
  					.println(Messages
  							.getString("RunCmdProgressImpl.load_glade_exeception_message") + e.getMessage()); //$NON-NLS-1$
  			System.exit(1);
  		}
  		window.setTitle(title);
  		labelMessage.setText(message);
  		progressBar.setText(command);
  		setListeners();
  	}
  
  	public RunCmdProgressImpl(String commandToRun) {
  		this(commandToRun, DEFAULT_TITLE, DEFAULT_MESSAGE);
  	}
  
  	public void execute() {
  		timer = new Timer(100, this);
  		timer.start();
  		Runnable run = new Runnable() {
  			public void run() {
  				try {
  
  					Process child = Runtime.getRuntime().exec(command);
  					InputStream errorIs = child.getErrorStream();
  					InputStreamReader errorIsReader = new InputStreamReader(
  							errorIs);
  					BufferedReader errorReader = new BufferedReader(
  							errorIsReader);
  					InputStream inputIs = child.getInputStream();
  					InputStreamReader inputIsReader = new InputStreamReader(
  							inputIs);
 					BufferedReader inputReader = new BufferedReader(
 							inputIsReader);
 					String errorLine;
 					errorLines = ""; //$NON-NLS-1$
 					while ((errorLine = errorReader.readLine()) != null) {
 						errorLines += errorLine + "\n"; //$NON-NLS-1$
 					}
 					String inputLine;
 					inputLines = ""; //$NON-NLS-1$
 					while ((inputLine = inputReader.readLine()) != null) {
 						inputLines += inputLine + "\n"; //$NON-NLS-1$
 					}
 					final String inputTxt = inputLines;
 					final String errorTxt = errorLines;
 					Runnable runnable = new Runnable() {
 						public void run() {
 							canClose = true;
 							timer.stop();
 							progressBar.setFraction(100.0);
 							if (!errorTxt.trim().equals("")) { //$NON-NLS-1$
 								textViewCmdError
 										.setBuffer(setTextBuffer(errorTxt));
 								expanderCmdError.show();
 								expanderCmdError.setExpanded(true);
 								progressBar
 										.setText(Messages
 												.getString("RunCmdProgressImpl.progressbar_error_msg") + command); //$NON-NLS-1$
 							} else {
 								closeWindow();
 							}
 							if (!inputTxt.trim().equals("")) { //$NON-NLS-1$
 								textViewCmdOutput
 										.setBuffer(setTextBuffer(inputTxt));
 								expanderCmdOutput.show();
 							}
 							process();
 						}
 					};
 					CustomEvents.addEvent(runnable);
 				} catch (IOException e) {
 					e.printStackTrace();
 				}
 			}
 		};
 		Thread thread = new Thread(run);
 		thread.start();
 	}
 
 	public String getInputString() {
 		return inputLines;
 	}
 
 	public String getErrorString() {
 		return errorLines;
 	}
 
 	private void setListeners() {
 
 		window.addListener(new LifeCycleListener() {
 			public void lifeCycleEvent(LifeCycleEvent event) {
 			}
 
 			public boolean lifeCycleQuery(LifeCycleEvent event) {
 				if (event.isOfType(LifeCycleEvent.Type.DESTROY)
 						|| event.isOfType(LifeCycleEvent.Type.DELETE)) {
 					closeWindow();
 				}
 				return true;
 			}
 		});
 
 		buttonClose.addListener(new ButtonListener() {
 			public void buttonEvent(ButtonEvent event) {
 				if (event.isOfType(ButtonEvent.Type.CLICK)) {
 					closeWindow();
 				}
 			}
 		});
 
 	}
 
 	private void closeWindow() {
 		if (canClose) {
 			window.destroy();
 		} else {
 			window.iconify();
 		}
 	}
 
 	private TextBuffer setTextBuffer(String txt) {
 		TextBuffer buffer = new TextBuffer();
 		buffer.setText(txt);
 		return buffer;
 	}
 
 	public boolean fire() {
 		double percent = progressBar.getFraction();
 		if (percent >= .99)
 			percent = 0.0;
 		else {
 			percent += 0.05;
 			if (percent >= 1.0)
 				percent = .999;
 		}
 		progressBar.setFraction(percent);
 		return true;
 	}
 }