123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029 |
- <?php
- /**
- * @file
- * Functions for form and batch generation and processing.
- */
- use Drupal\Component\Utility\UrlHelper;
- use Drupal\Core\Render\Element;
- use Drupal\Core\Render\Element\RenderElement;
- use Drupal\Core\Template\Attribute;
- use Drupal\Core\Url;
- use Symfony\Component\HttpFoundation\RedirectResponse;
- /**
- * Prepares variables for select element templates.
- *
- * Default template: select.html.twig.
- *
- * It is possible to group options together; to do this, change the format of
- * the #options property to an associative array in which the keys are group
- * labels, and the values are associative arrays in the normal #options format.
- *
- * @param $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #title, #value, #options, #description, #extra,
- * #multiple, #required, #name, #attributes, #size, #sort_options,
- * #sort_start.
- */
- function template_preprocess_select(&$variables) {
- $element = $variables['element'];
- Element::setAttributes($element, ['id', 'name', 'size']);
- RenderElement::setAttributes($element, ['form-select']);
- $variables['attributes'] = $element['#attributes'];
- $variables['options'] = form_select_options($element);
- }
- /**
- * Converts the options in a select element into a structured array for output.
- *
- * This function calls itself recursively to obtain the values for each optgroup
- * within the list of options and when the function encounters an object with
- * an 'options' property inside $element['#options'].
- *
- * @param array $element
- * An associative array containing properties of the select element. See
- * \Drupal\Core\Render\Element\Select for details, but note that the
- * #empty_option and #empty_value properties are processed, and the
- * #value property is set, before reaching this function.
- * @param array|null $choices
- * (optional) Either an associative array of options in the same format as
- * $element['#options'] above, or NULL. This parameter is only used internally
- * and is not intended to be passed in to the initial function call.
- *
- * @return mixed[]
- * A structured, possibly nested, array of options and optgroups for use in a
- * select form element.
- * - label: A translated string whose value is the text of a single HTML
- * option element, or the label attribute for an optgroup.
- * - options: Optional, array of options for an optgroup.
- * - selected: A boolean that indicates whether the option is selected when
- * rendered.
- * - type: A string that defines the element type. The value can be 'option'
- * or 'optgroup'.
- * - value: A string that contains the value attribute for the option.
- */
- function form_select_options($element, $choices = NULL) {
- if (!isset($choices)) {
- if (empty($element['#options'])) {
- return [];
- }
- $choices = $element['#options'];
- $sort_options = isset($element['#sort_options']) && $element['#sort_options'];
- $sort_start = $element['#sort_start'] ?? 0;
- }
- else {
- // We are within an option group.
- $sort_options = isset($choices['#sort_options']) && $choices['#sort_options'];
- $sort_start = $choices['#sort_start'] ?? 0;
- unset($choices['#sort_options']);
- unset($choices['#sort_start']);
- }
- // array_key_exists() accommodates the rare event where $element['#value'] is NULL.
- // isset() fails in this situation.
- $value_valid = isset($element['#value']) || array_key_exists('#value', $element);
- $value_is_array = $value_valid && is_array($element['#value']);
- // Check if the element is multiple select and no value has been selected.
- $empty_value = (empty($element['#value']) && !empty($element['#multiple']));
- $options = [];
- foreach ($choices as $key => $choice) {
- if (is_array($choice)) {
- $options[] = [
- 'type' => 'optgroup',
- 'label' => $key,
- 'options' => form_select_options($element, $choice),
- ];
- }
- elseif (is_object($choice) && isset($choice->option)) {
- $options = array_merge($options, form_select_options($element, $choice->option));
- }
- else {
- $option = [];
- $key = (string) $key;
- $empty_choice = $empty_value && $key == '_none';
- if ($value_valid && ((!$value_is_array && (string) $element['#value'] === $key || ($value_is_array && in_array($key, $element['#value']))) || $empty_choice)) {
- $option['selected'] = TRUE;
- }
- else {
- $option['selected'] = FALSE;
- }
- $option['type'] = 'option';
- $option['value'] = $key;
- $option['label'] = $choice;
- $options[] = $option;
- }
- }
- if ($sort_options) {
- $unsorted = array_slice($options, 0, $sort_start);
- $sorted = array_slice($options, $sort_start);
- uasort($sorted, function ($a, $b) {
- return strcmp((string) $a['label'], (string) $b['label']);
- });
- $options = array_merge($unsorted, $sorted);
- }
- return $options;
- }
- /**
- * Returns the indexes of a select element's options matching a given key.
- *
- * This function is useful if you need to modify the options that are
- * already in a form element; for example, to remove choices which are
- * not valid because of additional filters imposed by another module.
- * One example might be altering the choices in a taxonomy selector.
- * To correctly handle the case of a multiple hierarchy taxonomy,
- * #options arrays can now hold an array of objects, instead of a
- * direct mapping of keys to labels, so that multiple choices in the
- * selector can have the same key (and label). This makes it difficult
- * to manipulate directly, which is why this helper function exists.
- *
- * This function does not support optgroups (when the elements of the
- * #options array are themselves arrays), and will return FALSE if
- * arrays are found. The caller must either flatten/restore or
- * manually do their manipulations in this case, since returning the
- * index is not sufficient, and supporting this would make the
- * "helper" too complicated and cumbersome to be of any help.
- *
- * As usual with functions that can return array() or FALSE, do not
- * forget to use === and !== if needed.
- *
- * @param $element
- * The select element to search.
- * @param $key
- * The key to look for.
- *
- * @return
- * An array of indexes that match the given $key. Array will be
- * empty if no elements were found. FALSE if optgroups were found.
- */
- function form_get_options($element, $key) {
- $keys = [];
- foreach ($element['#options'] as $index => $choice) {
- if (is_array($choice)) {
- return FALSE;
- }
- elseif (is_object($choice)) {
- if (isset($choice->option[$key])) {
- $keys[] = $index;
- }
- }
- elseif ($index == $key) {
- $keys[] = $index;
- }
- }
- return $keys;
- }
- /**
- * Prepares variables for fieldset element templates.
- *
- * Default template: fieldset.html.twig.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #attributes, #children, #description, #id, #title,
- * #value.
- */
- function template_preprocess_fieldset(&$variables) {
- $element = $variables['element'];
- Element::setAttributes($element, ['id']);
- RenderElement::setAttributes($element);
- $variables['attributes'] = isset($element['#attributes']) ? $element['#attributes'] : [];
- $variables['prefix'] = isset($element['#field_prefix']) ? $element['#field_prefix'] : NULL;
- $variables['suffix'] = isset($element['#field_suffix']) ? $element['#field_suffix'] : NULL;
- $variables['title_display'] = isset($element['#title_display']) ? $element['#title_display'] : NULL;
- $variables['children'] = $element['#children'];
- $variables['required'] = !empty($element['#required']) ? $element['#required'] : NULL;
- if (isset($element['#title']) && $element['#title'] !== '') {
- $variables['legend']['title'] = ['#markup' => $element['#title']];
- }
- $variables['legend']['attributes'] = new Attribute();
- // Add 'visually-hidden' class to legend span.
- if ($variables['title_display'] == 'invisible') {
- $variables['legend_span']['attributes'] = new Attribute(['class' => ['visually-hidden']]);
- }
- else {
- $variables['legend_span']['attributes'] = new Attribute();
- }
- if (!empty($element['#description'])) {
- $description_id = $element['#attributes']['id'] . '--description';
- $description_attributes['id'] = $description_id;
- $variables['description']['attributes'] = new Attribute($description_attributes);
- $variables['description']['content'] = $element['#description'];
- // Add the description's id to the fieldset aria attributes.
- $variables['attributes']['aria-describedby'] = $description_id;
- }
- // Suppress error messages.
- $variables['errors'] = NULL;
- }
- /**
- * Prepares variables for details element templates.
- *
- * Default template: details.html.twig.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #attributes, #children, #description, #required,
- * #summary_attributes, #title, #value.
- */
- function template_preprocess_details(&$variables) {
- $element = $variables['element'];
- $variables['attributes'] = $element['#attributes'];
- $variables['summary_attributes'] = new Attribute($element['#summary_attributes']);
- if (!empty($element['#title'])) {
- $variables['summary_attributes']['role'] = 'button';
- if (!empty($element['#attributes']['id'])) {
- $variables['summary_attributes']['aria-controls'] = $element['#attributes']['id'];
- }
- $variables['summary_attributes']['aria-expanded'] = !empty($element['#attributes']['open']) ? 'true' : 'false';
- $variables['summary_attributes']['aria-pressed'] = $variables['summary_attributes']['aria-expanded'];
- }
- $variables['title'] = (!empty($element['#title'])) ? $element['#title'] : '';
- // If the element title is a string, wrap it a render array so that markup
- // will not be escaped (but XSS-filtered).
- if (is_string($variables['title']) && $variables['title'] !== '') {
- $variables['title'] = ['#markup' => $variables['title']];
- }
- $variables['description'] = (!empty($element['#description'])) ? $element['#description'] : '';
- $variables['children'] = (isset($element['#children'])) ? $element['#children'] : '';
- $variables['value'] = (isset($element['#value'])) ? $element['#value'] : '';
- $variables['required'] = !empty($element['#required']) ? $element['#required'] : NULL;
- // Suppress error messages.
- $variables['errors'] = NULL;
- }
- /**
- * Prepares variables for radios templates.
- *
- * Default template: radios.html.twig.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #title, #value, #options, #description, #required,
- * #attributes, #children.
- */
- function template_preprocess_radios(&$variables) {
- $element = $variables['element'];
- $variables['attributes'] = [];
- if (isset($element['#id'])) {
- $variables['attributes']['id'] = $element['#id'];
- }
- if (isset($element['#attributes']['title'])) {
- $variables['attributes']['title'] = $element['#attributes']['title'];
- }
- $variables['children'] = $element['#children'];
- }
- /**
- * Prepares variables for checkboxes templates.
- *
- * Default template: checkboxes.html.twig.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #children, #attributes.
- */
- function template_preprocess_checkboxes(&$variables) {
- $element = $variables['element'];
- $variables['attributes'] = [];
- if (isset($element['#id'])) {
- $variables['attributes']['id'] = $element['#id'];
- }
- if (isset($element['#attributes']['title'])) {
- $variables['attributes']['title'] = $element['#attributes']['title'];
- }
- $variables['children'] = $element['#children'];
- }
- /**
- * Prepares variables for vertical tabs templates.
- *
- * Default template: vertical-tabs.html.twig.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties and children of
- * the details element. Properties used: #children.
- */
- function template_preprocess_vertical_tabs(&$variables) {
- $element = $variables['element'];
- $variables['children'] = (!empty($element['#children'])) ? $element['#children'] : '';
- }
- /**
- * Prepares variables for input templates.
- *
- * Default template: input.html.twig.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #attributes.
- */
- function template_preprocess_input(&$variables) {
- $element = $variables['element'];
- // Remove name attribute if empty, for W3C compliance.
- if (isset($variables['attributes']['name']) && empty((string) $variables['attributes']['name'])) {
- unset($variables['attributes']['name']);
- }
- $variables['children'] = $element['#children'];
- }
- /**
- * Prepares variables for form templates.
- *
- * Default template: form.html.twig.
- *
- * @param $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #action, #method, #attributes, #children
- */
- function template_preprocess_form(&$variables) {
- $element = $variables['element'];
- if (isset($element['#action'])) {
- $element['#attributes']['action'] = UrlHelper::stripDangerousProtocols($element['#action']);
- }
- Element::setAttributes($element, ['method', 'id']);
- if (empty($element['#attributes']['accept-charset'])) {
- $element['#attributes']['accept-charset'] = "UTF-8";
- }
- $variables['attributes'] = $element['#attributes'];
- $variables['children'] = $element['#children'];
- }
- /**
- * Prepares variables for textarea templates.
- *
- * Default template: textarea.html.twig.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #title, #value, #description, #rows, #cols, #maxlength,
- * #placeholder, #required, #attributes, #resizable.
- */
- function template_preprocess_textarea(&$variables) {
- $element = $variables['element'];
- $attributes = ['id', 'name', 'rows', 'cols', 'maxlength', 'placeholder'];
- Element::setAttributes($element, $attributes);
- RenderElement::setAttributes($element, ['form-textarea']);
- $variables['wrapper_attributes'] = new Attribute();
- $variables['attributes'] = new Attribute($element['#attributes']);
- $variables['value'] = $element['#value'];
- $variables['resizable'] = !empty($element['#resizable']) ? $element['#resizable'] : NULL;
- $variables['required'] = !empty($element['#required']) ? $element['#required'] : NULL;
- }
- /**
- * Returns HTML for a form element.
- * Prepares variables for form element templates.
- *
- * Default template: form-element.html.twig.
- *
- * In addition to the element itself, the DIV contains a label for the element
- * based on the optional #title_display property, and an optional #description.
- *
- * The optional #title_display property can have these values:
- * - before: The label is output before the element. This is the default.
- * The label includes the #title and the required marker, if #required.
- * - after: The label is output after the element. For example, this is used
- * for radio and checkbox #type elements. If the #title is empty but the field
- * is #required, the label will contain only the required marker.
- * - invisible: Labels are critical for screen readers to enable them to
- * properly navigate through forms but can be visually distracting. This
- * property hides the label for everyone except screen readers.
- * - attribute: Set the title attribute on the element to create a tooltip
- * but output no label element. This is supported only for checkboxes
- * and radios in
- * \Drupal\Core\Render\Element\CompositeFormElementTrait::preRenderCompositeFormElement().
- * It is used where a visual label is not needed, such as a table of
- * checkboxes where the row and column provide the context. The tooltip will
- * include the title and required marker.
- *
- * If the #title property is not set, then the label and any required marker
- * will not be output, regardless of the #title_display or #required values.
- * This can be useful in cases such as the password_confirm element, which
- * creates children elements that have their own labels and required markers,
- * but the parent element should have neither. Use this carefully because a
- * field without an associated label can cause accessibility challenges.
- *
- * To associate the label with a different field, set the #label_for property
- * to the ID of the desired field.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #title, #title_display, #description, #id, #required,
- * #children, #type, #name, #label_for.
- */
- function template_preprocess_form_element(&$variables) {
- $element = &$variables['element'];
- // This function is invoked as theme wrapper, but the rendered form element
- // may not necessarily have been processed by
- // \Drupal::formBuilder()->doBuildForm().
- $element += [
- '#title_display' => 'before',
- '#wrapper_attributes' => [],
- '#label_attributes' => [],
- '#label_for' => NULL,
- ];
- $variables['attributes'] = $element['#wrapper_attributes'];
- // Add element #id for #type 'item'.
- if (isset($element['#markup']) && !empty($element['#id'])) {
- $variables['attributes']['id'] = $element['#id'];
- }
- // Pass elements #type and #name to template.
- if (!empty($element['#type'])) {
- $variables['type'] = $element['#type'];
- }
- if (!empty($element['#name'])) {
- $variables['name'] = $element['#name'];
- }
- // Pass elements disabled status to template.
- $variables['disabled'] = !empty($element['#attributes']['disabled']) ? $element['#attributes']['disabled'] : NULL;
- // Suppress error messages.
- $variables['errors'] = NULL;
- // If #title is not set, we don't display any label.
- if (!isset($element['#title'])) {
- $element['#title_display'] = 'none';
- }
- $variables['title_display'] = $element['#title_display'];
- $variables['prefix'] = isset($element['#field_prefix']) ? $element['#field_prefix'] : NULL;
- $variables['suffix'] = isset($element['#field_suffix']) ? $element['#field_suffix'] : NULL;
- $variables['description'] = NULL;
- if (!empty($element['#description'])) {
- $variables['description_display'] = $element['#description_display'];
- $description_attributes = [];
- if (!empty($element['#id'])) {
- $description_attributes['id'] = $element['#id'] . '--description';
- }
- $variables['description']['attributes'] = new Attribute($description_attributes);
- $variables['description']['content'] = $element['#description'];
- }
- // Add label_display and label variables to template.
- $variables['label_display'] = $element['#title_display'];
- $variables['label'] = ['#theme' => 'form_element_label'];
- $variables['label'] += array_intersect_key($element, array_flip(['#id', '#required', '#title', '#title_display']));
- $variables['label']['#attributes'] = $element['#label_attributes'];
- if (!empty($element['#label_for'])) {
- $variables['label']['#for'] = $element['#label_for'];
- if (!empty($element['#id'])) {
- $variables['label']['#id'] = $element['#id'] . '--label';
- }
- }
- $variables['children'] = $element['#children'];
- }
- /**
- * Prepares variables for form label templates.
- *
- * Form element labels include the #title and a #required marker. The label is
- * associated with the element itself by the element #id. Labels may appear
- * before or after elements, depending on form-element.html.twig and
- * #title_display.
- *
- * This function will not be called for elements with no labels, depending on
- * #title_display. For elements that have an empty #title and are not required,
- * this function will output no label (''). For required elements that have an
- * empty #title, this will output the required marker alone within the label.
- * The label will use the #id to associate the marker with the field that is
- * required. That is especially important for screenreader users to know
- * which field is required.
- *
- * To associate the label with a different field, set the #for property to the
- * ID of the desired field.
- *
- * @param array $variables
- * An associative array containing:
- * - element: An associative array containing the properties of the element.
- * Properties used: #required, #title, #id, #value, #description, #for.
- */
- function template_preprocess_form_element_label(&$variables) {
- $element = $variables['element'];
- // If title and required marker are both empty, output no label.
- if (isset($element['#title']) && $element['#title'] !== '') {
- $variables['title'] = ['#markup' => $element['#title']];
- }
- // Pass elements title_display to template.
- $variables['title_display'] = $element['#title_display'];
- // A #for property of a dedicated #type 'label' element as precedence.
- if (!empty($element['#for'])) {
- $variables['attributes']['for'] = $element['#for'];
- // A custom #id allows the referenced form input element to refer back to
- // the label element; e.g., in the 'aria-labelledby' attribute.
- if (!empty($element['#id'])) {
- $variables['attributes']['id'] = $element['#id'];
- }
- }
- // Otherwise, point to the #id of the form input element.
- elseif (!empty($element['#id'])) {
- $variables['attributes']['for'] = $element['#id'];
- }
- // Pass elements required to template.
- $variables['required'] = !empty($element['#required']) ? $element['#required'] : NULL;
- }
- /**
- * @defgroup batch Batch operations
- * @{
- * Creates and processes batch operations.
- *
- * Functions allowing forms processing to be spread out over several page
- * requests, thus ensuring that the processing does not get interrupted
- * because of a PHP timeout, while allowing the user to receive feedback
- * on the progress of the ongoing operations.
- *
- * The API is primarily designed to integrate nicely with the Form API
- * workflow, but can also be used by non-Form API scripts (like update.php)
- * or even simple page callbacks (which should probably be used sparingly).
- *
- * Example:
- * @code
- * $batch = array(
- * 'title' => t('Exporting'),
- * 'operations' => array(
- * array('my_function_1', array($account->id(), 'story')),
- * array('my_function_2', array()),
- * ),
- * 'finished' => 'my_finished_callback',
- * 'file' => 'path_to_file_containing_myfunctions',
- * );
- * batch_set($batch);
- * // Only needed if not inside a form _submit handler.
- * // Setting redirect in batch_process.
- * batch_process('node/1');
- * @endcode
- *
- * Note: if the batch 'title', 'init_message', 'progress_message', or
- * 'error_message' could contain any user input, it is the responsibility of
- * the code calling batch_set() to sanitize them first with a function like
- * \Drupal\Component\Utility\Html::escape() or
- * \Drupal\Component\Utility\Xss::filter(). Furthermore, if the batch operation
- * returns any user input in the 'results' or 'message' keys of $context, it
- * must also sanitize them first.
- *
- * Sample callback_batch_operation():
- * @code
- * // Simple and artificial: load a node of a given type for a given user
- * function my_function_1($uid, $type, &$context) {
- * // The $context array gathers batch context information about the execution (read),
- * // as well as 'return values' for the current operation (write)
- * // The following keys are provided :
- * // 'results' (read / write): The array of results gathered so far by
- * // the batch processing, for the current operation to append its own.
- * // 'message' (write): A text message displayed in the progress page.
- * // The following keys allow for multi-step operations :
- * // 'sandbox' (read / write): An array that can be freely used to
- * // store persistent data between iterations. It is recommended to
- * // use this instead of $_SESSION, which is unsafe if the user
- * // continues browsing in a separate window while the batch is processing.
- * // 'finished' (write): A float number between 0 and 1 informing
- * // the processing engine of the completion level for the operation.
- * // 1 (or no value explicitly set) means the operation is finished
- * // and the batch processing can continue to the next operation.
- *
- * $nodes = \Drupal::entityTypeManager()->getStorage('node')
- * ->loadByProperties(['uid' => $uid, 'type' => $type]);
- * $node = reset($nodes);
- * $context['results'][] = $node->id() . ' : ' . Html::escape($node->label());
- * $context['message'] = Html::escape($node->label());
- * }
- *
- * // A more advanced example is a multi-step operation that loads all rows,
- * // five by five.
- * function my_function_2(&$context) {
- * if (empty($context['sandbox'])) {
- * $context['sandbox']['progress'] = 0;
- * $context['sandbox']['current_id'] = 0;
- * $context['sandbox']['max'] = \Drupal::database()
- * ->query('SELECT COUNT(DISTINCT id) FROM {example}')
- * ->fetchField();
- * }
- * $limit = 5;
- * $result = \Drupal::database()->select('example')
- * ->fields('example', array('id'))
- * ->condition('id', $context['sandbox']['current_id'], '>')
- * ->orderBy('id')
- * ->range(0, $limit)
- * ->execute();
- * foreach ($result as $row) {
- * $context['results'][] = $row->id . ' : ' . Html::escape($row->title);
- * $context['sandbox']['progress']++;
- * $context['sandbox']['current_id'] = $row->id;
- * $context['message'] = Html::escape($row->title);
- * }
- * if ($context['sandbox']['progress'] != $context['sandbox']['max']) {
- * $context['finished'] = $context['sandbox']['progress'] / $context['sandbox']['max'];
- * }
- * }
- * @endcode
- *
- * Sample callback_batch_finished():
- * @code
- * function my_finished_callback($success, $results, $operations) {
- * // The 'success' parameter means no fatal PHP errors were detected. All
- * // other error management should be handled using 'results'.
- * if ($success) {
- * $message = \Drupal::translation()->formatPlural(count($results), 'One post processed.', '@count posts processed.');
- * }
- * else {
- * $message = t('Finished with an error.');
- * }
- * \Drupal::messenger()->addMessage($message);
- * // Providing data for the redirected page is done through $_SESSION.
- * foreach ($results as $result) {
- * $items[] = t('Loaded node %title.', array('%title' => $result));
- * }
- * $_SESSION['my_batch_results'] = $items;
- * }
- * @endcode
- */
- /**
- * Adds a new batch.
- *
- * Batch operations are added as new batch sets. Batch sets are used to spread
- * processing (primarily, but not exclusively, forms processing) over several
- * page requests. This helps to ensure that the processing is not interrupted
- * due to PHP timeouts, while users are still able to receive feedback on the
- * progress of the ongoing operations. Combining related operations into
- * distinct batch sets provides clean code independence for each batch set,
- * ensuring that two or more batches, submitted independently, can be processed
- * without mutual interference. Each batch set may specify its own set of
- * operations and results, produce its own UI messages, and trigger its own
- * 'finished' callback. Batch sets are processed sequentially, with the progress
- * bar starting afresh for each new set.
- *
- * @param $batch_definition
- * An associative array defining the batch, with the following elements (all
- * are optional except as noted):
- * - operations: (required) Array of operations to be performed, where each
- * item is an array consisting of the name of an implementation of
- * callback_batch_operation() and an array of parameter.
- * Example:
- * @code
- * array(
- * array('callback_batch_operation_1', array($arg1)),
- * array('callback_batch_operation_2', array($arg2_1, $arg2_2)),
- * )
- * @endcode
- * - title: A safe, translated string to use as the title for the progress
- * page. Defaults to t('Processing').
- * - init_message: Message displayed while the processing is initialized.
- * Defaults to t('Initializing.').
- * - progress_message: Message displayed while processing the batch. Available
- * placeholders are @current, @remaining, @total, @percentage, @estimate and
- * @elapsed. Defaults to t('Completed @current of @total.').
- * - error_message: Message displayed if an error occurred while processing
- * the batch. Defaults to t('An error has occurred.').
- * - finished: Name of an implementation of callback_batch_finished(). This is
- * executed after the batch has completed. This should be used to perform
- * any result massaging that may be needed, and possibly save data in
- * $_SESSION for display after final page redirection.
- * - file: Path to the file containing the definitions of the 'operations' and
- * 'finished' functions, for instance if they don't reside in the main
- * .module file. The path should be relative to base_path(), and thus should
- * be built using drupal_get_path().
- * - library: An array of batch-specific CSS and JS libraries.
- * - url_options: options passed to the \Drupal\Core\Url object when
- * constructing redirect URLs for the batch.
- * - progressive: A Boolean that indicates whether or not the batch needs to
- * run progressively. TRUE indicates that the batch will run in more than
- * one run. FALSE (default) indicates that the batch will finish in a single
- * run.
- * - queue: An override of the default queue (with name and class fields
- * optional). An array containing two elements:
- * - name: Unique identifier for the queue.
- * - class: The name of a class that implements
- * \Drupal\Core\Queue\QueueInterface, including the full namespace but not
- * starting with a backslash. It must have a constructor with two
- * arguments: $name and a \Drupal\Core\Database\Connection object.
- * Typically, the class will either be \Drupal\Core\Queue\Batch or
- * \Drupal\Core\Queue\BatchMemory. Defaults to Batch if progressive is
- * TRUE, or to BatchMemory if progressive is FALSE.
- */
- function batch_set($batch_definition) {
- if ($batch_definition) {
- $batch =& batch_get();
- // Initialize the batch if needed.
- if (empty($batch)) {
- $batch = [
- 'sets' => [],
- 'has_form_submits' => FALSE,
- ];
- }
- // Base and default properties for the batch set.
- $init = [
- 'sandbox' => [],
- 'results' => [],
- 'success' => FALSE,
- 'start' => 0,
- 'elapsed' => 0,
- ];
- $defaults = [
- 'title' => t('Processing'),
- 'init_message' => t('Initializing.'),
- 'progress_message' => t('Completed @current of @total.'),
- 'error_message' => t('An error has occurred.'),
- ];
- $batch_set = $init + $batch_definition + $defaults;
- // Tweak init_message to avoid the bottom of the page flickering down after
- // init phase.
- $batch_set['init_message'] .= '<br/> ';
- // The non-concurrent workflow of batch execution allows us to save
- // numberOfItems() queries by handling our own counter.
- $batch_set['total'] = count($batch_set['operations']);
- $batch_set['count'] = $batch_set['total'];
- // Add the set to the batch.
- if (empty($batch['id'])) {
- // The batch is not running yet. Simply add the new set.
- $batch['sets'][] = $batch_set;
- }
- else {
- // The set is being added while the batch is running.
- _batch_append_set($batch, $batch_set);
- }
- }
- }
- /**
- * Appends a batch set to a running batch.
- *
- * Inserts the new set right after the current one to ensure execution order,
- * and stores its operations in a queue. If the current batch has already
- * inserted a new set, additional sets will be inserted after the last inserted
- * set.
- *
- * @param &$batch
- * The batch array.
- * @param $batch_set
- * The batch set.
- */
- function _batch_append_set(&$batch, $batch_set) {
- $append_after_index = $batch['current_set'];
- $reached_current_set = FALSE;
- foreach ($batch['sets'] as $index => $set) {
- // As the indexes are not ordered numerically we need to first reach the
- // index of the current set and then search for the proper place to append
- // the new batch set.
- if (!$reached_current_set) {
- if ($index == $batch['current_set']) {
- $reached_current_set = TRUE;
- }
- continue;
- }
- if ($index > $append_after_index) {
- if (isset($set['appended_after_index'])) {
- $append_after_index = $index;
- }
- else {
- break;
- }
- }
- }
- $batch_set['appended_after_index'] = $append_after_index;
- // Iterate by reference over the existing batch sets and assign them by
- // reference in the new batch sets array in order not to break a retrieved
- // reference to the current set. Among other places a reference to the current
- // set is being retrieved in _batch_process(). Additionally, we have to
- // preserve the original indexes, as they are used to generate the queue name
- // of each batch set, otherwise the operations of the new batch set will be
- // queued in the queue of a previous batch set.
- // @see _batch_populate_queue().
- $new_sets = [];
- foreach ($batch['sets'] as $index => &$set) {
- $new_sets[$index] = &$set;
- if ($index == $append_after_index) {
- $new_set_index = count($batch['sets']);
- $new_sets[$new_set_index] = $batch_set;
- }
- }
- $batch['sets'] = $new_sets;
- _batch_populate_queue($batch, $new_set_index);
- }
- /**
- * Processes the batch.
- *
- * This function is generally not needed in form submit handlers;
- * Form API takes care of batches that were set during form submission.
- *
- * @param \Drupal\Core\Url|string $redirect
- * (optional) Either a path or Url object to redirect to when the batch has
- * finished processing. For example, to redirect users to the home page, use
- * '<front>'. If you wish to allow standard form API batch handling to occur
- * and force the user to be redirected to a custom location after the batch
- * has finished processing, you do not need to use batch_process() and this
- * parameter. Instead, make the batch 'finished' callback return an instance
- * of \Symfony\Component\HttpFoundation\RedirectResponse, which will be used
- * automatically by the standard batch processing pipeline (and which takes
- * precedence over this parameter). If this parameter is omitted and no
- * redirect response was returned by the 'finished' callback, the user will
- * be redirected to the page that started the batch. Any query arguments will
- * be automatically persisted.
- * @param \Drupal\Core\Url $url
- * (optional) URL of the batch processing page. Should only be used for
- * separate scripts like update.php.
- * @param $redirect_callback
- * (optional) Specify a function to be called to redirect to the progressive
- * processing page.
- *
- * @return \Symfony\Component\HttpFoundation\RedirectResponse|null
- * A redirect response if the batch is progressive. No return value otherwise.
- */
- function batch_process($redirect = NULL, Url $url = NULL, $redirect_callback = NULL) {
- $batch =& batch_get();
- if (isset($batch)) {
- // Add process information
- $process_info = [
- 'current_set' => 0,
- 'progressive' => TRUE,
- 'url' => isset($url) ? $url : Url::fromRoute('system.batch_page.html'),
- 'source_url' => Url::fromRouteMatch(\Drupal::routeMatch())->mergeOptions(['query' => \Drupal::request()->query->all()]),
- 'batch_redirect' => $redirect,
- 'theme' => \Drupal::theme()->getActiveTheme()->getName(),
- 'redirect_callback' => $redirect_callback,
- ];
- $batch += $process_info;
- // The batch is now completely built. Allow other modules to make changes
- // to the batch so that it is easier to reuse batch processes in other
- // environments.
- \Drupal::moduleHandler()->alter('batch', $batch);
- // Assign an arbitrary id: don't rely on a serial column in the 'batch'
- // table, since non-progressive batches skip database storage completely.
- $batch['id'] = \Drupal::database()->nextId();
- // Move operations to a job queue. Non-progressive batches will use a
- // memory-based queue.
- foreach ($batch['sets'] as $key => $batch_set) {
- _batch_populate_queue($batch, $key);
- }
- // Initiate processing.
- if ($batch['progressive']) {
- // Now that we have a batch id, we can generate the redirection link in
- // the generic error message.
- /** @var \Drupal\Core\Url $batch_url */
- $batch_url = $batch['url'];
- /** @var \Drupal\Core\Url $error_url */
- $error_url = clone $batch_url;
- $query_options = $error_url->getOption('query');
- $query_options['id'] = $batch['id'];
- $query_options['op'] = 'finished';
- $error_url->setOption('query', $query_options);
- $batch['error_message'] = t('Please continue to <a href=":error_url">the error page</a>', [':error_url' => $error_url->toString(TRUE)->getGeneratedUrl()]);
- // Clear the way for the redirection to the batch processing page, by
- // saving and unsetting the 'destination', if there is any.
- $request = \Drupal::request();
- if ($request->query->has('destination')) {
- $batch['destination'] = $request->query->get('destination');
- $request->query->remove('destination');
- }
- // Store the batch.
- \Drupal::service('batch.storage')->create($batch);
- // Set the batch number in the session to guarantee that it will stay alive.
- $_SESSION['batches'][$batch['id']] = TRUE;
- // Redirect for processing.
- $query_options = $error_url->getOption('query');
- $query_options['op'] = 'start';
- $query_options['id'] = $batch['id'];
- $batch_url->setOption('query', $query_options);
- if (($function = $batch['redirect_callback']) && function_exists($function)) {
- $function($batch_url->toString(), ['query' => $query_options]);
- }
- else {
- return new RedirectResponse($batch_url->setAbsolute()->toString(TRUE)->getGeneratedUrl());
- }
- }
- else {
- // Non-progressive execution: bypass the whole progressbar workflow
- // and execute the batch in one pass.
- require_once __DIR__ . '/batch.inc';
- _batch_process();
- }
- }
- }
- /**
- * Retrieves the current batch.
- */
- function &batch_get() {
- // Not drupal_static(), because Batch API operates at a lower level than most
- // use-cases for resetting static variables, and we specifically do not want a
- // global drupal_static_reset() resetting the batch information. Functions
- // that are part of the Batch API and need to reset the batch information may
- // call batch_get() and manipulate the result by reference. Functions that are
- // not part of the Batch API can also do this, but shouldn't.
- static $batch = [];
- return $batch;
- }
- /**
- * Populates a job queue with the operations of a batch set.
- *
- * Depending on whether the batch is progressive or not, the
- * Drupal\Core\Queue\Batch or Drupal\Core\Queue\BatchMemory handler classes will
- * be used. The name and class of the queue are added by reference to the
- * batch set.
- *
- * @param $batch
- * The batch array.
- * @param $set_id
- * The id of the set to process.
- */
- function _batch_populate_queue(&$batch, $set_id) {
- $batch_set = &$batch['sets'][$set_id];
- if (isset($batch_set['operations'])) {
- $batch_set += [
- 'queue' => [
- 'name' => 'drupal_batch:' . $batch['id'] . ':' . $set_id,
- 'class' => $batch['progressive'] ? 'Drupal\Core\Queue\Batch' : 'Drupal\Core\Queue\BatchMemory',
- ],
- ];
- $queue = _batch_queue($batch_set);
- $queue->createQueue();
- foreach ($batch_set['operations'] as $operation) {
- $queue->createItem($operation);
- }
- unset($batch_set['operations']);
- }
- }
- /**
- * Returns a queue object for a batch set.
- *
- * @param $batch_set
- * The batch set.
- *
- * @return
- * The queue object.
- */
- function _batch_queue($batch_set) {
- static $queues;
- if (!isset($queues)) {
- $queues = [];
- }
- if (isset($batch_set['queue'])) {
- $name = $batch_set['queue']['name'];
- $class = $batch_set['queue']['class'];
- if (!isset($queues[$class][$name])) {
- $queues[$class][$name] = new $class($name, \Drupal::database());
- }
- return $queues[$class][$name];
- }
- }
- /**
- * @} End of "defgroup batch".
- */
|