oxirs_star/

lib.rs

//! # OxiRS RDF-Star
//!
//! [![Version](https://img.shields.io/badge/version-0.2.2-blue)](https://github.com/cool-japan/oxirs/releases)
//! [![docs.rs](https://docs.rs/oxirs-star/badge.svg)](https://docs.rs/oxirs-star)
//!
//! **Status**: Production Release (v0.2.2)
//! **Stability**: Public APIs are stable. Production-ready with comprehensive testing.
//!
//! RDF-star and SPARQL-star implementation providing comprehensive support for quoted triples.
//!
//! This crate extends the standard RDF model with RDF-star capabilities, allowing triples
//! to be used as subjects or objects in other triples (quoted triples). It provides:
//!
//! - Complete RDF-star data model with proper type safety
//! - Parsing support for Turtle-star, N-Triples-star, TriG-star, and N-Quads-star
//! - SPARQL-star query execution with quoted triple patterns
//! - Serialization to all major RDF-star formats
//! - Storage backend integration with oxirs-core
//! - Performance-optimized handling of nested quoted triples
//! - Comprehensive CLI tools for validation and debugging
//! - Advanced error handling with context and recovery suggestions
//!
//! ## Quick Start
//!
//! ### Basic Quoted Triple Creation
//!
//! ```rust,ignore
//! use oxirs_star::{StarStore, StarTriple, StarTerm};
//!
//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
//! let mut store = StarStore::new();
//!
//! // Create a quoted triple
//! let quoted = StarTriple::new(
//!     StarTerm::iri("http://example.org/person1")?,
//!     StarTerm::iri("http://example.org/age")?,
//!     StarTerm::literal("25")?,
//! );
//!
//! // Use the quoted triple as a subject
//! let meta_triple = StarTriple::new(
//!     StarTerm::quoted_triple(quoted),
//!     StarTerm::iri("http://example.org/certainty")?,
//!     StarTerm::literal("0.9")?,
//! );
//!
//! store.insert(&meta_triple)?;
//! println!("Stored {} triples", store.len());
//! # Ok(())
//! # }
//! ```
//!
//! ### Parsing RDF-star Data
//!
//! ```rust,ignore
//! use oxirs_star::parser::{StarParser, StarFormat};
//!
//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
//! let turtle_star = r#"
//!     @prefix ex: <http://example.org/> .
//!
//!     << ex:alice ex:age 30 >> ex:certainty 0.9 .
//!     << ex:alice ex:name "Alice" >> ex:source ex:census2020 .
//! "#;
//!
//! let mut parser = StarParser::new();
//! let graph = parser.parse_str(turtle_star, StarFormat::TurtleStar)?;
//!
//! println!("Parsed {} quoted triples", graph.len());
//! # Ok(())
//! # }
//! ```
//!
//! ### Using the CLI Tools
//!
//! ```bash
//! # Validate an RDF-star file
//! oxirs-star validate data.ttls --strict
//!
//! # Convert between formats
//! oxirs-star convert input.ttls output.nts --to ntriples-star --pretty
//!
//! # Analyze data structure
//! oxirs-star analyze large_dataset.ttls --json --output report.json
//!
//! # Debug parsing issues
//! oxirs-star debug problematic.ttls --line 42 --context 5
//! ```
//!
//! ## Advanced Usage
//!
//! ### Nested Quoted Triples
//!
//! ```rust,ignore
//! use oxirs_star::{StarStore, StarTriple, StarTerm, StarConfig};
//!
//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
//! // Configure for deep nesting
//! let config = StarConfig {
//!     max_nesting_depth: 20,
//!     ..Default::default()
//! };
//!
//! let mut store = StarStore::with_config(config);
//!
//! // Create deeply nested structure
//! let base = StarTriple::new(
//!     StarTerm::iri("http://example.org/alice")?,
//!     StarTerm::iri("http://example.org/age")?,
//!     StarTerm::literal("30")?,
//! );
//!
//! let meta = StarTriple::new(
//!     StarTerm::quoted_triple(base),
//!     StarTerm::iri("http://example.org/certainty")?,
//!     StarTerm::literal("0.9")?,
//! );
//!
//! let meta_meta = StarTriple::new(
//!     StarTerm::quoted_triple(meta),
//!     StarTerm::iri("http://example.org/source")?,
//!     StarTerm::iri("http://example.org/study2023")?,
//! );
//!
//! store.insert(&meta_meta)?;
//! let stats = store.statistics();
//! println!("Max nesting depth: {}", stats.max_nesting_encountered);
//! # Ok(())
//! # }
//! ```
//!
//! ### Performance Optimization
//!
//! ```rust,ignore
//! use oxirs_star::{StarStore, StarConfig};
//!
//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
//! // Configure for high-performance scenarios
//! let config = StarConfig {
//!     max_nesting_depth: 10,
//!     enable_reification_fallback: true,
//!     buffer_size: 16384,  // Larger buffer for streaming
//!     strict_mode: false,  // Allow recovery from minor issues
//!     ..Default::default()
//! };
//!
//! let store = StarStore::with_config(config);
//! println!("Store configured for high performance");
//! # Ok(())
//! # }
//! ```
//!
//! ## Error Handling
//!
//! The crate provides detailed error types with context and recovery suggestions:
//!
//! ```rust,ignore
//! use oxirs_star::{StarError, StarResult};
//!
//! fn handle_errors() -> StarResult<()> {
//!     // ... some operation that might fail
//!     Err(StarError::NestingDepthExceeded {
//!         max_depth: 10,
//!         current_depth: 15,
//!         context: Some("While parsing complex quoted triple".to_string()),
//!     })
//! }
//!
//! # fn main() {
//! match handle_errors() {
//!     Err(e) => {
//!         eprintln!("Error: {}", e);
//!         for suggestion in e.recovery_suggestions() {
//!             eprintln!("Suggestion: {}", suggestion);
//!         }
//!     }
//!     Ok(_) => println!("Success"),
//! }
//! # }
//! ```
//!
//! ## Troubleshooting
//!
//! ### Common Issues
//!
//! 1. **Parsing Errors**: Use `oxirs-star debug` to identify syntax issues
//! 2. **Performance Issues**: Enable indexing and adjust buffer sizes
//! 3. **Memory Usage**: Reduce nesting depth or enable reification fallback
//! 4. **Format Detection**: Explicitly specify format if auto-detection fails
//!
//! ### Getting Help
//!
//! - Use the `dev_tools` module for validation and diagnostics
//! - Check the comprehensive documentation in the `docs` module
//! - Run `oxirs-star --help` for CLI usage information
//! - See the examples directory for real-world usage patterns

