[ActivityPub] Ensuring federation with other software

ActivityPubPlugin:
- Prevent sending a Delete for an Announce

Activitypub_announce:
- Update announce_to_array to add id, to and cc information to the retrieved object

Activitypub_follow:
- Add id to the arguments of follow_to_array, useful for Accept-Follow activities

Activitypub_notice:
- Fix notice validation, url isn't a MUST

Activitypub_inbox_handler:
- Make handle_follow use the received activity id for the later Accept-Follow

Activitypub_postman:
- Fix call to the updated announce_to_array
- Fix successive unnecessary calls to ActivityPubPlugin::actor_uri()
This commit is contained in:
tenma 2019-08-05 23:22:32 +01:00 committed by Diogo Peralta Cordeiro
parent 3472eca45b
commit 20d101e1f2
6 changed files with 53 additions and 39 deletions

View File

@ -747,10 +747,12 @@ class ActivityPubPlugin extends Plugin
return true; return true;
} }
// The deleting user must have permission to do so, but // We handle things locally either because:
// it still doesn't own the notitce, so we just need to // 1. the deleting user has special permissions to do so,
// handle things locally // but still doesn't own the notice
if (!$notice->isLocal()) { // 2. the notice is an announce, and there's no undo-share
// logic in GS's AP implementation
if (!$notice->isLocal() || $notice->isRepeat()) {
return true; return true;
} }

View File

@ -39,18 +39,31 @@ class Activitypub_announce extends Managed_DataObject
/** /**
* Generates an ActivityPub representation of a Announce * Generates an ActivityPub representation of a Announce
* *
* @param $actor * @param Profile $actor
* @param array $object * @param Notice $notice
* @return array pretty array to be used in a response * @return array pretty array to be used in a response
* @author Diogo Cordeiro <diogo@fc.up.pt> * @author Diogo Cordeiro <diogo@fc.up.pt>
*/ */
public static function announce_to_array($actor, $object) public static function announce_to_array(Profile $actor, Notice $notice): array
{ {
$actor_uri = ActivityPubPlugin::actor_uri($actor);
$notice_url = Activitypub_notice::getUrl($notice);
$to = [common_local_url('apActorFollowers', ['id' => $actor->getID()])];
foreach ($notice->getAttentionProfiles() as $to_profile) {
$to[] = $to_profile->getUri();
}
$cc[]= 'https://www.w3.org/ns/activitystreams#Public';
$res = [ $res = [
'@context' => 'https://www.w3.org/ns/activitystreams', '@context' => 'https://www.w3.org/ns/activitystreams',
'id' => common_root_url().'share_from_'.urlencode($actor_uri).'_to_'.urlencode($notice_url),
"type" => "Announce", "type" => "Announce",
"actor" => $actor, "actor" => $actor_uri,
"object" => $object "object" => $notice_url,
"to" => $to,
"cc" => $cc
]; ];
return $res; return $res;
} }

View File

