source: Dev/branches/rest-dojo-ui/client/rft/elastic/ElasticReadStore.js @ 381

define(["dojo", "dojox", "dojo/json"], function(dojo, dojox, JSON) {
        dojo.provide("rft.elastic.ElasticReadStore");

        dojo.require("dojox.data.QueryReadStore");

        dojo.declare("rft.elastic.ElasticReadStore", dojox.data.QueryReadStore, {
            fetch:function(request){
                var attr = Object.keys(request.query)[0];
                if (request.query[attr].length == 0) {
                        return 0;
                }
                var q = request.query[attr];

                request.serverQuery = dojo.toJson({ 
                                                                query: 
                                                                {
                                                                        query_string: 
                                                                        {
                                                                                default_field: attr, 
                                                                                query: q
                                                                        }
                                                                }
                                                        });
                    // Call superclasses' fetch
                    return this.inherited("fetch", arguments);
                  },
                _fetchItems: function(request, fetchHandler, errorHandler){
                        var serverQuery = request.serverQuery;
                        var xhrHandler = dojo.xhrPost( { url:this.url,
                                                                handleAs: "json",
                                                                postData: serverQuery });
                        request.abort = function(){
                                xhrHandler.cancel();
                        };
                        xhrHandler.addCallback(dojo.hitch(this, function(data){
                                this._xhrFetchHandler(data, request, fetchHandler, errorHandler);
                        }));
                        xhrHandler.addErrback(function(error){
                                errorHandler(error, request);
                        });
                },
                _xhrFetchHandler: function(data, request, fetchHandler, errorHandler) {
                        data = this._filterResponse(data);
                        this._items = [];
                        var numHits = data.hits.total || -1;
                        if(numHits > 0) {
                                this._items.push({i:data.hits.hits[0]._source, r:this, n:0});
                        }
                        fetchHandler(this._items, request, data.hits.total);
                        this._numRows = data.hits.total;
                }
        });
})