use oxirs_core::OxirsError;
use serde::{Deserialize, Serialize};
use thiserror::Error;
use tracing::{debug, info, span, Level};

pub mod adaptive_query_optimizer;
pub mod advanced_query;
pub mod annotation_aggregation;
pub mod annotation_lifecycle;
pub mod annotation_paths;
pub mod annotation_profile;
pub mod annotations;
pub mod backup_restore;
pub mod bloom_filter;
pub mod cache;
pub mod cli;
pub mod cluster_scaling;
pub mod compact_annotation_storage;
pub mod compatibility;
pub mod compliance;
pub mod compliance_reporting;
pub mod cryptographic_provenance;
pub mod distributed;
pub mod docs;
pub mod enhanced_errors;
pub mod execution;
pub mod functions;
pub mod governance;
pub mod gpu_acceleration;
pub mod graph_diff;
pub mod graphql_star;
pub mod hdt_star;
pub mod index;
pub mod jit_query_engine;
pub mod kg_embeddings;
pub mod lsm_annotation_store;
pub mod materialized_views;
pub mod memory_efficient_store;
pub mod migration_tools;
pub mod ml_embedding_pipeline;
pub mod ml_sparql_optimizer;
pub mod model;
pub mod monitoring;
pub mod parallel_query;
pub mod parser;
pub mod production;
pub mod profiling;
pub mod property_graph_bridge;
pub mod quantum_sparql_optimizer;
pub mod query;
pub mod query_optimizer;
pub mod quoted_graph;
pub mod rdf_star_formats;
pub mod reasoning;
pub mod reification;
pub mod reification_bridge;
pub mod security_audit;
pub mod semantics;
pub mod serialization;
pub mod serializer;
pub mod shacl_star;
pub mod sparql;
pub mod sparql_enhanced;
pub mod sparql_star_bind_values;
pub mod sparql_star_extended;
pub mod storage;
pub mod storage_integration;
pub mod store;
pub mod streaming_query;
pub mod temporal_versioning;
pub mod testing_utilities;
pub mod tiered_storage;
pub mod troubleshooting;
pub mod trust_scoring;
pub mod validation_framework;
pub mod w3c_compliance;
// RDF-star reification mapper (v1.1.0 round 5)
pub mod reification_mapper;
pub mod write_ahead_log;

