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, 45000, "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) 
                {               
                        for (int i= start; i<start+length; i++)
                                builder.append(ch[i]);  
                }
                
                @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	283	String doc = DownloadUtil.getContentString(url, 45000, "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			for (int i= start; i<start+length; i++)
98			builder.append(ch[i]);
99			}
100	torben	237
101	torben	1007	@Override
102			public void startElement (String uri, String name, String qName, Attributes atts)throws SAXException
103			{
104			if (name.equalsIgnoreCase("train"))
105			tempDeparture = new DepartureEntry();
106
107			builder.setLength(0); //reset StringBuilder
108	torben	699	}
109	torben	1007
110			@Override
111			public void endElement (String uri, String name, String qName) throws SAXException
112			{
113			if (name.equals("train")) {
114			departures.entries.add( tempDeparture );
115			} else if (name.equals("time")) {
116			tempDeparture.setTime(builder.toString().trim());
117			} else if (name.equals("updated")) {
118			tempDeparture.setLastUpdate(builder.toString().trim());
119			} else if (name.equals("trainnumber")) {
120			tempDeparture.setTrainNumber(builder.toString().trim());
121			} else if (name.equals("destination")) {
122			tempDeparture.setDestination(builder.toString().trim());
123			} else if (name.equals("origin")) {
124			tempDeparture.setOrigin(builder.toString().trim());
125			} else if (name.equals("location")) {
126			tempDeparture.setLocation(builder.toString().trim());
127			} else if (name.equals("status")) {
128			tempDeparture.setStatus(builder.toString().trim());
129			} else if (name.equals("note")) {
130			tempDeparture.setNote(builder.toString().trim());
131			} else if (name.equals("type")) {
132			tempDeparture.setType(builder.toString().trim());
133			} else if (name.equals("notification")) {
134			departures.notifications.add( builder.toString().trim() );
135			}
136			}
137	torben	237	}
138			}