jdormit/activitypub-php
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Limit recursive collection unpacking

Browse Source
This commit is contained in:
Jeremy Dormitzer 2019-04-14 12:55:01 -04:00
parent 6d0d364704
commit 6bb81d9657
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/ActivityEventHandlers/DeliveryHandler.php
View File

@ -138,10 +138,14 @@ class DeliveryHandler implements EventSubscriberInterface
/** /**
* Given an ActivityPubObject to deliver to, returns an array of inbox URLs * Given an ActivityPubObject to deliver to, returns an array of inbox URLs
* @param ActivityPubObject $recipient * @param ActivityPubObject $recipient
* @param int $depth The depth to which we will unpack nested collection references
* @return array * @return array
*/ */
private function resolveRecipient( ActivityPubObject $recipient ) private function resolveRecipient( ActivityPubObject $recipient, $depth = 5 )
{ {
if ( $depth < 0 ) {
return array();
}
if ( $recipient && $recipient->hasField( 'inbox' ) ) { if ( $recipient && $recipient->hasField( 'inbox' ) ) {
$inbox = $recipient['inbox']; $inbox = $recipient['inbox'];
if ( $inbox instanceof ActivityPubObject && $inbox->hasField( 'id' ) ) { if ( $inbox instanceof ActivityPubObject && $inbox->hasField( 'id' ) ) {
@ -158,7 +162,7 @@ class DeliveryHandler implements EventSubscriberInterface
$inboxes = array(); $inboxes = array();
foreach ( CollectionIterator::iterateCollection( $recipient ) as $item ) { foreach ( CollectionIterator::iterateCollection( $recipient ) as $item ) {
if ( $item instanceof ActivityPubObject ) { if ( $item instanceof ActivityPubObject ) {
$inboxes = array_unique( array_merge( $inboxes, $this->resolveRecipient( $item ) ) ); $inboxes = array_unique( array_merge( $inboxes, $this->resolveRecipient( $item, $depth - 1 ) ) );
} }
} }
return $inboxes; return $inboxes;