manifold/js/manifold-query.js

   1 function ManifoldQuery(action, object, timestamp, filters, params, fields, unique, query_uuid, aq, sq) {
   2     // get, update, delete, create
   3     var action;
   4     // slice, user, network...
   5     var object;
   6     // timestamp, now, latest(cache) : date of the results queried
   7     var timestamp;
   8     // key(field),op(=<>),value
   9     var filters;
  10     // todo
  11     var params;
  12     // hostname, ip,...
  13     var fields;
  14     // 0,1 : list of element of an object or single object
  15     var unique;
  16     // query_uuid : unique identifier of a query
  17     var query_uuid;
  18     // Query : root query (no sub-Query)
  19     var analyzed_query;
  20     // {} : Assoc Table of sub-queries ["resources"->subQ1, "users"->subQ2]
  21     var subqueries;
  22
  23 /*-------------------------------------------------------------
  24               Query properties are SQL like :
  25 ---------------------------------------------------------------
  26 SELECT fields FROM object WHERE filter;
  27 UPDATE object SET field=value WHERE filter; / returns SELECT
  28 DELETE FROM object WHERE filter
  29 INSERT INTO object VALUES(field=value)
  30 -------------------------------------------------------------*/
  31
  32     this.__repr = function () {
  33         res  = "ManifoldQuery ";
  34         res += " id=" + this.query_uuid;
  35         res += " a=" + this.action;
  36         res += " o=" + this.object;
  37         res += " ts=" + this.timestamp;
  38         res += " flts=" + this.filters;
  39         res += " flds=" + this.fields;
  40         res += " prms=" + this.params;
  41         return res;
  42     }
  43
  44     this.clone = function() {
  45         q = new ManifoldQuery();
  46         return jQuery.extend(true, q, this);
  47     }
  48     this.add_filter = function(key, op, value) {
  49         this.filters.push(new Array(key, op, value));
  50     }
  51     this.update_filter = function(key, op, value) {
  52         // Need to be improved...
  53         // remove all occurrences of key if operation is not defined
  54         if(!op){
  55             this.filters = jQuery.grep(this.filters, function(val, i) {
  56                 return val[0] != key;
  57             });
  58         // Else remove the key+op filters
  59         }else{
  60             this.filters = jQuery.grep(this.filters, function(val, i) {return (val[0] != key || val[1] != op);});
  61         }
  62         this.filters.push(new Array(key, op, value));
  63     }
  64
  65     this.remove_filter = function (key,op,value) {
  66         // if operator is null then remove all occurences of this key
  67         if(!op){
  68             this.filters = jQuery.grep(this.filters, function(val, i) {
  69                 return val[0] != key;
  70             });
  71         }else{
  72             this.filters = jQuery.grep(this.filters, function(val, i) {return (val[0] != key || val[1] != op);});
  73         }
  74     }
  75
  76     // FIXME These functions computing diff's between queries are meant to be shared
  77     this.diff_fields = function(otherQuery) {
  78         var f1 = this.fields;
  79         var f2 = otherQuery.fields;
  80
  81         /* added elements are the ones in f2 not in f1 */
  82         var added   = jQuery.grep(f2, function (x) { return jQuery.inArray(x, f1) == -1 });
  83         /* removed elements are the ones in f1 not in f2 */
  84         var removed = jQuery.grep(f1, function (x) { return jQuery.inArray(x, f2) == -1 });
  85
  86         return {'added':added, 'removed':removed};
  87     }
  88
  89     // FIXME Modify filter to filters
  90     this.diff_filter = function(otherQuery) {
  91         var f1 = this.filters;
  92         var f2 = otherQuery.filters;
  93
  94         /* added elements are the ones in f2 not in f1 */
  95         var added   = jQuery.grep(f2, function (x) { return !arrayInArray(x, f1)});
  96         /* removed elements are the ones in f1 not in f2 */
  97         var removed = jQuery.grep(f1, function (x) { return !arrayInArray(x, f2)});
  98
  99         return {'added':added, 'removed':removed};
 100     }
 101
 102     // Callaback received 3 parameters: query, data, parent_query
 103     this.iter_subqueries = function(callback, data)
 104     {
 105         rec = function(query, callback, data, parent_query) {
 106             jQuery.each(query.subqueries, function(object, subquery) {
 107                 rec(subquery, callback, data, query);
 108             });
 109             callback(query, data, parent_query);
 110         };
 111
 112         if (this.analyzed_query !== undefined)
 113             query = this.analyzed_query;
 114         else
 115             query = this;
 116
 117         rec(query, callback, data, null);
 118     }
 119
 120 // we send queries as a json string now
 121 //    this.as_POST = function() {
 122 //        return {'action': this.action, 'object': this.object, 'timestamp': this.timestamp,
 123 //              'filters': this.filters, 'params': this.params, 'fields': this.fields};
 124 //    }
 125     this.analyze_subqueries = function() {
 126         /* adapted from the PHP function in com_tophat/includes/query.php */
 127         var q = new ManifoldQuery();
 128         q.query_uuid = this.query_uuid;
 129         q.action = this.action;
 130         q.object = this.object;
 131         q.timestamp = this.timestamp;
 132
 133         /* Filters */
 134         jQuery.each(this.filters, function(i, filter) {
 135             var k = filter[0];
 136             var op = filter[1];
 137             var v = filter[2];
 138             var pos = k.indexOf('.');
 139             if (pos != -1) {
 140                 var object = k.substr(0, pos);
 141                 var field = k.substr(pos+1);
 142                 if (!q.subqueries[object]) {
 143                     q.subqueries[object] = new ManifoldQuery();
 144                     q.subqueries[object].action = q.action;
 145                     q.subqueries[object].object = object;
 146                     q.subqueries[object].timestamp = q.timestamp;
 147                 }
 148                 q.subqueries[object].filters.push(Array(field, op, v));
 149             } else {
 150                 q.filters.push(filter);
 151             }
 152         });
 153
 154         /* Params */
 155         jQuery.each(this.params, function(param, value) {
 156             var pos = param.indexOf('.');
 157             if (pos != -1) {
 158                 var object = param.substr(0, pos);
 159                 var field = param.substr(pos+1);
 160                 if (!q.subqueries[object]) {
 161                     q.subqueries[object] = new ManifoldQuery();
 162                     q.subqueries[object].action = q.action;
 163                     q.subqueries[object].object = object;
 164                     q.subqueries[object].timestamp = q.timestamp;
 165                 }
 166                 q.subqueries[object].params[field] = value;
 167             } else {
 168                 q.params[field] = value;
 169             }
 170         });
 171
 172         /* Fields */
 173         jQuery.each(this.fields, function(i, v) {
 174             var pos = v.indexOf('.');
 175             if (pos != -1) {
 176                 var object = v.substr(0, pos);
 177                 var field = v.substr(pos+1);
 178                 if (!q.subqueries[object]) {
 179                     q.subqueries[object] = new ManifoldQuery();
 180                     q.subqueries[object].action = q.action;
 181                     q.subqueries[object].object = object;
 182                     q.subqueries[object].timestamp = q.timestamp;
 183                 }
 184                 q.subqueries[object].fields.push(field);
 185             } else {
 186                 q.fields.push(v);
 187             }
 188         });
 189         this.analyzed_query = q;
 190     }
 191
 192     /* constructor */
 193     if (typeof action == "undefined")
 194         this.action = "get";
 195     else
 196         this.action = action;
 197
 198     if (typeof object == "undefined")
 199         this.object = null;
 200     else
 201         this.object = object;
 202
 203     if (typeof timestamp == "undefined")
 204         this.timestamp = "now";
 205     else
 206         this.timestamp = timestamp;
 207
 208     if (typeof filters == "undefined")
 209         this.filters = [];
 210     else
 211         this.filters = filters;
 212
 213     if (typeof params == "undefined")
 214         this.params = {};
 215     else
 216         this.params = params;
 217
 218     if (typeof fields == "undefined")
 219         this.fields = [];
 220     else
 221         this.fields = fields;
 222
 223     if (typeof unique == "undefined")
 224         this.unique = false;
 225     else
 226         this.unique = unique;
 227
 228     this.query_uuid = query_uuid;
 229
 230     if (typeof aq == "undefined")
 231         this.analyzed_query = null;
 232     else
 233         this.analyzed_query = aq;
 234
 235     if (typeof sq == "undefined")
 236         this.subqueries = {};
 237     else
 238         this.subqueries = sq;
 239 }