ManiphestTaskRelationship.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	abstract class ManiphestTaskRelationship
	extends PhabricatorObjectRelationship {

	public function isEnabledForObject($object) {
	$viewer = $this->getViewer();

	$has_app = PhabricatorApplication::isClassInstalledForViewer(
	'PhabricatorManiphestApplication',
	$viewer);
	if (!$has_app) {
	return false;
	}

	return ($object instanceof ManiphestTask);
	}

	protected function newMergeIntoTransactions(ManiphestTask $task) {
	return array(
	id(new ManiphestTransaction())
	->setTransactionType(ManiphestTransaction::TYPE_MERGED_INTO)
	->setNewValue($task->getPHID()),
	);
	}

	protected function newMergeFromTransactions(array $tasks) {
	$xactions = array();

	$subscriber_phids = $this->loadMergeSubscriberPHIDs($tasks);

	$xactions[] = id(new ManiphestTransaction())
	->setTransactionType(PhabricatorTransactions::TYPE_SUBSCRIBERS)
	->setNewValue(array('+' => $subscriber_phids));

	$xactions[] = id(new ManiphestTransaction())
	->setTransactionType(ManiphestTransaction::TYPE_MERGED_FROM)
	->setNewValue(mpull($tasks, 'getPHID'));

	return $xactions;
	}

	private function loadMergeSubscriberPHIDs(array $tasks) {
	$phids = array();

	foreach ($tasks as $task) {
	$phids[] = $task->getAuthorPHID();
	$phids[] = $task->getOwnerPHID();
	}

	$subscribers = id(new PhabricatorSubscribersQuery())
	->withObjectPHIDs(mpull($tasks, 'getPHID'))
	->execute();

	foreach ($subscribers as $phid => $subscriber_list) {
	foreach ($subscriber_list as $subscriber) {
	$phids[] = $subscriber;
	}
	}

	$phids = array_unique($phids);
	$phids = array_filter($phids);

	return $phids;
	}

	}