fix: multi currency seeders

Author: hackeresq

app/Models/CurrencyRate.php

@@ -111,7 +111,7 @@ public static function historic(string $currency, mixed $date = null): float
      *
      * @return array<string, float>
      */
-    public static function timeSeriesRates(string|array $currency, mixed $start = null, mixed $end = null): array
+    public static function timeSeriesRates(?string $currency = null, mixed $start = null, mixed $end = null): array
     {
         if (empty($start)) {
             return [];
@@ -132,19 +132,18 @@ public static function timeSeriesRates(string|array $currency, mixed $start = nu
             return $dateRange;
         }
 
-        [$currency, $adjustment] = self::getCurrencyAliasAdjustments($currency);
-
+        // handle currency alias
         if (! empty($currency)) {
 
-            $currencies = Arr::wrap($currency);
+            [$currency, $adjustment] = self::getCurrencyAliasAdjustments($currency);
 
         } else {
 
-            $currencies = Currency::all()->pluck('currency')->toArray();
+            $currency = Currency::all()->pluck('currency')->toArray();
         }
 
         // get rates
-        $rates = Frankfurter::setSymbols($currencies)->timeSeries($period->first(), $period->last());
+        $rates = Frankfurter::setSymbols($currency)->timeSeries($period->first(), $period->last());
 
         $rates = collect(Arr::get($rates, 'rates', []))->sortKeys()->toArray();
 
@@ -177,13 +176,18 @@ public static function timeSeriesRates(string|array $currency, mixed $start = nu
         // persist
         self::chunkInsert($updates);
 
-        return collect($updates)
-            ->whereBetween('date', [$start, $end ?? now()])
-            ->where('currency', $currency)
-            ->mapWithKeys(fn ($rate) => [
-                $rate['date'] => $rate['rate'] * $adjustment,
-            ])
-            ->toArray();
+        if (is_string($currency)) {
+
+            return collect($updates)
+                ->whereBetween('date', [$start, $end ?? now()])
+                ->where('currency', $currency)
+                ->mapWithKeys(fn ($rate) => [
+                    $rate['date'] => $rate['rate'] * ($adjustment ?? 1),
+                ])
+                ->toArray();
+        }
+
+        return [];
     }
 
     private static function getNearestPastDate(CarbonInterface $date, array $datesOnly, array $rates): ?CarbonInterface
@@ -265,7 +269,7 @@ public static function chunkInsert(array $updates): void
         }
     }
 
-    protected static function getCurrencyAliasAdjustments($currency)
+    protected static function getCurrencyAliasAdjustments(string $currency)
     {
         $adjustment = 1;
 

database/migrations/2025_12_28_000001_add_multi_currency_support.php

@@ -97,9 +97,14 @@ public function up(): void
                 '--force' => true,
             ]);
 
-            CurrencyRate::timeSeriesRates(
-                Holding::all()->groupBy('market_data.currency')->keys()->toArray(),
-                Transaction::min('date')
+            Holding::all()->groupBy('market_data.currency')->keys()->each(
+                fn ($currency) => dispatch(
+                    function () use ($currency) {
+                        CurrencyRate::timeSeriesRates(
+                            $currency,
+                            Transaction::min('date')
+                        );
+                    })
             );
 
             CurrencyRate::refreshCurrencyData();

database/seeders/MarketDataSeeder.php

@@ -54,8 +54,7 @@ public function run(): void
                     $rowCount++;
 
                     if ($rowCount % $chunkSize == 0) {
-                        DB::table('market_data')->upsert($this->rows, ['symbol'], ['name', 'currency', 'meta_data']);
-                        $this->rows = [];
+                        $this->bulkInsert($this->rows);
                     }
                 }
             }
@@ -77,11 +76,14 @@ public function run(): void
         }
     }
 
-    public function bulkInsert(array $rows)
+    public function bulkInsert($rows)
     {
         try {
 
-            DB::table('market_data')->insertOrIgnore($rows);
+            dispatch(
+                fn () => DB::table('market_data')->upsert($rows, ['symbol'], ['name', 'currency', 'meta_data'])
+            );
+
             $this->rows = [];
 
         } catch (\Throwable $e) {