Struct PdsClient 

pub struct PdsClient { /* private fields */ }

Thin wrapper over reqwest::Client pinned to one PDS base URL. Construct once per cairn process; one instance serves the whole command’s lifetime.

Implementations

impl PdsClient

pub fn new(base_url: &str) -> Result<Self, PdsError>

Construct a client for the given PDS base URL (e.g., https://bsky.social). Trailing slashes are normalized away.

pub fn with_http_client( base_url: &str, client: Client, ) -> Result<Self, PdsError>

Inject a preconfigured reqwest::Client. Used by tests that need to disable TLS verification (mock PDS at plain HTTP) without plumbing feature flags through the public API.

pub async fn create_session( &self, identifier: &str, password: &str, ) -> Result<CreateSessionResponse, PdsError>

Exchange handle+app-password for a PDS session.

pub async fn refresh_session( &self, refresh_jwt: &str, ) -> Result<RefreshSessionResponse, PdsError>

Rotate access+refresh tokens using a valid refresh token.

pub async fn delete_session(&self, refresh_jwt: &str) -> Result<(), PdsError>

Invalidate the refresh token server-side. Success on 2xx; callers typically treat any error here as non-fatal (local cleanup proceeds regardless, per Q3 in the criteria confirmation).

pub async fn put_record( &self, access_jwt: &str, repo: &str, collection: &str, rkey: &str, record: &Value, swap_record: Option<&str>, ) -> Result<PutRecordResponse, PdsError>

Put a record at (repo, collection, rkey). When swap_record is Some, the request is conditional on the PDS’s current record having that CID — §F1 swap-race detection rides on this. Used by cairn publish-service-record to emit the app.bsky.labeler.service record at rkey=self.

Distinct context discriminators for auth failures: "putRecord" generally, mapped upward to a specific swap-race error via PdsError::SwapRace when the PDS’s response body carries the InvalidSwap shape.

pub async fn get_record( &self, repo: &str, collection: &str, rkey: &str, ) -> Result<Option<GetRecordResponse>, PdsError>

Fetch a record via com.atproto.repo.getRecord. Unauthenticated public endpoint — used by cairn serve’s startup verify check to read the published app.bsky.labeler.service record without requiring an operator session on the serve host.

Returns:

• Ok(Some(_)) — record exists, body deserialized
• Ok(None) — record does not exist (HTTP 404 OR XRPC RecordNotFound error body). Distinct from a transport failure: callers that need to differentiate “absent” from “unreachable” branch on this distinction.
• Err(PdsError::Network { .. }) — transport-level failure (DNS, TLS, timeout, refused).
• Err(PdsError::UnexpectedStatus { .. }) — any other non-2xx (auth-required-on-private-PDS, server error, rate-limit response).

pub async fn delete_record( &self, access_jwt: &str, repo: &str, collection: &str, rkey: &str, swap_record: Option<&str>, ) -> Result<(), PdsError>

Delete a record at (repo, collection, rkey) via com.atproto.repo.deleteRecord. When swap_record is Some, the request is conditional on the PDS’s current record having that CID — same swap-race semantics as put_record. Used by cairn unpublish-service-record (#34) to remove the published app.bsky.labeler.service record.

Idempotency on the wire: real PDSes return 200 even when the target record is already absent, matching the ATProto spec. Callers that want a “did we actually delete something” distinction should consult their own state (e.g., labeler_config) before calling — that’s the path the unpublish flow takes.

pub async fn get_service_auth( &self, access_jwt: &str, aud: &str, lxm: &str, ) -> Result<String, PdsError>

Mint a fresh service auth JWT for calling aud with the given lexicon method. Returns the opaque token string; the CLI presents it as Authorization: Bearer <token> to Cairn.

Trait Implementations

impl Clone for PdsClient

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PdsClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.