skyzen 0.1.1

A fast, ergonomic HTTP framework that works everywhere
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

//! Durable Object context for non-routed methods.

use skyzen_services::durable::{Alarm, DurableDb, DurableKv};

use super::connections::DurableConnections;
use super::id::DurableObjectId;

/// Provides service access in `websocket` and other non-routed contexts.
///
/// NOT an extractor — passed explicitly by the runtime to
/// [`DurableObject::websocket`](super::DurableObject::websocket).
pub struct DurableContext {
    kv: DurableKv,
    db: DurableDb,
    alarm: Alarm,
    connections: DurableConnections,
    id: DurableObjectId,
}

impl std::fmt::Debug for DurableContext {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("DurableContext")
            .field("id", &self.id)
            .finish_non_exhaustive()
    }
}

impl DurableContext {
    /// Create a new `DurableContext` with all services.
    #[must_use]
    #[allow(clippy::missing_const_for_fn)] // Box<dyn> fields prevent const
    pub fn new(
        kv: DurableKv,
        db: DurableDb,
        alarm: Alarm,
        connections: DurableConnections,
        id: DurableObjectId,
    ) -> Self {
        Self {
            kv,
            db,
            alarm,
            connections,
            id,
        }
    }

    /// Access the Durable Object's KV storage.
    #[must_use]
    pub const fn kv(&self) -> &DurableKv {
        &self.kv
    }

    /// Access the Durable Object's database.
    #[must_use]
    pub const fn db(&self) -> &DurableDb {
        &self.db
    }

    /// Access the Durable Object's alarm scheduler.
    #[must_use]
    pub const fn alarm(&self) -> &Alarm {
        &self.alarm
    }

    /// Access the Durable Object's WebSocket connections.
    #[must_use]
    pub const fn connections(&self) -> &DurableConnections {
        &self.connections
    }

    /// The unique identity of this Durable Object instance.
    #[must_use]
    pub const fn id(&self) -> &DurableObjectId {
        &self.id
    }
}