removed mongoFsync function because it won't work with the default connection

Author: pushrbx

app/Console/Commands/Indexer/AnimeIndexer.php

@@ -129,11 +129,6 @@ public function handle()
 
             $success[] = $id;
             Storage::put('indexer/indexer_anime.save', $i);
-
-            // we want to sync to disk after every 300 items to avoid data loss.
-            if ($i % 300 == 0) {
-                mongoFsync();
-            }
         }
 
         Storage::delete('indexer/indexer_anime.save');

app/Console/Commands/Indexer/IncrementalIndexer.php

@@ -150,11 +150,6 @@ private function fetchIds(string $mediaType, array $idsToFetch, bool $resume): v
 
             $success[] = $id;
             Storage::put("indexer/incremental/{$mediaType}_resume.save", $index);
-
-            // we want to sync to disk after every 300 items to avoid data loss.
-            if ($i % 300 == 0) {
-                mongoFsync();
-            }
         }
 
         Storage::delete("indexer/incremental/{$mediaType}_resume.save");
@@ -168,7 +163,6 @@ private function fetchIds(string $mediaType, array $idsToFetch, bool $resume): v
 
         // finalize the latest state
         Storage::move("indexer/incremental/$mediaType.json.tmp", "indexer/incremental/$mediaType.json");
-        mongoFsync();
     }
 
     public function handle(): int

app/Support/helpers.php

@@ -123,16 +123,3 @@ function ensureEnumPrimitiveValue(int|string|bool|float|null|\Spatie\Enum\Larave
         return $value;
     }
 }
-
-if (!function_exists("mongoFsync")) {
-    function mongoFsync(bool $async = true): void {
-        $mongo = Illuminate\Support\Facades\DB::getMongoClient();
-        $adminDb = $mongo->selectDatabase('admin');
-        if ($async) {
-            $adminDb->command(['fsync' => 1]);
-        } else {
-            // sync journal too
-            $adminDb->command(['fsync' => 1, 'async' => false]);
-        }
-    }
-}