jarust_core 1.6.2

use crate::jasession::JaSession;
use crate::jasession::NewSessionParams;
use jarust_interface::janus_interface::JanusInterface;
use jarust_interface::janus_interface::JanusInterfaceImpl;
use jarust_interface::japrotocol::ServerInfoRsp;
use std::time::Duration;

#[derive(Clone, Debug)]
pub struct JaConnection {
    interface: JanusInterfaceImpl,
}

impl JaConnection {
    pub(crate) async fn open(
        interface: impl JanusInterface,
    ) -> Result<Self, jarust_interface::Error> {
        tracing::info!("Creating new connection");
        Ok(Self {
            interface: JanusInterfaceImpl::new(interface),
        })
    }

    /// Creates a new session with janus server.
    #[tracing::instrument(level = tracing::Level::DEBUG, skip_all)]
    pub async fn create_session(
        &mut self,
        ka_interval: u32,
        timeout: Duration,
    ) -> Result<JaSession, jarust_interface::Error> {
        tracing::info!("Creating new session");
        let session_id = self.interface.create(timeout).await?;
        let session = JaSession::new(NewSessionParams {
            session_id,
            ka_interval,
            interface: self.interface.clone(),
        })
        .await;
        tracing::info!(id = session_id, "Session created");
        Ok(session)
    }

    /// Retrieve Janus server info
    #[tracing::instrument(level = tracing::Level::DEBUG, skip_all)]
    pub async fn server_info(
        &self,
        timeout: Duration,
    ) -> Result<ServerInfoRsp, jarust_interface::Error> {
        let res = self.interface.server_info(timeout).await?;
        Ok(res)
    }
}