package com.extensions;import java.io.IOException;import java.io.File;import java.io.PrintWriter;import java.io.FileOutputStream;import java.io.FileInputStream;import java.io.OutputStream;import javax.servlet.ServletException;import javax.servlet.ServletContext;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpSession;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import java.util.zip.ZipEntry;import java.util.zip.ZipFile;import java.util.zip.ZipInputStream;import java.util.StringTokenizer;public class ExtractZipsServlet extends HttpServlet { protected void processRequest(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { final Log log = LogFactory.getLog(ExtractZipsServlet.class); log.debug("Extract archives..."); StringBuffer answer = new StringBuffer(); int entryStart = 0; int entryEnd = 0; int endupEntries = 0; boolean notAcceptable = false; final String[] extensions = {".exe", ".bat", ".sh", ".jar", ".zip", ".rar", ".ace"}; String extension = ""; ServletContext servletContext = null; String clientEmail = null; PrintWriter out = response.getWriter(); response.setContentType("text/xml"); response.setHeader("Cache-Control", "no-cache"); response.setHeader("Pragma", "No-cache"); response.setDateHeader("Expires",0); HttpSession session = request.getSession(false); if(session != null) { servletContext = request.getSession(false).getServletContext(); clientEmail = (String)(session.getAttribute("email")); } String arhName = request.getParameter("arh_name"); String entryS = request.getParameter("entry_start"); String entryE = request.getParameter("entry_end"); String endupentries = request.getParameter("endupentries"); if(entryS != null) { entryStart = Integer.valueOf(entryS); } if(entryE != null) { entryEnd = Integer.valueOf(entryE); } if(endupentries != null) { endupEntries = Integer.valueOf(endupentries); } try{ if(clientEmail != null) { String strDirectory = clientEmail+"DAT"; // Extract the DAT archives File file = new File(servletContext.getRealPath( "//WEB-INF//users//"+strDirectory+"//" + arhName)); if(file.exists()) { if((entryStart != entryEnd)&&(entryEnd != 0)) { FileInputStream fileInputStream = new FileInputStream(file); ZipInputStream zipInputStream = new ZipInputStream(fileInputStream); int skipentry = 0; int nextentry = entryStart; ZipEntry entry = zipInputStream.getNextEntry(); while((skipentry < entryStart)&&(entry != null)) { entry = zipInputStream.getNextEntry(); skipentry++; } notAcceptable = false; extension = ""; if(entry != null) { extension = (entry.getName()).substring( (entry.getName()).length() - 4, (entry.getName()).length()); } for(int i = 0; i < extensions.length; i++) { if((entry != null) && (extension.equalsIgnoreCase(extensions[i]))) { notAcceptable = true; break; } } do { if(!entry.isDirectory()&&(notAcceptable == false)) { String fileName = ""; StringTokenizer stringTokenizer = new StringTokenizer(entry.getName(),"//"); while(stringTokenizer.hasMoreTokens()) { fileName = stringTokenizer.nextToken(); } OutputStream outputStream = new FileOutputStream(servletContext.getRealPath( "//WEB-INF//users//"+strDirectory+"//" + fileName)); byte[] buffer = new byte[1024]; int len; while ((len = zipInputStream.read(buffer)) > 0) { outputStream.write(buffer, 0, len); } try { if(outputStream != null) {outputStream.close();} } catch (Exception ex) { log.error("I can't close the stream ..."); } } try { Thread.sleep(50); } catch (Exception ex) {} entry = zipInputStream.getNextEntry(); nextentry ++; notAcceptable = false; extension = ""; if(entry != null) { extension = (entry.getName()).substring( (entry.getName()).length() - 4, (entry.getName()).length()); } for(int i = 0; i < extensions.length; i++) { if((entry != null) && (extension.equalsIgnoreCase(extensions[i]))) { notAcceptable = true; break; } } if (((nextentry == entryEnd) && (entryEnd == endupEntries) && (endupEntries != 0))|| (((nextentry + 1) == entryEnd) && (entryEnd > endupEntries) && (endupEntries != 0))) { try { if(zipInputStream != null) { zipInputStream.close();} } catch (Exception ex) { log.error("I can't close the stream ..."); } try { if(fileInputStream != null) { fileInputStream.close();} } catch (Exception ex) { log.error("I can't close the stream ..."); } try { Thread.sleep(100); file.delete(); } catch (Exception ex) { log.error("I can't delete this archive " + file.getName() + "..."); } break; } try { Thread.sleep(100); } catch (Exception ex) {} } while((nextentry < entryEnd)&&(entry != null)); try { if(zipInputStream != null) { zipInputStream.close();} } catch (Exception ex) { log.error("I can't close the stream ..."); } try { if(fileInputStream != null) { fileInputStream.close();} } catch (Exception ex) { log.error("I can't close the stream ..."); } answer.append(" "); } else { ZipFile zipFile = new ZipFile(file); int zipsize = zipFile.size(); int chunksize = (int)(zipsize/10); //if there are less than 10 files if(chunksize == 0) { chunksize = 1; } answer.append("" + zipsize + " " + chunksize + " "); try{ zipFile.close(); } catch (Exception ex) { log.error("Unable to close zip file ..."); } } } else { answer.append( ""+ ""+ "The last message: "+ "Sorry, but the " + arhName + " doesn't exist (the extract process stops here) ..." + ""); } } else { answer.append( ""+ ""+ "The last message: "+ "Sorry, but you are not logged in ..."+ ""); } out.println(answer); } catch(Exception e) { log.error("An unexpected error occured ..."); answer.delete(0, answer.length()); answer.append( ""+ ""+ "The last message: "+ "Sorry, but an unexepected error ocurred ..."+ ""); out.println(answer); } finally { if(out != null) {out.close();} } } /** Handles the HTTP GET
method. * @param request servlet request * @param response servlet response */ protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { processRequest(request, response); } /** Handles the HTTP POST
method. * @param request servlet request * @param response servlet response */ protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { processRequest(request, response); } /** Returns a short description of the servlet. */ public String getServletInfo() { return "Short description"; }}


Is Blockchain Tech Integral to AI’s Development?
The tech world is a rapidly evolving landscape where it feels as if the next exciting breakthrough is just around the corner. Technology is advancing