loro-ffi 1.13.6

use std::sync::Arc;

use loro::{ContainerTrait, LoroResult};

use crate::{ContainerID, DiffEvent, LoroDoc, Subscriber, Subscription};

#[derive(Debug, Clone)]
pub struct LoroCounter {
    pub(crate) inner: loro::LoroCounter,
}

impl LoroCounter {
    pub fn new() -> Self {
        Self {
            inner: loro::LoroCounter::new(),
        }
    }

    /// Whether the container is attached to a document
    ///
    /// The edits on a detached container will not be persisted.
    /// To attach the container to the document, please insert it into an attached container.
    pub fn is_attached(&self) -> bool {
        self.inner.is_attached()
    }

    /// If a detached container is attached, this method will return its corresponding attached handler.
    pub fn get_attached(&self) -> Option<Arc<LoroCounter>> {
        self.inner
            .get_attached()
            .map(|x| Arc::new(LoroCounter { inner: x }))
    }

    /// Return container id of the Counter.
    pub fn id(&self) -> ContainerID {
        self.inner.id().into()
    }

    /// Increment the counter by the given value.
    pub fn increment(&self, value: f64) -> LoroResult<()> {
        self.inner.increment(value)
    }

    /// Decrement the counter by the given value.
    pub fn decrement(&self, value: f64) -> LoroResult<()> {
        self.inner.decrement(value)
    }

    /// Get the current value of the counter.
    pub fn get_value(&self) -> f64 {
        self.inner.get_value()
    }

    pub fn is_deleted(&self) -> bool {
        self.inner.is_deleted()
    }

    pub fn doc(&self) -> Option<Arc<LoroDoc>> {
        self.inner.doc().map(|x| Arc::new(LoroDoc { doc: x }))
    }

    pub fn subscribe(&self, subscriber: Arc<dyn Subscriber>) -> Option<Arc<Subscription>> {
        self.inner
            .subscribe(Arc::new(move |e| {
                subscriber.on_diff(DiffEvent::from(e));
            }))
            .map(|x| Arc::new(x.into()))
    }
}

impl Default for LoroCounter {
    fn default() -> Self {
        Self::new()
    }
}