View source
<?php
function revision_scheduler_list_page($entity_type, $entity) {
list($entity_id) = entity_extract_ids($entity_type, $entity);
$header = array(
t('Revision'),
t('Action'),
array(
'data' => t('Scheduled Date'),
'sort' => 'desc',
'field' => 'time_scheduled',
),
t('Operations'),
);
$query = db_select('revision_scheduler', 'r')
->extend('TableSort')
->extend('PagerDefault')
->limit(25)
->fields('r')
->orderByHeader($header)
->condition('entity_type', $entity_type)
->condition('entity_id', $entity_id);
$order = $query
->getOrderBy();
if (!empty($order['time_scheduled'])) {
$query
->orderBy('time_executed', $order['time_scheduled']);
$query
->orderBy('time_queued', $order['time_scheduled']);
$query
->orderBy('id', $order['time_scheduled']);
}
$operations = $query
->execute()
->fetchAll();
$revision_ids = array();
foreach ($operations as $operation) {
$revision_ids[] = $operation->revision_id;
}
$revisions = revision_scheduler_entity_revision_load_multiple($entity_type, $entity_id, $revision_ids);
$rows = array();
foreach ($operations as $id => $operation) {
$revision = !empty($revisions[$operation->revision_id]) ? $revisions[$operation->revision_id] : FALSE;
$operation_info = revision_scheduler_entity_revision_operation_get_info($entity_type, $operation->operation);
$row = array(
t('Revision @id: @label', array(
'@id' => $operation->revision_id,
'@label' => $revision ? entity_label($entity_type, $revision) : t('(Deleted)'),
)),
check_plain($operation_info['label']),
format_date($operation->time_scheduled),
);
if (!empty($operation->time_executed)) {
$row[] = t('Completed on @date', array(
'@date' => format_date($operation->time_executed),
));
}
elseif (!empty($operation->time_queued)) {
$row[] = t('Queued on @date', array(
'@date' => format_date($operation->time_queued),
));
}
else {
$operations = array();
if (revision_scheduler_operation_access('run', $operation)) {
$value = implode('-', array(
'run',
$operation->id,
$operation->operation,
$operation->time_scheduled,
));
$operations['run'] = array(
'title' => t('Run now'),
'href' => 'revision-scheduler/' . $operation->id . '/run',
'query' => array(
'token' => drupal_get_token($value),
) + drupal_get_destination(),
);
}
if (revision_scheduler_operation_access('update', $operation)) {
$operations['edit'] = array(
'title' => t('Edit'),
'href' => 'revision-scheduler/' . $operation->id . '/edit',
'query' => drupal_get_destination(),
);
}
if (revision_scheduler_operation_access('delete', $operation)) {
$operations['delete'] = array(
'title' => t('Cancel'),
'href' => 'revision-scheduler/' . $operation->id . '/delete',
'query' => drupal_get_destination(),
);
}
$row[] = array(
'data' => array(
'#theme' => 'links',
'#links' => $operations,
'#attributes' => array(
'class' => array(
'links',
'inline',
),
),
),
);
}
$rows[$id] = $row;
}
$build['table'] = array(
'#theme' => 'table',
'#header' => $header,
'#rows' => $rows,
'#empty' => t('No scheduled revisions available.'),
);
$build['pager'] = array(
'#theme' => 'pager',
'#weight' => 5,
);
return $build;
}
function revision_scheduler_add_form($form, &$form_state, $entity_type, $entity) {
$form_state['build_info']['base_form_id'] = 'revision_scheduler_edit_form';
list($entity_id, $revision_id) = entity_extract_ids($entity_type, $entity);
$operation = new stdClass();
$operation->id = NULL;
$operation->entity_type = $entity_type;
$operation->entity_id = $entity_id;
$operation->revision_id = $revision_id;
$operation->operation = NULL;
$operation->uid = $GLOBALS['user']->uid;
return revision_scheduler_edit_form($form, $form_state, $operation);
}
function revision_scheduler_edit_form($form, &$form_state, $operation, $entity = NULL) {
$form['id'] = array(
'#type' => 'value',
'#value' => $operation->id,
);
$form['entity_type'] = array(
'#type' => 'value',
'#value' => $operation->entity_type,
);
$form['entity_id'] = array(
'#type' => 'value',
'#value' => $operation->entity_id,
);
$form['uid'] = array(
'#type' => 'value',
'#value' => $operation->uid,
);
$parents = isset($form['#parents']) ? $form['#parents'] : array();
$operation_parents = array_merge($parents, array(
'operation',
));
$operation_state_name = $operation_parents[0];
if (count($operation_parents) > 1) {
$operation_state_name .= '[' . implode('][', array_slice($operation_parents, 1)) . ']';
}
if ($revision_id = drupal_array_get_nested_value($form_state, array_merge(array(
'values',
), $parents, array(
'revision_id',
)))) {
$operation->revision_id = $revision_id;
}
$revision_ids = revision_scheduler_get_all_entity_revision_ids($operation->entity_type, $operation->entity_id);
$revisions = revision_scheduler_entity_revision_load_multiple($operation->entity_type, $operation->entity_id, $revision_ids);
krsort($revisions);
if (empty($entity) && !empty($operation->revision_id) && !empty($revisions[$operation->revision_id])) {
$entity = $revisions[$operation->revision_id];
}
$wrapper = 'revision-scheduler-operation-wrapper-' . $operation->entity_type . '-' . (int) $operation->entity_id . '-' . (int) $operation->id;
$form['revision_id'] = array(
'#type' => 'select',
'#title' => t('Revision'),
'#options' => array(),
'#default_value' => $operation->revision_id,
'#required' => TRUE,
'#ajax' => array(
'callback' => 'revision_scheduler_update_operation_options',
'wrapper' => $wrapper,
'method' => 'replace',
'effect' => 'fade',
),
);
foreach ($revisions as $revision_id => $revision) {
$form['revision_id']['#options'][$revision_id] = t('Revision @id: @label', array(
'@id' => $revision_id,
'@label' => entity_label($operation->entity_type, $revision),
));
}
$form['operation'] = array(
'#prefix' => '<div id="' . $wrapper . '">',
'#suffix' => '</div>',
'#type' => 'select',
'#title' => t('Scheduled operation'),
'#options' => revision_scheduler_entity_revision_operation_get_options($operation->entity_type, $entity),
'#default_value' => $operation->operation,
'#required' => TRUE,
'#attributes' => array(
'class' => array(
'revision-scheduler-operation',
),
),
);
$date_format = variable_get('revision_scheduler_date_pattern', 'Y-m-d H:i');
$form['time_scheduled'] = array(
'#type' => 'textfield',
'#title' => t('Scheduled date'),
'#default_value' => !empty($operation->time_scheduled) ? format_date($operation->time_scheduled, 'custom', $date_format) : '',
'#description' => t('Format: %time. The timezone is %timezone.', array(
'%time' => format_date(REQUEST_TIME, 'custom', $date_format),
'%timezone' => drupal_get_user_timezone(),
)),
'#element_validate' => array(
'revision_scheduler_validate_time_scheduled',
),
'#attributes' => array(
'class' => array(
'revision-scheduler-time-scheduled',
),
),
'#states' => array(
'invisible' => array(
':input[name="' . $operation_state_name . '"]' => array(
'value' => '',
),
),
'optional' => array(
':input[name="' . $operation_state_name . '"]' => array(
'value' => '',
),
),
),
);
if (module_exists('date_popup')) {
$form['time_scheduled']['#type'] = 'date_popup';
$form['time_scheduled']['#date_format'] = $date_format;
$form['time_scheduled']['#date_year_range'] = '0:+5';
$form['time_scheduled']['#date_increment'] = 5;
}
$form['actions'] = array(
'#type' => 'actions',
);
$form['actions']['submit'] = array(
'#type' => 'submit',
'#value' => t('Schedule'),
);
if (!isset($_GET['destination']) && !empty($operation->entity_id) && ($uri = entity_uri($operation->entity_type, $entity))) {
$_GET['destination'] = $uri['path'];
}
$form['actions']['cancel'] = array(
'#type' => 'link',
'#title' => t('Cancel'),
'#href' => '<front>',
'#weight' => 10,
);
if (isset($_GET['destination'])) {
$url = drupal_parse_url(urldecode($_GET['destination']));
$form['actions']['cancel']['#href'] = $url['path'];
if (!empty($url['query'])) {
$form['actions']['cancel']['#options']['query'] = $url['query'];
}
}
return $form;
}
function revision_scheduler_update_operation_options($form, $form_state) {
return $form['operation'];
}
function revision_scheduler_validate_time_scheduled($element, &$form_state) {
$value = $element['#value'];
if (!empty($value) && is_array($value)) {
$value = implode(' ', array_filter($value));
}
if (!empty($value)) {
$value = strtotime($value);
if ($value === FALSE) {
form_error($element, t('Invalid revision scheduled date.'));
}
elseif ($value < REQUEST_TIME) {
form_error($element, t('You cannot set a revision scheduled date in the past.'));
}
}
else {
$parents = $element['#parents'];
array_pop($parents);
$parents[] = 'operation';
$operation_value = drupal_array_get_nested_value($form_state['values'], $parents);
if (!empty($operation_value)) {
form_set_error(implode('][', $element['#parents']), t('The revision scheduled date field is required.'));
}
}
}
function revision_scheduler_edit_form_submit($form, &$form_state) {
form_state_values_clean($form_state);
$operation = (object) $form_state['values'];
revision_scheduler_operation_save($operation);
drupal_set_message('The scheduled revision operation has been saved.');
}
function revision_scheduler_delete_form($form, &$form_state, $operation) {
$form['id'] = array(
'#type' => 'value',
'#value' => $operation->id,
);
$entity = revision_scheduler_entity_revision_load($operation->entity_type, $operation->entity_id, $operation->revision_id);
return confirm_form($form, 'Are you sure you want to cancel this scheduled revision?', entity_uri($operation->entity_type, $entity), NULL, NULL, t('No'));
}
function revision_scheduler_delete_form_submit($form, &$form_state) {
$id = $form_state['values']['id'];
revision_scheduler_operation_delete($id);
drupal_set_message('The scheduled revision operation has been cancelled.');
}
