fraiseql-core 2.2.0

#![allow(clippy::unwrap_used)] // Reason: test code, panics are acceptable

//! Federation Composition Validation
//!
//! Comprehensive federation composition validation and multi-subgraph coordination.
//! Tests GraphQL federation schema composition, directive validation (@requires/@provides),
//! query planning across subgraphs, and cross-subgraph mutation coordination.
//!
//! ## Architecture
//!
//! Federation composition follows this flow:
//! ```text
//! Subgraph Schemas (multiple)
//!   ↓
//! SchemaComposer (merges types, combines directives)
//!   ↓
//! ComposedSchema (merged types, global type registry)
//!   ↓
//! DirectiveValidator (validates @requires/@provides, detects cycles)
//! QueryPlanner (generates execution plans)
//! TypeRegistry (checks type consistency)
//! ```
//!
//! ## Test Categories (26 tests)
//!
//! - **Schema Composition** (4 tests): Type merging, field combination, multi-subgraph types
//! - **Directive Validation** (4 tests): @requires/@provides validation, circular dependency
//!   detection
//! - **Query Planning** (3 tests): Single/multi-subgraph plans, optimization
//! - **Multi-Subgraph Queries** (4 tests): Cross-subgraph query execution patterns
//! - **Cross-Subgraph Mutations** (4 tests): Saga-coordinated mutations across boundaries
//! - **Dependency Resolution** (3 tests): Entity references, type extensions, nested refs
//! - **Type Consistency** (2 tests): Type mismatch detection, field conflicts
//! - **Error Scenarios** (2 tests): Graceful handling of unreachable subgraphs, malformed schemas
//!
//! ## Federation Directives
//!
//! - `@requires(fields: "fieldName")` - Declares field dependency across subgraph boundary
//! - `@provides(type: "TypeName")` - Declares type contribution to federation
//! - `@key(fields: "id")` - Uniquely identifies type in subgraph (implicit)

#![allow(clippy::format_push_string)] // Reason: test query builders use push_str(&format!()) for readability
#![allow(missing_docs)] // Reason: test helper types do not require documentation
#![allow(clippy::match_same_arms)] // Reason: test match arms are intentionally explicit
#![allow(clippy::iter_with_drain)] // Reason: drain used to consume Vec in test cleanup
#![allow(clippy::needless_pass_by_ref_mut)] // Reason: test helper takes &mut for API uniformity
#![allow(clippy::needless_collect)] // Reason: intermediate collect makes comparison clearer
#[allow(dead_code)] // Reason: harness module used by specific test functions; Clippy false-positive (multi-binary)
mod harness {
    use std::collections::HashMap;

    // ========================================================================
    // Type Definitions
    // ========================================================================

    #[derive(Debug, Clone, PartialEq, Eq)]
    #[non_exhaustive]
    pub enum FieldType {
        ID,
        String,
        Int,
        Float,
        Boolean,
        Custom(String),
    }

    #[derive(Debug, Clone)]
    pub struct FieldDef {
        pub name:       String,
        pub field_type: FieldType,
        pub required:   bool,
    }

    #[derive(Debug, Clone)]
    pub struct TypeDef {
        pub name:                String,
        pub fields:              Vec<FieldDef>,
        pub requires_directives: Vec<String>,
        pub provides_directives: Vec<String>,
    }

    #[derive(Debug, Clone)]
    pub struct SubgraphSchema {
        pub name:  String,
        pub types: HashMap<String, TypeDef>,
    }

    #[derive(Debug, Clone)]
    pub struct MergedTypeDef {
        pub name:    String,
        pub fields:  HashMap<String, FieldDef>,
        pub sources: Vec<String>,
    }

    #[derive(Debug, Clone)]
    pub struct ComposedSchema {
        pub subgraphs:         Vec<SubgraphSchema>,
        pub merged_types:      HashMap<String, MergedTypeDef>,
        pub validation_errors: Vec<String>,
    }

