RiverRat  - An MIT iCampus project

http://web.mit.edu/riverrat/

RiverRatListener.java

package riverrat;

import riverrat.testing.DelayedInputStream;
import java.io.InputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.SocketException;
import java.util.Vector;
import org.xml.sax.XMLReader;
import org.xml.sax.InputSource;
import org.xml.sax.ContentHandler;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
import org.xml.sax.SAXParseException;
import org.xml.sax.helpers.DefaultHandler;
import org.xml.sax.helpers.XMLReaderFactory;

public class RiverRatListener extends DefaultHandler implements Runnable {
        static int port = 8080;
        
        static String host = "localhost";
        
        static final boolean DELAY_INPUT = false;
        
        static final boolean DEBUG = false;
                
        static DefaultHandler defaulthandler;
        static ContentHandler contenthandler;
        static PrintWriter out;
        static XMLReader parser;
        static Socket socket;
        static InputStream stream;
        static InputSource source;
        
        public RiverRatListener() {
        }
                
        public RiverRatListener(ContentHandler somehandler) {
                contenthandler = somehandler;
        }
        
        public RiverRatListener(ContentHandler somehandler, String connect_host, int connect_port) {
                this(somehandler);
                host = connect_host; port = connect_port;
        }
        
        public void startElement(String uri, String localpart, String rawname, Attributes attrs) throws SAXException {
                System.out.println("< --- "+rawname);
                int length = attrs != null ? attrs.getLength() : 0;
                for (int i = 0; i < length; i++) {
                        System.out.println("Attribute: "+attrs.getQName(i)+' '+attrs.getValue(i));
                }
        }

        public void endElement(String uri, String localpart, String rawname) throws SAXException {
                System.out.println(" --- >"+rawname);
        }

        public void startDocument() {
                System.out.println("Document started.");
        }

        public void endDocument() {
                System.out.println("Document ended.");
        }
                
        public void warning(SAXParseException ex) throws SAXException {
                System.err.println("Warning: "+ex);
        }

        public void error(SAXParseException ex) throws SAXException {
                System.err.println("Error: "+ex);
        }

        public void fatalError(SAXParseException ex) throws SAXException {
                System.err.println("Fatal Error: "+ex);
        }
        
        public void run() {
                defaulthandler = new RiverRatListener();
                if(contenthandler == null) {
                        contenthandler = defaulthandler;
                }
                if(DEBUG) {
                        if (contenthandler instanceof Race) System.out.println("contenthandler is the Race class");
                        if (contenthandler instanceof RiverRatListener) System.out.println("contenthandler is the RiverRatListener class");
                }
                out = new PrintWriter(System.out);
                try { //instantiate parser
                        parser = XMLReaderFactory.createXMLReader("org.apache.xerces.parsers.SAXParser");
                } catch (Exception e) {
                        System.err.println("error: Unable to instantiate parser");
                }
                //set parser features
                try {
                        parser.setFeature("http://xml.org/sax/features/namespaces",true);
                        parser.setFeature("http://xml.org/sax/features/validation",false);
                        parser.setFeature("http://apache.org/xml/features/validation/schema",false);
                        parser.setFeature("http://apache.org/xml/features/validation/schema-full-checking",false);
                } catch (SAXException e) {
                        System.err.println("warning: Parser doesn't support features... "+e);
                }
                parser.setContentHandler(contenthandler);
                //tells the XML parser to use the contenthandler class as it's Content handler.
                parser.setErrorHandler(defaulthandler);
                //tells the XML parser to use the defaulthandler class as it's error handler.
                System.out.println("Attempting connection to "+host+" on port "+port);
                try { //try to open socket
                        socket = new Socket(host, port);        //try to open TCP connection to host on port
                        try { //try to parse the stream
                                System.out.println("Connection accepted: "+socket);
                                if(DELAY_INPUT) {
                                        stream = new DelayedInputStream(socket.getInputStream()); //grabs TCP socket input stream
                                } else {
                                        stream = socket.getInputStream();
                                }
                                source = new InputSource(stream);
                                source.setSystemId(""+port);
                                if(source == null) System.err.println("InputSource is null!!!!!");
                                try {
                                        parser.parse(source); //do the magic shit
                                } catch(NullPointerException e) {
                                        System.err.println("NullPointerException trying to parse. This probably means that the ContentHandler class is null.");
                                }
                        } finally {
                                socket.close();
                        }
                } catch (SocketException se) {
                        System.err.println("SocketException caught: "+se.getMessage());
                } catch (SAXParseException se) {
                        System.err.println("SAXParseException caught: "+se.getMessage());
                } catch (Exception e) {
                        System.err.println("Error: "+e.getMessage());
                        e.printStackTrace(System.err);
                } //try
        } //run()
        
        public static void main(String args[]) {
                RiverRatListener rrlistener = new RiverRatListener();
                Thread listenthread = new Thread(rrlistener);
                listenthread.start();
                while(true) {
                        System.out.println("This is the main loop.");
                        try {
                                Thread.sleep(10000);
                        } catch (InterruptedException e) {
                                System.err.println("Interrupted!");
                        }
                }
        } //main()
} //class RiverRatListener

 

Brought to you by the RiverRat team.