pixelscript 0.5.11

// Copyright 2026 Jordan Castro <jordan@grupojvm.com>
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
//
use std::{
    collections::HashMap, ops::{BitAnd, BitOr}, os::raw::c_void, ptr, sync::{Arc, Mutex, OnceLock}
};

use crate::{pxs_debug, shared::{PtrMagic, module::ModuleCallback, var::{default_deleter, pxs_DeleterFn}}};

/// Flags for `ObjectCallback`.
/// 
/// Define how to setup the object in backend.
/// 
/// When `UsesId`, the callback should use `_pxs_ptr`.
/// When `UsesRef`, the callback should use the language reference.
/// When `IsProp`, the callback should be used as a getter/setter.
pub enum ObjectFlags {
    UsesId = 1 << 0,
    UsesRef = 1 << 1,
    IsProp = 1 << 2
}

impl BitOr for ObjectFlags {
    type Output = u8;

    fn bitor(self, rhs: Self) -> Self::Output {
        (self as u8) | (rhs as u8)
    }
}

impl BitAnd for ObjectFlags {
    type Output = u8;

    fn bitand(self, rhs: Self) -> Self::Output {
        (self as u8) & (rhs as u8)
    }
}

/// What objects use for callbacks. They are wrappers around ModuleCallbck.
/// 
/// When `is_id` is true, when setting up this callback it should pass the `_pxs_ptr`.
/// Otherwise it will pass the actual language reference.
/// 
/// When `is_prop` is true, the method will act as a property. 
#[derive(Clone)]
pub struct ObjectCallback {
    /// The internal callback structure (same as module.)
    pub cbk: ModuleCallback,
    /// Flags for determining how a object method should be defined
    pub flags: u8
}

/// A PixelScript Object.
///
/// The way this works is via the host, a Pseudo type can be created. So when the scripting
/// language interacts with the object, it calls it's pseudo methods.
///
/// example:
/// ```c
/// struct Person {
///     const char* name;
///     int age;
///
///     Person(const char* name, int age) {
///         this->name = name;
///         this->age = age;
///     }
///
///     void set_name(const char* name) {
///         this->name = name;
///     }
///
///     void set_age(int age) {
///         this->age = age;
///     }
///
///     int get_age() {
///         return this->age;
///     }
///
///     const char* get_name() {
///         return this->name;
///     }
/// };
///
/// void free_person(void* p) {
///     // TODO
/// }
/// Var* person_set_name(int argc, Var** argv, void* opaque) {
///     Var* object = argv[0];
///     Person* p = object.value.object_val as Person;
///     Var* name = argv[1];
///     p->set_name(name.value.string_val);
///     return NULL;
/// }
/// Var* new_person(int argc, Var** argv, void* opaque) {
///     Person* p = malloc();
///     PixelObject* object_ptr = pixelscript_new_object(p, free_person);
///     pixelscript_object_add_callback(object_ptr, "set_name", person_set_name);
///     return pixelscript_var_object(object_ptr);
/// }
///
/// // OOP base
/// pixelscript_add_object("Person", new_person);
///
/// // Or functional
/// pixelscript_add_callback("new_person", new_person);
/// ```
///
/// In a JS example:
/// ```js
/// let p = new Person("Jordan");
/// p.set_name("James");
/// ```
///
/// This is why a Objects are more like Pseudo types than actual class/objects.
#[allow(non_camel_case_types)]
pub struct pxs_PixelObject {
    /// Type name (this is a hash)
    pub type_name: String,
    /// The Host pointer
    pub ptr: *mut c_void,
    /// The language object pointer.
    pub lang_ptr: Mutex<*mut c_void>,
    /// The PXS FREE METHOD. This SHOULD NEVER EVER EVER BE TOUCHED in Host code.
    pxs_free_method: Mutex<pxs_DeleterFn>,
    /// The Method for freeing
    pub free_method: pxs_DeleterFn,
    /// Callbacks with names.
    ///
    /// Important to note that a PixelObject can not have `static` callbacks.
    ///
    /// The first Var will always be the ptr.
    pub callbacks: Vec<ObjectCallback>,
    // PixelObject does not hold variables. They are all getters/

    /// Refernce Counting. This is internal reference counting PXS side.
    pub ref_count: Mutex<u16>
}

impl pxs_PixelObject {
    pub fn new(ptr: *mut c_void, free_method: pxs_DeleterFn, type_name: &str) -> Self {
        Self {
            ptr,
            free_method,
            callbacks: vec![],
            lang_ptr: Mutex::new(ptr::null_mut()),
            type_name: type_name.to_string(),
            pxs_free_method: Mutex::new(default_deleter),
            ref_count: Mutex::new(1)
        }
    }

