add publish and example

solar_client/examples/publish.rs

@@ -0,0 +1,32 @@
+use anyhow::Result;
+use serde_json::json;
+use solar_client::{Client, SolarClient};
+
+const SERVER_ADDR: &str = "http://127.0.0.1:3030";
+const TEXT: &str = "Testing message publishing via the solar JSON-RPC client";
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let client = Client::new(SERVER_ADDR.to_owned())?;
+
+    // Construct a JSON post.
+    //
+    // This can take any shape conforming to
+    // `kuska_ssb::api::dto::content::TypedMessage`.
+    //
+    // Consult the `kuska_ssb` repo for more details:
+    // https://github.com/Kuska-ssb/ssb
+    let post = json!({
+        "type": "post",
+        "text": TEXT,
+    });
+
+    let msg_ref_and_seq_num = client.publish(post).await?;
+    println!("{:?}", msg_ref_and_seq_num);
+    // ("%J0k3hbXE6CjoA2yFpUsy+A1K+GRcTc5Eh6LH7OuzzUE=.sha256", 231)
+
+    // Or destructure the tuple into individual components:
+    // let (msg_ref, seq_num) = client.publish(post).await?;
+
+    Ok(())
+}

solar_client/src/lib.rs

@@ -1,5 +1,4 @@
 use anyhow::Result;
-// TODO: Should we rather be using a custom kuska type?
 use serde_json::Value;
 
 #[jsonrpc_client::api]
@@ -48,6 +47,8 @@ pub trait SolarClient {
 
     async fn ping(&self) -> String;
 
+    async fn publish(&self, msg: Value) -> (String, u64);
+
     async fn subscribers(&self, channel: &str) -> Vec<String>;
 
     async fn subscriptions(&self, pub_key: &str) -> Vec<String>;