/[projects]/android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/TimetableServlet.java
ViewVC logotype

Diff of /android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/TimetableServlet.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 711 by torben, Wed May 5 20:11:03 2010 UTC revision 1158 by torben, Mon Oct 4 05:51:55 2010 UTC
# Line 1  Line 1 
1  package dk.thoerup.traininfoservice.banedk;  package dk.thoerup.traininfoservice.banedk;
2    
3    import java.io.ByteArrayOutputStream;
4  import java.io.IOException;  import java.io.IOException;
5  import java.util.List;  
6  import java.util.logging.Level;  import java.util.logging.Level;
7  import java.util.logging.Logger;  import java.util.logging.Logger;
8    
9  import javax.servlet.ServletException;  import javax.servlet.ServletException;
10    import javax.servlet.annotation.WebServlet;
11  import javax.servlet.http.HttpServlet;  import javax.servlet.http.HttpServlet;
12  import javax.servlet.http.HttpServletRequest;  import javax.servlet.http.HttpServletRequest;
13  import javax.servlet.http.HttpServletResponse;  import javax.servlet.http.HttpServletResponse;
14    
15    import org.simpleframework.xml.Serializer;
16    import org.simpleframework.xml.core.Persister;
17    
18    import dk.thoerup.android.traininfo.common.TimetableBean;
19  import dk.thoerup.circuitbreaker.CircuitBreakerException;  import dk.thoerup.circuitbreaker.CircuitBreakerException;
20  import dk.thoerup.traininfoservice.Statistics;  import dk.thoerup.traininfoservice.Statistics;
21    
22  /**  /**
23   * Servlet implementation class TimetableServlet   * Servlet implementation class TimetableServlet
24   */   */
25    @WebServlet(urlPatterns={"/TimetableServlet"})
26  public class TimetableServlet extends HttpServlet {  public class TimetableServlet extends HttpServlet {
27          private static final long serialVersionUID = 1L;          private static final long serialVersionUID = 1L;
28                
# Line 24  public class TimetableServlet extends Ht Line 31  public class TimetableServlet extends Ht
31                    
32          TimetableFetcher fetcher;          TimetableFetcher fetcher;
33                    
34            
35          @Override          @Override
36          public void init() throws ServletException {          public void init() throws ServletException {
37                  super.init();                  super.init();
38                                    
39                  boolean useTempSite =  Boolean.parseBoolean( getServletContext().getInitParameter("usetempsite") );                  boolean useAzureSite =  Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );
40                  int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );                  int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
41                  logger.info( "TimetableServlet, use temp site=" + useTempSite + ", cache=" + cacheTimeout);                  int replyTimeout =  Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );
42                  fetcher = new TimetableFetcher(useTempSite,cacheTimeout);                  logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);
43                    fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);
44          }          }
45                    
46          @Override          @Override
47          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
48                  if (request.getParameter("train") == null) {                  if (request.getParameter("train") == null) {
49                          response.sendError(400, "not enough parameters");                          response.sendError(400, "not enough parameters (train)");
50                            return;
51                    }
52                    if (request.getParameter("type") == null) {
53                            response.sendError(400, "not enough parameters (type)");
54                          return;                          return;
55                  }                  }
56                  Statistics.getInstance().incrementTimetableLookups();                  Statistics.getInstance().incrementTimetableLookups();
57                                    
58                  String train = request.getParameter("train").trim();                  String train = request.getParameter("train").trim();
59                  String trainID;                  String type = request.getParameter("type").trim();
                 String type = request.getParameter("type");  
                   
                 if (type != null) {  
                          trainID = train;  
                 } else { //remove this failover sometime after release of client 0.6.4  
                         String sections[] = train.split(" ");  
                         if (sections.length != 2) {  
                                 response.sendError(400, "Invalid parameter");  
                                 return;  
                         }  
60                                                                    
                         type = lookupType(sections[0]);  
                         trainID = sections[1];  
                 }  
                   
61                  try                  try
62                  {                  {
63                          List<TimetableBean> timetable = fetcher.cachedLookupTimetable(trainID, type);                          TimetableBean timetable = fetcher.cachedLookupTimetable(train, type);
64                                    
65                          String responseXML = formatTimetable(timetable);                          String responseXML = formatTimetable(timetable);
66                                    
67                          response.setContentType("text/xml");                          response.setContentType("text/xml");
68                          response.getWriter().print(responseXML);                          response.getWriter().print(responseXML);
69                  } catch (java.io.IOException ioe) {                  } catch (java.io.IOException ioe) {
70                          logger.warning("(timetable) Read failed, train="+train + ". " + ioe.getMessage());                          logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
71                            Statistics.getInstance().incrementTimetableErrors();
72                          response.sendError(500, "Backend timed out");                          response.sendError(500, "Backend timed out");
73                  } catch (CircuitBreakerException cbe) {                  } catch (CircuitBreakerException cbe) {
74                          logger.warning("Circuitbreaker - failing fast");                          logger.warning("Circuitbreaker - failing fast, type=" + type + ", train="+train);
75                            Statistics.getInstance().incrementTimetableErrors();
76                          response.sendError(500);                          response.sendError(500);
77                  }catch (Exception e) {                  }catch (Exception e) {
78                          logger.log(Level.WARNING, "failure looking up timetable: train=" +train, e);                          logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
79                            Statistics.getInstance().incrementTimetableErrors();
80                          response.sendError(500);                          response.sendError(500);
81                  }                  }
82                                    
83          }          }
         /*remove /outcomment/deprecate after 0.6.4 release */  
         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";  
                 }  
         }  
84                    
85          String formatTimetable(List<TimetableBean> timetable) {          String formatTimetable(TimetableBean timetable) throws ServletException {
86                  StringBuffer sb = new StringBuffer();                  Serializer serializer = new Persister();
87                    
88                  sb.append("<timetable>");                  ByteArrayOutputStream out = new ByteArrayOutputStream();
89                    
90                  for (TimetableBean bean : timetable) {                  try {
91                          sb.append("<entry");                          serializer.write(timetable, out);
92                          if (bean.isCurrent())                  } catch (Exception e) {
93                                  sb.append(" current=\"true\"");                          throw new ServletException(e);
                         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>");  
94                  }                  }
95                                    
96                  sb.append("</timetable>");                  return out.toString();
                   
                 return sb.toString();  
97          }          }
98    
99  }  }
Legend:
Removed from v.711  
changed lines
  Added in v.1158
  ViewVC Help
Powered by ViewVC 1.1.20