RiverRat  - An MIT iCampus project

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

Race.java

/* Version 2! Another attempt, shit was broken. */
package riverrat;

import java.util.Vector;
import org.xml.sax.Locator;
import org.xml.sax.ContentHandler;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;

public class Race implements ContentHandler {
        public static final int MODE_FINISHED = 3;
        
        public static final int MODE_LIVE = 2;

        public static final int MODE_SETUP = 1;
        
        public static final int MODE_NONE = 0;
        
        RiverRatListener rrlistener;
        
        Thread listenthread;
        
        Vector boatlist;
        
        Vector marklist;
        
        long starttime;
        
        int mode;
        
        String name;
        
        int racenum;
        
        int raceid;
        
        public Race() {
                //do race initialization stuff here
                boatlist = new Vector();
                marklist = new Vector();
                starttime = (long)-1;
        }
        
        public Race(String host, int port) {
                this();
                rrlistener = new RiverRatListener(this, host, port);
                listenthread = new Thread(rrlistener);
                listenthread.start();
        }
        
        public synchronized int numBoats() {
                return boatlist.size();
        }
        
        public synchronized int numMarks() {
                return marklist.size();
        }
        
        public synchronized void addBoat(Boat newboat) {
                boatlist.addElement(newboat);
        }
        
        public synchronized void addMark(Mark newmark) {
                marklist.addElement(newmark);
        }
        
        public synchronized void addRaceObject(RaceObject newobject) {
                if (newobject instanceof Mark) addMark((Mark) newobject);
                else if (newobject instanceof Boat) addBoat((Boat) newobject);
        }
        
        public synchronized Boat getBoat(int id) throws NoSuchObjectException {
                for(int i = 0; i < boatlist.size(); i++) {
                        if(((Boat) boatlist.elementAt(i)).getID() == id) {
                                return (Boat) boatlist.elementAt(i);
                        }
                }
                throw new NoSuchObjectException();
        }
        
        public synchronized Mark getMark(int id) throws NoSuchObjectException {
                for(int i = 0; i < marklist.size(); i++) {
                        if(((Mark) marklist.elementAt(i)).getID() == id) {
                                return (Mark) marklist.elementAt(i);
                        }
                }
                throw new NoSuchObjectException();
        }       
        
        public synchronized long getStartTime() {
                return starttime;
        }
        
        public synchronized int getMode() {
                return mode;
        }
        
        public synchronized String getName() {
                return name;
        }
        
        public synchronized int getNum() {
                return racenum;
        }
        
        public synchronized int getID() {
                return raceid;
        }

        public void startDocument() throws SAXException {
                //System.out.println("Starting document");
        }
        
