aspire 0.5.1

mod interrupt;
mod truth_value;
mod warning;

use std::cell::RefCell;
use std::ffi::CString;
use std::os::raw::{c_char, c_void};
use std::ptr;
use std::sync::{Arc, RwLock};

use crate::SymbolicFun;
use crate::config::Configuration;
use crate::error::{ClingoError, Error, check};
use crate::observer::{GroundStatement, ObserverState, make_observer};
use crate::solve::{SolveHandle, solve_yielding};
use crate::symbol::Symbol;

use self::interrupt::RawControlPtr;
use self::warning::logger_trampoline;

pub use self::interrupt::InterruptHandle;
pub use self::truth_value::TruthValue;
pub use self::warning::Warning;

/// Owns a `clingo_control_t` and frees it on drop.
///
/// This is the main entry point for grounding and solving logic programs.
pub struct Control {
    pub(crate) ptr: ptr::NonNull<clingo_sys::clingo_control_t>,
    // Shared with InterruptHandle; nulled on drop so late interrupts are no-ops.
    interrupt_ptr: Arc<RwLock<RawControlPtr>>,
    // Boxed logger closure, kept alive for the lifetime of the Control.
    // Must be dropped *after* ptr since clingo may call the logger during cleanup.
    #[expect(clippy::type_complexity)]
    _logger: Option<Box<Box<dyn FnMut(Warning, &str)>>>,
    // Observer state shared with clingo via raw pointer. Always registered;
    // when Some, observer callbacks accumulate into the state.
    // Swapped via RefCell on each ground_observed call.
    observer_state: Box<RefCell<Option<ObserverState>>>,
}

// clingo_control_t is single-threaded; do not send across threads.

impl Drop for Control {
    fn drop(&mut self) {
        // Null out the shared pointer so any outstanding InterruptHandles become no-ops.
        // The write lock ensures no interrupt call is in flight during free.
        self.interrupt_ptr.write().unwrap().0 = ptr::null_mut();
        unsafe {
            clingo_sys::clingo_control_free(self.ptr.as_ptr());
        }
    }
}

impl Control {
    /// Create a new control object.
    ///
    /// `args` are command-line style options forwarded to the grounder/solver
    /// (e.g. `["0"]` for enumerating all models).
    pub fn new(args: &[&str]) -> Result<Self, Error> {
        Self::with_logger(args, None::<fn(Warning, &str)>, 20)
    }

    /// Create a new control object with a custom logger.
    ///
    /// The logger receives a `Warning` code and message string.
    /// `message_limit` controls how many messages are reported
    /// before being suppressed (0 for unlimited).
    pub fn with_logger(
        args: &[&str],
        logger: Option<impl FnMut(Warning, &str) + 'static>,
        message_limit: u32,
    ) -> Result<Self, Error> {
        let c_args: Vec<CString> = args
            .iter()
            .map(|s| CString::new(*s))
            .collect::<Result<_, _>>()?;
        let c_ptrs: Vec<*const c_char> = c_args.iter().map(|s| s.as_ptr()).collect();

        let (logger_fn, logger_data, boxed_logger) = match logger {
            Some(f) => {
                #[expect(clippy::type_complexity)]
                let mut boxed: Box<Box<dyn FnMut(Warning, &str)>> = Box::new(Box::new(f));
                let data = &mut *boxed as *mut Box<dyn FnMut(Warning, &str)> as *mut c_void;
                (Some(logger_trampoline as _), data, Some(boxed))
            }
            None => (None, ptr::null_mut(), None),
        };

        let mut raw: *mut clingo_sys::clingo_control_t = ptr::null_mut();
        check(unsafe {
            clingo_sys::clingo_control_new(
                c_ptrs.as_ptr(),
                c_ptrs.len(),
                logger_fn,
                logger_data,
                message_limit as std::os::raw::c_uint,
                &mut raw,
            )
        })?;

        let observer_state = Box::new(RefCell::new(None));
        let observer = make_observer();

        let ctl_ptr =
            ptr::NonNull::new(raw).expect("clingo_control_new returned null without error");

        check(unsafe {
            clingo_sys::clingo_control_register_observer(
                ctl_ptr.as_ptr(),
                &observer,
                false,
                &*observer_state as *const RefCell<Option<ObserverState>> as *mut c_void,
            )
        })?;

        Ok(Control {
            ptr: ctl_ptr,
            interrupt_ptr: Arc::new(RwLock::new(RawControlPtr(ctl_ptr.as_ptr()))),
            _logger: boxed_logger,
            observer_state,
        })
    }

    /// Get a handle that can be used to interrupt a running solve from another thread.
    ///
    /// The returned handle is `Send + Sync + Clone`. If the `Control` is dropped
    /// before the handle is used, `interrupt()` becomes a no-op.
    pub fn interrupt_handle(&self) -> InterruptHandle {
        InterruptHandle {
            ptr: Arc::clone(&self.interrupt_ptr),
        }
    }

