From 041c01359bb40471e9ca467bac922ce95045e909 Mon Sep 17 00:00:00 2001 From: Daniel Supernault Date: Sat, 9 Dec 2023 23:53:02 -0700 Subject: [PATCH] Update HomeFeedPipeline, fix StatusService validation --- app/Jobs/HomeFeedPipeline/FeedInsertPipeline.php | 2 +- app/Jobs/HomeFeedPipeline/FeedInsertRemotePipeline.php | 2 +- app/Jobs/HomeFeedPipeline/HashtagInsertFanoutPipeline.php | 2 +- app/Jobs/HomeFeedPipeline/HashtagRemoveFanoutPipeline.php | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/app/Jobs/HomeFeedPipeline/FeedInsertPipeline.php b/app/Jobs/HomeFeedPipeline/FeedInsertPipeline.php index de7032faf..19a546e83 100644 --- a/app/Jobs/HomeFeedPipeline/FeedInsertPipeline.php +++ b/app/Jobs/HomeFeedPipeline/FeedInsertPipeline.php @@ -69,7 +69,7 @@ class FeedInsertPipeline implements ShouldQueue, ShouldBeUniqueUntilProcessing $sid = $this->sid; $status = StatusService::get($sid, false); - if(!$status) { + if(!$status || !isset($status['account']) || !isset($status['account']['id'])) { return; } diff --git a/app/Jobs/HomeFeedPipeline/FeedInsertRemotePipeline.php b/app/Jobs/HomeFeedPipeline/FeedInsertRemotePipeline.php index 738c09699..e24696bd8 100644 --- a/app/Jobs/HomeFeedPipeline/FeedInsertRemotePipeline.php +++ b/app/Jobs/HomeFeedPipeline/FeedInsertRemotePipeline.php @@ -69,7 +69,7 @@ class FeedInsertRemotePipeline implements ShouldQueue, ShouldBeUniqueUntilProces $sid = $this->sid; $status = StatusService::get($sid, false); - if(!$status) { + if(!$status || !isset($status['account']) || !isset($status['account']['id'])) { return; } diff --git a/app/Jobs/HomeFeedPipeline/HashtagInsertFanoutPipeline.php b/app/Jobs/HomeFeedPipeline/HashtagInsertFanoutPipeline.php index 2e6bf4758..a200c06e8 100644 --- a/app/Jobs/HomeFeedPipeline/HashtagInsertFanoutPipeline.php +++ b/app/Jobs/HomeFeedPipeline/HashtagInsertFanoutPipeline.php @@ -77,7 +77,7 @@ class HashtagInsertFanoutPipeline implements ShouldQueue, ShouldBeUniqueUntilPro $sid = $hashtag->status_id; $status = StatusService::get($sid, false); - if(!$status) { + if(!$status || !isset($status['account']) || !isset($status['account']['id'])) { return; } diff --git a/app/Jobs/HomeFeedPipeline/HashtagRemoveFanoutPipeline.php b/app/Jobs/HomeFeedPipeline/HashtagRemoveFanoutPipeline.php index ea9d87fbb..f1968e120 100644 --- a/app/Jobs/HomeFeedPipeline/HashtagRemoveFanoutPipeline.php +++ b/app/Jobs/HomeFeedPipeline/HashtagRemoveFanoutPipeline.php @@ -71,7 +71,7 @@ class HashtagRemoveFanoutPipeline implements ShouldQueue, ShouldBeUniqueUntilPro $hid = $this->hid; $status = StatusService::get($sid, false); - if(!$status) { + if(!$status || !isset($status['account']) || !isset($status['account']['id'])) { return; }