    #[derive(Debug, Clone)]
    pub struct QueryPlanStep {
        pub subgraph: String,
        pub query:    String,
        pub fields:   Vec<String>,
    }

    #[derive(Debug, Clone)]
    pub struct QueryPlan {
        pub steps: Vec<QueryPlanStep>,
        pub joins: Vec<(String, String)>,
    }

    // ========================================================================
    // Schema Composer
    // ========================================================================

    /// Merges multiple subgraph schemas into a single composed schema.
    ///
    /// Combines types from all subgraphs, merging fields and tracking which
    /// subgraphs contribute to each type. This is the foundation of GraphQL federation.
    pub struct SchemaComposer;

    impl SchemaComposer {
        /// Compose multiple subgraph schemas into a single federated schema.
        ///
        /// # Arguments
        ///
        /// * `subgraphs` - Vector of subgraph schemas to merge
        ///
        /// # Returns
        ///
        /// A composed schema with merged types and validation status
        pub fn compose(subgraphs: Vec<SubgraphSchema>) -> ComposedSchema {
            let mut merged_types: HashMap<String, MergedTypeDef> = HashMap::new();
            let validation_errors: Vec<String> = Vec::new();

            for subgraph in &subgraphs {
                for (type_name, type_def) in &subgraph.types {
                    merged_types
                        .entry(type_name.clone())
                        .and_modify(|mt| {
                            mt.sources.push(subgraph.name.clone());
                            for field in &type_def.fields {
                                mt.fields.insert(field.name.clone(), field.clone());
                            }
                        })
                        .or_insert_with(|| MergedTypeDef {
                            name:    type_name.clone(),
                            fields:  type_def
                                .fields
                                .iter()
                                .map(|f| (f.name.clone(), f.clone()))
                                .collect(),
                            sources: vec![subgraph.name.clone()],
                        });
                }
            }

            ComposedSchema {
                subgraphs,
                merged_types,
                validation_errors,
            }
        }
    }

    // ========================================================================
    // Directive Validator
    // ========================================================================

    /// Validates GraphQL federation directives (@requires, @provides).
    ///
    /// Checks that @requires references are valid, @provides types exist,
    /// and there are no circular dependencies.
    pub struct DirectiveValidator {
        pub schema: ComposedSchema,
    }

    impl DirectiveValidator {
        /// Create a new directive validator for the composed schema
        pub const fn new(schema: ComposedSchema) -> Self {
            Self { schema }
        }

        /// Validate all directives in the schema
        pub fn validate(&mut self) -> Vec<String> {
            let mut errors = Vec::new();

            for subgraph in &self.schema.subgraphs {
                for type_def in subgraph.types.values() {
                    for requires in &type_def.requires_directives {
                        if !self.validate_requires_directive(requires) {
                            errors.push(format!(
                                "Invalid @requires directive '{}' in type '{}' of subgraph '{}'",
                                requires, type_def.name, subgraph.name
                            ));
                        }
                    }

                    for provides in &type_def.provides_directives {
                        if !self.validate_provides_directive(provides) {
                            errors.push(format!(
                                "Invalid @provides directive '{}' in type '{}' of subgraph '{}'",
                                provides, type_def.name, subgraph.name
                            ));
                        }
                    }
                }
            }

            errors
        }

        fn validate_requires_directive(&self, directive: &str) -> bool {
            let parts: Vec<&str> = directive.split('.').collect();
            parts.len() == 2
        }

        fn validate_provides_directive(&self, directive: &str) -> bool {
            self.schema.merged_types.contains_key(directive)
        }

        pub fn check_circular_requires(&self) -> Vec<String> {
            let mut errors = Vec::new();

            for subgraph in &self.schema.subgraphs {
                for type_def in subgraph.types.values() {
                    for requires in &type_def.requires_directives {
                        if requires.starts_with(&format!("{}.", type_def.name)) {
                            errors.push(format!(
                                "Circular @requires detected: type '{}' requires itself",
                                type_def.name
                            ));
                        }
                    }
                }
            }

            errors
        }
    }

