@atproto/api

import { Agent, CredentialSession } from '@atproto/api'

const session = new CredentialSession(new URL('https://bsky.social'))
await session.login({
  identifier: 'your.bsky.social',
  password: 'xxxx-xxxx-xxxx-xxxx', // App password
})

const agent = new Agent(session)

import { Agent } from '@atproto/api'
import { OAuthClient } from '@atproto/oauth-client'

const oauthClient = new OAuthClient({
  // OAuth configuration
})

const oauthSession = await oauthClient.restore('did:plc:123')
const agent = new Agent(oauthSession)

new Agent(sessionManager: SessionManager | FetchHandler | FetchHandlerOptions)

// ATProto methods
await agent.com.atproto.repo.createRecord({
  repo: agent.did!,
  collection: 'app.bsky.feed.post',
  record: {
    $type: 'app.bsky.feed.post',
    text: 'Hello, world!',
    createdAt: new Date().toISOString(),
  },
})

// Bluesky methods
await agent.app.bsky.feed.getTimeline({
  limit: 50
})

// Chat methods (if available)
await agent.chat.bsky.convo.listConvos({})

// Moderation tools
await agent.tools.ozone.moderation.queryStatuses({})

new RichText(props: RichTextProps, opts?: RichTextOpts)

import { Agent, RichText } from '@atproto/api'

const rt = new RichText({
  text: 'Hello @alice.bsky.social! Check out https://example.com #atproto',
})

await rt.detectFacets(agent)

await agent.post({
  text: rt.text,
  facets: rt.facets,
})

let markdown = ''
for (const segment of rt.segments()) {
  if (segment.isLink()) {
    markdown += `[${segment.text}](${segment.link?.uri})`
  } else if (segment.isMention()) {
    markdown += `[@${segment.text}](https://bsky.app/profile/${segment.mention?.did})`
  } else if (segment.isTag()) {
    markdown += `[#${segment.tag?.tag}](https://bsky.app/hashtag/${segment.tag?.tag})`
  } else {
    markdown += segment.text
  }
}

import { moderatePost, moderateProfile } from '@atproto/api'

// Get user preferences
const prefs = await agent.getPreferences()
const labelDefs = await agent.getLabelDefinitions(prefs)

// Moderate a post
const postMod = moderatePost(postView, {
  userDid: agent.did,
  moderationPrefs: prefs.moderationPrefs,
  labelDefs,
})

// Check moderation decisions for feeds
if (postMod.ui('contentList').filter) {
  // Don't show in feeds
}

if (postMod.ui('contentList').blur) {
  // Show behind a cover
  console.log('Reasons:', postMod.ui('contentList').blurs)
}

if (postMod.ui('contentList').alert) {
  // Show warnings
  console.log('Alerts:', postMod.ui('contentList').alerts)
}

// Moderate a profile
const profileMod = moderateProfile(profileView, {
  userDid: agent.did,
  moderationPrefs: prefs.moderationPrefs,
  labelDefs,
})

new CredentialSession(
  serviceUrl: URL,
  fetch?: typeof globalThis.fetch,
  persistSession?: AtpPersistSessionHandler
)

import { AtpAgent } from '@atproto/api'

const agent = new AtpAgent({
  service: 'https://bsky.social',
})

await agent.login({
  identifier: 'alice.bsky.social',
  password: 'xxxx-xxxx-xxxx-xxxx',
})

import {
  // Post types
  AppBskyFeedPost,
  AppBskyFeedDefs,
  
  // Profile types
  AppBskyActorDefs,
  AppBskyActorProfile,
  
  // Graph types
  AppBskyGraphDefs,
  AppBskyGraphFollow,
  
  // Rich text types
  AppBskyRichtextFacet,
  
  // Common types
  BlobRef,
  AtUri,
} from '@atproto/api'

import { AppBskyFeedPost } from '@atproto/api'

const post = {
  $type: 'app.bsky.feed.post',
  text: 'Hello, world!',
  createdAt: new Date().toISOString(),
}

// Type guard
if (AppBskyFeedPost.isRecord(post)) {
  // TypeScript knows post is a PostRecord
}

// Validation
const result = AppBskyFeedPost.validateRecord(post)
if (result.success) {
  // Valid record
  const validPost = result.value
} else {
  // Validation error
  console.error(result.error)
}

import { Agent } from '@atproto/api'

Agent.configure({
  appLabelers: ['did:plc:...'], // Default labelers
})

agent.setHeader('X-Custom-Header', 'value')
agent.setHeader('Authorization', () => `Bearer ${getToken()}`)
agent.unsetHeader('X-Custom-Header')
agent.clearHeaders()

const session = new CredentialSession(
  new URL('https://bsky.social'),
  customFetch
)

import { XRPCError, ResponseType } from '@atproto/api'

try {
  await agent.post({ text: 'Hello!' })
} catch (error) {
  if (error instanceof XRPCError) {
    console.error('Status:', error.status)
    console.error('Error:', error.error)
    console.error('Message:', error.message)
    
    if (error.status === ResponseType.RateLimitExceeded) {
      // Handle rate limit
    }
  }
}

import { Agent, CredentialSession, RichText } from '@atproto/api'

const session = new CredentialSession(new URL('https://bsky.social'))
await session.login({
  identifier: 'alice.bsky.social',
  password: 'xxxx-xxxx-xxxx-xxxx',
})

const agent = new Agent(session)

// Upload image
const imageData = await fetch('https://example.com/image.jpg')
  .then(r => r.arrayBuffer())
const uploadResult = await agent.uploadBlob(new Uint8Array(imageData), {
  encoding: 'image/jpeg'
})

// Create rich text
const rt = new RichText({
  text: 'Check out this cool website: https://example.com @alice.bsky.social',
})
await rt.detectFacets(agent)

// Create post with image and rich text
await agent.post({
  text: rt.text,
  facets: rt.facets,
  embed: {
    $type: 'app.bsky.embed.images',
    images: [{
      image: uploadResult.data.blob,
      alt: 'A cool image',
    }],
  },
})