Something went wrong. Try again.
Mirror of https://github.com/improsocial/improAn extensible Bluesky client for web
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211import { describe, it } from "node:test";import assert from "node:assert/strict";import { DataStore } from "/js/dataLayer/dataStore.js";
describe("setPosts", () => { it("should insert multiple posts", () => { const dataStore = new DataStore(); const posts = [ { uri: "at://did:test/app.bsky.feed.post/1", record: { text: "one" } }, { uri: "at://did:test/app.bsky.feed.post/2", record: { text: "two" } }, { uri: "at://did:test/app.bsky.feed.post/3", record: { text: "three" } }, ]; dataStore.setPosts(posts); for (const post of posts) { assert.deepEqual(dataStore.$posts.get(post.uri), post); } });
it("should match $posts.set behavior when given a single post", () => { const dataStoreA = new DataStore(); const dataStoreB = new DataStore(); const post = { uri: "at://did:test/app.bsky.feed.post/solo", record: { text: "solo" }, }; dataStoreA.$posts.set(post.uri, post); dataStoreB.setPosts([post]); assert.deepEqual( dataStoreA.$posts.get(post.uri), dataStoreB.$posts.get(post.uri), ); });
it("should store nested quoted posts as embedded previews", () => { const dataStore = new DataStore(); const nestedQuotedPost = { $type: "app.bsky.embed.record#viewRecord", uri: "at://did:test/app.bsky.feed.post/nested", cid: "nested-cid", author: { did: "did:test", handle: "nested.test" }, value: { text: "nested" }, indexedAt: "2026-07-19T00:00:00Z", }; const quotedPost = { $type: "app.bsky.embed.record#viewRecord", uri: "at://did:test/app.bsky.feed.post/quoted", cid: "quoted-cid", author: { did: "did:test", handle: "quoted.test" }, value: { text: "quoted" }, embeds: [ { $type: "app.bsky.embed.record#view", record: nestedQuotedPost, }, ], indexedAt: "2026-07-19T00:00:00Z", }; const post = { uri: "at://did:test/app.bsky.feed.post/root", record: { text: "root" }, embed: { $type: "app.bsky.embed.record#view", record: quotedPost, }, };
dataStore.setPosts([post]);
assert.deepEqual(dataStore.$posts.get(quotedPost.uri), null); assert.deepEqual(dataStore.$embeddedPosts.get(quotedPost.uri), { uri: quotedPost.uri, cid: quotedPost.cid, author: quotedPost.author, record: quotedPost.value, embed: quotedPost.embeds[0], labels: undefined, likeCount: undefined, replyCount: undefined, repostCount: undefined, quoteCount: undefined, indexedAt: quotedPost.indexedAt, }); assert.deepEqual(dataStore.$posts.get(nestedQuotedPost.uri), null); assert.deepEqual(dataStore.$embeddedPosts.get(nestedQuotedPost.uri), { uri: nestedQuotedPost.uri, cid: nestedQuotedPost.cid, author: nestedQuotedPost.author, record: nestedQuotedPost.value, embed: undefined, labels: undefined, likeCount: undefined, replyCount: undefined, repostCount: undefined, quoteCount: undefined, indexedAt: nestedQuotedPost.indexedAt, }); });
it("should replace an embedded preview with a full post", () => { const dataStore = new DataStore(); const quotedUri = "at://did:test/app.bsky.feed.post/quoted"; const quotedPost = { $type: "app.bsky.embed.record#viewRecord", uri: quotedUri, cid: "quoted-cid", author: { did: "did:test", handle: "quoted.test" }, value: { text: "quoted" }, indexedAt: "2026-07-19T00:00:00Z", }; dataStore.setPosts([ { uri: "at://did:test/app.bsky.feed.post/root", record: { text: "root" }, embed: { $type: "app.bsky.embed.record#view", record: quotedPost, }, }, ]);
const fullPost = { uri: quotedUri, cid: "quoted-cid", author: quotedPost.author, record: quotedPost.value, indexedAt: quotedPost.indexedAt, viewer: { like: "at://did:test/app.bsky.feed.like/quoted" }, }; dataStore.setPosts([fullPost]);
assert.deepEqual(dataStore.$embeddedPosts.get(quotedUri), null); assert.deepEqual(dataStore.$posts.get(quotedUri), fullPost); });});
describe("setConvo", () => { it("should save the convo and prepend it to the loaded convo list", () => { const dataStore = new DataStore(); dataStore.$convoList.set({ convos: [{ id: "c1" }], cursor: "page2" }); const convo = { id: "c2", status: "accepted" };
dataStore.setConvo(convo);
assert.deepEqual(dataStore.$convos.get("c2"), convo); assert.deepEqual( dataStore.$convoList.get().convos.map((listConvo) => listConvo.id), ["c2", "c1"], ); assert.deepEqual(dataStore.$convoList.get().cursor, "page2"); });
it("should replace an existing list entry instead of duplicating it", () => { const dataStore = new DataStore(); dataStore.$convoList.set({ convos: [{ id: "c1", unreadCount: 0 }], cursor: null, });
dataStore.setConvo({ id: "c1", status: "accepted", unreadCount: 2, });
const list = dataStore.$convoList.get(); assert.deepEqual(list.convos.length, 1); assert.deepEqual(list.convos[0].unreadCount, 2); });
it("should leave unloaded lists null", () => { const dataStore = new DataStore();
dataStore.setConvo({ id: "c1", status: "accepted" });
assert.deepEqual(dataStore.$convos.get("c1").id, "c1"); assert.deepEqual(dataStore.$convoList.get(), null); assert.deepEqual(dataStore.$convoRequestList.get(), null); });
it("should route request convos to the request list", () => { const dataStore = new DataStore(); dataStore.$convoList.set({ convos: [], cursor: null }); dataStore.$convoRequestList.set({ convos: [], cursor: null });
dataStore.setConvo({ id: "c1", status: "request" });
assert.deepEqual(dataStore.$convoList.get().convos, []); assert.deepEqual( dataStore.$convoRequestList.get().convos.map((listConvo) => listConvo.id), ["c1"], ); });
it("should move an accepted convo out of the request list", () => { const dataStore = new DataStore(); dataStore.$convoList.set({ convos: [], cursor: null }); dataStore.$convoRequestList.set({ convos: [{ id: "c1", status: "request" }], cursor: null, });
dataStore.setConvo({ id: "c1", status: "accepted" });
assert.deepEqual( dataStore.$convoList.get().convos.map((listConvo) => listConvo.id), ["c1"], ); assert.deepEqual(dataStore.$convoRequestList.get().convos, []); });});