@ -42,13 +42,18 @@ class Activitypub_follow extends Managed_DataObject
* @author Diogo Cordeiro <diogo@fc.up.pt> * @author Diogo Cordeiro <diogo@fc.up.pt>
* @param string $actor * @param string $actor
* @param string $object * @param string $object
* @param string|null $id Activity id, to be used when generating for an Accept Activity
* @return array pretty array to be used in a response * @return array pretty array to be used in a response
*/ */
public static function follow_to_array($actor, $object) public static function follow_to_array(string $actor, string $object, ?string $id = null): array
{ {
if ($id === null) {
$id = common_root_url().'follow_from_'.urlencode($actor).'_to_'.urlencode($object);
}
$res = [ $res = [
'@context' => 'https://www.w3.org/ns/activitystreams', '@context' => 'https://www.w3.org/ns/activitystreams',
'id' => common_root_url().'follow_from_'.urlencode($actor).'_to_'.urlencode($object), 'id' => $id,
'type' => 'Follow', 'type' => 'Follow',
'actor' => $actor, 'actor' => $actor,
'object' => $object 'object' => $object
@ -61,13 +66,14 @@ class Activitypub_follow extends Managed_DataObject
* *
* @param Profile $actor_profile Remote Actor * @param Profile $actor_profile Remote Actor
* @param string $object Local Actor * @param string $object Local Actor
* @param string $id Activity id
* @throws AlreadyFulfilledException * @throws AlreadyFulfilledException
* @throws HTTP_Request2_Exception * @throws HTTP_Request2_Exception
* @throws NoProfileException * @throws NoProfileException
* @throws ServerException * @throws ServerException
* @author Diogo Cordeiro <diogo@fc.up.pt> * @author Diogo Cordeiro <diogo@fc.up.pt>
*/ */
public static function follow($actor_profile, $object) public static function follow(Profile $actor_profile, string $object, string $id)
{ {
// Get Actor's Aprofile // Get Actor's Aprofile
$actor_aprofile = Activitypub_profile::from_profile($actor_profile); $actor_aprofile = Activitypub_profile::from_profile($actor_profile);
@ -87,6 +93,6 @@ class Activitypub_follow extends Managed_DataObject
// Notify remote instance that we have accepted their request // 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); 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($object_profile, [$actor_aprofile]); $postman = new Activitypub_postman($object_profile, [$actor_aprofile]);
$postman->accept_follow(); $postman->accept_follow($id);
} }
} }

View File

@ -77,7 +77,7 @@ class Activitypub_notice extends Managed_DataObject
'published' => str_replace(' ', 'T', $notice->getCreated()).'Z', 'published' => str_replace(' ', 'T', $notice->getCreated()).'Z',
'url' => self::getUrl($notice), 'url' => self::getUrl($notice),
'attributedTo' => ActivityPubPlugin::actor_uri($profile), 'attributedTo' => ActivityPubPlugin::actor_uri($profile),
'to' => ['https://www.w3.org/ns/activitystreams#Public'], 'to' => $to,
'cc' => $cc, 'cc' => $cc,
'conversation' => $notice->getConversationUrl(), 'conversation' => $notice->getConversationUrl(),
'content' => $notice->getRendered(), 'content' => $notice->getRendered(),
@ -235,9 +235,7 @@ class Activitypub_notice extends Managed_DataObject
common_debug('ActivityPub Notice Validator: Rejected because Content was not specified.'); common_debug('ActivityPub Notice Validator: Rejected because Content was not specified.');
throw new Exception('Object content was not specified.'); throw new Exception('Object content was not specified.');
} }
if (!isset($object['url'])) { if (isset($object['url']) && !filter_var($object['url'], FILTER_VALIDATE_URL)) {
throw new Exception('Object URL was not specified.');
} elseif (!filter_var($object['url'], FILTER_VALIDATE_URL)) {
common_debug('ActivityPub Notice Validator: Rejected because Object URL is invalid.'); common_debug('ActivityPub Notice Validator: Rejected because Object URL is invalid.');
throw new Exception('Invalid Object URL.'); throw new Exception('Invalid Object URL.');
} }

View File

