swarm_engine_core/learn/

profile_adapter.rs

//! ProfileAdapter - ScenarioProfile と OfflineModel の統合
//!
//! ## 概要
//!
//! 新しい ScenarioProfile と既存の OfflineModel を橋渡しする。
//! 既存コードを変更せずに、ScenarioProfile を使用可能にする。
//!
//! ## 変換方向
//!
//! ```text
//! ScenarioProfile → OfflineModel (Orchestrator 適用用)
//! OfflineModel → ScenarioProfile (移行用)
//! ```

use super::learned_component::{LearnedDepGraph, LearnedExploration, LearnedStrategy};
use super::offline::{
    ActionOrderSource, LearnedActionOrder, OfflineModel, OptimalParameters, StrategyConfig,
};
use super::scenario_profile::ScenarioProfile;

// ============================================================================
// ScenarioProfile → OfflineModel 変換
// ============================================================================

/// ScenarioProfile から OfflineModel を生成
///
/// Orchestrator に適用するための変換。
/// ScenarioProfile の各コンポーネントから OfflineModel を構築する。
pub fn profile_to_offline_model(profile: &ScenarioProfile) -> OfflineModel {
    let mut model = OfflineModel::default();

    // LearnedExploration → OptimalParameters
    if let Some(exploration) = &profile.exploration {
        model.parameters = OptimalParameters {
            ucb1_c: exploration.ucb1_c,
            learning_weight: exploration.learning_weight,
            ngram_weight: exploration.ngram_weight,
        };
    }

    // LearnedStrategy → StrategyConfig
    if let Some(strategy) = &profile.strategy {
        model.strategy_config = StrategyConfig {
            initial_strategy: strategy.initial_strategy.clone(),
            maturity_threshold: strategy.maturity_threshold as u32,
            error_rate_threshold: strategy.error_rate_threshold,
        };
    }

    // LearnedDepGraph → LearnedActionOrder + recommended_paths
    if let Some(dep_graph) = &profile.dep_graph {
        // Action order を設定
        if !dep_graph.action_order.is_empty() {
            // アクション集合のハッシュを計算
            use std::collections::hash_map::DefaultHasher;
            use std::hash::{Hash, Hasher};
            let mut hasher = DefaultHasher::new();
            dep_graph.action_order.hash(&mut hasher);
            let action_set_hash = hasher.finish();

            model.action_order = Some(LearnedActionOrder {
                discover: dep_graph.action_order.clone(),
                not_discover: Vec::new(), // TODO: 分離が必要な場合は対応
                action_set_hash,
                source: ActionOrderSource::Manual, // Profile から生成
            });
        }

        // Recommended paths を設定
        model.recommended_paths = dep_graph.recommended_paths.clone();
    }

    // Metadata
    model.updated_at = profile.updated_at;
    model.analyzed_sessions = profile
        .dep_graph
        .as_ref()
        .map(|d| d.learned_from.len())
        .unwrap_or(0);

    model
}

// ============================================================================
// OfflineModel → ScenarioProfile 変換 (移行用)
// ============================================================================

/// OfflineModel から ScenarioProfile のコンポーネントを抽出
///
/// 既存データの移行用。
pub fn offline_model_to_components(
    model: &OfflineModel,
) -> (
    Option<LearnedDepGraph>,
    Option<LearnedExploration>,
    Option<LearnedStrategy>,
) {
    // OptimalParameters → LearnedExploration
    let exploration = Some(LearnedExploration {
        ucb1_c: model.parameters.ucb1_c,
        learning_weight: model.parameters.learning_weight,
        ngram_weight: model.parameters.ngram_weight,
        confidence: 0.8, // 既存データは高信頼度と仮定
        session_count: model.analyzed_sessions,
        updated_at: model.updated_at,
    });

    // StrategyConfig → LearnedStrategy
    let strategy = Some(LearnedStrategy {
        initial_strategy: model.strategy_config.initial_strategy.clone(),
        maturity_threshold: model.strategy_config.maturity_threshold as usize,
        error_rate_threshold: model.strategy_config.error_rate_threshold,
        confidence: 0.8,
        session_count: model.analyzed_sessions,
        updated_at: model.updated_at,
    });

    // LearnedActionOrder → LearnedDepGraph
    let dep_graph = model.action_order.as_ref().map(|order| {
        use crate::exploration::DependencyGraph;

        LearnedDepGraph {
            graph: DependencyGraph::new(), // 空のグラフ（action_order のみ使用）
            action_order: order.discover.clone(),
            recommended_paths: model.recommended_paths.clone(),
            confidence: 0.8, // 既存データは高信頼度と仮定
            learned_from: Vec::new(),
            updated_at: model.updated_at,
        }
    });

    (dep_graph, exploration, strategy)
}

