source: MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action/WorkspaceAction.java @ 692

package eu.clarin.cmdi.mdservice.action;

import java.io.BufferedInputStream;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.StringReader;
import java.io.StringWriter;
import java.net.MalformedURLException;
import java.net.URL;

import javax.servlet.http.HttpServletRequest;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.OutputKeys;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerConfigurationException;
import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.TransformerFactoryConfigurationError;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;

import net.sf.json.JSON;
import net.sf.json.JSONSerializer;
import net.sf.json.xml.XMLSerializer;

import org.apache.commons.io.IOUtils;
import org.apache.struts2.interceptor.ServletRequestAware;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;

import com.opensymphony.xwork2.ActionSupport;

/**
 *
 * @author 
 *
 */
public class WorkspaceAction extends ActionSupport 
{

        private static final long serialVersionUID = 1L;
        
        /** 
         * Properties to be filled by Struts with according request-parameters
         */     
        private String actionkey;
        private String data;
        private String id;
        private String format;
        private String userMsg;
        
        private String base_path;
        
        public String getData() {
                return data;
        }

        public void setData(String data) {
                this.data = data;
        }

        public String getID() {
                return id;
        }

        public void setID(String _id) {
                this.id = _id;
        }
        
        public String getFormat() {
                return format;
        }

        public void setFormat(String format) {
                this.format = format;
        }
        
        public String getActionkey() {
                return actionkey;
        }

        public void setActionkey(String actionKey) {
                actionkey = actionKey;
        }

        /**
         * primitive identification of the target-proxy
         * base for finding the right base_url in the props
         * subclass has to override with its specific proxykey
         * @return
         */
        public String getProxyKey() {
                return "workspaceprofile";
        }
        
        public String getUserMsg() {
                return userMsg;
        }

        public void setUserMsg(String userMsg) {
                this.userMsg = this.userMsg + "\n" + userMsg;
        }


        private InputStream resultStream;
        private InputStream sourceStream;

        /**
         * The stream holding the resulting data to be sent back to the user as response
         * @return
         */
        public InputStream getResultStream() {
                return resultStream;
    }
        public void setResultStream(InputStream _resultStream){
                resultStream = _resultStream;
        }
        public void setSourceStream(InputStream _sourceStream){
                sourceStream = _sourceStream;
        }
        
        
        public URL getBaseURL() {
                File file=new File(getPath());
            URL url=null;
            try{
                    url=file.toURL(); 
                    Admin.notifyUser(" JSON TEST: url "  + url);
            } catch (MalformedURLException e){
                Admin.notifyUser("JSON exception has been caught" + e);
            }
            
            return url;
        }
        
        public String getBasePath() {           
                if (base_path == null) {
                        base_path = Admin.getConfig().getProperty(getProxyKey() + ".path");
                }
                return base_path;
        }
        //TODO identification of WOrkspaceProfile (user, name, id)
        public String getWorkspaceProfile() {
                return "WorkspaceProfile.xml";
        }
        
        public String getFullFormat() {
                return "xml2json";
        }
        
        public URL getURL() {
                File file=new File(getPath());
            URL url=null;
            try{
                    url=file.toURL(); 
                    //Admin.notifyUser("url "  + url);
            } catch (MalformedURLException e){
                //Admin.notifyUser("" + e);
            }
                return url;
        }
        
        
        public String getPath() {
                String targetPath = getBasePath() + getWorkspaceProfile();         
        Admin.notifyUser(targetPath);              
        return targetPath;
        }

        public InputStream getSourceStream() throws IOException {       
                InputStream stream = new BufferedInputStream( new FileInputStream(getPath()));
        
                
                return   stream;
        }
        
        public void prepare() throws Exception {                
                
                //Admin.notifyUser("execute:");
                sourceStream = getSourceStream(); 
                if (format.equals("xml")) {                     
                        resultStream = sourceStream;    
                }else { //JSON
                        // set srcFile (for MDTransformer to pass to xsl-scripts) 
                        MDTransformer.getMDTransformer().setSrcFile(getURL());
                        resultStream =  MDTransformer.getMDTransformer().transformXML(sourceStream, getFullFormat());
                }
                        
                Admin.notifyUser(getProxyKey() + " success:" + (resultStream!=null));
        }

