RiverRat  - An MIT iCampus project

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

NMEAFakeServer.java

package riverrat.testing;

import org.xml.sax.Attributes;
import org.xml.sax.helpers.AttributesImpl;
import java.io.*;
import java.util.*;
import java.net.*;

public class NMEAFakeServer extends FakeServer {
        protected static String file = "track6.raw";
        
        protected BufferedReader breader;
        
        protected boolean DELAY_INPUT = false;
        
        protected boolean FILE_DATA;
        
        protected static final String hostname = "localhost";
        //protected static final String hostname = "ragamuffin.local";
        
        protected String nmeahost = "localhost";
        
        protected int nmeaport = 9999;
        
        public NMEAFakeServer() {
                super();
                FILE_DATA = true;
                //FILE_DATA = false;
                //nmeahost = hostname;
                //nmeaport = 9999;
        }
        
        public NMEAFakeServer(int newport) {
                super(newport);
                FILE_DATA = true;
                //FILE_DATA = false;
                //nmeahost = hostname;
                //nmeaport = 9999;
        }
        
        public NMEAFakeServer(String newhost, int newport) {
                super();
                FILE_DATA = false;
                nmeahost = newhost;
                nmeaport = newport;
        }
        
        public void setupState() {
                //dump setup data
                startDocument();

                AttributesImpl race_attrs = new AttributesImpl();
                race_attrs.addAttribute(null, null, "regatta", "string", "Schell");
                race_attrs.addAttribute(null, null, "race", "int", "4");
                race_attrs.addAttribute(null, null, "id", "int", "2492");
                startElement(null, null, "race", (Attributes) race_attrs);
                
                        startElement(null, null, "setup", null);

                                AttributesImpl starttime_attrs = new AttributesImpl();
                                starttime_attrs.addAttribute(null, null, "date", "string", "3/12/04");
                                starttime_attrs.addAttribute(null, null, "time", "int", "1079136231671");
                                startElement(null, null, "starttime", starttime_attrs);
                                endElement(null, null, "starttime");
                
                                AttributesImpl boat_attrs = new AttributesImpl();
                                boat_attrs.addAttribute(null, null, "sn", "int", "24");
                                boat_attrs.addAttribute(null, null, "id", "int", "0");
                                startElement(null, null, "boat", boat_attrs);
                                endElement(null, null, "boat");
                
                                AttributesImpl mark_attrs = new AttributesImpl();
                                mark_attrs.addAttribute(null, null, "id", "int", "1");
                                mark_attrs.addAttribute(null, null, "position", "string", "dynamic");
                                startElement(null, null, "mark", mark_attrs);
                                endElement(null, null, "mark");
                
                                mark_attrs = new AttributesImpl();
                                mark_attrs.addAttribute(null, null, "id", "int", "0");
                                mark_attrs.addAttribute(null, null, "position", "string", "dynamic");
                                startElement(null, null, "mark", mark_attrs);
                                endElement(null, null, "mark");
                
                        endElement(null, null, "setup");
                        startElement(null, null, "live", null);
        }
        
        public void endRace() {
                endElement(null, null, "live");
                endElement(null, null, "race");
        }
        
        public void printBoat(float lat, float lon, long time) {
                AttributesImpl boat_attrs = new AttributesImpl();
                boat_attrs.addAttribute(null, null, "id", "int", "0");
                boat_attrs.addAttribute(null, null, "time", "long", ""+time);
                boat_attrs.addAttribute(null, null, "lat", "float", ""+lat);
                boat_attrs.addAttribute(null, null, "lon", "float", ""+lon);
                startElement(null, null, "boat", boat_attrs);
                endElement(null, null, "boat");
        }

