o_sfu_core/

server.rs

//! Server-runtime integration surface.
//!
//! The top-level runtime uses these facades for diagnostics, metrics, room
//! management, transport construction and packet sinks. The caller-facing
//! session API remains under [`crate::prelude`].

/// diagnostics response types used by runtime inspection endpoints
pub mod diagnostics {
    pub use o_sfu_telemetry::diagnostics::*;
}

/// process-local metric catalog and typed recorders
///
/// runtime edges record through this facade instead of assembling metric names
/// or label sets manually
/// the Prometheus renderer reads the catalog declared by these types
pub mod metrics {
    pub use crate::engine::metrics::*;
}

/// recording sink trait used by media routing code
///
/// recording integrations register packet sinks through the packet-sink
/// registry while transport code only depends on this narrow sink contract
pub mod recording {
    pub use crate::engine::packet_sink_registry::PacketSink as MediaPacketSink;
}

/// room packet-sink registry shared by transport workers
///
/// packet sinks are looked up by room when media has to fan out to recording or
/// other non-local destinations
/// the registry keeps that routing concern out of packet-loop callers
pub mod packet_sinks {
    pub use crate::engine::packet_sink_registry::{
        PacketSink, RegisteredPacketSink, RoomPacketSinkRegistry,
    };
}

/// room manager, room runtime and user-session integration types
///
/// this facade is the server crate's entry point for admitting users, sending
/// outbound messages and reading room statistics
/// pure routing and transport details remain behind the room API
///
/// # Slow-consumer shutdown
///
/// [`room::UserOutboundSender::send`] queues output without waiting for
/// capacity
/// when the queue is full it also records an overflow sentinel
/// [`room::UserOutboundReceiver::recv_event`] returns that sentinel before
/// output that was already queued
/// the caller should stop normal draining after
/// [`room::UserOutboundEvent::Overflow`]
///
/// ```
/// # use std::sync::Arc;
/// # use o_sfu_core::server::{
/// #     metrics::RuntimeMetrics,
/// #     room::{
/// #         RoomEventMessage, UserOutbound, UserOutboundEvent, UserOutboundSendError,
/// #         UserOutboundSender,
/// #     },
/// #     session::UserId,
/// # };
/// # #[tokio::main(flavor = "current_thread")]
/// # async fn main() {
/// let (sender, mut receiver) =
///     UserOutboundSender::channel(1, Arc::new(RuntimeMetrics::default()));
/// let departed = |id| {
///     UserOutbound::Message(RoomEventMessage::UserDeparted {
///         user_id: UserId::Integer(id),
///     })
/// };
/// let queued_output = departed(1);
/// assert!(sender.send(queued_output).is_ok());
///
/// assert!(matches!(
///     sender.send(departed(2)),
///     Err(UserOutboundSendError::Full(_))
/// ));
/// assert!(matches!(
///     receiver.recv_event().await,
///     UserOutboundEvent::Overflow(_)
/// ));
/// # }
/// ```
pub mod room {
    #[cfg(any(test, feature = "testing-transport"))]
    pub mod test_support {
        pub use crate::engine::{
            room::{NegotiatedPublish, RoomManagerTestApi, RoomTestApi},
            source_model::test_support::{
                TestSourceKind, TestSubscriptionStates, source_kind_for_stream_id,
                source_publish_intent_for_source, stream_id_for_source,
                subscription_intents_from_test_states,
            },
        };
    }

    #[cfg(feature = "internal-benchmarks")]
    pub mod benchmark_support {
        pub use crate::engine::room::run_source_policy_turn_for_benchmark;
    }

