anyllm 0.1.1

//! Request-level instruction types.
//!
//! `SystemPrompt` carries a single system instruction plus a typed,
//! per-prompt options bag (`SystemOptions`) for provider-specific metadata
//! like Anthropic cache hints. See the design doc at
//! `docs/superpowers/specs/2026-04-15-instruction-carrier-fidelity-design.md`.

use std::any::{Any, TypeId};
use std::collections::HashMap;
use std::fmt;

use serde::{Deserialize, Serialize};

type ErasedAny = dyn Any + Send + Sync;

/// A single request-level system instruction.
///
/// Holds plain-text instruction content plus a typed [`SystemOptions`] bag
/// for provider-specific per-prompt metadata (such as Anthropic
/// `cache_control`).
///
/// Serializes as `{"content": "..."}` — typed options are skipped because
/// their values are erased and cannot be re-expressed in JSON portably.
/// This matches the lossy serde treatment of
/// [`RequestOptions`](crate::RequestOptions) in `ChatRequestRecord`.
#[non_exhaustive]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct SystemPrompt {
    /// System prompt text.
    pub content: String,

    /// Typed provider-specific options for this prompt.
    #[serde(skip, default)]
    pub options: SystemOptions,
}

impl SystemPrompt {
    /// Construct a system prompt from plain text.
    #[must_use]
    pub fn new(content: impl Into<String>) -> Self {
        Self {
            content: content.into(),
            options: SystemOptions::new(),
        }
    }

    /// Insert a typed provider-specific option.
    #[must_use]
    pub fn with_option<T>(mut self, value: T) -> Self
    where
        T: Clone + Send + Sync + 'static,
    {
        self.options.insert(value);
        self
    }

    /// Borrow a typed provider-specific option by type.
    #[must_use]
    pub fn option<T>(&self) -> Option<&T>
    where
        T: Send + Sync + 'static,
    {
        self.options.get::<T>()
    }
}

impl PartialEq for SystemPrompt {
    /// Compares system prompts by portable `content` only.
    ///
    /// Typed entries in [`SystemOptions`] are type-erased and therefore not
    /// portably comparable, mirroring how
    /// [`RequestOptions`](crate::RequestOptions) is excluded from
    /// [`ChatRequestRecord`](crate::ChatRequestRecord) equality.
    fn eq(&self, other: &Self) -> bool {
        self.content == other.content
    }
}

impl Eq for SystemPrompt {}

impl From<&str> for SystemPrompt {
    fn from(value: &str) -> Self {
        Self::new(value)
    }
}

impl From<String> for SystemPrompt {
    fn from(value: String) -> Self {
        Self::new(value)
    }
}

/// Type-erased bag of per-prompt options keyed by Rust type.
///
/// Mirrors [`RequestOptions`](crate::RequestOptions) semantics but scoped to
/// a single [`SystemPrompt`]. Each prompt owns its own bag so distinct
/// prompts can carry distinct provider-specific data (e.g., different
/// Anthropic `cache_control` hints).
///
/// Stored values must be `Clone` at insertion time so cloning a
/// [`SystemPrompt`] preserves its typed options.
#[derive(Clone, Default)]
pub struct SystemOptions {
    inner: HashMap<TypeId, ErasedValue>,
}

impl SystemOptions {
    /// Create an empty typed system-prompt option bag.
    #[must_use]
    pub fn new() -> Self {
        Self::default()
    }

    /// Insert or replace a typed option.
    pub fn insert<T>(&mut self, value: T)
    where
        T: Clone + Send + Sync + 'static,
    {
        self.inner
            .insert(TypeId::of::<T>(), ErasedValue::new(value));
    }

    /// Borrow a typed option by type.
    #[must_use]
    pub fn get<T>(&self) -> Option<&T>
    where
        T: Send + Sync + 'static,
    {
        self.inner
            .get(&TypeId::of::<T>())?
            .as_any()
            .downcast_ref::<T>()
    }

    /// Mutably borrow a typed option by type.
    pub fn get_mut<T>(&mut self) -> Option<&mut T>
    where
        T: Send + Sync + 'static,
    {
        self.inner
            .get_mut(&TypeId::of::<T>())?
            .as_any_mut()
            .downcast_mut::<T>()
    }