    /// Add a logic program block.
    ///
    /// `name` is the program section name (typically `"base"`).
    /// `parameters` are the parameter names of the program block
    /// (empty for `#program base.`).
    /// `program` is the ASP source text.
    pub fn add(&mut self, name: &str, parameters: &[&str], program: &str) -> Result<(), Error> {
        let c_name = CString::new(name)?;
        let c_params: Vec<CString> = parameters
            .iter()
            .map(|s| CString::new(*s))
            .collect::<Result<_, _>>()?;
        let c_param_ptrs: Vec<*const c_char> = c_params.iter().map(|s| s.as_ptr()).collect();
        let c_program = CString::new(program)?;

        check(unsafe {
            clingo_sys::clingo_control_add(
                self.ptr.as_ptr(),
                c_name.as_ptr(),
                c_param_ptrs.as_ptr(),
                c_param_ptrs.len(),
                c_program.as_ptr(),
            )
        })?;
        Ok(())
    }

    /// Ground the given program parts.
    ///
    /// Each element is `(name, &[symbol_values])`. For the common case of
    /// grounding just the `"base"` part with no parameters, use
    /// [`ground_base`](Self::ground_base).
    ///
    /// No external-function callback is supported yet — pass programs that
    /// don't use `@`-functions.
    pub fn ground(&mut self, parts: &[(&str, &[Symbol])]) -> Result<(), Error> {
        let c_names: Vec<CString> = parts
            .iter()
            .map(|(name, _)| CString::new(*name))
            .collect::<Result<_, _>>()?;

        let raw_params: Vec<Vec<clingo_sys::clingo_symbol_t>> = parts
            .iter()
            .map(|(_, params)| params.iter().map(|s| s.0).collect())
            .collect();

        let c_parts: Vec<clingo_sys::clingo_part_t> = c_names
            .iter()
            .zip(raw_params.iter())
            .map(|(c_name, params)| clingo_sys::clingo_part_t {
                name: c_name.as_ptr(),
                params: params.as_ptr(),
                size: params.len(),
            })
            .collect();

        check(unsafe {
            clingo_sys::clingo_control_ground(
                self.ptr.as_ptr(),
                c_parts.as_ptr(),
                c_parts.len(),
                None,
                ptr::null_mut(),
            )
        })?;
        Ok(())
    }

    /// Convenience: ground just the `"base"` part with no parameters.
    pub fn ground_base(&mut self) -> Result<(), Error> {
        self.ground(&[("base", &[])])
    }

    /// Ground and return the observed statements.
    ///
    /// The observer captures all ground statements produced during grounding.
    pub fn ground_observed(
        &mut self,
        parts: &[(&str, &[Symbol])],
    ) -> Result<Vec<GroundStatement>, Error> {
        // Swap in a fresh state to collect into.
        *self.observer_state.borrow_mut() = Some(ObserverState::new());
        self.ground(parts)?;
        // Swap out the state and convert.
        let state = self.observer_state.borrow_mut().take().unwrap();
        Ok(state.into_statements())
    }

    /// Convenience: observe the `"base"` part with no parameters.
    pub fn ground_base_observed(&mut self) -> Result<Vec<GroundStatement>, Error> {
        self.ground_observed(&[("base", &[])])
    }

