Something went wrong. Try again.
@recaptime-dev's working patches + fork for Phorge, a community fork of Phabricator. (Upstream dev and stable branches are at upstream/main and upstream/stable respectively.) hq.recaptime.dev/wiki/Phorge
phorge phabricator
Something went wrong. Try again.
1.3 kB · 52 lines
PHP
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253<?php
final class PhabricatorSubscribersQuery extends PhabricatorQuery {
private $objectPHIDs; private $subscriberPHIDs;
public static function loadSubscribersForPHID($phid) { if (!$phid) { return array(); }
$subscribers = id(new PhabricatorSubscribersQuery()) ->withObjectPHIDs(array($phid)) ->execute(); return $subscribers[$phid]; }
public function withObjectPHIDs(array $object_phids) { $this->objectPHIDs = $object_phids; return $this; }
public function withSubscriberPHIDs(array $subscriber_phids) { $this->subscriberPHIDs = $subscriber_phids; return $this; }
public function execute() { $query = new PhabricatorEdgeQuery();
$edge_type = PhabricatorObjectHasSubscriberEdgeType::EDGECONST;
$query->withSourcePHIDs($this->objectPHIDs); $query->withEdgeTypes(array($edge_type));
if ($this->subscriberPHIDs) { $query->withDestinationPHIDs($this->subscriberPHIDs); }
$edges = $query->execute();
$results = array_fill_keys($this->objectPHIDs, array()); foreach ($edges as $src => $edge_types) { foreach ($edge_types[$edge_type] as $dst => $data) { $results[$src][] = $dst; } }
return $results; }}