From ac1ca888c766711550d38d14e93da18a04f7fdee Mon Sep 17 00:00:00 2001 From: Vitor Pamplona Date: Fri, 17 Jul 2026 16:56:25 -0400 Subject: [PATCH] feat(cli): amy concord import + prior-epoch history read MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit A refounded Concord community (CORD-06 rotates community_root + bumps the epoch) keeps its pre-refounding messages under the prior epoch's derived Chat Plane stream key. The client only ever fetches the current epoch, so older history is invisible and the feed says "All caught up". Add the diagnostics to reach it: - `amy concord import` — fetch this account's own kind-13302 list, decrypt it, and upsert every community WITH its heldRoots (the prior-epoch access roots Amethyst persists across Refoundings). Decrypts against the account identity, not signer.pubKey (which for a bunker is the ephemeral transport key, not the self-encryption peer). - `amy concord read --epoch [--root ]` — read a prior epoch's Chat Plane; the root auto-resolves from the stored heldRoots when --root is omitted. Output includes the epoch + derived plane. - StoredCommunity.heldRoots persistence. Verified live against Soapbox #nostrhub: epoch 0 (a held root) returns 7 messages the app never shows; epoch 2 (current) returns 2 — reproducing the gap and confirming heldRoots-walking recovers the history. Design for the in-app fix (walk heldRoots on the read side) lives in commons/plans/2026-07-17-concord-epoch-walking-backfill.md. Co-Authored-By: Claude Opus 4.8 (1M context) --- .../cli/commands/ConcordChannelCommands.kt | 23 +- .../amethyst/cli/commands/ConcordCommands.kt | 68 ++++- .../amethyst/cli/stores/ConcordStore.kt | 9 + ...26-07-17-concord-epoch-walking-backfill.md | 257 ++++++++++++++++++ 4 files changed, 354 insertions(+), 3 deletions(-) create mode 100644 commons/plans/2026-07-17-concord-epoch-walking-backfill.md diff --git a/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordChannelCommands.kt b/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordChannelCommands.kt index 7c0577670b..3769ef8ba3 100644 --- a/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordChannelCommands.kt +++ b/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordChannelCommands.kt @@ -94,18 +94,37 @@ object ConcordChannelCommands { val limit = args.intFlag("limit", 50) val sc = ConcordStore(dataDir.concordFile).find(handle) ?: return ConcordCommands.notFound(handle) + // Diagnostic overrides (concord-epoch-walking-backfill): read a PRIOR epoch's Chat Plane by + // supplying that epoch's community_root. A Refounding (CORD-06 §3) rotates the root and bumps + // the epoch, so pre-refounding messages live under a different derived stream key that the + // normal read (current epoch only) never fetches. Both derive from the same channel id, which + // is epoch-invariant, so channel resolution stays on the current epoch below. + val epoch = args.longFlag("epoch", sc.rootEpoch) + // Resolve the root for that epoch: explicit --root wins; else the current root if --epoch is + // the current epoch; else a stored heldRoot for that epoch (populated by `amy concord import`). + val rootHex = + args.flag("root") + ?: sc.root.takeIf { epoch == sc.rootEpoch } + ?: sc.heldRoots.firstOrNull { it.epoch == epoch }?.root + ?: return Output + .error("not_found", "no root known for epoch $epoch — pass --root or run `amy concord import` to load heldRoots") + .let { 1 } + if (!HEX64.matches(rootHex)) return Output.error("bad_args", "--root must be a 64-char hex community_root").let { 2 } + Context.open(dataDir).use { ctx -> ctx.prepare() val channelId = resolve(ctx, sc, channelRef) ?: return Output.error("not_found", "no channel '$channelRef'") - val channel = ConcordActions.publicChannel(sc.root.hexToByteArray(), channelId.hexToByteArray(), sc.rootEpoch) + val channel = ConcordActions.publicChannel(rootHex.hexToByteArray(), channelId.hexToByteArray(), epoch) val relays = ConcordCommands.relaysFor(ctx, sc) // The channel plane is NIP-42-gated to its own derived stream key; register it so the drain authenticates. ctx.registerConcordStreamKeys(relays, listOf(channel.secretKey)) val wraps = ctx.drain(relays.associateWith { listOf(ConcordActions.planeFilter(channel.publicKeyHex)) }, pendingOnAuthRequired = true).map { it.second } - val msgs = ConcordActions.channelMessages(wraps, channel, channelId, sc.rootEpoch).takeLast(limit) + val msgs = ConcordActions.channelMessages(wraps, channel, channelId, epoch).takeLast(limit) Output.emit( mapOf( "channel" to channelId, + "epoch" to epoch, + "plane" to channel.publicKeyHex, "count" to msgs.size, "messages" to msgs.map { mapOf("id" to it.id, "author" to it.author, "content" to it.content, "created_at" to it.createdAt) }, ), diff --git a/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordCommands.kt b/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordCommands.kt index ce377b5992..1f7ed423a5 100644 --- a/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordCommands.kt +++ b/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/commands/ConcordCommands.kt @@ -26,8 +26,12 @@ import com.vitorpamplona.amethyst.cli.DataDir import com.vitorpamplona.amethyst.cli.Output import com.vitorpamplona.amethyst.cli.stores.ConcordStore import com.vitorpamplona.amethyst.cli.stores.StoredCommunity +import com.vitorpamplona.amethyst.cli.stores.StoredHeldRoot import com.vitorpamplona.amethyst.commons.actions.ConcordActions +import com.vitorpamplona.quartz.concord.cord02Community.ConcordCommunityList +import com.vitorpamplona.quartz.concord.cord02Community.ConcordCommunityListEvent import com.vitorpamplona.quartz.nip01Core.core.toHexKey +import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl import com.vitorpamplona.quartz.nip01Core.relay.normalizer.RelayUrlNormalizer import com.vitorpamplona.quartz.utils.TimeUtils @@ -45,10 +49,11 @@ object ConcordCommands { route( "concord", tail, - "concord ", + "concord ", mapOf( "create" to { rest -> create(dataDir, rest) }, "list" to { rest -> list(dataDir, rest) }, + "import" to { rest -> import(dataDir, rest) }, "channels" to { rest -> ConcordChannelCommands.channels(dataDir, rest) }, "send" to { rest -> ConcordChannelCommands.send(dataDir, rest) }, "read" to { rest -> ConcordChannelCommands.read(dataDir, rest) }, @@ -117,6 +122,67 @@ object ConcordCommands { return 0 } + /** + * Fetch this account's own encrypted kind-13302 Concord community list, decrypt it, and + * upsert every community into the local store — crucially carrying each community's + * `heldRoots` (the prior-epoch access roots Amethyst accumulates across Refoundings, CORD-06). + * With those persisted, `amy concord read --epoch ` can re-derive a pre-refounding Chat + * Plane. A fresh account (never lived through a Refounding) simply has empty `heldRoots`. + */ + private suspend fun import( + dataDir: DataDir, + @Suppress("UNUSED_PARAMETER") rest: Array, + ): Int { + Context.open(dataDir).use { ctx -> + ctx.prepare() + val relays = (ctx.outboxRelays() + ctx.bootstrapRelays()) + // Filter by the ACCOUNT identity, not ctx.signer.pubKey — for a bunker the signer's pubKey + // is the ephemeral NIP-46 transport key, not the user's identity. + val filter = Filter(kinds = listOf(ConcordCommunityListEvent.KIND), authors = listOf(ctx.identity.pubKeyHex)) + val events = ctx.drain(relays.associateWith { listOf(filter) }).map { it.second } + val newest = + events.filterIsInstance().maxByOrNull { it.createdAt } + ?: return Output.error("not_found", "no kind-13302 Concord list published by this account").let { 1 } + + // Decrypt with the ACCOUNT identity as the NIP-44 self-peer. `newest.decrypt(signer)` uses + // `signer.pubKey`, which for a bunker is the ephemeral transport key, not the identity the + // list is self-encrypted to — so decrypt manually against ctx.identity.pubKeyHex. + val entries = + try { + ConcordCommunityList.decode(ctx.signer.nip44Decrypt(newest.content, ctx.identity.pubKeyHex)) + } catch (e: Exception) { + return Output.error("decrypt_failed", "could not decrypt kind-13302: ${e.message}").let { 1 } + } + val store = ConcordStore(dataDir.concordFile) + val existing = store.load().associateBy { it.communityId } + val imported = + entries.map { e -> + val prior = existing[e.id] + store.upsert( + StoredCommunity( + name = e.name.ifBlank { prior?.name ?: "" }, + communityId = e.id, + owner = e.owner, + ownerSalt = e.ownerSalt, + root = e.root, + rootEpoch = e.rootEpoch, + generalChannelId = prior?.generalChannelId ?: "", + relays = e.relays, + heldRoots = e.heldRoots.map { StoredHeldRoot(it.epoch, it.key) }, + ), + ) + mapOf( + "name" to e.name, + "community_id" to e.id, + "root_epoch" to e.rootEpoch, + "held_roots" to e.heldRoots.map { mapOf("epoch" to it.epoch, "root" to it.key) }, + ) + } + Output.emit(mapOf("imported" to imported)) + return 0 + } + } + private suspend fun invite( dataDir: DataDir, rest: Array, diff --git a/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/stores/ConcordStore.kt b/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/stores/ConcordStore.kt index 95cfb90f22..379dc44b83 100644 --- a/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/stores/ConcordStore.kt +++ b/cli/src/main/kotlin/com/vitorpamplona/amethyst/cli/stores/ConcordStore.kt @@ -39,6 +39,15 @@ data class StoredCommunity( val rootEpoch: Long = 0, val generalChannelId: String = "", val relays: List = emptyList(), + // Past access roots kept per epoch (CORD-06 Refounding rotates the root). Lets `read --epoch ` + // re-derive a prior epoch's Chat Plane to reach pre-refounding history. Populated by `import`. + val heldRoots: List = emptyList(), +) + +/** A past community_root for a specific epoch, mirroring quartz `HeldRoot`. */ +data class StoredHeldRoot( + val epoch: Long = 0, + val root: String = "", ) /** diff --git a/commons/plans/2026-07-17-concord-epoch-walking-backfill.md b/commons/plans/2026-07-17-concord-epoch-walking-backfill.md new file mode 100644 index 0000000000..ec18d79865 --- /dev/null +++ b/commons/plans/2026-07-17-concord-epoch-walking-backfill.md @@ -0,0 +1,257 @@ +# Concord epoch-walking message backfill + +**Date:** 2026-07-17 +**Module:** `commons` (drivers), with `quartz` primitives (present) + `amethyst` wiring +**Status:** design / not started + +## Problem + +A Concord community that has been **refounded** (CORD-06 §3 — hard removal +rotates `community_root` and bumps the epoch) loses all of its pre-refounding +chat history from the client's view. Every channel message is encrypted under a +plane stream key derived from the *root at the epoch it was authored under* +(`publicChannel(community_root, channel_id, rootEpoch)`), and the message carries +an `["epoch", n]` tag so cross-epoch replay is rejected +(`ChannelChat.isBoundTo`). The client only ever derives, subscribes to, AUTHs +as, and decrypts the plane at the **single current** `entry.rootEpoch`. So after +a refounding the feed shows only messages authored since that refounding, then +reports **"All caught up"** — which is literally correct *for the current +epoch*, while months of history sit on the same relays under the previous +epochs' stream keys, unfetched. + +### Reproduced live (2026-07-17, `amy` vs the real Soapbox Community) + +Joined the Armada invite and probed `relay.ditto.pub` + `relay.dreamith.to`: + +| Fact | Value | +|---|---| +| `rootEpoch` (from invite bundle) | **2** — refounded ≥ once | +| nostrhub @ epoch 2 | 2 messages, both authored **2026-07-17** | +| general @ epoch 2 | 62 messages, **oldest 2026-07-16** | +| ditto @ epoch 2 | 4 messages, **oldest 2026-07-16** | +| agora @ epoch 2 | 3 messages, **oldest 2026-07-16** | + +Every channel's history begins on 2026-07-16 (the refounding date). The app's +"only 2 messages in nostrhub" reproduces exactly through the CLI. Not a relay, +AUTH, or paging-cap issue — a structural epoch gap. + +## Key finding: prior roots are already retained but never consumed + +The hard part — keeping the old keys — **is already done**: + +- `ConcordCommunityListEntry.heldRoots: List` + (`quartz/.../cord02Community/ConcordCommunityList.kt:31,60`, wire field + `held_roots`). `HeldRoot`'s own KDoc: *"A past root key for a specific epoch, + kept so historical channel keys stay derivable."* +- `Account.adoptConcordRoot` (`amethyst/.../model/Account.kt:2513`) appends the + outgoing `(rootEpoch, root)` to `heldRoots` on **every** rotation — both the + refounder path (`refoundConcordCommunity`) and the receive path + (`drainConcordRekeys` → `openBaseRekey`). It is persisted to the account's + Concord list event. + +But a repo-wide grep confirms **no code in the fetch / fold / subscribe path +ever reads `heldRoots`.** `ConcordCommunitySession`, `ConcordSessionRegistry`, +`ConcordSubscriptionPlanner`, and the amethyst filter assemblers all derive +planes solely from `entry.rootEpoch` / `entry.root`. The retained roots are dead +data. **This plan is almost entirely about consuming `heldRoots` on the read +side** — the retention infrastructure the feature needs already exists. + +### Scope boundary — who this helps + +- **Members present across the refoundings** (have populated `heldRoots`): can + fully backfill. Primary target. +- **Fresh joiners via an invite** (empty `heldRoots`; the invite bundle carries + only the current root): **cryptographically cannot** decrypt prior-epoch + history — they were never given those roots, and the relays gate each epoch's + kind-1059 behind AUTH-as-that-epoch's-stream-key. This is by design (a + refounding is meant to sever access) and is **out of scope**. We must not try + to work around it by stuffing old roots into invites — that would hand a + brand-new member the keys a removal was meant to deny. If cross-refounding + history for new joiners is ever wanted, it's a *protocol* change (Armada would + re-publish compacted history under the new root), tracked separately. + +## Design + +`ConcordCommunitySession` is documented as "a pure function of its entry" and is +rebuilt wholesale on rotation (`ConcordSessionRegistry.sync` replaces it when +`root`/`rootEpoch` changes). Two ways to add historical epochs: + +- **(A) Generalize the session to be multi-epoch** — derive a plane key set per + `(epoch, root)` in `{current} ∪ heldRoots`, index buffered wraps and decrypt + attempts across all of them. +- **(B) Keep the current-epoch session as-is (live + write) and attach + read-only "historical epoch readers"** — one lightweight derivation set per + held root, contributing subscribe addresses + AUTH keys + decrypt attempts, + but never used for writing/moderation/rekey. + +**Recommend (B).** Writes, moderation, control-plane folding, rekey adoption, +and Guestbook all must stay strictly on the current epoch — mixing historical +roots into those paths risks authoring under a stale key or re-folding a +superseded control plane. A read-only historical layer keeps the blast radius to +message fetch/decrypt. The channel id is **epoch-invariant** (`ConcordChannelKeys` +KDoc: "stays constant across visibility conversions and epoch rotations"), so a +decrypted historical message lands in the *same* channel feed as current ones — +no feed-merge logic needed; `LocalCache`/the gatherer keys on channel id. + +### New concept: `EpochPlaneSet` + +A small value type: for one `(epoch, root)`, derive the control-plane key and, +given the current folded channel-id list, the per-channel `publicChannel` keys. +The current epoch already computes this inline in `ConcordCommunitySession`; +factor the derivation into a reusable helper so current + historical share it. + +> Channel *membership* comes from folding the **current** control plane (channels +> aren't re-listed per epoch). We assume the channel-id set is stable across the +> covered epochs (channels created after an old epoch simply have no messages +> there → empty, harmless). Deleted/renamed channels: the id persists, so old +> messages still decrypt. Private channels: use `entry.privateChannels` +> (`PrivateChannelKey` already carries a per-`epoch` key) instead of the root. + +## Component-by-component changes + +### 1. `quartz` — none required (primitives already exist) +`ConcordActions.publicChannel/controlPlane/channelRumors/channelMessages` and +`ChannelChat.isBoundTo` already take an explicit `epoch`. Reuse verbatim. + +### 2. `commons/.../model/concord/ConcordCommunitySession.kt` +- Build historical `EpochPlaneSet`s from `entry.heldRoots` (bounded — see + §Bounding) alongside the existing current-epoch derivation. +- `channelAddresses()` → also emit each historical channel plane pubkey so the + planner subscribes to them. +- `streamKeys()` → include historical control + channel `GroupKey`s so the + NIP-42 AUTH set authenticates as each prior epoch's stream key (this is what + unlocks the gated relays for old wraps). Keep the aux (Guestbook / next-rekey) + isolation rule intact. +- `ingest(wrap)` → currently matches a wrap by its plane address against the + current-epoch address map. Extend the address→(channelId, key, **epoch**) map + to include historical entries; on match, decrypt with that epoch's key and + validate `isBoundTo(rumor, channelId, thatEpoch)`. Emit the rumor exactly as + today (same `onRumor` sink → same channel feed). +- Historical wraps feed `observedAuthors` too — a nice side effect: the member + roster harvest gets the full-history posters for free. +- Do **not** route historical wraps into `refold()` (control plane), + `refoldGuestbook()`, or rekey buffers — read path only. + +### 3. `commons/.../model/concord/ConcordSessionRegistry.kt` +`subscribeAddresses()` already unions `session.channelAddresses()`; once the +session emits historical addresses it flows through unchanged. Verify no other +call site assumes one-address-per-channel. + +### 4. `commons/.../actions/ConcordSubscriptionPlanner.kt` +`channelPlaneSubs()` derives `publicChannel(root, channelId, entry.rootEpoch)`. +Generalize to emit a plane sub per `(channel, epoch)` across the covered epoch +set, collapsed into the existing `{kinds:[1059,21059], authors:[…]}` batching in +`relayBasedFilters()`. The historical subs can be one-shot (no live tail needed — +old epochs are frozen), so consider a bounded `until`-less REQ that EOSEs rather +than a standing subscription, to cap connection cost. + +### 5. `amethyst/.../concord/datasource/` filter assemblers +- `ConcordChannelHistoryFilterAssembler` (`BackwardRelayPager`) — today pages one + plane pubkey (`session.channelPlaneAddress(channelId)`, current epoch). The + pager must **step to the previous epoch's plane pubkey when the current epoch + is exhausted** rather than declaring `PagingStatus.exhausted`. Options: + (a) page all epoch planes concurrently and only report exhausted when every + epoch's relays are done; (b) sequential — walk newest→oldest epoch. (a) is + simpler to reason about with the existing per-(uniqueId,relay) EOSE tracking; + (b) gives cleaner "load older" UX. Prefer (a). +- `ConcordChannelFilterAssembler` (live tail) — historical planes need no live + tail; only the current epoch keeps a standing sub. +- **"All caught up"** (`ConcordChannelScreen.kt:199` on `historyStatus.exhausted`) + becomes correct once exhaustion means "all covered epochs drained," not "the + current epoch drained." + +### 6. AUTH — register historical stream keys +`ConcordSessionManager.streamAuthSecretsFor(relay)` derives from +`session.streamKeys()`; once that includes historical keys, `AuthCoordinator` +signs one kind-22242 per prior-epoch stream key and the gated relays serve the +old wraps. Watch the `RelayAuthStatus` LruCache size (widened 10→200 for the +current-epoch multi-identity work) — N epochs × M channels can exceed 200; size +it to `epochs × (channels + 1)` with headroom. + +### 7. `cli` — diagnostics (`ConcordChannelCommands.read`) — **DONE** +`StoredCommunity` has no `heldRoots`, and a fresh `amy concord join` can't obtain +them — so amy can't self-serve a member's history. Landed: +- `amy concord read --epoch --root ` — derives the + Chat Plane at an explicitly supplied `(epoch, root)` and drains it (both flags + default to the stored current epoch/root; channel-id resolution stays on the + current epoch since ids are epoch-invariant). Output now also emits `epoch` and + the derived `plane` pubkey. Verified: explicit `--epoch 2 --root ` + reproduces the stored plane pubkey byte-for-byte; each epoch derives a distinct + plane; a non-hex `--root` errors `bad_args`/exit 2. Confirms old-epoch wraps can + be probed once a prior root is known. +- **DONE:** `StoredCommunity.heldRoots` + `amy concord import` — fetches this + account's own encrypted kind-13302 `ConcordCommunityListEvent`, decrypts it + with the account signer, and upserts every community **including its + `heldRoots`** (the prior-epoch access roots Amethyst persists in that same + published event via `Account.adoptConcordRoot`). `read --epoch ` then + auto-resolves the root for that epoch from the stored `heldRoots` (explicit + `--root` still wins). So a member who lived through the Refoundings can: + `amy concord import` → `amy concord read --epoch ` + and reach pre-refounding history without knowing the raw prior roots. A fresh + account simply imports empty `heldRoots` (nothing to recover — the expected + cryptographic wall). Import + decrypt are **read-only** (no publish). + +## Bounding (cost control) + +Each covered epoch multiplies the subscription/AUTH footprint by +`(channels + 1)` stream keys. Bound it: +- **Config:** `CONCORD_BACKFILL_EPOCHS` (default: all held — the list is small in + practice; refoundings are rare). If a community is refounded often, cap to the + N most recent held epochs. +- **Time window:** the member-roster harvest already bounds to + `now − 90d` (`ConcordMemberHarvest`, `CONCORD_MEMBER_HARVEST_WINDOW_SECS`). + The *interactive* channel backfill should be user-driven (paged on scroll, no + `since` floor) so a member can reach the true beginning; the *background* + harvest keeps its window. +- Historical planes are frozen → prefer one-shot EOSE REQs over standing subs to + avoid holding N× subscriptions open forever. + +## Testing + +- **quartz** — none new (primitives unchanged); existing epoch/`isBoundTo` tests + cover the binding. +- **commons unit** (`ConcordCommunitySessionTest`, `ConcordSubscriptionPlannerTest`, + `ConcordSessionRegistryTest`): + - Build an entry with `heldRoots = [(epoch0,rootA),(epoch1,rootB)]`, current + epoch 2/rootC. Assert `channelAddresses()`/`streamKeys()`/planner subs emit + a plane per `(channel, epoch)` across all three. + - Feed the session wraps authored under each historical key; assert the rumor + is decrypted with the *matching* epoch key, `isBoundTo` passes, and it + reaches the `onRumor` sink; a wrap whose epoch tag ≠ its plane epoch is + dropped. + - Assert historical wraps do **not** enter `refold()`/control state. +- **commons paging** (`BackwardRelayPagerTest`): a multi-epoch channel reports + `exhausted` only after every epoch's relays EOSE on an empty page. +- **Live, via `amy`**: use the new `--epoch/--root` diag against Soapbox once a + prior Soapbox root is available (ask maintainer / capture from an account that + lived through the refounding) → confirm epoch-1 nostrhub wraps decrypt. + +## Risks / open questions + +1. **Fresh joiners still see nothing pre-refounding** — inherent, documented + above. UI could show a "History before requires having been a member" + affordance instead of a bare "All caught up," so it doesn't read as a bug. +2. **AUTH fan-out on gated relays** — N epochs × M channels AUTH events on one + connection. Current-epoch work already accumulates multiple identities on one + connection successfully; validate it scales (LruCache sizing, relay + per-connection AUTH limits). Fall back to bounding epochs if a relay balks. +3. **`heldRoots` completeness** — only populated from the moment the account + started adopting rotations. A member who joined at epoch 2 has no epoch-0/1 + roots even if present later; nothing to do — same cryptographic limit. +4. **Private channels across epochs** — `PrivateChannelKey.epoch` exists, but + verify a private channel's key was actually re-delivered per epoch (rotated on + revocation); if a member missed an epoch's private key, that epoch of that + channel is unreadable (expected). +5. **Standing-sub vs one-shot for history** — decide before wiring the planner; + affects connection budget on the audio-room-heavy relay set. + +## Suggested sequence + +1. Factor `EpochPlaneSet` derivation + make `ConcordCommunitySession` emit + historical addresses/keys/decrypt (commons unit-tested in isolation — no + network). Ship behind a flag defaulting off. +2. Planner + AUTH wiring; commons tests. +3. amethyst `BackwardRelayPager` epoch-stepping + "All caught up" semantics. +4. ~~`amy --epoch/--root` diagnostic~~ **DONE** (§7); still need a real prior + Soapbox root to validate old-epoch decrypt end-to-end. +5. Flip the flag on; on-device verify on a refounded community.