mirror of https://github.com/pixelfed/pixelfed.git
626 lines
19 KiB
PHP
626 lines
19 KiB
PHP
<?php
|
|
|
|
namespace App\Util\ActivityPub;
|
|
|
|
use Cache, DB, Log, Purify, Redis, Validator;
|
|
use App\{
|
|
Activity,
|
|
DirectMessage,
|
|
Follower,
|
|
FollowRequest,
|
|
Like,
|
|
Notification,
|
|
Media,
|
|
Profile,
|
|
Status,
|
|
StatusHashtag,
|
|
UserFilter
|
|
};
|
|
use Carbon\Carbon;
|
|
use App\Util\ActivityPub\Helpers;
|
|
use Illuminate\Support\Str;
|
|
use App\Jobs\LikePipeline\LikePipeline;
|
|
use App\Jobs\FollowPipeline\FollowPipeline;
|
|
use App\Jobs\DeletePipeline\DeleteRemoteProfilePipeline;
|
|
|
|
use App\Util\ActivityPub\Validator\Accept as AcceptValidator;
|
|
use App\Util\ActivityPub\Validator\Add as AddValidator;
|
|
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;
|
|
|
|
class Inbox
|
|
{
|
|
protected $headers;
|
|
protected $profile;
|
|
protected $payload;
|
|
protected $logger;
|
|
|
|
public function __construct($headers, $profile, $payload)
|
|
{
|
|
$this->headers = $headers;
|
|
$this->profile = $profile;
|
|
$this->payload = $payload;
|
|
}
|
|
|
|
public function handle()
|
|
{
|
|
$this->handleVerb();
|
|
|
|
// if(!Activity::where('data->id', $this->payload['id'])->exists()) {
|
|
// (new Activity())->create([
|
|
// 'to_id' => $this->profile->id,
|
|
// 'data' => json_encode($this->payload)
|
|
// ]);
|
|
// }
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
public function handleVerb()
|
|
{
|
|
$verb = (string) $this->payload['type'];
|
|
switch ($verb) {
|
|
|
|
case 'Add':
|
|
if(AddValidator::validate($this->payload) == false) { return; }
|
|
$this->handleAddActivity();
|
|
break;
|
|
|
|
case 'Create':
|
|
$this->handleCreateActivity();
|
|
break;
|
|
|
|
case 'Follow':
|
|
if(FollowValidator::validate($this->payload) == false) { return; }
|
|
$this->handleFollowActivity();
|
|
break;
|
|
|
|
case 'Announce':
|
|
if(AnnounceValidator::validate($this->payload) == false) { return; }
|
|
$this->handleAnnounceActivity();
|
|
break;
|
|
|
|
case 'Accept':
|
|
if(AcceptValidator::validate($this->payload) == false) { return; }
|
|
$this->handleAcceptActivity();
|
|
break;
|
|
|
|
case 'Delete':
|
|
$this->handleDeleteActivity();
|
|
break;
|
|
|
|
case 'Like':
|
|
if(LikeValidator::validate($this->payload) == false) { return; }
|
|
$this->handleLikeActivity();
|
|
break;
|
|
|
|
case 'Reject':
|
|
$this->handleRejectActivity();
|
|
break;
|
|
|
|
case 'Undo':
|
|
$this->handleUndoActivity();
|
|
break;
|
|
|
|
default:
|
|
// TODO: decide how to handle invalid verbs.
|
|
break;
|
|
}
|
|
}
|
|
|
|
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)
|
|
{
|
|
return Helpers::profileFetch($actorUrl);
|
|
}
|
|
|
|
public function handleAddActivity()
|
|
{
|
|
// stories ;)
|
|
}
|
|
|
|
public function handleCreateActivity()
|
|
{
|
|
$activity = $this->payload['object'];
|
|
$actor = $this->actorFirstOrCreate($this->payload['actor']);
|
|
if(!$actor || $actor->domain == null) {
|
|
return;
|
|
}
|
|
$to = $activity['to'];
|
|
$cc = isset($activity['cc']) ? $activity['cc'] : [];
|
|
if(count($to) == 1 &&
|
|
count($cc) == 0 &&
|
|
parse_url($to[0], PHP_URL_HOST) == config('pixelfed.domain.app')
|
|
) {
|
|
$this->handleDirectMessage();
|
|
return;
|
|
}
|
|
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']);
|
|
if(!$actor || $actor->domain == null) {
|
|
return;
|
|
}
|
|
|
|
$inReplyTo = $activity['inReplyTo'];
|
|
$url = isset($activity['url']) ? $activity['url'] : $activity['id'];
|
|
|
|
Helpers::statusFirstOrFetch($url, true);
|
|
return;
|
|
}
|
|
|
|
public function handleNoteCreate()
|
|
{
|
|
$activity = $this->payload['object'];
|
|
$actor = $this->actorFirstOrCreate($this->payload['actor']);
|
|
if(!$actor || $actor->domain == null) {
|
|
return;
|
|
}
|
|
|
|
if($actor->followers()->count() == 0) {
|
|
return;
|
|
}
|
|
|
|
$url = isset($activity['url']) ? $activity['url'] : $activity['id'];
|
|
if(Status::whereUrl($url)->exists()) {
|
|
return;
|
|
}
|
|
Helpers::statusFetch($url);
|
|
return;
|
|
}
|
|
|
|
public function handleDirectMessage()
|
|
{
|
|
$activity = $this->payload['object'];
|
|
$actor = $this->actorFirstOrCreate($this->payload['actor']);
|
|
$profile = Profile::whereNull('domain')
|
|
->whereUsername(array_last(explode('/', $activity['to'][0])))
|
|
->firstOrFail();
|
|
|
|
if(in_array($actor->id, $profile->blockedIds()->toArray())) {
|
|
return;
|
|
}
|
|
|
|
$msg = $activity['content'];
|
|
$msgText = strip_tags($activity['content']);
|
|
|
|
if(Str::startsWith($msgText, '@' . $profile->username)) {
|
|
$len = strlen('@' . $profile->username);
|
|
$msgText = substr($msgText, $len + 1);
|
|
}
|
|
|
|
if($profile->user->settings->public_dm == false || $profile->is_private) {
|
|
if($profile->follows($actor) == true) {
|
|
$hidden = false;
|
|
} else {
|
|
$hidden = true;
|
|
}
|
|
} else {
|
|
$hidden = false;
|
|
}
|
|
|
|
$status = new Status;
|
|
$status->profile_id = $actor->id;
|
|
$status->caption = $msgText;
|
|
$status->rendered = $msg;
|
|
$status->visibility = 'direct';
|
|
$status->scope = 'direct';
|
|
$status->url = $activity['id'];
|
|
$status->in_reply_to_profile_id = $profile->id;
|
|
$status->save();
|
|
|
|
$dm = new DirectMessage;
|
|
$dm->to_id = $profile->id;
|
|
$dm->from_id = $actor->id;
|
|
$dm->status_id = $status->id;
|
|
$dm->is_hidden = $hidden;
|
|
$dm->type = 'text';
|
|
$dm->save();
|
|
|
|
if(count($activity['attachment'])) {
|
|
$photos = 0;
|
|
$videos = 0;
|
|
$allowed = explode(',', config('pixelfed.media_types'));
|
|
$activity['attachment'] = array_slice($activity['attachment'], 0, config('pixelfed.max_album_length'));
|
|
foreach($activity['attachment'] as $a) {
|
|
$type = $a['mediaType'];
|
|
$url = $a['url'];
|
|
$valid = Helpers::validateUrl($url);
|
|
if(in_array($type, $allowed) == false || $valid == false) {
|
|
continue;
|
|
}
|
|
|
|
$media = new Media();
|
|
$media->remote_media = true;
|
|
$media->status_id = $status->id;
|
|
$media->profile_id = $status->profile_id;
|
|
$media->user_id = null;
|
|
$media->media_path = $url;
|
|
$media->remote_url = $url;
|
|
$media->mime = $type;
|
|
$media->save();
|
|
if(explode('/', $type)[0] == 'image') {
|
|
$photos = $photos + 1;
|
|
}
|
|
if(explode('/', $type)[0] == 'video') {
|
|
$videos = $videos + 1;
|
|
}
|
|
}
|
|
|
|
if($photos && $videos == 0) {
|
|
$dm->type = $photos == 1 ? 'photo' : 'photos';
|
|
$dm->save();
|
|
}
|
|
if($videos && $photos == 0) {
|
|
$dm->type = $videos == 1 ? 'video' : 'videos';
|
|
$dm->save();
|
|
}
|
|
}
|
|
|
|
if(filter_var($msgText, FILTER_VALIDATE_URL)) {
|
|
if(Helpers::validateUrl($msgText)) {
|
|
$dm->type = 'link';
|
|
$dm->meta = [
|
|
'domain' => parse_url($msgText, PHP_URL_HOST),
|
|
'local' => parse_url($msgText, PHP_URL_HOST) ==
|
|
parse_url(config('app.url'), PHP_URL_HOST)
|
|
];
|
|
$dm->save();
|
|
}
|
|
}
|
|
|
|
$nf = UserFilter::whereUserId($profile->id)
|
|
->whereFilterableId($actor->id)
|
|
->whereFilterableType('App\Profile')
|
|
->whereFilterType('dm.mute')
|
|
->exists();
|
|
|
|
if($profile->domain == null && $hidden == false && !$nf) {
|
|
$notification = new Notification();
|
|
$notification->profile_id = $profile->id;
|
|
$notification->actor_id = $actor->id;
|
|
$notification->action = 'dm';
|
|
$notification->message = $dm->toText();
|
|
$notification->rendered = $dm->toHtml();
|
|
$notification->item_id = $dm->id;
|
|
$notification->item_type = "App\DirectMessage";
|
|
$notification->save();
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
public function handleFollowActivity()
|
|
{
|
|
$actor = $this->actorFirstOrCreate($this->payload['actor']);
|
|
$target = $this->actorFirstOrCreate($this->payload['object']);
|
|
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)
|
|
->exists()
|
|
) {
|
|
return;
|
|
}
|
|
if($target->is_private == true) {
|
|
FollowRequest::firstOrCreate([
|
|
'follower_id' => $actor->id,
|
|
'following_id' => $target->id
|
|
]);
|
|
|
|
Cache::forget('profile:follower_count:'.$target->id);
|
|
Cache::forget('profile:follower_count:'.$actor->id);
|
|
Cache::forget('profile:following_count:'.$target->id);
|
|
Cache::forget('profile:following_count:'.$actor->id);
|
|
|
|
} else {
|
|
$follower = new Follower;
|
|
$follower->profile_id = $actor->id;
|
|
$follower->following_id = $target->id;
|
|
$follower->local_profile = empty($actor->domain);
|
|
$follower->save();
|
|
|
|
FollowPipeline::dispatch($follower);
|
|
|
|
// send Accept to remote profile
|
|
$accept = [
|
|
'@context' => 'https://www.w3.org/ns/activitystreams',
|
|
'id' => $target->permalink().'#accepts/follows/' . $follower->id,
|
|
'type' => 'Accept',
|
|
'actor' => $target->permalink(),
|
|
'object' => [
|
|
'id' => $this->payload['id'],
|
|
'actor' => $actor->permalink(),
|
|
'type' => 'Follow',
|
|
'object' => $target->permalink()
|
|
]
|
|
];
|
|
Helpers::sendSignedObject($target, $actor->inbox_url, $accept);
|
|
Cache::forget('profile:follower_count:'.$target->id);
|
|
Cache::forget('profile:follower_count:'.$actor->id);
|
|
Cache::forget('profile:following_count:'.$target->id);
|
|
Cache::forget('profile:following_count:'.$actor->id);
|
|
}
|
|
}
|
|
|
|
public function handleAnnounceActivity()
|
|
{
|
|
$actor = $this->actorFirstOrCreate($this->payload['actor']);
|
|
$activity = $this->payload['object'];
|
|
|
|
if(!$actor || $actor->domain == null) {
|
|
return;
|
|
}
|
|
|
|
if(Helpers::validateLocalUrl($activity) == false) {
|
|
return;
|
|
}
|
|
|
|
$parent = Helpers::statusFetch($activity);
|
|
|
|
if(empty($parent)) {
|
|
return;
|
|
}
|
|
|
|
$status = Status::firstOrCreate([
|
|
'profile_id' => $actor->id,
|
|
'reblog_of_id' => $parent->id,
|
|
'type' => 'share'
|
|
]);
|
|
|
|
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'
|
|
]);
|
|
|
|
$parent->reblogs_count = $parent->shares()->count();
|
|
$parent->save();
|
|
}
|
|
|
|
public function handleAcceptActivity()
|
|
{
|
|
|
|
$actor = $this->payload['object']['actor'];
|
|
$obj = $this->payload['object']['object'];
|
|
$type = $this->payload['object']['type'];
|
|
|
|
if($type !== 'Follow') {
|
|
return;
|
|
}
|
|
|
|
$actor = Helpers::validateLocalUrl($actor);
|
|
$target = Helpers::validateUrl($obj);
|
|
|
|
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;
|
|
}
|
|
|
|
$follower = Follower::firstOrCreate([
|
|
'profile_id' => $actor->id,
|
|
'following_id' => $target->id,
|
|
]);
|
|
FollowPipeline::dispatch($follower);
|
|
|
|
$request->delete();
|
|
}
|
|
|
|
public function handleDeleteActivity()
|
|
{
|
|
if(!isset(
|
|
$this->payload['actor'],
|
|
$this->payload['object']
|
|
)) {
|
|
return;
|
|
}
|
|
$actor = $this->payload['actor'];
|
|
$obj = $this->payload['object'];
|
|
if(is_string($obj) == true && $actor == $obj && Helpers::validateUrl($obj)) {
|
|
$profile = Profile::whereRemoteUrl($obj)->first();
|
|
if(!$profile || $profile->private_key != null) {
|
|
return;
|
|
}
|
|
DeleteRemoteProfilePipeline::dispatchNow($profile);
|
|
return;
|
|
} else {
|
|
$type = $this->payload['object']['type'];
|
|
$typeCheck = in_array($type, ['Person', 'Tombstone']);
|
|
if(!Helpers::validateUrl($actor) || !Helpers::validateUrl($obj['id']) || !$typeCheck) {
|
|
return;
|
|
}
|
|
if(parse_url($obj['id'], PHP_URL_HOST) !== parse_url($actor, PHP_URL_HOST)) {
|
|
return;
|
|
}
|
|
$id = $this->payload['object']['id'];
|
|
switch ($type) {
|
|
case 'Person':
|
|
$profile = Profile::whereRemoteUrl($actor)->first();
|
|
if(!$profile || $profile->private_key != null) {
|
|
return;
|
|
}
|
|
DeleteRemoteProfilePipeline::dispatchNow($profile);
|
|
return;
|
|
break;
|
|
|
|
case 'Tombstone':
|
|
$profile = Helpers::profileFetch($actor);
|
|
$status = Status::whereProfileId($profile->id)
|
|
->whereUri($id)
|
|
->orWhere('url', $id)
|
|
->orWhere('object_url', $id)
|
|
->first();
|
|
if(!$status) {
|
|
return;
|
|
}
|
|
$status->directMessage()->delete();
|
|
$status->media()->delete();
|
|
$status->likes()->delete();
|
|
$status->shares()->delete();
|
|
$status->delete();
|
|
return;
|
|
break;
|
|
|
|
default:
|
|
return;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
public function handleLikeActivity()
|
|
{
|
|
$actor = $this->payload['actor'];
|
|
|
|
if(!Helpers::validateUrl($actor)) {
|
|
return;
|
|
}
|
|
|
|
$profile = self::actorFirstOrCreate($actor);
|
|
$obj = $this->payload['object'];
|
|
if(!Helpers::validateUrl($obj)) {
|
|
return;
|
|
}
|
|
$status = Helpers::statusFirstOrFetch($obj);
|
|
if(!$status || !$profile) {
|
|
return;
|
|
}
|
|
$like = Like::firstOrCreate([
|
|
'profile_id' => $profile->id,
|
|
'status_id' => $status->id
|
|
]);
|
|
|
|
if($like->wasRecentlyCreated == true) {
|
|
$status->likes_count = $status->likes()->count();
|
|
$status->save();
|
|
LikePipeline::dispatch($like);
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
public function handleRejectActivity()
|
|
{
|
|
|
|
}
|
|
|
|
public function handleUndoActivity()
|
|
{
|
|
$actor = $this->payload['actor'];
|
|
$profile = self::actorFirstOrCreate($actor);
|
|
$obj = $this->payload['object'];
|
|
|
|
switch ($obj['type']) {
|
|
case 'Accept':
|
|
break;
|
|
|
|
case 'Announce':
|
|
$obj = $obj['object'];
|
|
if(!Helpers::validateLocalUrl($obj)) {
|
|
return;
|
|
}
|
|
$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();
|
|
break;
|
|
|
|
case 'Block':
|
|
break;
|
|
|
|
case 'Follow':
|
|
$following = self::actorFirstOrCreate($obj['object']);
|
|
if(!$following) {
|
|
return;
|
|
}
|
|
Follower::whereProfileId($profile->id)
|
|
->whereFollowingId($following->id)
|
|
->delete();
|
|
Notification::whereProfileId($following->id)
|
|
->whereActorId($profile->id)
|
|
->whereAction('follow')
|
|
->whereItemId($following->id)
|
|
->whereItemType('App\Profile')
|
|
->forceDelete();
|
|
break;
|
|
|
|
case 'Like':
|
|
$status = Helpers::statusFirstOrFetch($obj['object']);
|
|
if(!$status) {
|
|
return;
|
|
}
|
|
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;
|
|
}
|
|
return;
|
|
}
|
|
}
|