aingle_minimal 0.6.2

// Copyright 2019-2026 Apilium Technologies OÜ. All rights reserved.
// SPDX-License-Identifier: Apache-2.0 OR Commercial

//! Sensor Abstraction Layer for IoT Devices
//!
//! Provides a unified interface for reading various types of sensors commonly
//! found in IoT devices. Supports both built-in sensors and custom sensor implementations.
//!
//! # Supported Sensor Types
//! - Temperature (Celsius)
//! - Humidity (percentage)
//! - Pressure (hPa)
//! - Light (lux)
//! - Motion/PIR (binary)
//! - GPS/Location (lat/lon)
//! - Accelerometer (3-axis)
//! - Custom sensors via trait implementation
//!
//! # Example
//! ```rust
//! use aingle_minimal::sensors::{Sensor, SensorType, MockSensor};
//!
//! let sensor = MockSensor::new(SensorType::Temperature);
//! let reading = sensor.read().expect("sensor read failed");
//! println!("Temperature: {}°C", reading.value);
//! ```

use crate::error::{Error, Result};
use serde::{Deserialize, Serialize};
use std::time::{SystemTime, UNIX_EPOCH};

/// Sensor reading with metadata
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct SensorReading {
    /// Sensor type
    pub sensor_type: SensorType,
    /// Measured value
    pub value: f64,
    /// Unit of measurement
    pub unit: String,
    /// Timestamp (Unix epoch milliseconds)
    pub timestamp: u64,
    /// Quality indicator (0.0 to 1.0)
    pub quality: f64,
    /// Optional metadata
    #[serde(default)]
    pub metadata: std::collections::HashMap<String, String>,
}

impl SensorReading {
    /// Create a new sensor reading
    pub fn new(sensor_type: SensorType, value: f64, unit: String) -> Self {
        Self {
            sensor_type,
            value,
            unit,
            timestamp: SystemTime::now()
                .duration_since(UNIX_EPOCH)
                .unwrap()
                .as_millis() as u64,
            quality: 1.0,
            metadata: std::collections::HashMap::new(),
        }
    }

    /// Set quality indicator
    pub fn with_quality(mut self, quality: f64) -> Self {
        self.quality = quality.clamp(0.0, 1.0);
        self
    }

    /// Add metadata field
    pub fn with_metadata(mut self, key: String, value: String) -> Self {
        self.metadata.insert(key, value);
        self
    }

    /// Check if reading is valid (quality > threshold)
    pub fn is_valid(&self, threshold: f64) -> bool {
        self.quality >= threshold
    }
}

/// Sensor types supported by the platform
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
pub enum SensorType {
    /// Temperature sensor (Celsius)
    Temperature,
    /// Humidity sensor (percentage)
    Humidity,
    /// Barometric pressure (hPa)
    Pressure,
    /// Light sensor (lux)
    Light,
    /// Motion/PIR sensor (binary)
    Motion,
    /// GPS location (lat/lon)
    GPS,
    /// Accelerometer (3-axis)
    Accelerometer,
    /// Gyroscope (3-axis)
    Gyroscope,
    /// Magnetometer (3-axis)
    Magnetometer,
    /// Proximity sensor (cm)
    Proximity,
    /// Sound level (dB)
    Sound,
    /// Air quality (PPM)
    AirQuality,
    /// Voltage (V)
    Voltage,
    /// Current (A)
    Current,
    /// Power (W)
    Power,
    /// Custom sensor type
    Custom(u16),
}

impl SensorType {
    /// Get default unit for this sensor type
    pub fn default_unit(&self) -> &'static str {
        match self {
            SensorType::Temperature => "°C",
            SensorType::Humidity => "%",
            SensorType::Pressure => "hPa",
            SensorType::Light => "lux",
            SensorType::Motion => "bool",
            SensorType::GPS => "deg",
            SensorType::Accelerometer => "m/s²",
            SensorType::Gyroscope => "rad/s",
            SensorType::Magnetometer => "μT",
            SensorType::Proximity => "cm",
            SensorType::Sound => "dB",
            SensorType::AirQuality => "PPM",
            SensorType::Voltage => "V",
            SensorType::Current => "A",
            SensorType::Power => "W",
            SensorType::Custom(_) => "custom",
        }
    }

    /// Get human-readable name
    pub fn name(&self) -> &'static str {
        match self {
            SensorType::Temperature => "Temperature",
            SensorType::Humidity => "Humidity",
            SensorType::Pressure => "Pressure",
            SensorType::Light => "Light",
            SensorType::Motion => "Motion",
            SensorType::GPS => "GPS",
            SensorType::Accelerometer => "Accelerometer",
            SensorType::Gyroscope => "Gyroscope",
            SensorType::Magnetometer => "Magnetometer",
            SensorType::Proximity => "Proximity",
            SensorType::Sound => "Sound",
            SensorType::AirQuality => "Air Quality",
            SensorType::Voltage => "Voltage",
            SensorType::Current => "Current",
            SensorType::Power => "Power",
            SensorType::Custom(_) => "Custom",
        }
    }
}

/// Calibration parameters for sensor tuning
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct CalibrationParams {
    /// Offset to add to raw readings
    pub offset: f64,
    /// Scale factor to multiply raw readings
    pub scale: f64,
    /// Reference value for calibration
    pub reference: Option<f64>,
    /// Calibration timestamp
    pub calibrated_at: u64,
}

impl Default for CalibrationParams {
    fn default() -> Self {
        Self {
            offset: 0.0,
            scale: 1.0,
            reference: None,
            calibrated_at: 0,
        }
    }
}

impl CalibrationParams {
    /// Apply calibration to a raw value
    pub fn apply(&self, raw: f64) -> f64 {
        (raw * self.scale) + self.offset
    }
}

/// GPS coordinate
#[derive(Debug, Clone, Copy, Serialize, Deserialize)]
pub struct GpsCoordinate {
    /// Latitude in degrees
    pub latitude: f64,
    /// Longitude in degrees
    pub longitude: f64,
    /// Altitude in meters
    pub altitude: Option<f64>,
    /// Accuracy in meters
    pub accuracy: Option<f64>,
}

