lib-io.js

来自「Hippo CMS是一个以信息为中心的开源内容管理系统。Hippo CMS目标是」· JavaScript 代码 · 共 238 行

/*
* Copyright 2001-2007 Hippo (www.hippo.nl)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
*   http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/*
 * Created on May 4, 2004
 * Flowscript IO Library 
 * author jreijn
 */

importClass(Packages.org.apache.cocoon.ProcessingException);
importClass(Packages.org.apache.cocoon.xml.dom.DOMStreamer);
importClass(Packages.org.apache.excalibur.xml.dom.DOMParser);
importClass(Packages.org.apache.excalibur.source.SourceResolver);
importClass(Packages.org.apache.excalibur.source.ModifiableSource);
importClass(Packages.org.xml.sax.InputSource);
importClass(Packages.javax.xml.transform.TransformerFactory);
importClass(Packages.javax.xml.transform.OutputKeys);
importClass(Packages.javax.xml.transform.sax.SAXTransformerFactory);
importClass(Packages.javax.xml.transform.stream.StreamResult);

var libio = {}

/**
 * load an XML document into a DOM document
 */
libio.loadDocument = function (uri) {
    var parser = null;
    var source = null;
    var resolver = null;
    try {
        parser = cocoon.getComponent(DOMParser.ROLE);
        resolver = cocoon.getComponent(SourceResolver.ROLE);
        source = resolver.resolveURI(uri);
        var is = new InputSource(source.getInputStream());
        is.setSystemId(source.getURI());
        return parser.parseDocument(is);
    }
    /** /// Insert/remove space after asterisks toe disable/enable code
    catch (e) {
        if (e instanceof Throwable) {
            e.printStackTrace();
        }
        else {
            print(e);
        }
        throw e;
    }
  /**/
    finally {
        if (source != null) {
            resolver.release(source);
        }
        if (parser != null) {
          cocoon.releaseComponent(parser);
        }
        if (resolver != null) {
          cocoon.releaseComponent(resolver);
        }
    }
}


/**
 * The saveDocument function
 * saves a DOM Document back to a source
 */
libio.saveDocument = function (document, uri) {
    var source = null;
    var resolver = null;
    var outputStream = null;
    try {
        resolver = cocoon.getComponent(SourceResolver.ROLE);
        source = resolver.resolveURI(uri);
        
        var tf = TransformerFactory.newInstance();

        if (source instanceof ModifiableSource
            && tf.getFeature(SAXTransformerFactory.FEATURE)) {

            outputStream = source.getOutputStream();
            var transformerHandler = tf.newTransformerHandler();
            var transformer = transformerHandler.getTransformer();
            transformer.setOutputProperty(OutputKeys.INDENT, "no");
            transformer.setOutputProperty(OutputKeys.METHOD, "xml");
            transformerHandler.setResult(new StreamResult(outputStream));

            var streamer = new DOMStreamer(transformerHandler);
            streamer.stream(document);
        } else {
            throw new ProcessingException("Cannot write to source " + uri);
        }
    } finally {
        if (source != null)
            resolver.release(source);
        cocoon.releaseComponent(resolver);
        if (outputStream != null) {
            try {
                outputStream.flush();
                outputStream.close();
            } catch (error) {
                cocoon.log.error("Could not flush/close outputstream: " + error);
            }
        }
    }
}


/**
 * The deleteDocument function
 * deletes a source
 */
libio.deleteDocument = function (uri) {
    var source = null;
    var resolver = null;

    try {
        resolver = cocoon.getComponent(SourceResolver.ROLE);
        source = resolver.resolveURI(uri);
        source["delete"]();
    } 
    catch (error) {
       cocoon.log.error("Error occured while deleting document: " + error);
    }
    finally {
        if (source != null)
            resolver.release(source);
            cocoon.releaseComponent(resolver);
            
    }
}

/**
 * The deleteCollection function
 * deletes a collection of sources like a directory on filesystem
 */
libio.deleteCollection = function (uri) {
    var source = null;
    var resolver = null;
    var path = uri;

    try {
        resolver = cocoon.getComponent(SourceResolver.ROLE);
        source = resolver.resolveURI(uri);              
        if (source["isCollection"]()) {
            var childrenof = source["getChildren"]();
            var childnodes = childrenof.toArray();
            for (i=0; i<childnodes.length; i++) {
                deleteCollection(path + childnodes[i].getName().toString());
            }
        }
        source["delete"]();
    } 
    catch (error) {
       cocoon.log.error("Error occured while deleting directory: " + error);
    }
    finally {
        if (source != null) {
            resolver.release(source);
        }
        if (resolver != null) {
            cocoon.releaseComponent(resolver);
        }
            
    }
}

/**
 * The makeCollection function
 * makes a collection like a directory on filesystem
 */


libio.makeCollection = function (uri) {
    var source = null;
    var resolver = null;
    var path = uri;

    try {
        resolver = cocoon.getComponent(SourceResolver.ROLE);
        source = resolver.resolveURI(uri);              
        if (!source["exists"]()) {
            source["makeCollection"]();
        }       
    } 
    catch (error) {
       cocoon.log.error("Error occured while creating directory: " + error);
    }
    finally {
        if (source != null) {
            resolver.release(source);
        }
        cocoon.releaseComponent(resolver);
            
    }
}


/**
 * Checks if a resource exists.
 */
libio.checkExists = function (uri)
{

    var source = null;
    var resolver = null;
    try {
        resolver = cocoon.getComponent(SourceResolver.ROLE);
        source = resolver.resolveURI(uri);
        if(source.exists()) {
            return true;
        }
        else {
            return false;
        }
    } 
    finally {
        if (source != null) {
            resolver.release(source);
        }
        if (resolver != null) {
            cocoon.releaseComponent(resolver);
        }
    }   
}