Restructure client architecture with namespace-based NSID partials

src/AtpClient.php

···
 
 namespace SocialDept\AtpClient;
 
+use Illuminate\Http\Client\Factory;
+use SocialDept\AtpClient\Client\Client;
+use SocialDept\AtpClient\Client\AtprotoClient;
+use SocialDept\AtpClient\Client\BskyClient;
+use SocialDept\AtpClient\Client\ChatClient;
+use SocialDept\AtpClient\Client\OzoneClient;
+use SocialDept\AtpClient\Session\SessionManager;
+
 class AtpClient
 {
-    // Build wonderful things
-}
+    /**
+     * Raw API communication/networking class
+     */
+    public Client $client;
+
+    /**
+     * Collection of Bluesky (app.bsky.*) related functions
+     */
+    public BskyClient $bsky;
+
+    /**
+     * Collection of AT Protocol (com.atproto.*) related functions
+     */
+    public AtprotoClient $atproto;
+
+    /**
+     * Collection of Chat (chat.bsky.*) related functions
+     */
+    public ChatClient $chat;
+
+    /**
+     * Collection of Ozone (tools.ozone.*) related functions
+     */
+    public OzoneClient $ozone;
+
+    public function __construct(
+        SessionManager $sessions,
+        Factory $http,
+        string $identifier,
+    ) {
+        // Load the network client
+        $this->client = new Client($this, $sessions, $http, $identifier);
+
+        // Load all function collections
+        $this->bsky = new BskyClient($this);
+        $this->atproto = new AtprotoClient($this);
+        $this->chat = new ChatClient($this);
+        $this->ozone = new OzoneClient($this);
+    }
+}

src/AtpClientServiceProvider.php

···
 use SocialDept\AtpClient\Auth\DPoPNonceManager;
 use SocialDept\AtpClient\Auth\OAuthEngine;
 use SocialDept\AtpClient\Auth\TokenRefresher;
-use SocialDept\AtpClient\Client\AtpClient;
 use SocialDept\AtpClient\Contracts\CredentialProvider;
 use SocialDept\AtpClient\Contracts\KeyStore;
 use SocialDept\AtpClient\Providers\ArrayCredentialProvider;

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

···
 
 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;
+use SocialDept\AtpClient\AtpClient;
+use SocialDept\AtpClient\Client\Requests\Atproto;
 
 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
+     * The parent AtpClient instance
      */
-    public function getSession(): Response
-    {
-        return $this->get('com.atproto.server.getSession');
-    }
+    public AtpClient $atp;
 
     /**
-     * Describe server
+     * Repository operations (com.atproto.repo.*)
      */
-    public function describeServer(): Response
-    {
-        return $this->get('com.atproto.server.describeServer');
-    }
+    public Atproto\Repo $repo;
 
     /**
-     * Resolve handle to DID
+     * Server operations (com.atproto.server.*)
      */
-    public function resolveHandle(string $handle): Response
-    {
-        return $this->get('com.atproto.identity.resolveHandle', compact('handle'));
-    }
+    public Atproto\Server $server;
 
     /**
-     * Update handle
+     * Identity operations (com.atproto.identity.*)
      */
-    public function updateHandle(string $handle): Response
-    {
-        return $this->post('com.atproto.identity.updateHandle', compact('handle'));
-    }
+    public Atproto\Identity $identity;
 
     /**
-     * Get blob from sync
+     * Sync operations (com.atproto.sync.*)
      */
-    public function getBlob(string $did, string $cid): Response
-    {
-        return $this->get('com.atproto.sync.getBlob', compact('did', 'cid'));
-    }
+    public Atproto\Sync $sync;
 
-    /**
-     * 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
+    public function __construct(AtpClient $parent)
     {
-        return $this->get('com.atproto.sync.listRepos', compact('limit', 'cursor'));
+        $this->atp = $parent;
+        $this->repo = new Atproto\Repo($this);
+        $this->server = new Atproto\Server($this);
+        $this->identity = new Atproto\Identity($this);
+        $this->sync = new Atproto\Sync($this);
     }
 }

src/Client/BskyClient.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;
+use SocialDept\AtpClient\AtpClient;
+use SocialDept\AtpClient\Client\Requests\Bsky;
 
 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
+     * The parent AtpClient instance
      */
-    public function getPostThread(string $uri, int $depth = 6): Response
-    {
-        return $this->get('app.bsky.feed.getPostThread', compact('uri', 'depth'));
-    }
+    public AtpClient $atp;
 
     /**
-     * Get actor profile
+     * Feed operations (app.bsky.feed.*)
      */
-    public function getProfile(string $actor): Response
-    {
-        return $this->get('app.bsky.actor.getProfile', compact('actor'));
-    }
+    public Bsky\Feed $feed;
 
     /**
-     * Search posts
+     * Actor operations (app.bsky.actor.*)
      */
