wip

src/Client.php

@@ -3,6 +3,8 @@
 namespace Spatie\Ray;
 
 use Exception;
+use Spatie\Ray\Exceptions\CouldNotConnectToRay;
+use Spatie\Ray\Exceptions\StopExecutionRequested;
 
 class Client
 {
@@ -43,9 +45,18 @@ public function lockExists(string $lockName): bool
 
             $response = json_decode($curlResult, true);
 
+            if ($response['stop_execution'] ?? false) {
+                throw StopExecutionRequested::make();
+            }
+
             return $response['active'] ?? false;
+
         } catch (Exception $exception) {
-            throw new Exception("Ray seems not be running at {$this->host}:{$this->portNumber}");
+            if ($exception instanceof  StopExecutionRequested) {
+                throw $exception;
+            }
+
+            throw CouldNotConnectToRay::make($this->host, $this->portNumber);
         }
     }
 

src/Exceptions/CouldNotConnectToRay.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Spatie\Ray\Exceptions;
+
+use Exception;
+
+class CouldNotConnectToRay extends Exception
+{
+    public static function make(string $host, int $portNumber): self
+    {
+        return new static("Couldn't connect to Ray It doesn't seem to be running at {$host}:{$portNumber}");
+    }
+}

src/Exceptions/StopExecutionRequested.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Spatie\Ray\Exceptions;
+
+use Exception;
+
+class StopExecutionRequested extends Exception
+{
+    public static function make(): self
+    {
+        return new static("This exception is thrown because you requested to stop the execution in Ray.");
+    }
+}