Fire invalidation as a job so it can be queued (#15)

src/Jobs/InvalidateTags.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Thoughtco\StatamicCacheTracker\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Thoughtco\StatamicCacheTracker\Facades\Tracker;
+
+class InvalidateTags implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable;
+
+    public function __construct(public array $tags) {}
+
+    public function handle(): void
+    {
+        Tracker::invalidate($this->tags);
+    }
+}

src/Listeners/Subscriber.php

@@ -4,6 +4,7 @@
 
 use Statamic\Events;
 use Thoughtco\StatamicCacheTracker\Facades\Tracker;
+use Thoughtco\StatamicCacheTracker\Jobs\InvalidateTags;
 
 class Subscriber
 {
@@ -115,6 +116,6 @@ public function invalidateAndDeleteTerm($event)
 
     private function invalidateContent($tags)
     {
-        Tracker::invalidate($tags);
+        InvalidateTags::dispatch($tags);
     }
 }

tests/Unit/EventListenerTest.php

@@ -7,6 +7,7 @@
 use Thoughtco\StatamicCacheTracker\Events\TrackContentTags;
 use Thoughtco\StatamicCacheTracker\Facades\Tracker;
 use Thoughtco\StatamicCacheTracker\Http\Middleware\CacheTracker;
+use Thoughtco\StatamicCacheTracker\Jobs\InvalidateTags;
 use Thoughtco\StatamicCacheTracker\Tests\TestCase;
 
 class EventListenerTest extends TestCase
@@ -23,8 +24,29 @@ public function it_tracks_tags_from_events()
         };
 
         $middleware = new CacheTracker();
-        $response = $middleware->handle($request, $next);
+        $middleware->handle($request, $next);
 
         $this->assertSame(['test::tag'], collect(Tracker::all())->firstWhere('url', 'http://localhost/')['tags']);
     }
+
+    #[Test]
+    public function dispatching_job_clears_tags()
+    {
+        $request = Request::create('/');
+
+        $next = function () {
+            TrackContentTags::dispatch(['test::tag']);
+
+            return response('');
+        };
+
+        $middleware = new CacheTracker();
+        $middleware->handle($request, $next);
+
+        $this->assertSame(['test::tag'], collect(Tracker::all())->firstWhere('url', 'http://localhost/')['tags']);
+
+        InvalidateTags::dispatch(['test::tag']);
+
+        $this->assertSame([], Tracker::all());
+    }
 }