-    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'));
-    }
+    public Bsky\Actor $actor;
 
-    /**
-     * Get reposts for a post
-     */
-    public function getRepostedBy(string $uri, int $limit = 50, ?string $cursor = null): Response
+    public function __construct(AtpClient $parent)
     {
-        return $this->get('app.bsky.feed.getRepostedBy', compact('uri', 'limit', 'cursor'));
+        $this->atp = $parent;
+        $this->feed = new Bsky\Feed($this);
+        $this->actor = new Bsky\Actor($this);
     }
 }

src/Client/ChatClient.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;
+use SocialDept\AtpClient\AtpClient;
+use SocialDept\AtpClient\Client\Requests\Chat;
 
 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
+     * The parent AtpClient instance
      */
-    public function deleteMessageForSelf(string $convoId, string $messageId): Response
-    {
-        return $this->post('chat.bsky.convo.deleteMessageForSelf', compact('convoId', 'messageId'));
-    }
+    public AtpClient $atp;
 
     /**
-     * Update read status
+     * Conversation operations (chat.bsky.convo.*)
      */
-    public function updateRead(string $convoId, ?string $messageId = null): Response
-    {
-        return $this->post('chat.bsky.convo.updateRead', compact('convoId', 'messageId'));
-    }
+    public Chat\Convo $convo;
 
     /**
-     * Mute conversation
+     * Actor operations (chat.bsky.actor.*)
      */
-    public function muteConvo(string $convoId): Response
-    {
-        return $this->post('chat.bsky.convo.muteConvo', compact('convoId'));
-    }
+    public Chat\Actor $actor;
 
-    /**
-     * Unmute conversation
-     */
-    public function unmuteConvo(string $convoId): Response
+    public function __construct(AtpClient $parent)
     {
-        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');
+        $this->atp = $parent;
+        $this->convo = new Chat\Convo($this);
+        $this->actor = new Chat\Actor($this);
     }
 }

src/Client/Client.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client;
+
+use Illuminate\Http\Client\Factory;
+use SocialDept\AtpClient\AtpClient;
+use SocialDept\AtpClient\Auth\DPoPNonceManager;
+use SocialDept\AtpClient\Http\HasHttp;
+use SocialDept\AtpClient\Session\SessionManager;
+
+class Client
+{
+    use HasHttp;
+
+    /**
+     * The parent AtpClient instance we belong to
+     */
+    public AtpClient $atp;
+
+    public function __construct(
+        AtpClient $parent,
+        SessionManager $sessions,
+        Factory $http,
+        string $identifier,
+    ) {
+        $this->atp = $parent;
+        $this->sessions = $sessions;
+        $this->http = $http;
+        $this->identifier = $identifier;
+        $this->nonceManager = app(DPoPNonceManager::class);
+    }
+}

src/Client/OzoneClient.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;
+use SocialDept\AtpClient\AtpClient;
+use SocialDept\AtpClient\Client\Requests\Ozone;
 
 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
+     * The parent AtpClient instance
      */
-    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)));
-    }
+    public AtpClient $atp;
 
     /**
-     * Emit moderation event
+     * Moderation operations (tools.ozone.moderation.*)
      */
-    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'));
-    }
+    public Ozone\Moderation $moderation;
 
     /**
-     * Get blob
+     * Server operations (tools.ozone.server.*)
      */
-    public function getBlob(string $did, string $cid): Response
-    {
-        return $this->get('tools.ozone.server.getBlob', compact('did', 'cid'));
-    }
+    public Ozone\Server $server;
 
     /**
-     * Get config
+     * Team operations (tools.ozone.team.*)
      */
-    public function getConfig(): Response
-    {
-        return $this->get('tools.ozone.server.getConfig');
-    }
+    public Ozone\Team $team;
 
-    /**
-     * Get team member
-     */
-    public function getTeamMember(string $did): Response
+    public function __construct(AtpClient $parent)
     {
-        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'));
+        $this->atp = $parent;
+        $this->moderation = new Ozone\Moderation($this);
+        $this->server = new Ozone\Server($this);
+        $this->team = new Ozone\Team($this);
     }
 }

src/Client/Requests/Atproto/Identity.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Atproto;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Identity extends Request
+{
+    /**
+     * Resolve handle to DID
+     */
+    public function resolveHandle(string $handle): Response
+    {
+        return $this->atp->client->get('com.atproto.identity.resolveHandle', compact('handle'));
+    }
+
+    /**
+     * Update handle
+     */
+    public function updateHandle(string $handle): Response
+    {
+        return $this->atp->client->post('com.atproto.identity.updateHandle', compact('handle'));
+    }
+}

