Function test_execute_plan_simple

atomic-repository/src/query_plan.rs:779–811

()

    #[test]
    fn test_execute_plan_simple() {
        use tempfile::tempdir;

        let dir = tempdir().unwrap();
        let repo = Repository::init(dir.path()).unwrap();
        repo.init_vault().unwrap();

        // Store and index an entry
        repo.vault_store(
            "memory/auth.md",
            atomic_core::pristine::vault::VaultEntryType::Memory,
            b"# Authentication\nOAuth2 details\n".to_vec(),
            r#"{"name":"auth"}"#.to_string(),
        )
        .unwrap();
        repo.vault_index_kg("memory/auth.md").unwrap();

        // Execute a simple search plan
        let plan = parse_plan(
            r#"{
            "steps": [
                {"type": "kg_search", "query": "auth", "limit": 5, "bind": "results"}
            ]
        }"#,
        )
        .unwrap();

        let result = execute_plan(&repo, &plan).unwrap();
        assert!(!result.nodes.is_empty());
        assert!(result.elapsed_ms < 5000);
        assert_eq!(result.step_stats.len(), 1);
        assert_eq!(result.step_stats[0].step_type, "kg_search");
    }

    #[test]
    fn test_execute_plan_empty() {