p2panda-store 0.6.1

Database traits and SQLite implementations for p2panda
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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143

// SPDX-License-Identifier: MIT OR Apache-2.0

use std::collections::BTreeMap;

use p2panda_core::{SigningKey, Topic};

use crate::topics::TopicStore;
use crate::{SqliteStore, Transaction};

#[tokio::test]
async fn update_and_resolve_topic_mapping() {
    let store = SqliteStore::temporary().await;

    let topic = Topic::random();

    // The log id is the same as the topic, in a use case like this there will be one log
    // per-author in each topic.
    let log_id = topic;

    let alice = SigningKey::from_bytes(&[1u8; 32]).verifying_key();
    let bob = SigningKey::from_bytes(&[2u8; 32]).verifying_key();

    let permit = store.begin().await.unwrap();

    let result = store.associate(&topic, &alice, &log_id).await.unwrap();
    assert!(result);

    let result = store.associate(&topic, &bob, &log_id).await.unwrap();
    assert!(result);

    store.commit(permit).await.unwrap();

    // Inserting bob again results in a false result.
    let permit = store.begin().await.unwrap();

    let result = store.associate(&topic, &bob, &log_id).await.unwrap();
    assert!(!result);

    store.commit(permit).await.unwrap();

    let expected_logs = BTreeMap::from([(alice, vec![topic]), (bob, vec![topic])]);

    let logs = store.resolve(&topic).await.unwrap();
    assert_eq!(logs, expected_logs);
}

#[tokio::test]
async fn path_based_log_ids() {
    let store = SqliteStore::temporary().await;

    let topic = Topic::random();

    // Here we demonstrate use cases where there are multiple logs per-author in each topic.
    let log_id_kittens = "kittens".to_string();
    let log_id_kittens_sleepy = "kittens.sleepy".to_string();
    let log_id_puppies = "puppies".to_string();

    let alice = SigningKey::from_bytes(&[1u8; 32]).verifying_key();
    let bob = SigningKey::from_bytes(&[2u8; 32]).verifying_key();

    let permit = store.begin().await.unwrap();

    let result = store
        .associate(&topic, &alice, &log_id_kittens)
        .await
        .unwrap();
    assert!(result);

    let result = store
        .associate(&topic, &alice, &log_id_kittens_sleepy)
        .await
        .unwrap();
    assert!(result);

    let result = store
        .associate(&topic, &bob, &log_id_puppies)
        .await
        .unwrap();
    assert!(result);

    store.commit(permit).await.unwrap();

    let expected_logs = BTreeMap::from([
        (alice, vec![log_id_kittens, log_id_kittens_sleepy]),
        (bob, vec![log_id_puppies]),
    ]);

    let logs = store.resolve(&topic).await.unwrap();
    assert_eq!(logs, expected_logs);
}

#[tokio::test]
async fn remove_association() {
    let store = SqliteStore::temporary().await;

    let topic = Topic::random();

    // Here we demonstrate use cases where there are multiple logs per-author in each topic.
    let log_id_kittens = "kittens".to_string();
    let log_id_kittens_sleepy = "kittens.sleepy".to_string();

    let alice = SigningKey::from_bytes(&[1u8; 32]).verifying_key();

    let permit = store.begin().await.unwrap();

    let result = store
        .associate(&topic, &alice, &log_id_kittens)
        .await
        .unwrap();
    assert!(result);

    let result = store
        .associate(&topic, &alice, &log_id_kittens_sleepy)
        .await
        .unwrap();
    assert!(result);

    store.commit(permit).await.unwrap();

    let expected_logs = BTreeMap::from([(
        alice,
        vec![log_id_kittens.clone(), log_id_kittens_sleepy.clone()],
    )]);

    let logs = store.resolve(&topic).await.unwrap();
    assert_eq!(logs, expected_logs);

    let permit = store.begin().await.unwrap();

    let result = store
        .remove(&topic, &alice, &log_id_kittens_sleepy)
        .await
        .unwrap();

    store.commit(permit).await.unwrap();

    assert!(result);

    let expected_logs = BTreeMap::from([(alice, vec![log_id_kittens])]);

    let logs = store.resolve(&topic).await.unwrap();
    assert_eq!(logs, expected_logs);
}