✨ Start, stop and refresh webhooks

Author: lorisleiva

Diff for: app/Calendar.php

@@ -6,6 +6,7 @@
 use App\Event;
 use App\GoogleAccount;
 use App\Jobs\SynchronizeGoogleEvents;
+use App\Jobs\WatchGoogleEvents;
 use Illuminate\Database\Eloquent\Model;
 
 class Calendar extends Model
@@ -30,4 +31,9 @@ public function synchronize()
     {
         SynchronizeGoogleEvents::dispatch($this);
     }
+
+    public function watch()
+    {
+        WatchGoogleEvents::dispatch($this);
+    }
 }

Diff for: app/Concerns/Synchronizable.php

@@ -33,4 +33,5 @@ public function getGoogleService($service)
     }
 
     abstract public function synchronize();
+    abstract public function watch();
 }

Diff for: app/Console/Kernel.php

@@ -3,6 +3,7 @@
 namespace App\Console;
 
 use App\Jobs\PeriodicSynchronizations;
+use App\Jobs\RefreshWebhookSynchronizations;
 use Illuminate\Console\Scheduling\Schedule;
 use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
 
@@ -26,6 +27,7 @@ class Kernel extends ConsoleKernel
     protected function schedule(Schedule $schedule)
     {
         $schedule->job(new PeriodicSynchronizations())->everyFifteenMinutes();
+        $schedule->job(new RefreshWebhookSynchronizations())->daily();
     }
 
     /**

Diff for: app/GoogleAccount.php

@@ -5,6 +5,7 @@
 use App\Calendar;
 use App\Concerns\Synchronizable;
 use App\Jobs\SynchronizeGoogleCalendars;
+use App\Jobs\WatchGoogleCalendars;
 use App\Services\Google;
 use App\User;
 use Illuminate\Database\Eloquent\Model;
@@ -35,4 +36,9 @@ public function synchronize()
     {
         SynchronizeGoogleCalendars::dispatch($this);
     }
+
+    public function watch()
+    {
+        WatchGoogleCalendars::dispatch($this);
+    }
 }

Diff for: app/Jobs/RefreshWebhookSynchronizations.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace App\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+
+class RefreshWebhookSynchronizations implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public function handle()
+    {
+        Synchronization::query()
+            ->whereNotNull('resource_id')
+            ->whereNull('expired_at')
+            ->orWhere('expired_at', '<', now()->addDays(2))
+            ->get()
+            ->each->refreshWebhook();
+    }
+}

Diff for: app/Synchronization.php

@@ -23,6 +23,36 @@ public function ping()
         return $this->synchronizable->synchronize();
     }
 
+    public function startListeningForChanges()
+    {
+        return $this->synchronizable->watch();
+    }
+
+    public function stopListeningForChanges()
+    {
+        if (! $this->resource_id) {
+            return;
+        }
+
+        $this->synchronizable
+            ->getGoogleService('Calendar')
+            ->channels->stop($this->asGoogleChannel());
+    }
+
+    public function refreshWebhook()
+    {
+        $this->stopListeningForChanges();
+
+        // Update the UUID since the previous one has 
+        // already been associated to a Google Channel.
+        $this->id = Uuid::uuid4();
+        $this->save();
+
+        $this->startListeningForChanges();
+
+        return $this;
+    }
+
     public function asGoogleChannel()
     {
         return tap(new \Google_Service_Calendar_Channel(), function ($channel) {
@@ -48,7 +78,12 @@ public static function boot()
         });
 
         static::created(function ($synchronization) {
+            $synchronization->startListeningForChanges();
             $synchronization->ping();
         });
+
+        static::deleting(function ($synchronization) {
+            $synchronization->stopListeningForChanges();
+        });
     }
 }