traininfo/provider/XmlDepartureProvider.java

package dk.thoerup.traininfo.provider;

import java.io.StringReader;

import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;

import org.xml.sax.Attributes;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;
import org.xml.sax.XMLReader;
import org.xml.sax.helpers.DefaultHandler;

import android.util.Log;
import dk.thoerup.traininfo.DepartureBean;
import dk.thoerup.traininfo.DepartureEntry;
import dk.thoerup.traininfo.util.AndroidTimeoutCache;
import dk.thoerup.traininfo.util.DownloadUtil;
import dk.thoerup.traininfo.util.XmlUtil;

public class XmlDepartureProvider implements DepartureProvider {

        final static int CACHE_TIMEOUT = 60*1000;
                
        
        AndroidTimeoutCache<String,DepartureBean> departureCache = new AndroidTimeoutCache<String,DepartureBean>(CACHE_TIMEOUT); 
        
                
        
        DepartureEntry tempDeparture;
        StringBuilder builder = new StringBuilder(512);
        

        
        @Override
        public DepartureBean lookupDepartures(int stationID, boolean arrival) {         
                
                String key = "" + stationID + ":" + arrival;
                
                DepartureBean departures = departureCache.get(key);
        
                if (departures == null) {                       
                        departures = lookupDeparturesWorker(stationID, arrival);
                        
                        if (departures != null) {                       
                                departureCache.put(key, departures);
                        }
                        
                } else {
                        Log.i("XmlDepartureProvider", "cache hit !!!");
                }               
                
                return departures;
        }
        
        private DepartureBean lookupDeparturesWorker(int stationID, boolean arrival) {

                try
                {       
                        int iArrival = arrival ? 1 : 0;
                        String url = XmlUtil.SERVICE_BASE + "/DepartureServlet?format=xml&station=" + stationID + "&arrival=" + iArrival;
                        Log.i("xmlurl",url);
                        String doc =  DownloadUtil.getContentString(url, 30000, "ISO-8859-1");
                        
                        InputSource source = new InputSource( new StringReader(doc));
                        
                        SAXParserFactory spf = SAXParserFactory.newInstance();
            SAXParser sp = spf.newSAXParser();
            XMLReader xr = sp.getXMLReader();

            DepartureParser departureParser = new DepartureParser();
                        xr.setContentHandler(departureParser);
                        xr.setErrorHandler(departureParser);
                        xr.parse(source);
                        
                        return departureParser.getDepartures();
                        
                } catch (Exception e) {
                        Log.e("XmlDepartureProvider", "looupFunction", e);
                        return null;
                }               
        }
        

        class DepartureParser extends DefaultHandler { 
                
                private DepartureBean departures = new DepartureBean(); 

                public DepartureBean getDepartures() {
                        return departures;
                }
        
                // this can be called several times fore the same text-node if there are many chardata / lines
                @Override
                public void characters (char ch[], int start, int length) 
                {               
                        builder.append(ch, start, length);
                }
                
                @Override
                public void startElement (String uri, String name, String qName, Attributes atts)throws SAXException
                {
                        if (name.equalsIgnoreCase("train"))
                                tempDeparture = new DepartureEntry();
                        
                        builder.setLength(0); //reset StringBuilder
                }
                
