. /** * ActivityPub implementation for GNU social * * @package GNUsocial * @author Diogo Cordeiro * @copyright 2018-2019 Free Software Foundation, Inc http://www.fsf.org * @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later * @link http://www.gnu.org/software/social/ */ defined('GNUSOCIAL') || die(); /** * ActivityPub error representation * * @category Plugin * @package GNUsocial * @author Diogo Cordeiro * @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later */ class Activitypub_follow extends Managed_DataObject { /** * Generates an ActivityPub representation of a subscription * * @author Diogo Cordeiro * @param string $actor * @param string $object * @return array pretty array to be used in a response */ public static function follow_to_array($actor, $object) { $res = [ '@context' => 'https://www.w3.org/ns/activitystreams', 'id' => common_root_url().'follow_from_'.urlencode($actor).'_to_'.urlencode($object), 'type' => 'Follow', 'actor' => $actor, 'object' => $object ]; return $res; } /** * Handles a Follow Activity received by our inbox. * * @param Profile $actor_profile Remote Actor * @param string $object Local Actor * @throws AlreadyFulfilledException * @throws HTTP_Request2_Exception * @throws NoProfileException * @throws ServerException * @author Diogo Cordeiro */ public static function follow($actor_profile, $object) { // Get Actor's Aprofile $actor_aprofile = Activitypub_profile::from_profile($actor_profile); // Get Object profile $object_profile = new Activitypub_explorer; $object_profile = $object_profile->lookup($object)[0]; if (!Subscription::exists($actor_profile, $object_profile)) { Subscription::start($actor_profile, $object_profile); common_debug('ActivityPubPlugin: Accepted Follow request from '.ActivityPubPlugin::actor_uri($actor_profile).' to '.$object); } else { common_debug('ActivityPubPlugin: Received a repeated Follow request from '.ActivityPubPlugin::actor_uri($actor_profile).' to '.$object); } // Notify remote instance that we have accepted their request common_debug('ActivityPubPlugin: Notifying remote instance that we have accepted their Follow request request from '.ActivityPubPlugin::actor_uri($actor_profile).' to '.$object); $postman = new Activitypub_postman($actor_profile, [$actor_aprofile]); $postman->accept_follow(); } }