    /// Remove and return a typed option by type.
    pub fn remove<T>(&mut self) -> Option<T>
    where
        T: Send + Sync + 'static,
    {
        self.inner
            .remove(&TypeId::of::<T>())
            .and_then(|entry| entry.into_any().downcast::<T>().ok())
            .map(|boxed| *boxed)
    }

    /// Returns whether a typed option of `T` is present.
    #[must_use]
    pub fn contains<T>(&self) -> bool
    where
        T: Send + Sync + 'static,
    {
        self.inner.contains_key(&TypeId::of::<T>())
    }

    /// Borrow a typed option, inserting a default value produced by `f` when
    /// none is present.
    ///
    /// Mirrors [`RequestOptions::get_or_insert_with`](crate::RequestOptions::get_or_insert_with).
    /// The returned reference is always valid: if no value of type `T` was
    /// stored, `f` is invoked, its result is inserted, and a mutable borrow
    /// of the stored value is returned. Otherwise the existing value is
    /// borrowed in place without invoking `f`.
    pub fn get_or_insert_with<T, F>(&mut self, f: F) -> &mut T
    where
        T: Clone + Send + Sync + 'static,
        F: FnOnce() -> T,
    {
        self.inner
            .entry(TypeId::of::<T>())
            .or_insert_with(|| ErasedValue::new(f()))
            .as_any_mut()
            .downcast_mut::<T>()
            .expect("type id matches inserted value type")
    }

    /// Returns whether the bag is empty.
    #[must_use]
    pub fn is_empty(&self) -> bool {
        self.inner.is_empty()
    }

    /// Returns the number of stored typed options.
    #[must_use]
    pub fn len(&self) -> usize {
        self.inner.len()
    }
}

impl fmt::Debug for SystemOptions {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("SystemOptions")
            .field("len", &self.len())
            .finish()
    }
}

struct ErasedValue {
    value: Box<ErasedAny>,
    clone_fn: fn(&ErasedAny) -> Box<ErasedAny>,
}

impl ErasedValue {
    fn new<T>(value: T) -> Self
    where
        T: Clone + Send + Sync + 'static,
    {
        fn clone_value<T>(value: &ErasedAny) -> Box<ErasedAny>
        where
            T: Clone + Send + Sync + 'static,
        {
            let typed = value
                .downcast_ref::<T>()
                .expect("value type did not match clone function");
            Box::new(typed.clone())
        }

        Self {
            value: Box::new(value),
            clone_fn: clone_value::<T>,
        }
    }

    fn as_any(&self) -> &ErasedAny {
        self.value.as_ref()
    }

    fn as_any_mut(&mut self) -> &mut ErasedAny {
        self.value.as_mut()
    }

    fn into_any(self) -> Box<ErasedAny> {
        self.value
    }
}

