mirror
/
pixelfed
mirror of https://github.com/pixelfed/pixelfed.git
1
0
Fork 1
Code Issues Releases Wiki Activity

Merge pull request #3976 from pixelfed/staging 

Update InboxPipeline
This commit is contained in:
daniel 2022-12-19 23:19:11 -07:00 committed by GitHub
parent 5f8ff9d280 06c10401c8
commit d384ae3669
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/Jobs/InboxPipeline/InboxValidator.php
View File

@ -17,6 +17,7 @@ use Illuminate\Queue\SerializesModels;
use App\Jobs\DeletePipeline\DeleteRemoteProfilePipeline;
use Illuminate\Support\Facades\Http;
use Illuminate\Http\Client\ConnectionException;
use Illuminate\Support\Lottery;
class InboxValidator implements ShouldQueue
{
@ -81,7 +82,8 @@ class InboxValidator implements ShouldQueue
if(isset($payload['type']) && in_array($payload['type'], ['Follow', 'Accept']) ) {
ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('follow');
} else {
ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('inbox');
$onQueue = Lottery::odds(1, 12)->winner(fn () => 'high')->loser(fn () => 'inbox')->choose();
ActivityHandler::dispatch($headers, $profile, $payload)->onQueue($onQueue);
}
return;
} else {

2
app/Jobs/InboxPipeline/InboxWorker.php
View File

@ -66,7 +66,7 @@ class InboxWorker implements ShouldQueue
}
if($this->verifySignature($headers, $payload) == true) {
ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('inbox');
ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('shared');
return;
} else {
return;