nostr_rust

An ergonomic, Nostr API Client for Rust.

• Changelog

Example

[dependencies]
nostr_rust = "*"

And then the code:

```rust,norun use std::{ str::FromStr, sync::{Arc, Mutex}, thread, };

use nostr_rust::{nostr_client::Client, req::ReqFilter, Identity, Message, events::extract_events_ws, utils::parse_content_tags};

fn handle_message(relay_url: &String, message: &Message) -> Result<(), String> { println!("Received message from {}: {:?}", relay_url, message);

let events = extract_events_ws(message);
println!("Events: {:?}", events);

Ok(())

}

fn main() { let my_identity = Identity::from_str("your private key as hex string") .unwrap();

let nostr_client = Arc::new(Mutex::new(
    Client::new(vec!["wss://relay.nostr.info"]).unwrap(),
));

// Run a new thread to handle messages
let nostr_clone = nostr_client.clone();
let handle_thread = thread::spawn(move || {
    println!("Listening...");
    let events = nostr_clone.lock().unwrap().next_data().unwrap();

    for (relay_url, message) in events.iter() {
        handle_message(relay_url, message).unwrap();
    }
});

// Change metadata
nostr_client
    .lock()
    .unwrap()
    .set_metadata(
        &my_identity,
        Some("Rust Nostr Client test account"),
        Some("Hello Nostr! #5"),
        None,
        None,
        0,
    )
    .unwrap();

// Subscribe to my last text note
let subscription_id = nostr_client
    .lock()
    .unwrap()
    .subscribe(vec![ReqFilter {
        ids: None,
        authors: Some(vec![
            "884704bd421721e292edbff42eb77547fe115c6ff9825b08fc366be4cd69e9f6".to_string(),
        ]),
        kinds: None,
        e: None,
        p: None,
        since: None,
        until: None,
        limit: Some(1),
    }])
    .unwrap();

// Unsubscribe
nostr_client
    .lock()
    .unwrap()
    .unsubscribe(&subscription_id)
    .unwrap();

// You can use the parse content tags method to get the content and the tags from a string
// let tags = parse_content_tags("hello #world", vec![], Some(nostr_rust::DEFAULT_HASHTAG), true, true);
// assert_eq!(tags.content, "hello #world");
//  assert_eq!(tags.tags, vec![vec!["t", "world"]]);

// Publish a text note
nostr_client
    .lock()
    .unwrap()
    .publish_text_note(&my_identity, "Hello Nostr! :)", &[], 0)
    .unwrap();

// Publish a proof of work text note with a difficulty target of 15
nostr_client
    .lock()
    .unwrap()
    .publish_text_note(&my_identity, "Hello Nostr! :)", &[], 15)
    .unwrap();

// Wait for the thread to finish
handle_thread.join().unwrap();

}

Async feature

If you want to use the async version of the client, you can enable the async feature:

[dependencies]
nostr_rust = { version = "*", features = ["async"] }

NIPs Supported

License

Licensed under MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)