                @Override
                public void endElement (String uri, String name, String qName) throws SAXException
                {
                        if (name.equals("train")) {                     
                                departures.entries.add( tempDeparture );
                        } else if (name.equals("time")) {
                                tempDeparture.setTime(builder.toString().trim());
                        } else if (name.equals("updated")) {
                                tempDeparture.setLastUpdate(builder.toString().trim());
                        } else if (name.equals("trainnumber")) {
                                tempDeparture.setTrainNumber(builder.toString().trim());
                        } else if (name.equals("destination")) {
                                tempDeparture.setDestination(builder.toString().trim());
                        } else if (name.equals("origin")) {
                                tempDeparture.setOrigin(builder.toString().trim());
                        } else if (name.equals("location")) {
                                tempDeparture.setLocation(builder.toString().trim());
                        } else if (name.equals("status")) {
                                tempDeparture.setStatus(builder.toString().trim());
                        } else if (name.equals("note")) {
                                tempDeparture.setNote(builder.toString().trim());
                        } else if (name.equals("type")) {
                                tempDeparture.setType(builder.toString().trim());
                        } else if (name.equals("notification")) {
                                departures.notifications.add( builder.toString().trim() );
                        }
                }
        }
}
1	torben	237	package dk.thoerup.traininfo.provider;
2
3			import java.io.StringReader;
4
5			import javax.xml.parsers.SAXParser;
6			import javax.xml.parsers.SAXParserFactory;
7
8			import org.xml.sax.Attributes;
9			import org.xml.sax.InputSource;
10			import org.xml.sax.SAXException;
11			import org.xml.sax.XMLReader;
12			import org.xml.sax.helpers.DefaultHandler;
13
14			import android.util.Log;
15			import dk.thoerup.traininfo.DepartureBean;
16	torben	981	import dk.thoerup.traininfo.DepartureEntry;
17	torben	390	import dk.thoerup.traininfo.util.AndroidTimeoutCache;
18	torben	238	import dk.thoerup.traininfo.util.DownloadUtil;
19	torben	357	import dk.thoerup.traininfo.util.XmlUtil;
20	torben	237
21	torben	1007	public class XmlDepartureProvider implements DepartureProvider {
22	torben	237
23	torben	390	final static int CACHE_TIMEOUT = 60*1000;
24	torben	391
25	torben	237
26	torben	981	AndroidTimeoutCache<String,DepartureBean> departureCache = new AndroidTimeoutCache<String,DepartureBean>(CACHE_TIMEOUT);
27	torben	390
28	torben	319
29
30	torben	981	DepartureEntry tempDeparture;
31	torben	237	StringBuilder builder = new StringBuilder(512);
32
33	torben	1007
34
35	torben	237	@Override
36	torben	1007	public DepartureBean lookupDepartures(int stationID, boolean arrival) {
37	torben	390
38	torben	835	String key = "" + stationID + ":" + arrival;
39
40	torben	1007	DepartureBean departures = departureCache.get(key);
41	torben	319
42	torben	390	if (departures == null) {
43	torben	1007	departures = lookupDeparturesWorker(stationID, arrival);
44	torben	319
45	torben	1007	if (departures != null) {
46	torben	835	departureCache.put(key, departures);
47	torben	390	}
48	torben	319
49			} else {
50			Log.i("XmlDepartureProvider", "cache hit !!!");
51			}
52
53	torben	1007	return departures;
54	torben	319	}
55
56	torben	1007	private DepartureBean lookupDeparturesWorker(int stationID, boolean arrival) {
57
58	torben	237	try
59	torben	294	{
60	torben	835	int iArrival = arrival ? 1 : 0;
61			String url = XmlUtil.SERVICE_BASE + "/DepartureServlet?format=xml&station=" + stationID + "&arrival=" + iArrival;
62	torben	294	Log.i("xmlurl",url);
63	torben	1052	String doc = DownloadUtil.getContentString(url, 30000, "ISO-8859-1");
64	torben	237
65			InputSource source = new InputSource( new StringReader(doc));
66
67			SAXParserFactory spf = SAXParserFactory.newInstance();
68			SAXParser sp = spf.newSAXParser();
69			XMLReader xr = sp.getXMLReader();
70
71	torben	1007	DepartureParser departureParser = new DepartureParser();
72			xr.setContentHandler(departureParser);
73			xr.setErrorHandler(departureParser);
74	torben	237	xr.parse(source);
75	torben	319
76	torben	1007	return departureParser.getDepartures();
77
78	torben	237	} catch (Exception e) {
79			Log.e("XmlDepartureProvider", "looupFunction", e);
80	torben	1007	return null;
81			}
82	torben	237	}
83
84	torben	1007
85			class DepartureParser extends DefaultHandler {
86	torben	319
87	torben	1007	private DepartureBean departures = new DepartureBean();
88
89			public DepartureBean getDepartures() {
90			return departures;
91			}
92	torben	237
93	torben	1007	// this can be called several times fore the same text-node if there are many chardata / lines
94			@Override
95			public void characters (char ch[], int start, int length)
96			{
97	torben	1024	builder.append(ch, start, length);
98	torben	1007	}
99	torben	237
100	torben	1007	@Override
101			public void startElement (String uri, String name, String qName, Attributes atts)throws SAXException
102			{
103			if (name.equalsIgnoreCase("train"))
104			tempDeparture = new DepartureEntry();
105
106			builder.setLength(0); //reset StringBuilder
107	torben	699	}
108	torben	1007
109			@Override
110			public void endElement (String uri, String name, String qName) throws SAXException
111			{
112			if (name.equals("train")) {
113			departures.entries.add( tempDeparture );
114			} else if (name.equals("time")) {
115			tempDeparture.setTime(builder.toString().trim());
116			} else if (name.equals("updated")) {
117			tempDeparture.setLastUpdate(builder.toString().trim());
118			} else if (name.equals("trainnumber")) {
119			tempDeparture.setTrainNumber(builder.toString().trim());
120			} else if (name.equals("destination")) {
121			tempDeparture.setDestination(builder.toString().trim());
122			} else if (name.equals("origin")) {
123			tempDeparture.setOrigin(builder.toString().trim());
124			} else if (name.equals("location")) {
125			tempDeparture.setLocation(builder.toString().trim());
126			} else if (name.equals("status")) {
127			tempDeparture.setStatus(builder.toString().trim());
128			} else if (name.equals("note")) {
129			tempDeparture.setNote(builder.toString().trim());
130			} else if (name.equals("type")) {
131			tempDeparture.setType(builder.toString().trim());
132			} else if (name.equals("notification")) {
133			departures.notifications.add( builder.toString().trim() );
134			}
135			}
136	torben	237	}
137			}