Implement HTTP client layer and namespace-based client classes

src/AtpClientServiceProvider.php

···
 use Illuminate\Support\ServiceProvider;
 use SocialDept\AtpClient\Auth\ClientMetadataManager;
 use SocialDept\AtpClient\Auth\DPoPKeyManager;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
 use SocialDept\AtpClient\Auth\OAuthEngine;
 use SocialDept\AtpClient\Auth\TokenRefresher;
 use SocialDept\AtpClient\Client\AtpClient;
···
         // Register core services
         $this->app->singleton(ClientMetadataManager::class);
         $this->app->singleton(DPoPKeyManager::class);
+        $this->app->singleton(DPoPNonceManager::class);
         $this->app->singleton(TokenRefresher::class);
         $this->app->singleton(SessionManager::class, function ($app) {
             return new SessionManager(

src/Auth/DPoPNonceManager.php

···
+<?php
+
+namespace SocialDept\AtpClient\Auth;
+
+use Illuminate\Support\Facades\Cache;
+
+class DPoPNonceManager
+{
+    /**
+     * Get DPoP nonce for PDS endpoint
+     */
+    public function getNonce(string $pdsEndpoint): string
+    {
+        $cacheKey = 'dpop_nonce:'.md5($pdsEndpoint);
+
+        // Return cached nonce if available
+        if ($nonce = Cache::get($cacheKey)) {
+            return $nonce;
+        }
+
+        // Fetch new nonce from server
+        $nonce = $this->fetchNonce($pdsEndpoint);
+
+        // Cache for 5 minutes
+        Cache::put($cacheKey, $nonce, now()->addMinutes(5));
+
+        return $nonce;
+    }
+
+    /**
+     * Store nonce returned from server response
+     */
+    public function storeNonce(string $pdsEndpoint, string $nonce): void
+    {
+        $cacheKey = 'dpop_nonce:'.md5($pdsEndpoint);
+        Cache::put($cacheKey, $nonce, now()->addMinutes(5));
+    }
+
+    /**
+     * Clear cached nonce (e.g., after nonce error)
+     */
+    public function clearNonce(string $pdsEndpoint): void
+    {
+        $cacheKey = 'dpop_nonce:'.md5($pdsEndpoint);
+        Cache::forget($cacheKey);
+    }
+
+    /**
+     * Fetch nonce from PDS server
+     */
+    protected function fetchNonce(string $pdsEndpoint): string
+    {
+        // Make a HEAD request to get initial nonce
+        // The server returns nonce in DPoP-Nonce header
+        try {
+            $response = app('http')->head($pdsEndpoint.'/xrpc/_health');
+
+            return $response->header('DPoP-Nonce') ?? 'fallback-nonce-'.time();
+        } catch (\Exception $e) {
+            // Fallback if health endpoint fails
+            return 'fallback-nonce-'.time();
+        }
+    }
+}

src/Client/AtpClient.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client;
+
+use Illuminate\Http\Client\Factory;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
+use SocialDept\AtpClient\Session\SessionManager;
+
+class AtpClient
+{
+    public function __construct(
+        protected SessionManager $sessions,
+        protected Factory $http,
+        protected string $identifier,
+    ) {}
+
+    /**
+     * Get Bluesky client (app.bsky.*)
+     */
+    public function bsky(): BskyClient
+    {
+        return new BskyClient($this->sessions, $this->http, $this->identifier);
+    }
+
+    /**
+     * Get AT Protocol client (com.atproto.*)
+     */
+    public function atproto(): AtprotoClient
+    {
+        return new AtprotoClient($this->sessions, $this->http, $this->identifier);
+    }
+
+    /**
+     * Get Chat client (chat.bsky.*)
+     */
+    public function chat(): ChatClient
+    {
+        return new ChatClient($this->sessions, $this->http, $this->identifier);
+    }
+
+    /**
+     * Get Ozone client (tools.ozone.*)
+     */
+    public function ozone(): OzoneClient
+    {
+        return new OzoneClient($this->sessions, $this->http, $this->identifier);
+    }
+
+    /**
+     * Get the current session identifier
+     */
+    public function getIdentifier(): string
+    {
+        return $this->identifier;
+    }
+
+    /**
+     * Get the session manager
+     */
+    public function getSessionManager(): SessionManager
+    {
+        return $this->sessions;
+    }
+}

src/Client/AtprotoClient.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client;
+
+use Illuminate\Http\Client\Factory;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
+use SocialDept\AtpClient\Http\HasHttp;
+use SocialDept\AtpClient\Http\Response;
+use SocialDept\AtpClient\Session\SessionManager;
+
+class AtprotoClient
+{
+    use HasHttp;
+
+    public function __construct(
+        SessionManager $sessions,
+        Factory $http,
+        string $identifier,
+    ) {
+        $this->sessions = $sessions;
+        $this->http = $http;
+        $this->identifier = $identifier;
+        $this->nonceManager = app(DPoPNonceManager::class);
+    }
+
+    /**
+     * Create a record
+     */
+    public function createRecord(string $repo, string $collection, array $record, ?string $rkey = null, bool $validate = true, ?string $swapCommit = null): Response
+    {
+        return $this->post('com.atproto.repo.createRecord', array_filter(compact('repo', 'collection', 'record', 'rkey', 'validate', 'swapCommit'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Delete a record
+     */
+    public function deleteRecord(string $repo, string $collection, string $rkey, ?string $swapRecord = null, ?string $swapCommit = null): Response
+    {
+        return $this->post('com.atproto.repo.deleteRecord', array_filter(compact('repo', 'collection', 'rkey', 'swapRecord', 'swapCommit'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Put (upsert) a record
+     */
+    public function putRecord(string $repo, string $collection, string $rkey, array $record, bool $validate = true, ?string $swapRecord = null, ?string $swapCommit = null): Response
+    {
+        return $this->post('com.atproto.repo.putRecord', array_filter(compact('repo', 'collection', 'rkey', 'record', 'validate', 'swapRecord', 'swapCommit'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Get a record
+     */
+    public function getRecord(string $repo, string $collection, string $rkey, ?string $cid = null): Response
+    {
+        return $this->get('com.atproto.repo.getRecord', compact('repo', 'collection', 'rkey', 'cid'));
+    }
+
+    /**
+     * List records in a collection
+     */
+    public function listRecords(string $repo, string $collection, int $limit = 50, ?string $cursor = null, bool $reverse = false): Response
+    {
+        return $this->get('com.atproto.repo.listRecords', compact('repo', 'collection', 'limit', 'cursor', 'reverse'));
+    }
+
+    /**
+     * Upload a blob
+     */
+    public function uploadBlob(string $data, string $mimeType): Response
+    {
+        return $this->post('com.atproto.repo.uploadBlob', ['blob' => $data, 'mimeType' => $mimeType]);
+    }
+
+    /**
+     * Describe the repository
+     */
+    public function describeRepo(string $repo): Response
+    {
+        return $this->get('com.atproto.repo.describeRepo', compact('repo'));
+    }
+
+    /**
+     * Get current session
+     */
+    public function getSession(): Response
+    {
+        return $this->get('com.atproto.server.getSession');
+    }
+
+    /**
+     * Describe server
+     */
+    public function describeServer(): Response
+    {
+        return $this->get('com.atproto.server.describeServer');
+    }
+
+    /**
+     * Resolve handle to DID
+     */
+    public function resolveHandle(string $handle): Response
+    {
+        return $this->get('com.atproto.identity.resolveHandle', compact('handle'));
+    }
+
+    /**
+     * Update handle
+     */
+    public function updateHandle(string $handle): Response
+    {
+        return $this->post('com.atproto.identity.updateHandle', compact('handle'));
+    }
+
+    /**
+     * Get blob from sync
+     */
+    public function getBlob(string $did, string $cid): Response
+    {
+        return $this->get('com.atproto.sync.getBlob', compact('did', 'cid'));
+    }
+
+    /**
+     * Get checkout from sync
+     */
+    public function getCheckout(string $did): Response
+    {
+        return $this->get('com.atproto.sync.getCheckout', compact('did'));
+    }
+
+    /**
+     * Get commit path from sync
+     */
+    public function getCommitPath(string $did, ?string $latest = null, ?string $earliest = null): Response
+    {
+        return $this->get('com.atproto.sync.getCommitPath', compact('did', 'latest', 'earliest'));
+    }
+
+    /**
+     * Get repo from sync
+     */
+    public function getRepo(string $did, ?string $since = null): Response
+    {
+        return $this->get('com.atproto.sync.getRepo', compact('did', 'since'));
+    }
+
+    /**
+     * List repos from sync
+     */
+    public function listRepos(int $limit = 500, ?string $cursor = null): Response
+    {
+        return $this->get('com.atproto.sync.listRepos', compact('limit', 'cursor'));
+    }
+}

src/Client/BskyClient.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client;
+
+use Illuminate\Http\Client\Factory;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
+use SocialDept\AtpClient\Http\HasHttp;
+use SocialDept\AtpClient\Http\Response;
+use SocialDept\AtpClient\Session\SessionManager;
+
+class BskyClient
+{
+    use HasHttp;
+
+    public function __construct(
+        SessionManager $sessions,
+        Factory $http,
+        string $identifier,
+    ) {
+        $this->sessions = $sessions;
+        $this->http = $http;
+        $this->identifier = $identifier;
+        $this->nonceManager = app(DPoPNonceManager::class);
+    }
+
+    /**
+     * Get timeline feed
+     */
+    public function getTimeline(int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('app.bsky.feed.getTimeline', compact('limit', 'cursor'));
+    }
+
+    /**
+     * Get author feed
+     */
+    public function getAuthorFeed(string $actor, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('app.bsky.feed.getAuthorFeed', compact('actor', 'limit', 'cursor'));
+    }
+
+    /**
+     * Get post thread
+     */
+    public function getPostThread(string $uri, int $depth = 6): Response
+    {
+        return $this->get('app.bsky.feed.getPostThread', compact('uri', 'depth'));
+    }
+
+    /**
+     * Get actor profile
+     */
+    public function getProfile(string $actor): Response
+    {
+        return $this->get('app.bsky.actor.getProfile', compact('actor'));
+    }
+
+    /**
+     * Search posts
+     */
+    public function searchPosts(string $q, int $limit = 25, ?string $cursor = null): Response
+    {
+        return $this->get('app.bsky.feed.searchPosts', compact('q', 'limit', 'cursor'));
+    }
+
+    /**
+     * Get likes for a post
+     */
+    public function getLikes(string $uri, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('app.bsky.feed.getLikes', compact('uri', 'limit', 'cursor'));
+    }
+
+    /**
+     * Get reposts for a post
+     */
+    public function getRepostedBy(string $uri, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('app.bsky.feed.getRepostedBy', compact('uri', 'limit', 'cursor'));
+    }
+}

src/Client/ChatClient.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client;
+
+use Illuminate\Http\Client\Factory;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
+use SocialDept\AtpClient\Http\HasHttp;
+use SocialDept\AtpClient\Http\Response;
+use SocialDept\AtpClient\Session\SessionManager;
+
+class ChatClient
+{
+    use HasHttp;
+
+    public function __construct(
+        SessionManager $sessions,
+        Factory $http,
+        string $identifier,
+    ) {
+        $this->sessions = $sessions;
+        $this->http = $http;
+        $this->identifier = $identifier;
+        $this->nonceManager = app(DPoPNonceManager::class);
+    }
+
+    /**
+     * Get conversation
+     */
+    public function getConvo(string $convoId): Response
+    {
+        return $this->get('chat.bsky.convo.getConvo', compact('convoId'));
+    }
+
+    /**
+     * Get conversation for members
+     */
+    public function getConvoForMembers(array $members): Response
+    {
+        return $this->get('chat.bsky.convo.getConvoForMembers', compact('members'));
+    }
+
+    /**
+     * List conversations
+     */
+    public function listConvos(int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('chat.bsky.convo.listConvos', compact('limit', 'cursor'));
+    }
+
+    /**
+     * Get messages
+     */
+    public function getMessages(string $convoId, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('chat.bsky.convo.getMessages', compact('convoId', 'limit', 'cursor'));
+    }
+
+    /**
+     * Send message
+     */
+    public function sendMessage(string $convoId, array $message): Response
+    {
+        return $this->post('chat.bsky.convo.sendMessage', compact('convoId', 'message'));
+    }
+
+    /**
+     * Send message batch
+     */
+    public function sendMessageBatch(array $items): Response
+    {
+        return $this->post('chat.bsky.convo.sendMessageBatch', compact('items'));
+    }
+
+    /**
+     * Delete message
+     */
+    public function deleteMessageForSelf(string $convoId, string $messageId): Response
+    {
+        return $this->post('chat.bsky.convo.deleteMessageForSelf', compact('convoId', 'messageId'));
+    }
+
+    /**
+     * Update read status
+     */
+    public function updateRead(string $convoId, ?string $messageId = null): Response
+    {
+        return $this->post('chat.bsky.convo.updateRead', compact('convoId', 'messageId'));
+    }
+
+    /**
+     * Mute conversation
+     */
+    public function muteConvo(string $convoId): Response
+    {
+        return $this->post('chat.bsky.convo.muteConvo', compact('convoId'));
+    }
+
+    /**
+     * Unmute conversation
+     */
+    public function unmuteConvo(string $convoId): Response
+    {
+        return $this->post('chat.bsky.convo.unmuteConvo', compact('convoId'));
+    }
+
+    /**
+     * Leave conversation
+     */
+    public function leaveConvo(string $convoId): Response
+    {
+        return $this->post('chat.bsky.convo.leaveConvo', compact('convoId'));
+    }
+
+    /**
+     * Get log
+     */
+    public function getLog(?string $cursor = null): Response
+    {
+        return $this->get('chat.bsky.convo.getLog', compact('cursor'));
+    }
+
+    /**
+     * Get actor metadata
+     */
+    public function getActorMetadata(): Response
+    {
+        return $this->get('chat.bsky.actor.getActorMetadata');
+    }
+
+    /**
+     * Export account data
+     */
+    public function exportAccountData(): Response
+    {
+        return $this->get('chat.bsky.actor.exportAccountData');
+    }
+
+    /**
+     * Delete account
+     */
+    public function deleteAccount(): Response
+    {
+        return $this->post('chat.bsky.actor.deleteAccount');
+    }
+}

src/Client/OzoneClient.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client;
+
+use Illuminate\Http\Client\Factory;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
+use SocialDept\AtpClient\Http\HasHttp;
+use SocialDept\AtpClient\Http\Response;
+use SocialDept\AtpClient\Session\SessionManager;
+
+class OzoneClient
+{
+    use HasHttp;
+
+    public function __construct(
+        SessionManager $sessions,
+        Factory $http,
+        string $identifier,
+    ) {
+        $this->sessions = $sessions;
+        $this->http = $http;
+        $this->identifier = $identifier;
+        $this->nonceManager = app(DPoPNonceManager::class);
+    }
+
+    /**
+     * Get moderation event
+     */
+    public function getModerationEvent(int $id): Response
+    {
+        return $this->get('tools.ozone.moderation.getEvent', compact('id'));
+    }
+
+    /**
+     * Get moderation events
+     */
+    public function getModerationEvents(?string $subject = null, ?array $types = null, ?string $createdBy = null, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('tools.ozone.moderation.getEvents', array_filter(compact('subject', 'types', 'createdBy', 'limit', 'cursor'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Get record
+     */
+    public function getRecord(string $uri, ?string $cid = null): Response
+    {
+        return $this->get('tools.ozone.moderation.getRecord', compact('uri', 'cid'));
+    }
+
+    /**
+     * Get repo
+     */
+    public function getRepo(string $did): Response
+    {
+        return $this->get('tools.ozone.moderation.getRepo', compact('did'));
+    }
+
+    /**
+     * Query events
+     */
+    public function queryEvents(?array $types = null, ?string $createdBy = null, ?string $subject = null, int $limit = 50, ?string $cursor = null, bool $sortDirection = false): Response
+    {
+        return $this->get('tools.ozone.moderation.queryEvents', array_filter(compact('types', 'createdBy', 'subject', 'limit', 'cursor', 'sortDirection'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Query statuses
+     */
+    public function queryStatuses(?string $subject = null, ?array $tags = null, ?string $excludeTags = null, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('tools.ozone.moderation.queryStatuses', array_filter(compact('subject', 'tags', 'excludeTags', 'limit', 'cursor'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Search repos
+     */
+    public function searchRepos(?string $term = null, ?string $invitedBy = null, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('tools.ozone.moderation.searchRepos', array_filter(compact('term', 'invitedBy', 'limit', 'cursor'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Emit moderation event
+     */
+    public function emitEvent(array $event, string $subject, array $subjectBlobCids = [], ?string $createdBy = null): Response
+    {
+        return $this->post('tools.ozone.moderation.emitEvent', compact('event', 'subject', 'subjectBlobCids', 'createdBy'));
+    }
+
+    /**
+     * Get blob
+     */
+    public function getBlob(string $did, string $cid): Response
+    {
+        return $this->get('tools.ozone.server.getBlob', compact('did', 'cid'));
+    }
+
+    /**
+     * Get config
+     */
+    public function getConfig(): Response
+    {
+        return $this->get('tools.ozone.server.getConfig');
+    }
+
+    /**
+     * Get team member
+     */
+    public function getTeamMember(string $did): Response
+    {
+        return $this->get('tools.ozone.team.getMember', compact('did'));
+    }
+
+    /**
+     * List team members
+     */
+    public function listTeamMembers(int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->get('tools.ozone.team.listMembers', compact('limit', 'cursor'));
+    }
+
+    /**
+     * Add team member
+     */
+    public function addTeamMember(string $did, string $role): Response
+    {
+        return $this->post('tools.ozone.team.addMember', compact('did', 'role'));
+    }
+
+    /**
+     * Update team member
+     */
+    public function updateTeamMember(string $did, ?bool $disabled = null, ?string $role = null): Response
+    {
+        return $this->post('tools.ozone.team.updateMember', array_filter(compact('did', 'disabled', 'role'), fn ($v) => ! is_null($v)));
+    }
+
+    /**
+     * Delete team member
+     */
+    public function deleteTeamMember(string $did): Response
+    {
+        return $this->post('tools.ozone.team.deleteMember', compact('did'));
+    }
+}

src/Exceptions/ValidationException.php

···
+<?php
+
+namespace SocialDept\AtpClient\Exceptions;
+
+class ValidationException extends \Exception
+{
+    public function __construct(
+        public readonly array $errors,
+        string $message = 'Response validation failed',
+        int $code = 0,
+        ?\Throwable $previous = null
+    ) {
+        parent::__construct($message, $code, $previous);
+    }
+
+    /**
+     * Get validation errors
+     */
+    public function getErrors(): array
+    {
+        return $this->errors;
+    }
+}

src/Http/HasHttp.php

···
+<?php
+
+namespace SocialDept\AtpClient\Http;
+
+use Illuminate\Http\Client\Factory;
+use Illuminate\Http\Client\Response as LaravelResponse;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
+use SocialDept\AtpClient\Exceptions\ValidationException;
+use SocialDept\AtpClient\Session\SessionManager;
+use SocialDept\Schema\Facades\Schema;
+
+trait HasHttp
+{
+    protected SessionManager $sessions;
+
+    protected Factory $http;
+
+    protected string $identifier;
+
+    protected DPoPNonceManager $nonceManager;
+
+    /**
+     * Make XRPC call
+     */
+    protected function call(
+        string $nsid,
+        string $method,
+        ?array $params = null,
+        ?array $body = null
+    ): Response {
+        // Ensure session is valid (auto-refresh)
+        $session = $this->sessions->ensureValid($this->identifier);
+
+        // Build URL
+        $url = rtrim($session->pdsEndpoint(), '/').'/xrpc/'.$nsid;
+
+        // Get DPoP nonce
+        $nonce = $this->nonceManager->getNonce($session->pdsEndpoint());
+
+        // Create DPoP proof using DPoPKeyManager
+        $dpopProof = app(\SocialDept\AtpClient\Auth\DPoPKeyManager::class)->createProof(
+            key: $session->dpopKey(),
+            method: $method,
+            url: $url,
+            nonce: $nonce,
+            accessToken: $session->accessToken(),
+        );
+
+        // Filter null parameters
+        $params = array_filter($params ?? [], fn ($v) => ! is_null($v));
+
+        // Build request
+        $request = $this->http
+            ->withHeaders([
+                'Authorization' => 'Bearer '.$session->accessToken(),
+                'DPoP' => $dpopProof,
+            ]);
+
+        // Send request
+        $response = match ($method) {
+            'GET' => $request->get($url, $params),
+            'POST' => $request->post($url, $body ?? $params),
+            'DELETE' => $request->delete($url, $params),
+            default => throw new \InvalidArgumentException("Unsupported method: {$method}"),
+        };
+
+        // Store nonce from response if present
+        if ($newNonce = $response->header('DPoP-Nonce')) {
+            $this->nonceManager->storeNonce($session->pdsEndpoint(), $newNonce);
+        }
+
+        // Validate response if schema exists
+        if (Schema::exists($nsid)) {
+            $this->validateResponse($nsid, $response);
+        }
+
+        return new Response($response);
+    }
+
+    /**
+     * Validate response against schema
+     */
+    protected function validateResponse(string $nsid, LaravelResponse $response): void
+    {
+        if (! $response->successful()) {
+            return; // Don't validate error responses
+        }
+
+        $data = $response->json();
+
+        if (! Schema::validate($nsid, $data)) {
+            $errors = Schema::getErrors($nsid, $data);
+            throw new ValidationException($errors);
+        }
+    }
+
+    /**
+     * Make GET request
+     */
+    protected function get(string $nsid, array $params = []): Response
+    {
+        return $this->call($nsid, 'GET', $params);
+    }
+
+    /**
+     * Make POST request
+     */
+    protected function post(string $nsid, array $body = []): Response
+    {
+        return $this->call($nsid, 'POST', null, $body);
+    }
+
+    /**
+     * Make DELETE request
+     */
+    protected function delete(string $nsid, array $params = []): Response
+    {
+        return $this->call($nsid, 'DELETE', $params);
+    }
+}

src/Http/Response.php

···
+<?php
+
+namespace SocialDept\AtpClient\Http;
+
+use Illuminate\Http\Client\Response as LaravelResponse;
+use Illuminate\Support\Collection;
+
+class Response
+{
+    public function __construct(
+        protected LaravelResponse $response
+    ) {}
+
+    /**
+     * Get JSON response data
+     */
+    public function json(?string $key = null, mixed $default = null): mixed
+    {
+        return $this->response->json($key, $default);
+    }
+
+    /**
+     * Get response as collection
+     */
+    public function collect(?string $key = null): Collection
+    {
+        return $this->response->collect($key);
+    }
+
+    /**
+     * Get HTTP status code
+     */
+    public function status(): int
+    {
+        return $this->response->status();
+    }
+
+    /**
+     * Check if response was successful
+     */
+    public function successful(): bool
+    {
+        return $this->response->successful();
+    }
+
+    /**
+     * Check if response failed
+     */
+    public function failed(): bool
+    {
+        return $this->response->failed();
+    }
+
+    /**
+     * Get response body
+     */
+    public function body(): string
+    {
+        return $this->response->body();
+    }
+
+    /**
+     * Convert to array
+     */
+    public function toArray(): array
+    {
+        return $this->response->json();
+    }
+
+    /**
+     * Get underlying Laravel response
+     */
+    public function getResponse(): LaravelResponse
+    {
+        return $this->response;
+    }
+}