feat(p2p): export P2PStatusInfo and DrainStatusInfo via ts-rs

The seeder's wait-for-drain helper previously hand-rolled the
P2PStatusInfo / DrainStatusInfo interfaces locally -- exactly the
kind of type-drift source the project has been burned by before.

Adds TS derives to P2PStatusInfo, DrainStatusInfo, and
ReplicationStatus so cargo test export_bindings generates canonical
TypeScript types into the storage-client-ts sdk. Seeder now imports
from the generated bindings instead of declaring its own.

P2PStatusInfo intentionally keeps snake_case on the wire because
multiple existing consumers (doorway federation/main/server routes,
elohim-app connection-indicator, simulate.sh, genesis Jenkinsfile)
already read snake_case field names from /p2p/status. Adding
rename_all = "camelCase" would have been a breaking wire change
for a polish commit. ts-rs emits the TypeScript type with snake_case
field names to match. DrainStatusInfo and ReplicationStatus keep
their existing camelCase (all their fields are single-word anyway).

usize fields on P2PStatusInfo and ReplicationStatus use
#[ts(type = "number")] to avoid the ts-rs bigint trap -- peer and
row counts here fit comfortably in a JS number.

Also fixes a latent bug in wait-for-drain: the log line referenced
status.connectedPeers, but the wire format is connected_peers, so
the peers suffix never rendered. Now uses the correct field.

Seeder @elohim/storage-client dependency flipped from "^0.1.0" to
"workspace:*" so pnpm actually resolves it from the monorepo workspace
instead of whatever registry snapshot was pinned. Without this the
new generated types would never reach the seeder's node_modules.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: Mbd06b

elohim/elohim-storage/src/p2p/mod.rs

@@ -47,6 +47,7 @@ use libp2p::{
     tcp, yamux, Multiaddr, PeerId, SwarmBuilder,
 };
 use serde::Serialize;
+use ts_rs::TS;
 use sha2::{Digest, Sha256};
 use std::sync::Arc;
 use std::time::Duration;