/// 3-axis sensor data (accelerometer, gyroscope, magnetometer)
#[derive(Debug, Clone, Copy, Serialize, Deserialize)]
pub struct Axis3D {
    pub x: f64,
    pub y: f64,
    pub z: f64,
}

impl Axis3D {
    /// Calculate magnitude
    pub fn magnitude(&self) -> f64 {
        (self.x * self.x + self.y * self.y + self.z * self.z).sqrt()
    }
}

/// Sensor trait - implement this for custom sensors
pub trait Sensor: Send + Sync {
    /// Read current sensor value
    fn read(&self) -> Result<SensorReading>;

    /// Get sensor type
    fn sensor_type(&self) -> SensorType;

    /// Calibrate the sensor
    fn calibrate(&mut self, params: CalibrationParams) -> Result<()>;

    /// Get current calibration parameters
    fn get_calibration(&self) -> CalibrationParams;

    /// Check if sensor is available and working
    fn is_available(&self) -> bool {
        true
    }

    /// Get sensor name/identifier
    fn name(&self) -> &str {
        self.sensor_type().name()
    }

    /// Get sampling rate in Hz (optional)
    fn sampling_rate(&self) -> Option<f64> {
        None
    }

    /// Reset the sensor
    fn reset(&mut self) -> Result<()> {
        Ok(())
    }
}

/// Mock sensor for testing
pub struct MockSensor {
    sensor_type: SensorType,
    calibration: CalibrationParams,
    base_value: f64,
}

impl MockSensor {
    /// Create a new mock sensor
    pub fn new(sensor_type: SensorType) -> Self {
        let base_value = match sensor_type {
            SensorType::Temperature => 20.0,
            SensorType::Humidity => 50.0,
            SensorType::Pressure => 1013.25,
            SensorType::Light => 500.0,
            SensorType::Motion => 0.0,
            _ => 0.0,
        };

        Self {
            sensor_type,
            calibration: CalibrationParams::default(),
            base_value,
        }
    }

    /// Set base value for testing
    pub fn set_value(&mut self, value: f64) {
        self.base_value = value;
    }
}

impl Sensor for MockSensor {
    fn read(&self) -> Result<SensorReading> {
        // Add some random variation
        let variation: f64 = (rand::random::<f64>() - 0.5) * 2.0;
        let raw = self.base_value + variation;
        let value = self.calibration.apply(raw);

        Ok(SensorReading::new(
            self.sensor_type,
            value,
            self.sensor_type.default_unit().to_string(),
        ))
    }

    fn sensor_type(&self) -> SensorType {
        self.sensor_type
    }

    fn calibrate(&mut self, params: CalibrationParams) -> Result<()> {
        self.calibration = params;
        Ok(())
    }

    fn get_calibration(&self) -> CalibrationParams {
        self.calibration.clone()
    }
}

/// Sensor manager for handling multiple sensors
pub struct SensorManager {
    sensors: Vec<Box<dyn Sensor>>,
}

impl SensorManager {
    /// Create a new sensor manager
    pub fn new() -> Self {
        Self {
            sensors: Vec::new(),
        }
    }

    /// Register a sensor
    pub fn register(&mut self, sensor: Box<dyn Sensor>) {
        log::info!("Registered sensor: {}", sensor.name());
        self.sensors.push(sensor);
    }

    /// Read all sensors
    pub fn read_all(&self) -> Vec<Result<SensorReading>> {
        self.sensors.iter().map(|s| s.read()).collect()
    }

    /// Read sensors of a specific type
    pub fn read_by_type(&self, sensor_type: SensorType) -> Vec<Result<SensorReading>> {
        self.sensors
            .iter()
            .filter(|s| s.sensor_type() == sensor_type)
            .map(|s| s.read())
            .collect()
    }

    /// Get sensor count
    pub fn sensor_count(&self) -> usize {
        self.sensors.len()
    }

    /// Get available sensors (working sensors)
    pub fn available_sensors(&self) -> Vec<&dyn Sensor> {
        self.sensors
            .iter()
            .filter(|s| s.is_available())
            .map(|s| s.as_ref())
            .collect()
    }
}

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

/// Sensor statistics
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct SensorStats {
    /// Total readings taken
    pub total_readings: u64,
    /// Failed readings
    pub failed_readings: u64,
    /// Average reading interval (ms)
    pub avg_interval_ms: u64,
    /// Last reading timestamp
    pub last_reading: u64,
}

impl SensorStats {
    /// Create new stats
    pub fn new() -> Self {
        Self::default()
    }

    /// Record a successful reading
    pub fn record_success(&mut self) {
        self.total_readings += 1;
        self.last_reading = SystemTime::now()
            .duration_since(UNIX_EPOCH)
            .unwrap()
            .as_millis() as u64;
    }

    /// Record a failed reading
    pub fn record_failure(&mut self) {
        self.failed_readings += 1;
    }

    /// Get success rate
    pub fn success_rate(&self) -> f64 {
        if self.total_readings == 0 {
            return 0.0;
        }
        let successful = self.total_readings - self.failed_readings;
        (successful as f64) / (self.total_readings as f64)
    }
}

/// Sensor adapter for common sensor hardware
pub mod adapters {
    use super::*;

    // ============================================================================
    // DHT22 Temperature/Humidity Sensor (1-Wire Protocol)
    // ============================================================================

    /// DHT22 register/timing constants
    pub mod dht22_const {
        /// Minimum time between readings (microseconds)
        pub const MIN_INTERVAL_US: u32 = 2_000_000;
        /// Start signal low time (microseconds)
        pub const START_LOW_US: u32 = 1000;
        /// Start signal high time (microseconds)
        pub const START_HIGH_US: u32 = 30;
        /// Bit 0 high time threshold (microseconds)
        pub const BIT_THRESHOLD_US: u32 = 50;
    }

    /// DHT22 Temperature/Humidity sensor
    ///
    /// Uses 1-wire protocol on a single GPIO pin.
    /// Provides temperature (-40 to 80°C) and humidity (0-100%) readings.
    pub struct Dht22Sensor {
        calibration: CalibrationParams,
        /// Last raw data (5 bytes: 2 humidity, 2 temperature, 1 checksum)
        last_raw: [u8; 5],
        /// Simulated mode for testing without hardware
        simulated: bool,
        /// Simulated temperature value
        sim_temperature: f64,
        /// Simulated humidity value
        sim_humidity: f64,
    }

