Merge pull request #693 from FitzwilliamMuseum/hotfix/social-media-se…

…arch Add twitterPurge and instagramPurge to importController
FitzwilliamMuseum · Jun 20, 2024 · 56ab429 · 56ab429
2 parents c373ff8 + 76d57e5
commit 56ab429
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 1 deletion.
diff --git a/app/Console/Kernel.php b/app/Console/Kernel.php
@@ -65,7 +65,7 @@ public function solrTasks(Schedule $schedule)
         $schedule->call('App\Http\Controllers\solrImportController@vacancies')->cron('0 */5 * * *');
         $schedule->call('App\Http\Controllers\solrImportController@resources')->cron('0 */5 * * *');
 //        $schedule->call('App\Http\Controllers\instagramController@instagram')->cron('0 */5 * * *');
-        $schedule->call('App\Http\Controllers\twitterController@twitter')->cron('0 */5 * * *');
+//        $schedule->call('App\Http\Controllers\twitterController@twitter')->cron('0 */5 * * *');
         # Import Jekyll to solr
         $schedule->call('App\Http\Controllers\jekyllController@import')->cron('0 */5 * * *');
         # Import WordPress to solr

diff --git a/app/Http/Controllers/solrImportController.php b/app/Http/Controllers/solrImportController.php
@@ -526,6 +526,32 @@ public function shopifyRefresh(): Result|ResultInterface
         return $client->update($delete);
     }
 
+    /**
+     * @return ResultInterface|Result
+     */
+    public function twitterPurge(): Result|ResultInterface
+    {
+        $configSolr = Config::get('solarium');
+        $client = new Client(new Curl(), new EventDispatcher(), $configSolr);
+        $delete = $client->createUpdate();
+        $delete->addDeleteQuery('contentType:twitter');
+        $delete->addCommit();
+        return $client->update($delete);
+    }
+
+    /**
+     * @return ResultInterface|Result
+     */
+    public function instagramPurge(): Result|ResultInterface
+    {
+        $configSolr = Config::get('solarium');
+        $client = new Client(new Curl(), new EventDispatcher(), $configSolr);
+        $delete = $client->createUpdate();
+        $delete->addDeleteQuery('contentType:instagram');
+        $delete->addCommit();
+        return $client->update($delete);
+    }
+
     /**
      * @return ResultInterface|Result
      */