@ -129,7 +129,7 @@ class Activitypub_inbox_handler
$this->handle_delete($this->actor, $this->object); $this->handle_delete($this->actor, $this->object);
break; break;
case 'Follow': case 'Follow':
$this->handle_follow($this->actor, $this->object); $this->handle_follow($this->actor, $this->activity);
break; break;
case 'Like': case 'Like':
$this->handle_like($this->actor, $this->object); $this->handle_like($this->actor, $this->object);
@ -232,7 +232,7 @@ class Activitypub_inbox_handler
* Handles a Follow Activity received by our inbox. * Handles a Follow Activity received by our inbox.
* *
* @param Profile $actor Actor * @param Profile $actor Actor
* @param array $object Activity * @param array $activity Activity
* @throws AlreadyFulfilledException * @throws AlreadyFulfilledException
* @throws HTTP_Request2_Exception * @throws HTTP_Request2_Exception
* @throws NoProfileException * @throws NoProfileException
@ -241,9 +241,9 @@ class Activitypub_inbox_handler
* @throws \HttpSignatures\Exception * @throws \HttpSignatures\Exception
* @author Diogo Cordeiro <diogo@fc.up.pt> * @author Diogo Cordeiro <diogo@fc.up.pt>
*/ */
private function handle_follow($actor, $object) private function handle_follow($actor, $activity)
{ {
Activitypub_follow::follow($actor, $object); Activitypub_follow::follow($actor, $activity['object'], $activity['id']);
} }
/** /**

View File

@ -119,7 +119,7 @@ class Activitypub_postman
*/ */
public function follow() public function follow()
{ {
$data = Activitypub_follow::follow_to_array(ActivityPubPlugin::actor_uri($this->actor), $this->to[0]->getUrl()); $data = Activitypub_follow::follow_to_array($this->actor_uri, $this->to[0]->getUrl());
$res = $this->send(json_encode($data, JSON_UNESCAPED_SLASHES), $this->to[0]->get_inbox()); $res = $this->send(json_encode($data, JSON_UNESCAPED_SLASHES), $this->to[0]->get_inbox());
$res_body = json_decode($res->getBody()); $res_body = json_decode($res->getBody());
@ -149,7 +149,7 @@ class Activitypub_postman
{ {
$data = Activitypub_undo::undo_to_array( $data = Activitypub_undo::undo_to_array(
Activitypub_follow::follow_to_array( Activitypub_follow::follow_to_array(
ActivityPubPlugin::actor_uri($this->actor), $this->actor_uri,
$this->to[0]->getUrl() $this->to[0]->getUrl()
) )
); );
@ -171,21 +171,19 @@ class Activitypub_postman
/** /**
* Send a Accept Follow notification to remote instance * Send a Accept Follow notification to remote instance
* *
* @param string $id Follow activity id
* @return bool * @return bool
* @throws HTTP_Request2_Exception * @throws HTTP_Request2_Exception
* @throws Exception * @throws Exception Description of HTTP Response error or generic error message.
* @throws Exception
* @throws Exception
* @throws Exception
* @author Diogo Cordeiro <diogo@fc.up.pt> * @author Diogo Cordeiro <diogo@fc.up.pt>
*/ */
public function accept_follow() public function accept_follow(string $id): bool
{ {
$data = Activitypub_accept::accept_to_array( $data = Activitypub_accept::accept_to_array(
Activitypub_follow::follow_to_array( Activitypub_follow::follow_to_array(
$this->to[0]->getUrl(), $this->to[0]->getUrl(),
ActivityPubPlugin::actor_uri($this->actor) $this->actor_uri,
$id
) )
); );
$res = $this->send(json_encode($data, JSON_UNESCAPED_SLASHES), $this->to[0]->get_inbox()); $res = $this->send(json_encode($data, JSON_UNESCAPED_SLASHES), $this->to[0]->get_inbox());
@ -214,7 +212,7 @@ class Activitypub_postman
public function like($notice) public function like($notice)
{ {
$data = Activitypub_like::like_to_array( $data = Activitypub_like::like_to_array(
ActivityPubPlugin::actor_uri($this->actor), $this->actor_uri,
Activitypub_notice::getUrl($notice) Activitypub_notice::getUrl($notice)
); );
$data = json_encode($data, JSON_UNESCAPED_SLASHES); $data = json_encode($data, JSON_UNESCAPED_SLASHES);
@ -248,7 +246,7 @@ class Activitypub_postman
{ {
$data = Activitypub_undo::undo_to_array( $data = Activitypub_undo::undo_to_array(
Activitypub_like::like_to_array( Activitypub_like::like_to_array(
ActivityPubPlugin::actor_uri($this->actor), $this->actor_uri,
Activitypub_notice::getUrl($notice) Activitypub_notice::getUrl($notice)
) )
); );
@ -314,11 +312,8 @@ class Activitypub_postman
*/ */
public function announce($notice) public function announce($notice)
{ {
$data = Activitypub_announce::announce_to_array( $data = json_encode(Activitypub_announce::announce_to_array($this->actor, $notice),
ActivityPubPlugin::actor_uri($this->actor), JSON_UNESCAPED_SLASHES);
Activitypub_notice::getUrl($notice)
);
$data = json_encode($data, JSON_UNESCAPED_SLASHES);
foreach ($this->to_inbox() as $inbox) { foreach ($this->to_inbox() as $inbox) {
$res = $this->send($data, $inbox); $res = $this->send($data, $inbox);