    impl Dht22Sensor {
        /// Create a new DHT22 sensor (simulated mode)
        pub fn new() -> Self {
            Self {
                calibration: CalibrationParams::default(),
                last_raw: [0u8; 5],
                simulated: true,
                sim_temperature: 22.0,
                sim_humidity: 45.0,
            }
        }

        /// Create with embedded-hal GPIO pin (requires `embedded` feature)
        #[cfg(feature = "embedded")]
        pub fn with_pin<P>(_pin: P) -> Self
        where
            P: embedded_hal::digital::InputPin + embedded_hal::digital::OutputPin,
        {
            Self {
                calibration: CalibrationParams::default(),
                last_raw: [0u8; 5],
                simulated: false,
                sim_temperature: 0.0,
                sim_humidity: 0.0,
            }
        }

        /// Set simulated values for testing
        pub fn set_simulated_values(&mut self, temperature: f64, humidity: f64) {
            self.sim_temperature = temperature;
            self.sim_humidity = humidity;
        }

        /// Parse temperature from raw bytes
        fn parse_temperature(raw: &[u8; 5]) -> f64 {
            let mut temp = ((raw[2] & 0x7F) as u16) << 8 | raw[3] as u16;
            if raw[2] & 0x80 != 0 {
                temp = -(temp as i16) as u16;
            }
            temp as f64 / 10.0
        }

        /// Parse humidity from raw bytes
        fn parse_humidity(raw: &[u8; 5]) -> f64 {
            let humidity = (raw[0] as u16) << 8 | raw[1] as u16;
            humidity as f64 / 10.0
        }

        /// Verify checksum
        fn verify_checksum(raw: &[u8; 5]) -> bool {
            let sum = raw[0]
                .wrapping_add(raw[1])
                .wrapping_add(raw[2])
                .wrapping_add(raw[3]);
            sum == raw[4]
        }

        /// Read humidity value
        pub fn read_humidity(&self) -> Result<SensorReading> {
            if self.simulated {
                let value = self.calibration.apply(self.sim_humidity);
                return Ok(SensorReading::new(
                    SensorType::Humidity,
                    value,
                    "%".to_string(),
                ));
            }
            let humidity = Self::parse_humidity(&self.last_raw);
            let value = self.calibration.apply(humidity);
            Ok(SensorReading::new(
                SensorType::Humidity,
                value,
                "%".to_string(),
            ))
        }
    }

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

    impl Sensor for Dht22Sensor {
        fn read(&self) -> Result<SensorReading> {
            if self.simulated {
                // Return simulated reading with small random variation
                let variation = (rand::random::<f64>() - 0.5) * 0.5;
                let temp = self.sim_temperature + variation;
                let value = self.calibration.apply(temp);
                return Ok(SensorReading::new(
                    SensorType::Temperature,
                    value,
                    "°C".to_string(),
                ));
            }

            // Verify checksum
            if !Self::verify_checksum(&self.last_raw) {
                return Err(Error::ValidationFailed(
                    "DHT22 checksum mismatch".to_string(),
                ));
            }

            let temp = Self::parse_temperature(&self.last_raw);
            let value = self.calibration.apply(temp);
            Ok(SensorReading::new(
                SensorType::Temperature,
                value,
                "°C".to_string(),
            ))
        }

        fn sensor_type(&self) -> SensorType {
            SensorType::Temperature
        }

        fn calibrate(&mut self, params: CalibrationParams) -> Result<()> {
            self.calibration = params;
            Ok(())
        }

        fn get_calibration(&self) -> CalibrationParams {
            self.calibration.clone()
        }

        fn is_available(&self) -> bool {
            self.simulated || self.last_raw.iter().any(|&b| b != 0)
        }
    }

    // ============================================================================
    // BMP280 Pressure/Temperature Sensor (I2C Protocol)
    // ============================================================================

    /// BMP280 I2C register addresses
    pub mod bmp280_reg {
        pub const CHIP_ID: u8 = 0xD0;
        pub const RESET: u8 = 0xE0;
        pub const STATUS: u8 = 0xF3;
        pub const CTRL_MEAS: u8 = 0xF4;
        pub const CONFIG: u8 = 0xF5;
        pub const PRESS_MSB: u8 = 0xF7;
        pub const TEMP_MSB: u8 = 0xFA;
        pub const CALIB_START: u8 = 0x88;
        /// Expected chip ID value
        pub const CHIP_ID_VALUE: u8 = 0x58;
        /// Default I2C address (SDO to GND)
        pub const I2C_ADDR_PRIMARY: u8 = 0x76;
        /// Alternate I2C address (SDO to VCC)
        pub const I2C_ADDR_SECONDARY: u8 = 0x77;
    }

    /// BMP280 calibration data (from device registers)
    #[derive(Debug, Clone, Default)]
    pub struct Bmp280Calibration {
        pub dig_t1: u16,
        pub dig_t2: i16,
        pub dig_t3: i16,
        pub dig_p1: u16,
        pub dig_p2: i16,
        pub dig_p3: i16,
        pub dig_p4: i16,
        pub dig_p5: i16,
        pub dig_p6: i16,
        pub dig_p7: i16,
        pub dig_p8: i16,
        pub dig_p9: i16,
    }

    /// BMP280 Pressure/Temperature sensor
    ///
    /// Uses I2C protocol. Provides pressure (300-1100 hPa) and temperature
    /// (-40 to 85°C) readings with high precision.
    #[allow(dead_code)]
    pub struct Bmp280Sensor {
        calibration: CalibrationParams,
        /// Device calibration coefficients
        device_calib: Bmp280Calibration,
        /// I2C address (used with real hardware)
        i2c_addr: u8,
        /// Simulated mode
        simulated: bool,
        /// Simulated pressure (hPa)
        sim_pressure: f64,
        /// Simulated temperature (°C)
        sim_temperature: f64,
        /// Fine temperature for compensation (used with real hardware)
        t_fine: i32,
    }

