mirror of
https://github.com/pixelfed/pixelfed.git
synced 2024-12-29 16:33:17 +00:00
87 lines
2 KiB
PHP
87 lines
2 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs\MovePipeline;
|
|
|
|
use App\Follower;
|
|
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');
|
|
}
|
|
|
|
Follower::whereFollowingId($actorAccount['id'])->delete();
|
|
}
|
|
}
|