lingxia-webview 0.6.3

use crate::WebViewError;
use napi_ohos::Status;
use napi_ohos::bindgen_prelude::Function;
use napi_ohos::threadsafe_function::{ThreadsafeCallContext, ThreadsafeFunctionCallMode};
use std::sync::OnceLock;

// Global ThreadSafe Function storage
//
// Node-API ThreadSafe Function limitation: napi_call_threadsafe_function() can only
// pass a single void* data pointer. To pass multiple parameters, we pack them into
// a single string with colon separator: "function_name:arg1:arg2:..."
// Store the actual ThreadsafeFunction type with correct parameters
type TsfnType = napi_ohos::threadsafe_function::ThreadsafeFunction<
    String,
    napi_ohos::Unknown<'static>,
    String,
    napi_ohos::Status,
    false,
    false,
    200,
>;
static CALLBACK_TSFN: OnceLock<TsfnType> = OnceLock::new();

/// Initialize the ThreadSafe Function for TSFN calls
pub fn init(callback_function: Function<'static>) -> Result<(), String> {
    // Create ThreadSafe Function for callback - pass colon-separated string with function name and args
    let tsfn = callback_function
        .build_threadsafe_function::<String>()
        .callee_handled::<false>()
        .max_queue_size::<200>()
        .build_callback(|ctx: ThreadsafeCallContext<String>| {
            let data = ctx.value;
            log::info!("ThreadSafe callback called with data: {}", data);

            // Return the data string to ArkTS
            Ok(data)
        });

    let tsfn = match tsfn {
        Ok(tsfn) => {
            log::info!("ThreadSafe Function created successfully");
            tsfn
        }
        Err(e) => {
            log::error!("Failed to create threadsafe function: {:?}", e);
            return Err(format!("Failed to create threadsafe function: {:?}", e));
        }
    };

    // Store the ThreadSafe Function globally
    if CALLBACK_TSFN.set(tsfn).is_err() {
        log::error!("ThreadSafe Function already set");
        return Err("ThreadSafe Function already set".to_string());
    }

    Ok(())
}

/// Helper function for TSFN calls
pub fn call_arkts(name: &str, args: &[&str]) -> Result<(), WebViewError> {
    let tsfn = CALLBACK_TSFN.get().ok_or_else(|| {
        log::error!("TSFN not initialized");
        WebViewError::WebView("No callback".to_string())
    })?;

    let data = format!("{}|{}", name, args.join("|"));
    // log::info!("Calling TSFN with data: {}", data);

    match tsfn.call(data, ThreadsafeFunctionCallMode::NonBlocking) {
        Status::Ok => Ok(()),
        status => {
            log::error!("TSFN call failed for {}: {:?}", name, status);
            Err(WebViewError::WebView("TSFN call failed".to_string()))
        }
    }
}