    impl Bmp280Sensor {
        /// Create a new BMP280 sensor (simulated mode)
        pub fn new() -> Self {
            Self {
                calibration: CalibrationParams::default(),
                device_calib: Bmp280Calibration::default(),
                i2c_addr: bmp280_reg::I2C_ADDR_PRIMARY,
                simulated: true,
                sim_pressure: 1013.25,
                sim_temperature: 22.0,
                t_fine: 0,
            }
        }

        /// Create with I2C bus (requires `embedded` feature)
        #[cfg(feature = "embedded")]
        pub fn with_i2c<I>(_i2c: I, addr: u8) -> Self
        where
            I: embedded_hal::i2c::I2c,
        {
            Self {
                calibration: CalibrationParams::default(),
                device_calib: Bmp280Calibration::default(),
                i2c_addr: addr,
                simulated: false,
                sim_pressure: 0.0,
                sim_temperature: 0.0,
                t_fine: 0,
            }
        }

        /// Set simulated values
        pub fn set_simulated_values(&mut self, pressure: f64, temperature: f64) {
            self.sim_pressure = pressure;
            self.sim_temperature = temperature;
        }

        /// Get I2C address
        pub fn i2c_addr(&self) -> u8 {
            self.i2c_addr
        }

        /// Compensate raw temperature using calibration coefficients
        /// (Used with real hardware I2C readings)
        #[allow(dead_code)]
        fn compensate_temperature(&mut self, adc_t: i32) -> f64 {
            let var1 = (((adc_t >> 3) - ((self.device_calib.dig_t1 as i32) << 1))
                * (self.device_calib.dig_t2 as i32))
                >> 11;
            let var2 = (((((adc_t >> 4) - (self.device_calib.dig_t1 as i32))
                * ((adc_t >> 4) - (self.device_calib.dig_t1 as i32)))
                >> 12)
                * (self.device_calib.dig_t3 as i32))
                >> 14;
            self.t_fine = var1 + var2;
            ((self.t_fine * 5 + 128) >> 8) as f64 / 100.0
        }

        /// Compensate raw pressure using calibration coefficients
        /// (Used with real hardware I2C readings)
        #[allow(dead_code)]
        fn compensate_pressure(&self, adc_p: i32) -> f64 {
            let mut var1 = (self.t_fine as i64) - 128000;
            let mut var2 = var1 * var1 * (self.device_calib.dig_p6 as i64);
            var2 += (var1 * (self.device_calib.dig_p5 as i64)) << 17;
            var2 += (self.device_calib.dig_p4 as i64) << 35;
            var1 = ((var1 * var1 * (self.device_calib.dig_p3 as i64)) >> 8)
                + ((var1 * (self.device_calib.dig_p2 as i64)) << 12);
            var1 = (((1i64 << 47) + var1) * (self.device_calib.dig_p1 as i64)) >> 33;

            if var1 == 0 {
                return 0.0;
            }

            let mut p = 1048576 - adc_p as i64;
            p = (((p << 31) - var2) * 3125) / var1;
            var1 = ((self.device_calib.dig_p9 as i64) * (p >> 13) * (p >> 13)) >> 25;
            var2 = ((self.device_calib.dig_p8 as i64) * p) >> 19;
            p = ((p + var1 + var2) >> 8) + ((self.device_calib.dig_p7 as i64) << 4);

            (p as f64) / 256.0 / 100.0 // Convert to hPa
        }

        /// Read temperature
        pub fn read_temperature(&mut self) -> Result<SensorReading> {
            if self.simulated {
                let variation = (rand::random::<f64>() - 0.5) * 0.2;
                let value = self.calibration.apply(self.sim_temperature + variation);
                return Ok(SensorReading::new(
                    SensorType::Temperature,
                    value,
                    "°C".to_string(),
                ));
            }
            // Would read from I2C here
            Ok(SensorReading::new(
                SensorType::Temperature,
                0.0,
                "°C".to_string(),
            ))
        }
    }

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

    impl Sensor for Bmp280Sensor {
        fn read(&self) -> Result<SensorReading> {
            if self.simulated {
                let variation = (rand::random::<f64>() - 0.5) * 0.5;
                let pressure = self.sim_pressure + variation;
                let value = self.calibration.apply(pressure);
                return Ok(SensorReading::new(
                    SensorType::Pressure,
                    value,
                    "hPa".to_string(),
                ));
            }

            // In real implementation, would read from I2C bus
            // For now, return default reading
            Ok(SensorReading::new(
                SensorType::Pressure,
                1013.25,
                "hPa".to_string(),
            ))
        }

        fn sensor_type(&self) -> SensorType {
            SensorType::Pressure
        }

        fn calibrate(&mut self, params: CalibrationParams) -> Result<()> {
            self.calibration = params;
            Ok(())
        }

        fn get_calibration(&self) -> CalibrationParams {
            self.calibration.clone()
        }

        fn is_available(&self) -> bool {
            self.simulated || self.device_calib.dig_t1 != 0
        }
    }

    // ============================================================================
    // MPU6050 Accelerometer/Gyroscope Sensor (I2C Protocol)
    // ============================================================================

    /// MPU6050 I2C register addresses
    pub mod mpu6050_reg {
        pub const WHO_AM_I: u8 = 0x75;
        pub const PWR_MGMT_1: u8 = 0x6B;
        pub const PWR_MGMT_2: u8 = 0x6C;
        pub const ACCEL_CONFIG: u8 = 0x1C;
        pub const GYRO_CONFIG: u8 = 0x1B;
        pub const ACCEL_XOUT_H: u8 = 0x3B;
        pub const GYRO_XOUT_H: u8 = 0x43;
        pub const TEMP_OUT_H: u8 = 0x41;
        /// Expected WHO_AM_I value
        pub const WHO_AM_I_VALUE: u8 = 0x68;
        /// Default I2C address (AD0 to GND)
        pub const I2C_ADDR_PRIMARY: u8 = 0x68;
        /// Alternate I2C address (AD0 to VCC)
        pub const I2C_ADDR_SECONDARY: u8 = 0x69;
    }

    /// Accelerometer full-scale range
    #[derive(Debug, Clone, Copy, PartialEq, Eq)]
    pub enum AccelRange {
        G2 = 0,
        G4 = 1,
        G8 = 2,
        G16 = 3,
    }

