Changeset 7832 for mauRepo/NewmoonJSP

Timestamp:

24/01/11 17:15:15 (9 years ago)

Author:

mnagni

Message:

 

Location:

mauRepo/NewmoonJSP/src/main/java/ndg/newmoon/web

Files:

• NewmoonContextListener.java (modified) (3 diffs)
• XMIEncoderBean.java (modified) (1 diff)
• XMIEncoderHelper.java (added)

mauRepo/NewmoonJSP/src/main/java/ndg/newmoon/web/NewmoonContextListener.java

@@ -12 +12 @@
 public class NewmoonContextListener implements ServletContextListener {
         
-        public static final String EXIST_HOME = "exist.home";
+        //public static final String EXIST_HOME = "exist.home";
         public static final String TMP_DIR = "tmp.dir";
+        public static final String NM_RULES_CONFORMANCE = "nm.rules.conformance";
+        public static final String NM_RULES_SCHEMA_ENCODING = "nm.rules.schema.encoding";
+        public static final String NM_REPORT_STYLESHEET = "nm.report.schema";
 
         /**
@@ -21 +24 @@
         
         public void contextDestroyed(ServletContextEvent event) {
-                System.clearProperty(EXIST_HOME);               
+                //System.clearProperty(EXIST_HOME);             
                 try {
                         DBManager.getInstance().stopExist();
@@ -30 +33 @@
 
         public void contextInitialized(ServletContextEvent event) {
+                /*
                 System.setProperty(EXIST_HOME, event.getServletContext().getRealPath("/") + "WEB-INF/existData");
                 if (LOG.isInfoEnabled()) {
                         LOG.info("System property exist.home set to " + System.getProperty(EXIST_HOME));
                 }
-                event.getServletContext().setAttribute(TMP_DIR, event.getServletContext().getRealPath("/") + "WEB-INF/tmpDir");
+                */
+                
+                String webInfPath = event.getServletContext().getRealPath("/WEB-INF");
+                event.getServletContext().setAttribute(TMP_DIR, webInfPath + "/tmpDir");
                 if (LOG.isInfoEnabled()) {
                         LOG.info("ServletContext attribute tmp.dir set to " + event.getServletContext().getAttribute(TMP_DIR));
                 }
+                event.getServletContext().setAttribute(NM_RULES_CONFORMANCE, webInfPath + "/rules/conformance-test");
+                event.getServletContext().setAttribute(NM_RULES_SCHEMA_ENCODING, webInfPath + "/rules/schema-encoding");
+                event.getServletContext().setAttribute(NM_REPORT_STYLESHEET, webInfPath + "/resources/conf-test/results-stylesheet.xsl");
         }
 

mauRepo/NewmoonJSP/src/main/java/ndg/newmoon/web/XMIEncoderBean.java

@@ -2 +2 @@
 
 import java.io.File;
-import java.io.FileFilter;
-import java.io.FileOutputStream;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
 import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Enumeration;
-import java.util.List;
-import java.util.zip.ZipEntry;
-import java.util.zip.ZipException;
-import java.util.zip.ZipFile;
+import java.io.InputStream;
+import java.io.OutputStream;
 
+import javax.faces.context.ExternalContext;
 import javax.faces.context.FacesContext;
 import javax.servlet.ServletContext;
+import javax.servlet.http.HttpServletResponse;
 
 import ndg.services.newmoon.NewmoonException;
-import ndg.services.newmoon.XMIEncoder;
-import ndg.services.newmoon.NewmoonManager.GML_VERSION;
 
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.io.FilenameUtils;
 import org.apache.commons.io.IOUtils;