        public void changeNodeName(Document doc, Node node, String new_name){
                // Create an element with the new name 
                Node node2 = (Node ) doc.createElement(new_name); 
                // Copy the attributes to the new element NamedNodeMap attrs = element.getAttributes(); for (int i=0; i<attrs.getLength(); i++) { Attr attr2 = (Attr)doc.importNode(attrs.item(i), true); element2.getAttributes().setNamedItem(attr2); } 
                // Move all the children 
                while (node.hasChildNodes()) { node2.appendChild(node.getFirstChild()); } 
                // Replace the old node with the new node
                Admin.notifyUser("replace:" + node2.getNodeName() + "," + node.getNodeName());
                node.getParentNode().replaceChild(node2, node); 
        }
        
        public String save(){
                
        String jsonData = getData();
        Admin.notifyUser("JSON data:"+jsonData);
        
        resultStream = null;
        
        XMLSerializer serializer = new XMLSerializer();
                JSON json = JSONSerializer.toJSON( jsonData );
                //Admin.notifyUser("test5");
                serializer.setRootName("WorkspaceProfile");
        serializer.setTypeHintsEnabled(false);
        String xml = serializer.write( json );
        Admin.notifyUser("XML:" + xml);
        
        
        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
        DocumentBuilder builder;
                try {
                        builder = factory.newDocumentBuilder();
                        try {
                                Document  document = builder.parse(new InputSource(new StringReader(xml)));
                                NodeList list = document.getElementsByTagName("e");
                                Admin.notifyUser("list:" + list.getLength());
                                while (list.getLength() > 0){
                                        Admin.notifyUser(0 + "::" + list.item(0).getNodeName() + "::" + list.item(0).getParentNode().getNodeName());
                                        if (list.item(0).getParentNode().getNodeName().equals("Queries")){
                                                changeNodeName(document, list.item(0),"Query"); 
                                        }else{
                                                if (list.item(0).getParentNode().getNodeName().equals("Querysets")){
                                                        changeNodeName(document, list.item(0),"Queryset");
                                                } else{
                                                        if (list.item(0).getParentNode().getNodeName().equals("collections")){
                                                                changeNodeName(document, list.item(0),"item");
                                                        } else {
                                                                if (list.item(0).getParentNode().getNodeName().equals("columns")){
                                                                        changeNodeName(document, list.item(0),"col");
                                                                }       
                                                        }
                                                }
                                        }
                                        list = document.getElementsByTagName("e");
                                }
                                
                                Transformer transformer;
                                try {
                                        transformer = TransformerFactory.newInstance().newTransformer();
                                        transformer.setOutputProperty(OutputKeys.INDENT, "yes");
                                        StreamResult result = new StreamResult(new StringWriter());
                                        DOMSource source = new DOMSource(document);
                                        try {
                                                transformer.transform(source, result);
                                                String xmlString = result.getWriter().toString();
                                                
                                                Admin.notifyUser("XML:" + xmlString);
                                        
                                        InputStream is_xml = new ByteArrayInputStream( xmlString.getBytes( ) );
                                        Admin.writeToFile(getPath(), is_xml);
                                        
                                        } catch (TransformerException e1) {
                                                // TODO Auto-generated catch block
                                                e1.printStackTrace();
                                        }

                                        
                                        
                                } catch (TransformerConfigurationException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                } catch (TransformerFactoryConfigurationError e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                                
                        } catch (SAXException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        } catch (IOException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                } catch (ParserConfigurationException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        
                String ret = "1";
                resultStream = new ByteArrayInputStream(ret.getBytes());
                                

                return SUCCESS;
        }
        /**
         * default Action method
         */
        public String execute() throws Exception {
                
                prepare();
                if (resultStream == null) {
                        return ERROR;   
                } else {
                        return SUCCESS;
                }               
        }
        
        

}