nostralink 0.2.4

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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

use super::{test_env, TestEnv};
use crate::prelude::*;
use rstest::*;
use std::time::Duration;

#[rstest]
#[tokio::test]
async fn test_forum(test_env: TestEnv) -> Result<(), RdfStoreError> {
    use nostr::Keys;
    let mut forum = ForumBuilder::default()
        .name("Linux".to_string())
        .title("en", "Test")
        .build()
        .unwrap();

    let keys = Keys::generate();
    let forum_event = forum.event_builder()?.sign(&keys).await?;
    test_env.events_store.insert_event(&forum_event)?;

    let subs = [subl("lang_filter", Literal::from("en"))?];

    let set =
        test_env
            .events_store
            .run_query(&nrq_get("forums")?, subs, None)?;
    assert_eq!(set.count(), 1);

    let no_post_ev = NoteBuilder::default()
        .body(Some("Post".to_string()))
        .build()?
        .event_builder()?
        .sign(&keys)
        .await?;

    let post_ev = NoteBuilder::default()
        .body(Some("Forum post".to_string()))
        .build()?
        .event_builder()?
        .tag_forum(forum_event.id)
        .sign(&keys)
        .await?;

    test_env.events_store.insert_event(&no_post_ev)?;
    test_env.events_store.insert_event(&post_ev)?;

    let (subs, _) = QuerySubsBuilder::default()
        .only_followees(0)
        .since(Duration::from_secs(3600))
        .in_forum(forum_event.id)
        .build()
        .map_err(|_| RdfStoreError::LDBuilderError)?
        .subs_with_ckey()?;

    println!("subs: {subs:?}");

    let rset = test_env.events_store.run_query(
        &nrq_get("content_union")?,
        subs,
        None,
    )?;
    for row in &rset.rows {
        println!("=> {row:?}");
    }
    assert_eq!(rset.count(), 1);
    let row = rset.first().unwrap();
    let revid = row.get(SPVars::EVENT_ID).unwrap();
    assert_eq!(revid.to_string(), post_ev.id.to_hex());

    Ok(())
}