Subversion Repositories Applications.papyrus

/*
        Copyright (c) 2004-2006, The Dojo Foundation
        All Rights Reserved.

        Licensed under the Academic Free License version 2.1 or above OR the
        modified BSD license. For more information on Dojo licensing, see:

                http://dojotoolkit.org/community/licensing.shtml
*/



dojo.provide("dojo.data.RdfStore");
dojo.provide("dojo.data.RhizomeStore");
dojo.require("dojo.lang.declare");
dojo.require("dojo.data.core.RemoteStore");
dojo.require("dojo.experimental");
dojo.data.RdfDatatypeSerializer = function (type, convertFunc, uri) {
        this.type = type;
        this._converter = convertFunc;
        this.uri = uri;
        this.serialize = function (value) {
                return this._converter.call(value, value);
        };
};
dojo.declare("dojo.data.RdfStore", dojo.data.core.RemoteStore, {_datatypeMap:{literal:function (value) {
        var literal = value.value;
        if (value["xml:lang"]) {
                literal.lang = value["xml:lang"];
        }
        return literal;
}, uri:function (value) {
        return {id:value.value};
}, bnode:function (value) {
        return {id:"_:" + value.value};
}, "http://www.w3.org/2001/XMLSchema#int":function (value) {
        return parseInt(value.value);
}, "http://www.w3.org/2001/XMLSchema#integer":function (value) {
        return parseInt(value.value);
}, "http://www.w3.org/2001/XMLSchema#long":function (value) {
        return parseInt(value.value);
}, "http://www.w3.org/2001/XMLSchema#float":function (value) {
        return parseFloat(value.value);
}, "http://www.w3.org/2001/XMLSchema#double":function (value) {
        return parseFloat(value.value);
}, "http://www.w3.org/2001/XMLSchema#boolean":function (value) {
        return !value || value == "false" || value == "0" ? false : true;
}}, _datatypeSerializers:[new dojo.data.RdfDatatypeSerializer(Number, Number.toString, "http://www.w3.org/2001/XMLSchema#float"), new dojo.data.RdfDatatypeSerializer(Boolean, Boolean.toString, "http://www.w3.org/2001/XMLSchema#boolean")], _findDatatypeSerializer:function (value) {
        var length = this._datatypeSerializers.length;
        for (var i = 0; i < length; i++) {
                var datatype = this._datatypeSerializers[i];
                if (value instanceof datatype.type) {
                        return datatype;
                }
        }
}, _toRDFValue:function (value) {
        var rdfvalue = {};
        if (value.id) {
                if (value.id.slice(0, 2) == "_:") {
                        rdfvalue.type = "bnode";
                        rdfvalue.value = value.id.substring(2);
                } else {
                        rdfvalue.type = "uri";
                        rdfvalue.value = value.id;
                }
        } else {
                if (typeof value == "string" || value instanceof String) {
                        rdfvalue.type = "literal";
                        rdfvalue.value = value;
                        if (value.lang) {
                                rdfvalue["xml:lang"] = value.lang;
                        }
                } else {
                        if (typeof value == "number") {
                                value = new Number(value);
                        } else {
                                if (typeof value == "boolean") {
                                        value = new Boolean(value);
                                }
                        }
                        var datatype = this._findDatatypeSerializer(value);
                        if (datatype) {
                                rdfvalue = {"type":"typed-literal", "datatype":datatype.uri, "value":value.toString()};
                        } else {
                                rdfvalue = {"type":"literal", "value":value.toString()};
                        }
                }
        }
        return rdfvalue;
}, _setupSaveRequest:function (saveKeywordArgs, requestKw) {
        var rdfResult = {"head":{"vars":["s", "p", "o"]}, "results":{"bindings":[]}};
        var resources = [];
        for (var key in this._deleted) {
                resources.push(key);
        }
        rdfResult.results.deleted = resources;
        for (key in this._changed) {
                var subject = this._toRDFValue(this.getIdentity(key));
                var attributes = this._changed[key];
                for (var attr in attributes) {
                        var predicate = {type:"uri", value:attr};
                        var values = attributes[attr];
                        if (!values.length) {
                                continue;
                        }
                        var rdfvalues = [];
                        for (var i = 0; i < values.length; i++) {
                                var rdfvalue = this._toRDFValue(values[i]);
                                rdfResult.results.bindings.push({s:subject, p:predicate, o:rdfvalue});
                        }
                }
        }
        var oldRegistry = dojo.json.jsonRegistry;
        dojo.json.jsonRegistry = this._jsonRegistry;
        var jsonString = dojo.json.serialize(rdfResult);
        dojo.json.jsonRegistry = oldRegistry;
        requestKw.postContent = jsonString;
}, _resultToQueryMetadata:function (json) {
        return json.head;
}, _resultToQueryData:function (json) {
        var items = {};
        var stmts = json.results.bindings;
        for (var i = 0; i < stmts.length; i++) {
                var stmt = stmts[i];
                var subject = stmt.s.value;
                if (stmt.s.type == "bnode") {
                        subject = "_:" + subject;
                }
                var attributes = data[subject];
                if (!attributes) {
                        attributes = {};
                        data[stmt.s] = attributes;
                }
                var attr = attributes[stmt.p.value];
                if (!attr) {
                        attributes[stmt.p.value] = [stmt.o];
                } else {
                        attr.push(stmt.o);
                }
        }
        return items;
}});
dojo.declare("dojo.data.RhizomeStore", dojo.data.RdfStore, {initializer:function (kwArgs) {
        this._serverQueryUrl = kwArgs.baseUrl + "search?view=json&searchType=RxPath&search=";
        this._serverSaveUrl = kwArgs.baseUrl + "save-metadata";
}, _resultToQueryMetadata:function (json) {
        return json;
}, _resultToQueryData:function (json) {
        return json;
}, _setupSaveRequest:function (saveKeywordArgs, requestKw) {
        requestKw.url = this._serverSaveUrl;
        requestKw.method = "post";
        requestKw.mimetype = "text/plain";
        var resources = [];
        for (var key in this._deleted) {
                resources.push(key);
        }
        var changes = {};
        for (key in this._changed) {
                if (!this._added[key]) {
                        resources.push(key);
                }
                var attributes = this._changed[key];
                var rdfattributes = {};
                for (var attr in attributes) {
                        var values = attributes[attr];
                        if (!values.length) {
                                continue;
                        }
                        var rdfvalues = [];
                        for (var i = 0; i < values.length; i++) {
                                var rdfvalue = this._toRDFValue(values[i]);
                                rdfvalues.push(rdfvalue);
                        }
                        rdfattributes[attr] = rdfvalues;
                }
                changes[key] = rdfattributes;
        }
        var oldRegistry = dojo.json.jsonRegistry;
        dojo.json.jsonRegistry = this._jsonRegistry;
        var jsonString = dojo.json.serialize(changes);
        dojo.json.jsonRegistry = oldRegistry;
        requestKw.content = {rdfFormat:"json", resource:resources, metadata:jsonString};
}});