traininfoservice/banedk/TimetableServlet.java

package dk.thoerup.traininfoservice.banedk;

import java.io.IOException;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import dk.thoerup.curcuitbreaker.CircuitBreakerException;

/**
 * Servlet implementation class TimetableServlet
 */
public class TimetableServlet extends HttpServlet {
        private static final long serialVersionUID = 1L;
       
        
        Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
        
        TimetableFetcher fetcher = new TimetableFetcher();
        
        @Override
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                String train = request.getParameter("train").trim();
                
                String sections[] = train.split(" ");
                if (sections.length != 2) {
                        response.sendError(400, "Invalid parameter");
                        return;
                }
                
                String type = lookupType(sections[0]);
                String trainID = sections[1];
                try
                {
                        List<TimetableBean> timetable = fetcher.cachedLookupTimetable(trainID, type);
                
                        String responseXML = formatTimetable(timetable);
                
                        response.setContentType("text/xml");
                        response.getWriter().print(responseXML);
                } catch (java.net.SocketTimeoutException ste) {
                        logger.warning("(timetable) Read timed out, train="+train);
                        response.sendError(500, "Backend timed out");
                } catch (CircuitBreakerException cbe) {
                        logger.warning("Circuitbreaker - failing fast");
                        response.sendError(500);
                }catch (Exception e) {
                        logger.log(Level.WARNING, "failure looking up timetable: train=" +train, e);
                        response.sendError(500);
                }
                
        }
        
        String lookupType(String trainCode) {
                trainCode = trainCode.toLowerCase();
                
                if (trainCode.equals("a") || trainCode.equals("b") || trainCode.equals("bx") || trainCode.equals("c") || 
                                trainCode.equals("e") || trainCode.equals("f") || trainCode.equals("h")) {
                        return "S2";
                } else {
                        return "FJRN";
                }
        }
        
        String formatTimetable(List<TimetableBean> timetable) {
                StringBuffer sb = new StringBuffer();
                
                sb.append("<timetable>");
                
                for (TimetableBean bean : timetable) {
                        sb.append("<entry");
                        if (bean.isCurrent())
                                sb.append(" current=\"true\"");
                        sb.append(">");
                        
                        sb.append("<station>").append( bean.getStation() ).append("</station>");
                        sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");
                        sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");
                        
                        sb.append("</entry>");
                }
                
                sb.append("</timetable>");
                
                return sb.toString();
        }

}
1	package dk.thoerup.traininfoservice.banedk;
2
3	import java.io.IOException;
4	import java.util.List;
5	import java.util.logging.Level;
6	import java.util.logging.Logger;
7
8	import javax.servlet.ServletException;
9	import javax.servlet.http.HttpServlet;
10	import javax.servlet.http.HttpServletRequest;
11	import javax.servlet.http.HttpServletResponse;
12
13	import dk.thoerup.curcuitbreaker.CircuitBreakerException;
14
15	/**
16	* Servlet implementation class TimetableServlet
17	*/
18	public class TimetableServlet extends HttpServlet {
19	private static final long serialVersionUID = 1L;
20
21
22	Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
23
24	TimetableFetcher fetcher = new TimetableFetcher();
25
26	@Override
27	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
28	String train = request.getParameter("train").trim();
29
30	String sections[] = train.split(" ");
31	if (sections.length != 2) {
32	response.sendError(400, "Invalid parameter");
33	return;
34	}
35
36	String type = lookupType(sections[0]);
37	String trainID = sections[1];
38	try
39	{
40	List<TimetableBean> timetable = fetcher.cachedLookupTimetable(trainID, type);
41
42	String responseXML = formatTimetable(timetable);
43
44	response.setContentType("text/xml");
45	response.getWriter().print(responseXML);
46	} catch (java.net.SocketTimeoutException ste) {
47	logger.warning("(timetable) Read timed out, train="+train);
48	response.sendError(500, "Backend timed out");
49	} catch (CircuitBreakerException cbe) {
50	logger.warning("Circuitbreaker - failing fast");
51	response.sendError(500);
52	}catch (Exception e) {
53	logger.log(Level.WARNING, "failure looking up timetable: train=" +train, e);
54	response.sendError(500);
55	}
56
57	}
58
59	String lookupType(String trainCode) {
60	trainCode = trainCode.toLowerCase();
61
62	if (trainCode.equals("a") \|\| trainCode.equals("b") \|\| trainCode.equals("bx") \|\| trainCode.equals("c") \|\|
63	trainCode.equals("e") \|\| trainCode.equals("f") \|\| trainCode.equals("h")) {
64	return "S2";
65	} else {
66	return "FJRN";
67	}
68	}
69
70	String formatTimetable(List<TimetableBean> timetable) {
71	StringBuffer sb = new StringBuffer();
72
73	sb.append("<timetable>");
74
75	for (TimetableBean bean : timetable) {
76	sb.append("<entry");
77	if (bean.isCurrent())
78	sb.append(" current=\"true\"");
79	sb.append(">");
80
81	sb.append("<station>").append( bean.getStation() ).append("</station>");
82	sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");
83	sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");
84
85	sb.append("</entry>");
86	}
87
88	sb.append("</timetable>");
89
90	return sb.toString();
91	}
92
93	}