Struct Repo 

pub struct Repo { /* private fields */ }

High-level client for AT Protocol record repository operations.

Wraps com.atproto.repo.* XRPC calls with typed helpers. Automatically uses the provided PDS endpoint for all operations.

Example

let repo = Repo::new(http, "https://pds.example.com", "token", "did:plc:abc123");
let record = serde_json::json!({ "text": "Hello world" });
let strong_ref = repo.create_record("app.bsky.feed.post", &record).await?;

Implementations

impl Repo

pub fn new( http: &Client, pds_endpoint: &str, access_token: &str, did: &str, ) -> Self

Create a new Repo client with explicit parameters.

pub fn from_session( http: &Client, session: &AtrgSession, pds_endpoint: &str, ) -> Self

Create a Repo client from an authenticated session.

pub fn did(&self) -> &str

Return a reference to the DID this repo operates on.

pub fn pds_endpoint(&self) -> &str

Return a reference to the PDS endpoint.

pub async fn get_record<T: DeserializeOwned>( &self, uri: &AtUri, ) -> Result<Record<T>, RepoError>

Get a record by AT-URI.

Calls com.atproto.repo.getRecord.

pub async fn list_records<T: DeserializeOwned>( &self, collection: &str, cursor: Option<&str>, limit: Option<usize>, ) -> Result<Page<Record<T>>, RepoError>

List records in a collection.

Calls com.atproto.repo.listRecords.

pub async fn create_record( &self, collection: &str, record: &Value, ) -> Result<StrongRef, RepoError>

Create a new record with an auto-generated TID as the rkey.

Calls com.atproto.repo.createRecord.

pub async fn put_record( &self, collection: &str, rkey: &str, record: &Value, ) -> Result<StrongRef, RepoError>

Create or update a record at a specific rkey.

Calls com.atproto.repo.putRecord.

pub async fn delete_record(&self, uri: &AtUri) -> Result<(), RepoError>

Delete a record.

Calls com.atproto.repo.deleteRecord.

pub async fn upload_blob( &self, data: Vec<u8>, mime_type: &str, ) -> Result<BlobRef, RepoError>

Upload a blob to the authenticated user’s PDS.

Delegates to blob::upload_blob.

pub fn new_tid() -> Tid

Generate a new Tid for use as a record key.