jacquard-router 0.9.0

Canonical router middleware for Jacquard
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

//! Router-owned delivery compatibility helpers.
//!
//! These helpers keep cast objective admission above engine internals. Profiles
//! surface delivery support, the router checks objective compatibility, and
//! host effects receive an explicit delivery intent only after that check.

use jacquard_core::{
    DeliveryCompatibility, DeliveryCompatibilityPolicy, RouteAdmissionRejection,
    RouteDeliveryObjective, TransportDeliveryIntent, TransportDeliverySupport,
};

// proc-macro-scope: Router delivery admission is plain helper logic over shared delivery models.

#[must_use = "delivery admission must be checked before host send intent is used"]
pub fn admitted_delivery_intent(
    objective: &RouteDeliveryObjective,
    support: &TransportDeliverySupport,
    policy: DeliveryCompatibilityPolicy,
) -> Result<TransportDeliveryIntent, RouteAdmissionRejection> {
    match objective.compatible_with(support, policy) {
        DeliveryCompatibility::Compatible => Ok(intent_for_support(support)),
        DeliveryCompatibility::Rejected(reason) => Err(reason),
    }
}

fn intent_for_support(support: &TransportDeliverySupport) -> TransportDeliveryIntent {
    match support {
        TransportDeliverySupport::IsolatedUnicast { endpoint, .. } => {
            TransportDeliveryIntent::Unicast {
                endpoint: endpoint.clone(),
            }
        }
        TransportDeliverySupport::Multicast {
            endpoint,
            group_id,
            receivers,
        } => TransportDeliveryIntent::Multicast {
            endpoint: endpoint.clone(),
            group_id: *group_id,
            receivers: receivers.clone(),
        },
        TransportDeliverySupport::Broadcast {
            endpoint,
            domain_id,
            ..
        } => TransportDeliveryIntent::Broadcast {
            endpoint: endpoint.clone(),
            domain_id: *domain_id,
        },
    }
}