@skyware/jetstream

A fully typed client for the Bluesky Jetstream service.

Documentation

Installation

npm install @skyware/jetstream

Example Usage

import{Jetstream}from"@skyware/jetstream";constjetstream=newJetstream({wantedCollections: ["app.bsky.feed.post","app.bsky.feed.like"],// omit to receive all collectionswantedDids: ["did:web:example.com"],// omit to receive events from all dids});jetstream.onCreate("app.bsky.feed.post",(event)=>{console.log(`New post: ${event.commit.record.text}`)});jetstream.onDelete("app.bsky.feed.post",(event)=>{console.log(`Deleted post: ${event.commit.rkey}`)});// Other events: // - "commit" (to receive all commits regardless of collection)// - "identity" (identity update events)// - `${collection}` (to receive all commits related to a specific collection)jetstream.on("account",(event)=>{console.log(`Account updated: ${event.did}`)});jetstream.start()