Live update queue charts

laravel · Oct 6, 2023 · 078e344 · 078e344
1 parent 521523b
commit 078e344
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 1 deletion.
diff --git a/resources/views/livewire/queues.blade.php b/resources/views/livewire/queues.blade.php
@@ -119,8 +119,25 @@ class="h-12 mt-1"
                                         },
                                     }
                                 )
+
+                                Livewire.on('queues-chart-update', ({ queues }) => {
+                                    if (chart === undefined) {
+                                        return
+                                    }
+
+                                    if (queues['{{ $queue }}'] === undefined && chart) {
+                                        chart.destroy()
+                                        chart = undefined
+                                        return
+                                    }
+
+                                    chart.data.labels = queues['{{ $queue }}'].map(reading => reading.date)
+                                    chart.data.datasets[0].data = queues['{{ $queue }}'].map(reading => reading.queued)
+                                    chart.data.datasets[1].data = queues['{{ $queue }}'].map(reading => reading.processed)
+                                    chart.data.datasets[2].data = queues['{{ $queue }}'].map(reading => reading.failed)
+                                    chart.update()
+                                })
                             }
-                            // TODO: Live update chart
                         }"
                     >
                         <canvas x-ref="canvas" class="w-full ring-1 ring-gray-900/10 dark:ring-gray-100/10 bg-white dark:bg-gray-800 rounded-md shadow-sm"></canvas>

diff --git a/src/Livewire/Queues.php b/src/Livewire/Queues.php
@@ -23,6 +23,10 @@ public function render(QueuesQuery $query): Renderable
     {
         [$queues, $time, $runAt] = $this->remember($query);
 
+        if (request()->hasHeader('X-Livewire')) {
+            $this->dispatch('queues-chart-update', queues: $queues);
+        }
+
         return View::make('pulse::livewire.queues', [
             'queues' => $queues,
             'showConnection' => $queues->keys()->map(fn ($queue) => Str::before($queue, ':'))->unique()->count() > 1,