        public void startElement(String uri, String localpart, String rawname, Attributes attrs) throws SAXException {
                //System.out.println("Starting element "+rawname);
                String attrname;
                int length = attrs != null ? attrs.getLength() : 0;
                if(rawname == "race") {
                        //parse race attributes
                        for(int i = 0; i < length; i++) {
                                attrname = attrs.getQName(i);
                                if(attrname == "id") {
                                        raceid = Integer.decode(attrs.getValue(i)).intValue();
                                } else if(attrname == "race") {
                                        racenum = Integer.decode(attrs.getValue(i)).intValue();
                                } else if(attrname == "regatta") {
                                        name = attrs.getValue(i);
                                }
                        }
                } else if(rawname == "setup") {
                        mode = MODE_SETUP;
                } else if(rawname == "live") {
                        mode = MODE_LIVE;
                } else if(rawname == "starttime") {
                        //parse starting time of the Race and fill in starttime with it
                        for(int i = 0; i < length; i++) {
                                attrname = attrs.getQName(i);
                                if(attrname == "data") {
                                        //parse the month/day/year portion of the starting time
                                } else if(attrname == "time") {
                                        //parse the System.time portion of the starting time
                                        starttime = Long.decode(attrs.getValue(i)).longValue();
                                }
                        }
                } else if((rawname == "boat") || (rawname == "mark")) {
                        int newobjid = -1, newobjsn = -1;
                        long newobjtime = (long) -1;
                        float newobjlat = 0.0f, newobjlon = 0.0f, newobjhdg = -1.0f, newobjvel = -1.0f, newobjheel = 0.0f;
                        for(int i = 0; i < length; i++) {
                                attrname = attrs.getQName(i);
                                if(attrname == "id") {
                                        newobjid = Integer.decode(attrs.getValue(i)).intValue();
                                } else if(attrname == "sn") {
                                        newobjsn = Integer.decode(attrs.getValue(i)).intValue();
                                } else if(attrname == "time") {
                                        newobjtime = Long.decode(attrs.getValue(i)).longValue();
                                } else if(attrname == "lat") {
                                        newobjlat = Float.parseFloat(attrs.getValue(i));
                                } else if(attrname == "lon") {
                                        newobjlon = Float.parseFloat(attrs.getValue(i));
                                } else if(attrname == "hdg") {
                                        newobjhdg = Float.parseFloat(attrs.getValue(i));
                                } else if(attrname == "vel") {
                                        newobjvel = Float.parseFloat(attrs.getValue(i));
                                } else if(attrname == "heel") {
                                        newobjheel = Float.parseFloat(attrs.getValue(i));
                                }
                        }
                        //have all the values now in newobj_vars
                        if(mode == MODE_SETUP) {
                                //try to update existing object. if it doesn't exist, create it.
                                if(rawname == "boat") {
                                        try {
                                                //update object
                                                getBoat(newobjid).setSN(newobjsn);
                                        } catch(NoSuchObjectException ex) {
                                                //doesn't exist, create it first, then update it
                                                addBoat(new Boat(newobjid));
                                                getBoat(newobjid).setSN(newobjsn);
                                        }
                                }
                                if(rawname == "mark") {
                                        try {
                                                //update object
                                                getMark(newobjid).setSN(newobjsn);
                                        } catch(NoSuchObjectException ex) {
                                                //doesn't exist, create it
                                                addMark(new Mark(newobjid));
                                                getMark(newobjid).setSN(newobjsn);
                                        }
                                }
                        } else if(mode == MODE_LIVE) {
                                //update existing object. if specified object does not exist, throw a NoSuchObjectException
                                if(rawname == "boat") {
                                        try {
                                                //update object
                                                getBoat(newobjid).update(new Fix(newobjlat, newobjlon, newobjtime, newobjvel, newobjhdg, newobjheel));
                                        } catch(NoSuchObjectException ex) {
                                                //something's fucked.
                                        }
                                } else if(rawname == "mark") {
                                        try {
                                                //update object
                                                getMark(newobjid).update(new Fix(newobjlat, newobjlon, newobjtime, newobjvel, newobjhdg, newobjheel));
                                        } catch(NoSuchObjectException ex) {
                                                //something's fucked
                                        }
                                }
                        }
                }
        }
                
        public void endDocument() throws SAXException {
                //System.out.println("Ending document");
        }
        
        public void endElement(String uri, String localpart, String rawname) throws SAXException {
                //System.out.println("Ending element "+rawname);
                if((rawname == "setup") || (rawname == "live")) {
                        mode = MODE_NONE;
                }
                if(rawname == "race") {
                        mode = MODE_FINISHED;
                }
        }
        
        public void characters(char[] ch, int start, int length) throws SAXException {}
        
        public void endPrefixMapping(String prefix) throws SAXException {}
        
        public void ignorableWhitespace(char[] ch, int start, int length) throws SAXException {}
        
        public void processingInstruction(String target, String data) throws SAXException {}
        
        public void setDocumentLocator(Locator locator) {}

        public void skippedEntity(String name) throws SAXException {}

        public void startPrefixMapping(String prefix, String uri) throws SAXException {}
        
        public static void main(String args[]) {
                System.out.println("Starting Race class test case...");
                Race testrace = new Race("localhost", 8080);
                while(true) {
                        System.out.println("Race now has "+testrace.numBoats()+" boats.");
                        System.out.println("Race is in mode "+testrace.getMode());
                        if(testrace.getMode() == MODE_FINISHED) {
                                System.out.println("Race finished.");
                                System.exit(0);
                        }
                        for(int boatid = 0; boatid < testrace.numBoats(); boatid++) {
                                System.out.println(" - "+testrace.getBoat(boatid).boatToString());
                        }
                        try {
                                Thread.sleep(100);
                        } catch(InterruptedException ex) {
                                System.err.println("Interrupted.");
                        }
                }
        }
} //class Race

 

Brought to you by the RiverRat team.