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.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import dk.thoerup.circuitbreaker.CircuitBreakerException;
import dk.thoerup.traininfoservice.Statistics;

/**
 * Servlet implementation class TimetableServlet
 */
@WebServlet(urlPatterns={"/TimetableServlet"})
public class TimetableServlet extends HttpServlet {
        private static final long serialVersionUID = 1L;
       
        
        Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
        
        TimetableFetcher fetcher;
        
        
        @Override
        public void init() throws ServletException {
                super.init();
                
                boolean useAzureSite =  Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );
                int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
                int replyTimeout =  Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );
                logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);
                fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);
        }
        
        @Override
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                if (request.getParameter("train") == null) {
                        response.sendError(400, "not enough parameters (train)");
                        return;
                }
                if (request.getParameter("type") == null) {
                        response.sendError(400, "not enough parameters (type)");
                        return;
                }
                Statistics.getInstance().incrementTimetableLookups();
                
                String train = request.getParameter("train").trim();
                String type = request.getParameter("type").trim();
                                
                try
                {
                        List<TimetableBean> timetable = fetcher.cachedLookupTimetable(train, type);
                
                        String responseXML = formatTimetable(timetable);
                
                        response.setContentType("text/xml");
                        response.getWriter().print(responseXML);
                } catch (java.io.IOException ioe) {
                        logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
                        Statistics.getInstance().incrementTimetableErrors();
                        response.sendError(500, "Backend timed out");
                } catch (CircuitBreakerException cbe) {
                        logger.warning("Circuitbreaker - failing fast");
                        Statistics.getInstance().incrementTimetableErrors();
                        response.sendError(500);
                }catch (Exception e) {
                        logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
                        Statistics.getInstance().incrementTimetableErrors();
                        response.sendError(500);
                }
                
        }
        
        String formatTimetable(List<TimetableBean> timetable) {
                StringBuffer sb = new StringBuffer();
                //sb.append("<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>\n");
                
                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("<stationid>").append( bean.getStationId() ).append("</stationid>");
                        //sb.append("<cancelled>").append( bean.isCancelled() ).append("</cancelled>");
                        sb.append("</entry>");
                }
                
                sb.append("</timetable>");
                
                return sb.toString();
        }

}
1	torben	350	package dk.thoerup.traininfoservice.banedk;
2
3			import java.io.IOException;
4			import java.util.List;
5	torben	378	import java.util.logging.Level;
6	torben	350	import java.util.logging.Logger;
7
8			import javax.servlet.ServletException;
9	torben	958	import javax.servlet.annotation.WebServlet;
10	torben	350	import javax.servlet.http.HttpServlet;
11			import javax.servlet.http.HttpServletRequest;
12			import javax.servlet.http.HttpServletResponse;
13
14	torben	468	import dk.thoerup.circuitbreaker.CircuitBreakerException;
15	torben	711	import dk.thoerup.traininfoservice.Statistics;
16	torben	421
17	torben	350	/**
18			* Servlet implementation class TimetableServlet
19			*/
20	torben	958	@WebServlet(urlPatterns={"/TimetableServlet"})
21	torben	350	public class TimetableServlet extends HttpServlet {
22			private static final long serialVersionUID = 1L;
23
24
25			Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
26
27	torben	581	TimetableFetcher fetcher;
28	torben	350
29	torben	1026
30	torben	425	@Override
31	torben	581	public void init() throws ServletException {
32			super.init();
33
34	torben	1036	boolean useAzureSite = Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );
35	torben	584	int cacheTimeout = Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
36	torben	1026	int replyTimeout = Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );
37	torben	1036	logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);
38			fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);
39	torben	581	}
40
41			@Override
42	torben	350	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
43	torben	458	if (request.getParameter("train") == null) {
44	torben	717	response.sendError(400, "not enough parameters (train)");
45	torben	458	return;
46			}
47	torben	717	if (request.getParameter("type") == null) {
48			response.sendError(400, "not enough parameters (type)");
49			return;
50			}
51	torben	711	Statistics.getInstance().incrementTimetableLookups();
52	torben	458
53	torben	350	String train = request.getParameter("train").trim();
54	torben	717	String type = request.getParameter("type").trim();
55	torben	697
56	torben	350	try
57			{
58	torben	717	List<TimetableBean> timetable = fetcher.cachedLookupTimetable(train, type);
59	torben	350
60			String responseXML = formatTimetable(timetable);
61
62			response.setContentType("text/xml");
63			response.getWriter().print(responseXML);
64	torben	462	} catch (java.io.IOException ioe) {
65	torben	717	logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
66	torben	716	Statistics.getInstance().incrementTimetableErrors();
67	torben	378	response.sendError(500, "Backend timed out");
68	torben	421	} catch (CircuitBreakerException cbe) {
69			logger.warning("Circuitbreaker - failing fast");
70	torben	716	Statistics.getInstance().incrementTimetableErrors();
71	torben	421	response.sendError(500);
72	torben	451	}catch (Exception e) {
73	torben	717	logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
74	torben	716	Statistics.getInstance().incrementTimetableErrors();
75	torben	378	response.sendError(500);
76	torben	350	}
77
78			}
79
80			String formatTimetable(List<TimetableBean> timetable) {
81			StringBuffer sb = new StringBuffer();
82	torben	859	//sb.append("<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>\n");
83	torben	350
84			sb.append("<timetable>");
85
86			for (TimetableBean bean : timetable) {
87			sb.append("<entry");
88			if (bean.isCurrent())
89			sb.append(" current=\"true\"");
90			sb.append(">");
91
92			sb.append("<station>").append( bean.getStation() ).append("</station>");
93			sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");
94			sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");
95	torben	836	sb.append("<stationid>").append( bean.getStationId() ).append("</stationid>");
96	torben	975	//sb.append("<cancelled>").append( bean.isCancelled() ).append("</cancelled>");
97	torben	350	sb.append("</entry>");
98			}
99
100			sb.append("</timetable>");
101
102			return sb.toString();
103			}
104
105			}