src/Client/Requests/Atproto/Repo.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Atproto;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Repo extends Request
+{
+    /**
+     * Create a record
+     */
+    public function createRecord(string $repo, string $collection, array $record, ?string $rkey = null, bool $validate = true, ?string $swapCommit = null): Response
+    {
+        return $this->atp->client->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->atp->client->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->atp->client->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->atp->client->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->atp->client->get('com.atproto.repo.listRecords', compact('repo', 'collection', 'limit', 'cursor', 'reverse'));
+    }
+
+    /**
+     * Upload a blob
+     */
+    public function uploadBlob(string $data, string $mimeType): Response
+    {
+        return $this->atp->client->post('com.atproto.repo.uploadBlob', ['blob' => $data, 'mimeType' => $mimeType]);
+    }
+
+    /**
+     * Describe the repository
+     */
+    public function describeRepo(string $repo): Response
+    {
+        return $this->atp->client->get('com.atproto.repo.describeRepo', compact('repo'));
+    }
+}

src/Client/Requests/Atproto/Server.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Atproto;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Server extends Request
+{
+    /**
+     * Get current session
+     */
+    public function getSession(): Response
+    {
+        return $this->atp->client->get('com.atproto.server.getSession');
+    }
+
+    /**
+     * Describe server
+     */
+    public function describeServer(): Response
+    {
+        return $this->atp->client->get('com.atproto.server.describeServer');
+    }
+}

src/Client/Requests/Atproto/Sync.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Atproto;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Sync extends Request
+{
+    /**
+     * Get blob from sync
+     */
+    public function getBlob(string $did, string $cid): Response
+    {
+        return $this->atp->client->get('com.atproto.sync.getBlob', compact('did', 'cid'));
+    }
+
+    /**
+     * Get checkout from sync
+     */
+    public function getCheckout(string $did): Response
+    {
+        return $this->atp->client->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->atp->client->get('com.atproto.sync.getCommitPath', compact('did', 'latest', 'earliest'));
+    }
+
+    /**
+     * Get repo from sync
+     */
+    public function getRepo(string $did, ?string $since = null): Response
+    {
+        return $this->atp->client->get('com.atproto.sync.getRepo', compact('did', 'since'));
+    }
+
+    /**
+     * List repos from sync
+     */
+    public function listRepos(int $limit = 500, ?string $cursor = null): Response
+    {
+        return $this->atp->client->get('com.atproto.sync.listRepos', compact('limit', 'cursor'));
+    }
+}

src/Client/Requests/Bsky/Actor.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Bsky;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Actor extends Request
+{
+    /**
+     * Get actor profile
+     */
+    public function getProfile(string $actor): Response
+    {
+        return $this->atp->client->get('app.bsky.actor.getProfile', compact('actor'));
+    }
+}

src/Client/Requests/Bsky/Feed.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Bsky;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Feed extends Request
+{
+    /**
+     * Get timeline feed
+     */
+    public function getTimeline(int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->atp->client->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->atp->client->get('app.bsky.feed.getAuthorFeed', compact('actor', 'limit', 'cursor'));
+    }
+
+    /**
+     * Get post thread
+     */
+    public function getPostThread(string $uri, int $depth = 6): Response
+    {
+        return $this->atp->client->get('app.bsky.feed.getPostThread', compact('uri', 'depth'));
+    }
+
+    /**
+     * Search posts
+     */
+    public function searchPosts(string $q, int $limit = 25, ?string $cursor = null): Response
+    {
+        return $this->atp->client->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->atp->client->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->atp->client->get('app.bsky.feed.getRepostedBy', compact('uri', 'limit', 'cursor'));
+    }
+}

src/Client/Requests/Chat/Actor.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Chat;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Actor extends Request
+{
+    /**
+     * Get actor metadata
+     */
+    public function getActorMetadata(): Response
+    {
+        return $this->atp->client->get('chat.bsky.actor.getActorMetadata');
+    }
+
+    /**
+     * Export account data
+     */
+    public function exportAccountData(): Response
+    {
+        return $this->atp->client->get('chat.bsky.actor.exportAccountData');
+    }
+
+    /**
+     * Delete account
+     */
+    public function deleteAccount(): Response
+    {
+        return $this->atp->client->post('chat.bsky.actor.deleteAccount');
+    }
+}