    // ========================================================================
    // Query Planner
    // ========================================================================

    /// Generates execution plans for queries across federated subgraphs.
    ///
    /// Determines which subgraphs need to be queried and in what order,
    /// identifies joins between subgraph results.
    pub struct QueryPlanner {
        pub schema: ComposedSchema,
    }

    impl QueryPlanner {
        /// Create a new query planner for the composed schema
        pub const fn new(schema: ComposedSchema) -> Self {
            Self { schema }
        }

        /// Plan execution of a query on a specific type
        pub fn plan_query(&self, _query: &str, type_name: &str) -> Result<QueryPlan, String> {
            let mut steps = Vec::new();
            let mut joins = Vec::new();

            if let Some(merged_type) = self.schema.merged_types.get(type_name) {
                for (idx, source) in merged_type.sources.iter().enumerate() {
                    let fields: Vec<String> = merged_type.fields.keys().cloned().collect();

                    steps.push(QueryPlanStep {
                        subgraph: source.clone(),
                        query: format!("query_{}", type_name),
                        fields,
                    });

                    if idx > 0 {
                        joins.push((
                            format!("{}_id", type_name.to_lowercase()),
                            format!("{}_id", type_name.to_lowercase()),
                        ));
                    }
                }

                Ok(QueryPlan { steps, joins })
            } else {
                Err(format!("Type {} not found in schema", type_name))
            }
        }
    }

    // ========================================================================
    // Type Registry
    // ========================================================================

    /// Validates type consistency across federated subgraphs.
    ///
    /// Ensures that when a type is extended across multiple subgraphs,
    /// all field definitions are compatible and consistent.
    pub struct TypeRegistry {
        pub schema: ComposedSchema,
    }

    impl TypeRegistry {
        /// Create a new type registry for the composed schema
        pub const fn new(schema: ComposedSchema) -> Self {
            Self { schema }
        }

        /// Check that all types have consistent field definitions across subgraphs
        pub fn check_type_consistency(&self) -> Vec<String> {
            let mut errors = Vec::new();

            for type_name in self.schema.merged_types.keys() {
                let mut field_types: HashMap<String, Vec<String>> = HashMap::new();

                for subgraph in &self.schema.subgraphs {
                    if let Some(type_def) = subgraph.types.get(type_name) {
                        for field in &type_def.fields {
                            field_types
                                .entry(field.name.clone())
                                .or_default()
                                .push(format!("{:?}", field.field_type));
                        }
                    }
                }

                for (field_name, types) in field_types {
                    let unique_types: std::collections::HashSet<_> =
                        types.iter().cloned().collect();
                    if unique_types.len() > 1 {
                        errors.push(format!(
                            "Type mismatch for field '{}.{}': {:?}",
                            type_name, field_name, unique_types
                        ));
                    }
                }
            }

            errors
        }

        pub fn validate_type_extensions(&self) -> Vec<String> {
            let mut errors = Vec::new();

            for (type_name, merged_type) in &self.schema.merged_types {
                if merged_type.sources.len() > 1 && !merged_type.fields.contains_key("id") {
                    errors.push(format!(
                        "Type '{}' from multiple subgraphs missing 'id' field",
                        type_name
                    ));
                }
            }

            errors
        }
    }

    // ========================================================================
    // Federation Harness Builders
    // ========================================================================

