(refactor) Use first class callable

app/Http/Requests/CreateActivityRequest.php

@@ -5,8 +5,10 @@
 namespace App\Http\Requests;
 
 use App\Enums\EventType;
+use Illuminate\Contracts\Validation\Validator;
 use Illuminate\Foundation\Http\FormRequest;
 use Illuminate\Validation\Rule;
+use Illuminate\Validation\ValidationException;
 
 final class CreateActivityRequest extends FormRequest
 {
@@ -27,4 +29,17 @@ public function rules(): array
             ],
         ];
     }
+
+    protected function failedValidation(Validator $validator)
+    {
+        $errors = $validator->errors();
+        $errors->add('events', 'The events field is invalid.');
+
+        $response = response()->json([
+            'events' => 'The events field is invalid.',
+            'errors' => $validator->errors(),
+        ], 422);
+
+        throw new ValidationException($validator, $response);
+    }
 }

app/Jobs/IngestActivity.php

@@ -32,28 +32,34 @@ public function handle(): void
         $events = $this->activity->events;
 
         collect($events)
-            ->each(function (Event $event): void {
-                $path = $this->urlToPath($event->payload['url']);
-                $bucket = $this->bucket->setTime($this->bucket->hour, 0, 0);
-
-                /** @var Page $page */
-                $page = $this->activity->project->pages()->firstOrCreate([
-                    'path' => $path,
-                    'bucket' => $bucket,
-                ], [
-                    'views' => 0,
-                    'average_time' => 0,
-                ]);
-
-                match ($event->type) {
-                    EventType::View => $this->handleView($page),
-                    EventType::ViewDuration => $this->handleViewDuration($page, $event),
-                };
-            });
+            ->each($this->processEvent(...));
 
         $this->activity->delete();
     }
 
+    /**
+     * Process the event.
+     */
+    private function processEvent(Event $event): void
+    {
+        $path = $this->urlToPath($event->payload['url']);
+        $bucket = $this->bucket->setTime($this->bucket->hour, 0, 0);
+
+        /** @var Page $page */
+        $page = $this->activity->project->pages()->firstOrCreate([
+            'path' => $path,
+            'bucket' => $bucket,
+        ], [
+            'views' => 0,
+            'average_time' => 0,
+        ]);
+
+        match ($event->type) {
+            EventType::View => $this->handleView($page),
+            EventType::ViewDuration => $this->handleViewDuration($page, $event),
+        };
+    }
+
     /**
      * Handle the view event.
      */