pixelfed/app/Util/ActivityPub/Inbox.php

467 lines
14 KiB
PHP
Raw Normal View History

2018-06-01 03:17:07 +00:00
<?php
namespace App\Util\ActivityPub;
2019-01-01 06:28:34 +00:00
use Cache, DB, Log, Purify, Redis, Validator;
2018-11-17 22:33:24 +00:00
use App\{
Activity,
Follower,
FollowRequest,
Like,
Notification,
Profile,
2019-09-06 02:40:40 +00:00
Status,
StatusHashtag,
2018-11-17 22:33:24 +00:00
};
use Carbon\Carbon;
use App\Util\ActivityPub\Helpers;
use App\Jobs\LikePipeline\LikePipeline;
2019-07-25 01:25:51 +00:00
use App\Jobs\FollowPipeline\FollowPipeline;
2018-06-01 03:17:07 +00:00
2020-04-30 02:52:48 +00:00
use App\Util\ActivityPub\Validator\Accept as AcceptValidator;
use App\Util\ActivityPub\Validator\Announce as AnnounceValidator;
use App\Util\ActivityPub\Validator\Follow as FollowValidator;
use App\Util\ActivityPub\Validator\Like as LikeValidator;
use App\Util\ActivityPub\Validator\UndoFollow as UndoFollowValidator;
2019-01-04 03:04:29 +00:00
2018-08-28 03:07:36 +00:00
class Inbox
{
2018-11-17 22:33:24 +00:00
protected $headers;
2018-06-01 03:17:07 +00:00
protected $profile;
protected $payload;
2018-11-17 22:33:24 +00:00
protected $logger;
2018-06-01 03:17:07 +00:00
2018-11-17 22:33:24 +00:00
public function __construct($headers, $profile, $payload)
2018-06-01 03:17:07 +00:00
{
2018-11-17 22:33:24 +00:00
$this->headers = $headers;
2018-06-01 03:17:07 +00:00
$this->profile = $profile;
$this->payload = $payload;
}
public function handle()
{
2018-12-24 02:42:50 +00:00
$this->handleVerb();
2020-04-29 19:27:05 +00:00
2020-05-21 22:45:51 +00:00
// if(!Activity::where('data->id', $this->payload['id'])->exists()) {
// (new Activity())->create([
// 'to_id' => $this->profile->id,
// 'data' => json_encode($this->payload)
// ]);
// }
2020-04-30 02:28:30 +00:00
return;
2018-06-01 03:17:07 +00:00
}
public function handleVerb()
{
2019-04-07 04:27:32 +00:00
$verb = (string) $this->payload['type'];
2018-06-01 03:17:07 +00:00
switch ($verb) {
case 'Create':
$this->handleCreateActivity();
break;
case 'Follow':
2020-05-21 22:45:51 +00:00
if(FollowValidator::validate($this->payload) == false) { return; }
2018-06-01 03:17:07 +00:00
$this->handleFollowActivity();
break;
2018-11-17 22:33:24 +00:00
case 'Announce':
2020-04-30 02:52:48 +00:00
if(AnnounceValidator::validate($this->payload) == false) { return; }
2018-11-17 22:33:24 +00:00
$this->handleAnnounceActivity();
break;
case 'Accept':
2020-04-30 02:52:48 +00:00
if(AcceptValidator::validate($this->payload) == false) { return; }
2018-11-17 22:33:24 +00:00
$this->handleAcceptActivity();
break;
case 'Delete':
$this->handleDeleteActivity();
break;
case 'Like':
2020-05-21 22:45:51 +00:00
if(LikeValidator::validate($this->payload) == false) { return; }
2018-11-17 22:33:24 +00:00
$this->handleLikeActivity();
break;
case 'Reject':
$this->handleRejectActivity();
break;
case 'Undo':
$this->handleUndoActivity();
break;
2018-06-01 03:17:07 +00:00
default:
// TODO: decide how to handle invalid verbs.
break;
}
}
2018-11-17 22:33:24 +00:00
public function verifyNoteAttachment()
{
$activity = $this->payload['object'];
if(isset($activity['inReplyTo']) &&
!empty($activity['inReplyTo']) &&
Helpers::validateUrl($activity['inReplyTo'])
) {
// reply detected, skip attachment check
return true;
}
$valid = Helpers::verifyAttachments($activity);
return $valid;
}
public function actorFirstOrCreate($actorUrl)
{
2019-08-17 07:45:55 +00:00
return Helpers::profileFetch($actorUrl);
2018-11-17 22:33:24 +00:00
}
2018-06-01 03:17:07 +00:00
public function handleCreateActivity()
{
2018-11-17 22:33:24 +00:00
$activity = $this->payload['object'];
if(!$this->verifyNoteAttachment()) {
return;
}
if($activity['type'] == 'Note' && !empty($activity['inReplyTo'])) {
$this->handleNoteReply();
} elseif($activity['type'] == 'Note' && !empty($activity['attachment'])) {
$this->handleNoteCreate();
}
}
public function handleNoteReply()
{
$activity = $this->payload['object'];
$actor = $this->actorFirstOrCreate($this->payload['actor']);
2019-04-05 05:19:56 +00:00
if(!$actor || $actor->domain == null) {
return;
}
2018-11-17 22:33:24 +00:00
$inReplyTo = $activity['inReplyTo'];
2019-09-07 04:00:24 +00:00
$url = isset($activity['url']) ? $activity['url'] : $activity['id'];
2018-11-17 22:33:24 +00:00
2019-04-05 05:19:56 +00:00
Helpers::statusFirstOrFetch($url, true);
return;
2018-11-17 22:33:24 +00:00
}
public function handleNoteCreate()
{
$activity = $this->payload['object'];
$actor = $this->actorFirstOrCreate($this->payload['actor']);
if(!$actor || $actor->domain == null) {
return;
}
2019-07-27 05:13:29 +00:00
if($actor->followers()->count() == 0) {
2019-07-27 05:02:13 +00:00
return;
}
2018-11-17 22:33:24 +00:00
2019-09-07 04:00:24 +00:00
$url = isset($activity['url']) ? $activity['url'] : $activity['id'];
2018-12-24 02:42:50 +00:00
if(Status::whereUrl($url)->exists()) {
2018-11-17 22:33:24 +00:00
return;
}
2019-06-25 04:46:35 +00:00
Helpers::statusFetch($url);
2019-04-05 05:19:56 +00:00
return;
2018-06-01 03:17:07 +00:00
}
public function handleFollowActivity()
{
2018-11-17 22:33:24 +00:00
$actor = $this->actorFirstOrCreate($this->payload['actor']);
2020-05-21 22:45:51 +00:00
$target = $this->profile;
if(!$actor || $actor->domain == null || $target->domain !== null) {
return;
}
if(
Follower::whereProfileId($actor->id)
->whereFollowingId($target->id)
->exists() ||
FollowRequest::whereFollowerId($actor->id)
->whereFollowingId($target->id)
2020-05-21 23:45:31 +00:00
->exists()
2020-05-21 22:45:51 +00:00
) {
2018-11-17 22:33:24 +00:00
return;
}
if($target->is_private == true) {
FollowRequest::firstOrCreate([
'follower_id' => $actor->id,
'following_id' => $target->id
]);
} else {
2020-05-21 22:45:51 +00:00
$follower = new Follower;
2020-05-21 23:48:05 +00:00
$follower->profile_id = $actor->id;
$follower->following_id = $target->id;
$follower->local_profile = empty($actor->domain);
$follower->save();
2020-05-21 22:45:51 +00:00
FollowPipeline::dispatch($follower);
2019-08-12 06:23:46 +00:00
2018-11-17 22:33:24 +00:00
// send Accept to remote profile
$accept = [
'@context' => 'https://www.w3.org/ns/activitystreams',
2018-12-28 05:55:21 +00:00
'id' => $target->permalink().'#accepts/follows/' . $follower->id,
2018-11-17 22:33:24 +00:00
'type' => 'Accept',
'actor' => $target->permalink(),
2019-08-12 06:23:46 +00:00
'object' => [
'id' => $this->payload['id'],
2019-08-12 06:23:46 +00:00
'actor' => $actor->permalink(),
'type' => 'Follow',
'object' => $target->permalink()
]
2018-11-17 22:33:24 +00:00
];
Helpers::sendSignedObject($target, $actor->inbox_url, $accept);
}
2018-06-01 03:17:07 +00:00
}
2018-11-17 22:33:24 +00:00
public function handleAnnounceActivity()
{
2018-12-24 02:42:50 +00:00
$actor = $this->actorFirstOrCreate($this->payload['actor']);
$activity = $this->payload['object'];
2019-06-25 05:57:48 +00:00
2018-12-24 02:42:50 +00:00
if(!$actor || $actor->domain == null) {
return;
}
2019-06-25 05:57:48 +00:00
2018-12-24 02:42:50 +00:00
if(Helpers::validateLocalUrl($activity) == false) {
return;
}
2019-06-25 05:57:48 +00:00
$parent = Helpers::statusFetch($activity);
if(empty($parent)) {
2018-12-24 02:42:50 +00:00
return;
}
2019-06-25 05:57:48 +00:00
2018-12-24 02:42:50 +00:00
$status = Status::firstOrCreate([
'profile_id' => $actor->id,
2018-12-25 06:57:36 +00:00
'reblog_of_id' => $parent->id,
2019-06-25 05:57:48 +00:00
'type' => 'share'
2018-12-24 02:42:50 +00:00
]);
2019-06-25 05:57:48 +00:00
2018-12-25 06:35:04 +00:00
Notification::firstOrCreate([
'profile_id' => $parent->profile->id,
'actor_id' => $actor->id,
'action' => 'share',
'message' => $status->replyToText(),
'rendered' => $status->replyToHtml(),
'item_id' => $parent->id,
'item_type' => 'App\Status'
]);
2019-06-25 06:10:34 +00:00
2019-06-18 18:57:56 +00:00
$parent->reblogs_count = $parent->shares()->count();
$parent->save();
2018-11-17 22:33:24 +00:00
}
public function handleAcceptActivity()
{
2019-07-25 01:25:51 +00:00
2019-08-12 02:27:17 +00:00
$actor = $this->payload['object']['actor'];
2019-07-25 01:32:07 +00:00
$obj = $this->payload['object']['object'];
2019-07-25 01:25:51 +00:00
$type = $this->payload['object']['type'];
if($type !== 'Follow') {
return;
2019-02-25 03:07:43 +00:00
}
2019-07-25 01:25:51 +00:00
2019-08-12 02:27:17 +00:00
$actor = Helpers::validateLocalUrl($actor);
$target = Helpers::validateUrl($obj);
2019-07-25 01:25:51 +00:00
if(!$actor || !$target) {
return;
}
$actor = Helpers::profileFetch($actor);
$target = Helpers::profileFetch($target);
$request = FollowRequest::whereFollowerId($actor->id)
->whereFollowingId($target->id)
->whereIsRejected(false)
->first();
if(!$request) {
return;
}
2019-08-13 01:26:57 +00:00
$follower = Follower::firstOrCreate([
'profile_id' => $actor->id,
'following_id' => $target->id,
]);
2019-07-25 01:25:51 +00:00
FollowPipeline::dispatch($follower);
$request->delete();
2018-11-17 22:33:24 +00:00
}
public function handleDeleteActivity()
{
2019-09-06 02:40:40 +00:00
if(!isset(
$this->payload['actor'],
$this->payload['object'],
)) {
return;
}
2018-12-25 04:42:31 +00:00
$actor = $this->payload['actor'];
$obj = $this->payload['object'];
2020-04-29 21:56:21 +00:00
if(is_string($obj) == true) {
return;
}
2019-09-06 02:40:40 +00:00
$type = $this->payload['object']['type'];
$typeCheck = in_array($type, ['Person', 'Tombstone']);
2019-09-07 05:25:55 +00:00
if(!Helpers::validateUrl($actor) || !Helpers::validateUrl($obj['id']) || !$typeCheck) {
2019-06-27 06:44:09 +00:00
return;
2019-09-06 02:40:40 +00:00
}
if(parse_url($obj['id'], PHP_URL_HOST) !== parse_url($actor, PHP_URL_HOST)) {
2019-06-27 06:44:09 +00:00
return;
2018-12-25 04:42:31 +00:00
}
2019-09-06 02:40:40 +00:00
$id = $this->payload['object']['id'];
switch ($type) {
case 'Person':
2020-04-29 21:35:48 +00:00
// todo: fix race condition
return;
2019-10-07 09:36:51 +00:00
$profile = Helpers::profileFetch($actor);
2019-10-07 09:30:53 +00:00
if(!$profile || $profile->private_key != null) {
2019-09-06 02:40:40 +00:00
return;
}
Notification::whereActorId($profile->id)->delete();
$profile->avatar()->delete();
$profile->followers()->delete();
$profile->following()->delete();
$profile->likes()->delete();
$profile->media()->delete();
$profile->statuses()->delete();
$profile->delete();
return;
break;
case 'Tombstone':
2019-10-07 09:36:51 +00:00
$profile = Helpers::profileFetch($actor);
2019-10-07 09:30:53 +00:00
$status = Status::whereProfileId($profile->id)
->whereUri($id)
2019-10-07 09:39:56 +00:00
->orWhere('url', $id)
2019-10-07 09:30:53 +00:00
->orWhere('object_url', $id)
->first();
2019-09-06 02:40:40 +00:00
if(!$status) {
return;
}
2019-10-07 09:30:53 +00:00
$status->media()->delete();
$status->likes()->delete();
$status->shares()->delete();
2019-09-06 02:40:40 +00:00
$status->delete();
return;
break;
default:
return;
break;
}
2018-11-17 22:33:24 +00:00
}
public function handleLikeActivity()
2018-06-01 03:17:07 +00:00
{
2018-11-17 22:33:24 +00:00
$actor = $this->payload['actor'];
2019-04-18 05:29:22 +00:00
2019-09-06 02:40:40 +00:00
if(!Helpers::validateUrl($actor)) {
return;
}
2019-04-18 05:29:22 +00:00
2018-11-17 22:33:24 +00:00
$profile = self::actorFirstOrCreate($actor);
$obj = $this->payload['object'];
2019-09-06 02:40:40 +00:00
if(!Helpers::validateUrl($obj)) {
return;
}
2018-11-17 22:33:24 +00:00
$status = Helpers::statusFirstOrFetch($obj);
2019-04-07 04:27:32 +00:00
if(!$status || !$profile) {
return;
}
2018-11-17 22:33:24 +00:00
$like = Like::firstOrCreate([
'profile_id' => $profile->id,
'status_id' => $status->id
]);
2019-04-18 05:29:22 +00:00
if($like->wasRecentlyCreated == true) {
2019-06-18 18:57:56 +00:00
$status->likes_count = $status->likes()->count();
$status->save();
2019-04-18 05:29:22 +00:00
LikePipeline::dispatch($like);
2018-11-17 22:33:24 +00:00
}
2019-04-18 05:29:22 +00:00
return;
2018-11-17 22:33:24 +00:00
}
public function handleRejectActivity()
{
}
public function handleUndoActivity()
{
$actor = $this->payload['actor'];
$profile = self::actorFirstOrCreate($actor);
$obj = $this->payload['object'];
switch ($obj['type']) {
2019-02-25 03:07:43 +00:00
case 'Accept':
2018-12-25 04:42:31 +00:00
break;
case 'Announce':
2019-06-25 19:17:16 +00:00
$obj = $obj['object'];
2019-09-06 02:40:40 +00:00
if(!Helpers::validateLocalUrl($obj)) {
return;
}
2019-06-25 06:10:34 +00:00
$status = Helpers::statusFetch($obj);
if(!$status) {
return;
}
Status::whereProfileId($profile->id)
->whereReblogOfId($status->id)
->forceDelete();
Notification::whereProfileId($status->profile->id)
->whereActorId($profile->id)
->whereAction('share')
->whereItemId($status->reblog_of_id)
->whereItemType('App\Status')
->forceDelete();
2018-11-17 22:33:24 +00:00
break;
2019-02-25 03:07:43 +00:00
case 'Block':
break;
case 'Follow':
$following = self::actorFirstOrCreate($obj['object']);
2019-04-07 04:27:32 +00:00
if(!$following) {
return;
}
2019-02-25 03:07:43 +00:00
Follower::whereProfileId($profile->id)
->whereFollowingId($following->id)
->delete();
Notification::whereProfileId($following->id)
->whereActorId($profile->id)
->whereAction('follow')
->whereItemId($following->id)
->whereItemType('App\Profile')
->forceDelete();
2019-02-25 03:07:43 +00:00
break;
case 'Like':
$status = Helpers::statusFirstOrFetch($obj['object']);
2019-04-07 04:27:32 +00:00
if(!$status) {
return;
}
2019-02-25 03:07:43 +00:00
Like::whereProfileId($profile->id)
->whereStatusId($status->id)
->forceDelete();
Notification::whereProfileId($status->profile->id)
->whereActorId($profile->id)
->whereAction('like')
->whereItemId($status->id)
->whereItemType('App\Status')
->forceDelete();
break;
2018-06-01 03:17:07 +00:00
}
2019-06-25 06:10:34 +00:00
return;
2018-06-01 03:17:07 +00:00
}
2018-08-28 03:07:36 +00:00
}