Application: gvSIG desktop

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 *

 * This program 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, or (at your option) any later version.

 *

 * This program 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 this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 */

package org.gvsig.mkmvnproject;

import java.awt.BorderLayout;

import java.awt.Color;

import java.awt.Dimension;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PipedInputStream;

import java.io.PipedOutputStream;

import java.io.PrintStream;

import javax.swing.JPanel;

import javax.swing.JScrollPane;

import javax.swing.JTextArea;

import javax.swing.SwingUtilities;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * A panel which shows the execution log messages of the create plugin process.

 * 

 * @author gvSIG Team

 * @version $Id$

 */

public class CreatePluginConsolePanel extends JPanel {

	private static final long serialVersionUID = -7213048219847956909L;

	private static final Logger LOG = LoggerFactory

			.getLogger(CreatePluginConsolePanel.class);

	private JTextArea console;

	private PrintStream printStream;

	private PipedOutputStream pipedos;

	private PipedInputStream pipedis;

	private Thread consoleThread;

	/**

	 * Constructor.

	 * 

	 * @throws IOException

	 *             if there is an error creating the console streams

	 */

	public CreatePluginConsolePanel() throws IOException {

		super();

		initialize();

	}

	/**

	 * Constructor.

	 * 

	 * @param isDoubleBuffered

	 *            if the panel must be double buffered.

	 * @throws IOException

	 *             if there is an error creating the console streams

	 */

	public CreatePluginConsolePanel(boolean isDoubleBuffered)

			throws IOException {

		super(isDoubleBuffered);

		initialize();

	}

	/**

	 * Initializes the panel GUI.

	 * 

	 * @throws IOException

	 */

	private void initialize() throws IOException {

		Dimension dimension = new Dimension(600, 200);

		setSize(dimension);

		setLayout(new BorderLayout());

		console = new JTextArea();

		console.setEditable(false);

		// console.setColumns(20);

		// console.setRows(5);

		console.setBackground(Color.WHITE);

		console.setLineWrap(true);

		console.setWrapStyleWord(true);

		JScrollPane consoleScrollPane = new JScrollPane(console);

		add(consoleScrollPane, BorderLayout.CENTER);

		pipedis = new PipedInputStream();

		pipedos = new PipedOutputStream(pipedis);

		printStream = new PrintStream(pipedos);

		consoleThread = new ConsoleThread(pipedis, console);

		consoleThread.start();

	}

	/**

	 * Returns a {@link PrintStream} which allows to write messages to the

	 * console.

	 * 

	 * @return a {@link PrintStream} which allows to write messages to the

	 *         console

	 */

	public PrintStream getPrintStream() {

		return printStream;

	}

	/**

	 * Returns a {@link PrintStream} which allows to write error messages to the

	 * console.

	 * 

	 * @return a {@link PrintStream} which allows to write error messages to the

	 *         console

	 */

	public PrintStream getErrorPrintStream() {

		return getPrintStream();

	}

	/**

	 * Closes the console. Once this method is called, any more calls to the

	 * console {@link PrintStream} will throw an exception.

	 */

	public void closeConsole() {

		printStream.flush();

		printStream.close();

		try {

			pipedos.close();

			pipedis.close();

			// Wait for the thread to finish

			consoleThread.join(500);

		} catch (IOException e) {

			LOG.warn("Error closing the internal piped streams", e);

		} catch (InterruptedException e) {

			// Nothing special to do

			LOG.debug("Console thread interrupted while waiting to finish", e);

		}

	}

	private static final class ConsoleThread extends Thread {

		private final PipedInputStream pipedis;

		private final JTextArea console;

		/**

		 * Constructor.

		 */

		public ConsoleThread(PipedInputStream pipedis, JTextArea console) {

			super("Create plugin console update thread");

			setDaemon(true);

			this.pipedis = pipedis;

			this.console = console;

		}

		@Override

		public void run() {

			try {

				BufferedReader reader = new BufferedReader(

						new InputStreamReader(pipedis));

				String line;

				while ((line = reader.readLine()) != null) {

					SwingUtilities.invokeLater(new ConsoleUpdateRunnable(

							console, line));

				}

				LOG.debug("Console input stream end, finish reading");

				reader.close();

			} catch (IOException e) {

				LOG.error("Error reading from the console string", e);

			}

		}

	}

	/**

	 * Runnable used to update the console text field.

	 * 

	 * @author gvSIG Team

	 * @version $Id$

	 */

	private static final class ConsoleUpdateRunnable implements Runnable {

		private final String newLine;

		private final JTextArea console;

		/**

		 * Constructor.

		 */

		public ConsoleUpdateRunnable(JTextArea console, String newLine) {

			this.console = console;

			this.newLine = newLine;

		}

