Beacon Telemetry (#20)

Author: jbrooksuk

config/cachet.php

@@ -97,4 +97,6 @@
     'major_outage' => 25.0,
 
     'beacon' => env('CACHET_BEACON', true),
+
+    'docker' => env('CACHET_DOCKER', false),
 ];

src/Jobs/SendBeaconJob.php

@@ -2,6 +2,15 @@
 
 namespace Cachet\Jobs;
 
+use Cachet\Cachet;
+use Cachet\Events\Beacon\BeaconSent;
+use Cachet\Models\Component;
+use Cachet\Models\Incident;
+use Cachet\Models\Metric;
+use Cachet\Models\Schedule;
+use Cachet\Settings\AppSettings;
+use Illuminate\Support\Facades\Http;
+
 class SendBeaconJob
 {
     /**
@@ -11,6 +20,23 @@ class SendBeaconJob
      */
     public function handle()
     {
-        //
+        if (! config('cachet.beacon')) {
+            return;
+        }
+
+        $request = Http::asJson()->post('https://cachethq.io/beacon', [
+            'install_id' => app(AppSettings::class)->install_id,
+            'version' => Cachet::version(),
+            'docker' => config('cachet.docker'),
+            'database' => config('database.default'),
+            'data' => [
+                'components' => Component::query()->count(),
+                'incidents' => Incident::query()->count(),
+                'metrics' => Metric::query()->count(),
+                'schedules' => Schedule::query()->count(),
+            ],
+        ]);
+
+        BeaconSent::dispatchIf($request->successful());
     }
 }

tests/Unit/Jobs/SendBeaconJobTest.php

@@ -0,0 +1,45 @@
+<?php
+
+use Cachet\Cachet;
+use Cachet\Jobs\SendBeaconJob;
+use Cachet\Models\Component;
+use Cachet\Models\Incident;
+use Cachet\Models\Metric;
+use Cachet\Models\Schedule;
+use Illuminate\Http\Client\Request;
+use Illuminate\Support\Facades\Http;
+
+it('will not send the beacon if disabled', function () {
+    Http::fake();
+
+    config(['cachet.beacon' => false]);
+
+    dispatch(new SendBeaconJob());
+
+    Http::assertNothingSent();
+});
+
+it('sends telemetry data', function () {
+    Http::fake([
+        'https://cachethq.io/beacon' => Http::response([]),
+    ]);
+
+    config(['cachet.beacon' => true]);
+
+    Component::factory()->count(1)->create();
+    Incident::factory()->count(2)->create();
+    Metric::factory()->count(3)->create();
+    Schedule::factory()->count(4)->create();
+
+    dispatch(new SendBeaconJob());
+
+    Http::assertSent(function (Request $request) {
+        return $request['version'] === Cachet::version() &&
+            $request['docker'] === false &&
+            $request['data']['components'] === 1 &&
+            $request['data']['incidents'] === 2 &&
+            $request['data']['metrics'] === 3 &&
+            $request['data']['schedules'] === 4;
+    });
+    Http::assertSentCount(1);
+});