cachethq · jbrooksuk · Aug 2, 2026
diff --git a/src/Actions/Component/CreateComponent.php b/src/Actions/Component/CreateComponent.php
@@ -4,6 +4,7 @@
 
 use Cachet\Data\Requests\Component\CreateComponentRequestData;
 use Cachet\Models\Component;
+use Illuminate\Support\Facades\DB;
 
 class CreateComponent
 {
@@ -12,8 +13,10 @@ class CreateComponent
      */
     public function handle(CreateComponentRequestData $component): Component
     {
-        return tap(Component::create($component->except('meta')->toArray()), function (Component $model) use ($component) {
-            $model->syncMeta($component->meta ?? []);
+        return DB::transaction(function () use ($component): Component {
+            return tap(Component::create($component->except('meta')->toArray()), function (Component $model) use ($component) {
+                $model->syncMeta($component->meta ?? []);
+            });
         });
     }
 }
diff --git a/src/Actions/Component/DeleteComponent.php b/src/Actions/Component/DeleteComponent.php
@@ -8,11 +8,12 @@ class DeleteComponent
 {
     /**
      * Handle the action.
+     *
+     * The delete is soft, so the component keeps its subscriptions for a
+     * restore; the model purges them once it is hard deleted.
      */
     public function handle(Component $component): void
     {
-        $component->subscribers()->detach();
-
         $component->delete();
     }
 }
diff --git a/src/Actions/Component/UpdateComponent.php b/src/Actions/Component/UpdateComponent.php
@@ -3,6 +3,7 @@
 namespace Cachet\Actions\Component;
 
 use Cachet\Data\Requests\Component\UpdateComponentRequestData;
+use Cachet\Enums\ComponentStatusEnum;
 use Cachet\Enums\ComponentStatusSourceEnum;
 use Cachet\Models\Component;
 use Illuminate\Contracts\Auth\Authenticatable;
@@ -23,19 +24,19 @@ public function handle(Component $component, UpdateComponentRequestData $data, ?
         DB::transaction(function () use ($component, $data, $user): void {
             $attributes = $data->except('meta', 'status')->toArray();
 
-            if ($data->status === null) {
-                $component->update($attributes);
-            } else {
+            if ($data->status instanceof ComponentStatusEnum) {
                 $this->changeComponentStatus->handle(
                     $component,
                     $data->status,
                     ComponentStatusSourceEnum::Manual,
                     $user,
                     attributes: $attributes,
                 );
+            } else {
+                $component->update($attributes);
             }
 
-            if ($data->meta !== null) {
+            if (is_array($data->meta)) {
                 $component->syncMeta($data->meta);
             }
         });

diff --git a/src/Actions/ComponentGroup/CreateComponentGroup.php b/src/Actions/ComponentGroup/CreateComponentGroup.php
@@ -5,29 +5,29 @@
 use Cachet\Data\Requests\ComponentGroup\CreateComponentGroupRequestData;
 use Cachet\Models\Component;
 use Cachet\Models\ComponentGroup;
+use Illuminate\Support\Facades\DB;
 
 class CreateComponentGroup
 {
-    /**
-     * Handle the action.
-     */
     /**
      * Handle the action.
      */
     public function handle(CreateComponentGroupRequestData $data): ComponentGroup
     {
-        return tap(ComponentGroup::create(
-            $data->except('components', 'meta')->toArray(),
-        ), function (ComponentGroup $componentGroup) use ($data) {
-            $componentGroup->syncMeta($data->meta ?? []);
+        return DB::transaction(function () use ($data): ComponentGroup {
+            return tap(ComponentGroup::create(
+                $data->except('components', 'meta')->toArray(),
+            ), function (ComponentGroup $componentGroup) use ($data) {
+                $componentGroup->syncMeta($data->meta ?? []);
 
-            if (! $data->components) {
-                return;
-            }
+                if (! $data->components) {
+                    return;
+                }
 
-            Component::query()->whereIn('id', $data->components)->update([
-                'component_group_id' => $componentGroup->id,
-            ]);
+                Component::query()->whereIn('id', $data->components)->update([
+                    'component_group_id' => $componentGroup->id,
+                ]);
+            });
         });
     }
 }
diff --git a/src/Actions/ComponentGroup/DeleteComponentGroup.php b/src/Actions/ComponentGroup/DeleteComponentGroup.php
@@ -3,6 +3,7 @@
 namespace Cachet\Actions\ComponentGroup;
 
 use Cachet\Models\ComponentGroup;
+use Illuminate\Support\Facades\DB;
 
 class DeleteComponentGroup
 {
@@ -11,8 +12,10 @@ class DeleteComponentGroup
      */
     public function handle(ComponentGroup $componentGroup): void
     {
-        $componentGroup->components()->update(['component_group_id' => null]);
+        DB::transaction(function () use ($componentGroup): void {
+            $componentGroup->components()->update(['component_group_id' => null]);
 
-        $componentGroup->delete();
+            $componentGroup->delete();
+        });
     }
 }
diff --git a/src/Actions/ComponentGroup/UpdateComponentGroup.php b/src/Actions/ComponentGroup/UpdateComponentGroup.php
@@ -5,6 +5,7 @@
 use Cachet\Data\Requests\ComponentGroup\UpdateComponentGroupRequestData;
 use Cachet\Models\Component;
 use Cachet\Models\ComponentGroup;
+use Illuminate\Support\Facades\DB;
 
 class UpdateComponentGroup
 {
@@ -13,17 +14,19 @@ class UpdateComponentGroup
      */
     public function handle(ComponentGroup $componentGroup, UpdateComponentGroupRequestData $data): ComponentGroup
     {
-        $componentGroup->update($data->except('components', 'meta')->toArray());
+        DB::transaction(function () use ($componentGroup, $data): void {
+            $componentGroup->update($data->except('components', 'meta')->toArray());
 
-        if ($data->meta !== null) {
-            $componentGroup->syncMeta($data->meta);
-        }
+            if (is_array($data->meta)) {
+                $componentGroup->syncMeta($data->meta);
+            }
 
-        if ($data->components) {
-            Component::query()->whereIn('id', $data->components)->update([
-                'component_group_id' => $componentGroup->id,
-            ]);
-        }
+            if (is_array($data->components) && $data->components !== []) {
+                Component::query()->whereIn('id', $data->components)->update([
+                    'component_group_id' => $componentGroup->id,
+                ]);
+            }
+        });
 
         return $componentGroup->fresh();
     }

diff --git a/src/Actions/Incident/CreateIncident.php b/src/Actions/Incident/CreateIncident.php
@@ -26,7 +26,7 @@ public function handle(CreateIncidentRequestData $data): Incident
         if (isset($data->template)) {
             $template = IncidentTemplate::query()
                 ->where('slug', $data->template)
-                ->first();
+                ->firstOrFail();
 
             $data = $data->withMessage($this->parseTemplate($template, $data));
         }
@@ -65,7 +65,7 @@ private function parseTemplate(IncidentTemplate $template, CreateIncidentRequest
                 'name' => $data->name,
                 'status' => $data->status,
                 'message' => $data->message ?? null,
-                'visible' => $data->visible,
+                'visible' => $data->visible->value,
                 'notify' => $data->notifications,
                 'stickied' => $data->stickied,
                 'occurred_at' => $data->occurredAt ?? Carbon::now(),

diff --git a/src/Actions/Incident/DeleteIncident.php b/src/Actions/Incident/DeleteIncident.php
@@ -8,11 +8,13 @@ class DeleteIncident
 {
     /**
      * Handle the action.
+     *
+     * The delete is soft, so the incident keeps its updates and component
+     * attachments for a restore; the model purges them once it is hard
+     * deleted.
      */
     public function handle(Incident $incident): void
     {
-        $incident->updates()->delete();
-
         $incident->delete();
     }
 }
diff --git a/src/Actions/Incident/UpdateIncident.php b/src/Actions/Incident/UpdateIncident.php
@@ -4,6 +4,7 @@
 
 use Cachet\Data\Requests\Incident\UpdateIncidentRequestData;
 use Cachet\Models\Incident;
+use Illuminate\Support\Facades\DB;
 
 class UpdateIncident
 {
@@ -12,11 +13,13 @@ class UpdateIncident
      */
     public function handle(Incident $incident, UpdateIncidentRequestData $data): Incident
     {
-        $incident->update($data->except('meta')->toArray());
+        DB::transaction(function () use ($incident, $data): void {
+            $incident->update($data->except('meta')->toArray());
 
-        if ($data->meta !== null) {
-            $incident->syncMeta($data->meta);
-        }
+            if (is_array($data->meta)) {
+                $incident->syncMeta($data->meta);
+            }
+        });
 
         return $incident->fresh();
     }

diff --git a/src/Actions/Metric/DeleteMetric.php b/src/Actions/Metric/DeleteMetric.php
@@ -3,6 +3,7 @@
 namespace Cachet\Actions\Metric;
 
 use Cachet\Models\Metric;
+use Illuminate\Support\Facades\DB;
 
 class DeleteMetric
 {
@@ -11,7 +12,9 @@ class DeleteMetric
      */
     public function handle(Metric $metric): void
     {
-        $metric->metricPoints()->delete();
-        $metric->delete();
+        DB::transaction(function () use ($metric): void {
+            $metric->metricPoints()->delete();
+            $metric->delete();
+        });
     }
 }
diff --git a/src/Actions/Schedule/UpdateSchedule.php b/src/Actions/Schedule/UpdateSchedule.php
@@ -5,6 +5,7 @@
 use Cachet\Data\Requests\Schedule\ScheduleComponentRequestData;
 use Cachet\Data\Requests\Schedule\UpdateScheduleRequestData;
 use Cachet\Models\Schedule;
+use Illuminate\Support\Facades\DB;
 
 class UpdateSchedule
 {
@@ -13,21 +14,23 @@ class UpdateSchedule
      */
     public function handle(Schedule $schedule, UpdateScheduleRequestData $data): Schedule
     {
-        $schedule->update($data->except('components', 'meta')->toArray());
-
-        if ($data->meta !== null) {
-            $schedule->syncMeta($data->meta);
-        }
-
-        if ($data->components) {
-            $components = collect($data->components)
-                ->mapWithKeys(fn (ScheduleComponentRequestData $component) => [
-                    $component->id => ['component_status' => $component->status],
-                ])
-                ->all();
-
-            $schedule->components()->sync($components);
-        }
+        DB::transaction(function () use ($schedule, $data): void {
+            $schedule->update($data->except('components', 'meta')->toArray());
+
+            if (is_array($data->meta)) {
+                $schedule->syncMeta($data->meta);
+            }
+
+            if (is_array($data->components) && $data->components !== []) {
+                $components = collect($data->components)
+                    ->mapWithKeys(fn (ScheduleComponentRequestData $component) => [
+                        $component->id => ['component_status' => $component->status],
+                    ])
+                    ->all();
+
+                $schedule->components()->sync($components);
+            }
+        });
 
         // @todo Dispatch notification that maintenance was updated.
 

diff --git a/src/Actions/Subscriber/CreateSubscriber.php b/src/Actions/Subscriber/CreateSubscriber.php
@@ -3,6 +3,7 @@
 namespace Cachet\Actions\Subscriber;
 
 use Cachet\Models\Subscriber;
+use Illuminate\Support\Facades\DB;
 
 class CreateSubscriber
 {
@@ -11,19 +12,21 @@ class CreateSubscriber
      */
     public function handle(string $email, bool $global = true, array $components = [], bool $verified = false, ?array $meta = null): Subscriber
     {
-        $subscriber = Subscriber::firstOrCreate([
-            'email' => $email,
-        ], [
-            'global' => $global,
-            'email_verified_at' => $verified ? now() : null,
-        ]);
+        return DB::transaction(function () use ($email, $global, $components, $verified, $meta): Subscriber {
+            $subscriber = Subscriber::firstOrCreate([
+                'email' => $email,
+            ], [
+                'global' => $global,
+                'email_verified_at' => $verified ? now() : null,
+            ]);
 
-        $subscriber->components()->attach($components);
+            $subscriber->components()->attach($components);
 
-        if ($meta !== null) {
-            $subscriber->syncMeta($meta);
-        }
+            if ($meta !== null) {
+                $subscriber->syncMeta($meta);
+            }
 
-        return $subscriber;
+            return $subscriber;
+        });
     }
 }
diff --git a/src/Actions/Subscriber/UnsubscribeSubscriber.php b/src/Actions/Subscriber/UnsubscribeSubscriber.php
@@ -3,6 +3,7 @@
 namespace Cachet\Actions\Subscriber;
 
 use Cachet\Models\Subscriber;
+use Illuminate\Support\Facades\DB;
 
 class UnsubscribeSubscriber
 {
@@ -13,8 +14,10 @@ class UnsubscribeSubscriber
      */
     public function handle(Subscriber $subscriber): void
     {
-        $subscriber->components()->detach();
+        DB::transaction(function () use ($subscriber): void {
+            $subscriber->components()->detach();
 
-        $subscriber->delete();
+            $subscriber->delete();
+        });
     }
 }