dont throw errors on 404

Author: Niek Brekelmans

src/HetznerDnsClient.php

@@ -2,17 +2,17 @@
 
 namespace DutchCodingCompany\HetznerDnsClient;
 
+use DutchCodingCompany\HetznerDnsClient\Traits\ThrowsOnErrorsExceptNotFound;
 use Sammyjo20\Saloon\Http\SaloonConnector;
 use Sammyjo20\Saloon\Traits\Plugins\AcceptsJson;
-use Sammyjo20\Saloon\Traits\Plugins\AlwaysThrowsOnErrors;
 
 /**
  * @method RequestCollections\ZoneCollection zones()
  * @method RequestCollections\RecordCollection records()
  */
 class HetznerDnsClient extends SaloonConnector
 {
-    use AcceptsJson, AlwaysThrowsOnErrors;
+    use AcceptsJson, ThrowsOnErrorsExceptNotFound;
     use Traits\ResolvesApiToken;
 
     protected array $requests = [

src/RequestCollections/RecordCollection.php

@@ -18,7 +18,7 @@
 
 class RecordCollection extends RequestCollection
 {
-    public function all(?int $page = null, ?int $per_page = null, ?string $zone_id = null): Records
+    public function all(?int $page = null, ?int $per_page = null, ?string $zone_id = null): ?Records
     {
         return $this->connector->request(new ListRecords(page: $page, per_page: $per_page, zone_id: $zone_id))->send()->dto();
     }
@@ -28,6 +28,21 @@ public function create(string $zone_id, RecordType $type, string $name, string $
         return $this->connector->request(new CreateRecord(zone_id: $zone_id, type: $type, name: $name, value: $value, ttl: $ttl))->send()->dto();
     }
 
+    public function createIfNotExists(string $zone_id, RecordType $type, string $name, string $value, ?int $ttl = null): Record
+    {
+        $records = $this->all(zone_id: $zone_id);
+        $record = collect($records->records)
+            ->where('name', $name)
+            ->filter(fn (Record $record) => $record->type->value === $type->value)
+            ->first();
+
+        if (! is_null($record)) {
+            return $record; // already exists
+        }
+
+        return $this->create($zone_id, $type, $name, $value, $ttl);
+    }
+
     public function get(string $record_id): Record
     {
         return $this->connector->request(new GetRecord(record_id: $record_id))->send()->dto();

src/RequestCollections/ZoneCollection.php

@@ -14,7 +14,7 @@
 
 class ZoneCollection extends RequestCollection
 {
-    public function all(string $name = null,?int $per_page = null, ?string $search_name = null): Zones
+    public function all(string $name = null,?int $per_page = null, ?string $search_name = null): ?Zones
     {
         return $this->connector->request(new ListZones(name: $name, per_page: $per_page, search_name: $search_name))->send()->dto();
     }
@@ -24,11 +24,19 @@ public function create(string $name, ?int $ttl = null): Zone
         return $this->connector->request(new CreateZone(name: $name, ttl: $ttl))->send()->dto();
     }
 
-    public function get(string $zone_id): Zone
+    public function get(string $zone_id): ?Zone
     {
         return $this->connector->request(new GetZone(zone_id: $zone_id))->send()->dto();
     }
 
+    public function getByName(string $name): ?Zone
+    {
+        $zones = $this->all(name: $name);
+
+        /** @var Zone $zone */
+        return collect($zones?->zones)->where('name', $name)->first();
+    }
+
     public function update(string $zone_id, string $name, ?int $ttl = null): Zone
     {
         return $this->connector->request(new UpdateZone(zone_id: $zone_id, name: $name, ttl: $ttl))->send()->dto();

src/Requests/Records/CreateRecord.php

@@ -22,8 +22,7 @@ public function __construct(
         protected string $name,
         protected string $value,
         protected ?int $ttl = null,
-    )
-    {}
+    ) {}
 
     protected ?string $connector = HetznerDnsClient::class;
 

src/Requests/Records/UpdateRecord.php

@@ -24,8 +24,7 @@ public function __construct(
         protected string $name,
         protected string $value,
         protected ?int $ttl = null,
-    )
-    {}
+    ) {}
 
     protected ?string $connector = HetznerDnsClient::class;
 

src/Traits/ThrowsOnErrorsExceptNotFound.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace DutchCodingCompany\HetznerDnsClient\Traits;
+
+use Sammyjo20\Saloon\Http\SaloonRequest;
+use Sammyjo20\Saloon\Http\SaloonResponse;
+use Sammyjo20\Saloon\Traits\Plugins\AlwaysThrowsOnErrors;
+
+trait ThrowsOnErrorsExceptNotFound
+{
+    /**
+     * Always throw if there is something wrong with the request.
+     *
+     * @param SaloonRequest $request
+     * @return void
+     * @throws \Sammyjo20\Saloon\Exceptions\SaloonInvalidConnectorException
+     */
+    public function bootThrowsOnErrorsExceptNotFound(SaloonRequest $request): void
+    {
+        if ($this instanceof SaloonRequest && $this->traitExistsOnConnector(ThrowsOnErrorsExceptNotFound::class)) {
+            return;
+        }
+
+        $this->addResponseInterceptor(function (SaloonRequest $request, SaloonResponse $response) {
+            if($response->status() !== 404) {
+                $response->throw();
+            }
+
+            return $response;
+        });
+    }
+}