Homec4science
Diffusion Phabricator (production) Browse

phab/src/applications/transactions/bulk/PhabricatorEditEngineBulkJobType.php
f887648972a3production

Last Change
Raw File

PhabricatorEditEngineBulkJobType.php
View Options

<?php
final class PhabricatorEditEngineBulkJobType
extends PhabricatorWorkerBulkJobType {
public function getBulkJobTypeKey() {
return 'transaction.edit';
}
public function getJobName(PhabricatorWorkerBulkJob $job) {
return pht('Bulk Edit');
}
public function getDescriptionForConfirm(PhabricatorWorkerBulkJob $job) {
$parts = array();
$parts[] = pht(
'You are about to apply a bulk edit which will affect '.
'%s object(s).',
new PhutilNumber($job->getSize()));
if ($job->getIsSilent()) {
$parts[] = pht(
'If you start work now, this edit will be applied silently: it will '.
'not send mail or publish notifications.');
} else {
$parts[] = pht(
'If you start work now, this edit will send mail and publish '.
'notifications normally.');
$parts[] = pht('To silence this edit, run this command:');
$command = csprintf(
'phabricator/ $ ./bin/bulk make-silent --id %R',
$job->getID());
$command = (string)$command;
$parts[] = phutil_tag('tt', array(), $command);
$parts[] = pht(
'After running this command, reload this page to see the new setting.');
}
return $parts;
}
public function getJobSize(PhabricatorWorkerBulkJob $job) {
return count($job->getParameter('objectPHIDs', array()));
}
public function getDoneURI(PhabricatorWorkerBulkJob $job) {
return $job->getParameter('doneURI');
}
public function createTasks(PhabricatorWorkerBulkJob $job) {
$tasks = array();
foreach ($job->getParameter('objectPHIDs', array()) as $phid) {
$tasks[] = PhabricatorWorkerBulkTask::initializeNewTask($job, $phid);
}
return $tasks;
}
public function runTask(
PhabricatorUser $actor,
PhabricatorWorkerBulkJob $job,
PhabricatorWorkerBulkTask $task) {
$object = id(new PhabricatorObjectQuery())
->setViewer($actor)
->withPHIDs(array($task->getObjectPHID()))
->requireCapabilities(
array(
PhabricatorPolicyCapability::CAN_VIEW,
PhabricatorPolicyCapability::CAN_EDIT,
))
->executeOne();
if (!$object) {
return;
}
$raw_xactions = $job->getParameter('xactions');
$xactions = $this->buildTransactions($object, $raw_xactions);
$is_silent = $job->getIsSilent();
$editor = $object->getApplicationTransactionEditor()
->setActor($actor)
->setContentSource($job->newContentSource())
->setContinueOnNoEffect(true)
->setContinueOnMissingFields(true)
->setIsSilent($is_silent)
->applyTransactions($object, $xactions);
}
private function buildTransactions($object, array $raw_xactions) {
$xactions = array();
foreach ($raw_xactions as $raw_xaction) {
$xaction = $object->getApplicationTransactionTemplate()
->setTransactionType($raw_xaction['type']);
if (isset($raw_xaction['new'])) {
$xaction->setNewValue($raw_xaction['new']);
}
if (isset($raw_xaction['comment'])) {
$comment = $xaction->getApplicationTransactionCommentObject()
->setContent($raw_xaction['comment']);
$xaction->attachComment($comment);
}
if (isset($raw_xaction['metadata'])) {
foreach ($raw_xaction['metadata'] as $meta_key => $meta_value) {
$xaction->setMetadataValue($meta_key, $meta_value);
}
}
if (array_key_exists('old', $raw_xaction)) {
$xaction->setOldValue($raw_xaction['old']);
}
$xactions[] = $xaction;
}
return $xactions;
}
}
c4science · Help