bmux_plugin 0.0.1-alpha.3

//! Generic process-local handlers for attach presentation input endpoints.

use crate::{AttachInputEndpoint, AttachInputEvent, AttachInputResult};
use std::collections::BTreeMap;
use std::sync::{Arc, OnceLock, RwLock};

pub type AttachPresentationInputHandler =
    Arc<dyn Fn(&AttachInputEvent) -> Option<AttachInputResult> + Send + Sync>;

/// Explicit opt-in lifecycle callback for process-local retained controls.
///
/// The argument is the owner-scoped hook identity losing focus. The return
/// value indicates that retained presentation changed. No input is synthesized.
pub type AttachPresentationFocusLostHandler = Arc<dyn Fn(&str) -> bool + Send + Sync>;

pub type AttachPresentationPasteHandler =
    Arc<dyn Fn(&str, &str) -> AttachInputResult + Send + Sync>;

/// Opt-in notification for a successfully flushed retained surface revision.
pub type AttachPresentationCommittedHandler = Arc<dyn Fn(u64) + Send + Sync>;

pub type AttachPresentationResponseHandler = Arc<dyn Fn(&[u8]) -> AttachInputResult + Send + Sync>;

#[derive(Default)]
pub struct AttachPresentationInputRegistry {
    shortcuts: RwLock<BTreeMap<AttachInputEndpoint, AttachPresentationInputHandler>>,
    responses: RwLock<BTreeMap<AttachInputEndpoint, AttachPresentationResponseHandler>>,
    committed: RwLock<BTreeMap<AttachInputEndpoint, AttachPresentationCommittedHandler>>,
    paste: RwLock<BTreeMap<AttachInputEndpoint, AttachPresentationPasteHandler>>,
    handlers: RwLock<BTreeMap<AttachInputEndpoint, AttachPresentationInputHandler>>,
    focus_lost: RwLock<BTreeMap<AttachInputEndpoint, AttachPresentationFocusLostHandler>>,
}

impl AttachPresentationInputRegistry {
    #[must_use]
    pub fn new() -> Self {
        Self::default()
    }

    pub fn register_shortcut(
        &self,
        endpoint: AttachInputEndpoint,
        handler: AttachPresentationInputHandler,
    ) {
        if let Ok(mut handlers) = self.shortcuts.write() {
            handlers.insert(endpoint, handler);
        }
    }

    #[allow(clippy::needless_collect)] // Release registry lock before invoking callbacks that may unregister themselves.
    pub fn shortcut(&self, event: &AttachInputEvent) -> Option<AttachInputResult> {
        let handlers = self
            .shortcuts
            .read()
            .ok()?
            .values()
            .cloned()
            .collect::<Vec<_>>();
        handlers
            .into_iter()
            .find_map(|handler| handler(event).filter(|result| result.consumed))
    }

    pub fn register_response(
        &self,
        endpoint: AttachInputEndpoint,
        handler: AttachPresentationResponseHandler,
    ) {
        if let Ok(mut handlers) = self.responses.write() {
            handlers.insert(endpoint, handler);
        }
    }

    pub fn response(
        &self,
        endpoint: &AttachInputEndpoint,
        payload: &[u8],
    ) -> Option<AttachInputResult> {
        let handler = self.responses.read().ok()?.get(endpoint)?.clone();
        Some(handler(payload))
    }

    pub fn register(&self, endpoint: AttachInputEndpoint, handler: AttachPresentationInputHandler) {
        if let Ok(mut handlers) = self.handlers.write() {
            handlers.insert(endpoint, handler);
        }
    }

    #[must_use]
    pub fn invoke(
        &self,
        endpoint: &AttachInputEndpoint,
        event: &AttachInputEvent,
    ) -> Option<AttachInputResult> {
        self.handlers
            .read()
            .ok()
            .and_then(|handlers| handlers.get(endpoint).cloned())
            .and_then(|handler| handler(event))
    }

    pub fn register_focus_lost(
        &self,
        endpoint: AttachInputEndpoint,
        handler: AttachPresentationFocusLostHandler,
    ) {
        if let Ok(mut handlers) = self.focus_lost.write() {
            handlers.insert(endpoint, handler);
        }
    }

    #[must_use]
    pub fn observes_focus_loss(&self, endpoint: &AttachInputEndpoint) -> bool {
        self.focus_lost
            .read()
            .is_ok_and(|handlers| handlers.contains_key(endpoint))
    }

    #[must_use]
    pub fn notify_focus_lost(&self, endpoint: &AttachInputEndpoint, hook_id: &str) -> bool {
        let handler = self
            .focus_lost
            .read()
            .ok()
            .and_then(|handlers| handlers.get(endpoint).cloned());
        handler.is_some_and(|handler| handler(hook_id))
    }

    pub fn register_paste(
        &self,
        endpoint: AttachInputEndpoint,
        handler: AttachPresentationPasteHandler,
    ) {
        if let Ok(mut handlers) = self.paste.write() {
            handlers.insert(endpoint, handler);
        }
    }

