add queue monitor

Author: rick-bongers

src/Console/Commands/SendQueueAnalyticsCommand.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Programic\Tools\Console\Commands;
+
+use Illuminate\Console\Command;
+use Programic\Tools\Contracts\AnalyticsClient;
+use Programic\Tools\Contracts\QueueSummary;
+
+class SendQueueAnalyticsCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'queue:monitor';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Send queue monitor to 3rd party';
+
+    /**
+     * @var QueueSummary
+     */
+    protected $queueSummary;
+
+    /**
+     * Execute the console command.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        $queueSummary = app(QueueSummary::class);
+        $analyticsClient = app(AnalyticsClient::class);
+        $results = $queueSummary->all();
+
+        $response = $analyticsClient->send($results);
+
+
+        if ($response['status'] === 'OK') {
+            $this->line('<info>' . $response['message'] . '</info>');
+
+            return;
+        }
+
+        $this->line('<error>' . $response['message'] . '</error>');
+    }
+}

src/Contracts/AnalyticsClient.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Programic\Tools\Contracts;
+
+use Illuminate\Support\Collection;
+
+interface AnalyticsClient
+{
+    public function __construct($auth);
+
+    public function send(Collection $data): array;
+}

src/Services/Analytics/Databox.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Programic\Tools\Services\Analytics;
+
+use Illuminate\Support\Collection;
+use Programic\Tools\Contracts\AnalyticsClient;
+
+class Databox implements AnalyticsClient
+{
+    private $token;
+
+    public function __construct($token)
+    {
+        $this->token = $token;
+
+        if (!$token) {
+            throw new \Exception('Databox token must be set');
+        }
+    }
+
+    public function send(Collection $data): array
+    {
+        $postData = [];
+
+        $data->each(function ($queue) use (&$postData) {
+            $name = $queue[0]->queue;
+            $count = $queue->sum('count');
+
+            foreach ($queue as $item) {
+                $postData[] = [
+                    "\$queue_{$item->queue}" => $item->count,
+                    'event' => str_replace('\\\\', '\\', (trim($item->event, '"'))),
+                    'date' => now()->format('c'),
+                ];
+            }
+        });
+
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL,'https://push.databox.com');
+        curl_setopt($ch, CURLOPT_POST, 1);
+        curl_setopt($ch, CURLOPT_USERPWD, "$this->token:");
+        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode(['data' => $postData]));
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+
+        $headers = [
+            'Accept: application/vnd.databox.v2+json',
+            'Content-Type: application/json',
+        ];
+
+        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
+
+        $server_output = curl_exec($ch);
+
+        curl_close($ch);
+
+        return json_decode($server_output, true);
+    }
+}

src/Services/Queue/DatabaseQueueService.php

@@ -13,7 +13,7 @@ public function all(): Collection
         return $this->format(
             DB::table('queue_jobs')
                 ->select(DB::raw('COUNT(0) as count, queue, JSON_EXTRACT(payload, "$.displayName") as event'))
-                ->where('available_at', '>', DB::raw('UNIX_TIMESTAMP(NOW())'))
+//                ->where('available_at', '>', DB::raw('UNIX_TIMESTAMP(NOW())'))
                 ->groupByRaw('queue, JSON_EXTRACT(payload, "$.displayName")')
                 ->get()
                 ->groupBy('queue')

src/ToolsServiceProvider.php

@@ -2,11 +2,15 @@
 
 namespace Programic\Tools;
 
+use Illuminate\Console\Scheduling\Schedule;
 use Illuminate\Routing\Router;
 use Illuminate\Support\ServiceProvider;
+use Programic\Tools\Console\Commands\SendQueueAnalyticsCommand;
+use Programic\Tools\Contracts\AnalyticsClient;
 use Programic\Tools\Contracts\QueueSummary;
 use Programic\Tools\Controllers\ToolsController;
 use Programic\Tools\Middleware\SentryContext;
+use Programic\Tools\Services\Analytics\Databox;
 
 class ToolsServiceProvider extends ServiceProvider
 {
@@ -36,6 +40,17 @@ public function boot(Router $router)
         });
 
         $this->app['router']->get('ohdear-health-check', [ToolsController::class, 'ohdear']);
+
+        $databoxToken = config('services.databox.token');
+
+        if ($databoxToken) {
+            $this->app->singleton(AnalyticsClient::class, fn () => new Databox($databoxToken));
+
+            $this->app->booted(function () {
+                $schedule = $this->app->make(Schedule::class);
+                $schedule->command(SendQueueAnalyticsCommand::class)->everyMinute()->withoutOverlapping();
+            });
+        }
     }
 
     /**
@@ -45,6 +60,8 @@ public function boot(Router $router)
      */
     public function register()
     {
-        // Register magic
+        $this->commands([
+           SendQueueAnalyticsCommand::class,
+        ]);
     }
 }