radicle-feed 0.1.1

A Radicle feed library for implementing Radicle COB feeds
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

pub mod entry;
pub mod error;
pub mod feed;
pub mod storage;

// Re-export commonly used types
pub use entry::{ActionEntry, Author};
pub use feed::{FeedProcessor, ProcessingStats};
pub use storage::{FeedStorage, MemoryStorage, StorageStats};

// Version information
pub const VERSION: &str = env!("CARGO_PKG_VERSION");

#[cfg(test)]
mod tests {
    use std::str::FromStr;

    use radicle::{
        cob::{ObjectId, Timestamp, TypeName},
        git::Oid,
        node::Alias,
        prelude::{Did, RepoId},
    };

    use super::*;

    #[test]
    fn test_memory_storage() {
        let storage = MemoryStorage::new();
        let stats = storage.get_stats().unwrap();
        assert_eq!(stats.total_actions, 0);
    }

    #[test]
    fn test_memory_insert_batch() {
        let mut storage = MemoryStorage::new();

        storage
            .insert_batch(&[
                ActionEntry {
                    operation_id: Oid::from_str("4ec0362610c1df9be322d82b4514933de7e0e587")
                        .unwrap(),
                    cob_id: ObjectId::from_str("4ec0362610c1df9be322d82b4514933de7e0e587").unwrap(),
                    rid: RepoId::from_str("rad:z281hhqRHPQ1sop3irVT451vNY68i").unwrap(),
                    timestamp: Timestamp::from_secs(1760362137),
                    action: "action".to_string(),
                    author: Author {
                        did: Did::from_str(
                            "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5",
                        )
                        .unwrap(),
                        alias: Alias::from_str("alice").ok(),
                    },
                    typename: TypeName::from_str("xyz.radicle.issue").unwrap(),
                },
                ActionEntry {
                    operation_id: Oid::from_str("49458fc9b9bb2e3138b1ceda59944c9f200bbc08")
                        .unwrap(),
                    cob_id: ObjectId::from_str("49458fc9b9bb2e3138b1ceda59944c9f200bbc08").unwrap(),
                    rid: RepoId::from_str("rad:z281hhqRHPQ1sop3irVT451vNY68i").unwrap(),
                    timestamp: Timestamp::from_secs(1760362137),
                    action: "action".to_string(),
                    author: Author {
                        did: Did::from_str(
                            "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5",
                        )
                        .unwrap(),
                        alias: Alias::from_str("alice").ok(),
                    },
                    typename: TypeName::from_str("xyz.radicle.issue").unwrap(),
                },
            ])
            .unwrap();

        let stats = storage.get_stats().unwrap();
        assert_eq!(stats.total_actions, 2);
    }
}