src/Client/Requests/Chat/Convo.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Chat;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Convo extends Request
+{
+    /**
+     * Get conversation
+     */
+    public function getConvo(string $convoId): Response
+    {
+        return $this->atp->client->get('chat.bsky.convo.getConvo', compact('convoId'));
+    }
+
+    /**
+     * Get conversation for members
+     */
+    public function getConvoForMembers(array $members): Response
+    {
+        return $this->atp->client->get('chat.bsky.convo.getConvoForMembers', compact('members'));
+    }
+
+    /**
+     * List conversations
+     */
+    public function listConvos(int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->atp->client->get('chat.bsky.convo.listConvos', compact('limit', 'cursor'));
+    }
+
+    /**
+     * Get messages
+     */
+    public function getMessages(string $convoId, int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->atp->client->get('chat.bsky.convo.getMessages', compact('convoId', 'limit', 'cursor'));
+    }
+
+    /**
+     * Send message
+     */
+    public function sendMessage(string $convoId, array $message): Response
+    {
+        return $this->atp->client->post('chat.bsky.convo.sendMessage', compact('convoId', 'message'));
+    }
+
+    /**
+     * Send message batch
+     */
+    public function sendMessageBatch(array $items): Response
+    {
+        return $this->atp->client->post('chat.bsky.convo.sendMessageBatch', compact('items'));
+    }
+
+    /**
+     * Delete message
+     */
+    public function deleteMessageForSelf(string $convoId, string $messageId): Response
+    {
+        return $this->atp->client->post('chat.bsky.convo.deleteMessageForSelf', compact('convoId', 'messageId'));
+    }
+
+    /**
+     * Update read status
+     */
+    public function updateRead(string $convoId, ?string $messageId = null): Response
+    {
+        return $this->atp->client->post('chat.bsky.convo.updateRead', compact('convoId', 'messageId'));
+    }
+
+    /**
+     * Mute conversation
+     */
+    public function muteConvo(string $convoId): Response
+    {
+        return $this->atp->client->post('chat.bsky.convo.muteConvo', compact('convoId'));
+    }
+
+    /**
+     * Unmute conversation
+     */
+    public function unmuteConvo(string $convoId): Response
+    {
+        return $this->atp->client->post('chat.bsky.convo.unmuteConvo', compact('convoId'));
+    }
+
+    /**
+     * Leave conversation
+     */
+    public function leaveConvo(string $convoId): Response
+    {
+        return $this->atp->client->post('chat.bsky.convo.leaveConvo', compact('convoId'));
+    }
+
+    /**
+     * Get log
+     */
+    public function getLog(?string $cursor = null): Response
+    {
+        return $this->atp->client->get('chat.bsky.convo.getLog', compact('cursor'));
+    }
+}

src/Client/Requests/Ozone/Moderation.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Ozone;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Moderation extends Request
+{
+    /**
+     * Get moderation event
+     */
+    public function getModerationEvent(int $id): Response
+    {
+        return $this->atp->client->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->atp->client->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->atp->client->get('tools.ozone.moderation.getRecord', compact('uri', 'cid'));
+    }
+
+    /**
+     * Get repo
+     */
+    public function getRepo(string $did): Response
+    {
+        return $this->atp->client->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->atp->client->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->atp->client->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->atp->client->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->atp->client->post('tools.ozone.moderation.emitEvent', compact('event', 'subject', 'subjectBlobCids', 'createdBy'));
+    }
+}

src/Client/Requests/Ozone/Server.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Ozone;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Server extends Request
+{
+    /**
+     * Get blob
+     */
+    public function getBlob(string $did, string $cid): Response
+    {
+        return $this->atp->client->get('tools.ozone.server.getBlob', compact('did', 'cid'));
+    }
+
+    /**
+     * Get config
+     */
+    public function getConfig(): Response
+    {
+        return $this->atp->client->get('tools.ozone.server.getConfig');
+    }
+}

src/Client/Requests/Ozone/Team.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests\Ozone;
+
+use SocialDept\AtpClient\Client\Requests\Request;
+use SocialDept\AtpClient\Http\Response;
+
+class Team extends Request
+{
+    /**
+     * Get team member
+     */
+    public function getTeamMember(string $did): Response
+    {
+        return $this->atp->client->get('tools.ozone.team.getMember', compact('did'));
+    }
+
+    /**
+     * List team members
+     */
+    public function listTeamMembers(int $limit = 50, ?string $cursor = null): Response
+    {
+        return $this->atp->client->get('tools.ozone.team.listMembers', compact('limit', 'cursor'));
+    }
+
+    /**
+     * Add team member
+     */
+    public function addTeamMember(string $did, string $role): Response
+    {
+        return $this->atp->client->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->atp->client->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->atp->client->post('tools.ozone.team.deleteMember', compact('did'));
+    }
+}

src/Client/Requests/Request.php

···
+<?php
+
+namespace SocialDept\AtpClient\Client\Requests;
+
+use SocialDept\AtpClient\AtpClient;
+
+class Request
+{
+    /**
+     * The parent AtpClient instance we belong to
+     */
+    public AtpClient $atp;
+
+    public function __construct($parent)
+    {
+        $this->atp = $parent->atp;
+    }
+}