medea-jason 0.14.2

//! Functionality for calling Dart closures from Rust.
//!
//! Dart DL API doesn't allow calling Dart closures directly. So Dart registers
//! a static function that accepts and invokes the provided Dart closures.
//!
//! Dart side must register these function during the FFI initialization phase:
//! after Dart DL API is initialized and before any other exported Rust function
//! is called.

use std::marker::PhantomData;

use dart_sys::Dart_PersistentHandle;
use flutter_rust_bridge::DartOpaque;
use medea_macro::dart_bridge;

use crate::{
    api::DartValue,
    platform::{Callback, utils::dart_api},
};

#[dart_bridge("flutter/lib/src/native/ffi/function.g.dart")]
mod function {
    use dart_sys::Dart_Handle;

    use crate::{api::DartValue, platform::Error};

    /// Invokes other Dart closures that accept a [`DartValue`] argument.
    extern "C" {
        pub fn caller(f: Dart_Handle, val: DartValue) -> Result<(), Error>;
    }
}

impl<A: Into<DartValue>> Callback<A> {
    /// Invokes the underlying [`Function`] (if any) passing the single provided
    /// argument to it.
    pub fn call1<T: Into<A>>(&self, arg: T) {
        if let Some(f) = self.0.borrow().as_ref() {
            f.call1(arg.into());
        }
    }
}

/// Dart closure that can be called from Rust.
#[derive(Debug)]
pub struct Function<T> {
    /// [`Dart_PersistentHandle`] to the Dart closure that should be called.
    dart_fn: Dart_PersistentHandle,

    /// Type of this closure argument.
    _arg: PhantomData<*const T>,
}

impl<T> Function<T> {
    /// Creates a new [`Function`] from the provided [`Dart_Handle`] to a Dart
    /// closure, and persists the provided [`Dart_Handle`] so it won't be moved
    /// by the Dart VM GC.
    ///
    /// [`Dart_Handle`]: dart_sys::Dart_Handle
    #[must_use]
    pub fn new(cb: DartOpaque) -> Self {
        let opaque = cb.into_inner().unwrap();
        let ptr = opaque.create_dart_handle();
        let dart_fn = unsafe { dart_api::new_persistent_handle(ptr.cast()) };

        Self { dart_fn, _arg: PhantomData }
    }
}

impl Function<()> {
    /// Calls the underlying Dart closure.
    pub fn call0(&self) {
        self.call1(());
    }
}

impl<T: Into<DartValue>> Function<T> {
    /// Calls the underlying Dart closure with the provided argument.
    pub fn call1(&self, arg: T) {
        let fn_handle =
            unsafe { dart_api::handle_from_persistent(self.dart_fn) };
        unsafe { function::caller(fn_handle, arg.into()) }.unwrap();
    }
}

impl<T> Drop for Function<T> {
    /// Manually deallocates saved [`Dart_PersistentHandle`] so it won't leak.
    fn drop(&mut self) {
        unsafe {
            dart_api::delete_persistent_handle(self.dart_fn);
        }
    }
}