    pub fn add_callback(&mut self, name: &str, full_name: &str, idx: i32, flags: u8) {
        self.callbacks.push(
            ObjectCallback {
                cbk: ModuleCallback {
            name: name.to_string(),
            full_name: full_name.to_string(),
            idx,
        }, flags});
    }

    pub fn update_lang_ptr(&self, n_ptr: *mut c_void) {
        let mut guard = self.lang_ptr.lock().unwrap();

        if !guard.is_null() {
            eprintln!("Can not mutate if ptr is already set.");
            return;
        }

        *guard = n_ptr;
    }

    /// Update pxs_free method
    pub fn update_pxs_free_method(&self, free_method: pxs_DeleterFn) {
        let mut guard = self.pxs_free_method.lock().unwrap();

        *guard = free_method;
    }

    /// Add to reference counting
    pub fn add_reference(&self) {
        let mut guard = self.ref_count.lock().unwrap();
        *guard += 1;
    }

    /// Remove from reference counting
    pub fn sub_reference(&self) {
        let mut guard = self.ref_count.lock().unwrap();
        *guard -= 1;
    }

    /// Check current ref count
    pub fn current_ref_count(&self) -> u16 {
        let guard = self.ref_count.lock().unwrap();
        return *guard;
    }
}

impl PtrMagic for pxs_PixelObject {}
unsafe impl Send for pxs_PixelObject {}
unsafe impl Sync for pxs_PixelObject {}
impl Drop for pxs_PixelObject {
    fn drop(&mut self) {
        let mut lang_ptr = self.lang_ptr.lock().unwrap();
        if !lang_ptr.is_null() {
            // Free Language memory
            let pxs_free_method = self.pxs_free_method.get_mut().unwrap();
            unsafe { (pxs_free_method)(*lang_ptr); }
        }
        *lang_ptr = ptr::null_mut();
        if self.ptr.is_null() {
            return;
        }
        // pxs_debug!("Freeing ptr: {:#?}", self.ptr);
        // Free host memory
        unsafe {
            (self.free_method)(self.ptr);
        }
    }
}

/// Lookup state structure
pub struct ObjectLookup {
    /// Object hash shared between all runtimes.
    pub object_hash: HashMap<i32, Arc<pxs_PixelObject>>,
    /// next idx avail
    pub next_idx: i32
}

/// The object lookup!
static OBJECT_LOOKUP: OnceLock<Mutex<ObjectLookup>> = OnceLock::new();

/// Get the Object lookup global state. Shared between all runtimes.
fn get_object_lookup() -> std::sync::MutexGuard<'static, ObjectLookup> {
    OBJECT_LOOKUP
        .get_or_init(|| {
            Mutex::new(ObjectLookup {
                object_hash: HashMap::new(),
                next_idx: 0
            })
        })
        .lock()
        .unwrap()
}

/// Apply reference counting to object in lookup.
pub(crate) fn apply_ref_count_delete(idx: i32) {
    let mut lookup = get_object_lookup();
    // Check for object
    let object = lookup.object_hash.get(&idx);
    if let Some(object) = object {
        object.sub_reference();
        // Check # of references
        if object.current_ref_count() == 0 {
            // Drop it
            lookup.object_hash.remove(&idx);
        }
    }
}

/// Apply reference counting to a object in lookup.
/// Adds a new count if found.
pub(crate) fn apply_ref_count_alloc(idx: i32) {
    let lookup = get_object_lookup();
    // Check for object.
    let object = lookup.object_hash.get(&idx);
    if let Some(object) = object {
        object.add_reference();
    }
}

pub(crate) fn clear_object_lookup() {
    let mut lookup = get_object_lookup();
    pxs_debug!("Clearing object lookup size: {}", lookup.object_hash.len());
    lookup.object_hash.clear();
}

// add_object(Arc::clone(&pixel_arc))
pub(crate) fn lookup_add_object(pixel_obj: Arc<pxs_PixelObject>) -> i32 {
    let mut lookup = get_object_lookup();

    let idx = lookup.next_idx;

    lookup
        .object_hash
        .insert(idx as i32, Arc::clone(&pixel_obj));

    lookup.next_idx += 1;
    idx as i32
}

/// Get a PixelObject Arc
pub(crate) fn get_object(idx: i32) -> Option<Arc<pxs_PixelObject>> {
    let lookup = get_object_lookup();

    if let Some(res) = lookup.object_hash.get(&idx) {
        Some(res.to_owned())
    } else {
        None
    }
}