freshblu-server 0.1.2

HTTP/WebSocket/MQTT server for the FreshBlu IoT messaging platform
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

use async_trait::async_trait;
use freshblu_core::message::DeviceEvent;
use tokio::sync::broadcast;
use uuid::Uuid;

use crate::bus::MessageBus;
use crate::hub::MessageHub;

/// Single-process message bus backed by the in-memory `MessageHub`.
/// Used when no NATS_URL is configured (dev mode / single-pod deployment).
#[derive(Default)]
pub struct LocalBus {
    hub: MessageHub,
}

impl LocalBus {
    pub fn new() -> Self {
        Self::default()
    }
}

#[async_trait]
impl MessageBus for LocalBus {
    async fn publish(&self, target: &Uuid, event: DeviceEvent) -> anyhow::Result<()> {
        self.hub.deliver(target, event);
        Ok(())
    }

    async fn publish_many(&self, targets: &[Uuid], event: DeviceEvent) -> anyhow::Result<()> {
        self.hub.deliver_many(targets, event);
        Ok(())
    }

    fn connect(&self, uuid: Uuid) -> broadcast::Receiver<DeviceEvent> {
        self.hub.connect(uuid)
    }

    fn disconnect(&self, uuid: &Uuid) {
        self.hub.disconnect(uuid);
    }

    fn is_online(&self, uuid: &Uuid) -> bool {
        self.hub.is_online(uuid)
    }

    fn online_count(&self) -> usize {
        self.hub.online_count()
    }
}