v0.0.111

Author: RandyMcMillan

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "gnostr"
-version = "0.0.110"
+version = "0.0.111"
 edition = "2021"
 description = "gnostr:a git+nostr workflow utility"
 authors = [

src/bin/gnostr-query.rs

@@ -0,0 +1,113 @@
+use gnostr_query::cli::cli;
+use gnostr_query::ConfigBuilder;
+use log::{debug, trace};
+use serde_json::{json, to_string};
+use url::Url;
+
+/// Usage
+/// nip-0034 kinds
+/// gnostr-query -k 1630,1632,1621,30618,1633,1631,1617,30617
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    let matches = cli().await?;
+    let mut filt = serde_json::Map::new();
+
+    if let Some(authors) = matches.get_one::<String>("authors") {
+        filt.insert(
+            "authors".to_string(),
+            json!(authors.split(',').collect::<Vec<&str>>()),
+        );
+    }
+
+    if let Some(ids) = matches.get_one::<String>("ids") {
+        filt.insert(
+            "ids".to_string(),
+            json!(ids.split(',').collect::<Vec<&str>>()),
+        );
+    }
+
+    let mut limit_check: i32 = 0;
+    if let Some(limit) = matches.get_one::<i32>("limit") {
+        // ["EOSE","gnostr-query"] counts as a message!      + 1
+        filt.insert("limit".to_string(), json!(limit.clone() /*+ 1*/));
+        limit_check = *limit;
+    }
+
+    if let Some(generic) = matches.get_many::<String>("generic") {
+        let generic_vec: Vec<&String> = generic.collect();
+        if generic_vec.len() == 2 {
+            let tag = format!("#{}", generic_vec[0]);
+            let val = generic_vec[1].split(',').collect::<Vec<&str>>();
+            filt.insert(tag, json!(val));
+        }
+    }
+
+    if let Some(hashtag) = matches.get_one::<String>("hashtag") {
+        filt.insert(
+            "#t".to_string(),
+            json!(hashtag.split(',').collect::<Vec<&str>>()),
+        );
+    }
+
+    if let Some(mentions) = matches.get_one::<String>("mentions") {
+        filt.insert(
+            "#p".to_string(),
+            json!(mentions.split(',').collect::<Vec<&str>>()),
+        );
+    }
+
+    if let Some(references) = matches.get_one::<String>("references") {
+        filt.insert(
+            "#e".to_string(),
+            json!(references.split(',').collect::<Vec<&str>>()),
+        );
+    }
+
+    if let Some(kinds) = matches.get_one::<String>("kinds") {
+        if let Ok(kind_ints) = kinds
+            .split(',')
+            .map(|s| s.parse::<i64>())
+            .collect::<Result<Vec<i64>, _>>()
+        {
+            filt.insert("kinds".to_string(), json!(kind_ints));
+        } else {
+            eprintln!("Error parsing kinds. Ensure they are integers.");
+            std::process::exit(1);
+        }
+    }
+
+    let config = ConfigBuilder::new()
+        .host("localhost")
+        .port(8080)
+        .use_tls(true)
+        .retries(5)
+        .authors("")
+        .ids("")
+        .limit(limit_check)
+        .generic("", "")
+        .hashtag("")
+        .mentions("")
+        .references("")
+        .kinds("")
+        .build()?;
+
+    debug!("{config:?}");
+    let q = json!(["REQ", "gnostr-query", filt]);
+    let query_string = to_string(&q)?;
+    let relay_url_str = matches.get_one::<String>("relay").clone().unwrap();
+    let relay_url = Url::parse(relay_url_str)?;
+    let vec_result = gnostr_query::send(query_string.clone(), relay_url, Some(limit_check)).await;
+    //trace
+    trace!("{:?}", vec_result);
+
+    let mut json_result: Vec<String> = vec![];
+    for element in vec_result.unwrap() {
+        println!("{}", element);
+        json_result.push(element);
+    }
+    //trace
+    for element in json_result {
+        trace!("json_result={}", element);
+    }
+    Ok(())
+}