lb_rs/service/
events.rs

1pub use tokio::sync::broadcast::{self, Receiver, Sender};
2use tracing::*;
3use uuid::Uuid;
4
5use crate::{Lb, LbErrKind};
6
7#[derive(Clone)]
8pub struct EventSubs {
9    tx: Sender<Event>,
10}
11
12#[derive(Clone, Debug)]
13pub enum Event {
14    /// A metadata for a given id or it's descendants changed. The id returned
15    /// may be deleted. Updates to document contents will not cause this
16    /// message to be sent (unless a document was deleted).
17    MetadataChanged(Actor),
18
19    /// The contents of this document have changed either by this lb
20    /// library or as a result of sync
21    DocumentWritten(Uuid, Actor),
22
23    PendingSharesChanged,
24
25    Sync(SyncIncrement),
26
27    StatusUpdated,
28
29    UserSignedIn,
30}
31
32#[derive(Debug, Clone, PartialEq)]
33pub enum Actor {
34    User,
35    Sync,
36}
37
38impl Default for EventSubs {
39    fn default() -> Self {
40        let (tx, _) = broadcast::channel::<Event>(10000);
41        Self { tx }
42    }
43}
44
45impl EventSubs {
46    pub(crate) fn pending_shares_changed(&self) {
47        self.queue(Event::PendingSharesChanged);
48    }
49
50    pub(crate) fn meta_changed(&self, actor: Actor) {
51        self.queue(Event::MetadataChanged(actor));
52    }
53
54    pub(crate) fn doc_written(&self, id: Uuid, actor: Actor) {
55        self.queue(Event::DocumentWritten(id, actor));
56    }
57
58    pub(crate) fn sync_update(&self, s: SyncIncrement) {
59        self.queue(Event::Sync(s));
60    }
61
62    pub(crate) fn status_updated(&self) {
63        self.queue(Event::StatusUpdated);
64    }
65
66    /// executed after root and account are created
67    pub(crate) fn signed_in(&self) {
68        self.queue(Event::UserSignedIn);
69    }
70
71    fn queue(&self, evt: Event) {
72        if let Err(e) = self.tx.send(evt.clone()) {
73            error!(?evt, ?e, "could not queue");
74        }
75    }
76}
77
78impl Lb {
79    pub fn subscribe(&self) -> Receiver<Event> {
80        self.events.tx.subscribe()
81    }
82}
83
84#[derive(Debug, Clone)]
85pub enum SyncIncrement {
86    SyncStarted,
87    PullingDocument(Uuid, bool),
88    PushingDocument(Uuid, bool),
89    SyncFinished(Option<LbErrKind>),
90}
lb_rs/service/events.rs

lb_rs/service/
events.rs
