import java.awt.*;
import java.awt.event.*;
import java.io.*;
import javax.swing.*;
import javax.swing.text.*;
public class Konsole extends JFrame implements WindowListener, ActionListener, Runnable {
private JTextPane textPane;
private StyledDocument textArea;
private Thread reader;
private boolean quit;
private final PipedInputStream pin = new PipedInputStream();
private SimpleAttributeSet red;
/** Default constructor of Konsole
* The goal of the game is to redirect the classical output for serr.
* To do so, we will use an independant thread.
*
* Creating the object and the window:
*/
public Konsole() {
setTitle("Java Konsole");
textPane = new JTextPane();
textArea = textPane.getStyledDocument();
red = new SimpleAttributeSet();
StyleConstants.setForeground(red, Color.red);
textPane.setEditable(false);
textPane.setFont(new Font("Monospaced", Font.PLAIN, 11));
JButton button = new JButton("Clear");
getContentPane().setLayout(new BorderLayout());
getContentPane().add(new JScrollPane(textPane), BorderLayout.CENTER);
getContentPane().add(button, BorderLayout.SOUTH);
this.addWindowListener(this);
button.addActionListener(this);
redirect();
setDefaultCloseOperation(HIDE_ON_CLOSE);
setSize(800, 600);
}
/**
* Redirection of the stream
*
*/
private void redirect() {
try {
PipedOutputStream pout = new PipedOutputStream(pin);
System.setErr(new PrintStream(pout, true));
} catch (java.io.IOException io) {
try {
textArea.insertString(textArea.getLength(), "Couldn't redirect STDERR to this konsole\n" + io.getMessage(), null);
} catch (BadLocationException exception) {
}
} catch (SecurityException se) {
try {
textArea.insertString(textArea.getLength(), "Couldn't redirect STDERR to this konsole\n" + se.getMessage(), null);
} catch (BadLocationException exception) {
}
}
quit = false; // signals the Thread that it should exit
// Starting thread to read from the PipedInputStream
//
reader = new Thread(this);
reader.setDaemon(true);
reader.start();
}
public synchronized void actionPerformed(ActionEvent evt) {
try {
textArea.remove(0, textArea.getLength());
} catch (BadLocationException exception) {
}
}
/**
* Running the threads
*/
public synchronized void run() {
try {
while (Thread.currentThread() == reader) {
try {
this.wait(100);
} catch (InterruptedException ie) {
}
if (pin.available() != 0) {
String input = this.readLine(pin);
textArea.insertString(textArea.getLength(), input, red);
if (!isVisible()) {
setVisible(true);
}
}
if (quit) {
return;
}
}
} catch (Exception e) {
try {
textArea.insertString(textArea.getLength(), "\nKonsole reports an Internal error.", null);
textArea.insertString(textArea.getLength(), "The error is: " + e, null);
} catch (BadLocationException exception) {
}
}
}
/**
* Reading standard output
*/
protected synchronized String readLine(PipedInputStream in) throws IOException {
String input = "";
do {
int available = in.available();
if (available == 0) {
break;
}
byte[] b = new byte[available];
in.read(b);
input = input + new String(b, 0, b.length);
} while (!input.endsWith("\n") && !input.endsWith("\r\n") && !quit);
return input;
}
public void windowClosing(WindowEvent e) {
setVisible(false);
}
public void windowClosed(WindowEvent e) {
quit = true;
this.notifyAll(); // stop all threads
try {
reader.join(1000);
pin.close();
} catch (Exception ex) {
}
}
public void windowOpened(WindowEvent e) {
}
public void windowIconified(WindowEvent e) {
}
public void windowDeiconified(WindowEvent e) {
}
public void windowActivated(WindowEvent e) {
}
public void windowDeactivated(WindowEvent e) {
}
}