// RDF 1.1 reification ↔ RDF-star bidirectional converter (v1.1.0 round 7)
pub mod triple_reifier;

// RDF-star provenance tracker (v1.1.0 round 6)
pub mod provenance_tracker;

// W3C RDF Patch A/D/TX format (v1.1.0 round 8)
pub mod rdf_patch;

// In-memory store for RDF-star quoted triples (v1.1.0 round 9)
pub mod quoted_triple_store;

// RDF-star annotation graph for triple metadata (v1.1.0 round 10)
pub mod annotation_graph;

// RDF-star serialization to Turtle-star, N-Triples-star, JSON-LD-star (v1.1.0 round 11)
pub mod rdf_star_serializer;

// RDF-star pattern matching for nested triple queries (v1.1.0 round 13)
pub mod star_pattern_matcher;

// RDF-star graph normalization (v1.1.0 round 12)
pub mod star_normalizer;

// RDF-star query to standard RDF rewriting (v1.1.0 round 11)
pub mod star_query_rewriter;

/// RDF / RDF-star graph diff: added/removed triples, RDF Patch generation/application,
/// symmetric difference, blank-node-aware isomorphic diff (v1.1.0 round 13)
pub mod triple_diff;

/// RDF-star graph statistics collector (v1.1.0 round 14).
pub mod star_statistics;

/// RDF-star graph merging with conflict resolution (v1.1.0 round 15).
pub mod graph_merger;

// Re-export main types
pub use enhanced_errors::{
    EnhancedError, EnhancedResult, ErrorAggregator, ErrorCategory, ErrorContext, ErrorSeverity,
    WithErrorContext,
};
pub use model::*;
pub use store::StarStore;
pub use troubleshooting::{DiagnosticAnalyzer, MigrationAssistant, TroubleshootingGuide};

/// Parse error details for RDF-star format
#[derive(Debug, Error)]
#[error("Parse error: {message}")]
pub struct ParseErrorDetails {
    pub message: String,
    pub line: Option<usize>,
    pub column: Option<usize>,
    pub input_fragment: Option<String>,
    pub expected: Option<String>,
    pub suggestion: Option<String>,
}