    #[cfg(any(test, feature = "testing-transport"))]
    pub use crate::engine::room::{ConsumerRouteState, JoinPlacementTestGate};
    pub use crate::{
        MediaWorkerId,
        engine::room::{
            BroadcastPayload, BroadcastPayloadError, DEFAULT_USER_OUTBOUND_QUEUE_BYTE_CAPACITY,
            DEFAULT_USER_OUTBOUND_QUEUE_CAPACITY, IncomingBitrateSnapshot, JoinUserRequest,
            MAX_BROADCAST_PAYLOAD_BYTES, RemoteTrackProjection, RemoteTrackSnapshot, Room,
            RoomAdmissionPolicy, RoomConfig, RoomDetailCapture, RoomEventMessage, RoomJoinError,
            RoomManager, RoomManagerJoinError, RoomManagerServeError, RoomMediaCounts,
            RoomOverviewCapture, RoomRuntimeContext, RoomRuntimePolicy, RoomUserAdmission,
            RoomUserCapture, RoomUserPermissions, RoomUserStatsSnapshot, RoomUsersCapture,
            RouterPlacement, RouterPlacements, RouterPlacementsError, RuntimeRoomDirectorySnapshot,
            RuntimeRoomStatsSnapshot, UserCloseReason, UserOutbound, UserOutboundEvent,
            UserOutboundOverflow, UserOutboundOverflowKind, UserOutboundQueueLimits,
            UserOutboundReceiver, UserOutboundSendError, UserOutboundSender,
        },
    };
}

/// signaling-domain payloads shared by rooms and WebSocket sessions
///
/// these types describe users, features, permissionsm recording state and
/// host-visible close codes
/// they are re-exported here so the runtime does not import private room or
/// engine modules for protocol payload construction
pub mod session {
    pub use crate::engine::{
        AvailableFeatures, JsonPayload, PeerSnapshot, RecordingOptions, RecordingState,
        RecordingStateUpdate, StopCode, UserId, UserInfo, UserPermissions, VideoLayoutIntent,
        WebSocketCloseCode,
    };
}

/// source descriptor model accepted by publication and subscription flows
///
/// source-model types make published media identity explicit before it reaches
/// room routing or transport negotiation
pub mod source_model {
    pub use crate::engine::source_model::{
        PublishedSourceDescriptor, PublishedSourceDescriptorParts, PublishedSourceId,
        PublishedSourceOwner, SourceEncodingDescriptor, SourceEncodingDescriptorParts,
        SourceEncodingId, SourceModelError,
    };
}

/// media transport construction and extension boundary
///
/// the runtime builds one `MediaTransport` from owner configuration and process
/// services then room code uses the opaque handle for media operations
///
/// code above this module should not branch on RTC worker internals
pub mod transport {

    #[cfg(any(test, feature = "testing-transport"))]
    pub mod test_support {
        //! non-production media transport route inspectors

        pub use crate::engine::media_transport::test_support::*;
    }

    #[cfg(feature = "internal-benchmarks")]
    pub mod benchmark_support {
        //! feature-gated packet-loop benchmark fixtures

        pub use crate::engine::media_transport::benchmark_support::*;
    }

    #[cfg(any(test, fuzzing))]
    pub mod fuzz_support {
        pub use crate::engine::media_transport::fuzz_support::{
            client_rtp_capabilities_from_answer, route_packet_loop_ingress_demux,
        };
    }

    pub use crate::{
        MediaWorkerId,
        engine::media_transport::{
            ActiveSpeakerActivityReason, ActiveSpeakerActivityState, ActiveSpeakerSource,
            ActiveSpeakerSourceDiagnostic, AppliedProducer, AppliedSessionAnswer, ConsumerActivity,
            MediaTransport, MediaTransportBuildError, MediaTransportConfig, MediaTransportDeps,
            ProducerActivity, ReceiverBandwidthSnapshot, RelayRouteActivity, SessionOffer,
            SessionUploadEncoding, SessionUploadSlot, SourcePacketGate, SourcePolicySignal,
            SourcePolicyUpdateSubscription, TransportAdapterError, TransportBitrateSnapshot,
            TransportConsumerRoute, TransportHealthSnapshot, TransportMediaId,
            TransportQualitySample, TransportQualitySnapshot, TransportRelayRouteAction,
            TransportRelayRouteEffect, TransportResult, TransportSessionHealth,
            TransportSessionKey, TransportSourceDiagnosticsSnapshot, TransportSourceKey,
            TransportWorkerPressureSnapshot,
        },
        prelude::SessionBitrateLimits,
    };
}