-import org.apache.commons.io.filefilter.AndFileFilter;
-import org.apache.commons.io.filefilter.DirectoryFileFilter;
-import org.apache.commons.io.filefilter.IOFileFilter;
-import org.apache.commons.io.filefilter.NotFileFilter;
-import org.apache.commons.io.filefilter.RegexFileFilter;
 import org.richfaces.event.FileUploadEvent;
 import org.richfaces.model.UploadedFile;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class XMIEncoderBean {
 
-        private static GML_VERSION gmlVersion = GML_VERSION.v3_2;
-        
-        private String getTempDir() {
-                ServletContext context = (ServletContext)FacesContext.getCurrentInstance().getExternalContext().getContext();
-                return (String)context.getAttribute(NewmoonContextListener.TMP_DIR);
+        private XMIEncoderHelper helper = null;
+        private boolean encodeReady = false;
+
+        private static final ServletContext sc = (ServletContext) FacesContext.getCurrentInstance().getExternalContext()
+                        .getContext();
+
+        /**
+         * Logger for this class.
+         */
+        private static final Logger LOG = LoggerFactory.getLogger(XMIEncoderBean.class);
+
+        public void xmiListener(FileUploadEvent event) throws NewmoonException {
+                UploadedFile requestItem = event.getUploadedFile();
+                File requestTmpDir = new File((String) sc.getAttribute(NewmoonContextListener.TMP_DIR),
+                                FilenameUtils.getBaseName(requestItem.getName()));
+
+                if (requestTmpDir.exists()) {
+                        try {
+                                FileUtils.deleteDirectory(requestTmpDir);
+                        } catch (IOException e) {
+                                LOG.warn("Problems to cleanup the tempDir", e);
+                        }
+                }
+
+                requestTmpDir.mkdir();
+                File zipRequest = new File(requestTmpDir, requestItem.getName());
+                try {
+                        FileUtils.writeByteArrayToFile(zipRequest, requestItem.getData());
+                } catch (IOException e) {
+                        throw new NewmoonException("Upload error", e);
+                }
+                helper = new XMIEncoderHelper(zipRequest);
+                new Thread(helper).start();
         }
 
-        public void xmiListener(FileUploadEvent event) throws NewmoonException {
-                UploadedFile item = event.getUploadedFile();
-                File tmpDir = new File(getTempDir(), FilenameUtils.getBaseName(item.getName()));
-                tmpDir.mkdir();
-                File zip = new File(tmpDir, item.getName());
+        public boolean isEncodeReady() {
+                return helper != null ? helper.isEncodeReady() : false;
+        }
+
+        public void downloadZip(OutputStream out, Object data) throws IOException {
+                //data is the item passed throught the VALUE attribute in the a4j:mediaOutput
+                //actually is not used
+                boolean delete = false;
+                if (helper == null)
+                        return;
                 try {
-                        FileUtils.writeByteArrayToFile(zip, item.getData());
-                        unzipPackage(zip, tmpDir);
-                        encodePackage(new File(tmpDir, FilenameUtils.getBaseName(item.getName())));
-                        FileUtils.deleteDirectory(tmpDir);
-                } catch (IOException e) {
-                        throw new NewmoonException("Encoding error", e);
+                        finalizeResponse(helper.getZipResponse(), out);
+                        delete = true;
+                } finally {
+                        if (delete) {
+                                FileUtils.deleteDirectory(helper.getRequestTmpDir());
+                                helper = null;
+                                encodeReady = false;
+                        }
                 }
         }
 
-        private void encodePackage(File tmpDir) throws IOException, NewmoonException {
-                File register = null;
-                File xmi = null;
+        private void finalizeResponse(File zipFile, OutputStream output) throws IOException {
+                // Prepare.
+                byte[] zip;
+                zip = IOUtils.toByteArray(new FileInputStream(zipFile));
 
-                FileFilter ff = new RegexFileFilter("\\A.+-register\\..+\\Z");
-                File[] regs = tmpDir.listFiles(ff);
-                if (regs == null || regs.length != 1) {
-                        throw new IOException("none or more than one register");
-                }
-                register = regs[0];
+                FacesContext facesContext = FacesContext.getCurrentInstance();
+                ExternalContext externalContext = facesContext.getExternalContext();
+                HttpServletResponse response = (HttpServletResponse) externalContext.getResponse();
 
-                List<IOFileFilter> ffs = new ArrayList<IOFileFilter>();
-                ffs.add(new NotFileFilter((IOFileFilter) ff));
-                ffs.add(new NotFileFilter(DirectoryFileFilter.DIRECTORY));              
+                response.reset();
+                response.setContentType("application/zip");
+                response.setHeader("Content-disposition", "attachment; filename=\"" + zipFile.getName() + "\"");
 
-                File[] xmis = tmpDir.listFiles((FileFilter)new AndFileFilter(ffs));
-                if (xmis == null || xmis.length != 1) {
-                        throw new IOException("none or more than one xmi");
-                }
-                xmi = xmis[0];
-
-                XMIEncoder encoder = new XMIEncoder();
-                String workingPath = FilenameUtils.getBaseName(FilenameUtils.getFullPathNoEndSeparator(xmi.getPath()));
-
-                List<String> encFilePaths = encoder.doEncode(xmi, FilenameUtils.getName(register.getPath()),
-                                workingPath, gmlVersion, FilenameUtils.getBaseName(xmi.getPath()));
-                for (String filePath : encFilePaths) {
-                        System.out.println(filePath);
-                }               
-        }
-
-        private void unzipPackage(File is, File tmpDir) throws ZipException, IOException {
-                ZipFile zipFile = new ZipFile(is);
-
-                if (!tmpDir.isDirectory()) {
-                        throw new IOException("tmpDir is not a Directory");
-                }
-
-                Enumeration<? extends ZipEntry> zipen = zipFile.entries();
-                ZipEntry item = null;
-                String base = tmpDir.getPath() + File.separatorChar;
-                while (zipen.hasMoreElements()) {
-                        item = zipen.nextElement();
-
-                        if (item.isDirectory()) {
-                                (new File(base + item.getName())).mkdir();
-                                continue;
-                        }
-
-                        // System.err.println("Extracting file: " + item.getName());
-                        IOUtils.copy(zipFile.getInputStream(item), new FileOutputStream(base + item.getName()));
-                }
+                // Write file to response.
+                //OutputStream output;
+                //output = response.getOutputStream();
+                output.write(zip);
+                output.flush();
+                output.close();
+                // facesContext.responseComplete();
         }
 }