Add cast delivery admission support

Author: hxrts

crates/cast-support/src/delivery.rs

@@ -1,6 +1,6 @@
 use std::collections::BTreeSet;
 
-use jacquard_core::{ByteCount, NodeId, RatioPermille};
+use jacquard_core::{BroadcastDomainId, ByteCount, NodeId, RatioPermille};
 use serde::{Deserialize, Serialize};
 
 use crate::{
@@ -81,6 +81,7 @@ pub struct CastDeliveryObjective {
     pub sender: NodeId,
     pub receivers: CastReceiverSet,
     pub group_id: Option<CastGroupId>,
+    pub broadcast_domain_id: Option<BroadcastDomainId>,
     pub coverage: CastCoverageObjective,
 }
 
@@ -92,6 +93,7 @@ impl CastDeliveryObjective {
             sender,
             receivers: CastReceiverSet::one(receiver),
             group_id: None,
+            broadcast_domain_id: None,
             coverage: CastCoverageObjective::AllReceivers,
         }
     }
@@ -108,13 +110,15 @@ impl CastDeliveryObjective {
             sender,
             receivers: CastReceiverSet::new(receivers),
             group_id: Some(group_id),
+            broadcast_domain_id: None,
             coverage,
         }
     }
 
     #[must_use]
-    pub fn broadcast(
+    pub fn broadcast_in_domain(
         sender: NodeId,
+        domain_id: BroadcastDomainId,
         receivers: impl IntoIterator<Item = NodeId>,
         coverage: CastCoverageObjective,
     ) -> Self {
@@ -123,6 +127,7 @@ impl CastDeliveryObjective {
             sender,
             receivers: CastReceiverSet::new(receivers),
             group_id: None,
+            broadcast_domain_id: Some(domain_id),
             coverage,
         }
     }
@@ -224,6 +229,7 @@ pub struct MulticastDeliverySupport {
 #[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
 pub struct BroadcastDeliverySupport {
     pub sender: NodeId,
+    pub domain_id: BroadcastDomainId,
     pub receivers: Vec<ReceiverCoverageEvidence>,
     pub support: BroadcastSupportKind,
     pub confidence_permille: RatioPermille,
@@ -398,6 +404,7 @@ fn broadcast_delivery_support(
     }
     Some(BroadcastDeliverySupport {
         sender: evidence.sender,
+        domain_id: objective.broadcast_domain_id?,
         receivers,
         support: evidence.support,
         confidence_permille: confidence,

crates/cast-support/src/multicast.rs

@@ -1,6 +1,6 @@
 use std::collections::{BTreeMap, BTreeSet};
 
-use jacquard_core::{ByteCount, NodeId, RatioPermille};
+use jacquard_core::{ByteCount, MulticastGroupId, NodeId, RatioPermille};
 use serde::{Deserialize, Serialize};
 
 use crate::{
@@ -13,7 +13,19 @@ use crate::{
 // proc-macro-scope: Multicast profile evidence shaping is plain helper logic.
 
 #[derive(Clone, Debug, PartialEq, Eq, PartialOrd, Ord, Hash, Serialize, Deserialize)]
-pub struct CastGroupId(pub Vec<u8>);
+pub struct CastGroupId(pub MulticastGroupId);
+
+impl CastGroupId {
+    #[must_use]
+    pub const fn new(group_id: MulticastGroupId) -> Self {
+        Self(group_id)
+    }
+
+    #[must_use]
+    pub const fn to_route_group_id(&self) -> MulticastGroupId {
+        self.0
+    }
+}
 
 #[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
 pub struct MulticastObservation {

crates/cast-support/tests/delivery.rs

@@ -6,7 +6,10 @@ use jacquard_cast_support::{
     CastEvidencePolicy, CastGroupId, CastReceiverSet, MulticastObservation,
     ReceiverCoverageObservation, UnicastObservation,
 };
-use jacquard_core::{ByteCount, DurationMs, NodeId, OrderStamp, RatioPermille, Tick};
+use jacquard_core::{
+    BroadcastDomainId, ByteCount, DurationMs, MulticastGroupId, NodeId, OrderStamp, RatioPermille,
+    Tick,
+};
 
 fn node(byte: u8) -> NodeId {
     NodeId([byte; 32])
@@ -62,8 +65,12 @@ fn unicast_observation(to: u8, confidence: u16, reverse: Option<u16>) -> Unicast
     }
 }
 
-fn group(name: &[u8]) -> CastGroupId {
-    CastGroupId(name.to_vec())
+fn group(byte: u8) -> CastGroupId {
+    CastGroupId::new(MulticastGroupId([byte; 16]))
+}
+
+fn domain(byte: u8) -> BroadcastDomainId {
+    BroadcastDomainId([byte; 16])
 }
 
 #[test]
@@ -106,7 +113,7 @@ fn multicast_delivery_respects_partial_coverage_policy() {
     let (evidence, _) = shape_multicast_evidence(
         [MulticastObservation {
             sender: node(1),
-            group_id: group(b"team"),
+            group_id: group(1),
             receivers: vec![receiver(2, 900), receiver(3, 800)],
             group_pressure_permille: RatioPermille(100),
             fanout_limit: 3,
@@ -117,7 +124,7 @@ fn multicast_delivery_respects_partial_coverage_policy() {
     );
     let objective = CastDeliveryObjective::multicast(
         node(1),
-        group(b"team"),
+        group(1),
         [node(2), node(4)],
         CastCoverageObjective::AnyReceiver,
     );
@@ -168,8 +175,12 @@ fn broadcast_delivery_can_reject_gateway_assisted_reverse_support() {
         ],
         evidence_policy(),
     );
-    let objective =
-        CastDeliveryObjective::broadcast(node(1), [node(2)], CastCoverageObjective::AllReceivers);
+    let objective = CastDeliveryObjective::broadcast_in_domain(
+        node(1),
+        domain(1),
+        [node(2)],
+        CastCoverageObjective::AllReceivers,
+    );
     let policy = CastDeliveryPolicy {
         require_bidirectional: true,
         allow_gateway_assisted_broadcast: false,
@@ -214,8 +225,9 @@ fn broadcast_delivery_ordering_is_deterministic() {
         ],
         evidence_policy(),
     );
-    let objective = CastDeliveryObjective::broadcast(
+    let objective = CastDeliveryObjective::broadcast_in_domain(
         node(1),
+        domain(1),
         [node(2), node(3)],
         CastCoverageObjective::AnyReceiver,
     );

crates/cast-support/tests/multicast.rs

@@ -4,7 +4,9 @@ use jacquard_cast_support::{
     shape_multicast_evidence, CastEvidenceBounds, CastEvidenceMeta, CastEvidencePolicy,
     CastGroupId, MulticastObservation, ReceiverCoverageObservation,
 };
-use jacquard_core::{ByteCount, DurationMs, NodeId, OrderStamp, RatioPermille, Tick};
+use jacquard_core::{
+    ByteCount, DurationMs, MulticastGroupId, NodeId, OrderStamp, RatioPermille, Tick,
+};
 
 fn node(byte: u8) -> NodeId {
     NodeId([byte; 32])
@@ -39,20 +41,20 @@ fn receiver(byte: u8, confidence: u16) -> ReceiverCoverageObservation {
     }
 }
 
-fn group(name: &[u8]) -> CastGroupId {
-    CastGroupId(name.to_vec())
+fn group(byte: u8) -> CastGroupId {
+    CastGroupId::new(MulticastGroupId([byte; 16]))
 }
 
 fn observation(
-    name: &[u8],
+    group_byte: u8,
     receivers: Vec<ReceiverCoverageObservation>,
     pressure: u16,
     fanout: u32,
     order: u64,
 ) -> MulticastObservation {
     MulticastObservation {
         sender: node(1),
-        group_id: group(name),
+        group_id: group(group_byte),
         receivers,
         group_pressure_permille: RatioPermille(pressure),
         fanout_limit: fanout,
@@ -65,7 +67,7 @@ fn observation(
 fn multicast_full_and_partial_coverage_are_explicit() {
     let (evidence, _report) = shape_multicast_evidence(
         [observation(
-            b"team",
+            1,
             vec![receiver(2, 800), receiver(3, 700)],
             100,
             2,
@@ -86,26 +88,23 @@ fn multicast_full_and_partial_coverage_are_explicit() {
 fn multicast_group_pressure_reduces_ranking() {
     let (evidence, _report) = shape_multicast_evidence(
         [
-            observation(b"quiet", vec![receiver(2, 800)], 100, 1, 1),
-            observation(b"loaded", vec![receiver(3, 800)], 900, 1, 2),
+            observation(1, vec![receiver(2, 800)], 100, 1, 1),
+            observation(2, vec![receiver(3, 800)], 900, 1, 2),
         ],
         policy(),
     );
 
-    assert_eq!(evidence[0].group_id, group(b"quiet"));
-    assert_eq!(evidence[1].group_id, group(b"loaded"));
+    assert_eq!(evidence[0].group_id, group(1));
+    assert_eq!(evidence[1].group_id, group(2));
 }
 
 #[test]
 fn multicast_stale_group_evidence_and_bounded_fanout_are_omitted() {
-    let mut stale = observation(b"stale", vec![receiver(2, 800)], 100, 1, 1);
+    let mut stale = observation(1, vec![receiver(2, 800)], 100, 1, 1);
     stale.meta = meta(1_001, 1);
 
     let (evidence, report) = shape_multicast_evidence(
-        [
-            stale,
-            observation(b"wide", vec![receiver(3, 800)], 100, 4, 2),
-        ],
+        [stale, observation(2, vec![receiver(3, 800)], 100, 4, 2)],
         policy(),
     );
 
@@ -117,14 +116,14 @@ fn multicast_stale_group_evidence_and_bounded_fanout_are_omitted() {
 #[test]
 fn multicast_receiver_order_is_stable_across_input_ordering() {
     let first = observation(
-        b"group",
+        1,
         vec![receiver(4, 700), receiver(2, 900), receiver(3, 800)],
         100,
         3,
         1,
     );
     let second = observation(
-        b"group",
+        1,
         vec![receiver(3, 800), receiver(2, 900), receiver(4, 700)],
         100,
         3,
@@ -149,7 +148,7 @@ fn multicast_receiver_order_is_stable_across_input_ordering() {
 fn multicast_low_confidence_receivers_do_not_force_all_or_nothing_delivery() {
     let (evidence, _report) = shape_multicast_evidence(
         [observation(
-            b"mixed",
+            1,
             vec![receiver(2, 800), receiver(3, 400), receiver(4, 700)],
             100,
             3,
@@ -168,3 +167,23 @@ fn multicast_low_confidence_receivers_do_not_force_all_or_nothing_delivery() {
         vec![node(2), node(4)]
     );
 }
+
+#[test]
+fn route_group_identity_is_direct_and_stable() {
+    let id = MulticastGroupId([9; 16]);
+
+    assert_eq!(CastGroupId::new(id).to_route_group_id(), id);
+}
+
+#[test]
+fn route_group_identity_distinguishes_explicit_ids_with_shared_prefix() {
+    let mut left = [7; 16];
+    let mut right = [7; 16];
+    left[15] = 1;
+    right[15] = 2;
+
+    assert_ne!(
+        CastGroupId::new(MulticastGroupId(left)).to_route_group_id(),
+        CastGroupId::new(MulticastGroupId(right)).to_route_group_id()
+    );
+}

crates/cast-support/tests/surface.rs

@@ -4,7 +4,9 @@ use jacquard_cast_support::{
     CastEvidencePolicy, CastGroupId, MulticastObservation, ReceiverCoverageObservation,
     UnicastObservation, UnicastSupportKind,
 };
-use jacquard_core::{ByteCount, DurationMs, NodeId, OrderStamp, RatioPermille, Tick};
+use jacquard_core::{
+    ByteCount, DurationMs, MulticastGroupId, NodeId, OrderStamp, RatioPermille, Tick,
+};
 
 fn node(byte: u8) -> NodeId {
     NodeId([byte; 32])
@@ -79,7 +81,7 @@ fn multicast_surface_enforces_group_coverage_bounds() {
     let (evidence, report) = shape_multicast_evidence(
         [MulticastObservation {
             sender: node(1),
-            group_id: CastGroupId(b"group".to_vec()),
+            group_id: CastGroupId::new(MulticastGroupId([1; 16])),
             receivers,
             group_pressure_permille: RatioPermille(100),
             fanout_limit: 2,

crates/core/src/base/identity.rs

@@ -27,6 +27,8 @@ super::bytes_newtype!(DiscoveryScopeId, 16);
 super::bytes_newtype!(HomeId, 16);
 super::bytes_newtype!(ClusterId, 16);
 super::bytes_newtype!(GatewayId, 16);
+super::bytes_newtype!(MulticastGroupId, 16);
+super::bytes_newtype!(BroadcastDomainId, 16);
 super::bytes_newtype!(RouteId, 16);
 super::bytes_newtype!(RoutingEngineContractId, 16);
 super::bytes_newtype!(RouteOperationId, 16);