X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FProfileUpdate.php;h=ba15436d841c0ad189bcb6b6ead793d3e46f58ae;hb=60532ee7e4152af9997e0d7b69c7b35262d5528d;hp=7fab86cbfdb0f941aa7e860f35821a3cf6d9eb05;hpb=72c3a62e7f1ba5679b6503d760409d5345f5a4de;p=friendica.git diff --git a/src/Worker/ProfileUpdate.php b/src/Worker/ProfileUpdate.php index 7fab86cbfd..ba15436d84 100644 --- a/src/Worker/ProfileUpdate.php +++ b/src/Worker/ProfileUpdate.php @@ -1,30 +1,49 @@ . + * */ namespace Friendica\Worker; -use Friendica\BaseObject; +use Friendica\Core\Logger; +use Friendica\Core\Worker; +use Friendica\DI; use Friendica\Protocol\Diaspora; use Friendica\Protocol\ActivityPub; -use Friendica\Core\Worker; +/** + * Send updated profile data to Diaspora and ActivityPub + */ class ProfileUpdate { public static function execute($uid = 0) { if (empty($uid)) { return; } - $a = BaseObject::getApp(); + $a = DI::app(); - $inboxes = ActivityPub::fetchTargetInboxesforUser($uid); + $inboxes = ActivityPub\Transmitter::fetchTargetInboxesforUser($uid); - foreach ($inboxes as $inbox) { - logger('Profile update for user ' . $uid . ' to ' . $inbox .' via ActivityPub', LOGGER_DEBUG); - Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true], - 'APDelivery', Delivery::PROFILEUPDATE, '', $inbox, $uid); + foreach ($inboxes as $inbox => $receivers) { + Logger::info('Profile update for user ' . $uid . ' to ' . $inbox .' via ActivityPub'); + Worker::add(['priority' => $a->getQueueValue('priority'), 'created' => $a->getQueueValue('created'), 'dont_fork' => true], + 'APDelivery', Delivery::PROFILEUPDATE, 0, $inbox, $uid, $receivers); } Diaspora::sendProfile($uid);