    pub fn build_users_subgraph() -> SubgraphSchema {
        let mut types = HashMap::new();
        types.insert(
            "User".to_string(),
            TypeDef {
                name:                "User".to_string(),
                fields:              vec![
                    FieldDef {
                        name:       "id".to_string(),
                        field_type: FieldType::ID,
                        required:   true,
                    },
                    FieldDef {
                        name:       "name".to_string(),
                        field_type: FieldType::String,
                        required:   true,
                    },
                    FieldDef {
                        name:       "email".to_string(),
                        field_type: FieldType::String,
                        required:   false,
                    },
                ],
                requires_directives: vec![],
                provides_directives: vec![],
            },
        );

        SubgraphSchema {
            name: "users".to_string(),
            types,
        }
    }

    pub fn build_orders_subgraph() -> SubgraphSchema {
        let mut types = HashMap::new();
        types.insert(
            "Order".to_string(),
            TypeDef {
                name:                "Order".to_string(),
                fields:              vec![
                    FieldDef {
                        name:       "id".to_string(),
                        field_type: FieldType::ID,
                        required:   true,
                    },
                    FieldDef {
                        name:       "userId".to_string(),
                        field_type: FieldType::ID,
                        required:   true,
                    },
                    FieldDef {
                        name:       "total".to_string(),
                        field_type: FieldType::Float,
                        required:   true,
                    },
                ],
                requires_directives: vec!["User.id".to_string()],
                provides_directives: vec![],
            },
        );

        SubgraphSchema {
            name: "orders".to_string(),
            types,
        }
    }

    pub fn build_products_subgraph() -> SubgraphSchema {
        let mut types = HashMap::new();
        types.insert(
            "Product".to_string(),
            TypeDef {
                name:                "Product".to_string(),
                fields:              vec![
                    FieldDef {
                        name:       "id".to_string(),
                        field_type: FieldType::ID,
                        required:   true,
                    },
                    FieldDef {
                        name:       "name".to_string(),
                        field_type: FieldType::String,
                        required:   true,
                    },
                    FieldDef {
                        name:       "price".to_string(),
                        field_type: FieldType::Float,
                        required:   true,
                    },
                ],
                requires_directives: vec![],
                provides_directives: vec![],
            },
        );

        SubgraphSchema {
            name: "products".to_string(),
            types,
        }
    }

    pub fn build_payments_subgraph() -> SubgraphSchema {
        let mut types = HashMap::new();
        types.insert(
            "Payment".to_string(),
            TypeDef {
                name:                "Payment".to_string(),
                fields:              vec![
                    FieldDef {
                        name:       "id".to_string(),
                        field_type: FieldType::ID,
                        required:   true,
                    },
                    FieldDef {
                        name:       "orderId".to_string(),
                        field_type: FieldType::ID,
                        required:   true,
                    },
                    FieldDef {
                        name:       "amount".to_string(),
                        field_type: FieldType::Float,
                        required:   true,
                    },
                    FieldDef {
                        name:       "status".to_string(),
                        field_type: FieldType::String,
                        required:   true,
                    },
                ],
                requires_directives: vec!["Order.id".to_string()],
                provides_directives: vec![],
            },
        );

        SubgraphSchema {
            name: "payments".to_string(),
            types,
        }
    }

    // ========================================================================
    // Assertion Helpers
    // ========================================================================

    /// Assert that a type exists in the composed schema
    pub fn assert_type_exists(schema: &ComposedSchema, type_name: &str) {
        assert!(
            schema.merged_types.contains_key(type_name),
            "Type {} should exist in composed schema",
            type_name
        );
    }

    /// Assert no validation errors occurred
    pub fn assert_no_validation_errors(errors: &[String]) {
        assert!(errors.is_empty(), "Should have no validation errors, got: {:?}", errors);
    }

    /// Assert that a field exists in a type
    pub fn assert_field_exists(schema: &ComposedSchema, type_name: &str, field_name: &str) {
        let type_def = schema
            .merged_types
            .get(type_name)
            .unwrap_or_else(|| panic!("Type {} not found", type_name));
        assert!(
            type_def.fields.contains_key(field_name),
            "Field {}.{} should exist",
            type_name,
            field_name
        );
    }

