jerry/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-11-04 08:21:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(desktop): make relay inbox tests seed their item

Browse Source 
Create fresh mention items inside relay-backed Home inbox tests so they do not depend on stale seeded feed contents.

Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
Thomas Petersen
2026-05-14 14:33:31 -04:00
parent 14bc93cbb2
commit babfbe2f00
1 changed files with 109 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

132
desktop/tests/e2e/stream.spec.ts
View File

@@ -1,6 +1,6 @@
import { expect, test, type Browser, type Page } from "@playwright/test";
import { installRelayBridge } from "../helpers/bridge";
import { installRelayBridge, TEST_IDENTITIES } from "../helpers/bridge";
import { assertRelaySeeded } from "../helpers/seed";
const isCi = Boolean(process.env.CI);
@@ -76,6 +76,56 @@ async function createAndJoinSharedStream(
);
}
async function sendChannelMessage(
page: Page,
{
channelName,
content,
mentionPubkeys,
}: {
channelName: string;
content: string;
mentionPubkeys?: string[];
},
) {
await page.evaluate(
async ({ channelName: targetChannelName, content, mentionPubkeys }) => {
const tauriWindow = window as Window & {
__TAURI_INTERNALS__?: {
invoke: (
command: string,
payload?: Record<string, unknown>,
) => Promise<unknown>;
};
};
const invoke = tauriWindow.__TAURI_INTERNALS__?.invoke;
if (!invoke) {
throw new Error("Tauri invoke bridge is unavailable.");
}
const channels = (await invoke("get_channels")) as Array<{
id: string;
name: string;
}>;
const channel = channels.find(({ name }) => name === targetChannelName);
if (!channel) {
throw new Error(`Channel not found: ${targetChannelName}`);
}
await invoke("send_channel_message", {
channelId: channel.id,
content,
kind: null,
mediaTags: null,
mentionPubkeys: mentionPubkeys ?? null,
parentEventId: null,
});
},
{ channelName, content, mentionPubkeys },
);
}
async function scrollTimelineAwayFromBottom(page: Page, minDistance = 160) {
const timeline = page.getByTestId("message-timeline");
await timeline.hover();
@@ -106,38 +156,74 @@ test("loads channels from the relay", async ({ page }) => {
await expect(page.getByTestId("dm-list")).toContainText("alice-tyler");
});
test("loads the home feed from the relay", async ({ page }) => {
await installRelayBridge(page, "tyler");
await page.goto("/");
test("loads the home feed from the relay", async ({ browser }) => {
const message = `Relay home mention ${Date.now()}`;
const targetContext = await browser.newContext();
const senderContext = await browser.newContext();
const page = await targetContext.newPage();
const senderPage = await senderContext.newPage();
await expect(page.getByTestId("chat-title")).toHaveText("Home");
await expect(page.getByTestId("home-inbox")).toBeVisible();
await expect(page.getByTestId("home-inbox-list")).toContainText(
"Please review the release checklist.",
);
await expect(page.getByTestId("home-inbox-detail")).toBeVisible();
try {
await installRelayBridge(page, "tyler");
await installRelayBridge(senderPage, "alice");
await page.goto("/");
await senderPage.goto("/");
await expect(page.getByTestId("chat-title")).toHaveText("Home");
await expect(page.getByTestId("home-inbox")).toBeVisible();
await sendChannelMessage(senderPage, {
channelName: "general",
content: message,
mentionPubkeys: [TEST_IDENTITIES.tyler.pubkey],
});
await expect(page.getByTestId("home-inbox-list")).toContainText(message, {
timeout: relayDeliveryTimeoutMs,
});
await expect(page.getByTestId("home-inbox-detail")).toBeVisible();
} finally {
await targetContext.close();
await senderContext.close();
}
});
test("shows sent inbox replies immediately in the inbox detail pane", async ({
page,
browser,
}) => {
const message = `Relay inbox reply target ${Date.now()}`;
const reply = `Inbox reply ${Date.now()}`;
const targetContext = await browser.newContext();
const senderContext = await browser.newContext();
const page = await targetContext.newPage();
const senderPage = await senderContext.newPage();
await installRelayBridge(page, "tyler");
await page.goto("/");
try {
await installRelayBridge(page, "tyler");
await installRelayBridge(senderPage, "alice");
await page.goto("/");
await senderPage.goto("/");
await page
.getByTestId("home-inbox-list")
.getByText("Please review the release checklist.")
.first()
.click();
await expect(page.getByTestId("home-inbox-detail")).toBeVisible();
await expect(page.getByTestId("message-input")).toBeEnabled();
await sendChannelMessage(senderPage, {
channelName: "general",
content: message,
mentionPubkeys: [TEST_IDENTITIES.tyler.pubkey],
});
await page.getByTestId("message-input").fill(reply);
await page.getByTestId("send-message").click();
await page.getByTestId("home-inbox-list").getByText(message).click({
timeout: relayDeliveryTimeoutMs,
});
await expect(page.getByTestId("home-inbox-detail")).toBeVisible();
await expect(page.getByTestId("message-input")).toBeEnabled();
await expect(page.getByTestId("home-inbox-detail")).toContainText(reply);
await page.getByTestId("message-input").fill(reply);
await page.getByTestId("send-message").click();
await expect(page.getByTestId("home-inbox-detail")).toContainText(reply);
} finally {
await targetContext.close();
await senderContext.close();
}
});
test("creates a relay-backed stream", async ({ page }) => {