added calls to notification endpoints

Author: SniperSister

app/Jobs/UpdateSite.php

@@ -110,6 +110,9 @@ public function handle(): void
                 "Status code has changed after update for site: " . $this->site->id
             );
         }
+
+        // Notify users
+        $connection->notificationSuccess(["fromVersion" => $healthResult->cms_version]);
     }
 
     protected function performExtraction(PrepareUpdate $prepareResult): void
@@ -166,6 +169,12 @@ protected function performExtraction(PrepareUpdate $prepareResult): void
 
     public function failed(\Exception $exception): void
     {
+        /** @var Connection $connection */
+        $connection = $this->site->connection;
+
+        // Notify users
+        $connection->notificationFailed(["fromVersion" => $this->site->cms_version]);
+
         // We log any issues during the update to the DB
         $this->site->updates()->create([
             'old_version' => $this->site->cms_version,

app/RemoteSite/Connection.php

@@ -9,6 +9,7 @@
 use App\RemoteSite\Responses\GetUpdate as GetUpdateResponse;
 use App\RemoteSite\Responses\HealthCheck as HealthCheckResponse;
 use App\RemoteSite\Responses\PrepareUpdate as PrepareUpdateResponse;
+use App\RemoteSite\Responses\Notification as NotificationResponse;
 use App\RemoteSite\Responses\ResponseInterface;
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\RequestException;
@@ -22,6 +23,8 @@
  * @method  GetUpdateResponse getUpdate()
  * @method  PrepareUpdateResponse prepareUpdate(array<string,string> $data)
  * @method  FinalizeUpdateResponse finalizeUpdate(array<string,string> $data)
+ * @method  NotificationResponse notificationSuccess(array<string,string> $data)
+ * @method  NotificationResponse notificationFailed(array<string,string> $data)
  */
 class Connection
 {

app/RemoteSite/Responses/Notification.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace App\RemoteSite\Responses;
+
+use App\DTO\BaseDTO;
+
+class Notification extends BaseDTO implements ResponseInterface
+{
+    public function __construct(
+        public bool $success
+    ) {
+    }
+}

app/RemoteSite/WebserviceEndpoint.php

@@ -7,13 +7,16 @@
 use App\RemoteSite\Responses\GetUpdate;
 use App\RemoteSite\Responses\HealthCheck;
 use App\RemoteSite\Responses\PrepareUpdate;
+use App\RemoteSite\Responses\Notification;
 
 enum WebserviceEndpoint: string
 {
     case checkHealth = "/api/index.php/v1/joomlaupdate/healthcheck";
     case getUpdate = "/api/index.php/v1/joomlaupdate/getUpdate";
     case prepareUpdate = "/api/index.php/v1/joomlaupdate/prepareUpdate";
     case finalizeUpdate = "/api/index.php/v1/joomlaupdate/finalizeUpdate";
+    case notificationSuccess = "/api/index.php/v1/joomlaupdate/notificationSuccess";
+    case notificationFailed = "/api/index.php/v1/joomlaupdate/notificationFailed";
 
     public function getMethod(): HttpMethod
     {
@@ -25,6 +28,8 @@ public function getMethod(): HttpMethod
                 // no break
             case self::prepareUpdate->name:
             case self::finalizeUpdate->name:
+            case self::notificationSuccess->name:
+            case self::notificationFailed->name:
                 return HttpMethod::POST;
         }
 
@@ -42,6 +47,9 @@ public function getResponseClass(): string
                 return PrepareUpdate::class;
             case self::finalizeUpdate->name:
                 return FinalizeUpdate::class;
+            case self::notificationSuccess->name:
+            case self::notificationFailed->name:
+                return Notification::class;
         }
     }