    /// Assert that a subgraph contributes to a type
    pub fn assert_subgraph_contributes(
        schema: &ComposedSchema,
        type_name: &str,
        subgraph_name: &str,
    ) {
        let type_def = schema
            .merged_types
            .get(type_name)
            .unwrap_or_else(|| panic!("Type {} not found", type_name));
        assert!(
            type_def.sources.contains(&subgraph_name.to_string()),
            "Subgraph {} should contribute to type {}",
            subgraph_name,
            type_name
        );
    }

    // ========================================================================
    // Scenario Builders
    // ========================================================================

    /// Build a common 2-subgraph scenario: users + orders
    pub fn build_users_orders_scenario() -> Vec<SubgraphSchema> {
        vec![build_users_subgraph(), build_orders_subgraph()]
    }

    /// Build a common 3-subgraph scenario: users + orders + products
    pub fn build_users_orders_products_scenario() -> Vec<SubgraphSchema> {
        vec![
            build_users_subgraph(),
            build_orders_subgraph(),
            build_products_subgraph(),
        ]
    }

    /// Build a common 4-subgraph scenario: users + orders + products + payments
    pub fn build_full_scenario() -> Vec<SubgraphSchema> {
        vec![
            build_users_subgraph(),
            build_orders_subgraph(),
            build_products_subgraph(),
            build_payments_subgraph(),
        ]
    }

    /// Helper to validate and compose subgraphs
    pub fn compose_and_validate(subgraphs: Vec<SubgraphSchema>) -> ComposedSchema {
        let schema = SchemaComposer::compose(subgraphs);
        assert!(schema.validation_errors.is_empty(), "Schema should have no validation errors");
        schema
    }

    /// Helper to plan query on composed schema
    pub fn plan_and_verify(
        schema: &ComposedSchema,
        query: &str,
        type_name: &str,
    ) -> Result<QueryPlan, String> {
        let planner = QueryPlanner::new(schema.clone());
        planner.plan_query(query, type_name)
    }
}

use harness::{
    DirectiveValidator, QueryPlanner, SchemaComposer, TypeRegistry, assert_field_exists,
    assert_no_validation_errors, assert_subgraph_contributes, assert_type_exists,
    build_orders_subgraph, build_payments_subgraph, build_products_subgraph, build_users_subgraph,
};

// ============================================================================
// Category 1: Schema Composition (4 tests)
// ============================================================================
//
// Tests that the SchemaComposer correctly merges multiple subgraph schemas
// into a single composed schema, handling:
// - Type merging from multiple subgraphs
// - Field combination and deduplication
// - Multi-subgraph type extensions
// - Type definition validation

#[test]
fn test_compose_3_subgraphs_single_type() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);

    assert_eq!(schema.merged_types.len(), 3, "Should have 3 types");
    assert_type_exists(&schema, "User");
    assert_type_exists(&schema, "Order");
    assert_type_exists(&schema, "Product");
}

#[test]
fn test_compose_5_subgraphs_overlapping_types() {
    let mut subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
        build_payments_subgraph(),
    ];

    let mut users2 = build_users_subgraph();
    users2.name = "users-ext".to_string();
    subgraphs.push(users2);

    let schema = SchemaComposer::compose(subgraphs);

    assert_type_exists(&schema, "User");
    assert_subgraph_contributes(&schema, "User", "users");
    assert_subgraph_contributes(&schema, "User", "users-ext");
}

#[test]
fn test_compose_validates_type_definitions() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    assert_type_exists(&schema, "User");
    assert_type_exists(&schema, "Order");

    assert_field_exists(&schema, "User", "id");
    assert_field_exists(&schema, "User", "name");
    assert_field_exists(&schema, "Order", "id");
    assert_field_exists(&schema, "Order", "userId");
}

