rain-engine-skills 0.1.0

//! Built-in native skills for RainEngine.
//!
//! These skills give the agent "hands" — the ability to interact with
//! the local filesystem, execute commands, make HTTP requests, and
//! search session memory.

pub mod file_ops;
pub mod http_fetch;
pub mod memory_search;
pub mod shell_exec;
pub mod web_reader;

use rain_engine_core::{RetryPolicy, SkillManifest};
use std::collections::HashSet;
use std::sync::Arc;
use tokio::sync::RwLock;

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct AccessPolicy {
    pub allowlist: HashSet<String>,
    pub permissive: bool,
}

impl AccessPolicy {
    pub fn new(allowlist: HashSet<String>, permissive: bool) -> Self {
        Self {
            allowlist,
            permissive,
        }
    }
}

pub type SharedAccessPolicy = Arc<RwLock<AccessPolicy>>;

pub fn shared_access_policy(allowlist: HashSet<String>, permissive: bool) -> SharedAccessPolicy {
    Arc::new(RwLock::new(AccessPolicy::new(allowlist, permissive)))
}

/// Helper to build a SkillManifest with common defaults.
fn base_manifest(name: &str, description: &str, input_schema: serde_json::Value) -> SkillManifest {
    SkillManifest {
        name: name.to_string(),
        description: description.to_string(),
        input_schema,
        required_scopes: vec!["tool:run".to_string()],
        capability_grants: vec![],
        resource_policy: rain_engine_core::ResourcePolicy {
            timeout_ms: 30_000,
            max_memory_bytes: 16 * 1024 * 1024,
            max_fuel: None,
            priority_class: 0,
            retry_policy: RetryPolicy {
                max_attempts: 3,
                initial_interval_ms: 250,
                backoff_multiplier: 2.0,
                max_interval_ms: 10_000,
            },
            dry_run_supported: false,
        },
        approval_required: false,
        circuit_breaker_threshold: 0.5,
    }
}