+
+
+ {name}
+
+ {thread ? (
+
+ );
+}
diff --git a/src/bundled/pulse/PulsePage.tsx b/src/bundled/pulse/PulsePage.tsx
new file mode 100644
index 00000000..8632fdbb
--- /dev/null
+++ b/src/bundled/pulse/PulsePage.tsx
@@ -0,0 +1,354 @@
+import { useMemo, useRef, useState, type ReactNode } from "react";
+import {
+ Hash,
+ Inbox,
+ MessageCircle,
+ Search,
+ Sparkles,
+ RefreshCw,
+} from "lucide-react";
+import type { RelayData } from "../../features/relay/service";
+import type { RelaySession } from "../../features/relay/session";
+import type { ConversationExtensions } from "../../features/conversation/contracts";
+import { useChannelList, useRelayConnection } from "../../features/relay/react";
+import { PanelFrame } from "../../features/panels/PanelFrame";
+import { MessageRow } from "../../features/messages/MessageRow";
+import { readView, writeView } from "../../shared/view-state";
+import { channelLabel, filterRows, visibleChannels } from "./feed";
+import { usePulseFeed } from "./usePulseFeed";
+import { PulseConversation } from "./PulseConversation";
+import styles from "./Pulse.module.css";
+
+type View = "for-you" | "all" | "search";
+type Selection = { channelId: string; thread?: string | undefined };
+const views = [
+ { id: "search", title: "Search", icon: Search },
+ { id: "for-you", title: "For you", icon: Sparkles },
+ { id: "all", title: "All messages", icon: MessageCircle },
+] as const;
+export function PulsePage({
+ relay,
+ extensions,
+ companion,
+}: {
+ relay: RelayData;
+ extensions?: ConversationExtensions | undefined;
+ companion?: ReactNode;
+}) {
+ const connection = useRelayConnection(relay);
+ return (
+
+ setThread(undefined)}
+ onOpenLink={openLink}
+ />
+
+ ) : (
+ <>
+ {window.status === "error" && !window.rows.length ? (
+
+
+ ) : window.status !== "ready" && !window.rows.length ? (
+ {window.error}
+ ++ Loading messages… +
+ ) : ( +
+
+
+ )}
+ A little closer to what matters.
++ {connection.status === "connecting" + ? "Connecting to your community…" + : "Connect to a community to see your conversations in Pulse."} +
+ {connection.status === "error" && ( + <> +{connection.error}
+ + + )} +
+
+
+ {current ? (
+
+
+
+
+ );
+}
diff --git a/src/bundled/pulse/README.md b/src/bundled/pulse/README.md
new file mode 100644
index 00000000..bead257e
--- /dev/null
+++ b/src/bundled/pulse/README.md
@@ -0,0 +1,83 @@
+# Pulse experiment
+
+A bundled **source page plugin**, independently toggleable in Settings → Plugins.
+This is not a self-contained external API-v1 install artifact. Run this branch of
+buzz-app and choose **Pulse** in the top navigation. Messages is unchanged.
+
+## Design reference
+
+Inspired by [`block/buzz`'s `am-pulse-proto`](https://github.com/block/buzz/tree/2d620055e574f41f466ae13b88cfb0aa77ede068/desktop/src/features/pulse),
+inspected against merge base `cec5c8fd9280d30f56effac701e1e19d5cfe6fea` with main.
+The relevant additions are `UnifiedPulseView`, `PulseConversationSplitView`,
+`PulseBriefing`, and the feature README—not the branch's unrelated mobile,
+identity, agent-recovery, or broader shell changes.
+
+Carried over:
+- A centered 960px rounded canvas, quiet separators, compact 220px conversation
+ navigation, and Search / For you / All messages destinations.
+- Author-led activity with source-conversation links and in-place thread drill-in.
+- Conversation selection independent of feed order; shared, separately scoped
+ channel/thread drafts; responsive navigation and light/dark semantic tokens.
+
+Adapted to buzz-app:
+- The host keeps its own navigation, canvas, appearance and companion launcher.
+- A page owns its React tree and CSS module; no host or `FOUNDATION` file changes.
+- `relay` supplies one existing session. The page creates one bounded observed
+ activity view after the roster is available, disposed on unmount/roster change.
+ No new socket, cache, signer, outbox, polling loop, or model-provider connection.
+- Reuses `ChannelTimeline`, `MessageRow`, `MessageComposer`, `ThreadPanel` and
+ `PanelFrame`. Emoji/Mentions remain optional conversation contributions.
+ Shared message styling is retained rather than copied or overridden with
+ prototype bubble styles. Links keep ordinary external navigation in this pass;
+ only the host companion dock is embedded, not a second local object dock.
+- Session-owned state remounts by scope **and** generation. Navigation and drafts
+ persist under stable scope, not generation. The full roster's membership key
+ participates in missing DM-profile recovery; names never gate conversation reads.
+
+## Honest boundaries
+
+**For you is not an AI briefing.** It filters recent original top-level posts to
+DMs and exact `p`-tag mentions of the viewer. It does not infer requests from prose,
+agent runtime status or unread state. No provider receives messages. buzz-app does
+not currently expose a shared summarization or read-marker capability.
+
+The feed requests 200 recent events across the visible joined roster and shows at
+most 30 conversations, one newest matching root each. Host retained-view limits
+still apply. Busy channels may dominate the window; search covers retained activity,
+not full history. The channel rail remains roster-ordered, not a fabricated activity
+ranking. A partial roster is labeled. Hidden non-DM and archived channels are omitted.
+
+Author edits/deletes use the shared fold. Delivery uncertainty remains visible.
+Feed rows deliberately do not interpret relay thread summaries: the session does
+not expose the signing identity needed to validate those summaries in this page.
+Opening a thread uses the authoritative shared reader and its existing bounded,
+oldest-first history behavior. Selected channel state survives reload; thread
+selection and feed search do not become new URL routes.
+
+## Trying it
+
+From this worktree:
+
+```sh
+bin/just web
+```
+
+For actual community data, use the repository's existing opt-in live setup in
+[README](../../../../README.md#relay-channels), then `BUZZ_LIVE=1 bin/just web`.
+No identity configuration is added by this plugin. Packaged login and native
+acceptance remain the host's existing limitations.
+
+## Checks
+
+- `feed.test.ts`: visible sources, deterministic grouping, author edits/deletes,
+ failed-edit rollback, exact mentions, bounded search and DM names.
+- App composition test: contribution registration, disable and shared-session lifetime.
+- Native catalog test: independent enable/disable flag and reserved bundled identity.
+- `tests/browser/pulse*.spec.mjs`: Chromium/WebKit search, conversation opening,
+ separate retained drafts, thread reader, live source edits, access revocation,
+ plugin unload/re-enable, companion placement, theme and narrow viewport.
+
+Browser fixtures use synthetic signed data; they do not publish to a real relay.
+The lifecycle fixture exercises reply draft composition, not successful publication.
+A full `just scan`, attended live use, final design approval and packaged native
+acceptance are required before calling this ready for integration.
diff --git a/src/bundled/pulse/feed.test.ts b/src/bundled/pulse/feed.test.ts
new file mode 100644
index 00000000..57609e4f
--- /dev/null
+++ b/src/bundled/pulse/feed.test.ts
@@ -0,0 +1,116 @@
+import { expect, it } from "vitest";
+import { keypair, message, signed } from "../../features/relay/testing";
+import { channelLabel, filterRows, pulseRows, visibleChannels } from "./feed";
+import type { ChannelSummary } from "../../features/relay/contracts";
+const user = keypair();
+const channels: ChannelSummary[] = [
+ { id: "a", name: "Design" },
+ { id: "b", name: "B" },
+ {
+ id: "dm",
+ name: "DM",
+ channelType: "dm",
+ hidden: true,
+ participants: [user.pubkey],
+ },
+ { id: "hidden", name: "Hidden", hidden: true },
+ { id: "archived", name: "Archived", archived: true },
+];
+it("uses only visible joined channels and folded roots, with stable chronological ordering", () => {
+ const a = message(user, "a", "First", 1);
+ const b = message(user, "b", "Second", 2);
+ const events = [
+ a,
+ b,
+ message(user, "a", "Reply", 3, [["e", a.id, "", "reply"]]),
+ message(user, "hidden", "Secret", 4),
+ message(user, "archived", "Old", 5),
+ message(user, "unknown", "Unknown", 6),
+ ];
+ expect(visibleChannels(channels).map((c) => c.id)).toEqual(["a", "b", "dm"]);
+ expect(pulseRows(events, channels).map((row) => row.id)).toEqual([
+ b.id,
+ a.id,
+ ]);
+ expect(pulseRows([...events].reverse(), channels)).toEqual(
+ pulseRows(events, channels),
+ );
+});
+it("uses shared edit/delete semantics and preserves delivery uncertainty", () => {
+ const root = message(user, "a", "Before", 1);
+ const edit = signed(user, {
+ kind: 40003,
+ content: "After",
+ created_at: 2,
+ tags: [
+ ["h", "a"],
+ ["e", root.id],
+ ],
+ });
+ expect(pulseRows([root, edit], channels)[0]?.content).toBe("After");
+ expect(
+ pulseRows([root, { ...edit, delivery: "failed" }], channels)[0]?.content,
+ ).toBe("Before");
+ expect(
+ pulseRows(
+ [{ ...root, delivery: "unknown", error: "Timed out" }],
+ channels,
+ )[0],
+ ).toMatchObject({ delivery: "unknown", deliveryError: "Timed out" });
+ const deletion = signed(user, {
+ kind: 5,
+ content: "",
+ tags: [
+ ["h", "a"],
+ ["e", root.id],
+ ],
+ });
+ expect(pulseRows([root, edit, deletion], channels)).toEqual([]);
+ expect(
+ pulseRows(
+ [root],
+ channels.filter((c) => c.id !== "a"),
+ ),
+ ).toEqual([]);
+});
+it("For you uses exact notification identity or DM membership, not prose or invented unread status", () => {
+ const prose = message(user, "a", "@Reader please review", 3);
+ const mention = message(user, "b", "A request", 2, [["p", user.pubkey]]);
+ const dm = message(user, "dm", "Hello", 1);
+ const rows = pulseRows([prose, mention, dm], channels);
+ expect(
+ filterRows(rows, channels, new Map(), "for-you", "", user.pubkey).map(
+ (row) => row.id,
+ ),
+ ).toEqual([mention.id, dm.id]);
+ expect(
+ filterRows(rows, channels, new Map(), "search", "design").map(
+ (row) => row.id,
+ ),
+ ).toEqual([prose.id]);
+});
+it("groups one newest matching source per channel and searches current profile labels", () => {
+ const events = [
+ message(user, "a", "one", 1),
+ message(user, "a", "two", 2),
+ message(user, "dm", "hello", 3),
+ ];
+ const profiles = new Map([[user.pubkey, { name: "Alice" }]]);
+ const rows = pulseRows(events, channels);
+ expect(filterRows(rows, channels, profiles, "all", "")).toHaveLength(2);
+ expect(
+ filterRows(rows, channels, profiles, "search", "one")[0]?.content,
+ ).toBe("one");
+ expect(
+ channelLabel(
+ { id: "dm", name: "DM", channelType: "dm", participants: [user.pubkey] },
+ profiles,
+ ),
+ ).toBe("Alice");
+ expect(
+ channelLabel(
+ { id: "self", name: "Self", channelType: "dm", participants: [] },
+ profiles,
+ ),
+ ).toBe("Notes to self");
+});
diff --git a/src/bundled/pulse/feed.ts b/src/bundled/pulse/feed.ts
new file mode 100644
index 00000000..9c2aa7da
--- /dev/null
+++ b/src/bundled/pulse/feed.ts
@@ -0,0 +1,83 @@
+import type {
+ ChannelSummary,
+ ChannelMessage,
+ Profile,
+} from "../../features/relay/contracts";
+import type { VisibleEvent } from "../../features/relay/projection";
+import { foldMessages } from "../../features/relay/fold";
+
+export function visibleChannels(channels: readonly ChannelSummary[]) {
+ return channels.filter(
+ (channel) =>
+ !channel.archived && (!channel.hidden || channel.channelType === "dm"),
+ );
+}
+export function channelLabel(
+ channel: ChannelSummary,
+ profiles: ReadonlyMap
+
+ YOUR COMMUNITY, AT A GLANCE
+
+
+
+ {title}
+
+ {view === "for-you"
+ ? "Your direct conversations and messages that mention you. Original excerpts, not AI summaries."
+ : view === "search"
+ ? "Find something in the recent activity loaded here."
+ : "A quieter way to catch up. Open a conversation and pick up where it left off."}
+
+ {view === "search" && (
+
+ )}
+
+ {(feed.error || list.status === "error") && (
+
+
+ false}
+ />
+
+
+ );
+ })
+ ) : (
+
+
+ )}
+
+
+ )}
+ {loading && !rows.length ? (
+ + Some activity couldn’t be loaded. This feed may be out of + date. +
+ ++ Gathering recent conversations… +
+ ) : rows.length ? ( + rows.map((row) => { + const channel = channels.find( + (item) => item.id === row.channelId, + ); + if (!channel) return null; + return ( +
+
+
+ )}
+
+ A little quiet here
++ {search + ? "No recent conversations match that search." + : view === "for-you" + ? "No direct conversations or mentions in this recent window." + : "Recent conversations will appear here."} +
+
-
- ) : window.status !== "ready" && !window.rows.length ? (
- {window.error}
- -- Loading messages… -
- ) : ( -
+
+ ) : window.status !== "ready" && !window.rows.length ? (
+ {window.error}
+ ++ Loading messages… +
+ ) : ( +
-
- YOUR COMMUNITY, AT A GLANCE
-
-
+ )}
+ {title}
-
+
+
+
+
+
+ {title}
+
+ {view === "for-you"
+ ? "Recent mentions and direct conversations"
+ : view === "search"
+ ? "Search the recent activity loaded here"
+ : "Recent conversations across your community"}
+
+ {view === "search" && (
+
+ )}
+
+ {pendingOrder && (
-
-
+
- {view === "for-you"
- ? "Your direct conversations and messages that mention you. Original excerpts, not AI summaries."
- : view === "search"
- ? "Find something in the recent activity loaded here."
- : "A quieter way to catch up. Open a conversation and pick up where it left off."}
-
- {view === "search" && (
-
)}
-
- {(feed.error || list.status === "error") && (
-
+
+ open(channel.id, undefined, event.currentTarget)
+ }
+ >
{channel.channelType === "dm"
- ? "Direct conversation"
- : `# ${channelLabel(channel, feed.profiles)}`}
-
- Open conversation ↗
-
- false}
- />
-
-
- );
- })
- ) : (
-
-
- )}
+ ? `DM · ${channelLabel(channel, feed.profiles)}`
+ : `#${channelLabel(channel, feed.profiles)}`}
+
+ }
+ footer={
+
-
- )}
- {loading && !rows.length ? (
- - Some activity couldn’t be loaded. This feed may be out of - date. -
- -- Gathering recent conversations… + {(feed.error || list.status === "error") && ( +
+
-
+ )}
+ {loading && !rows.length ? (
+ + Some activity couldn’t be loaded. This feed may be out of + date.
- ) : rows.length ? ( - rows.map((row) => { - const channel = channels.find( - (item) => item.id === row.channelId, - ); - if (!channel) return null; - return ( -+ Gathering recent conversations… +
+ ) : rows.length ? ( + orderedRows.map((row) => { + const channel = channels.find( + (item) => item.id === row.channelId, + ); + if (!channel) return null; + return ( +
-
-
- )}
-
- A little quiet here
-- {search - ? "No recent conversations match that search." - : view === "for-you" - ? "No direct conversations or mentions in this recent window." - : "Recent conversations will appear here."} -
-
+
+
+
+ }
+ profile={feed.profiles.get(row.authorId)}
+ participantProfiles={feed.profiles}
+ media={session.media}
+ extensions={extensions}
+ day={false}
+ retry={
+ session.outbox ? session.messages.retry : undefined
+ }
+ onOpenLink={() => false}
+ />
+
+ );
+ })
+ ) : (
+
+
+
+ )}
+
+ A little quiet here
++ {search + ? "No recent conversations match that search." + : view === "for-you" + ? "No direct conversations or mentions in this recent window." + : "Recent conversations will appear here."} +
+
{day && (
@@ -69,29 +114,18 @@ export const MessageRow = memo(function MessageRow({
)}
-
- ) => {
- event.currentTarget.focus();
- onOpenLink(target);
- },
- }
- : {})}
- >
- {picture ? (
- 
- ) : (
- name.slice(0, 2).toUpperCase()
- )}
-
+
diff --git a/src/features/messages/Messages.module.css b/src/features/messages/Messages.module.css
index df8bdd2a..b110e90b 100644
--- a/src/features/messages/Messages.module.css
+++ b/src/features/messages/Messages.module.css
@@ -669,3 +669,74 @@ button.avatar:focus-visible,
text-overflow: ellipsis;
white-space: nowrap;
}
+
+/* Optional shared presentation. Default Messages layout is unchanged. */
+.bubbleMessage {
+ gap: 10px;
+ padding: 12px 0;
+ align-items: flex-end;
+}
+.bubbleMessage .avatar {
+ width: 28px;
+ height: 28px;
+ font-size: 10px;
+}
+.bubbleMessage .messageBody {
+ margin-left: 38px;
+ flex: 0 1 auto;
+ max-width: 82%;
+}
+.bubbleMessage .byline {
+ padding: 0 4px;
+ margin-bottom: 6px;
+ gap: 6px;
+ font-size: 12px;
+ line-height: 18px;
+}
+.bubbleMessage .text {
+ width: fit-content;
+ max-width: 100%;
+ margin: 0;
+ padding: 8px 14px;
+ border-radius: 20px;
+ background: var(--surface-control);
+}
+.bubbleAnchor {
+ position: relative;
+ width: fit-content;
+ max-width: 100%;
+}
+.bubbleAnchor .avatar {
+ position: absolute;
+ left: -38px;
+ bottom: 0;
+}
+.outgoing {
+ justify-content: flex-end;
+}
+.outgoing .messageBody {
+ margin-left: 0;
+}
+.outgoing .byline {
+ justify-content: flex-end;
+}
+.outgoing .bubbleAnchor {
+ margin-left: auto;
+}
+.outgoing .text {
+ margin-left: auto;
+ background: var(--primary);
+ color: var(--on-primary);
+}
+.outgoing .text :where(a, h1, h2, h3, h4, h5, h6, blockquote) {
+ color: inherit;
+}
+.outgoing .text :where(code, pre, table) {
+ color: var(--text);
+ background: var(--surface-control);
+}
+.bubbleThread {
+ border: 0;
+ border-radius: 0;
+ box-shadow: none;
+}
diff --git a/src/features/messages/ThreadPanel.tsx b/src/features/messages/ThreadPanel.tsx
index 80a01d32..17dc2f9c 100644
--- a/src/features/messages/ThreadPanel.tsx
+++ b/src/features/messages/ThreadPanel.tsx
@@ -12,13 +12,13 @@ import type { ConversationExtensions } from "../conversation/contracts";
import type { RelaySession } from "../relay/session";
import type { ThreadView } from "../relay/threads";
import { useRowProfiles } from "../relay/react";
-import { MessageRow } from "./MessageRow";
+import { MessageRow, type MessagePresentation } from "./MessageRow";
import { MessageComposer } from "./MessageComposer";
import styles from "./Messages.module.css";
import { useReading } from "./use-reading";
import { messageViewKey } from "./view-key";
-export type ThreadPanelProps = {
+export type ThreadPanelProps = MessagePresentation & {
extensions?: ConversationExtensions | undefined;
session: RelaySession;
scope: string;
@@ -46,6 +46,8 @@ export function ThreadPanel(props: ThreadPanelProps) {
}
function OwnedThreadPanel({
session,
+ presentation,
+ viewer,
extensions,
scope,
channelName,
@@ -77,7 +79,7 @@ function OwnedThreadPanel({
}, [session, channelId, messageId, attempt]);
return (
+ {!bubbles && avatar}
{name}
+ {context}
-
+ {text}
+ {!outgoing && avatar}
+
+ ) : (
+ text
+ )}