		public void run() {

			console.append(newLine);

			console.append("\n");

		}

	}

}

import java.io.IOException;

import org.gvsig.andami.PluginServices;

import org.gvsig.andami.messages.NotificationManager;

import org.gvsig.andami.plugins.Extension;

	private boolean enabled = true;

	private final Object lock = new Object();

		// TODO: add support to parallel executions in Andami??

		// Create messages console

		CreatePluginConsoleWindow console = null;

		try {

			console = new CreatePluginConsoleWindow();

			PluginServices.getMDIManager().addCentredWindow(console);

		} catch (IOException e) {

			NotificationManager.addWarning("Error creating the console", e);

		}

		try {

			// Disable extension so it can't be executed again.

			synchronized (lock) {

				enabled = false;

			}

			new CreatePluginThread(console).start();

		} finally {

			synchronized (lock) {

				// create plugin process finish. Enable extension.

				enabled = true;

			}

		}

	}

	/**

	 * Thread to launch the ant base plugin creation project.

	 * 

	 * @author gvSIG Team

	 * @version $Id$

	 */

	private static final class CreatePluginThread extends Thread {

		private final CreatePluginConsoleWindow console;

		/**

		 * Constructor.

		 * 

		 * @param console

		 */

		public CreatePluginThread(CreatePluginConsoleWindow console) {

			this.console = console;

			setName("Create plugin execution thread");

			setDaemon(true);

		}

		@Override

		public void run() {

			DefaultLogger log = new DefaultLogger();

			log.setMessageOutputLevel(Project.MSG_INFO);

			if (console != null) {

				log.setErrorPrintStream(console.getErrorPrintStream());

				log.setOutputPrintStream(console.getPrintStream());

			} else {

				LOG.warn("Console window not available, will use the default console for Ant");

				log.setErrorPrintStream(System.err);

				log.setOutputPrintStream(System.out);

			}

			ClassLoader loader = this.getClass().getClassLoader();

			URL build = loader.getResource("scripts/" + ANT_BUILD_FILE);

			File file = new File(build.getFile());

			final Project ant = new Project();

			ant.addBuildListener(log);

			ant.setUserProperty("ant.file", file.getAbsolutePath());

			ant.init();

			ProjectHelper.getProjectHelper().parse(ant, file);

			LOG.info("Starting ant task with the file {} and the target {}",

					file, ANT_TARGET);

			ant.executeTarget(ANT_TARGET);

		}

		return enabled;

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 *

 * This program 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, or (at your option) any later version.

 *

 * This program 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 this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 */

package org.gvsig.mkmvnproject;

import java.awt.Dimension;

import java.io.IOException;

import org.gvsig.andami.ui.mdiManager.IWindow;

import org.gvsig.andami.ui.mdiManager.IWindowListener;

import org.gvsig.andami.ui.mdiManager.WindowInfo;

/**

 * A gvSIG window which shows the execution log messages of the create plugin

 * process.

 * 

 * @author gvSIG Team

 * @version $Id$

 */

public class CreatePluginConsoleWindow extends CreatePluginConsolePanel

		implements IWindow, IWindowListener {

	private static final long serialVersionUID = -5589080107545290284L;

	private WindowInfo info;

	private Object profile = WindowInfo.EDITOR_PROFILE;

	/**

	 * Constructor.

	 * 

	 * @throws IOException

	 *             if there is an error creating the console streams

	 */

	public CreatePluginConsoleWindow() throws IOException {

		super();

		initializeWindow();

	}

	/**

	 * Constructor.

	 * 

	 * @param isDoubleBuffered

	 *            if the panel must be double buffered.

	 * @throws IOException

	 *             if there is an error creating the console streams

	 */

	public CreatePluginConsoleWindow(boolean isDoubleBuffered) throws IOException {

		super(isDoubleBuffered);

		initializeWindow();

	}

	/**

	 * Initializes the window.

	 */

	private void initializeWindow() {

		Dimension dimension = new Dimension(600, 300);

		setSize(dimension);

		int code = WindowInfo.ICONIFIABLE | WindowInfo.MAXIMIZABLE

				| WindowInfo.RESIZABLE | WindowInfo.MODELESSDIALOG;

		profile = WindowInfo.EDITOR_PROFILE;

		info = new WindowInfo(code);

		info.setTitle("Console");

		info.setMinimumSize(dimension);

	}

	public WindowInfo getWindowInfo() {

		return info;

	}

	public Object getWindowProfile() {

		return profile;

	}

	public void windowActivated() {

		// Nothing to do

	}

	public void windowClosed() {

		super.closeConsole();

	}

}