        public void mainServer() {
                //System.out.println("mainServer(): called");
                
                if(FILE_DATA) {
                        System.out.print("opening file...");
                        openFile(file, DELAY_INPUT);
                        System.out.println("opened file.");
                        System.out.print("setting up BufferedReader...");
                        breader = new BufferedReader(new InputStreamReader(fileInputStream));
                        System.out.println("set up BufferedReader.");
                } else {        //get stream from network socket
                        try {
                                System.out.println("opening NMEA stream on "+nmeahost+":"+nmeaport+"...");
                                breader = new BufferedReader(new InputStreamReader((new Socket(nmeahost, nmeaport)).getInputStream()));
                                System.out.println("opened NMEA stream.");
                        } catch(UnknownHostException e) {
                                System.err.println("NMEA Host not found.");
                                System.exit(1);
                        } catch(SocketException e) {
                                System.err.println("Socket exception connecting to NMEA host.");
                                System.exit(1);
                        } catch(IOException e) {
                                System.err.println("IO Exception connecting to NMEA host.");
                                System.exit(1);
                        }
                }
                
                Date currentdate = new Date(System.currentTimeMillis());
                String logfilename = "nmealog/"+currentdate.toString();
                
                
                PrintWriter filewriter = null;
                //make file with date string
                try {
                        filewriter = new PrintWriter(new FileWriter(logfilename), true);
                } catch(IOException e) {
                        System.err.println("Cannot write to file.");
                        System.err.println(e.getMessage());
                        System.exit(1);
                }
                
                System.out.println("using log file: "+logfilename);
                filewriter.println("using log file.");
                filewriter.flush();
                
                sout.print("<?xml version=\"1.0\" ?>");
                
                String line = null;
                String[] sentence;
                long time = 0;
                float lat = 0.0f, lon = 0.0f;
                
                //print state information
                setupState();
                
                //initialize NMEA parser, parse NMEA data from file
                //and use callbacks from BasicServer to output data
                try {
                        while((line = breader.readLine()) != null) {
                                //System.out.println("read line: "+line);
                                filewriter.println(line);
                                //try {
                                //      Thread.sleep(10);
                                //} catch(InterruptedException e) {
                                //}
                                if(line.startsWith("$GPGGA")) {
                                        sentence = line.split(",");
                                        if(sentence[0].equals("$GPGGA")) {
                                                System.out.println("++++++++++++++++");
                                                
                                                //parse timestamp component
                                                try {
                                                        try {
                                                                time = Long.decode(sentence[1]).longValue();
                                                        } catch(NumberFormatException e) {
                                                        }
                                                } catch(ArrayIndexOutOfBoundsException e) {
                                                }
                                                
                                                //parse latitude component
                                                try {
                                                        try {
                                                                lat = (Float.parseFloat(sentence[2].substring(0,2)))                            //degrees component
                                                                                + (Float.parseFloat(sentence[2].substring(2))/60.0f);           //minutes component
                                                        } catch(IndexOutOfBoundsException e) {
                                                        } catch(NumberFormatException e) {
                                                        }
                                                        if(sentence[3].equals("S")) lat = -lat;
                                                } catch(ArrayIndexOutOfBoundsException e) {
                                                }
                                                
                                                //parse longitude component
                                                try {
                                                        try {
                                                                lon = (Float.parseFloat(sentence[4].substring(0,3))) 
                                                                                + (Float.parseFloat(sentence[4].substring(3))/60.0f);
                                                        } catch(IndexOutOfBoundsException e) {
                                                        } catch(NumberFormatException e) {
                                                        }
                                                        if(sentence[5].equals("W")) lon = -lon;
                                                } catch(ArrayIndexOutOfBoundsException e) {
                                                }
                                        }
                                        System.out.println("latitude is "+lat);
                                        System.out.println("longitude is "+lon);
                                        System.out.println("time is "+time);
                                        printBoat(lat, lon, time);
                                }
                        }
                } catch(IOException e) {
                }
                //end of NMEA parsing code
                
                System.out.println("done parsing stream/file.");
                
                //send end of race data
                endRace();
        }
        
        public static void main(String args[]) {
                if(args.length != 0) {
                        //get filename from 1st argument
                        filename = args[0];
                }
                NMEAFakeServer testserver = new NMEAFakeServer(hostname, 9999);
                Thread serverthread = new Thread(testserver);
                serverthread.start();
                
                while(true) {
                        System.out.println("This is the main loop.");
                        try {
                                Thread.sleep(10000);
                        } catch(InterruptedException e) {
                                System.err.println("Interrupted.");
                        }
                }
        }
}

 

Brought to you by the RiverRat team.