From 8d8751655f1fbf990244d53fe0110731c68da07a Mon Sep 17 00:00:00 2001
From: Sebastian Martinez <me@sebastinez.dev>
Date: Mon, 15 May 2023 20:54:19 +0200
Subject: [PATCH] cli: Add `rad node events` command

Allows third party implementations to listen to the event stream of a
node.

In case of a serialization error we exit the event subscription and end
the process.

Signed-off-by: Sebastian Martinez <me@sebastinez.dev>
---
 radicle-cli/src/commands/node.rs        | 11 +++++++++++
 radicle-cli/src/commands/node/events.rs | 14 ++++++++++++++
 2 files changed, 25 insertions(+)
 create mode 100644 radicle-cli/src/commands/node/events.rs

diff --git a/radicle-cli/src/commands/node.rs b/radicle-cli/src/commands/node.rs
index df89d539..14a71156 100644
--- a/radicle-cli/src/commands/node.rs
+++ b/radicle-cli/src/commands/node.rs
@@ -9,6 +9,8 @@ use crate::terminal::args::{Args, Error, Help};
 
 #[path = "node/control.rs"]
 mod control;
+#[path = "node/events.rs"]
+mod events;
 #[path = "node/routing.rs"]
 mod routing;
 #[path = "node/tracking.rs"]
@@ -21,6 +23,7 @@ pub const HELP: Help = Help {
     usage: r#"
 Usage
 
+    rad node events [<option>...]
     rad node status [<option>...]
     rad node start [--daemon|-d] [<option>...] [-- <node-option>...]
     rad node stop [<option>...]
@@ -47,6 +50,7 @@ pub enum Operation {
         nid: NodeId,
         addr: Address,
     },
+    Events,
     Routing,
     Start {
         daemon: bool,
@@ -69,6 +73,7 @@ pub enum TrackingMode {
 #[derive(Default)]
 pub enum OperationName {
     Connect,
+    Events,
     Routing,
     Start,
     #[default]
@@ -96,6 +101,7 @@ impl Args for Options {
                 }
                 Value(val) if op.is_none() => match val.to_string_lossy().as_ref() {
                     "connect" => op = Some(OperationName::Connect),
+                    "events" => op = Some(OperationName::Events),
                     "routing" => op = Some(OperationName::Routing),
                     "start" => op = Some(OperationName::Start),
                     "status" => op = Some(OperationName::Status),
@@ -138,6 +144,7 @@ impl Args for Options {
                 nid: nid.ok_or_else(|| anyhow!("an NID must be provided"))?,
                 addr: addr.ok_or_else(|| anyhow!("an address must be provided"))?,
             },
+            OperationName::Events => Operation::Events,
             OperationName::Routing => Operation::Routing,
             OperationName::Start => Operation::Start { daemon, options },
             OperationName::Status => Operation::Status,
@@ -158,6 +165,10 @@ pub fn run(options: Options, ctx: impl term::Context) -> anyhow::Result<()> {
             let mut node = Node::new(profile.socket());
             control::connect(&mut node, nid, addr)?
         }
+        Operation::Events => {
+            let node = Node::new(profile.socket());
+            events::run(node)?;
+        }
         Operation::Routing => {
             let store =
                 radicle::node::routing::Table::reader(profile.home.node().join(ROUTING_DB_FILE))?;
diff --git a/radicle-cli/src/commands/node/events.rs b/radicle-cli/src/commands/node/events.rs
new file mode 100644
index 00000000..11a8c66d
--- /dev/null
+++ b/radicle-cli/src/commands/node/events.rs
@@ -0,0 +1,14 @@
+use std::time;
+
+use radicle::node::Handle;
+
+pub fn run(node: impl Handle) -> anyhow::Result<()> {
+    let events = node.subscribe(time::Duration::MAX)?;
+    for event in events {
+        let event = event?;
+        let json_string = serde_json::to_string(&event)?;
+        println!("{json_string}");
+    }
+
+    Ok(())
+}