    impl AccelRange {
        /// Get sensitivity in LSB/g
        pub fn sensitivity(&self) -> f64 {
            match self {
                AccelRange::G2 => 16384.0,
                AccelRange::G4 => 8192.0,
                AccelRange::G8 => 4096.0,
                AccelRange::G16 => 2048.0,
            }
        }
    }

    /// Gyroscope full-scale range
    #[derive(Debug, Clone, Copy, PartialEq, Eq)]
    pub enum GyroRange {
        Dps250 = 0,
        Dps500 = 1,
        Dps1000 = 2,
        Dps2000 = 3,
    }

    impl GyroRange {
        /// Get sensitivity in LSB/(°/s)
        pub fn sensitivity(&self) -> f64 {
            match self {
                GyroRange::Dps250 => 131.0,
                GyroRange::Dps500 => 65.5,
                GyroRange::Dps1000 => 32.8,
                GyroRange::Dps2000 => 16.4,
            }
        }
    }

    /// MPU6050 Accelerometer/Gyroscope sensor
    ///
    /// Uses I2C protocol. Provides 3-axis acceleration and angular velocity.
    #[allow(dead_code)]
    pub struct Mpu6050Sensor {
        calibration: CalibrationParams,
        /// I2C address (used with real hardware)
        i2c_addr: u8,
        /// Accelerometer range
        accel_range: AccelRange,
        /// Gyroscope range
        gyro_range: GyroRange,
        /// Simulated mode
        simulated: bool,
        /// Simulated accelerometer values (g)
        sim_accel: Axis3D,
        /// Simulated gyroscope values (°/s)
        sim_gyro: Axis3D,
    }

    impl Mpu6050Sensor {
        /// Create a new MPU6050 sensor (simulated mode)
        pub fn new() -> Self {
            Self {
                calibration: CalibrationParams::default(),
                i2c_addr: mpu6050_reg::I2C_ADDR_PRIMARY,
                accel_range: AccelRange::G2,
                gyro_range: GyroRange::Dps250,
                simulated: true,
                sim_accel: Axis3D {
                    x: 0.0,
                    y: 0.0,
                    z: 1.0,
                }, // Earth gravity on Z
                sim_gyro: Axis3D {
                    x: 0.0,
                    y: 0.0,
                    z: 0.0,
                },
            }
        }

        /// Create with I2C bus (requires `embedded` feature)
        #[cfg(feature = "embedded")]
        pub fn with_i2c<I>(_i2c: I, addr: u8) -> Self
        where
            I: embedded_hal::i2c::I2c,
        {
            Self {
                calibration: CalibrationParams::default(),
                i2c_addr: addr,
                accel_range: AccelRange::G2,
                gyro_range: GyroRange::Dps250,
                simulated: false,
                sim_accel: Axis3D {
                    x: 0.0,
                    y: 0.0,
                    z: 0.0,
                },
                sim_gyro: Axis3D {
                    x: 0.0,
                    y: 0.0,
                    z: 0.0,
                },
            }
        }

        /// Set simulated accelerometer values
        pub fn set_simulated_accel(&mut self, accel: Axis3D) {
            self.sim_accel = accel;
        }

        /// Set simulated gyroscope values
        pub fn set_simulated_gyro(&mut self, gyro: Axis3D) {
            self.sim_gyro = gyro;
        }

        /// Set accelerometer range
        pub fn set_accel_range(&mut self, range: AccelRange) {
            self.accel_range = range;
        }

        /// Set gyroscope range
        pub fn set_gyro_range(&mut self, range: GyroRange) {
            self.gyro_range = range;
        }

        /// Read gyroscope data
        pub fn read_gyro(&self) -> Result<SensorReading> {
            if self.simulated {
                let magnitude = self.sim_gyro.magnitude();
                let value = self.calibration.apply(magnitude);
                let mut reading =
                    SensorReading::new(SensorType::Gyroscope, value, "°/s".to_string());
                reading
                    .metadata
                    .insert("x".to_string(), format!("{:.4}", self.sim_gyro.x));
                reading
                    .metadata
                    .insert("y".to_string(), format!("{:.4}", self.sim_gyro.y));
                reading
                    .metadata
                    .insert("z".to_string(), format!("{:.4}", self.sim_gyro.z));
                return Ok(reading);
            }
            // Would read from I2C here
            Ok(SensorReading::new(
                SensorType::Gyroscope,
                0.0,
                "°/s".to_string(),
            ))
        }

        /// Read accelerometer as Axis3D
        pub fn read_accel_3d(&self) -> Result<Axis3D> {
            if self.simulated {
                return Ok(Axis3D {
                    x: self.sim_accel.x + (rand::random::<f64>() - 0.5) * 0.01,
                    y: self.sim_accel.y + (rand::random::<f64>() - 0.5) * 0.01,
                    z: self.sim_accel.z + (rand::random::<f64>() - 0.5) * 0.01,
                });
            }
            Ok(Axis3D {
                x: 0.0,
                y: 0.0,
                z: 0.0,
            })
        }
    }

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

    impl Sensor for Mpu6050Sensor {
        fn read(&self) -> Result<SensorReading> {
            if self.simulated {
                // Add small random variation
                let variation = Axis3D {
                    x: (rand::random::<f64>() - 0.5) * 0.02,
                    y: (rand::random::<f64>() - 0.5) * 0.02,
                    z: (rand::random::<f64>() - 0.5) * 0.02,
                };
                let accel = Axis3D {
                    x: self.sim_accel.x + variation.x,
                    y: self.sim_accel.y + variation.y,
                    z: self.sim_accel.z + variation.z,
                };
                let magnitude = accel.magnitude();
                let value = self.calibration.apply(magnitude);

                let mut reading =
                    SensorReading::new(SensorType::Accelerometer, value, "g".to_string());
                reading
                    .metadata
                    .insert("x".to_string(), format!("{:.4}", accel.x));
                reading
                    .metadata
                    .insert("y".to_string(), format!("{:.4}", accel.y));
                reading
                    .metadata
                    .insert("z".to_string(), format!("{:.4}", accel.z));
                return Ok(reading);
            }

            // In real implementation, would read from I2C bus
            Ok(SensorReading::new(
                SensorType::Accelerometer,
                0.0,
                "g".to_string(),
            ))
        }