/// RDF-star specific error types
#[derive(Debug, Error)]
pub enum StarError {
    #[error("Invalid quoted triple: {message}")]
    InvalidQuotedTriple {
        message: String,
        context: Option<String>,
        suggestion: Option<String>,
    },
    #[error("Parse error in RDF-star format: {0}")]
    ParseError(#[from] Box<ParseErrorDetails>),
    #[error("Serialization error: {message}")]
    SerializationError {
        message: String,
        format: Option<String>,
        context: Option<String>,
    },
    #[error("SPARQL-star query error: {message}")]
    QueryError {
        message: String,
        query_fragment: Option<String>,
        position: Option<usize>,
        suggestion: Option<String>,
    },
    #[error("Core RDF error: {0}")]
    CoreError(#[from] OxirsError),
    #[error("Reification error: {message}")]
    ReificationError {
        message: String,
        reification_strategy: Option<String>,
        context: Option<String>,
    },
    #[error("Invalid term type for RDF-star context: {message}")]
    InvalidTermType {
        message: String,
        term_type: Option<String>,
        expected_types: Option<Vec<String>>,
        suggestion: Option<String>,
    },
    #[error("Nesting depth exceeded: maximum depth {max_depth} reached")]
    NestingDepthExceeded {
        max_depth: usize,
        current_depth: usize,
        context: Option<String>,
    },
    #[error("Format not supported: {format}")]
    UnsupportedFormat {
        format: String,
        available_formats: Vec<String>,
    },
    #[error("Configuration error: {message}")]
    ConfigurationError {
        message: String,
        parameter: Option<String>,
        valid_range: Option<String>,
    },
    #[error("Internal error: {message}")]
    InternalError {
        message: String,
        context: Option<String>,
    },
}

/// Result type for RDF-star operations
pub type StarResult<T> = std::result::Result<T, StarError>;

impl StarError {
    /// Create a simple invalid quoted triple error (backward compatibility)
    pub fn invalid_quoted_triple(message: impl Into<String>) -> Self {
        Self::InvalidQuotedTriple {
            message: message.into(),
            context: None,
            suggestion: None,
        }
    }

    /// Create a simple parse error (backward compatibility)
    pub fn parse_error(message: impl Into<String>) -> Self {
        Self::ParseError(Box::new(ParseErrorDetails {
            message: message.into(),
            line: None,
            column: None,
            input_fragment: None,
            expected: None,
            suggestion: None,
        }))
    }

    /// Create a simple serialization error (backward compatibility)
    pub fn serialization_error(message: impl Into<String>) -> Self {
        Self::SerializationError {
            message: message.into(),
            format: None,
            context: None,
        }
    }

    /// Create a simple query error (backward compatibility)
    pub fn query_error(message: impl Into<String>) -> Self {
        Self::QueryError {
            message: message.into(),
            query_fragment: None,
            position: None,
            suggestion: None,
        }
    }

    /// Create a simple reification error (backward compatibility)
    pub fn reification_error(message: impl Into<String>) -> Self {
        Self::ReificationError {
            message: message.into(),
            reification_strategy: None,
            context: None,
        }
    }

    /// Create a simple invalid term type error (backward compatibility)
    pub fn invalid_term_type(message: impl Into<String>) -> Self {
        Self::InvalidTermType {
            message: message.into(),
            term_type: None,
            expected_types: None,
            suggestion: None,
        }
    }

    /// Create a nesting depth error
    pub fn nesting_depth_exceeded(
        max_depth: usize,
        current_depth: usize,
        context: Option<String>,
    ) -> Self {
        Self::NestingDepthExceeded {
            max_depth,
            current_depth,
            context,
        }
    }

    /// Create a configuration error
    pub fn configuration_error(message: impl Into<String>) -> Self {
        Self::ConfigurationError {
            message: message.into(),
            parameter: None,
            valid_range: None,
        }
    }

    /// Create an internal error (for unexpected conditions such as lock poisoning)
    pub fn internal_error(message: impl Into<String>) -> Self {
        Self::InternalError {
            message: message.into(),
            context: None,
        }
    }

    /// Create an internal error for lock poisoning
    pub fn lock_error(context: impl Into<String>) -> Self {
        Self::InternalError {
            message: "Lock poisoned".to_string(),
            context: Some(context.into()),
        }
    }

    /// Create an unsupported format error with available alternatives
    pub fn unsupported_format(format: impl Into<String>, available: Vec<String>) -> Self {
        Self::UnsupportedFormat {
            format: format.into(),
            available_formats: available,
        }
    }

    /// Get available recovery suggestions for the error
    pub fn recovery_suggestions(&self) -> Vec<String> {
        let mut suggestions = Vec::new();

        match self {
            Self::NestingDepthExceeded { max_depth, .. } => {
                suggestions.push(format!(
                    "Consider increasing max_nesting_depth beyond {max_depth}"
                ));
                suggestions.push("Check for circular references in quoted triples".to_string());
            }
            Self::UnsupportedFormat {
                available_formats, ..
            } => {
                suggestions.push(format!(
                    "Supported formats: {}",
                    available_formats.join(", ")
                ));
            }
            Self::ConfigurationError {
                valid_range: Some(range),
                ..
            } => {
                suggestions.push(format!("Valid range: {range}"));
            }
            Self::ConfigurationError {
                valid_range: None, ..
            } => {}
            _ => {}
        }

        suggestions
    }

    /// Create a resource error (backward compatibility)
    pub fn resource_error(message: impl Into<String>) -> Self {
        Self::ConfigurationError {
            message: message.into(),
            parameter: Some("resource".to_string()),
            valid_range: None,
        }
    }

    /// Create a processing error (backward compatibility)
    pub fn processing_error(message: impl Into<String>) -> Self {
        Self::ConfigurationError {
            message: message.into(),
            parameter: Some("processing".to_string()),
            valid_range: None,
        }
    }
}

/// Configuration for RDF-star processing
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct StarConfig {
    /// Maximum nesting depth for quoted triples (default: 10)
    pub max_nesting_depth: usize,
    /// Enable automatic reification fallback
    pub enable_reification_fallback: bool,
    /// Strict mode for parsing (reject invalid constructs)
    pub strict_mode: bool,
    /// Enable SPARQL-star extensions
    pub enable_sparql_star: bool,
    /// Buffer size for streaming operations
    pub buffer_size: usize,
    /// Maximum parse errors before aborting (None for unlimited)
    pub max_parse_errors: Option<usize>,
}

impl Default for StarConfig {
    fn default() -> Self {
        Self {
            max_nesting_depth: 10,
            enable_reification_fallback: true,
            strict_mode: false,
            enable_sparql_star: true,
            buffer_size: 8192,
            max_parse_errors: Some(100),
        }
    }
}

/// Statistics for RDF-star processing
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct StarStatistics {
    /// Total number of quoted triples processed
    pub quoted_triples_count: usize,
    /// Maximum nesting depth encountered
    pub max_nesting_encountered: usize,
    /// Number of reified triples
    pub reified_triples_count: usize,
    /// Number of SPARQL-star queries executed
    pub sparql_star_queries_count: usize,
    /// Processing time statistics (in microseconds)
    pub processing_time_us: u64,
}

/// Initialize the RDF-star system with configuration
pub fn init_star_system(config: StarConfig) -> StarResult<()> {
    let span = span!(Level::INFO, "init_star_system");
    let _enter = span.enter();

    info!("Initializing OxiRS RDF-star system");
    debug!("Configuration: {:?}", config);

    // Validate configuration
    if config.max_nesting_depth == 0 {
        return Err(StarError::ConfigurationError {
            message: "Max nesting depth must be greater than 0".to_string(),
            parameter: Some("max_nesting_depth".to_string()),
            valid_range: Some("1..=1000".to_string()),
        });
    }

    if config.buffer_size == 0 {
        return Err(StarError::ConfigurationError {
            message: "Buffer size must be greater than 0".to_string(),
            parameter: Some("buffer_size".to_string()),
            valid_range: Some("1..=1048576".to_string()),
        });
    }

    // Additional validation for reasonable limits
    if config.max_nesting_depth > 1000 {
        return Err(StarError::ConfigurationError {
            message: "Max nesting depth is too large and may cause performance issues".to_string(),
            parameter: Some("max_nesting_depth".to_string()),
            valid_range: Some("1..=1000".to_string()),
        });
    }

    info!("RDF-star system initialized successfully");
    Ok(())
}

/// Utility function to validate quoted triple nesting depth
pub fn validate_nesting_depth(term: &StarTerm, max_depth: usize) -> StarResult<()> {
    fn check_depth(term: &StarTerm, current_depth: usize, max_depth: usize) -> StarResult<usize> {
        match term {
            StarTerm::QuotedTriple(triple) => {
                if current_depth >= max_depth {
                    return Err(StarError::InvalidQuotedTriple {
                        message: format!(
                            "Nesting depth {current_depth} exceeds maximum {max_depth}"
                        ),
                        context: None,
                        suggestion: None,
                    });
                }

                let subj_depth = check_depth(&triple.subject, current_depth + 1, max_depth)?;
                let pred_depth = check_depth(&triple.predicate, current_depth + 1, max_depth)?;
                let obj_depth = check_depth(&triple.object, current_depth + 1, max_depth)?;

                Ok(subj_depth.max(pred_depth).max(obj_depth))
            }
            _ => Ok(current_depth),
        }
    }

    check_depth(term, 0, max_depth)?;
    Ok(())
}

/// Version information
pub const VERSION: &str = env!("CARGO_PKG_VERSION");

/// Developer tooling and debugging utilities
///
/// This module provides comprehensive tools for validating, debugging, and analyzing
/// RDF-star data. It's designed to help developers identify issues, optimize performance,
/// and ensure data quality.
///
/// # Examples
///
/// ```rust,ignore
/// use oxirs_star::dev_tools::{detect_format, validate_content, StarProfiler};
/// use oxirs_star::StarConfig;
///
/// // Detect format from content
/// let content = "<< :s :p :o >> :meta :value .";
/// let format = detect_format(content);
/// println!("Detected format: {:?}", format);
///
/// // Validate content with detailed diagnostics
/// let config = StarConfig::default();
/// let result = validate_content(content, &config);
/// if !result.is_valid() {
///     for error in &result.errors {
///         println!("Error: {}", error);
///     }
/// }
///
/// // Profile performance
/// let mut profiler = StarProfiler::new();
/// let result = profiler.time_operation("parsing", || {
///     // ... parsing operation
///     42
/// });
/// println!("Operation took: {:?}", profiler.total_time());
/// ```
pub mod dev_tools {
    use super::*;
    use std::collections::HashMap;

    /// RDF-star format detection result
    #[derive(Debug, Clone, PartialEq)]
    pub enum DetectedFormat {
        TurtleStar,
        NTriplesStar,
        TrigStar,
        NQuadsStar,
        Unknown,
    }

    /// Detect RDF-star format from input content
    pub fn detect_format(content: &str) -> DetectedFormat {
        let content = content.trim();

        // Check for TriG-star indicators
        if content.contains("GRAPH") || content.contains("{") && content.contains("}") {
            return DetectedFormat::TrigStar;
        }

        // Check for N-Quads-star (4 terms per line)
        let lines: Vec<&str> = content
            .lines()
            .filter(|line| !line.trim().is_empty() && !line.trim().starts_with('#'))
            .collect();
        if !lines.is_empty() {
            let first_line = lines[0].trim();
            let terms: Vec<&str> = first_line.split_whitespace().collect();
            if terms.len() >= 4 && first_line.ends_with('.') {
                return DetectedFormat::NQuadsStar;
            }
        }

        // Check for quoted triples (RDF-star indicator)
        if content.contains("<<") && content.contains(">>") {
            // If has quotes and prefixes, likely Turtle-star
            if content.contains("@prefix") || content.contains("PREFIX") {
                return DetectedFormat::TurtleStar;
            }
            // Otherwise, likely N-Triples-star
            return DetectedFormat::NTriplesStar;
        }

        // Check for Turtle-star prefixes
        if content.contains("@prefix") || content.contains("@base") {
            return DetectedFormat::TurtleStar;
        }

        DetectedFormat::Unknown
    }

    /// Validate RDF-star content and return detailed diagnostic information
    pub fn validate_content(content: &str, config: &StarConfig) -> ValidationResult {
        let mut result = ValidationResult::new();

        // Basic format detection
        result.detected_format = detect_format(content);

        // Count quoted triples
        let quoted_count = content.matches("<<").count();
        result.quoted_triple_count = quoted_count;

        // Check for potential issues
        if quoted_count > 10000 && !config.enable_reification_fallback {
            result.warnings.push("Large number of quoted triples detected. Consider enabling reification fallback for better performance.".to_string());
        }

        // Check nesting depth by counting nested <<
        let max_nesting = find_max_nesting_depth(content);
        result.max_nesting_depth = max_nesting;

        if max_nesting > config.max_nesting_depth {
            result.errors.push(format!(
                "Nesting depth {} exceeds configured maximum {}",
                max_nesting, config.max_nesting_depth
            ));
        }

        // Check for common syntax issues
        check_syntax_issues(content, &mut result);

        result
    }

    /// Validation result with detailed diagnostics
    #[derive(Debug, Clone)]
    pub struct ValidationResult {
        pub detected_format: DetectedFormat,
        pub quoted_triple_count: usize,
        pub max_nesting_depth: usize,
        pub errors: Vec<String>,
        pub warnings: Vec<String>,
        pub suggestions: Vec<String>,
        pub line_errors: HashMap<u32, String>,
    }

    impl ValidationResult {
        fn new() -> Self {
            Self {
                detected_format: DetectedFormat::Unknown,
                quoted_triple_count: 0,
                max_nesting_depth: 0,
                errors: Vec::new(),
                warnings: Vec::new(),
                suggestions: Vec::new(),
                line_errors: HashMap::new(),
            }
        }

        /// Check if validation passed without errors
        pub fn is_valid(&self) -> bool {
            self.errors.is_empty()
        }

        /// Get a summary report of the validation
        pub fn summary(&self) -> String {
            let mut summary = String::new();
            summary.push_str(&format!("Format: {:?}\n", self.detected_format));
            summary.push_str(&format!("Quoted triples: {}\n", self.quoted_triple_count));
            summary.push_str(&format!("Max nesting depth: {}\n", self.max_nesting_depth));

            if !self.errors.is_empty() {
                summary.push_str(&format!("Errors: {}\n", self.errors.len()));
            }

            if !self.warnings.is_empty() {
                summary.push_str(&format!("Warnings: {}\n", self.warnings.len()));
            }

            summary
        }
    }

    fn find_max_nesting_depth(content: &str) -> usize {
        let mut max_depth: usize = 0;
        let mut current_depth: i32 = 0;

        for ch in content.chars() {
            match ch {
                '<' => {
                    // Look ahead for another '<' to detect quoted triple start
                    current_depth += 1;
                }
                '>' => {
                    current_depth = current_depth.saturating_sub(1);
                }
                _ => {}
            }
            max_depth = max_depth.max((current_depth / 2).max(0) as usize); // Divide by 2 since we count both < and >
        }

        max_depth
    }

    fn check_syntax_issues(content: &str, result: &mut ValidationResult) {
        let lines: Vec<&str> = content.lines().collect();

        for (line_num, line) in lines.iter().enumerate() {
            let line_num = line_num as u32 + 1;
            let trimmed = line.trim();

            // Skip comments and empty lines
            if trimmed.is_empty() || trimmed.starts_with('#') {
                continue;
            }

            // Check for unmatched quoted triple brackets
            let open_count = trimmed.matches("<<").count();
            let close_count = trimmed.matches(">>").count();

            if open_count != close_count {
                result.line_errors.insert(
                    line_num,
                    format!(
                        "Unmatched quoted triple brackets: {open_count} << vs {close_count} >>"
                    ),
                );
            }

            // Check for missing periods in N-Triples/N-Quads style
            if (result.detected_format == DetectedFormat::NTriplesStar
                || result.detected_format == DetectedFormat::NQuadsStar)
                && !trimmed.ends_with('.')
                && !trimmed.starts_with('@')
                && !trimmed.starts_with("PREFIX")
            {
                result.warnings.push(format!(
                    "Line {line_num}: Missing period at end of statement"
                ));
            }
        }
    }

    /// Performance profiler for RDF-star operations
    pub struct StarProfiler {
        start_time: std::time::Instant,
        operation_times: HashMap<String, u64>,
    }

    impl StarProfiler {
        pub fn new() -> Self {
            Self {
                start_time: std::time::Instant::now(),
                operation_times: HashMap::new(),
            }
        }

        pub fn time_operation<F, R>(&mut self, name: &str, operation: F) -> R
        where
            F: FnOnce() -> R,
        {
            let start = std::time::Instant::now();
            let result = operation();
            let duration = start.elapsed().as_micros() as u64;
            self.operation_times.insert(name.to_string(), duration);
            result
        }

        pub fn get_stats(&self) -> HashMap<String, u64> {
            self.operation_times.clone()
        }

        pub fn total_time(&self) -> u64 {
            self.start_time.elapsed().as_micros() as u64
        }
    }

    impl Default for StarProfiler {
        fn default() -> Self {
            Self::new()
        }
    }

    /// Generate a diagnostic report for RDF-star content
    pub fn generate_diagnostic_report(content: &str, config: &StarConfig) -> String {
        let validation = validate_content(content, config);
        let mut report = String::new();

        report.push_str("=== RDF-star Diagnostic Report ===\n\n");
        report.push_str(&validation.summary());

        if !validation.errors.is_empty() {
            report.push_str("\nErrors:\n");
            for (i, error) in validation.errors.iter().enumerate() {
                report.push_str(&format!("  {}. {}\n", i + 1, error));
            }
        }

        if !validation.warnings.is_empty() {
            report.push_str("\nWarnings:\n");
            for (i, warning) in validation.warnings.iter().enumerate() {
                report.push_str(&format!("  {}. {}\n", i + 1, warning));
            }
        }

        if !validation.suggestions.is_empty() {
            report.push_str("\nSuggestions:\n");
            for (i, suggestion) in validation.suggestions.iter().enumerate() {
                report.push_str(&format!("  {}. {}\n", i + 1, suggestion));
            }
        }

        if !validation.line_errors.is_empty() {
            report.push_str("\nLine-specific issues:\n");
            let mut sorted_lines: Vec<_> = validation.line_errors.iter().collect();
            sorted_lines.sort_by_key(|(line, _)| *line);

            for (line, error) in sorted_lines {
                report.push_str(&format!("  Line {line}: {error}\n"));
            }
        }

        report
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_config_default() {
        let config = StarConfig::default();
        assert_eq!(config.max_nesting_depth, 10);
        assert!(config.enable_reification_fallback);
        assert!(!config.strict_mode);
        assert!(config.enable_sparql_star);
    }

    #[test]
    fn test_nesting_depth_validation() {
        let simple_term = StarTerm::iri("http://example.org/test").unwrap();
        assert!(validate_nesting_depth(&simple_term, 5).is_ok());

        // Test nested quoted triple
        let inner_triple = StarTriple::new(
            StarTerm::iri("http://example.org/s").unwrap(),
            StarTerm::iri("http://example.org/p").unwrap(),
            StarTerm::iri("http://example.org/o").unwrap(),
        );
        let nested_term = StarTerm::quoted_triple(inner_triple);
        assert!(validate_nesting_depth(&nested_term, 5).is_ok());
        assert!(validate_nesting_depth(&nested_term, 0).is_err());
    }
}