UA-Fediland/pixelfed
2
0
Fork 0
mirror of https://github.com/pixelfed/pixelfed.git synced 2024-11-25 15:55:22 +00:00
Code Issues Projects Releases Packages Wiki Activity

Update LikePipeline, dispatch to feed queue. Fixes #4723

Browse source
This commit is contained in:
Daniel Supernault 2023-10-30 21:16:28 -06:00
parent eb291efe00
commit da510089e2
No known key found for this signature in database
GPG key ID: 23740873EE6F76A1
3 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
app/Http/Controllers/Api/ApiV1Controller.php
View file

@ -1271,7 +1271,7 @@ class ApiV1Controller extends Controller
Status::findOrFail($status['id'])->update([
'likes_count' => ($status['favourites_count'] ?? 0) + 1
]);
LikePipeline::dispatch($like);
LikePipeline::dispatch($like)->onQueue('feed');
}
$status['favourited'] = true;
@ -1308,7 +1308,7 @@ class ApiV1Controller extends Controller
if($like) {
$like->forceDelete();
$status->likes_count = $status->likes()->count();
$status->likes_count = $status->likes_count > 1 ? $status->likes_count - 1 : 0;
$status->save();
}

7
app/Http/Controllers/LikeController.php
View file

@ -25,8 +25,7 @@ class LikeController extends Controller
'item' => 'required|integer|min:1',
]);
// API deprecated
return;
abort(422, 'Deprecated API Endpoint');
$user = Auth::user();
$profile = $user->profile;
@ -34,7 +33,7 @@ class LikeController extends Controller
if (Like::whereStatusId($status->id)->whereProfileId($profile->id)->exists()) {
$like = Like::whereProfileId($profile->id)->whereStatusId($status->id)->firstOrFail();
UnlikePipeline::dispatch($like);
UnlikePipeline::dispatch($like)->onQueue('feed');
} else {
abort_if(
Like::whereProfileId($user->profile_id)
@ -60,7 +59,7 @@ class LikeController extends Controller
]) == false;
$like->save();
$status->save();
LikePipeline::dispatch($like);
LikePipeline::dispatch($like)->onQueue('feed');
}
}

2
app/Jobs/DeletePipeline/DeleteRemoteStatusPipeline.php
View file

@ -57,7 +57,7 @@ class DeleteRemoteStatusPipeline implements ShouldQueue
$status = $this->status;
if(AccountService::get($status->profile_id, true)) {
DecrementPostCount::dispatch($status->profile_id)->onQueue('feed');
DecrementPostCount::dispatch($status->profile_id)->onQueue('low');
}
NetworkTimelineService::del($status->id);