From 6c9c63893ecf2c896da2449bc94746a2eb845819 Mon Sep 17 00:00:00 2001
From: Massimo Banzi <m.banzi@arduino.cc>
Date: Mon, 29 Aug 2005 18:37:40 +0000
Subject: [PATCH] added ArduinoMessageSiphon, updated message siphon written by
 david

---
 app/ArduinoMessageSiphon.java | 149 ++++++++++++++++++++++++++++++++++
 1 file changed, 149 insertions(+)
 create mode 100644 app/ArduinoMessageSiphon.java

diff --git a/app/ArduinoMessageSiphon.java b/app/ArduinoMessageSiphon.java
new file mode 100644
index 000000000..ab40d51c4
--- /dev/null
+++ b/app/ArduinoMessageSiphon.java
@@ -0,0 +1,149 @@
+/*
+  Part of the Arduino project - http://arduino.berlios.de
+
+  This class reads from an input stream
+  and flushes out everything to the System.out
+  It can report interrupts back to the parent process
+  
+  @author	DojoDave
+  @www http://www.0j0.org
+
+
+  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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+*/
+
+// TODO migrate codebase to arduino.app
+package processing.app;
+
+import java.io.*;
+
+class ArduinoMessageSiphon extends Thread
+{
+	/** Stream to read from */
+	InputStream is;
+	
+	/** Process' parent in execution */
+	Thread parent;
+	
+	/** Output message from System.error */
+	public String theMsg ="";
+
+	/** Result value to be sent back */
+	public int result = -1;
+	
+	/** Count errors and warnings to be sent back */
+	public int totalErrors = 0;
+	
+	/** Debug Errors and Warnings */
+	public boolean debugWarning = false;
+	public boolean debugError = false;
+	public boolean logAllOutput = false;
+	
+	/**
+	  * Creates the stream to flush
+	  * @param	theIS is the input stream we will monitor
+	  *         process is the parent process that called this
+	  */
+	public ArduinoMessageSiphon(InputStream theIS, Thread process)
+	{
+		// Assign to member variables
+		is = theIS;
+		parent = process;
+
+	}
+
+	/**
+	  * Creates the stream to flush
+	  * @param	theIS is the input stream we will monitor
+	  *         process is the parent process that called this
+	  *         warnings will debug warnings when calling commands
+	  *         errors will debug errors when calling commands
+	  */
+	  
+	/**
+	  * The errors it will report are in the ranges
+	  * 	49 - 0  for the programmer's errors
+	  * 	99 - 50 for the compiler's errors
+	  */
+	public ArduinoMessageSiphon(InputStream theIS, Thread process, boolean warnings, boolean errors)
+	{
+		// Assign to member variables
+		is = theIS;
+		parent = process;
+		debugWarning = warnings;
+		debugError = errors;
+
+	}
+
+	/**
+	  * The errors it will report are in the ranges
+	  * 	49 - 0  for the programmer's errors
+	  * 	99 - 50 for the compiler's errors
+	  */
+	public ArduinoMessageSiphon(InputStream theIS, Thread process, boolean outlog)
+	{
+		// Assign to member variables
+		is = theIS;
+		parent = process;
+		logAllOutput = outlog;
+
+	}
+
+	/** Performs system call specific code */
+	public void run()
+	{
+        BufferedReader br = new BufferedReader(new InputStreamReader(is));
+        
+		try {
+			String theLine;
+			while ((theLine = br.readLine()) != null) {
+				if (logAllOutput) {
+					theMsg += theLine + "\r\n";
+					//System.out.println(theMsg);
+				}
+				if ((theLine.indexOf("warning:") != -1) && (theLine.indexOf("prog.c:") != -1) && (debugWarning)) {
+					theMsg += theLine + "\r\n";
+					totalErrors++;
+				}
+				if ((theLine.indexOf("error:") != -1) && (theLine.indexOf("prog.c:") != -1) && (debugError)) {
+					result = 97;
+					theMsg += theLine + "\r\n";
+					totalErrors++;
+				}
+				if (theLine.indexOf("Errors: none") != -1) {
+					result = 0;
+				}
+				if (theLine.indexOf("bytes transferred") != -1) {
+					result = 0;
+				}
+				if (theLine.toLowerCase().indexOf("not responding") != -1) {
+					result = 49;
+				}
+			}
+			br.close();
+
+			// waits 20 secs until being killed by the 
+			// parent process or just dies, no zombies wanted!!
+			try {
+				Thread.currentThread().sleep(20000); 
+			} catch (InterruptedException ie) {
+			}
+		} catch (Exception err) {
+			err.printStackTrace();
+			result = 96;
+		}
+	}
+}
+