ProtoRune

Hex version Hex Docs Hex downloads License

An Elixir SDK for the AT Protocol. Build your own atproto apps: custom lexicons, your own collections on the user's PDS, OAuth, identity resolution, repo sync. The Bluesky API comes along for the ride. Sessions are explicit, so there is no hidden global state to hunt down at 3am.

Installation

def deps do
  [
    {:proto_rune, "~> 0.7.0"} # x-release-please-version
  ]
end

Quick start

Login with a handle and an app password, then post:

{:ok, session} = ProtoRune.login("you.bsky.social", "your-app-password")

{:ok, post} = ProtoRune.Bsky.post(session, "Hello from Elixir!")

Everything takes the session as the first argument:

{:ok, timeline} = ProtoRune.Bsky.get_timeline(session, limit: 20)
{:ok, like} = ProtoRune.Bsky.like(session, post.uri, post.cid)
{:ok, repost} = ProtoRune.Bsky.repost(session, post.uri, post.cid)
{:ok, follow} = ProtoRune.Bsky.follow(session, "alice.bsky.social")
{:ok, did} = ProtoRune.resolve_handle("alice.bsky.social")
{:ok, doc} = ProtoRune.resolve_did("did:plc:abc123xyz")

Sessions

A session holds the tokens and account info. There are two kinds: app password sessions and OAuth sessions (PAR, PKCE and DPoP, no JWT dependency). Access tokens expire; refresh when needed:

{:ok, fresh_session} = ProtoRune.refresh_session(session)

For long-running apps, ProtoRune.SessionManager keeps a session fresh and persists each rotation encrypted. See the authentication guide.

Error handling

Everything returns tagged tuples:

case ProtoRune.login(identifier, password) do
  {:ok, session} -> ProtoRune.Bsky.post(session, "Success!")
  {:error, reason} -> IO.puts("Login failed: #{inspect(reason)}")
end

Building on atproto

Bluesky's app.bsky.* collections are just lexicons, and your app can define its own the same way. Records live on the user's PDS under your NSID; ProtoRune writes them with validation before anything hits the wire:

mix proto_rune.gen.lexicons --path priv/lexicons --output lib/my_app/lexicons
schema = MyApp.Lexicons.Blog.Post.get_schema(:main)

{:ok, %{uri: uri}} =
  ProtoRune.Atproto.Repo.create_record(
    session,
    %{
      repo: ProtoRune.Session.did(session),
      collection: "blog.myapp.post",
      record: %{"$type" => "blog.myapp.post", "title" => "hello atproto"}
    },
    schema: schema
  )

Drop lower when you need to: ProtoRune.Atproto.Repo for record CRUD with optimistic concurrency, ProtoRune.Atproto.Sync to download and verify repository checkouts (CAR files, signed commits), ProtoRune.Atproto.Identity for handle/DID resolution, and the XRPC layer for endpoints with no generated module. See the guides for custom lexicons, repository operations and XRPC.

Rich text

alias ProtoRune.RichText

{:ok, rt} =
  RichText.new()
  |> RichText.text("Hello ")
  |> RichText.mention("alice.bsky.social")
  |> RichText.text("! Check out ")
  |> RichText.link("ProtoRune", "https://github.com/zoedsoupe/proto_rune")
  |> RichText.build()

{:ok, post} = ProtoRune.Bsky.post(session, rt)

Byte offsets are calculated for you, mentions and links just work.

Bots

defmodule GreeterBot do
  use ProtoRune.Bot, name: __MODULE__, strategy: :polling

  require Logger

  @impl true
  def get_identifier, do: System.get_env("BOT_IDENTIFIER")

  @impl true
  def get_password, do: System.get_env("BOT_PASSWORD")

  @impl true
  def handle_event(:mention, payload) do
    Logger.info("Mentioned by #{payload.thread.post.author.handle}")
    {:ok, :handled}
  end

  def handle_event(_event, _payload), do: {:ok, :ignored}
end

{:ok, _pid} = GreeterBot.start_link()

Bots are OTP processes with polling out of the box, so they fit into your supervision tree like anything else.

Security notes

Two transport behaviors are worth knowing about:

Identity fetches never follow redirects implicitly. Fetches of stranger-chosen URLs (DID documents, well-known handle files, OAuth metadata) go through a guarded GET: absolute https redirects only, bounded hops, and each hop re-checked. Optionally they also refuse private, loopback, link-local and otherwise unroutable addresses, so a DID document published at a name that resolves to your internal network is refused instead of fetched. The address guard is off by default so a localhost PDS keeps working; turn it on for applications that resolve identity from untrusted input:

config :proto_rune, refuse_private_addresses: true

# or per call:
Identity.resolve_did(did, http: [refuse_private_addresses: true])

Known limits of the guard (same shape as the gaps in the module docs of ProtoRune.HTTPClient.SSRF): DNS answers are checked for A records only, and the address is resolved once here and again when the connection opens, so a name that changes answers between the two is not pinned.

HTTP runs on Finch. The library supervises one named Finch pool (ProtoRune.Finch) started by ProtoRune.Application. It is added to your application's supervision tree automatically when you depend on :proto_rune; configure pool sizes through config :proto_rune, ProtoRune.Finch, pools: %{...} (see Finch).

Built with ProtoRune

Docs

Full API reference on hexdocs.pm/proto_rune. Guides:

Issues: github.com/zoedsoupe/proto_rune/issues

Contributing

Fork, branch, write tests, mix test, mix format, open a PR. More details in CONTRIBUTING.md.

License

MIT. Built with love by @zoedsoupe.