loro-ffi 1.13.6

use std::sync::{Arc, Mutex};

use loro::{LoroResult, PeerID};

use crate::{Cursor, DiffEvent, LoroDoc, LoroValue, Side};

pub struct UndoManager(Mutex<loro::UndoManager>);

impl UndoManager {
    /// Create a new UndoManager.
    pub fn new(doc: &LoroDoc) -> Self {
        Self(Mutex::new(loro::UndoManager::new(doc)))
    }

    /// Undo the last change made by the peer.
    pub fn undo(&self) -> LoroResult<bool> {
        self.0.lock().unwrap().undo()
    }

    /// Redo the last change made by the peer.
    pub fn redo(&self) -> LoroResult<bool> {
        self.0.lock().unwrap().redo()
    }

    /// Record a new checkpoint.
    pub fn record_new_checkpoint(&self) -> LoroResult<()> {
        self.0.lock().unwrap().record_new_checkpoint()
    }

    /// Whether the undo manager can undo.
    pub fn can_undo(&self) -> bool {
        self.0.lock().unwrap().can_undo()
    }

    /// Whether the undo manager can redo.
    pub fn can_redo(&self) -> bool {
        self.0.lock().unwrap().can_redo()
    }

    /// How many times the undo manager can undo.
    pub fn undo_count(&self) -> u32 {
        self.0.lock().unwrap().undo_count() as u32
    }

    /// How many times the undo manager can redo.
    pub fn redo_count(&self) -> u32 {
        self.0.lock().unwrap().redo_count() as u32
    }

    /// If a local event's origin matches the given prefix, it will not be recorded in the
    /// undo stack.
    pub fn add_exclude_origin_prefix(&self, prefix: &str) {
        self.0.lock().unwrap().add_exclude_origin_prefix(prefix)
    }

    /// Set the maximum number of undo steps. The default value is 100.
    pub fn set_max_undo_steps(&self, size: u32) {
        self.0.lock().unwrap().set_max_undo_steps(size as usize)
    }

    /// Set the merge interval in ms. The default value is 0, which means no merge.
    pub fn set_merge_interval(&self, interval: i64) {
        self.0.lock().unwrap().set_merge_interval(interval)
    }

    /// Set the listener for push events.
    /// The listener will be called when a new undo/redo item is pushed into the stack.
    pub fn set_on_push(&self, on_push: Option<Arc<dyn OnPush>>) {
        if let Some(on_push) = on_push {
            self.0
                .lock()
                .unwrap()
                .set_on_push(Some(Box::new(move |u, c, e| {
                    loro::UndoItemMeta::from(on_push.on_push(u, c, e.map(|x| x.into())))
                })));
        } else {
            self.0.lock().unwrap().set_on_push(None);
        }
    }

    /// Set the listener for pop events.
    /// The listener will be called when an undo/redo item is popped from the stack.
    pub fn set_on_pop(&self, on_pop: Option<Arc<dyn OnPop>>) {
        if let Some(on_pop) = on_pop {
            self.0
                .lock()
                .unwrap()
                .set_on_pop(Some(Box::new(move |u, c, m| {
                    on_pop.on_pop(u, c, UndoItemMeta::from(m))
                })));
        } else {
            self.0.lock().unwrap().set_on_pop(None);
        }
    }

    pub fn group_start(&self) -> LoroResult<()> {
        self.0.lock().unwrap().group_start()
    }

    pub fn group_end(&self) {
        self.0.lock().unwrap().group_end()
    }

    pub fn peer(&self) -> PeerID {
        self.0.lock().unwrap().peer()
    }

    pub fn top_undo_meta(&self) -> Option<UndoItemMeta> {
        self.0
            .lock()
            .unwrap()
            .top_undo_meta()
            .map(UndoItemMeta::from)
    }

    pub fn top_redo_meta(&self) -> Option<UndoItemMeta> {
        self.0
            .lock()
            .unwrap()
            .top_redo_meta()
            .map(UndoItemMeta::from)
    }

    pub fn top_undo_value(&self) -> Option<LoroValue> {
        self.0.lock().unwrap().top_undo_value().map(Into::into)
    }

    pub fn top_redo_value(&self) -> Option<LoroValue> {
        self.0.lock().unwrap().top_redo_value().map(Into::into)
    }
}

#[uniffi::trait_interface]
pub trait OnPush: Send + Sync {
    fn on_push(
        &self,
        undo_or_redo: loro::UndoOrRedo,
        counter_span: loro::CounterSpan,
        diff_event: Option<DiffEvent>,
    ) -> UndoItemMeta;
}

#[uniffi::trait_interface]
pub trait OnPop: Send + Sync {
    fn on_pop(
        &self,
        undo_or_redo: loro::undo::UndoOrRedo,
        counter_span: loro::CounterSpan,
        undo_meta: UndoItemMeta,
    );
}

#[derive(Debug, Clone)]
pub struct UndoItemMeta {
    pub value: LoroValue,
    pub cursors: Vec<CursorWithPos>,
}

impl From<loro::undo::UndoItemMeta> for UndoItemMeta {
    fn from(meta: loro::undo::UndoItemMeta) -> Self {
        Self {
            value: meta.value.into(),
            cursors: meta
                .cursors
                .into_iter()
                .map(|c| CursorWithPos {
                    cursor: Arc::new(c.cursor.into()),
                    pos: AbsolutePosition {
                        pos: c.pos.pos as u32,
                        side: c.pos.side,
                    },
                })
                .collect(),
        }
    }
}

impl From<&UndoItemMeta> for loro::undo::UndoItemMeta {
    fn from(meta: &UndoItemMeta) -> Self {
        loro::undo::UndoItemMeta {
            value: (&meta.value).into(),
            cursors: meta
                .cursors
                .iter()
                .map(|c| loro::undo::CursorWithPos {
                    cursor: c.cursor.as_ref().clone().into(),
                    pos: loro::cursor::AbsolutePosition {
                        pos: c.pos.pos as usize,
                        side: c.pos.side,
                    },
                })
                .collect(),
        }
    }
}

impl From<UndoItemMeta> for loro::undo::UndoItemMeta {
    fn from(meta: UndoItemMeta) -> Self {
        loro::undo::UndoItemMeta {
            value: (meta.value).into(),
            cursors: meta
                .cursors
                .into_iter()
                .map(|c| loro::undo::CursorWithPos {
                    cursor: c.cursor.as_ref().clone().into(),
                    pos: loro::cursor::AbsolutePosition {
                        pos: c.pos.pos as usize,
                        side: c.pos.side,
                    },
                })
                .collect(),
        }
    }
}

#[derive(Debug, Clone)]
pub struct CursorWithPos {
    pub cursor: Arc<Cursor>,
    pub pos: AbsolutePosition,
}

#[derive(Debug, Clone, Copy)]
pub struct AbsolutePosition {
    pub pos: u32,
    pub side: Side,
}