Added: Model update and find methods

Author: KroderDev

CHANGELOG.md

@@ -12,6 +12,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Error propagation improvements with tests for all status codes.
 - Introduced `ParsesApiResponse` trait to centralize API response parsing logic.
 - Configurable HTTP methods for model updates and deletions.
+- `updateById`, instance `update`, `updateOrFail`, and `findOrFail` for remote models.
 
 ### Changed
 - Refactored `QueryBuilder` and `ApiModel` to use the new `ParsesApiResponse` trait, removing duplicate `parseResponse` implementations.

src/Models/Model.php

@@ -3,6 +3,7 @@
 namespace Kroderdev\LaravelMicroserviceCore\Models;
 
 use Illuminate\Database\Eloquent\Model as BaseModel;
+use Illuminate\Database\Eloquent\ModelNotFoundException;
 use Illuminate\Pagination\LengthAwarePaginator;
 use Illuminate\Support\Collection;
 use Illuminate\Support\Str;
@@ -79,6 +80,18 @@ public static function find($id, $columns = ['*']): ?self
         return static::fromResponse($data);
     }
 
+    /**
+     * Find a model by its primary key or throw an exception.
+     */
+    public static function findOrFail($id, $columns = ['*']): self
+    {
+        if ($model = static::find($id, $columns)) {
+            return $model;
+        }
+
+        throw (new ModelNotFoundException())->setModel(static::class, [$id]);
+    }
+
     /**
      * Paginate models from the API.
      */
@@ -103,6 +116,75 @@ public static function create(array $attributes = []): ?self
         return static::fromResponse($data);
     }
 
+    /**
+     * Update a model via the API.
+     *
+     * @param int|string $id The ID of the model to update.
+     * @param array $attributes The attributes to update.
+     * @return bool
+     */
+    public static function updateById($id, array $attributes): bool
+    {
+        $method = strtolower(config('microservice.models.update_method', 'put'));
+        $response = static::client()->{$method}(static::endpoint().'/'.$id, $attributes);
+
+        if (is_object($response) && method_exists($response, 'successful')) {
+            return $response->successful();
+        }
+
+        return true;
+    }
+
+    /**
+     * Update the model via the API.
+     */
+    public function update(array $attributes = [], array $options = []): bool
+    {
+        if (! $this->exists) {
+            return false;
+        }
+
+        $this->fill($attributes);
+
+        $method = strtolower(config('microservice.models.update_method', 'put'));
+        $response = static::client()->{$method}(static::endpoint().'/'.$this->getKey(), $this->attributesToArray());
+
+        $data = static::parseResponse($response);
+        if ($fresh = static::fromResponse($data)) {
+            $this->fill($fresh->attributesToArray());
+            $this->syncOriginal();
+        }
+
+        return true;
+    }
+
+    /**
+     * Update the model via the API, throwing an exception on failure.
+     */
+    public function updateOrFail(array $attributes = [], array $options = []): bool
+    {
+        if (! $this->exists) {
+            return false;
+        }
+
+        $this->fill($attributes);
+
+        $method = strtolower(config('microservice.models.update_method', 'put'));
+        $response = static::client()->{$method}(static::endpoint().'/'.$this->getKey(), $this->attributesToArray());
+
+        if (is_object($response) && method_exists($response, 'successful') && ! $response->successful()) {
+            throw new \RuntimeException('Update failed.');
+        }
+
+        $data = static::parseResponse($response);
+        if ($fresh = static::fromResponse($data)) {
+            $this->fill($fresh->attributesToArray());
+            $this->syncOriginal();
+        }
+
+        return true;
+    }
+
     /**
      * Save the model via the API.
      */

tests/Models/ApiModelTest.php

@@ -238,6 +238,83 @@ public function delete_users_respects_configured_method()
         ], $this->gateway->getCalls());
     }
 
+    /** @test */
+    public function static_update_users_gateway()
+    {
+        $this->gateway = new class () extends FakeGatewayClient {
+            public function put(string $uri, array $data = [])
+            {
+                parent::put($uri, $data);
+
+                return collect();
+            }
+        };
+        $this->app->bind(ApiGatewayClientInterface::class, fn () => $this->gateway);
+
+        RemoteUser::updateById(10, ['name' => 'Updated']);
+
+        $this->assertSame([
+            ['method' => 'PUT', 'uri' => '/users/10', 'data' => ['name' => 'Updated']],
+        ], $this->gateway->getCalls());
+    }
+
+    /** @test */
+    public function instance_update_users_gateway()
+    {
+        $user = new RemoteUser(['id' => 11, 'name' => 'Old']);
+        $user->exists = true;
+
+        $user->update(['name' => 'New']);
+
+        $this->assertSame([
+            ['method' => 'PUT', 'uri' => '/users/11', 'data' => ['id' => 11, 'name' => 'New']],
+        ], $this->gateway->getCalls());
+    }
+
+    /** @test */
+    public function find_or_fail_throws_when_not_found()
+    {
+        $this->gateway = new class () extends FakeGatewayClient {
+            public function get(string $uri, array $query = [])
+            {
+                parent::get($uri, $query);
+
+                return null;
+            }
+        };
+        $this->app->bind(ApiGatewayClientInterface::class, fn () => $this->gateway);
+
+        $this->expectException(\Illuminate\Database\Eloquent\ModelNotFoundException::class);
+
+        RemoteUser::findOrFail(999);
+    }
+
+    /** @test */
+    public function update_or_fail_throws_on_failure()
+    {
+        $this->gateway = new class () extends FakeGatewayClient {
+            public function put(string $uri, array $data = [])
+            {
+                parent::put($uri, $data);
+
+                return new class () {
+                    public function successful()
+                    {
+                        return false;
+                    }
+                };
+            }
+        };
+        $this->app->bind(ApiGatewayClientInterface::class, fn () => $this->gateway);
+
+        $user = new RemoteUser(['id' => 13, 'name' => 'Old']);
+        $user->exists = true;
+
+        $this->expectException(\RuntimeException::class);
+
+        $user->updateOrFail(['name' => 'Fail']);
+    }
+    
     /** @test */
     public function where_get_filters_results()
     {