source: Dev/branches/rest-dojo-ui/client/rft/store.js @ 340

define(['dojo/_base/lang','dojo/_base/array','dojo/_base/Deferred','dojo/store/JsonRest','./api'],
    function(lang,array,Deferred,JsonRest,api){
    
        var OBJ_TYPE = '__objectType';
        var OBJ_UID = '__objectUid';
        var REF_TYPE = '__referenceType';
        var REF_UID = '__referenceUid';

        var RftObject = function(values) {
            var self = this;
            lang.mixin(this,values);
            self.getUid = function() {
                return self[OBJ_UID];
            }
        };
    
        var rftStoreCtor = function(objectType) {
            var jsonStore = new JsonRest({
                target:"../server/api.php/data/"+objectType+"/",
                idProperty: OBJ_UID
            });
            var errHandler = api.defaultErrorHandler;
            return lang.delegate(jsonStore,{
                query: function(query, directives){
                    return Deferred.when( jsonStore.query(query,directives), function(results){
                        return array.map(results,function(result){
                            return new RftObject(typeof result == "object" ? result : object);
                        });
                    },errHandler);
                },
                get: function(id, directives){
                    return Deferred.when( jsonStore.get(id,directives), function(result){
                        return new RftObject(typeof result == "object" ? result : object);
                    },errHandler);
                },
                add: function(object, directives){
                    return Deferred.when( jsonStore.add(object,directives), function(result){
                        return new RftObject(typeof result == "object" ? result : object);
                    },errHandler);
                },
                put: function(object, directives){
                    return Deferred.when( jsonStore.put(object,directives), function(result) {
                        return new RftObject(typeof result == "object" ? result : object);
                    },errHandler);
                },
                remove: function(id, directives){
                    return jsonStore.remove(id,directives);
                }
            });
        };
    
        var storeCache = {};
    
        return {
            getStore: function(objectType) {
                if ( !storeCache[objectType] ) {
                    storeCache[objectType] = new rftStoreCtor(objectType);
                }
                return storeCache[objectType];
            },
            dereference: function(object) {
                if ( object[REF_TYPE] ) {
                    return this.getStore(object[REF_TYPE]).get(object[REF_UID]);
                }
                return object;
            }
        };

    });