tirea-contract 0.5.0

//! Activity management trait for external state updates.

use serde_json::Value;
use std::sync::Arc;
use tirea_state::Op;

/// Manager for activity state updates.
///
/// Implementations keep per-stream activity state and may emit external events.
pub trait ActivityManager: Send + Sync {
    /// Get the current activity snapshot for a stream.
    fn snapshot(&self, stream_id: &str) -> Value;

    /// Handle an activity operation for a stream.
    fn on_activity_op(&self, stream_id: &str, activity_type: &str, op: &Op);
}

/// No-op activity manager that silently discards all operations.
pub struct NoOpActivityManager;

impl ActivityManager for NoOpActivityManager {
    fn snapshot(&self, _stream_id: &str) -> Value {
        Value::Object(Default::default())
    }

    fn on_activity_op(&self, _stream_id: &str, _activity_type: &str, _op: &Op) {}
}

impl NoOpActivityManager {
    /// Create a shared no-op activity manager.
    pub fn arc() -> Arc<dyn ActivityManager> {
        Arc::new(Self)
    }
}

#[cfg(test)]
mod tests {
    use crate::testing::{TestFixture, TestFixtureState};
    use serde_json::json;

    // Write-through same-ref and cross-ref covered by tool_call::context::tests.

    #[test]
    fn test_rebuild_state_reflects_write_through() {
        let doc = json!({"__test_fixture": {"label": null}});
        let fix = TestFixture::new_with_state(doc);
        let ctx = fix.ctx_with("call-1", "test");

        // Write via state_of
        let ctrl = ctx.state_of::<TestFixtureState>();
        ctrl.set_label(Some("test_value".into()))
            .expect("failed to set label");

        // updated_state should return the run_doc snapshot which includes the write
        let rebuilt = fix.updated_state();
        assert_eq!(
            rebuilt["__test_fixture"]["label"], "test_value",
            "updated_state must reflect write-through updates"
        );
    }
}