mirror of
https://github.com/pixelfed/pixelfed.git
synced 2024-11-30 02:03:16 +00:00
103 lines
2.5 KiB
PHP
103 lines
2.5 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs\MovePipeline;
|
|
|
|
use App\Follower;
|
|
use App\Profile;
|
|
use App\Services\AccountService;
|
|
use App\UserFilter;
|
|
use App\Util\ActivityPub\Helpers;
|
|
use DateTime;
|
|
use Exception;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Queue\Queueable;
|
|
use Illuminate\Queue\Middleware\ThrottlesExceptions;
|
|
use Illuminate\Queue\Middleware\WithoutOverlapping;
|
|
|
|
class CleanupLegacyAccountMovePipeline implements ShouldQueue
|
|
{
|
|
use Queueable;
|
|
|
|
public $target;
|
|
|
|
public $activity;
|
|
|
|
/**
|
|
* The number of times the job may be attempted.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $tries = 6;
|
|
|
|
/**
|
|
* The maximum number of unhandled exceptions to allow before failing.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $maxExceptions = 3;
|
|
|
|
/**
|
|
* Create a new job instance.
|
|
*/
|
|
public function __construct($target, $activity)
|
|
{
|
|
$this->target = $target;
|
|
$this->activity = $activity;
|
|
}
|
|
|
|
/**
|
|
* Get the middleware the job should pass through.
|
|
*
|
|
* @return array<int, object>
|
|
*/
|
|
public function middleware(): array
|
|
{
|
|
return [
|
|
new WithoutOverlapping('process-move-cleanup-legacy-followers:'.$this->target),
|
|
(new ThrottlesExceptions(2, 5 * 60))->backoff(5),
|
|
];
|
|
}
|
|
|
|
/**
|
|
* Determine the time at which the job should timeout.
|
|
*/
|
|
public function retryUntil(): DateTime
|
|
{
|
|
return now()->addMinutes(5);
|
|
}
|
|
|
|
/**
|
|
* Execute the job.
|
|
*/
|
|
public function handle(): void
|
|
{
|
|
if (config('app.env') !== 'production' || (bool) config_cache('federation.activitypub.enabled') == false) {
|
|
throw new Exception('Activitypub not enabled');
|
|
}
|
|
|
|
$target = $this->target;
|
|
$actor = $this->activity;
|
|
|
|
$targetAccount = Helpers::profileFetch($target);
|
|
$actorAccount = Helpers::profileFetch($actor);
|
|
|
|
if (! $targetAccount || ! $actorAccount) {
|
|
throw new Exception('Invalid move accounts');
|
|
}
|
|
|
|
UserFilter::where('filterable_type', 'App\Profile')
|
|
->where('filterable_id', $actorAccount['id'])
|
|
->update(['filterable_id' => $targetAccount['id']]);
|
|
|
|
Follower::whereFollowingId($actorAccount['id'])->delete();
|
|
|
|
$oldProfile = Profile::find($actorAccount['id']);
|
|
|
|
if ($oldProfile) {
|
|
$oldProfile->moved_to_profile_id = $targetAccount['id'];
|
|
$oldProfile->save();
|
|
AccountService::del($oldProfile->id);
|
|
AccountService::del($targetAccount['id']);
|
|
}
|
|
}
|
|
}
|