traininfoservice/banedk/TimetableServlet.java

package dk.thoerup.traininfoservice.banedk;

import java.io.IOException;
import java.io.StringWriter;

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 org.simpleframework.xml.Serializer;
import org.simpleframework.xml.core.Persister;

import dk.thoerup.android.traininfo.common.DepartureBean;
import dk.thoerup.android.traininfo.common.TimetableBean;
import dk.thoerup.circuitbreaker.CircuitBreakerException;
import dk.thoerup.traininfoservice.Statistics;
import dk.thoerup.traininfoservice.TraininfoSettings;;

/**
 * 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();
                

                TraininfoSettings settings = (TraininfoSettings) getServletContext().getAttribute("settings");
                fetcher = new TimetableFetcher(settings);
        }
        
        @Override
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                if (request.getParameter("train") == null || request.getParameter("train").equals("") ) {
                        response.sendError(400, "not enough parameters (train)");
                        return;
                }
                if (request.getParameter("type") == null || request.getParameter("type").equals("") ) {
                        response.sendError(400, "not enough parameters (type)");
                        return;
                }
                Statistics.getInstance().incrementTimetableLookups();
                
                String train = request.getParameter("train").trim();
                String type = request.getParameter("type").trim();
                        
                
                TimetableBean timetable = null;
                try
                {
                        timetable = fetcher.cachedLookupTimetable(train, type);
                
                } catch (java.io.IOException ioe) {
                        logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
                        Statistics.getInstance().incrementTimetableErrors();
                        //timetable = generateErrorBean(1);
                        response.sendError( 500, "Backend didn't answer" );
                } catch (CircuitBreakerException cbe) {
                        logger.warning("Circuitbreaker - failing fast, type=" + type + ", train="+train);
                        Statistics.getInstance().incrementTimetableErrors();                    
                        timetable = generateErrorBean(1);
                }catch (Exception e) {
                        logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
                        Statistics.getInstance().incrementTimetableErrors();
                        response.sendError(500);
                }
                
                if (timetable != null) {
                        String responseXML = formatTimetable(timetable);
                
                        response.setContentType("text/xml");
                        response.getWriter().print(responseXML);
                }
                
        }
        
        protected TimetableBean generateErrorBean(int code) {
                TimetableBean bean = new TimetableBean();               
                bean.errorCode = code;
                return bean;
        }
        
        String formatTimetable(TimetableBean timetable) throws ServletException {
                Serializer serializer = new Persister();

                StringWriter out = new StringWriter();

                try {
                        serializer.write(timetable, out);
                } catch (Exception e) {
                        throw new ServletException(e);
                }
                
                return out.toString();
        }

}
1	torben	350	package dk.thoerup.traininfoservice.banedk;
2
3			import java.io.IOException;
4	torben	1190	import java.io.StringWriter;
5	torben	1060
6	torben	378	import java.util.logging.Level;
7	torben	350	import java.util.logging.Logger;
8
9			import javax.servlet.ServletException;
10	torben	958	import javax.servlet.annotation.WebServlet;
11	torben	350	import javax.servlet.http.HttpServlet;
12			import javax.servlet.http.HttpServletRequest;
13			import javax.servlet.http.HttpServletResponse;
14
15	torben	1060	import org.simpleframework.xml.Serializer;
16			import org.simpleframework.xml.core.Persister;
17
18	torben	1373	import dk.thoerup.android.traininfo.common.DepartureBean;
19	torben	1061	import dk.thoerup.android.traininfo.common.TimetableBean;
20	torben	468	import dk.thoerup.circuitbreaker.CircuitBreakerException;
21	torben	711	import dk.thoerup.traininfoservice.Statistics;
22	torben	1303	import dk.thoerup.traininfoservice.TraininfoSettings;;
23	torben	421
24	torben	350	/**
25			* Servlet implementation class TimetableServlet
26			*/
27	torben	958	@WebServlet(urlPatterns={"/TimetableServlet"})
28	torben	350	public class TimetableServlet extends HttpServlet {
29			private static final long serialVersionUID = 1L;
30
31
32			Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
33
34	torben	581	TimetableFetcher fetcher;
35	torben	350
36	torben	1026
37	torben	425	@Override
38	torben	581	public void init() throws ServletException {
39			super.init();
40
41	torben	1303
42			TraininfoSettings settings = (TraininfoSettings) getServletContext().getAttribute("settings");
43			fetcher = new TimetableFetcher(settings);
44	torben	581	}
45
46			@Override
47	torben	350	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
48	torben	1801	if (request.getParameter("train") == null \|\| request.getParameter("train").equals("") ) {
49	torben	717	response.sendError(400, "not enough parameters (train)");
50	torben	458	return;
51			}
52	torben	1801	if (request.getParameter("type") == null \|\| request.getParameter("type").equals("") ) {
53	torben	717	response.sendError(400, "not enough parameters (type)");
54			return;
55			}
56	torben	711	Statistics.getInstance().incrementTimetableLookups();
57	torben	458
58	torben	350	String train = request.getParameter("train").trim();
59	torben	717	String type = request.getParameter("type").trim();
60	torben	1373
61
62			TimetableBean timetable = null;
63	torben	350	try
64			{
65	torben	1373	timetable = fetcher.cachedLookupTimetable(train, type);
66	torben	350
67	torben	462	} catch (java.io.IOException ioe) {
68	torben	717	logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
69	torben	716	Statistics.getInstance().incrementTimetableErrors();
70	torben	1396	//timetable = generateErrorBean(1);
71			response.sendError( 500, "Backend didn't answer" );
72	torben	421	} catch (CircuitBreakerException cbe) {
73	torben	1158	logger.warning("Circuitbreaker - failing fast, type=" + type + ", train="+train);
74	torben	1373	Statistics.getInstance().incrementTimetableErrors();
75			timetable = generateErrorBean(1);
76	torben	451	}catch (Exception e) {
77	torben	717	logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
78	torben	716	Statistics.getInstance().incrementTimetableErrors();
79	torben	378	response.sendError(500);
80	torben	350	}
81
82	torben	1373	if (timetable != null) {
83			String responseXML = formatTimetable(timetable);
84
85			response.setContentType("text/xml");
86			response.getWriter().print(responseXML);
87			}
88
89	torben	350	}
90
91	torben	1373	protected TimetableBean generateErrorBean(int code) {
92			TimetableBean bean = new TimetableBean();
93			bean.errorCode = code;
94			return bean;
95			}
96
97	torben	1060	String formatTimetable(TimetableBean timetable) throws ServletException {
98			Serializer serializer = new Persister();
99
100	torben	1190	StringWriter out = new StringWriter();
101	torben	1060
102			try {
103			serializer.write(timetable, out);
104			} catch (Exception e) {
105			throw new ServletException(e);
106	torben	350	}
107
108	torben	1060	return out.toString();
109	torben	350	}
110
111			}