Something went wrong. Try again.
browse the protocol like its 2008 ibex.desertthunder.dev
ubuntu atproto svelte
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106import { describe, expect, it } from 'vitest';import { buildLiveStreamUrl, parseFirehoseEvent, parseTextLiveEvent } from './live-stream';
describe('live stream helpers', () => { it('builds Jetstream v2 URLs with server-side filters and a cursor', () => { const url = new URL( buildLiveStreamUrl('jetstream', { instance: 'wss://jetstream.us-east.bsky.network', did: 'did:plc:example', collection: 'app.bsky.feed.post', cursor: '12345' }) );
expect(url.pathname).toBe('/xrpc/network.bsky.jetstream.subscribeEvents'); expect(url.searchParams.get('dids')).toBe('did:plc:example'); expect(url.searchParams.get('collections')).toBe('app.bsky.feed.post'); expect(url.searchParams.get('cursor')).toBe('12345'); });
it('uses Spacedust backlink filters but does not add unsupported cursors', () => { const url = new URL( buildLiveStreamUrl('spacedust', { instance: 'wss://spacedust.microcosm.blue', did: 'did:plc:target', collection: 'app.bsky.feed.like:subject.uri', cursor: '12345' }) );
expect(url.pathname).toBe('/subscribe'); expect(url.searchParams.get('wantedSubjectDids')).toBe('did:plc:target'); expect(url.searchParams.get('wantedSources')).toBe('app.bsky.feed.like:subject.uri'); expect(url.searchParams.has('cursor')).toBe(false); });
it('normalizes Jetstream and Spacedust JSON events', () => { const jetstream = parseTextLiveEvent( 'jetstream', JSON.stringify({ $type: 'message', payload: { $type: 'network.bsky.jetstream.subscribeEvents#commit', did: 'did:plc:author', seq: 42, time: '2026-08-13T06:47:43.959Z', operation: 'create', collection: 'app.bsky.feed.post', rkey: '3example' } }) ); const spacedust = parseTextLiveEvent( 'spacedust', JSON.stringify({ kind: 'link', origin: 'live', link: { operation: 'create', source: 'app.bsky.feed.like:subject.uri', source_record: 'at://did:plc:author/app.bsky.feed.like/3example', subject: 'at://did:plc:target/app.bsky.feed.post/3target' } }) );
expect(jetstream).toMatchObject({ kind: 'commit', operation: 'create', did: 'did:plc:author', collection: 'app.bsky.feed.post' }); expect(spacedust).toMatchObject({ kind: 'link', did: 'did:plc:author', collection: 'app.bsky.feed.like', source: 'app.bsky.feed.like:subject.uri' }); });
it('normalizes decoded firehose commits and summarizes binary fields', () => { const event = parseFirehoseEvent({ $type: 'com.atproto.sync.subscribeRepos#commit', seq: 123, repo: 'did:plc:author', time: '2026-01-01T00:00:00Z', ops: [{ action: 'create', path: 'app.bsky.feed.post/3example' }], blocks: new Uint8Array(2048) });
expect(event).toMatchObject({ kind: 'commit', operation: 'create', did: 'did:plc:author', collection: 'app.bsky.feed.post', source: 'app.bsky.feed.post', summary: 'create app.bsky.feed.post/3example' }); expect(event.json).toContain('[2048 bytes]'); });
it('rejects non-WebSocket instances', () => { expect(() => buildLiveStreamUrl('jetstream', { instance: 'https://example.com' })).toThrow('WebSocket URL'); });});