package NET.worlds.console; import NET.worlds.core.IniFile; import java.awt.AWTEvent; import java.awt.Component; import java.awt.event.FocusEvent; import java.io.BufferedReader; import java.io.File; import java.io.FileNotFoundException; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.io.PrintWriter; import java.text.DateFormat; import java.util.Date; import java.util.Observer; class NewSharedTextArea extends GammaTextArea implements SharedTextArea { private static final long serialVersionUID = 6732411958099438561L; private static String sharedText; private boolean isShared; private String unsharedText; private String unaddedText = null; private PrintWriter logFile; private String logFileName; private static final long oneMeg = 1048576L; private static final long logLengthLimit = 524288L; private static PublicObservable obsLogFile = new PublicObservable(); private static int autoScrollLimit = IniFile.gamma().getIniInt("AutoScrollLimit", 0); public static int chatLengthLimit = IniFile.gamma().getIniInt("ChatLengthLimit", 20000); public NewSharedTextArea(int rows, int cols, boolean isShared) { super("", rows, cols, 2); this.isShared = isShared; this.setEditable(false); } @Override public void finalize() { this.disableLogging(); } @Override public Component getComponent() { return this; } @Override public synchronized void validate() { super.validate(); String text = this.isShared ? sharedText : this.unsharedText; if (text != null) { this.setText(text); } } @Override public synchronized void enableLogging(String fileName, String title, boolean append) { if (this.logFile != null) { if (this.logFileName.equals(fileName)) { return; } this.logFile.close(); } try { if (append && new File(fileName).exists()) { this.truncateIfExceeds(fileName, title, 524288L); this.logFile = new PrintWriter(new FileWriter(fileName, true)); } else { this.logFile = new PrintWriter(new FileWriter(fileName, false)); obsLogFile.setChanged(true); this.logFile.println(""); this.logFile.println(""); this.logFile.println("" + title + ""); this.logFile.println(""); this.logFile.println(""); } this.logFileName = fileName; this.logFile.println("
"); this.logFile.println("

Conversation of " + DateFormat.getDateTimeInstance().format(new Date()) + "

"); this.logFile.flush(); obsLogFile.notifyObservers(this); } catch (IOException var5) { System.out.println("Log file not opened: " + var5); } } public static void addLogObserver(Observer o) { obsLogFile.addObserver(o); } public static void deleteLogObserver(Observer o) { obsLogFile.deleteObserver(o); } private void truncateIfExceeds(String fileName, String title, long lengthLimit) { File f = new File(fileName); if (f.length() > lengthLimit) { File tf = new File(fileName + ".temp"); try { BufferedReader in = new BufferedReader(new FileReader(f)); PrintWriter out = new PrintWriter(new FileWriter(tf)); out.println(""); out.println(""); out.println("" + title + ""); out.println(""); out.println(""); in.skip(f.length() - lengthLimit / 2L); String line = in.readLine(); for (String var13 = in.readLine(); var13 != null; var13 = in.readLine()) { out.println(var13); } in.close(); out.close(); f.delete(); f = new File(fileName); tf.renameTo(f); } catch (FileNotFoundException var10) { System.out.println("DuplexPart fatal: " + var10); } catch (IOException var11) { System.out.println("DuplexPart: Unable to write, " + var11); } } } @Override public synchronized void disableLogging() { if (this.logFile != null) { this.logFile.close(); this.logFile = null; } } @Override public boolean canAddText() { if (this.getText().length() < 3) { return true; } else { return autoScrollLimit > 0 && autoScrollLimit < this.unaddedText.length() ? true : this.isLastLineVisible(); } } @Override public synchronized void println(String msg) { if (this.logFile != null && msg != null) { this.logFile.println(DuplexPart.toHtml(msg) + "
"); this.logFile.flush(); } if (this.unaddedText == null) { this.unaddedText = msg; } else if (msg != null) { this.unaddedText = this.unaddedText + "\n" + msg; } if (this.unaddedText != null && this.canAddText()) { if (this.getText().length() == 0) { this.append(this.unaddedText); } else { this.append("\n" + this.unaddedText); } this.unaddedText = null; String text = this.getText(); if (text.length() > chatLengthLimit) { int linePos = text.indexOf(10, chatLengthLimit / 2 - 80); if (linePos >= 0) { text = text.substring(linePos + 1); linePos = text.lastIndexOf(10); if (linePos > 0) { this.setText(text.substring(0, linePos)); this.append(text.substring(linePos)); } } } if (this.isShared) { sharedText = text; } else { this.unsharedText = text; } this.repaint(); } } @Override public synchronized void scrollToBottom() { String text = this.getText(); this.setText(""); this.append(text); this.repaint(); } @Override protected void processFocusEvent(FocusEvent e) { super.processFocusEvent(e); } @Override protected void processEvent(AWTEvent e) { this.poll(); super.processEvent(e); } @Override public synchronized void poll() { if (this.unaddedText != null) { this.println(null); } } @Override public boolean isFocusTraversable() { return false; } }