    #[must_use]
    pub fn paste(
        &self,
        endpoint: &AttachInputEndpoint,
        hook: &str,
        text: &str,
    ) -> Option<AttachInputResult> {
        let handler = self
            .paste
            .read()
            .ok()
            .and_then(|handlers| handlers.get(endpoint).cloned());
        handler.map(|handler| handler(hook, text))
    }

    pub fn register_committed(
        &self,
        endpoint: AttachInputEndpoint,
        handler: AttachPresentationCommittedHandler,
    ) {
        if let Ok(mut handlers) = self.committed.write() {
            handlers.insert(endpoint, handler);
        }
    }

    pub fn committed(&self, endpoint: &AttachInputEndpoint, revision: u64) {
        let handler = self
            .committed
            .read()
            .ok()
            .and_then(|handlers| handlers.get(endpoint).cloned());
        if let Some(handler) = handler {
            handler(revision);
        }
    }

    pub fn remove(&self, endpoint: &AttachInputEndpoint) {
        if let Ok(mut handlers) = self.shortcuts.write() {
            handlers.remove(endpoint);
        }
        if let Ok(mut handlers) = self.responses.write() {
            handlers.remove(endpoint);
        }
        if let Ok(mut handlers) = self.committed.write() {
            handlers.remove(endpoint);
        }
        if let Ok(mut handlers) = self.paste.write() {
            handlers.remove(endpoint);
        }
        if let Ok(mut handlers) = self.focus_lost.write() {
            handlers.remove(endpoint);
        }
        if let Ok(mut handlers) = self.handlers.write() {
            handlers.remove(endpoint);
        }
    }
}

static GLOBAL_REGISTRY: OnceLock<Arc<AttachPresentationInputRegistry>> = OnceLock::new();

#[must_use]
pub fn global_attach_presentation_input_registry() -> &'static AttachPresentationInputRegistry {
    GLOBAL_REGISTRY.get_or_init(|| Arc::new(AttachPresentationInputRegistry::new()))
}

/// Shared ownership of the default presentation's input registry.
#[must_use]
pub fn global_attach_presentation_input_registry_handle() -> Arc<AttachPresentationInputRegistry> {
    GLOBAL_REGISTRY
        .get_or_init(|| Arc::new(AttachPresentationInputRegistry::new()))
        .clone()
}

pub fn register_attach_presentation_input_handler(
    endpoint: AttachInputEndpoint,
    handler: AttachPresentationInputHandler,
) {
    global_attach_presentation_input_registry().register(endpoint, handler);
}

#[must_use]
pub fn invoke_attach_presentation_input_handler(
    endpoint: &AttachInputEndpoint,
    event: &AttachInputEvent,
) -> Option<AttachInputResult> {
    global_attach_presentation_input_registry().invoke(endpoint, event)
}

pub fn remove_attach_presentation_input_handler(endpoint: &AttachInputEndpoint) {
    global_attach_presentation_input_registry().remove(endpoint);
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn focus_loss_is_opt_in_and_removed_with_handler() {
        let registry = AttachPresentationInputRegistry::new();
        let endpoint = AttachInputEndpoint {
            capability: "example.input".to_string(),
            interface_id: "presentation-input".to_string(),
            operation: "handle-input".to_string(),
        };
        assert!(!registry.observes_focus_loss(&endpoint));
        assert!(!registry.notify_focus_lost(&endpoint, "owner:surface:region"));
        registry.register_focus_lost(
            endpoint.clone(),
            Arc::new(|hook| {
                assert_eq!(hook, "owner:surface:region");
                true
            }),
        );
        assert!(registry.observes_focus_loss(&endpoint));
        assert!(registry.notify_focus_lost(&endpoint, "owner:surface:region"));
        registry.remove(&endpoint);
        assert!(!registry.notify_focus_lost(&endpoint, "owner:surface:region"));
    }

    #[test]
    fn registered_handler_is_invoked_by_endpoint() {
        let registry = AttachPresentationInputRegistry::new();
        let endpoint = AttachInputEndpoint {
            capability: "example.input".to_string(),
            interface_id: "presentation-input".to_string(),
            operation: "handle-input".to_string(),
        };
        registry.register(
            endpoint.clone(),
            Arc::new(|_| {
                Some(AttachInputResult {
                    consumed: true,
                    ..AttachInputResult::default()
                })
            }),
        );
        let event = AttachInputEvent {
            hook_id: String::new(),
            event_kind: "pointer".to_string(),
            phase: "move".to_string(),
            button: None,
            key: None,
            col: Some(0),
            row: Some(0),
            wheel_delta: 0,
            modifiers: crate::AttachInputModifiers::default(),
            focused_pane: None,
            hovered_pane: None,
        };
        assert!(registry.invoke(&endpoint, &event).unwrap().consumed);
    }
}