radrootsd

commit 29c84cbaf982645f154a40a0592c241e5a729d10
parent 3b2369d9e7c0aac18c1e4c60f99e044d78c5d4d2
Author: triesap <triesap@radroots.dev>
Date:   Sun,  4 Jan 2026 03:37:05 +0000

events: flatten plot event response

- Replace flattened event view with explicit row fields
- Extract plot parsing into helper for reuse
- Sort plots by created_at on flattened row
- Update tests to assert against flattened row fields

Diffstat:
M
src/api/jsonrpc/methods/events/plot/list.rs
 | 
48
++++++++++++++++++++++++++++++++----------------

1 file changed, 32 insertions(+), 16 deletions(-)
diff --git a/src/api/jsonrpc/methods/events/plot/list.rs b/src/api/jsonrpc/methods/events/plot/list.rs
@@ -3,7 +3,7 @@ use jsonrpsee::server::RpcModule;
 use serde::Serialize;
 use std::time::Duration;
 
-use crate::api::jsonrpc::nostr::{event_tags, event_view_with_tags, NostrEventView};
+use crate::api::jsonrpc::nostr::{event_tags, event_view_with_tags};
 use crate::api::jsonrpc::params::{
     apply_time_bounds,
     limit_or,
@@ -22,18 +22,23 @@ use radroots_nostr::prelude::{
 };
 
 #[derive(Clone, Debug, Serialize)]
-struct PlotEventFlat {
-    #[serde(flatten)]
-    event: NostrEventView,
+struct PlotRow {
+    id: String,
+    author: String,
+    created_at: u64,
+    kind: u32,
+    tags: Vec<Vec<String>>,
+    content: String,
+    sig: String,
     plot: Option<RadrootsPlot>,
 }
 
 #[derive(Clone, Debug, Serialize)]
 struct PlotListResponse {
-    plots: Vec<PlotEventFlat>,
+    plots: Vec<PlotRow>,
 }
 
-fn build_plot_rows<I>(events: I) -> Vec<PlotEventFlat>
+fn build_plot_rows<I>(events: I) -> Vec<PlotRow>
 where
     I: IntoIterator<Item = RadrootsNostrEvent>,
 {
@@ -41,18 +46,29 @@ where
         .into_iter()
         .map(|ev| {
             let tags = event_tags(&ev);
-            let kind = ev.kind.as_u16() as u32;
-            let plot = plot_from_event(kind, &tags, &ev.content).ok();
-            PlotEventFlat {
-                event: event_view_with_tags(&ev, tags),
+            let plot = parse_plot_event(&ev, &tags);
+            let event = event_view_with_tags(&ev, tags);
+            PlotRow {
+                id: event.id,
+                author: event.author,
+                created_at: event.created_at,
+                kind: event.kind,
+                tags: event.tags,
+                content: event.content,
+                sig: event.sig,
                 plot,
             }
         })
         .collect::<Vec<_>>();
-    items.sort_by(|a, b| b.event.created_at.cmp(&a.event.created_at));
+    items.sort_by(|a, b| b.created_at.cmp(&a.created_at));
     items
 }
 
+fn parse_plot_event(event: &RadrootsNostrEvent, tags: &[Vec<String>]) -> Option<RadrootsPlot> {
+    let kind = event.kind.as_u16() as u32;
+    plot_from_event(kind, tags, &event.content).ok()
+}
+
 pub fn register(m: &mut RpcModule<RpcContext>, registry: &MethodRegistry) -> Result<()> {
     registry.track("events.plot.list");
     m.register_async_method("events.plot.list", |params, ctx, _| async move {
@@ -157,10 +173,10 @@ mod tests {
         let plots = build_plot_rows(vec![older, newer]);
 
         assert_eq!(plots.len(), 2);
-        assert_eq!(plots[0].event.id, new_id);
-        assert_eq!(plots[0].event.created_at, 200);
-        assert_eq!(plots[1].event.id, old_id);
-        assert_eq!(plots[1].event.created_at, 100);
+        assert_eq!(plots[0].id, new_id);
+        assert_eq!(plots[0].created_at, 200);
+        assert_eq!(plots[1].id, old_id);
+        assert_eq!(plots[1].created_at, 100);
     }
 
     #[test]
@@ -176,7 +192,7 @@ mod tests {
         let plots = build_plot_rows(vec![event]);
 
         assert_eq!(plots.len(), 1);
-        assert_eq!(plots[0].event.tags, tags);
+        assert_eq!(plots[0].tags, tags);
         let parsed = plots[0].plot.as_ref().expect("plot");
         assert_eq!(parsed.d_tag, "plot-1");
         assert_eq!(parsed.farm.pubkey, pubkey);