source: Dev/trunk/client/qed/store/ElasticReadStore.js @ 441

define([
    'dojo/_base/declare',
    "dojo/_base/json",
    'dojo/_base/lang',
    'dojo/_base/xhr',
    'dojox/data/QueryReadStore'
],function(declare, json, lang, xhr, QueryReadStore) {
    return declare(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 = json.toJson({ 
                query: {
                    query_string: {
                        default_field: attr, 
                        query: q
                    }
                }
            });
            return this.inherited(arguments);
        },
        _fetchItems: function(request, fetchHandler, errorHandler){
            var serverQuery = request.serverQuery;
            var xhrHandler = xhr.post({
                url: this.url,
                handleAs: "json",
                postData: serverQuery
            }).then(lang.hitch(this, function(data){
                this._xhrFetchHandler(data, request, fetchHandler, errorHandler);
            }),function(error){
                errorHandler(error, request);
            });
            request.abort = function(){
                xhrHandler.cancel();
            };
        },
        _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;
        }
    });
});