nostr-sqlite 0.35.0

SQLite Storage backend for Nostr apps
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

// Copyright (c) 2022-2023 Yuki Kishimoto
// Copyright (c) 2023-2024 Rust Nostr Developers
// Distributed under the MIT software license

use std::time::Duration;

use nostr::prelude::*;
use nostr_database::{NostrDatabase, Order};
use nostr_sqlite::SQLiteDatabase;
use tracing_subscriber::fmt::format::FmtSpan;

#[tokio::main]
async fn main() {
    tracing_subscriber::fmt::fmt()
        .with_span_events(FmtSpan::CLOSE)
        .init();

    let secret_key =
        SecretKey::from_bech32("nsec1j4c6269y9w0q2er2xjw8sv2ehyrtfxq3jwgdlxj6qfn8z4gjsq5qfvfk99")
            .unwrap();
    let keys_a = Keys::new(secret_key);
    println!("Pubkey A: {}", keys_a.public_key());

    let secret_key =
        SecretKey::from_bech32("nsec1ufnus6pju578ste3v90xd5m2decpuzpql2295m3sknqcjzyys9ls0qlc85")
            .unwrap();
    let keys_b = Keys::new(secret_key);
    println!("Pubkey B: {}", keys_b.public_key());

    let database = SQLiteDatabase::open("./db/sqlite.db").await.unwrap();

    println!(
        "Events stored: {}",
        database.count(vec![Filter::new()]).await.unwrap()
    );

    // for i in 0..100_000 {
    // let event = EventBuilder::text_note(format!("Event #{i}"), &[])
    // .to_event(&keys_a)
    // .unwrap();
    // database.save_event(&event).await.unwrap();
    //
    // let event = EventBuilder::text_note(
    // format!("Reply to event #{i}"),
    // &[
    // Tag::event(event.id),
    // Tag::PubKey(event.pubkey, None),
    // ],
    // )
    // .to_event(&keys_b)
    // .unwrap();
    // database.save_event(&event).await.unwrap();
    // }

    for i in 0..10 {
        let metadata = Metadata::new().name(format!("Name #{i}"));
        let event = EventBuilder::metadata(&metadata).to_event(&keys_a).unwrap();
        database.save_event(&event).await.unwrap();
    }

    // for i in 0..500_000 {
    // let event = EventBuilder::new(
    // Kind::Custom(123),
    // "Custom with d tag",
    // &[Tag::Identifier(format!("myid{i}"))],
    // )
    // .to_event(&keys_a)
    // .unwrap();
    // database.save_event(&event).await.unwrap();
    // }

    let event_id = EventId::all_zeros();
    database
        .event_id_seen(event_id, Url::parse("wss://relay.damus.io").unwrap())
        .await
        .unwrap();
    database
        .event_id_seen(event_id, Url::parse("wss://relay.nostr.info").unwrap())
        .await
        .unwrap();
    database
        .event_id_seen(event_id, Url::parse("wss://relay.damus.io").unwrap())
        .await
        .unwrap();

    let relays = database.event_seen_on_relays(event_id).await.unwrap();
    println!("Seen on: {relays:?}");

    let events = database
        .query(vec![Filter::new()
            .kinds(vec![Kind::Metadata, Kind::Custom(123), Kind::TextNote])
            .limit(20)
            //.kind(Kind::Custom(123))
            //.identifier("myid5000")
            .author(keys_a.public_key())])
        .await
        .unwrap();
    println!("Got {} events", events.len());

    loop {
        tokio::time::sleep(Duration::from_secs(30)).await
    }
}