    /// Solve the program, returning a handle for iterating models one at a time.
    ///
    /// The handle borrows the control mutably. Call `next_model()` to advance,
    /// then `close()` to get the final result.
    pub fn solve_iter(&mut self) -> Result<SolveHandle<'_>, ClingoError> {
        solve_yielding(self)
    }

    /// Get the configuration object for reading and modifying solver settings.
    pub fn configuration(&mut self) -> Result<Configuration<'_>, ClingoError> {
        let mut cfg: *mut clingo_sys::clingo_configuration_t = ptr::null_mut();
        check(unsafe { clingo_sys::clingo_control_configuration(self.ptr.as_ptr(), &mut cfg) })?;
        let mut root: clingo_sys::clingo_id_t = 0;
        check(unsafe { clingo_sys::clingo_configuration_root(cfg, &mut root) })?;
        Ok(unsafe { Configuration::new(cfg, root) })
    }

    /// Look up a symbol in the symbolic atoms table.
    ///
    /// Returns the (table, iterator) pair, or `None` if not found.
    fn find_symbolic_atom(
        &self,
        symbol: Symbol,
    ) -> Result<
        Option<(
            *const clingo_sys::clingo_symbolic_atoms_t,
            clingo_sys::clingo_symbolic_atom_iterator_t,
        )>,
        ClingoError,
    > {
        let mut atoms: *const clingo_sys::clingo_symbolic_atoms_t = ptr::null();
        check(unsafe { clingo_sys::clingo_control_symbolic_atoms(self.ptr.as_ptr(), &mut atoms) })?;

        let mut iter: clingo_sys::clingo_symbolic_atom_iterator_t = 0;
        check(unsafe { clingo_sys::clingo_symbolic_atoms_find(atoms, symbol.raw(), &mut iter) })?;

        let mut end: clingo_sys::clingo_symbolic_atom_iterator_t = 0;
        check(unsafe { clingo_sys::clingo_symbolic_atoms_end(atoms, &mut end) })?;

        let mut equal = false;
        check(unsafe {
            clingo_sys::clingo_symbolic_atoms_iterator_is_equal_to(atoms, iter, end, &mut equal)
        })?;

        if equal {
            Ok(None)
        } else {
            Ok(Some((atoms, iter)))
        }
    }

    /// Look up the program literal for a ground atom symbol.
    ///
    /// Returns `None` if the symbol doesn't appear in the ground program.
    fn literal_for_symbol(
        &self,
        symbol: Symbol,
    ) -> Result<Option<clingo_sys::clingo_literal_t>, ClingoError> {
        let Some((atoms, iter)) = self.find_symbolic_atom(symbol)? else {
            return Ok(None);
        };
        let mut literal: clingo_sys::clingo_literal_t = 0;
        check(unsafe { clingo_sys::clingo_symbolic_atoms_literal(atoms, iter, &mut literal) })?;
        Ok(Some(literal))
    }

    /// Check whether a ground atom is a fact (unconditionally true).
    ///
    /// Returns `None` if the symbol doesn't appear in the ground program.
    pub fn is_fact(&self, symbol: Symbol) -> Result<Option<bool>, ClingoError> {
        let Some((atoms, iter)) = self.find_symbolic_atom(symbol)? else {
            return Ok(None);
        };
        let mut fact = false;
        check(unsafe { clingo_sys::clingo_symbolic_atoms_is_fact(atoms, iter, &mut fact) })?;
        Ok(Some(fact))
    }

    /// Iterate over all ground atoms matching a predicate name and arity,
    /// converting each to `Fun<Args>`. Atoms whose arguments don't match
    /// the `Args` type are silently skipped.
    ///
    /// Returns a Vec of the found symbol together with its arguments.
    ///
    /// This uses the symbolic atoms table, so it works on `&self` and can
    /// be called through `SolveHandle::control()`.
    pub fn atoms<F: SymbolicFun>(&self) -> Result<Vec<(Symbol, F)>, Error> {
        let (name, arity) = F::signature();
        let c_name = CString::new(name)?;
        let arity = arity as u32;

        let mut signature: clingo_sys::clingo_signature_t = 0;
        check(unsafe {
            clingo_sys::clingo_signature_create(c_name.as_ptr(), arity, true, &mut signature)
        })?;

        let mut atoms_table: *const clingo_sys::clingo_symbolic_atoms_t = ptr::null();
        check(unsafe {
            clingo_sys::clingo_control_symbolic_atoms(self.ptr.as_ptr(), &mut atoms_table)
        })?;

        let mut iter: clingo_sys::clingo_symbolic_atom_iterator_t = 0;
        check(unsafe {
            clingo_sys::clingo_symbolic_atoms_begin(atoms_table, &signature, &mut iter)
        })?;

        let mut end: clingo_sys::clingo_symbolic_atom_iterator_t = 0;
        check(unsafe { clingo_sys::clingo_symbolic_atoms_end(atoms_table, &mut end) })?;

        let mut results = Vec::new();
        loop {
            let mut equal = false;
            check(unsafe {
                clingo_sys::clingo_symbolic_atoms_iterator_is_equal_to(
                    atoms_table,
                    iter,
                    end,
                    &mut equal,
                )
            })?;
            if equal {
                break;
            }

            let mut sym: clingo_sys::clingo_symbol_t = 0;
            check(unsafe {
                clingo_sys::clingo_symbolic_atoms_symbol(atoms_table, iter, &mut sym)
            })?;

            let symbol = unsafe { Symbol::from_raw(sym) };
            let f = F::from_symbol_result(symbol)?;
            results.push((symbol, f));

            check(unsafe { clingo_sys::clingo_symbolic_atoms_next(atoms_table, iter, &mut iter) })?;
        }

        Ok(results)
    }

    /// Assign a truth value to an external atom.
    ///
    /// The atom must have been declared with `#external` in the program.
    /// Returns `Ok(false)` if the symbol doesn't appear in the ground program.
    pub fn assign_external(&mut self, symbol: Symbol, value: TruthValue) -> Result<bool, Error> {
        let Some(literal) = self.literal_for_symbol(symbol)? else {
            return Ok(false);
        };
        check(unsafe {
            clingo_sys::clingo_control_assign_external(self.ptr.as_ptr(), literal, value.to_raw())
        })?;
        Ok(true)
    }

    /// Release an external atom, making it no longer external.
    ///
    /// After this, the atom is subject to normal program simplification.
    /// Returns `Ok(false)` if the symbol doesn't appear in the ground program.
    pub fn release_external(&mut self, symbol: Symbol) -> Result<bool, Error> {
        let Some(literal) = self.literal_for_symbol(symbol)? else {
            return Ok(false);
        };
        check(unsafe { clingo_sys::clingo_control_release_external(self.ptr.as_ptr(), literal) })?;
        Ok(true)
    }
}