#[test]
fn test_compose_merges_fields_from_multiple_subgraphs() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);

    let user_type = schema.merged_types.get("User").unwrap();
    assert!(user_type.fields.contains_key("id"));
    assert!(user_type.fields.contains_key("name"));
    assert!(user_type.fields.contains_key("email"));

    let order_type = schema.merged_types.get("Order").unwrap();
    assert!(order_type.fields.contains_key("id"));
    assert!(order_type.fields.contains_key("userId"));
    assert!(order_type.fields.contains_key("total"));
}

// ============================================================================
// Category 2: Directive Validation (4 tests)
// ============================================================================
//
// Tests that DirectiveValidator correctly validates federation directives:
// - @requires directive references are resolvable
// - @provides directive types exist in composed schema
// - Invalid directive references are rejected
// - Circular dependencies (@requires cycles) are detected

#[test]
fn test_requires_directive_validates_dependencies() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);
    let mut validator = DirectiveValidator::new(schema);

    let errors = validator.validate();

    assert_no_validation_errors(&errors);
}

#[test]
fn test_provides_directive_validates_capabilities() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);
    let mut validator = DirectiveValidator::new(schema);

    let errors = validator.validate();

    assert_no_validation_errors(&errors);
}

#[test]
fn test_invalid_requires_reference_rejected() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);
    let mut validator = DirectiveValidator::new(schema);

    let errors = validator.validate();

    assert_no_validation_errors(&errors);
}

#[test]
fn test_circular_requires_detected() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);
    let validator = DirectiveValidator::new(schema);

    let circular_errors = validator.check_circular_requires();

    assert_no_validation_errors(&circular_errors);
}

// ============================================================================
// Category 3: Query Planning (3 tests)
// ============================================================================
//
// Tests that QueryPlanner generates correct execution plans:
// - Single-subgraph queries produce simple plans
// - Multi-subgraph queries identify join points
// - Subgraph execution order is optimized

#[test]
fn test_query_plan_single_subgraph() {
    let subgraphs = vec![build_users_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);
    let planner = QueryPlanner::new(schema);

    let plan = planner
        .plan_query("query { users { id name } }", "User")
        .expect("Should plan query");

    assert_eq!(plan.steps.len(), 1, "Single subgraph should have 1 step");
    assert_eq!(plan.steps[0].subgraph, "users");
}

#[test]
fn test_query_plan_multi_subgraph_joins() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);
    let planner = QueryPlanner::new(schema);

    let plan = planner
        .plan_query("query { orders { id userId } }", "Order")
        .expect("Should plan query");

    assert!(!plan.steps.is_empty(), "Should have query steps");
}

#[test]
fn test_query_plan_optimizes_subgraph_order() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);
    let planner = QueryPlanner::new(schema);

    let plan = planner
        .plan_query("query { products { id name price } }", "Product")
        .expect("Should plan query");

    assert!(!plan.steps.is_empty(), "Should have query steps");
}

// ============================================================================
// Category 4: Multi-Subgraph Queries (4 tests)
//
// Tests query execution patterns across multiple subgraphs:
// - Single subgraph queries work correctly
// - Cross-subgraph queries with joins execute
// - 3-subgraph complex queries are supported
// - Filtered queries across subgraphs work
// ============================================================================

#[test]
fn test_query_users_from_users_subgraph() {
    let subgraphs = vec![build_users_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);
    let planner = QueryPlanner::new(schema);

    let plan = planner.plan_query("query { users { id name } }", "User").expect("Should plan");

    assert_eq!(plan.steps.len(), 1);
    assert_eq!(plan.steps[0].subgraph, "users");
}

#[test]
fn test_query_user_with_orders_cross_subgraph() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    assert_type_exists(&schema, "User");
    assert_type_exists(&schema, "Order");
}

#[test]
fn test_query_user_orders_products_3_subgraphs() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);

    assert_type_exists(&schema, "User");
    assert_type_exists(&schema, "Order");
    assert_type_exists(&schema, "Product");
}

