X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=plugins%2Fupdater%2Fupdater.js;h=7986fee79ba6a4e08cdec7c44746132c2b145315;hb=69867d5296684463d3aad4f6db867d24005102aa;hp=c61c2056215170a297ae27c7001f11230ab13f41;hpb=a306cc3564fe7e359f1b4b6057d3711141f7f821;p=myslice.git diff --git a/plugins/updater/updater.js b/plugins/updater/updater.js index c61c2056..7986fee7 100644 --- a/plugins/updater/updater.js +++ b/plugins/updater/updater.js @@ -4,9 +4,14 @@ * License: GPLv3 */ +// xxx this is ongoing work, very rough, and not working at all yet + ( function ( $ ) { - $.fn.Updater = function( method ) { + var debug=false; +// debug=true + + $.fn.Updater = function ( method ) { /* Method calling logic */ if ( methods[method] ) { return methods[ method ].apply( this, Array.prototype.slice.call( arguments, 1 )); @@ -14,130 +19,150 @@ return methods.init.apply( this, arguments ); } else { $.error( 'Method ' + method + ' does not exist on $.Updater' ); - } - + } }; var methods = { - init : function( options ) { return this.each(function(){ var $this = $(this); var updater = new Updater (options); $this.data('Updater',updater); - /* Subscribe to query updates */ + // xxx not tested yet var results_channel = '/results/' + options.query_uuid + '/changed'; - $.subscribe(results_channel, function (e,rows) { updater.update_slice (e,rows); } ); - - - // xxx - here -- here -- xxx - - $('#updater-' + options.plugin_uuid).click({instance: $this}, function (e) { - var data = e.data.instance.data().Slices; - tophat_async_exec([{'query': data.update_query, 'id': null}]); - //$('#updateslice-' + options.plugin_uuid).prop('disabled', true); - }); - - /* End of plugin initialization */ - - $(this).data('Slices', { - options: options, - target : $this, - update_query : null, - child_subscribe: false, /* Are we listening for children updates */ - Slices : Slices + $.subscribe(results_channel, function (e,rows) { updater.query_completed (e,rows); } ); + // under test.. + var failed_channel = '/results/' + options.query_uuid + '/failed'; + $.subscribe(failed_channel, $this, function (e,code,output) { updater.query_failed (e, code, output); } ); + }); + }, + destroy : function( ) { + return this.each(function(){ + var $this = $(this); + $(window).unbind('Updater'); + data.Updater.remove(); + $this.removeData('Updater'); }); + }, - } - }); - }, - destroy : function( ) { - - return this.each(function(){ - var $this = $(this), data = $this.data('Slices'); - $(window).unbind('Slices'); - data.Slices.remove(); - $this.removeData('Slices'); - }) - - }, - - show : function( content ) { } - }; - - /* Private methods */ - - function update_resources(e, resources, change) - { - data = e.data.instance.data().Slices; - - data.update_query.params['resource'] = resources - $.publish('/update/' + data.options.query_uuid, [data.update_query, true]); - } - - function update_leases(e, leases, change) - { - data = e.data.instance.data().Slices; - - data.update_query.params['lease'] = leases - $.publish('/update/' + data.options.query_uuid, [data.update_query, true]); - } - - function update_slice(e, rows, query) { - /* This function is called twice : get and update */ - - var data = e.data.instance.data().Slices; - - /* Update placeholders and trigger subqueries updates */ - if (rows.length == 0) { - alert("no result"); - return; - } - var slice = rows[0]; - - /* for get */ - if (data.update_query == null) { - data.update_query = new Query('update','slice', 'now', query.filter, {"resource": null, "lease": null}, query.fields, 0, data.options.query_uuid); - } - /* In case of update the list of resources and leases should be updated accordingly */ - - /* only for get ? */ - $.each(slice, function(key, value) { - if (typeof value == 'string') { - $('#myslice__' + key).html(value); + show : function( content ) { } + }; + + function Updater (options) { + this.options=options; + // xxx should try to locate update_query first, in case we have several Updaters + // on the same query + // however the mental model behind the global manifold object for now is + // to unambiguously find a query based on its query_uuid, which in the joomla + // implementation wouldn't fly + // we keep this for a later improvement + var query=manifold.find_query (options.query_uuid); + // very rough way of filling this for now + this.update_query = + new ManifoldQuery ("update", query.subject, null, query.filters, + {}, // params + query.fields, + undefined, /* unique */ + Math.uuid(32,16), + undefined, undefined /* maybe some day I'll get that one */); + manifold.insert_query (this.update_query); + // arm button once document is loaded + (function(updater) {$(document).ready(function(){updater.arm_button()})})(this); + + this.arm_button = function () { + $('#updater-' + this.options.plugin_uuid).click(this, this.submit_update_request); + }, + this.submit_update_request = function (e) { + var query_uuid = e.data.options.query_uuid; + var update_query = e.data.update_query; + if (debug) messages.debug("Updater.submit_update_request " + update_query.__repr()); + // actually send the Update query, but publish results as if coming from the original query + manifold.asynchroneous_exec ( [ {'query_uuid': update_query.query_uuid, 'publish_uuid' : query_uuid} ], false); + // disable button while the query is flying + $('#updater-' + e.data.options.plugin_uuid).attr('disabled', 'disabled'); + }, + + this.query_failed = function (e, code, output) { + var plugindiv=e.data; + var updater=plugindiv.data('Updater'); + $('#updater-' + updater.options.plugin_uuid).removeAttr('disabled'); + // just as a means to deom how to retrieve the stuff passed on the channel + if (debug) messages.debug("retrieved error code " + code + " and output " + output); + } + + update_resources = function (e, resources, change) { + data = e.data.instance.data().Slices; + + data.update_query.params['resource'] = resources + $.publish('/update/' + data.options.query_uuid, [data.update_query, true]); + }, + + update_leases = function (e, leases, change) { + data = e.data.instance.data().Slices; + + data.update_query.params['lease'] = leases + $.publish('/update/' + data.options.query_uuid, [data.update_query, true]); + }, + + + + query_completed = function (e, rows, query) { + + /* This function is called twice : get and update */ + messages.info("updater.query_completed - not implemented yet"); + + var data = e.data.instance.data().Slices; + + /* Update placeholders and trigger subqueries updates */ + if (rows.length == 0) { + alert("no result"); + return; + } + var slice = rows[0]; + + /* for get */ + if (data.update_query == null) { + data.update_query = new Query('update','slice', 'now', query.filter, {"resource": null, "lease": null}, query.fields, 0, data.options.query_uuid); + } + /* In case of update the list of resources and leases should be updated accordingly */ + + /* only for get ? */ + $.each(slice, function(key, value) { + if (typeof value == 'string') { + $('#myslice__' + key).html(value); + } + }); + + /* TODO avoid repetitions + made this code generic and plugin-independent */ + + if (query.method == 'update') { + // XXX NON, les uuid doivent etre les memes que dans la query Get, cet appel devrait etre fait avant. + query.analyzed_subqueries(); + } + + /* NOTE: Dans le cadre d'un update, on n'a pas besoin de refaire tout + * le query plan et obtenir toutes les infos, par contre on ne peut pas + * savoir d'avance quels parametres ont été accordés, changés, etc. + * Dans le cas général, ca pourrait affecter le query plan... + * Par contre on n'a pas d'information sur toutes les resources, mais + * uniquement celles dans la liste. Comment gérer ? + */ + + /* Inform child plugins about their respective parts of the results */ + /* Only for get */ + var r_subq = query.analyzed_query.subqueries['resource']; + var l_subq = query.analyzed_query.subqueries['lease']; + $.publish('/results/' + r_subq.uuid + '/changed', [slice['resource'], r_subq]); + $.publish('/results/' + l_subq.uuid + '/changed', [slice['lease'], l_subq]); + + /* Subscribe to get notifications from child plugins */ + if (!data.child_subscribe) { + $.subscribe('/update-set/' + r_subq.uuid, {instance: e.data.instance}, update_resources); + $.subscribe('/update-set/' + l_subq.uuid, {instance: e.data.instance}, update_leases); + data.child_subscribe = true } - }); - - /* TODO avoid repetitions + made this code generic and plugin-independent */ - - if (query.method == 'update') { - // XXX NON, les uuid doivent etre les memes que dans la query Get, cet appel devrait etre fait avant. - query.analyzed_subqueries(); - } - - /* NOTE: Dans le cadre d'un update, on n'a pas besoin de refaire tout - * le query plan et obtenir toutes les infos, par contre on ne peut pas - * savoir d'avance quels parametres ont été accordés, changés, etc. - * Dans le cas général, ca pourrait affecter le query plan... - * Par contre on n'a pas d'information sur toutes les resources, mais - * uniquement celles dans la liste. Comment gérer ? - */ - - /* Inform child plugins about their respective parts of the results */ - /* Only for get */ - var r_subq = query.analyzed_query.subqueries['resource']; - var l_subq = query.analyzed_query.subqueries['lease']; - $.publish('/results/' + r_subq.uuid + '/changed', [slice['resource'], r_subq]); - $.publish('/results/' + l_subq.uuid + '/changed', [slice['lease'], l_subq]); - - /* Subscribe to get notifications from child plugins */ - if (!data.child_subscribe) { - $.subscribe('/update-set/' + r_subq.uuid, {instance: e.data.instance}, update_resources); - $.subscribe('/update-set/' + l_subq.uuid, {instance: e.data.instance}, update_leases); - data.child_subscribe = true - } - + + } } - })( jQuery );