wip

Author: Sebastian BURGIN-FIX (ext)

app/Console/Commands/FetchLlmAnalyticsCommand.php

@@ -5,27 +5,24 @@
 use App\Jobs\FetchLlmUsageJob;
 use Carbon\CarbonImmutable;
 use Carbon\CarbonPeriod;
-use Carbon\Exceptions\InvalidFormatException;
 use Illuminate\Console\Command;
 
 class FetchLlmAnalyticsCommand extends Command
 {
+    private const string INITIAL_SYNC_START = '2026-01-01';
+
     protected $signature = 'llm:fetch-analytics
+        {--full : Full sync from the very beginning ('.self::INITIAL_SYNC_START.')}
         {--from= : Start date (YYYY-MM-DD), defaults to 3 days ago}
         {--to= : End date (YYYY-MM-DD), defaults to today}';
 
     protected $description = 'Fetch daily per-model LLM usage from the LiteLLM proxy and store it locally';
 
     public function handle(): int
     {
-        try {
-            $to = $this->date($this->option('to')) ?? CarbonImmutable::today();
-            $from = $this->date($this->option('from')) ?? $to->subDays(3);
-        } catch (InvalidFormatException) {
-            $this->error('Invalid date format, expected YYYY-MM-DD.');
-
-            return self::FAILURE;
-        }
+        $to = $this->date($this->option('to')) ?? CarbonImmutable::today();
+        $from = $this->date($this->option('from'))
+            ?? ($this->option('full') ? $this->date(self::INITIAL_SYNC_START) : $to->subDays(3));
 
         if ($from->greaterThan($to)) {
             $this->error('The --from date must not be after the --to date.');

tests/Feature/Commands/FetchLlmAnalyticsCommandTest.php

@@ -1,6 +1,8 @@
 <?php
 
 use App\Jobs\FetchLlmUsageJob;
+use Carbon\CarbonImmutable;
+use Carbon\Exceptions\InvalidFormatException;
 use Illuminate\Support\Facades\Queue;
 
 it('dispatches one job per day for the default range', function () {
@@ -11,6 +13,18 @@
     Queue::assertPushed(FetchLlmUsageJob::class, 4);
 })->group('llm-analytics');
 
+it('backfills from the initial sync start with the full flag', function () {
+    Queue::fake();
+
+    $this->artisan('llm:fetch-analytics', ['--full' => true])->assertSuccessful();
+
+    $expectedDays = (int) CarbonImmutable::parse('2026-01-01')->diffInDays(CarbonImmutable::today()) + 1;
+
+    Queue::assertPushed(FetchLlmUsageJob::class, $expectedDays);
+
+    Queue::assertPushed(fn (FetchLlmUsageJob $job) => $job->date->toDateString() === '2026-01-01');
+})->group('llm-analytics');
+
 it('dispatches one job per day for a custom range', function () {
     Queue::fake();
 
@@ -23,13 +37,11 @@
     Queue::assertPushed(fn (FetchLlmUsageJob $job) => $job->date->toDateString() === '2026-01-05');
 })->group('llm-analytics');
 
-it('fails on an invalid date', function () {
+it('throws on an invalid date', function () {
     Queue::fake();
 
-    $this->artisan('llm:fetch-analytics', ['--from' => 'not-a-date'])->assertFailed();
-
-    Queue::assertNothingPushed();
-})->group('llm-analytics');
+    $this->artisan('llm:fetch-analytics', ['--from' => 'not-a-date']);
+})->throws(InvalidFormatException::class)->group('llm-analytics');
 
 it('fails when from is after to', function () {
     Queue::fake();