skystreamer 0.2.2

Idiomatic Rust library for the AT Firehose streaming API
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

use atrium_api::{
    app::bsky,
    com::atproto::sync::subscribe_repos::RepoOp,
    types::{CidLink, Collection},
};

/// An operation in a commit.
///
/// Wrapper around [`atrium_api::com::atproto::sync::subscribe_repos::RepoOp`].
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum Operation {
    // app.bsky.feed.post
    Post(Option<CidLink>, RepoOp),
    // app.bsky.graph.follow
    Follow(Option<CidLink>, RepoOp),
    // app.bsky.graph.block
    Block(Option<CidLink>, RepoOp),
    // app.bsky.feed.repost
    Repost(Option<CidLink>, RepoOp),
    // app.bsky.feed.like
    Like(Option<CidLink>, RepoOp),
    // app.bsky.graph.listitem
    ListItem(Option<CidLink>, RepoOp),
    // app.bsky.actor.profile
    Profile(Option<CidLink>, RepoOp),
    // other stuff
    Other(String, Option<CidLink>, RepoOp),
}

impl Operation {
    pub fn from_op(op: RepoOp) -> Self {
        let path = op.path.split('/').next().unwrap_or_default();
        let cid = op.cid.clone();
        match path {
            bsky::feed::Post::NSID => Operation::Post(cid, op),
            bsky::graph::Follow::NSID => Operation::Follow(cid, op),
            bsky::graph::Block::NSID => Operation::Block(cid, op),
            bsky::feed::Repost::NSID => Operation::Repost(cid, op),
            bsky::feed::Like::NSID => Operation::Like(cid, op),
            bsky::graph::Listitem::NSID => Operation::ListItem(cid, op),
            bsky::actor::Profile::NSID => Operation::Profile(cid, op),
            _ => Operation::Other(path.to_string(), cid, op),
        }
    }

    /// Get the CID of the operation
    pub fn get_cid(&self) -> Option<CidLink> {
        match self {
            Operation::Post(cid, _)
            | Operation::Follow(cid, _)
            | Operation::Block(cid, _)
            | Operation::Repost(cid, _)
            | Operation::Like(cid, _)
            | Operation::ListItem(cid, _)
            | Operation::Profile(cid, _)
            | Operation::Other(_, cid, _) => cid.clone(),
        }
    }

    /// Get the operation type
    pub fn get_op(&self) -> RepoOp {
        match self {
            Operation::Post(_, op)
            | Operation::Follow(_, op)
            | Operation::Block(_, op)
            | Operation::Repost(_, op)
            | Operation::Like(_, op)
            | Operation::ListItem(_, op)
            | Operation::Profile(_, op)
            | Operation::Other(_, _, op) => op.clone(),
        }
    }
}