msnp11-sdk 0.12.1

use crate::errors::messaging_error::MessagingError;
use crate::errors::p2p_error::P2pError;
use crate::errors::sdk_error::SdkError;
use crate::event_handler::EventHandler;
use crate::{PlainText, Switchboard};
use std::sync::Arc;
use tokio::runtime::Runtime;

/// Wraps an obtained [Switchboard][crate::switchboard_server::switchboard_server::Switchboard] object for use outside a tokio runtime.
/// [Switchboard][crate::switchboard_server::switchboard_server::Switchboard] represents a messaging session with one or more
/// contacts. The official MSN clients usually create a new session every time a conversation
/// window is opened and leave it once it's closed.
#[derive(uniffi::Object)]
pub struct SwitchboardWrapper {
    inner: Arc<Switchboard>,
    rt: Runtime,
}

#[uniffi::export]
impl SwitchboardWrapper {
    /// Create new wrapper instance with an obtained [Switchboard][crate::switchboard_server::switchboard_server::Switchboard].
    #[uniffi::constructor]
    pub fn new(switchboard: Arc<Switchboard>) -> Result<Self, SdkError> {
        let rt = Runtime::new().or(Err(SdkError::CouldNotCreateRuntime))?;
        Ok(Self {
            inner: switchboard,
            rt,
        })
    }

    /// Adds a new handler that implements the [EventHandler] trait.
    pub fn add_event_handler(&self, handler: Arc<dyn EventHandler>) {
        self.rt
            .block_on(async { self.inner.add_event_handler(handler) })
    }

    /// Invites a new contact to this switchboard session. This makes it a temporary group chat.
    pub async fn invite(&self, email: &str) -> Result<(), SdkError> {
        self.inner.invite(email).await
    }

    /// Returns the session ID, if defined.
    pub async fn get_session_id(&self) -> Result<String, MessagingError> {
        self.inner.get_session_id().await
    }

    /// Sends a plain text message to the session.
    pub async fn send_text_message(&self, message: &PlainText) -> Result<(), MessagingError> {
        self.inner.send_text_message(message).await
    }

    /// Sends a nudge to the session.
    pub async fn send_nudge(&self) -> Result<(), MessagingError> {
        self.inner.send_nudge().await
    }

    /// Sends an "is writing..." notification to the session.
    pub async fn send_typing_user(&self, email: &str) -> Result<(), MessagingError> {
        self.inner.send_typing_user(email).await
    }

    /// Requests a contact's display picture and handles the transfer process. A [DisplayPicture][Event::DisplayPicture] event
    /// is received once the transfer is complete.
    pub async fn request_contact_display_picture(
        &self,
        email: &str,
        msn_object: &str,
    ) -> Result<(), P2pError> {
        self.rt.block_on(async {
            self.inner
                .request_contact_display_picture(email, msn_object)
                .await
        })
    }

    /// Disconnects from the Switchboard.
    pub async fn disconnect(&self) -> Result<(), SdkError> {
        self.inner.disconnect().await
    }
}