/// OfflineModel から ScenarioProfile を構築
pub fn migrate_offline_model_to_profile(
    profile_id: impl Into<String>,
    scenario_path: impl Into<std::path::PathBuf>,
    model: &OfflineModel,
) -> ScenarioProfile {
    use super::scenario_profile::{ProfileState, ScenarioSource};

    let (dep_graph, exploration, strategy) = offline_model_to_components(model);

    let mut profile =
        ScenarioProfile::new(profile_id, ScenarioSource::from_path(scenario_path.into()));

    profile.dep_graph = dep_graph;
    profile.exploration = exploration;
    profile.strategy = strategy;
    profile.state = ProfileState::Active; // 既存データがある = Active
    profile.updated_at = model.updated_at;

    profile
}

// ============================================================================
// LearnableSwarmBuilder 拡張用ヘルパー
// ============================================================================

/// ScenarioProfile から OfflineModel を取得する trait
pub trait ProfileToOfflineModel {
    /// OfflineModel に変換
    fn to_offline_model(&self) -> OfflineModel;
}

impl ProfileToOfflineModel for ScenarioProfile {
    fn to_offline_model(&self) -> OfflineModel {
        profile_to_offline_model(self)
    }
}

// ============================================================================
// Tests
// ============================================================================

#[cfg(test)]
mod tests {
    use super::*;
    use crate::exploration::DependencyGraph;
    use crate::learn::scenario_profile::ScenarioSource;

    #[test]
    fn test_profile_to_offline_model_empty() {
        let profile = ScenarioProfile::new("test", ScenarioSource::from_path("/test.toml"));
        let model = profile_to_offline_model(&profile);

        // デフォルト値が設定される
        assert!(model.parameters.ucb1_c > 0.0);
    }

    #[test]
    fn test_profile_to_offline_model_with_components() {
        let mut profile = ScenarioProfile::new("test", ScenarioSource::from_path("/test.toml"));

        profile.exploration = Some(LearnedExploration {
            ucb1_c: 2.5,
            learning_weight: 0.4,
            ngram_weight: 1.2,
            confidence: 0.9,
            session_count: 10,
            updated_at: 12345,
        });

        profile.strategy = Some(LearnedStrategy {
            initial_strategy: "greedy".to_string(),
            maturity_threshold: 10,
            error_rate_threshold: 0.3,
            confidence: 0.85,
            session_count: 10,
            updated_at: 12345,
        });

        profile.dep_graph = Some(
            LearnedDepGraph::new(
                DependencyGraph::new(),
                vec!["A".to_string(), "B".to_string()],
            )
            .with_confidence(0.95),
        );

        let model = profile_to_offline_model(&profile);

        assert_eq!(model.parameters.ucb1_c, 2.5);
        assert_eq!(model.parameters.learning_weight, 0.4);
        assert_eq!(model.strategy_config.initial_strategy, "greedy");
        assert_eq!(model.strategy_config.maturity_threshold, 10);
        assert!(model.action_order.is_some());
        assert_eq!(model.action_order.as_ref().unwrap().discover.len(), 2);
    }

    #[test]
    fn test_offline_model_to_components() {
        use super::ActionOrderSource;

        let mut model = OfflineModel::default();
        model.parameters.ucb1_c = 1.8;
        model.strategy_config.initial_strategy = "ucb1".to_string();
        model.action_order = Some(LearnedActionOrder {
            discover: vec!["X".to_string(), "Y".to_string()],
            not_discover: vec![],
            action_set_hash: 12345,
            source: ActionOrderSource::Manual,
        });
        model.analyzed_sessions = 5;

        let (dep_graph, exploration, strategy) = offline_model_to_components(&model);

        assert!(dep_graph.is_some());
        assert!(exploration.is_some());
        assert!(strategy.is_some());

        let exploration = exploration.unwrap();
        assert_eq!(exploration.ucb1_c, 1.8);

        let strategy = strategy.unwrap();
        assert_eq!(strategy.initial_strategy, "ucb1");

        let dep_graph = dep_graph.unwrap();
        assert_eq!(dep_graph.action_order.len(), 2);
    }

    #[test]
    fn test_migrate_offline_model_to_profile() {
        let mut model = OfflineModel::default();
        model.parameters.ucb1_c = 2.0;
        model.analyzed_sessions = 10;

        let profile =
            migrate_offline_model_to_profile("test-profile", "/path/to/scenario.toml", &model);

        assert_eq!(profile.id.0, "test-profile");
        assert!(profile.exploration.is_some());
        assert_eq!(profile.exploration.as_ref().unwrap().ucb1_c, 2.0);
    }

    #[test]
    fn test_profile_to_offline_model_trait() {
        let profile = ScenarioProfile::new("test", ScenarioSource::from_path("/test.toml"));
        let model = profile.to_offline_model();

        assert!(model.parameters.ucb1_c > 0.0);
    }
}