source: cats/shared/mod-SLOOT/trunk/nk/src/DBXEngine.java @ 3456

package sloot;

import com.ten60.netkernel.urii.*;
import com.ten60.netkernel.urii.aspect.IAspectBoolean;
import org.ten60.netkernel.xml.xahelper.*;
import org.ten60.netkernel.xml.xda.*;
import org.ten60.netkernel.xml.representation.*;


import org.ten60.netkernel.layer1.nkf.*;
import org.ten60.netkernel.layer1.nkf.impl.*;
import org.ten60.netkernel.layer1.representation.*;
import org.ten60.netkernel.layer1.meta.DependencyMeta;

import java.util.*;
import java.util.regex.*;
import java.net.URI;

import org.w3c.dom.*;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.transform.*;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;

import net.sf.saxon.s9api.*;

/**
 * Evaluate the DBX guide document.
 * @author maw
 */
public class DBXEngine extends NKFAccessorImpl {

        /** Creates a new instance of the DBX Engine */
        public DBXEngine() {
                super(4, SAFE_FOR_CONCURRENT_USE, INKFRequestReadOnly.RQT_SOURCE);
        }

        public void processRequest(INKFConvenienceHelper nk) throws Exception {
                sloot.dbx.Engine engine = new sloot.dbx.Engine();
                
                // get the NK request
                INKFRequestReadOnly nkreq = nk.getThisRequest();
                
                // set NK context
                engine.setNKContext(nk);
                
                // determine debug flag
                boolean debug = false;
                if (nkreq.argumentExists("debug")) {
                        String val = "" + debug;
                        String paramURI = nkreq.getArgument("debug");
                        if (paramURI.startsWith("data:text/plain,"))
                                val = paramURI.substring(("data:text/plain,").length(),paramURI.length());
                        else {
                                IXAspect param = (IXAspect)nk.sourceAspect(paramURI, IXAspect.class);
                                val = param.getXDA().getText(".",true);
                        }
                        debug = (val.equals("true") || val.equals("t"));
                }
                engine.setDebug(debug);
                
                // determine trace flag
                boolean trace = false;
                if (nkreq.argumentExists("trace")) {
                        String val = "" + trace;
                        String paramURI = nkreq.getArgument("trace");
                        if (paramURI.startsWith("data:text/plain,"))
                                val = paramURI.substring(("data:text/plain,").length(),paramURI.length());
                        else {
                                IXAspect param = (IXAspect)nk.sourceAspect(paramURI, IXAspect.class);
                                val = param.getXDA().getText(".",true);
                        }
                        trace = (val.equals("true") || val.equals("t"));
                }
                engine.setTrace(trace);

                // determine strict flag
                boolean strict = true;
                if (nkreq.argumentExists("strict")) {
                        String val = "" + strict;
                        String paramURI = nkreq.getArgument("strict");
                        if (paramURI.startsWith("data:text/plain,"))
                                val = paramURI.substring(("data:text/plain,").length(),paramURI.length());
                        else {
                                IXAspect param = (IXAspect)nk.sourceAspect(paramURI, IXAspect.class);
                                val = param.getXDA().getText(".",true);
                        }
                        strict = (val.equals("true") || val.equals("t"));
                }
                engine.setStrict(strict);
                        
                // determine cache directory
                String cache = "file:///tmp/sloot-dbx-cache";
                if (nkreq.argumentExists("cache")) {
                        String val = "" + cache;
                        String paramURI = nkreq.getArgument("cache");
                        if (paramURI.startsWith("data:text/plain,"))
                                val = paramURI.substring(("data:text/plain,").length(),paramURI.length());
                        else {
                                IXAspect param = (IXAspect)nk.sourceAspect(paramURI, IXAspect.class);
                                val = param.getXDA().getText(".",true);
                        }
                        cache = (val.equals("")?cache:val);
                }
                engine.setCacheDirectory(cache);

                // get the DBX guide document
                IXAspect optxa = (IXAspect)nk.sourceAspect("this:param:operator", IXAspect.class);
                engine.setGuide(optxa.getReadOnlyDocument());
                
                IURAspect aspect = engine.run();
                nk.createResponseFrom(aspect).setMimeType("application/xml");                   
        }
}