diff --git a/advancedqueue.drush.inc b/advancedqueue.drush.inc deleted file mode 100644 index ba269d5..0000000 --- a/advancedqueue.drush.inc +++ /dev/null @@ -1,97 +0,0 @@ - 'Run a processing job for a queue.', - 'arguments' => array( - 'queue' => dt('The name of the queue to process.'), - ), - 'options' => array( - 'timeout' => 'The maximum execution time of the script.', - 'all' => 'Process all queues.', - ), - ); - return $items; -} - -function drush_advancedqueue_process_queue() { - // Load information about the registred queues, and sort them by weight. - $all_queue_info = module_invoke_all('advanced_queue_info'); - drupal_alter('advanced_queue_info', $all_queue_info); - uasort($all_queue_info, 'drupal_sort_weight'); - - $all_option = (bool) drush_get_option('all'); - $queues = func_get_args(); - if (!($all_option xor !empty($queues))) { - return drush_set_error(dt('You have to specify either a set of queues or the --all parameter.')); - } - - if ($all_option) { - $queues = $all_queue_info; - } - else { - // Validate queues. - $queues = array_combine($queues, $queues); - $invalid_queues = array_diff_key($queues, $all_queue_info); - if ($invalid_queues) { - return drush_set_error(dt('The following queues are invalid: !queues. Aborting.', array('!queues' => implode(', ', $invalid_queues)))); - } - $queues = array_intersect_key($all_queue_info, $queues); - } - - // Run the worker for a certain period of time before killing it. - $timeout = drush_get_option('timeout'); - $end = $timeout ? time() + $timeout : 0; - - drush_log(dt('Starting processing loop.')); - - while (!$end || time() < $end) { - foreach ($queues as $queue_name => $queue_info) { - $queue = DrupalQueue::get($queue_name); - - if ($item = $queue->claimItem()) { - drush_advancedqueue_process_item($queue, $queue_name, $queue_info, $item); - continue 2; - } - } - - // Not item processed in that round, let the CPU rest. - sleep(1); - } - - drush_log(dt('Timeout: exiting processing loop.')); -} - -function drush_advancedqueue_process_item($queue, $queue_name, $queue_info, $item) { - $function = $queue_info['worker callback']; - drush_log(dt('[!queue:!id] Starting processing item (!item).', array('!queue' => $queue_name, '!id' => $item->item_id, '!item' => json_encode($item->data)))); - - try { - $output = $function($item->data); - if (is_array($output)) { - $item->status = $output[0]; - $item->result = $output[1]; - } - else { - // TODO: remove magic constants. - $item->status = $output ? 1 : 2; - } - } - catch (Exception $e) { - drush_log(dt('[!queue:!id] failed processing: !message', array('!queue' => $queue_name, '!id' => $item->item_id, '!message' => (string) $e))); - // TODO: remove magic constants. - $item->status = 2; - } - - drush_log(dt('[!queue:!id] Processing ended.', array('!queue' => $queue_name, '!id' => $item->item_id, '!item' => json_encode($item->data)))); - $queue->deleteItem($item); -} diff --git a/advancedqueue.info b/advancedqueue.info index e5480ed..ace3a37 100644 --- a/advancedqueue.info +++ b/advancedqueue.info @@ -3,12 +3,9 @@ description = Helper module for advanced queuing. package = Other core = 7.x -files[] = advancedqueue.module -files[] = advancedqueue.install files[] = advancedqueue.queue.inc -files[] = tests/advancedqueue.test - +; Views files[] = views/advancedqueue_handler_field_title.inc files[] = views/advancedqueue_handler_field_status.inc files[] = views/advancedqueue_handler_filter_status.inc diff --git a/advancedqueue.install b/advancedqueue.install index ae002f2..e29b44f 100644 --- a/advancedqueue.install +++ b/advancedqueue.install @@ -4,9 +4,9 @@ * Implementation of hook_enable(). */ function advancedqueue_enable() { - if (variable_get('queue_default_class', NULL) === NULL) { + if (variable_get('queue_default_reliable_class', NULL) === NULL) { // Take ownership of all the queues. - variable_set('queue_default_class', 'AdvancedQueue'); + variable_set('queue_default_reliable_class', 'AdvancedQueue'); } } @@ -14,9 +14,9 @@ function advancedqueue_enable() { * Implementation of hook_disable(). */ function advancedqueue_disable() { - if (variable_get('queue_default_class', NULL) === 'AdvancedQueue') { + if (variable_get('queue_default_reliable_class', NULL) === 'AdvancedQueue') { // Let the queues run free. - variable_del('queue_default_class', 'AdvancedQueue'); + variable_del('queue_default_reliable_class', 'AdvancedQueue'); } } diff --git a/advancedqueue.js b/advancedqueue.js deleted file mode 100644 index b044852..0000000 --- a/advancedqueue.js +++ /dev/null @@ -1,99 +0,0 @@ -(function ($) { - $(function() { - return; - - var element_settings = { - 'event': 'refreshRequest', - 'progress': { 'type': 'throbber' }, - 'url': 'queues' - }; - - // Bind AJAX behaviors to all items showing the class. - $('.views-ajax-link').once('views-ajax-processed').each(function () { - var element_settings = base_element_settings; - // Set the URL to go to the anchor. - if ($(this).attr('href')) { - element_settings.url = $(this).attr('href'); - } - var base = $(this).attr('id'); - Drupal.ajax[base] = new Drupal.ajax(base, this, element_settings); - }); - - }); - - /** - * Handler for the form serialization. - * - * Runs before the beforeSend() handler (see below), and unlike that one, runs - * before field data is collected. - */ - var simpleBeforeSerialize = function (element, options) { - // Allow detaching behaviors to update field values before collecting them. - // This is only needed when field values are added to the POST data, so only - // when there is a form such that this.form.ajaxSubmit() is used instead of - // $.ajax(). When there is no form and $.ajax() is used, beforeSerialize() - // isn't called, but don't rely on that: explicitly check this.form. - if (this.form) { - var settings = this.settings || Drupal.settings; - Drupal.detachBehaviors(this.form, settings, 'serialize'); - } - }; - - Drupal.behaviors.ViewsAjaxView.attach = function() { - if (Drupal.settings && Drupal.settings.views && Drupal.settings.views.ajaxViews) { - // Retrieve the path to use for views' ajax. - var ajax_path = Drupal.settings.views.ajax_path; - - // If there are multiple views this might've ended up showing up multiple times. - if (ajax_path.constructor.toString().indexOf("Array") != -1) { - ajax_path = ajax_path[0]; - } - - $.each(Drupal.settings.views.ajaxViews, function(i, settings) { - var view = '.view-dom-id-' + settings.view_dom_id; - var element_settings = { - url: ajax_path, - submit: settings, - setClick: true, - event: 'refreshRequested', - selector: view, - progress: { type: 'none' } - }; - - $(view).filter(':not(.views-refresh-processed)') - // Don't attach to nested views. Doing so would attach multiple behaviors - // to a given element. - .filter(function() { - // If there is at least one parent with a view class, this view - // is nested (e.g., an attachment). Bail. - return !$(this).parents('.view').size(); - }) - .each(function() { - $(this) - .addClass('views-refresh-processed') - .append($('
') - .each(function () { - // Set a reference that will work in subsequent calls. - var target = this; - var viewData = {}; - $.extend( - viewData, - settings - ); - - element_settings.submit = viewData; - var ajax = new Drupal.ajax(false, target, element_settings); - ajax.options.type = 'GET'; - ajax.beforeSerialize = simpleBeforeSerialize; - - setInterval(function() { - $(target).trigger('refreshRequested'); - }, 2000); - }) - ); - }); // $view.filter().each - }); // .each Drupal.settings.views.ajaxViews - } // if - }; - -})(jQuery); diff --git a/advancedqueue_example/advancedqueue_example.info b/advancedqueue_example/advancedqueue_example.info new file mode 100644 index 0000000..47e00de --- /dev/null +++ b/advancedqueue_example/advancedqueue_example.info @@ -0,0 +1,6 @@ +name = Advanced Queues example +description = Example module for Advanced Queues module. +package = Other +core = 7.x + +dependencies[] = advancedqueue diff --git a/advancedqueue_example/advancedqueue_example.module b/advancedqueue_example/advancedqueue_example.module new file mode 100644 index 0000000..92beeb8 --- /dev/null +++ b/advancedqueue_example/advancedqueue_example.module @@ -0,0 +1,49 @@ + 'advancedqueue_example_worker', + ); + return $items; +} + +/** + * Advanced queue worker; Process a queue item. + * + * @param $item + * The item object to process. + * @param $end_time + * (Optional) The time this process should end. + */ +function advancedqueue_example_worker($item, $end_time = FALSE) { + $data = $item->data; + $params = array( + '@id' => $item->item_id, + '@uid' => $data['uid'], + '@time' => date('r', $data['timestamp']), + ); + drush_print(dt('The "worker" is now processing a example task number @id for user ID @uid created at @time.', $params)); +} + +/** + * Implements hook_init(). + * + * Create dummy queue items. + */ +function advancedqueue_example_init() { + global $user; + $queue = DrupalQueue::get('example_queue', TRUE); + $task = array( + 'timestamp' => time(), + 'uid' => $user->uid, + ); + $queue->createItem($task); +} diff --git a/drush/advancedqueue.drush.inc b/drush/advancedqueue.drush.inc new file mode 100644 index 0000000..5732e60 --- /dev/null +++ b/drush/advancedqueue.drush.inc @@ -0,0 +1,132 @@ + 'Run a processing job for a queue.', + 'arguments' => array( + 'queue' => dt('The name of the queue to process.'), + ), + 'options' => array( + 'timeout' => 'The maximum execution time of the script.', + 'all' => 'Process all queues.', + ), + ); + return $items; +} + +function drush_advancedqueue_process_queue() { + // Load information about the registred queues, and sort them by weight. + $all_queue_info = module_invoke_all('advanced_queue_info'); + drupal_alter('advanced_queue_info', $all_queue_info); + uasort($all_queue_info, 'drupal_sort_weight'); + + $all_option = drush_get_option('all'); + $queues = drush_get_option('queue'); + if (!$all_option && !$queues) { + return drush_set_error(dt('You have to specify either a set of queues or the --all parameter.')); + } + + if ($all_option) { + $queues = $all_queue_info; + } + else { + // Validate queues. + $queues = array_combine($queues, $queues); + $invalid_queues = array_diff_key($queues, $all_queue_info); + if ($invalid_queues) { + return drush_set_error(dt('The following queues are invalid: !queues. Aborting.', array('!queues' => implode(', ', $invalid_queues)))); + } + $queues = array_intersect_key($all_queue_info, $queues); + } + + if (!$queues) { + return drush_set_error(dt('No queues exist.')); + } + + // Run the worker for a certain period of time before killing it. + $timeout = drush_get_option('timeout'); + $end = $timeout ? time() + $timeout : 0; + + drush_log(dt('Starting processing loop.')); + + while (!$end || time() < $end) { + foreach ($queues as $queue_name => $queue_info) { + // Add default values. + $queue_info += array( + 'delete when completed' => TRUE, + ); + + $queue = DrupalQueue::get($queue_name); + + if ($item = $queue->claimItem()) { + drush_advancedqueue_process_item($queue, $queue_name, $queue_info, $item, $end); + continue 2; + } + } + + // No item processed in that round, let the CPU rest. + sleep(1); + } + + drush_log(dt('Timeout: exiting processing loop.')); +} + +/** + * Process a queue item. + * + * @param $queue + * The queue object. + * @param $queue_name + * The queue name. + * @param $queue_info + * The queue info. + * @param $item + * The item to process. + * @param $end_time + * (Optional) The time the process should end. + */ +function drush_advancedqueue_process_item($queue, $queue_name, $queue_info, $item, $end_time = FALSE) { + $function = $queue_info['worker callback']; + $params = array( + '@queue' => $queue_name, + '@id' => $item->item_id, + '@title' => $item->title ? $item->title : dt('untitled'), + ); + drush_log(dt('[@queue:@id] Starting processing item @title.', $params)); + + try { + // Pass the claimed item itself and end date along to the worker + // callback. + $output = $function($item, $end_time); + if (is_array($output)) { + $item->status = $output[0]; + $item->result = $output[1]; + } + else { + // TODO: remove magic constants. + $item->status = $output ? 1 : 2; + } + } + catch (Exception $e) { + $params['!message'] = (string) $e; + drush_log(dt('[!queue:!id] failed processing: !message', $params)); + // TODO: remove magic constants. + $item->status = 2; + } + + drush_log(dt('[@queue:@id] Processing ended.', $params)); + + if ($queue_info['delete when completed']) { + // Item was processed, so we can delete it. + $queue->deleteItem($item); + } +} diff --git a/tests/advancedqueue.test b/tests/advancedqueue.test deleted file mode 100644 index 09e5148..0000000 --- a/tests/advancedqueue.test +++ /dev/null @@ -1,19 +0,0 @@ - 'Advanced queue', - 'description' => 'Validate that a Advanced Queue works as a normal queue.', - 'group' => 'Advanced Queue', - ); - } - - function setUp() { - parent::setUp('advancedqueue'); - variable_set('queue_default_class', 'AdvancedQueue'); - } -}