impl Clone for ErasedValue {
    fn clone(&self) -> Self {
        Self {
            value: (self.clone_fn)(self.value.as_ref()),
            clone_fn: self.clone_fn,
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[derive(Debug, Clone, PartialEq, Eq)]
    struct Flag(bool);

    #[derive(Debug, Clone, PartialEq, Eq)]
    struct Count(u32);

    #[test]
    fn system_options_insert_and_get() {
        let mut opts = SystemOptions::new();
        opts.insert(Flag(true));
        assert_eq!(opts.get::<Flag>(), Some(&Flag(true)));
    }

    #[test]
    fn system_options_stores_multiple_types() {
        let mut opts = SystemOptions::new();
        opts.insert(Flag(true));
        opts.insert(Count(7));
        assert_eq!(opts.len(), 2);
        assert_eq!(opts.get::<Flag>(), Some(&Flag(true)));
        assert_eq!(opts.get::<Count>(), Some(&Count(7)));
    }

    #[test]
    fn system_options_insert_replaces_same_type() {
        let mut opts = SystemOptions::new();
        opts.insert(Flag(true));
        opts.insert(Flag(false));
        assert_eq!(opts.get::<Flag>(), Some(&Flag(false)));
        assert_eq!(opts.len(), 1);
    }

    #[test]
    fn system_options_remove_returns_value() {
        let mut opts = SystemOptions::new();
        opts.insert(Count(42));
        let removed: Option<Count> = opts.remove::<Count>();
        assert_eq!(removed, Some(Count(42)));
        assert!(opts.get::<Count>().is_none());
    }

    #[test]
    fn system_options_contains_and_is_empty() {
        let mut opts = SystemOptions::new();
        assert!(opts.is_empty());
        assert!(!opts.contains::<Flag>());
        opts.insert(Flag(true));
        assert!(!opts.is_empty());
        assert!(opts.contains::<Flag>());
    }

    #[test]
    fn system_options_get_or_insert_with_inserts_when_missing() {
        let mut opts = SystemOptions::new();
        let value: &mut Count = opts.get_or_insert_with(|| Count(3));
        assert_eq!(value, &mut Count(3));

        value.0 = 5;

        assert_eq!(opts.get::<Count>(), Some(&Count(5)));
        assert_eq!(opts.len(), 1);
    }

    #[test]
    fn system_options_get_or_insert_with_does_not_invoke_when_present() {
        let mut opts = SystemOptions::new();
        opts.insert(Count(11));

        let mut invoked = false;
        let value: &mut Count = opts.get_or_insert_with(|| {
            invoked = true;
            Count(99)
        });

        assert!(!invoked, "factory should not run when value is present");
        assert_eq!(value, &mut Count(11));
        assert_eq!(opts.len(), 1);
    }

    #[test]
    fn system_options_clone_preserves_values() {
        let mut opts = SystemOptions::new();
        opts.insert(Flag(true));
        opts.insert(Count(3));
        let clone = opts.clone();
        assert_eq!(clone.get::<Flag>(), Some(&Flag(true)));
        assert_eq!(clone.get::<Count>(), Some(&Count(3)));
    }

    #[test]
    fn system_options_get_mut_modifies_in_place() {
        let mut opts = SystemOptions::new();
        opts.insert(Count(1));
        if let Some(c) = opts.get_mut::<Count>() {
            c.0 = 99;
        }
        assert_eq!(opts.get::<Count>(), Some(&Count(99)));
    }

    #[test]
    fn system_prompt_new_preserves_content() {
        let p = SystemPrompt::new("Be concise");
        assert_eq!(p.content, "Be concise");
        assert!(p.options.is_empty());
    }

    #[test]
    fn system_prompt_from_str_and_string() {
        let a: SystemPrompt = "a".into();
        let b: SystemPrompt = String::from("b").into();
        assert_eq!(a.content, "a");
        assert_eq!(b.content, "b");
    }

    #[test]
    fn system_prompt_with_option_round_trips() {
        let p = SystemPrompt::new("Cached preamble").with_option(Flag(true));
        assert_eq!(p.content, "Cached preamble");
        assert_eq!(p.option::<Flag>(), Some(&Flag(true)));
    }

    #[test]
    fn system_prompt_with_multiple_options() {
        let p = SystemPrompt::new("x")
            .with_option(Flag(true))
            .with_option(Count(5));
        assert_eq!(p.option::<Flag>(), Some(&Flag(true)));
        assert_eq!(p.option::<Count>(), Some(&Count(5)));
    }

    #[test]
    fn system_prompt_clone_preserves_options() {
        let p = SystemPrompt::new("x").with_option(Flag(true));
        let c = p.clone();
        assert_eq!(c.option::<Flag>(), Some(&Flag(true)));
    }

    #[test]
    fn system_prompt_serde_omits_options() {
        let p = SystemPrompt::new("X").with_option(Flag(true));
        let json = serde_json::to_value(&p).unwrap();
        assert_eq!(json, serde_json::json!({"content": "X"}));
    }

    #[test]
    fn system_prompt_serde_deserialize_defaults_options_empty() {
        let json = serde_json::json!({"content": "Y"});
        let p: SystemPrompt = serde_json::from_value(json).unwrap();
        assert_eq!(p.content, "Y");
        assert!(p.options.is_empty());
    }
}