@@ -219,8 +220,9 @@ pub struct P2PNode {
 /// Drain queue observability. Exposed via `P2PStatusInfo` so other peers can
 /// judge how busy/overloaded this node is and potentially route around it
 /// — not just for the local seeder's drain-complete check.
-#[derive(Debug, Clone, Serialize, Default)]
+#[derive(Debug, Clone, Serialize, Default, TS)]
 #[serde(rename_all = "camelCase")]
+#[ts(export, export_to = "../../sdk/storage-client-ts/src/generated/")]
 pub struct DrainStatusInfo {
     /// Total rows in the local content projection (scoped to lamad app).
     pub total: i32,
@@ -230,17 +232,28 @@ pub struct DrainStatusInfo {
     pub pending: i32,
 }
 
-/// P2P node status for observability
-#[derive(Debug, Clone, Serialize)]
+/// P2P node status for observability.
+///
+/// NOTE: This struct intentionally does NOT use `rename_all = "camelCase"`
+/// because the wire format on `/p2p/status` has historically been snake_case
+/// and multiple consumers (doorway federation/main/server, elohim-app
+/// connection-indicator, simulate.sh, genesis Jenkinsfile) read snake_case
+/// field names. ts-rs will emit snake_case field names in the generated
+/// TypeScript type, preserving backward compatibility.
+#[derive(Debug, Clone, Serialize, TS)]
+#[ts(export, export_to = "../../sdk/storage-client-ts/src/generated/")]
 pub struct P2PStatusInfo {
     pub peer_id: String,
     pub listen_addresses: Vec<String>,
+    #[ts(type = "number")]
     pub connected_peers: usize,
     pub bootstrap_nodes: Vec<String>,
+    #[ts(type = "number")]
     pub sync_documents: usize,
     /// NAT status detected by autonat: "Unknown", "Public", "Private"
     pub nat_status: String,
     /// Number of active relay reservations
+    #[ts(type = "number")]
     pub relay_reservations: usize,
     /// Addresses announced to the network
     pub announce_addresses: Vec<String>,

elohim/elohim-storage/src/p2p/replication.rs

@@ -7,16 +7,21 @@ use serde::Serialize;
 use std::collections::{HashMap, HashSet};
 use std::sync::Arc;
 use tokio::sync::RwLock;
+use ts_rs::TS;
 
 /// Replication progress exposed via /p2p/status
-#[derive(Debug, Clone, Default, Serialize)]
+#[derive(Debug, Clone, Default, Serialize, TS)]
 #[serde(rename_all = "camelCase")]
+#[ts(export, export_to = "../../sdk/storage-client-ts/src/generated/")]
 pub struct ReplicationStatus {
     /// Content IDs discovered but not yet fetched
+    #[ts(type = "number")]
     pub pending: usize,
     /// Content IDs successfully replicated
+    #[ts(type = "number")]
     pub completed: usize,
     /// Content IDs that failed fetch (will retry)
+    #[ts(type = "number")]
     pub failed: usize,
     /// True when all discovered content has been fetched or failed with max retries
     pub caught_up: bool,

elohim/sdk/storage-client-ts/src/generated/DrainStatusInfo.ts

@@ -0,0 +1,20 @@
+// This file was generated by [ts-rs](https://github.com/Aleph-Alpha/ts-rs). Do not edit this file manually.
+
+/**
+ * Drain queue observability. Exposed via `P2PStatusInfo` so other peers can
+ * judge how busy/overloaded this node is and potentially route around it
+ * — not just for the local seeder's drain-complete check.
+ */
+export type DrainStatusInfo = { 
+/**
+ * Total rows in the local content projection (scoped to lamad app).
+ */
+total: number, 
+/**
+ * Rows that have been successfully published to the libp2p Kad DHT.
+ */
+published: number, 
+/**
+ * Rows not yet drained. When this is 0 and stable, drain is caught up.
+ */
+pending: number, };

elohim/sdk/storage-client-ts/src/generated/P2PStatusInfo.ts

@@ -0,0 +1,41 @@
+// This file was generated by [ts-rs](https://github.com/Aleph-Alpha/ts-rs). Do not edit this file manually.
+import type { DrainStatusInfo } from "./DrainStatusInfo";
+import type { ReplicationStatus } from "./ReplicationStatus";
+
+/**
+ * P2P node status for observability.
+ *
+ * NOTE: This struct intentionally does NOT use `rename_all = "camelCase"`
+ * because the wire format on `/p2p/status` has historically been snake_case
+ * and multiple consumers (doorway federation/main/server, elohim-app
+ * connection-indicator, simulate.sh, genesis Jenkinsfile) read snake_case
+ * field names. ts-rs will emit snake_case field names in the generated
+ * TypeScript type, preserving backward compatibility.
+ */
+export type P2PStatusInfo = { peer_id: string, listen_addresses: Array<string>, connected_peers: number, bootstrap_nodes: Array<string>, sync_documents: number, 
+/**
+ * NAT status detected by autonat: "Unknown", "Public", "Private"
+ */
+nat_status: string, 
+/**
+ * Number of active relay reservations
+ */
+relay_reservations: number, 
+/**
+ * Addresses announced to the network
+ */
+announce_addresses: Array<string>, 
+/**
+ * Relay mode this node is running in
+ */
+relay_mode: string, 
+/**
+ * Replication progress for identity-driven content sync
+ */
+replication: ReplicationStatus, 
+/**
+ * Drain queue state — None when the DB pool or query is unavailable.
+ * Consumers should treat None as "data not available" (e.g., wait or
+ * avoid using this peer as a load signal), NOT as "caught up".
+ */
+drain: DrainStatusInfo | null, };

elohim/sdk/storage-client-ts/src/generated/ReplicationStatus.ts

@@ -0,0 +1,22 @@
+// This file was generated by [ts-rs](https://github.com/Aleph-Alpha/ts-rs). Do not edit this file manually.
+
+/**
+ * Replication progress exposed via /p2p/status
+ */
+export type ReplicationStatus = { 
+/**
+ * Content IDs discovered but not yet fetched
+ */
+pending: number, 
+/**
+ * Content IDs successfully replicated
+ */
+completed: number, 
+/**
+ * Content IDs that failed fetch (will retry)
+ */
+failed: number, 
+/**
+ * True when all discovered content has been fetched or failed with max retries
+ */
+caughtUp: boolean, };

elohim/sdk/storage-client-ts/src/generated/index.ts

@@ -108,6 +108,7 @@ export * from "./DignityFloorView";
 export * from "./DiscussionView";
 export * from "./DistributionPlanView";
 export * from "./DistributionRequestView";
+export * from "./DrainStatusInfo";
 export * from "./EconomicEvent";
 export * from "./EconomicEventView";
 export * from "./ExcessSupply";
@@ -157,6 +158,7 @@ export * from "./OrganizationContextView";
 export * from "./OsmElementType";
 export * from "./OsmReference";
 export * from "./OwnedNodeView";
+export * from "./P2PStatusInfo";
 export * from "./PackageManifestView";
 export * from "./ParticipantPositionView";
 export * from "./PlaceDashboardEntry";
@@ -184,6 +186,7 @@ export * from "./RelationshipSeedView";
 export * from "./RelationshipView";
 export * from "./RelationshipWithContent";
 export * from "./RelationshipWithContentView";
+export * from "./ReplicationStatus";
 export * from "./ReportCustodianMetricsInputView";
 export * from "./ResourceNature";
 export * from "./RespondToChallengeInputView";

genesis/seeder/package.json

@@ -51,7 +51,7 @@
     "test:watch": "vitest"
   },
   "dependencies": {
-    "@elohim/storage-client": "^0.1.0",
+    "@elohim/storage-client": "workspace:*",
     "@holochain/client": "^0.20.1",
     "multiformats": "^13.4.1",
     "ws": "^8.16.0"

genesis/seeder/src/wait-for-drain.ts

@@ -26,19 +26,7 @@
  * resulting observable state.
  */
 
-interface DrainStatus {
-  total: number;
-  published: number;
-  pending: number;
-}
-
-interface P2pStatus {
-  // Only the fields the seeder cares about. The full P2PStatusInfo has
-  // more (peerId, listenAddresses, natStatus, relayMode, etc.) but those
-  // are not load-bearing for drain-completion detection.
-  drain: DrainStatus | null;
-  connectedPeers?: number;
-}
+import type { DrainStatusInfo, P2PStatusInfo } from '@elohim/storage-client';
 
 export interface WaitForDrainOptions {
   /** Total wait budget before throwing. Default: 5 minutes. */
@@ -63,7 +51,7 @@ export interface WaitForDrainOptions {
 export async function waitForDrain(
   baseUrl: string,
   options: WaitForDrainOptions = {},
-): Promise<DrainStatus> {
+): Promise<DrainStatusInfo> {
   const timeoutMs = options.timeoutMs ?? 5 * 60_000;
   const pollIntervalMs = options.pollIntervalMs ?? 2_000;
   const expectedMinTotal = options.expectedMinTotal ?? 1;
@@ -74,7 +62,7 @@ export async function waitForDrain(
   const deadline = Date.now() + timeoutMs;
   let lastLoggedPending = -1;
   let consecutiveFetchErrors = 0;
-  let lastSeenDrain: DrainStatus | null = null;
+  let lastSeenDrain: DrainStatusInfo | null = null;
   let sawNonNullDrain = false;
 
   console.log(
@@ -96,7 +84,7 @@ export async function waitForDrain(
         }
       } else {
         consecutiveFetchErrors = 0;
-        const status = (await resp.json()) as P2pStatus;
+        const status = (await resp.json()) as P2PStatusInfo;
 
         if (status.drain === null || status.drain === undefined) {
           // Broken node signal — do NOT treat as "done".
@@ -108,8 +96,8 @@ export async function waitForDrain(
           // Only log when progress changes, to keep pipeline output readable.
           if (pending !== lastLoggedPending) {
             const peersSuffix =
-              status.connectedPeers !== undefined
-                ? ` (connectedPeers=${status.connectedPeers})`
+              status.connected_peers !== undefined
+                ? ` (connectedPeers=${status.connected_peers})`
                 : '';
             console.log(
               `waitForDrain: ${published}/${total} published, ${pending} pending${peersSuffix}`,