Przeglądaj źródła

Update UserFilterObserver, dispatch FeedFollowPipeline jobs

Daniel Supernault 1 rok temu
rodzic
commit
125208fb9e
1 zmienionych plików z 6 dodań i 0 usunięć
  1. 6 0
      app/Observers/UserFilterObserver.php

+ 6 - 0
app/Observers/UserFilterObserver.php

@@ -4,6 +4,8 @@ namespace App\Observers;
 
 
 use App\UserFilter;
 use App\UserFilter;
 use App\Services\UserFilterService;
 use App\Services\UserFilterService;
+use App\Jobs\HomeFeedPipeline\FeedFollowPipeline;
+use App\Jobs\HomeFeedPipeline\FeedUnfollowPipeline;
 
 
 class UserFilterObserver
 class UserFilterObserver
 {
 {
@@ -78,10 +80,12 @@ class UserFilterObserver
 		switch ($userFilter->filter_type) {
 		switch ($userFilter->filter_type) {
 			case 'mute':
 			case 'mute':
 				UserFilterService::mute($userFilter->user_id, $userFilter->filterable_id);
 				UserFilterService::mute($userFilter->user_id, $userFilter->filterable_id);
+				FeedUnfollowPipeline::dispatch($userFilter->user_id, $userFilter->filterable_id)->onQueue('feed');
 				break;
 				break;
 				
 				
 			case 'block':
 			case 'block':
 				UserFilterService::block($userFilter->user_id, $userFilter->filterable_id);
 				UserFilterService::block($userFilter->user_id, $userFilter->filterable_id);
+				FeedUnfollowPipeline::dispatch($userFilter->user_id, $userFilter->filterable_id)->onQueue('feed');
 				break;
 				break;
 		}
 		}
 	}
 	}
@@ -96,10 +100,12 @@ class UserFilterObserver
 		switch ($userFilter->filter_type) {
 		switch ($userFilter->filter_type) {
 			case 'mute':
 			case 'mute':
 				UserFilterService::unmute($userFilter->user_id, $userFilter->filterable_id);
 				UserFilterService::unmute($userFilter->user_id, $userFilter->filterable_id);
+				FeedFollowPipeline::dispatch($userFilter->user_id, $userFilter->filterable_id)->onQueue('feed');
 				break;
 				break;
 				
 				
 			case 'block':
 			case 'block':
 				UserFilterService::unblock($userFilter->user_id, $userFilter->filterable_id);
 				UserFilterService::unblock($userFilter->user_id, $userFilter->filterable_id);
+				FeedFollowPipeline::dispatch($userFilter->user_id, $userFilter->filterable_id)->onQueue('feed');
 				break;
 				break;
 		}
 		}
 	}
 	}