Changeset 3456

Timestamp:

08/22/13 12:26:32 (11 years ago)

Author:

mwindhouwer

Message:

mod-SLOOT*

• added support for caching to disk to DBX
• use <dbx:cache id="/relative/path/to/cache/entry"/> in a DBX to cache and reuse
• use active:dbx-cache+entry@data:text/plain,/relative/path/to/cache/entry to clear

Location:

cats/shared/mod-SLOOT/trunk

Files:

• module.xml (modified) (1 diff)
• nk/src/DBXEngine.java (modified) (1 diff)
• nk/src/dbx/Engine.java (modified) (5 diffs)
• tools/dbx-cache.acc (added)

cats/shared/mod-SLOOT/trunk/module.xml

@@ -51 +51 @@
         </rewrite>
         <rewrite>
+            <match>active:sloot.dbx-cache\+(.*)</match>
+            <to>active:sloot.accessor+operand@ffcpl:/tools/dbx-cache.acc+$1</to>
+        </rewrite>
+        <rewrite>
             <match>active:sloot.dbx(.*)\+operator@([^+]*)(.*)</match>
             <to>active:javascript+operator@ffcpl:/tools/dbx.js+_operator@$2$1$3</to>

cats/shared/mod-SLOOT/trunk/nk/src/DBXEngine.java

@@ -90 +90 @@
                 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);

cats/shared/mod-SLOOT/trunk/nk/src/dbx/Engine.java

@@ -3 +3 @@
 import com.ten60.netkernel.urii.*;
 import com.ten60.netkernel.urii.aspect.IAspectBoolean;
+import com.ten60.netkernel.urii.aspect.IAspectReadableBinaryStream;
 import org.ten60.netkernel.xml.xahelper.*;
 import org.ten60.netkernel.xml.xda.*;
@@ -47 +48 @@
         protected boolean strict = true;
         
+        // cache directory
+        protected String cacheDir = "file:///tmp/sloot-dbx-cache";
+        
         // profile hashmap
         protected SortedMap profiles = new TreeMap();
@@ -114 +118 @@
         }
 
+        public void setCacheDirectory(String cacheDir) {
+                this.cacheDir = cacheDir;
+        }
+        
         public IURAspect run() throws Exception {
                 long start = System.currentTimeMillis();
@@ -276 +284 @@
                                         // silently move on
                                         evalChildren();
+                } else if (action.equals("cache")) {
+                    cache();
                                 } else
                                         fatal(guide,"unknown DBX element!");
@@ -734 +744 @@
                         
                         evalChildren(template);
+                }
+                
+                /** cache the result */
+                protected void cache() throws Exception {
+                        // check if there is a when attribute
+                        String when = guide.getAttributeValue(new QName("when"));
+                        if ((when!=null) && (!when.trim().equals(""))) {
+                                if (!xpath2boolean(sxdoc.wrap(result),when.trim())) {
+                                        debug("dbx:cache@when eval["+when.trim()+"][false]");
+                                        // no caching
+                                evalChildren();
+                                return;
+                                } else {
+                        debug("dbx:cache@when eval["+when.trim()+"][true]");
+                                }
+                        }
+                // get cache id
+                String id = guide.getAttributeValue(new QName("id"));
+                if (id!=null)
+                        id = avt(id);
+                if ((id == null) || id.trim().equals(""))
+                        fatal(guide,"<dbx:cache/> without a id attribute, or it's empty!");
+                // lookup the id in the cache
+                String cacheFile = cacheDir+id;
+                try {
+                        InputSource is = new InputSource(((IAspectReadableBinaryStream)nk.sourceAspect(cacheFile,IAspectReadableBinaryStream.class)).getInputStream());
+                        XdmNode node = sxdoc.build(new SAXSource(is));
+                        debug("dbx:cache@file["+cacheFile+"][loaded]");
+                deepCopy(result,node);
+                node=null;
+                is=null;
+            } catch(Exception e) {
+                // TODO: check if its a not found exception, if not throw the exception
+                        debug("dbx:cache@file["+cacheFile+"][failed]["+e+"]");
+                        int children = result.getChildNodes().getLength();
+                        evalChildren();
+                        if (result.getChildNodes().getLength() == (children + 1)) {
+                        // now cache the result
+                        // DOMAspect dom = new DOMAspect(result.getLastChild());
+                        Document doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument();
+                        Node root = doc.importNode(result.getLastChild(),true);
+                        doc.appendChild(root);
+                        DOMAspect dom = new DOMAspect(doc);
+                        nk.sinkAspect(cacheFile,dom);
+                        debug("dbx:cache@file["+cacheFile+"][saved]");
+                } else if (result.getChildNodes().getLength() > (children + 1)) {
+                                warn(guide,"dbx:cache: more then one new child node has been created, this can't be cached!");
+                        }// else nothing to cache
+                        }
                 }