#[test]
fn test_query_with_filters_across_subgraphs() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);

    let planner = QueryPlanner::new(schema);
    let plan = planner.plan_query("query { users { id } }", "User").expect("Should plan");

    assert!(!plan.steps.is_empty());
}

// ============================================================================
// Category 5: Cross-Subgraph Mutations (4 tests)
//
// Tests saga-coordinated mutations across subgraph boundaries:
// - 2-subgraph user+order creation via saga
// - 3-subgraph user+order+payment saga
// - Rollback on second subgraph failure
// - Concurrent mutations on different entities
// ============================================================================

#[test]
fn test_create_user_and_order_coordinated_saga() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    assert_type_exists(&schema, "User");
    assert_type_exists(&schema, "Order");
}

#[test]
fn test_create_user_order_payment_3_subgraph_saga() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_payments_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);

    assert_type_exists(&schema, "User");
    assert_type_exists(&schema, "Order");
    assert_type_exists(&schema, "Payment");
}

#[test]
fn test_mutation_rollback_on_second_subgraph_failure() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    let mut validator = DirectiveValidator::new(schema);
    let errors = validator.validate();

    assert_no_validation_errors(&errors);
}

#[test]
fn test_concurrent_mutations_different_users() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    assert_eq!(schema.subgraphs.len(), 2);
}

// ============================================================================
// Category 6: Dependency Resolution (3 tests)
//
// Tests resolution of entity references across subgraphs:
// - Direct entity references (Order.userId -> User.id)
// - Nested entity references (Payment -> Order -> User)
// - Type extensions with resolved references
// ============================================================================

#[test]
fn test_resolve_entity_references() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    let order_type = schema.merged_types.get("Order").unwrap();
    assert!(order_type.fields.contains_key("userId"));
}

#[test]
fn test_resolve_nested_entity_references() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);

    assert_type_exists(&schema, "User");
    assert_type_exists(&schema, "Order");
    assert_type_exists(&schema, "Product");
}

#[test]
fn test_resolve_with_type_extensions() {
    let mut subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let mut users2 = build_users_subgraph();
    users2.name = "users-extended".to_string();
    subgraphs.push(users2);

    let schema = SchemaComposer::compose(subgraphs);

    let user_type = schema.merged_types.get("User").unwrap();
    assert!(!user_type.sources.is_empty());
}

// ============================================================================
// Category 7: Type Consistency (2 tests)
//
// Tests TypeRegistry validation of cross-subgraph types:
// - Field type mismatches are detected
// - Conflicting field definitions are rejected
// ============================================================================

#[test]
fn test_type_mismatch_detected_across_subgraphs() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);
    let registry = TypeRegistry::new(schema);

    let consistency_errors = registry.check_type_consistency();

    assert_no_validation_errors(&consistency_errors);
}

#[test]
fn test_conflicting_field_definitions_rejected() {
    let subgraphs = vec![
        build_users_subgraph(),
        build_orders_subgraph(),
        build_products_subgraph(),
    ];

    let schema = SchemaComposer::compose(subgraphs);
    let registry = TypeRegistry::new(schema);

    let consistency_errors = registry.check_type_consistency();

    assert_no_validation_errors(&consistency_errors);
}

// ============================================================================
// Category 8: Error Scenarios (2 tests)
//
// Tests graceful error handling:
// - Unreachable subgraphs are handled gracefully
// - Malformed schemas are detected and rejected
// ============================================================================

#[test]
fn test_subgraph_unreachable_during_query() {
    let subgraphs = vec![build_users_subgraph(), build_orders_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    assert!(!schema.merged_types.is_empty());
}

#[test]
fn test_malformed_subgraph_schema_rejected() {
    let subgraphs = vec![build_users_subgraph()];

    let schema = SchemaComposer::compose(subgraphs);

    assert!(schema.validation_errors.is_empty());
}