nostralink 0.2.1

Linked data library for nostr
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
52
53

//! Example showing how to use a nostr Client with a RdfEventsStore as database

use nostralink::prelude::*;
use std::path::PathBuf;

#[tokio::main]
async fn main() -> Result<(), RdfStoreError> {
    let args: Vec<String> = std::env::args().collect();
    let store_path = if args.len() > 1 {
        PathBuf::from(args[1].clone())
    } else {
        PathBuf::from("rdf_store")
    };

    let store = RdfEventsStore::open(store_path)?;

    let keys = Keys::generate();
    let client = Client::builder().database(store).signer(keys).build();

    client.add_relay("wss://relay.damus.io").await?;
    client.add_relay("wss://nos.lol").await?;
    client.connect().await;

    client
        .subscribe(
            Filter::new()
                .kind(Kind::TextNote)
                .limit(100)
                .since(Timestamp::now() - 3600),
            None,
        )
        .await?;

    client
        .handle_notifications(|notification| async {
            if let RelayPoolNotification::Event {
                relay_url: _,
                subscription_id: _,
                event,
            } = notification
            {
                let ttl = ttlify_event(&event).await
                    .map_err(|_| RdfStoreError::LDErr(LDError::TTLSerializationError))?;

                println!("{ttl}");
            }

            Ok(false)
        })
        .await?;

    Ok(())
}