Chat / Direct Messages

Send and receive Bluesky direct messages through the Chat module.

All examples use taskResult {} -- see the Error Handling guide for details. The chat proxy header (atproto-proxy: did:web:api.bsky.chat#bsky_chat) is applied automatically -- you use the same agent as for everything else.

Domain Types

ConvoSummary

A summary of a chat conversation.

LastMessage

Summary of the most recent message in a conversation.

ChatMessage

Discriminated union representing a message in a conversation. Uses [<RequireQualifiedAccess>].

Page<'T>

A paginated result containing a list of items and an optional cursor for the next page.

Functions

SRTP: All functions that take a convoId parameter accept either a ConvoSummary or a string conversation ID.

Conversations

taskResult {
    let! profile = Bluesky.getProfile agent aliceHandle
    let! convo = Chat.getConvoForMembers agent [ profile.Did ]
    printfn "Conversation: %s (members: %d)" convo.Id convo.Members.Length
}

Messages

sendMessage automatically detects links, mentions, and hashtags -- just like Bluesky.post. No extra steps needed.

taskResult {
    let! msg = Chat.sendMessage agent convo "Check out https://atproto.com!"

    match msg with
    | ChatMessage.Message m -> printfn "Sent: %s (id: %s)" m.Text m.Id
    | ChatMessage.Deleted _ -> ()
}

taskResult {
    let! page = Chat.getMessages agent convo (Some 20L) None

    for m in page.Items do
        match m with
        | ChatMessage.Message msg ->
            printfn "[%s] %s" (Did.value msg.Sender) msg.Text
        | ChatMessage.Deleted del ->
            printfn "(deleted: %s)" del.Id
}

Read State

taskResult {
    let! _ = Chat.markRead agent convo
    let! updatedCount = Chat.markAllRead agent
    printfn "Marked %d conversations as read" updatedCount
}

Muting

taskResult {
    let! _ = Chat.muteConvo agent convo
    let! _ = Chat.unmuteConvo agent convo
    return ()
}

Reactions

taskResult {
    let! _ = Chat.addReaction agent convo msgId "❤️"
    let! _ = Chat.removeReaction agent convo msgId "❤️"
    return ()
}

Power Users: Raw XRPC

For full control over facets or to include an embed (e.g., sharing a post into a DM), drop to the raw XRPC wrapper. You must apply the chat proxy header manually when using raw wrappers:

task {
    let text = "Check out https://atproto.com!"
    let! facets = RichText.parse agent text

    let! result =
        ChatBskyConvo.SendMessage.call (AtpAgent.withChatProxy agent)
            { ConvoId = convo.Id
              Message =
                { Text = text
                  Facets = if facets.IsEmpty then None else Some facets
                  Embed = None } }

    match result with
    | Ok msg -> printfn "Sent with custom facets"
    | Error err -> printfn "Failed: %A" err
}