        fn sensor_type(&self) -> SensorType {
            SensorType::Accelerometer
        }

        fn calibrate(&mut self, params: CalibrationParams) -> Result<()> {
            self.calibration = params;
            Ok(())
        }

        fn get_calibration(&self) -> CalibrationParams {
            self.calibration.clone()
        }

        fn is_available(&self) -> bool {
            true // Simulated or hardware
        }

        fn name(&self) -> &str {
            "MPU6050"
        }
    }
}

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

    #[test]
    fn test_sensor_reading_creation() {
        let reading = SensorReading::new(SensorType::Temperature, 25.5, "°C".to_string());
        assert_eq!(reading.sensor_type, SensorType::Temperature);
        assert_eq!(reading.value, 25.5);
        assert_eq!(reading.unit, "°C");
        assert_eq!(reading.quality, 1.0);
    }

    #[test]
    fn test_sensor_reading_quality() {
        let reading =
            SensorReading::new(SensorType::Temperature, 25.5, "°C".to_string()).with_quality(0.8);
        assert_eq!(reading.quality, 0.8);
        assert!(reading.is_valid(0.7));
        assert!(!reading.is_valid(0.9));
    }

    #[test]
    fn test_sensor_reading_quality_clamping() {
        let reading_high =
            SensorReading::new(SensorType::Temperature, 25.5, "°C".to_string()).with_quality(1.5);
        assert_eq!(reading_high.quality, 1.0);

        let reading_low =
            SensorReading::new(SensorType::Temperature, 25.5, "°C".to_string()).with_quality(-0.5);
        assert_eq!(reading_low.quality, 0.0);
    }

    #[test]
    fn test_sensor_reading_with_metadata() {
        let reading = SensorReading::new(SensorType::Temperature, 25.5, "°C".to_string())
            .with_metadata("location".to_string(), "room_1".to_string())
            .with_metadata("sensor_id".to_string(), "temp_001".to_string());

        assert_eq!(reading.metadata.len(), 2);
        assert_eq!(
            reading.metadata.get("location"),
            Some(&"room_1".to_string())
        );
        assert_eq!(
            reading.metadata.get("sensor_id"),
            Some(&"temp_001".to_string())
        );
    }

    #[test]
    fn test_sensor_types() {
        assert_eq!(SensorType::Temperature.default_unit(), "°C");
        assert_eq!(SensorType::Humidity.default_unit(), "%");
        assert_eq!(SensorType::Temperature.name(), "Temperature");
    }

    #[test]
    fn test_sensor_types_all_units() {
        assert_eq!(SensorType::Pressure.default_unit(), "hPa");
        assert_eq!(SensorType::Light.default_unit(), "lux");
        assert_eq!(SensorType::Motion.default_unit(), "bool");
        assert_eq!(SensorType::GPS.default_unit(), "deg");
        assert_eq!(SensorType::Accelerometer.default_unit(), "m/s²");
        assert_eq!(SensorType::Gyroscope.default_unit(), "rad/s");
        assert_eq!(SensorType::Magnetometer.default_unit(), "μT");
        assert_eq!(SensorType::Proximity.default_unit(), "cm");
        assert_eq!(SensorType::Sound.default_unit(), "dB");
        assert_eq!(SensorType::AirQuality.default_unit(), "PPM");
        assert_eq!(SensorType::Voltage.default_unit(), "V");
        assert_eq!(SensorType::Current.default_unit(), "A");
        assert_eq!(SensorType::Power.default_unit(), "W");
        assert_eq!(SensorType::Custom(42).default_unit(), "custom");
    }

    #[test]
    fn test_sensor_types_all_names() {
        assert_eq!(SensorType::Humidity.name(), "Humidity");
        assert_eq!(SensorType::Pressure.name(), "Pressure");
        assert_eq!(SensorType::Light.name(), "Light");
        assert_eq!(SensorType::Motion.name(), "Motion");
        assert_eq!(SensorType::GPS.name(), "GPS");
        assert_eq!(SensorType::Accelerometer.name(), "Accelerometer");
        assert_eq!(SensorType::Gyroscope.name(), "Gyroscope");
        assert_eq!(SensorType::Magnetometer.name(), "Magnetometer");
        assert_eq!(SensorType::Proximity.name(), "Proximity");
        assert_eq!(SensorType::Sound.name(), "Sound");
        assert_eq!(SensorType::AirQuality.name(), "Air Quality");
        assert_eq!(SensorType::Voltage.name(), "Voltage");
        assert_eq!(SensorType::Current.name(), "Current");
        assert_eq!(SensorType::Power.name(), "Power");
        assert_eq!(SensorType::Custom(42).name(), "Custom");
    }

    #[test]
    fn test_calibration() {
        let params = CalibrationParams {
            offset: 2.0,
            scale: 1.1,
            reference: Some(20.0),
            calibrated_at: 0,
        };
        assert_eq!(params.apply(10.0), 13.0); // (10 * 1.1) + 2.0
    }

    #[test]
    fn test_calibration_default() {
        let params = CalibrationParams::default();
        assert_eq!(params.offset, 0.0);
        assert_eq!(params.scale, 1.0);
        assert!(params.reference.is_none());
        assert_eq!(params.calibrated_at, 0);
        // Default calibration should not change values
        assert_eq!(params.apply(10.0), 10.0);
    }

    #[test]
    fn test_gps_coordinate() {
        let coord = GpsCoordinate {
            latitude: 40.7128,
            longitude: -74.0060,
            altitude: Some(10.0),
            accuracy: Some(5.0),
        };
        assert_eq!(coord.latitude, 40.7128);
        assert_eq!(coord.longitude, -74.0060);
        assert_eq!(coord.altitude, Some(10.0));
        assert_eq!(coord.accuracy, Some(5.0));
    }

    #[test]
    fn test_gps_coordinate_minimal() {
        let coord = GpsCoordinate {
            latitude: 51.5074,
            longitude: -0.1278,
            altitude: None,
            accuracy: None,
        };
        assert!(coord.altitude.is_none());
        assert!(coord.accuracy.is_none());
    }

    #[test]
    fn test_axis3d_magnitude() {
        let axis = Axis3D {
            x: 3.0,
            y: 4.0,
            z: 0.0,
        };
        assert_eq!(axis.magnitude(), 5.0);
    }

    #[test]
    fn test_axis3d_magnitude_3d() {
        let axis = Axis3D {
            x: 1.0,
            y: 2.0,
            z: 2.0,
        };
        assert_eq!(axis.magnitude(), 3.0); // sqrt(1 + 4 + 4) = 3
    }

    #[test]
    fn test_mock_sensor() {
        let sensor = MockSensor::new(SensorType::Temperature);
        let reading = sensor.read().unwrap();
        assert_eq!(reading.sensor_type, SensorType::Temperature);
        assert!(reading.value > 0.0);
    }

    #[test]
    fn test_mock_sensor_default_values() {
        // Temperature default: 20.0
        let temp = MockSensor::new(SensorType::Temperature);
        assert_eq!(temp.sensor_type(), SensorType::Temperature);

        // Humidity default: 50.0
        let humidity = MockSensor::new(SensorType::Humidity);
        assert_eq!(humidity.sensor_type(), SensorType::Humidity);

        // Pressure default: 1013.25
        let pressure = MockSensor::new(SensorType::Pressure);
        assert_eq!(pressure.sensor_type(), SensorType::Pressure);

        // Light default: 500.0
        let light = MockSensor::new(SensorType::Light);
        assert_eq!(light.sensor_type(), SensorType::Light);

        // Motion default: 0.0
        let motion = MockSensor::new(SensorType::Motion);
        assert_eq!(motion.sensor_type(), SensorType::Motion);

        // Other types default: 0.0
        let custom = MockSensor::new(SensorType::Custom(1));
        assert_eq!(custom.sensor_type(), SensorType::Custom(1));
    }

    #[test]
    fn test_mock_sensor_trait_methods() {
        let mut sensor = MockSensor::new(SensorType::Temperature);

        // name() should return sensor type name
        assert_eq!(sensor.name(), "Temperature");

        // is_available() should return true
        assert!(sensor.is_available());

        // sampling_rate() should return None
        assert!(sensor.sampling_rate().is_none());

        // reset() should succeed
        assert!(sensor.reset().is_ok());

        // get_calibration() should return default initially
        let cal = sensor.get_calibration();
        assert_eq!(cal.offset, 0.0);
        assert_eq!(cal.scale, 1.0);
    }

    #[test]
    fn test_mock_sensor_calibration() {
        let mut sensor = MockSensor::new(SensorType::Temperature);
        sensor.set_value(20.0);

        let params = CalibrationParams {
            offset: 5.0,
            scale: 1.0,
            reference: None,
            calibrated_at: 0,
        };

        sensor.calibrate(params).unwrap();
        let reading = sensor.read().unwrap();
        // Value should be around 25.0 (20.0 + 5.0 offset, plus small random variation)
        assert!(reading.value > 23.0 && reading.value < 27.0);
    }

    #[test]
    fn test_sensor_manager() {
        let mut manager = SensorManager::new();
        manager.register(Box::new(MockSensor::new(SensorType::Temperature)));
        manager.register(Box::new(MockSensor::new(SensorType::Humidity)));

        assert_eq!(manager.sensor_count(), 2);

        let readings = manager.read_all();
        assert_eq!(readings.len(), 2);

        let temp_readings = manager.read_by_type(SensorType::Temperature);
        assert_eq!(temp_readings.len(), 1);
    }

    #[test]
    fn test_sensor_manager_default() {
        let manager = SensorManager::default();
        assert_eq!(manager.sensor_count(), 0);
        assert!(manager.read_all().is_empty());
    }

    #[test]
    fn test_sensor_manager_available_sensors() {
        let mut manager = SensorManager::new();
        manager.register(Box::new(MockSensor::new(SensorType::Temperature)));
        manager.register(Box::new(MockSensor::new(SensorType::Humidity)));

        let available = manager.available_sensors();
        assert_eq!(available.len(), 2);
    }

    #[test]
    fn test_sensor_manager_read_by_type_no_match() {
        let mut manager = SensorManager::new();
        manager.register(Box::new(MockSensor::new(SensorType::Temperature)));

        let pressure_readings = manager.read_by_type(SensorType::Pressure);
        assert!(pressure_readings.is_empty());
    }

    #[test]
    fn test_sensor_stats() {
        let mut stats = SensorStats::new();
        stats.record_success();
        stats.record_success();
        stats.record_failure();

        assert_eq!(stats.total_readings, 2);
        assert_eq!(stats.failed_readings, 1);
        assert_eq!(stats.success_rate(), 0.5);
    }

    #[test]
    fn test_sensor_stats_empty() {
        let stats = SensorStats::new();
        assert_eq!(stats.total_readings, 0);
        assert_eq!(stats.failed_readings, 0);
        assert_eq!(stats.success_rate(), 0.0);
    }

    #[test]
    fn test_sensor_stats_all_success() {
        let mut stats = SensorStats::new();
        stats.record_success();
        stats.record_success();
        stats.record_success();

        assert_eq!(stats.total_readings, 3);
        assert_eq!(stats.failed_readings, 0);
        assert_eq!(stats.success_rate(), 1.0);
    }

    #[test]
    fn test_sensor_stats_last_reading_updated() {
        let mut stats = SensorStats::new();
        assert_eq!(stats.last_reading, 0);

        stats.record_success();
        assert!(stats.last_reading > 0);
    }

    // Tests for sensor adapters
    mod adapter_tests {
        use super::*;
        use crate::sensors::adapters::*;

        #[test]
        fn test_dht22_sensor() {
            let mut sensor = Dht22Sensor::new();
            assert_eq!(sensor.sensor_type(), SensorType::Temperature);

            // Read should succeed in simulated mode
            let reading = sensor.read().unwrap();
            assert_eq!(reading.sensor_type, SensorType::Temperature);
            assert!(reading.value > 0.0); // Simulated temp around 22°C

            // Test humidity reading
            let humidity = sensor.read_humidity().unwrap();
            assert_eq!(humidity.sensor_type, SensorType::Humidity);

            // Calibration should work
            let params = CalibrationParams {
                offset: 1.0,
                scale: 1.0,
                reference: None,
                calibrated_at: 0,
            };
            assert!(sensor.calibrate(params).is_ok());

            // Get calibration should return the set params
            let cal = sensor.get_calibration();
            assert_eq!(cal.offset, 1.0);

            // Test setting simulated values
            sensor.set_simulated_values(25.0, 60.0);
            let reading = sensor.read().unwrap();
            // Allow for random variation (±0.5 from set_simulated_values)
            assert!(reading.value > 23.5 && reading.value < 26.5);
        }

        #[test]
        fn test_dht22_default() {
            let sensor = Dht22Sensor::default();
            assert_eq!(sensor.sensor_type(), SensorType::Temperature);
        }

        #[test]
        fn test_bmp280_sensor() {
            let mut sensor = Bmp280Sensor::new();
            assert_eq!(sensor.sensor_type(), SensorType::Pressure);

            // Read should succeed in simulated mode
            let reading = sensor.read().unwrap();
            assert_eq!(reading.sensor_type, SensorType::Pressure);
            assert!(reading.value > 1000.0); // Around 1013.25 hPa

            // Test temperature reading
            let temp = sensor.read_temperature().unwrap();
            assert_eq!(temp.sensor_type, SensorType::Temperature);

            // Calibration should work
            let params = CalibrationParams {
                offset: 2.0,
                scale: 1.1,
                reference: None,
                calibrated_at: 0,
            };
            assert!(sensor.calibrate(params).is_ok());

            let cal = sensor.get_calibration();
            assert_eq!(cal.offset, 2.0);
            assert_eq!(cal.scale, 1.1);

            // Test I2C address
            assert_eq!(sensor.i2c_addr(), 0x76);
        }

        #[test]
        fn test_bmp280_default() {
            let sensor = Bmp280Sensor::default();
            assert_eq!(sensor.sensor_type(), SensorType::Pressure);
        }

        #[test]
        fn test_mpu6050_sensor() {
            let mut sensor = Mpu6050Sensor::new();
            assert_eq!(sensor.sensor_type(), SensorType::Accelerometer);

            // Read should succeed in simulated mode
            let reading = sensor.read().unwrap();
            assert_eq!(reading.sensor_type, SensorType::Accelerometer);
            // Default simulated value has z=1.0g (gravity)
            assert!(reading.value > 0.9 && reading.value < 1.1);

            // Test 3D accelerometer reading
            let accel = sensor.read_accel_3d().unwrap();
            assert!(accel.z > 0.9); // Gravity on Z axis

            // Test gyroscope reading
            let gyro = sensor.read_gyro().unwrap();
            assert_eq!(gyro.sensor_type, SensorType::Gyroscope);

            // Calibration should work
            let params = CalibrationParams {
                offset: 0.5,
                scale: 0.98,
                reference: Some(9.81),
                calibrated_at: 123456,
            };
            assert!(sensor.calibrate(params).is_ok());

            let cal = sensor.get_calibration();
            assert_eq!(cal.offset, 0.5);
            assert_eq!(cal.scale, 0.98);
            assert_eq!(cal.reference, Some(9.81));
            assert_eq!(cal.calibrated_at, 123456);

            // Test range configuration
            sensor.set_accel_range(AccelRange::G4);
            sensor.set_gyro_range(GyroRange::Dps500);
        }

        #[test]
        fn test_mpu6050_default() {
            let sensor = Mpu6050Sensor::default();
            assert_eq!(sensor.sensor_type(), SensorType::Accelerometer);
        }
    }

    // Serialization tests
    #[test]
    fn test_sensor_reading_serialize() {
        let reading = SensorReading::new(SensorType::Temperature, 25.5, "°C".to_string());
        let json = serde_json::to_string(&reading).unwrap();
        let parsed: SensorReading = serde_json::from_str(&json).unwrap();
        assert_eq!(parsed.value, 25.5);
        assert_eq!(parsed.sensor_type, SensorType::Temperature);
    }

    #[test]
    fn test_sensor_type_serialize() {
        for sensor_type in [
            SensorType::Temperature,
            SensorType::Humidity,
            SensorType::Custom(42),
        ] {
            let json = serde_json::to_string(&sensor_type).unwrap();
            let parsed: SensorType = serde_json::from_str(&json).unwrap();
            assert_eq!(parsed, sensor_type);
        }
    }

    #[test]
    fn test_calibration_params_serialize() {
        let params = CalibrationParams {
            offset: 1.5,
            scale: 0.99,
            reference: Some(20.0),
            calibrated_at: 1234567890,
        };
        let json = serde_json::to_string(&params).unwrap();
        let parsed: CalibrationParams = serde_json::from_str(&json).unwrap();
        assert_eq!(parsed.offset, 1.5);
        assert_eq!(parsed.scale, 0.99);
        assert_eq!(parsed.reference, Some(20.0));
    }

    #[test]
    fn test_gps_coordinate_serialize() {
        let coord = GpsCoordinate {
            latitude: 40.7128,
            longitude: -74.0060,
            altitude: Some(10.0),
            accuracy: None,
        };
        let json = serde_json::to_string(&coord).unwrap();
        let parsed: GpsCoordinate = serde_json::from_str(&json).unwrap();
        assert_eq!(parsed.latitude, 40.7128);
        assert_eq!(parsed.longitude, -74.0060);
    }

    #[test]
    fn test_axis3d_serialize() {
        let axis = Axis3D {
            x: 1.0,
            y: 2.0,
            z: 3.0,
        };
        let json = serde_json::to_string(&axis).unwrap();
        let parsed: Axis3D = serde_json::from_str(&json).unwrap();
        assert_eq!(parsed.x, 1.0);
        assert_eq!(parsed.y, 2.0);
        assert_eq!(parsed.z, 3.0);
    }

    #[test]
    fn test_sensor_stats_serialize() {
        let mut stats = SensorStats::new();
        stats.record_success();
        stats.record_failure();

        let json = serde_json::to_string(&stats).unwrap();
        let parsed: SensorStats = serde_json::from_str(&json).unwrap();
        assert_eq!(parsed.total_readings, 1);
        assert_eq!(parsed.failed_readings, 1);
    }
}