+ * + * resourceBase Set to replace the context resource base + + * warBase Path allowed for resource in war + * + *+ * + * + * @author Greg Wilkins (gregw) + * @author Nigel Canonizado + * + * @since Jetty 7 + */ +class BasicServlet extends HttpServlet +{ + protected final I2PAppContext _context; + protected final Log _log; + protected File _resourceBase; + private String _warBase; + + private final MimeTypes _mimeTypes; + + /** same as PeerState.PARTSIZE */ + private static final int BUFSIZE = 16*1024; + private ByteCache _cache = ByteCache.getInstance(16, BUFSIZE); + + private static final int WAR_CACHE_CONTROL_SECS = 24*60*60; + private static final int FILE_CACHE_CONTROL_SECS = 24*60*60; + + public BasicServlet() { + super(); + _context = I2PAppContext.getGlobalContext(); + _log = _context.logManager().getLog(getClass()); + _mimeTypes = new MimeTypes(); + } + + /* ------------------------------------------------------------ */ + public void init(ServletConfig cfg) throws ServletException { + super.init(cfg); + String rb=getInitParameter("resourceBase"); + if (rb!=null) + { + File f = new File(rb); + setResourceBase(f); + } + String wb = getInitParameter("warBase"); + if (wb != null) + setWarBase(wb); + } + + /** + * Files are served from here + */ + protected void setResourceBase(File base) throws UnavailableException { + if (!base.isDirectory()) + throw new UnavailableException("Resource base does not exist: " + base); + _resourceBase = base; + if (_log.shouldLog(Log.INFO)) + _log.info("Resource base is " + _resourceBase); + } + + /** + * Only paths starting with this in the path are served + */ + protected void setWarBase(String base) { + if (!base.startsWith("/")) + base = '/' + base; + if (!base.endsWith("/")) + base = base + '/'; + _warBase = base; + if (_log.shouldLog(Log.INFO)) + _log.info("War base is " + _warBase); + } + + /** get Resource to serve. + * Map a path to a resource. The default implementation calls + * HttpContext.getResource but derived servlets may provide + * their own mapping. + * @param pathInContext The path to find a resource for. + * @return The resource to serve or null if not existing + */ + public File getResource(String pathInContext) + { + if (_resourceBase==null) + return null; + File r = null; + if (!pathInContext.contains("..") && + !pathInContext.endsWith("/")) { + File f = new File(_resourceBase, pathInContext); + if (f.exists()) + r = f; + } + return r; + } + + /** get Resource to serve. + * Map a path to a resource. The default implementation calls + * HttpContext.getResource but derived servlets may provide + * their own mapping. + * @param pathInContext The path to find a resource for. + * @return The resource to serve or null. Returns null for directories + */ + public HttpContent getContent(String pathInContext) + { + if (_resourceBase==null) + return null; + HttpContent r = null; + if (_warBase != null && pathInContext.startsWith(_warBase)) { + r = new JarContent(pathInContext); + } else if (!pathInContext.contains("..") && + !pathInContext.endsWith("/")) { + File f = new File(_resourceBase, pathInContext); + // exists && !directory + if (f.isFile()) + r = new FileContent(f); + } + return r; + } + + /* ------------------------------------------------------------ */ + protected void doGet(HttpServletRequest request, HttpServletResponse response) + throws ServletException, IOException + { + // always starts with a '/' + String servletpath = request.getServletPath(); + String pathInfo=request.getPathInfo(); + // ??? right?? + String pathInContext = addPaths(servletpath, pathInfo); + + // Find the resource and content + try { + HttpContent content = getContent(pathInContext); + + // Handle resource + if (content == null) { + if (_log.shouldLog(Log.WARN)) + _log.warn("Not found: " + pathInContext); + response.sendError(404); + } else { + if (passConditionalHeaders(request, response, content)) { + if (_log.shouldLog(Log.INFO)) + _log.info("Sending: " + content); + sendData(request, response, content); + } else { + if (_log.shouldLog(Log.INFO)) + _log.info("Not modified: " + content); + } + } + } + catch(IllegalArgumentException e) + { + if (_log.shouldLog(Log.WARN)) + _log.warn("Error sending " + pathInContext, e); + if(!response.isCommitted()) + response.sendError(500, e.getMessage()); + } + catch(IOException e) + { + if (_log.shouldLog(Log.WARN)) + // typical browser abort + //_log.warn("Error sending", e); + _log.warn("Error sending " + pathInContext + ": " + e); + throw e; + } + } + + /* ------------------------------------------------------------ */ + protected void doPost(HttpServletRequest request, HttpServletResponse response) + throws ServletException, IOException + { + response.sendError(405); + } + + /* ------------------------------------------------------------ */ + /* (non-Javadoc) + * @see javax.servlet.http.HttpServlet#doTrace(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse) + */ + protected void doTrace(HttpServletRequest request, HttpServletResponse response) + throws ServletException, IOException + { + response.sendError(405); + } + + protected void doOptions(HttpServletRequest request, HttpServletResponse response) + throws ServletException, IOException + { + response.sendError(405); + } + + protected void doDelete(HttpServletRequest request, HttpServletResponse response) + throws ServletException, IOException + { + response.sendError(405); + } + + + /* ------------------------------------------------------------ */ + /** Check modification date headers. + * @return true to keep going, false if handled here + */ + protected boolean passConditionalHeaders(HttpServletRequest request,HttpServletResponse response, HttpContent content) + throws IOException + { + try + { + if (!request.getMethod().equals("HEAD") ) { + long ifmsl=request.getDateHeader("If-Modified-Since"); + if (ifmsl!=-1) + { + if (content.getLastModified()/1000 <= ifmsl/1000) + { + response.reset(); + response.setStatus(304); + response.flushBuffer(); + return false; + } + } + } + } + catch(IllegalArgumentException iae) + { + if(!response.isCommitted()) + response.sendError(400, iae.getMessage()); + throw iae; + } + return true; + } + + + /* ------------------------------------------------------------ */ + protected void sendData(HttpServletRequest request, + HttpServletResponse response, + HttpContent content) + throws IOException + { + InputStream in =null; + try { + in = content.getInputStream(); + } catch (IOException e) { + if (_log.shouldLog(Log.WARN)) + _log.warn("Not found: " + content); + response.sendError(404); + return; + } + + OutputStream out =null; + try { + out = response.getOutputStream(); + } catch (IllegalStateException e) { + out = new WriterOutputStream(response.getWriter()); + } + + // Write content normally + long content_length = content.getContentLength(); + writeHeaders(response,content,content_length); + if (content_length >= 0 && request.getMethod().equals("HEAD")) { + // if we know the content length, don't send it to be counted + if (_log.shouldLog(Log.INFO)) + _log.info("HEAD: " + content); + } else { + // GET or unknown size for HEAD + copy(in, out); + } + + return; + } + + /* ------------------------------------------------------------ */ + protected void writeHeaders(HttpServletResponse response,HttpContent content,long count) + throws IOException + { + if (content.getContentType()!=null && response.getContentType()==null) + response.setContentType(content.getContentType()); + + long lml = content.getLastModified(); + if (lml > 0) + response.setDateHeader("Last-Modified",lml); + + if (count != -1) + { + if (count
// ========================================================================
@@ -137,14 +151,11 @@ public class I2PSnarkServlet extends DefaultServlet {
*
*
*/
- @Override
- public void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+ private void doGetAndPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+ if (_log.shouldLog(Log.DEBUG))
+ _log.debug("Service " + req.getMethod() + " \"" + req.getContextPath() + "\" \"" + req.getServletPath() + "\" \"" + req.getPathInfo() + '"');
// since we are not overriding handle*(), do this here
String method = req.getMethod();
- if (!(method.equals("GET") || method.equals("HEAD") || method.equals("POST"))) {
- resp.sendError(405);
- return;
- }
_themePath = "/themes/snark/" + _manager.getTheme() + '/';
_imgPath = _themePath + "images/";
// this is the part after /i2psnark
@@ -176,17 +187,18 @@ public class I2PSnarkServlet extends DefaultServlet {
// index.jsp doesn't work, it is grabbed by the war handler before here
if (!(path == null || path.equals("/") || path.equals("/index.jsp") || path.equals("/index.html") || path.equals("/_post") || isConfigure)) {
if (path.endsWith("/")) {
+ // Listing of a torrent (torrent detail page)
// bypass the horrid Resource.getListHTML()
String pathInfo = req.getPathInfo();
- String pathInContext = URIUtil.addPaths(path, pathInfo);
+ String pathInContext = addPaths(path, pathInfo);
req.setCharacterEncoding("UTF-8");
resp.setCharacterEncoding("UTF-8");
resp.setContentType("text/html; charset=UTF-8");
- Resource resource = getResource(pathInContext);
- if (resource == null || (!resource.exists())) {
+ File resource = getResource(pathInContext);
+ if (resource == null) {
resp.sendError(404);
} else {
- String base = URIUtil.addPaths(req.getRequestURI(), "/");
+ String base = addPaths(req.getRequestURI(), "/");
String listing = getListHTML(resource, base, true, method.equals("POST") ? req.getParameterMap() : null);
if (method.equals("POST")) {
// P-R-G
@@ -198,11 +210,19 @@ public class I2PSnarkServlet extends DefaultServlet {
}
}
} else {
- super.service(req, resp);
+ // local completed files in torrent directories
+ if (method.equals("GET") || method.equals("HEAD"))
+ super.doGet(req, resp);
+ else if (method.equals("POST"))
+ super.doPost(req, resp);
+ else
+ resp.sendError(405);
}
return;
}
+ // Either the main page or /configure
+
req.setCharacterEncoding("UTF-8");
resp.setCharacterEncoding("UTF-8");
resp.setContentType("text/html; charset=UTF-8");
@@ -236,7 +256,7 @@ public class I2PSnarkServlet extends DefaultServlet {
out.write("\n" +
"\n");
}
@@ -249,18 +269,24 @@ public class I2PSnarkServlet extends DefaultServlet {
out.write("");
out.write("![\"\"](\"")
");
- out.write(_("I2PSnark"));
+ if (_contextName.equals(DEFAULT_NAME))
+ out.write(_("I2PSnark"));
+ else
+ out.write(_contextName);
out.write("");
} else {
- out.write("
");
out.write(" ");
- out.write(_("I2PSnark"));
+ if (_contextName.equals(DEFAULT_NAME))
+ out.write(_("I2PSnark"));
+ else
+ out.write(_contextName);
out.write(" ");
out.write(_("Forum"));
out.write("\n");
@@ -302,7 +328,7 @@ public class I2PSnarkServlet extends DefaultServlet {
List msgs = _manager.getMessages();
if (!msgs.isEmpty()) {
out.write("
");
- out.write(" 0)
@@ -342,7 +368,7 @@ public class I2PSnarkServlet extends DefaultServlet {
out.write(_("Status"));
out.write("\">\n");
if (_manager.util().connected() && !snarks.isEmpty()) {
- out.write(" ");
out.write("![]( "\\"\");")
![]( "\\"\");")
");
} else if ((!_manager.util().isConnecting()) && !snarks.isEmpty()) {
if (isDegraded)
- out.write("![]( "\\"\");")
![]( "\\"\");")
\n");
- String uri = "/i2psnark/";
+ String uri = _contextPath + '/';
boolean showDebug = "2".equals(peerParam);
for (int i = 0; i < snarks.size(); i++) {
Snark snark = (Snark)snarks.get(i);
@@ -1245,7 +1271,7 @@ public class I2PSnarkServlet extends DefaultServlet {
} else if (isRunning) {
// Stop Button
if (isDegraded)
- out.write("![]( "\\"\");")
![]( "\\"\");")
![]( "\\"\");")
![]( "\\"\");")
![]( "\\"\");")
![]( "\\"\");")
![]( "\\"\");")
![]( "\\"\");")
\n" +
+ out.write("