pixelfed/app/Jobs/MovePipeline/MoveMigrateFollowersPipelin...

132 lines
3.7 KiB
PHP
Raw Normal View History

2024-09-07 07:57:03 +00:00
<?php
namespace App\Jobs\MovePipeline;
use App\Follower;
use App\Util\ActivityPub\Helpers;
2024-09-09 06:35:08 +00:00
use DateTime;
2024-09-07 07:57:03 +00:00
use DB;
use Exception;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
2024-09-09 08:00:27 +00:00
use Illuminate\Queue\Middleware\ThrottlesExceptionsWithRedis;
2024-09-07 07:57:03 +00:00
use Illuminate\Queue\Middleware\WithoutOverlapping;
class MoveMigrateFollowersPipeline implements ShouldQueue
{
use Queueable;
2024-09-09 10:48:36 +00:00
public $target;
public $activity;
/**
* The number of times the job may be attempted.
*
* @var int
*/
public $tries = 15;
/**
* The maximum number of unhandled exceptions to allow before failing.
*
* @var int
*/
public $maxExceptions = 5;
/**
* The number of seconds the job can run before timing out.
*
* @var int
*/
public $timeout = 900;
/**
* Create a new job instance.
*/
public function __construct($target, $activity)
2024-09-07 07:57:03 +00:00
{
$this->target = $target;
$this->activity = $activity;
}
2024-09-09 10:48:36 +00:00
/**
* Get the middleware the job should pass through.
*
* @return array<int, object>
*/
2024-09-07 07:57:03 +00:00
public function middleware(): array
{
return [
new WithoutOverlapping('process-move-migrate-followers:'.$this->target),
2024-09-09 08:00:27 +00:00
(new ThrottlesExceptionsWithRedis(5, 2 * 60))->backoff(1),
2024-09-07 07:57:03 +00:00
];
}
2024-09-09 10:48:36 +00:00
/**
* Determine the time at which the job should timeout.
*/
2024-09-07 07:57:03 +00:00
public function retryUntil(): DateTime
{
2024-09-09 08:00:27 +00:00
return now()->addMinutes(15);
2024-09-07 07:57:03 +00:00
}
2024-09-09 10:48:36 +00:00
/**
* Execute the job.
*/
2024-09-07 07:57:03 +00:00
public function handle(): void
{
2024-09-09 10:48:36 +00:00
if (config('app.env') !== 'production' || (bool) config_cache('federation.activitypub.enabled') == false) {
throw new Exception('Activitypub not enabled');
2024-09-09 10:12:23 +00:00
}
2024-09-07 07:57:03 +00:00
2024-09-09 10:48:36 +00:00
$target = $this->target;
$actor = $this->activity;
2024-09-09 10:12:23 +00:00
2024-09-09 10:48:36 +00:00
$targetAccount = Helpers::profileFetch($target);
$actorAccount = Helpers::profileFetch($actor);
2024-09-09 10:12:23 +00:00
2024-09-09 10:48:36 +00:00
if (! $targetAccount || ! $actorAccount) {
throw new Exception('Invalid move accounts');
2024-09-07 07:57:03 +00:00
}
$activity = [
'@context' => 'https://www.w3.org/ns/activitystreams',
'type' => 'Follow',
2024-09-09 10:48:36 +00:00
'actor' => null,
'object' => $target,
2024-09-07 07:57:03 +00:00
];
$version = config('pixelfed.version');
$appUrl = config('app.url');
$userAgent = "(Pixelfed/{$version}; +{$appUrl})";
$addlHeaders = [
'Content-Type' => 'application/ld+json; profile="https://www.w3.org/ns/activitystreams"',
'User-Agent' => $userAgent,
];
2024-09-09 10:48:36 +00:00
$targetInbox = $targetAccount['sharedInbox'] ?? $targetAccount['inbox_url'];
$targetPid = $targetAccount['id'];
DB::table('followers')
->join('profiles', 'followers.profile_id', '=', 'profiles.id')
->where('followers.following_id', $actorAccount['id'])
->whereNotNull('profiles.user_id')
->whereNull('profiles.deleted_at')
->select('profiles.id', 'profiles.user_id', 'profiles.username', 'profiles.private_key', 'profiles.status')
->chunkById(100, function ($followers) use ($targetInbox, $targetPid, $target) {
foreach ($followers as $follower) {
if (! $follower->private_key || ! $follower->username || ! $follower->user_id || $follower->status === 'delete') {
continue;
2024-09-09 10:48:36 +00:00
}
Follower::updateOrCreate([
'profile_id' => $follower->id,
'following_id' => $targetPid,
]);
2024-09-09 10:48:36 +00:00
MoveSendFollowPipeline::dispatch($follower, $targetInbox, $targetPid, $target)->onQueue('follow');
}
2024-09-09 10:48:36 +00:00
}, 'id');
2024-09-07 07:57:03 +00:00
}
}