nostrstore 0.1.0

nostrstore is a lightweight, decentralized key-value store designed to work seamlessly with the Nostr protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use tracing::info;
use tracing_subscriber;

use nostrstore::{
    DatabaseBuilder, QueryOptions,
    operation::counter::CounterEvent,
};
use nostr_sdk::prelude::*;

#[tokio::main]
async fn main() {
    // install global collector configured based on RUST_LOG env var.
    tracing_subscriber::fmt::init();

    let keys =
        Keys::parse("nsec1fy50xae8lnd5pd2tx0yqvsflkmu4j0qefwacskhvdklytrf68vcqxunshc").unwrap();
    let db = DatabaseBuilder::new(keys.clone())
        .with_default_relays()
        .build()
        .await
        .unwrap();

    // read name from terminal input

    let mut input = String::new();
    println!("Enter your name: ");
    std::io::stdin().read_line(&mut input).unwrap();

    db.store("name", input.trim()).await.unwrap();

    let name = db.read("name").await.unwrap();
    info!("Name: {}", name);

    let history_name = db
        .read_history("name", QueryOptions::default())
        .await
        .unwrap()
        .iter()
        .map(|r| r.content.clone())
        .collect::<Vec<_>>();

    info!("History of Name: {:?}", history_name);

    // event stream
    db.store_event("my-counter", CounterEvent::Increment)
        .await
        .unwrap();

    let counter = db.read_event::<CounterEvent>("my-counter").await.unwrap();
    info!("Counter: {:?}", counter);
}