From 2a586ecac4dfcb7cdc0e15a7c4b6a25a2c51f66d Mon Sep 17 00:00:00 2001
From: myrmidex <myrmidex@myrmidex.net>
Date: Sun, 26 Apr 2026 21:15:07 +0200
Subject: [PATCH] 14 - Add PageCrawlObserver and ProcessCrawlJob skeleton

---
 app/Jobs/ProcessCrawlJob.php               | 21 ++++++++++++
 app/Models/PageCrawl.php                   |  3 ++
 app/Observers/PageCrawlObserver.php        | 14 ++++++++
 tests/Feature/Jobs/ProcessCrawlJobTest.php | 40 ++++++++++++++++++++++
 4 files changed, 78 insertions(+)
 create mode 100644 app/Jobs/ProcessCrawlJob.php
 create mode 100644 app/Observers/PageCrawlObserver.php
 create mode 100644 tests/Feature/Jobs/ProcessCrawlJobTest.php

diff --git a/app/Jobs/ProcessCrawlJob.php b/app/Jobs/ProcessCrawlJob.php
new file mode 100644
index 0000000..5c55b67
--- /dev/null
+++ b/app/Jobs/ProcessCrawlJob.php
@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Models\PageCrawl;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Queue\Queueable;
+
+class ProcessCrawlJob implements ShouldQueue
+{
+    use Queueable;
+
+    public function __construct(
+        public PageCrawl $pageCrawl,
+    ) {}
+
+    public function handle(): void
+    {
+        //
+    }
+}
diff --git a/app/Models/PageCrawl.php b/app/Models/PageCrawl.php
index aa6f77a..27cfe40 100644
--- a/app/Models/PageCrawl.php
+++ b/app/Models/PageCrawl.php
@@ -5,11 +5,14 @@
 namespace App\Models;
 
 use App\Enums\CrawlOutcomeEnum;
+use App\Observers\PageCrawlObserver;
 use Database\Factories\PageCrawlFactory;
+use Illuminate\Database\Eloquent\Attributes\ObservedBy;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\BelongsTo;
 
+#[ObservedBy(PageCrawlObserver::class)]
 class PageCrawl extends Model
 {
     /** @use HasFactory<PageCrawlFactory> */
diff --git a/app/Observers/PageCrawlObserver.php b/app/Observers/PageCrawlObserver.php
new file mode 100644
index 0000000..85a8517
--- /dev/null
+++ b/app/Observers/PageCrawlObserver.php
@@ -0,0 +1,14 @@
+<?php
+
+namespace App\Observers;
+
+use App\Jobs\ProcessCrawlJob;
+use App\Models\PageCrawl;
+
+class PageCrawlObserver
+{
+    public function created(PageCrawl $pageCrawl): void
+    {
+        ProcessCrawlJob::dispatch($pageCrawl);
+    }
+}
diff --git a/tests/Feature/Jobs/ProcessCrawlJobTest.php b/tests/Feature/Jobs/ProcessCrawlJobTest.php
new file mode 100644
index 0000000..98c632b
--- /dev/null
+++ b/tests/Feature/Jobs/ProcessCrawlJobTest.php
@@ -0,0 +1,40 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Tests\Feature\Jobs;
+
+use App\Jobs\ProcessCrawlJob;
+use App\Models\Page;
+use App\Models\PageCrawl;
+use Illuminate\Foundation\Testing\RefreshDatabase;
+use Illuminate\Support\Facades\Queue;
+use Tests\TestCase;
+
+class ProcessCrawlJobTest extends TestCase
+{
+    use RefreshDatabase;
+
+    public function test_creating_a_page_crawl_dispatches_process_crawl_job(): void
+    {
+        Queue::fake();
+
+        $page = Page::factory()->createQuietly(['url' => 'https://example.com/article']);
+        PageCrawl::factory()->page($page)->create();
+
+        Queue::assertPushed(ProcessCrawlJob::class);
+    }
+
+    public function test_dispatched_job_carries_the_correct_page_crawl(): void
+    {
+        Queue::fake();
+
+        $page = Page::factory()->createQuietly(['url' => 'https://example.com/article']);
+        $crawl = PageCrawl::factory()->page($page)->create();
+
+        Queue::assertPushed(
+            ProcessCrawlJob::class,
+            fn (ProcessCrawlJob $job) => $job->pageCrawl->id === $crawl->id,
+        );
+    }
+}