better-testing

ManiphestTaskRelationship.php
View Options

			<?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;
			}

			}