cranpose_render_wgpu/

lib.rs

//! WGPU renderer backend for GPU-accelerated 2D rendering.
//!
//! This renderer uses WGPU for cross-platform GPU support across
//! desktop (Windows/Mac/Linux), web (WebGPU), and mobile (Android/iOS).

mod effect_renderer;
pub(crate) mod gpu_stats;
mod normalized_scene;
mod offscreen;
mod pipeline;
mod render;
mod scene;
mod shader_cache;
mod shaders;
mod surface_executor;
mod surface_plan;
mod surface_requirements;
#[cfg(test)]
mod test_support;

pub use gpu_stats::FrameStatsSnapshot as RenderStatsSnapshot;
pub use scene::{ClickAction, HitRegion, Scene};

use cranpose_core::{MemoryApplier, NodeId};
use cranpose_render_common::{
    graph::{
        CachePolicy, DrawPrimitiveNode, IsolationReasons, LayerNode, PrimitiveEntry, PrimitiveNode,
        PrimitivePhase, ProjectiveTransform, RenderGraph, RenderNode, TextPrimitiveNode,
    },
    raster_cache::LayerRasterCacheHashes,
    text_hyphenation::choose_auto_hyphen_break as choose_shared_auto_hyphen_break,
    RenderScene, Renderer,
};
use cranpose_ui::{set_text_measurer, LayoutTree, TextMeasurer};
use cranpose_ui_graphics::{
    Brush, Color, CornerRadii, DrawPrimitive, GraphicsLayer, Point, Rect, RenderHash, Size,
};
use glyphon::{
    Attrs, AttrsOwned, Buffer, FamilyOwned, FontSystem, Metrics, Shaping, Style as GlyphonStyle,
    Weight as GlyphonWeight,
};
use lru::LruCache;
use render::GpuRenderer;
use rustc_hash::FxHasher;
use std::cell::RefCell;
use std::collections::{HashMap, HashSet};
use std::hash::{Hash, Hasher};
use std::num::NonZeroUsize;
use std::rc::Rc;
use std::sync::atomic::{AtomicU64, Ordering};
use std::sync::{Arc, Mutex, OnceLock};

/// Convert an axis-aligned rectangle to four corner positions (TL, TR, BL, BR).
pub(crate) fn rect_to_quad(rect: Rect) -> [[f32; 2]; 4] {
    [
        [rect.x, rect.y],
        [rect.x + rect.width, rect.y],
        [rect.x, rect.y + rect.height],
        [rect.x + rect.width, rect.y + rect.height],
    ]
}

/// Size-only cache for ultra-fast text measurement lookups.
/// Key: (text_hash, font_size_fixed_point, style_hash)
/// Value: (text_content, size) - text stored to handle hash collisions
type TextSizeCache = Arc<Mutex<LruCache<(u64, i32, u64), (String, Size)>>>;
type PreparedTextLayoutCache = Rc<
    RefCell<LruCache<PreparedTextLayoutCacheKey, (String, cranpose_ui::text::PreparedTextLayout)>>,
>;

#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
struct PreparedTextLayoutCacheKey {
    text_hash: u64,
    size_int: i32,
    style_hash: u64,
    options: cranpose_ui::text::TextLayoutOptions,
    max_width_bits: Option<u32>,
}

static TEXT_MEASURE_TELEMETRY_ENABLED: OnceLock<bool> = OnceLock::new();
static TEXT_MEASURE_TELEMETRY: OnceLock<TextMeasureTelemetry> = OnceLock::new();

#[derive(Default)]
struct TextMeasureTelemetry {
    measure_calls: AtomicU64,
    layout_calls: AtomicU64,
    offset_calls: AtomicU64,
    measure_with_options_calls: AtomicU64,
    prepare_with_options_calls: AtomicU64,
    measure_fast_path_hits: AtomicU64,
    measure_fast_path_misses: AtomicU64,
    prepare_fast_path_hits: AtomicU64,
    prepare_fast_path_misses: AtomicU64,
    prepared_layout_cache_hits: AtomicU64,
    prepared_layout_cache_misses: AtomicU64,
    size_cache_hits: AtomicU64,
    size_cache_misses: AtomicU64,
    text_cache_hits: AtomicU64,
    text_cache_misses: AtomicU64,
    text_cache_evictions: AtomicU64,
    text_cache_occupancy: AtomicU64,
    ensure_reshapes: AtomicU64,
    ensure_reuses: AtomicU64,
}

fn text_measure_telemetry_enabled() -> bool {
    *TEXT_MEASURE_TELEMETRY_ENABLED
        .get_or_init(|| std::env::var_os("CRANPOSE_TEXT_MEASURE_TELEMETRY").is_some())
}

fn text_measure_telemetry() -> &'static TextMeasureTelemetry {
    TEXT_MEASURE_TELEMETRY.get_or_init(TextMeasureTelemetry::default)
}

fn maybe_report_text_measure_telemetry(sequence: u64) {
    if !text_measure_telemetry_enabled() || !sequence.is_multiple_of(200) {
        return;
    }
    let telemetry = text_measure_telemetry();
    let measure_calls = telemetry.measure_calls.load(Ordering::Relaxed);
    let layout_calls = telemetry.layout_calls.load(Ordering::Relaxed);
    let offset_calls = telemetry.offset_calls.load(Ordering::Relaxed);
    let measure_with_options_calls = telemetry.measure_with_options_calls.load(Ordering::Relaxed);
    let prepare_with_options_calls = telemetry.prepare_with_options_calls.load(Ordering::Relaxed);
    let measure_fast_path_hits = telemetry.measure_fast_path_hits.load(Ordering::Relaxed);
    let measure_fast_path_misses = telemetry.measure_fast_path_misses.load(Ordering::Relaxed);
    let prepare_fast_path_hits = telemetry.prepare_fast_path_hits.load(Ordering::Relaxed);
    let prepare_fast_path_misses = telemetry.prepare_fast_path_misses.load(Ordering::Relaxed);
    let prepared_layout_cache_hits = telemetry.prepared_layout_cache_hits.load(Ordering::Relaxed);
    let prepared_layout_cache_misses = telemetry
        .prepared_layout_cache_misses
        .load(Ordering::Relaxed);
    let size_hits = telemetry.size_cache_hits.load(Ordering::Relaxed);
    let size_misses = telemetry.size_cache_misses.load(Ordering::Relaxed);
    let text_hits = telemetry.text_cache_hits.load(Ordering::Relaxed);
    let text_misses = telemetry.text_cache_misses.load(Ordering::Relaxed);
    let text_cache_evictions = telemetry.text_cache_evictions.load(Ordering::Relaxed);
    let text_cache_occupancy = telemetry.text_cache_occupancy.load(Ordering::Relaxed);
    let reshapes = telemetry.ensure_reshapes.load(Ordering::Relaxed);
    let reuses = telemetry.ensure_reuses.load(Ordering::Relaxed);

    let size_total = size_hits + size_misses;
    let text_total = text_hits + text_misses;
    let ensure_total = reshapes + reuses;
    let size_hit_rate = if size_total > 0 {
        (size_hits as f64 / size_total as f64) * 100.0
    } else {
        0.0
    };
    let text_hit_rate = if text_total > 0 {
        (text_hits as f64 / text_total as f64) * 100.0
    } else {
        0.0
    };
    let measure_fast_path_total = measure_fast_path_hits + measure_fast_path_misses;
    let measure_fast_path_rate = if measure_fast_path_total > 0 {
        (measure_fast_path_hits as f64 / measure_fast_path_total as f64) * 100.0
    } else {
        0.0
    };
    let prepare_fast_path_total = prepare_fast_path_hits + prepare_fast_path_misses;
    let prepare_fast_path_rate = if prepare_fast_path_total > 0 {
        (prepare_fast_path_hits as f64 / prepare_fast_path_total as f64) * 100.0
    } else {
        0.0
    };
    let prepared_layout_cache_total = prepared_layout_cache_hits + prepared_layout_cache_misses;
    let prepared_layout_cache_hit_rate = if prepared_layout_cache_total > 0 {
        (prepared_layout_cache_hits as f64 / prepared_layout_cache_total as f64) * 100.0
    } else {
        0.0
    };
    let reshape_rate = if ensure_total > 0 {
        (reshapes as f64 / ensure_total as f64) * 100.0
    } else {
        0.0
    };

    log::warn!(
        "[text-measure-telemetry] measure_calls={} layout_calls={} offset_calls={} measure_with_options_calls={} prepare_with_options_calls={} measure_fast_path_rate={:.1}% prepare_fast_path_rate={:.1}% prepared_layout_cache_hit_rate={:.1}% size_hit_rate={:.1}% text_cache_hit_rate={:.1}% text_cache_occupancy={} text_cache_evictions={} reshape_rate={:.1}% reshapes={} reuses={}",
        measure_calls,
        layout_calls,
        offset_calls,
        measure_with_options_calls,
        prepare_with_options_calls,
        measure_fast_path_rate,
        prepare_fast_path_rate,
        prepared_layout_cache_hit_rate,
        size_hit_rate,
        text_hit_rate,
        text_cache_occupancy,
        text_cache_evictions,
        reshape_rate,
        reshapes,
        reuses
    );
}

#[derive(Debug)]
pub enum WgpuRendererError {
    Layout(String),
    Wgpu(String),
}

/// CPU-readable RGBA frame captured from the renderer output.
#[derive(Debug, Clone)]
pub struct CapturedFrame {
    pub width: u32,
    pub height: u32,
    pub pixels: Vec<u8>,
}

#[doc(hidden)]
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq)]
pub struct DebugCpuAllocationStats {
    pub scene_graph_node_count: usize,
    pub scene_graph_heap_bytes: usize,
    pub scene_hits_len: usize,
    pub scene_hits_cap: usize,
    pub scene_node_index_len: usize,
    pub scene_node_index_cap: usize,
    pub text_renderer_pool_len: usize,
    pub text_renderer_pool_cap: usize,
    pub swash_image_cache_len: usize,
    pub swash_image_cache_cap: usize,
    pub swash_outline_cache_len: usize,
    pub swash_outline_cache_cap: usize,
    pub image_texture_cache_len: usize,
    pub image_texture_cache_cap: usize,
    pub scratch_shape_data_cap: usize,
    pub scratch_gradients_cap: usize,
    pub scratch_vertices_cap: usize,
    pub scratch_indices_cap: usize,
    pub scratch_image_vertices_cap: usize,
    pub scratch_image_indices_cap: usize,
    pub scratch_image_cmds_cap: usize,
    pub scratch_segment_items_cap: usize,
    pub scratch_effect_ranges_cap: usize,
    pub scratch_layer_events_cap: usize,
    pub staged_upload_bytes_cap: usize,
    pub staged_upload_copies_cap: usize,
    pub layer_surface_cache_len: usize,
    pub layer_surface_cache_cap: usize,
    pub layer_surface_cache_identity_len: usize,
    pub layer_surface_cache_identity_cap: usize,
    pub layer_surface_rect_cache_len: usize,
    pub layer_surface_rect_cache_cap: usize,
    pub layer_surface_requirements_cache_len: usize,
    pub layer_surface_requirements_cache_cap: usize,
    pub layer_cache_seen_this_frame_len: usize,
    pub layer_cache_seen_this_frame_cap: usize,
}

/// Unified hash key for text caching - shared between measurement and rendering.
#[derive(Clone, PartialEq, Eq, Hash)]
pub(crate) enum TextKey {
    Content(String),
    Node(NodeId),
}

#[derive(Clone, PartialEq, Eq)]
pub(crate) struct TextCacheKey {
    key: TextKey,
    scale_bits: u32, // f32 as bits for hashing
    style_hash: u64,
}

impl TextCacheKey {
    fn new(text: &str, font_size: f32, style_hash: u64) -> Self {
        Self {
            key: TextKey::Content(text.to_string()),
            scale_bits: font_size.to_bits(),
            style_hash,
        }
    }

    fn for_node(node_id: NodeId, font_size: f32, style_hash: u64) -> Self {
        Self {
            key: TextKey::Node(node_id),
            scale_bits: font_size.to_bits(),
            style_hash,
        }
    }
}

impl Hash for TextCacheKey {
    fn hash<H: Hasher>(&self, state: &mut H) {
        self.key.hash(state);
        self.scale_bits.hash(state);
        self.style_hash.hash(state);
    }
}

/// Cached text buffer shared between measurement and rendering
pub(crate) struct SharedTextBuffer {
    pub(crate) buffer: Buffer,
    text: String,
    font_size: f32,
    line_height: f32,
    style_hash: u64,
    /// Cached size to avoid recalculating on every access
    cached_size: Option<Size>,
}

pub(crate) struct EnsureTextBufferParams<'a> {
    pub(crate) annotated_text: &'a cranpose_ui::text::AnnotatedString,
    pub(crate) font_size_px: f32,
    pub(crate) line_height_px: f32,
    pub(crate) style_hash: u64,
    pub(crate) style: &'a cranpose_ui::text::TextStyle,
    pub(crate) scale: f32,
}

fn requires_advanced_shaping(text: &str) -> bool {
    text.chars().any(requires_advanced_shaping_char)
}

fn requires_advanced_shaping_char(ch: char) -> bool {
    let code = ch as u32;
    if ch.is_ascii() || ch.is_whitespace() {
        return false;
    }

    matches!(
        code,
        0x0300..=0x036F
            | 0x0590..=0x08FF
            | 0x0900..=0x109F
            | 0x135D..=0x135F
            | 0x1712..=0x1715
            | 0x1732..=0x1735
            | 0x1752..=0x1753
            | 0x1772..=0x1773
            | 0x17B4..=0x17D3
            | 0x1885..=0x18A9
            | 0x1A17..=0x1A1B
            | 0x1AB0..=0x1AFF
            | 0x1B00..=0x1CFF
            | 0x1CD0..=0x1DFF
            | 0x200C..=0x200F
            | 0x202A..=0x202E
            | 0x2066..=0x2069
            | 0x20D0..=0x20FF
            | 0x2DE0..=0x2DFF
            | 0x2E80..=0xA7FF
            | 0xA980..=0xABFF
            | 0xD800..=0xF8FF
            | 0xFB1D..=0xFEFF
            | 0x1F000..=u32::MAX
    )
}

fn select_text_shaping(
    annotated_text: &cranpose_ui::text::AnnotatedString,
    style: &cranpose_ui::text::TextStyle,
) -> Shaping {
    let requested = style
        .paragraph_style
        .platform_style
        .and_then(|platform| platform.shaping);

    match requested {
        Some(cranpose_ui::text::TextShaping::Basic)
            if !requires_advanced_shaping(annotated_text.text.as_str()) =>
        {
            Shaping::Basic
        }
        _ => Shaping::Advanced,
    }
}

fn glyph_foreground_color(
    span_style: &cranpose_ui::text::SpanStyle,
) -> Option<cranpose_ui_graphics::Color> {
    let has_solid_foreground = span_style.color.is_some()
        || matches!(
            span_style.brush.as_ref(),
            Some(cranpose_ui::Brush::Solid(_))
        );
    has_solid_foreground
        .then(|| span_style.resolve_foreground_color(cranpose_ui_graphics::Color::WHITE))
}

fn hash_optional_glyph_foreground_color<H: Hasher>(
    span_style: &cranpose_ui::text::SpanStyle,
    state: &mut H,
) {
    match glyph_foreground_color(span_style) {
        Some(color) => {
            1u8.hash(state);
            color.render_hash().hash(state);
        }
        None => 0u8.hash(state),
    }
}

fn text_span_buffer_hash(text: &cranpose_ui::text::AnnotatedString) -> u64 {
    let mut hasher = FxHasher::default();
    text.span_styles.len().hash(&mut hasher);
    for span in &text.span_styles {
        span.range.start.hash(&mut hasher);
        span.range.end.hash(&mut hasher);
        let span_style = cranpose_ui::text::TextStyle {
            span_style: span.item.clone(),
            ..Default::default()
        };
        span_style.measurement_hash().hash(&mut hasher);
        hash_optional_glyph_foreground_color(&span.item, &mut hasher);
    }
    hasher.finish()
}

fn text_buffer_style_hash(
    style: &cranpose_ui::text::TextStyle,
    text: &cranpose_ui::text::AnnotatedString,
) -> u64 {
    let mut hasher = FxHasher::default();
    style.measurement_hash().hash(&mut hasher);
    hash_optional_glyph_foreground_color(&style.span_style, &mut hasher);
    text_span_buffer_hash(text).hash(&mut hasher);
    hasher.finish()
}

impl SharedTextBuffer {
    /// Ensure the buffer has the correct text and font_size, only reshaping if needed
    pub(crate) fn ensure(
        &mut self,
        font_system: &mut FontSystem,
        font_family_resolver: &mut WgpuFontFamilyResolver,
        params: EnsureTextBufferParams<'_>,
    ) -> bool {
        let annotated_text = params.annotated_text;
        let font_size_px = params.font_size_px;
        let line_height_px = params.line_height_px;
        let style_hash = params.style_hash;
        let style = params.style;
        let scale = params.scale;
        let text_str = annotated_text.text.as_str();
        let text_changed = self.text != text_str;
        let font_changed = (self.font_size - font_size_px).abs() > 0.1;
        let line_height_changed = (self.line_height - line_height_px).abs() > 0.1;
        let style_changed = self.style_hash != style_hash;

        // Only reshape if something actually changed
        if !text_changed && !font_changed && !line_height_changed && !style_changed {
            return false;
        }

        // Set metrics and size for unlimited layout
        let metrics = Metrics::new(font_size_px, line_height_px);
        self.buffer.set_metrics(font_system, metrics);
        self.buffer
            .set_size(font_system, Some(f32::MAX), Some(f32::MAX));

        let unscaled_base_size = if scale > 0.0 {
            font_size_px / scale
        } else {
            14.0
        };
        let shaping = select_text_shaping(annotated_text, style);

        // Set text and shape
        if annotated_text.span_styles.is_empty() {
            let attrs = attrs_from_text_style(
                style,
                unscaled_base_size,
                scale,
                font_system,
                font_family_resolver,
            );
            let attrs_ref = attrs.as_attrs();
            self.buffer
                .set_text(font_system, text_str, &attrs_ref, shaping, None);
        } else {
            let boundaries = annotated_text.span_boundaries();
            let mut rich_spans: Vec<(usize, usize, AttrsOwned)> =
                Vec::with_capacity(boundaries.len().saturating_sub(1));
            let mut chunk_text_style = style.clone();
            for window in boundaries.windows(2) {
                let start = window[0];
                let end = window[1];
                if start == end {
                    continue;
                }
                let mut merged_style = style.span_style.clone();
                for span in &annotated_text.span_styles {
                    if span.range.start <= start && span.range.end >= end {
                        merged_style = merged_style.merge(&span.item);
                    }
                }
                chunk_text_style.span_style = merged_style;
                let attrs = attrs_from_text_style(
                    &chunk_text_style,
                    unscaled_base_size,
                    scale,
                    font_system,
                    font_family_resolver,
                );
                if let Some((_, previous_end, previous_attrs)) = rich_spans.last_mut() {
                    if *previous_end == start && *previous_attrs == attrs {
                        *previous_end = end;
                        continue;
                    }
                }
                rich_spans.push((start, end, attrs));
            }
            let default_attrs = attrs_from_text_style(
                style,
                unscaled_base_size,
                scale,
                font_system,
                font_family_resolver,
            );
            let default_attrs_ref = default_attrs.as_attrs();
            self.buffer.set_rich_text(
                font_system,
                rich_spans.iter().map(|(start, end, attrs)| {
                    (&annotated_text.text[*start..*end], attrs.as_attrs())
                }),
                &default_attrs_ref,
                shaping,
                None,
            );
        }
        self.buffer.shape_until_scroll(font_system, false);

        // Update cached values
        self.text.clear();
        self.text.push_str(text_str);
        self.font_size = font_size_px;
        self.line_height = line_height_px;
        self.style_hash = style_hash;
        self.cached_size = None; // Invalidate size cache
        true
    }

    /// Get or calculate the size of the shaped text
    pub(crate) fn size(&mut self) -> Size {
        if let Some(size) = self.cached_size {
            return size;
        }

        // Calculate size from buffer
        let mut max_width = 0.0f32;
        let mut total_height = 0.0f32;
        for run in self.buffer.layout_runs() {
            let mut run_height = run.line_height;
            for glyph in run.glyphs {
                let physical_height = glyph.font_size * 1.4; // 1.4 is our default line_height modifier
                if physical_height > run_height {
                    run_height = physical_height;
                }
            }

            max_width = max_width.max(run.line_w);
            total_height = total_height.max(run.line_top + run_height);
        }

        let size = Size {
            width: max_width,
            height: total_height,
        };

        self.cached_size = Some(size);
        size
    }
}

#[derive(Clone, Debug, PartialEq, Eq, Hash)]
struct TypefaceRequest {
    font_family: Option<cranpose_ui::text::FontFamily>,
    font_weight: cranpose_ui::text::FontWeight,
    font_style: cranpose_ui::text::FontStyle,
    font_synthesis: cranpose_ui::text::FontSynthesis,
}

impl TypefaceRequest {
    fn from_span_style(span_style: &cranpose_ui::text::SpanStyle) -> Self {
        Self {
            font_family: span_style.font_family.clone(),
            font_weight: span_style.font_weight.unwrap_or_default(),
            font_style: span_style.font_style.unwrap_or_default(),
            font_synthesis: span_style.font_synthesis.unwrap_or_default(),
        }
    }
}

#[derive(Default)]
struct WgpuFontFamilyResolver {
    request_cache: HashMap<TypefaceRequest, FamilyOwned>,
    loaded_typeface_paths: HashMap<String, String>,
    unavailable_typeface_paths: HashSet<String>,
    available_family_names: HashMap<String, String>,
    preferred_generic_family: Option<String>,
    indexed_face_count: usize,
    generic_fallback_seeded: bool,
}

impl WgpuFontFamilyResolver {
    fn prime(&mut self, font_system: &mut FontSystem) {
        self.ensure_non_empty_font_db(font_system);
        self.ensure_family_index(font_system);
        self.ensure_generic_fallbacks(font_system);
    }

    fn clear_resolution_caches(&mut self) {
        self.request_cache.clear();
    }

    fn set_preferred_generic_family(&mut self, family_name: Option<String>) {
        self.preferred_generic_family = family_name;
        self.generic_fallback_seeded = false;
        self.clear_resolution_caches();
    }

    fn resolve_family_owned(
        &mut self,
        font_system: &mut FontSystem,
        span_style: &cranpose_ui::text::SpanStyle,
    ) -> FamilyOwned {
        self.ensure_non_empty_font_db(font_system);
        self.ensure_family_index(font_system);
        self.ensure_generic_fallbacks(font_system);

        let request = TypefaceRequest::from_span_style(span_style);
        if let Some(cached) = self.request_cache.get(&request) {
            return cached.clone();
        }

        let resolved = self.resolve_family_owned_uncached(font_system, &request);
        self.request_cache.insert(request, resolved.clone());
        resolved
    }

    fn ensure_non_empty_font_db(&mut self, font_system: &mut FontSystem) {
        if font_system.db().faces().next().is_none() {
            log::warn!("Font database is empty; text will not render. Provide fonts via AppLauncher::with_fonts.");
        }
    }

    fn resolve_family_owned_uncached(
        &mut self,
        font_system: &mut FontSystem,
        request: &TypefaceRequest,
    ) -> FamilyOwned {
        use cranpose_ui::text::FontFamily;

        match request.font_family.as_ref() {
            None | Some(FontFamily::Default | FontFamily::SansSerif) => FamilyOwned::SansSerif,
            Some(FontFamily::Serif) => FamilyOwned::Serif,
            Some(FontFamily::Monospace) => FamilyOwned::Monospace,
            Some(FontFamily::Cursive) => FamilyOwned::Cursive,
            Some(FontFamily::Fantasy) => FamilyOwned::Fantasy,
            Some(FontFamily::Named(name)) => self
                .canonical_family_name(name)
                .map(|resolved| FamilyOwned::Name(resolved.into()))
                .unwrap_or(FamilyOwned::SansSerif),
            Some(FontFamily::FileBacked(file_backed)) => self
                .resolve_file_backed_family(font_system, file_backed, request)
                .unwrap_or(FamilyOwned::SansSerif),
            Some(FontFamily::LoadedTypeface(typeface_path)) => self
                .resolve_loaded_typeface_family(font_system, typeface_path.path.as_str())
                .unwrap_or(FamilyOwned::SansSerif),
        }
    }

    fn resolve_file_backed_family(
        &mut self,
        font_system: &mut FontSystem,
        file_backed: &cranpose_ui::text::FileBackedFontFamily,
        request: &TypefaceRequest,
    ) -> Option<FamilyOwned> {
        let mut candidates: Vec<&cranpose_ui::text::FontFile> = file_backed.fonts.iter().collect();
        candidates.sort_by_key(|candidate| {
            let style_penalty = if candidate.style == request.font_style {
                0u32
            } else {
                10_000u32
            };
            let weight_penalty =
                (i32::from(candidate.weight.0) - i32::from(request.font_weight.0)).unsigned_abs();
            style_penalty + weight_penalty
        });

        for candidate in candidates {
            let Some(family_name) = self.load_typeface_path(font_system, candidate.path.as_str())
            else {
                continue;
            };
            if let Some(canonical) = self.canonical_family_name(family_name.as_str()) {
                return Some(FamilyOwned::Name(canonical.into()));
            }
        }
        None
    }

    fn resolve_loaded_typeface_family(
        &mut self,
        font_system: &mut FontSystem,
        path: &str,
    ) -> Option<FamilyOwned> {
        self.load_typeface_path(font_system, path)
            .map(|family_name| {
                self.canonical_family_name(family_name.as_str())
                    .map(|resolved| FamilyOwned::Name(resolved.into()))
                    .unwrap_or(FamilyOwned::SansSerif)
            })
    }

    fn ensure_family_index(&mut self, font_system: &FontSystem) {
        let face_count = font_system.db().faces().count();
        if face_count == self.indexed_face_count {
            return;
        }

        self.available_family_names.clear();
        for face in font_system.db().faces() {
            for (family_name, _) in &face.families {
                self.available_family_names
                    .entry(family_name.to_lowercase())
                    .or_insert_with(|| family_name.clone());
            }
        }
        self.indexed_face_count = face_count;
        self.clear_resolution_caches();
        self.generic_fallback_seeded = false;
    }

    fn canonical_family_name(&self, family_name: &str) -> Option<String> {
        self.available_family_names
            .get(&family_name.to_lowercase())
            .cloned()
    }

    fn ensure_generic_fallbacks(&mut self, font_system: &mut FontSystem) {
        if self.generic_fallback_seeded {
            return;
        }

        let primary_family = self
            .preferred_generic_family
            .as_deref()
            .and_then(|name| self.canonical_family_name(name))
            .or_else(|| {
                font_system
                    .db()
                    .faces()
                    .find_map(|face| face.families.first().map(|(name, _)| name.clone()))
            });

        let Some(primary_family) = primary_family else {
            return;
        };

        let db = font_system.db_mut();
        db.set_sans_serif_family(primary_family.clone());
        db.set_serif_family(primary_family.clone());
        db.set_monospace_family(primary_family.clone());
        db.set_cursive_family(primary_family.clone());
        db.set_fantasy_family(primary_family);

        self.generic_fallback_seeded = true;
        self.clear_resolution_caches();
    }

    fn load_typeface_path(&mut self, font_system: &mut FontSystem, path: &str) -> Option<String> {
        if let Some(family_name) = self.loaded_typeface_paths.get(path) {
            return Some(family_name.clone());
        }

        if self.unavailable_typeface_paths.contains(path) {
            return None;
        }

        #[cfg(target_arch = "wasm32")]
        let _ = font_system;

        #[cfg(target_arch = "wasm32")]
        {
            log::warn!(
                "Typeface path '{}' requested on wasm target; filesystem font loading is unavailable",
                path
            );
            self.unavailable_typeface_paths.insert(path.to_string());
            return None;
        }

        #[cfg(not(target_arch = "wasm32"))]
        {
            let font_bytes = match std::fs::read(path) {
                Ok(bytes) => bytes,
                Err(error) => {
                    log::warn!("Failed to read typeface path '{}': {}", path, error);
                    self.unavailable_typeface_paths.insert(path.to_string());
                    return None;
                }
            };
            let preferred_family = primary_family_name_from_bytes(font_bytes.as_slice());
            let previous_face_count = font_system.db().faces().count();
            font_system.db_mut().load_font_data(font_bytes);

            self.ensure_family_index(font_system);

            let mut resolved_family =
                preferred_family.and_then(|name| self.canonical_family_name(name.as_str()));
            if resolved_family.is_none() && self.indexed_face_count > previous_face_count {
                resolved_family = font_system
                    .db()
                    .faces()
                    .skip(previous_face_count)
                    .find_map(|face| face.families.first().map(|(name, _)| name.clone()));
            }

            let Some(family_name) = resolved_family else {
                log::warn!(
                    "Typeface path '{}' loaded but no usable family name was resolved",
                    path
                );
                self.unavailable_typeface_paths.insert(path.to_string());
                return None;
            };
            let family_name = self
                .canonical_family_name(family_name.as_str())
                .unwrap_or(family_name);

            self.loaded_typeface_paths
                .insert(path.to_string(), family_name.clone());
            self.unavailable_typeface_paths.remove(path);
            Some(family_name)
        }
    }
}

fn load_fonts(font_system: &mut FontSystem, fonts: &[&[u8]]) -> Vec<String> {
    let mut loaded_families = Vec::new();
    for (i, font_data) in fonts.iter().enumerate() {
        log::info!("Loading font #{}, size: {} bytes", i, font_data.len());
        if let Some(family_name) = primary_family_name_from_bytes(font_data) {
            loaded_families.push(family_name);
        }
        font_system.db_mut().load_font_data(font_data.to_vec());
    }
    log::info!(
        "Total font faces loaded: {}",
        font_system.db().faces().count()
    );
    loaded_families
}

fn primary_family_name_from_bytes(bytes: &[u8]) -> Option<String> {
    let face = ttf_parser::Face::parse(bytes, 0).ok()?;
    let mut fallback_family = None;
    for name in face.names() {
        if name.name_id == ttf_parser::name_id::TYPOGRAPHIC_FAMILY {
            let resolved = name.to_string().filter(|value| !value.is_empty());
            if resolved.is_some() {
                return resolved;
            }
        }
        if fallback_family.is_none() && name.name_id == ttf_parser::name_id::FAMILY {
            fallback_family = name.to_string().filter(|value| !value.is_empty());
        }
    }
    fallback_family
}

const SHARED_TEXT_CACHE_CAPACITY: usize = 256;

fn new_shared_text_buffer(
    font_system: &mut FontSystem,
    font_size: f32,
    line_height: f32,
) -> SharedTextBuffer {
    let buffer = Buffer::new(font_system, Metrics::new(font_size, line_height));
    SharedTextBuffer {
        buffer,
        text: String::new(),
        font_size: 0.0,
        line_height: 0.0,
        style_hash: 0,
        cached_size: None,
    }
}

fn new_text_cache() -> LruCache<TextCacheKey, SharedTextBuffer> {
    LruCache::new(NonZeroUsize::new(SHARED_TEXT_CACHE_CAPACITY).unwrap())
}

pub(crate) fn shared_text_buffer_mut<'a>(
    cache: &'a mut LruCache<TextCacheKey, SharedTextBuffer>,
    key: TextCacheKey,
    font_system: &mut FontSystem,
    font_size: f32,
    line_height: f32,
) -> (bool, bool, usize, &'a mut SharedTextBuffer) {
    if cache.contains(&key) {
        let len = cache.len();
        let buffer = cache.get_mut(&key).expect("text cache hit must exist");
        return (true, false, len, buffer);
    }

    let evicted = cache
        .push(
            key.clone(),
            new_shared_text_buffer(font_system, font_size, line_height),
        )
        .is_some();
    let len = cache.len();
    let buffer = cache
        .get_mut(&key)
        .expect("inserted text cache entry must exist");
    (false, evicted, len, buffer)
}

pub(crate) struct TextSystemState {
    pub(crate) font_system: FontSystem,
    pub(crate) font_family_resolver: WgpuFontFamilyResolver,
    pub(crate) text_cache: LruCache<TextCacheKey, SharedTextBuffer>,
}

impl TextSystemState {
    fn from_fonts(fonts: &[&[u8]]) -> Self {
        let mut font_system = FontSystem::new();

        // On Android never load system fonts: modern Android ships variable Roboto
        // which can cause rasterization corruption or font-ID conflicts with glyphon.
        #[cfg(target_os = "android")]
        log::info!("Skipping Android system fonts – using application-provided fonts only");

        let loaded_families = load_fonts(&mut font_system, fonts);

        let mut font_family_resolver = WgpuFontFamilyResolver::default();
        font_family_resolver.set_preferred_generic_family(loaded_families.into_iter().next());
        font_family_resolver.prime(&mut font_system);
        Self::from_parts(font_system, font_family_resolver)
    }

    fn from_parts(font_system: FontSystem, font_family_resolver: WgpuFontFamilyResolver) -> Self {
        Self {
            font_system,
            font_family_resolver,
            text_cache: new_text_cache(),
        }
    }

    pub(crate) fn parts_mut(
        &mut self,
    ) -> (
        &mut FontSystem,
        &mut WgpuFontFamilyResolver,
        &mut LruCache<TextCacheKey, SharedTextBuffer>,
    ) {
        (
            &mut self.font_system,
            &mut self.font_family_resolver,
            &mut self.text_cache,
        )
    }
}

type SharedTextSystemState = Arc<Mutex<TextSystemState>>;

#[derive(Clone)]
pub struct WgpuTextSystem {
    render: SharedTextSystemState,
    measure: SharedTextSystemState,
}

impl WgpuTextSystem {
    pub fn from_fonts(fonts: &[&[u8]]) -> Self {
        Self {
            render: Arc::new(Mutex::new(TextSystemState::from_fonts(fonts))),
            measure: Arc::new(Mutex::new(TextSystemState::from_fonts(fonts))),
        }
    }

    fn install_measurer(&self) {
        set_text_measurer(WgpuTextMeasurer::new(Arc::clone(&self.measure)));
    }

    fn render_state(&self) -> SharedTextSystemState {
        Arc::clone(&self.render)
    }
}

/// WGPU-based renderer for GPU-accelerated 2D rendering.
///
/// This renderer supports:
/// - GPU-accelerated shape rendering (rectangles, rounded rectangles)
/// - Gradients (solid, linear, radial)
/// - GPU text rendering via glyphon
/// - Cross-platform support (Desktop, Web, Mobile)
pub struct WgpuRenderer {
    scene: Scene,
    gpu_renderer: Option<GpuRenderer>,
    render_text_state: SharedTextSystemState,
    /// Root scale factor for text rendering (use for density scaling)
    root_scale: f32,
}

impl WgpuRenderer {
    /// Create a new WGPU renderer.
    ///
    /// * `fonts` – font bytes to load, ordered by priority (first = highest priority).
    ///   Pass `&[]` to load no fonts; text will not render until fonts are provided.
    ///
    /// Call [`init_gpu`][Self::init_gpu] before rendering.
    pub fn new(fonts: &[&[u8]]) -> Self {
        Self::with_text_system(WgpuTextSystem::from_fonts(fonts))
    }

    pub fn with_text_system(text_system: WgpuTextSystem) -> Self {
        text_system.install_measurer();

        Self {
            scene: Scene::new(),
            gpu_renderer: None,
            render_text_state: text_system.render_state(),
            root_scale: 1.0,
        }
    }

    /// Initialize GPU resources with a WGPU device and queue.
    pub fn init_gpu(
        &mut self,
        device: Arc<wgpu::Device>,
        queue: Arc<wgpu::Queue>,
        surface_format: wgpu::TextureFormat,
        adapter_backend: wgpu::Backend,
    ) {
        self.gpu_renderer = Some(GpuRenderer::new(
            device,
            queue,
            surface_format,
            adapter_backend,
        ));
    }

    /// Set root scale factor for text rendering (e.g., density scaling on Android)
    pub fn set_root_scale(&mut self, scale: f32) {
        self.root_scale = scale;
    }

    pub fn root_scale(&self) -> f32 {
        self.root_scale
    }

    /// Render the scene to a texture view.
    pub fn render(
        &mut self,
        view: &wgpu::TextureView,
        width: u32,
        height: u32,
    ) -> Result<(), WgpuRendererError> {
        if let Some(gpu_renderer) = &mut self.gpu_renderer {
            let graph = self
                .scene
                .graph
                .as_ref()
                .ok_or_else(|| WgpuRendererError::Wgpu("scene graph is missing".to_string()))?;
            let mut text_state = self.render_text_state.lock().unwrap();
            let result =
                gpu_renderer.render(&mut text_state, view, graph, width, height, self.root_scale);
            result.map_err(WgpuRendererError::Wgpu)
        } else {
            Err(WgpuRendererError::Wgpu(
                "GPU renderer not initialized. Call init_gpu() first.".to_string(),
            ))
        }
    }

    /// Render the current scene into an RGBA pixel buffer for robot tests.
    ///
    /// Uses the renderer's configured root scale.
    pub fn capture_frame(
        &mut self,
        width: u32,
        height: u32,
    ) -> Result<CapturedFrame, WgpuRendererError> {
        self.capture_frame_with_scale(width, height, self.root_scale)
    }

    /// Render the current scene into an RGBA pixel buffer with an explicit scale.
    pub fn capture_frame_with_scale(
        &mut self,
        width: u32,
        height: u32,
        root_scale: f32,
    ) -> Result<CapturedFrame, WgpuRendererError> {
        if let Some(gpu_renderer) = &mut self.gpu_renderer {
            let graph = self
                .scene
                .graph
                .as_ref()
                .ok_or_else(|| WgpuRendererError::Wgpu("scene graph is missing".to_string()))?;
            let mut text_state = self.render_text_state.lock().unwrap();
            let pixels = gpu_renderer
                .render_to_rgba_pixels(&mut text_state, graph, width, height, root_scale)
                .map_err(WgpuRendererError::Wgpu)?;
            Ok(CapturedFrame {
                width,
                height,
                pixels,
            })
        } else {
            Err(WgpuRendererError::Wgpu(
                "GPU renderer not initialized. Call init_gpu() first.".to_string(),
            ))
        }
    }

    pub fn last_frame_stats(&self) -> Option<RenderStatsSnapshot> {
        self.gpu_renderer
            .as_ref()
            .and_then(GpuRenderer::last_frame_stats)
    }

    pub fn debug_cpu_allocation_stats(&self) -> DebugCpuAllocationStats {
        let mut stats = self
            .gpu_renderer
            .as_ref()
            .map(GpuRenderer::debug_cpu_allocation_stats)
            .unwrap_or_default();
        stats.scene_graph_node_count = self
            .scene
            .graph
            .as_ref()
            .map(RenderGraph::node_count)
            .unwrap_or(0);
        stats.scene_graph_heap_bytes = self
            .scene
            .graph
            .as_ref()
            .map(RenderGraph::heap_bytes)
            .unwrap_or(0);
        stats.scene_hits_len = self.scene.hits.len();
        stats.scene_hits_cap = self.scene.hits.capacity();
        stats.scene_node_index_len = self.scene.node_index.len();
        stats.scene_node_index_cap = self.scene.node_index.capacity();
        stats
    }

    /// Get access to the WGPU device (for surface configuration).
    pub fn device(&self) -> &wgpu::Device {
        self.gpu_renderer
            .as_ref()
            .map(|r| &*r.device)
            .expect("GPU renderer not initialized")
    }
}

impl Default for WgpuRenderer {
    fn default() -> Self {
        Self::new(&[])
    }
}

impl Renderer for WgpuRenderer {
    type Scene = Scene;
    type Error = WgpuRendererError;

    fn scene(&self) -> &Self::Scene {
        &self.scene
    }

    fn scene_mut(&mut self) -> &mut Self::Scene {
        &mut self.scene
    }

    fn rebuild_scene(
        &mut self,
        layout_tree: &LayoutTree,
        _viewport: Size,
    ) -> Result<(), Self::Error> {
        self.scene.clear();
        // Build scene in logical dp - scaling happens in GPU vertex upload
        pipeline::render_layout_tree(layout_tree.root(), &mut self.scene);
        Ok(())
    }

    fn rebuild_scene_from_applier(
        &mut self,
        applier: &mut MemoryApplier,
        root: NodeId,
        _viewport: Size,
    ) -> Result<(), Self::Error> {
        self.scene.clear();
        // Build scene in logical dp - scaling happens in GPU vertex upload
        // Traverse layout nodes via applier instead of rebuilding LayoutTree
        pipeline::render_from_applier(applier, root, &mut self.scene, 1.0);
        Ok(())
    }

    fn draw_dev_overlay(&mut self, text: &str, viewport: Size) {
        const DEV_OVERLAY_NODE_ID: NodeId = NodeId::MAX;
        let padding = 8.0;
        let font_size = 14.0;
        let char_width = 7.0;
        let text_width = text.len() as f32 * char_width;
        let text_height = font_size * 1.4;
        let x = (viewport.width - text_width - padding * 2.0).max(padding);
        let y = padding;

        let mut overlay_layer = LayerNode {
            node_id: Some(DEV_OVERLAY_NODE_ID),
            local_bounds: Rect {
                x: 0.0,
                y: 0.0,
                width: text_width + padding,
                height: text_height + padding / 2.0,
            },
            transform_to_parent: ProjectiveTransform::translation(x, y),
            motion_context_animated: false,
            translated_content_context: false,
            translated_content_offset: Point::default(),
            graphics_layer: GraphicsLayer::default(),
            clip_to_bounds: false,
            shadow_clip: None,
            hit_test: None,
            has_hit_targets: false,
            isolation: IsolationReasons::default(),
            cache_policy: CachePolicy::None,
            cache_hashes: LayerRasterCacheHashes::default(),
            cache_hashes_valid: false,
            children: vec![
                RenderNode::Primitive(PrimitiveEntry {
                    phase: PrimitivePhase::BeforeChildren,
                    node: PrimitiveNode::Draw(DrawPrimitiveNode {
                        primitive: DrawPrimitive::RoundRect {
                            rect: Rect {
                                x: 0.0,
                                y: 0.0,
                                width: text_width + padding,
                                height: text_height + padding / 2.0,
                            },
                            brush: Brush::Solid(Color(0.0, 0.0, 0.0, 0.7)),
                            radii: CornerRadii::uniform(4.0),
                        },
                        clip: None,
                    }),
                }),
                RenderNode::Primitive(PrimitiveEntry {
                    phase: PrimitivePhase::AfterChildren,
                    node: PrimitiveNode::Text(Box::new(TextPrimitiveNode {
                        node_id: DEV_OVERLAY_NODE_ID,
                        rect: Rect {
                            x: padding / 2.0,
                            y: padding / 4.0,
                            width: text_width,
                            height: text_height,
                        },
                        text: cranpose_ui::text::AnnotatedString::from(text),
                        text_style: cranpose_ui::TextStyle::default(),
                        font_size,
                        layout_options: cranpose_ui::TextLayoutOptions::default(),
                        clip: None,
                    })),
                }),
            ],
        };
        overlay_layer.recompute_raster_cache_hashes();

        let graph = self.scene.graph.get_or_insert_with(|| {
            RenderGraph::new(LayerNode {
                node_id: None,
                local_bounds: Rect::from_size(viewport),
                transform_to_parent: ProjectiveTransform::identity(),
                motion_context_animated: false,
                translated_content_context: false,
                translated_content_offset: Point::default(),
                graphics_layer: GraphicsLayer::default(),
                clip_to_bounds: false,
                shadow_clip: None,
                hit_test: None,
                has_hit_targets: false,
                isolation: IsolationReasons::default(),
                cache_policy: CachePolicy::None,
                cache_hashes: LayerRasterCacheHashes::default(),
                cache_hashes_valid: false,
                children: Vec::new(),
            })
        });

        graph.root.children.retain(|child| {
            !matches!(
                child,
                RenderNode::Layer(layer) if layer.node_id == Some(DEV_OVERLAY_NODE_ID)
            )
        });
        graph
            .root
            .children
            .push(RenderNode::Layer(Box::new(overlay_layer)));
        graph.root.recompute_raster_cache_hashes();
    }
}

fn resolve_font_size(style: &cranpose_ui::text::TextStyle) -> f32 {
    style.resolve_font_size(14.0)
}

fn resolve_line_height(style: &cranpose_ui::text::TextStyle, font_size: f32) -> f32 {
    style.resolve_line_height(14.0, font_size * 1.4)
}

fn resolve_max_span_font_size(
    style: &cranpose_ui::text::TextStyle,
    text: &cranpose_ui::text::AnnotatedString,
    base_font_size: f32,
) -> f32 {
    if text.span_styles.is_empty() {
        return base_font_size;
    }

    let mut max_font_size = base_font_size;
    for window in text.span_boundaries().windows(2) {
        let start = window[0];
        let end = window[1];
        if start == end {
            continue;
        }

        let mut merged_span = style.span_style.clone();
        for span in &text.span_styles {
            if span.range.start <= start && span.range.end >= end {
                merged_span = merged_span.merge(&span.item);
            }
        }
        let mut chunk_style = style.clone();
        chunk_style.span_style = merged_span;
        max_font_size = max_font_size.max(chunk_style.resolve_font_size(base_font_size));
    }
    max_font_size
}

pub(crate) fn resolve_effective_line_height(
    style: &cranpose_ui::text::TextStyle,
    text: &cranpose_ui::text::AnnotatedString,
    base_font_size: f32,
) -> f32 {
    let max_font_size = resolve_max_span_font_size(style, text, base_font_size);
    resolve_line_height(style, max_font_size)
}

/// Returns true if the fontdb contains at least one italic (or oblique) face
/// whose family matches the given `FamilyOwned`.
fn family_has_italic_face(font_system: &FontSystem, family: &FamilyOwned) -> bool {
    let family_ref = family.as_family();
    let family_name = font_system.db().family_name(&family_ref);
    font_system.db().faces().any(|face| {
        (face.style == glyphon::fontdb::Style::Italic
            || face.style == glyphon::fontdb::Style::Oblique)
            && face
                .families
                .iter()
                .any(|(name, _)| name.eq_ignore_ascii_case(family_name))
    })
}

fn attrs_from_text_style(
    style: &cranpose_ui::text::TextStyle,
    unscaled_base_font_size: f32,
    scale: f32,
    font_system: &mut FontSystem,
    font_family_resolver: &mut WgpuFontFamilyResolver,
) -> AttrsOwned {
    let mut attrs = Attrs::new();
    let span_style = &style.span_style;
    let font_weight = span_style.font_weight;
    let font_style = span_style.font_style;
    let letter_spacing = span_style.letter_spacing;

    let unscaled_font_size = style.resolve_font_size(unscaled_base_font_size);
    let unscaled_line_height =
        style.resolve_line_height(unscaled_base_font_size, unscaled_font_size * 1.4);

    let font_size_px = unscaled_font_size * scale;
    let line_height_px = unscaled_line_height * scale;
    attrs = attrs.metrics(glyphon::Metrics::new(font_size_px, line_height_px));

    if let Some(color) = glyph_foreground_color(span_style) {
        let r = (color.0 * 255.0).clamp(0.0, 255.0) as u8;
        let g = (color.1 * 255.0).clamp(0.0, 255.0) as u8;
        let b = (color.2 * 255.0).clamp(0.0, 255.0) as u8;
        let a = (color.3 * 255.0).clamp(0.0, 255.0) as u8;
        attrs = attrs.color(glyphon::Color::rgba(r, g, b, a));
    }

    let family_owned = font_family_resolver.resolve_family_owned(font_system, span_style);
    attrs = attrs.family(family_owned.as_family());

    if let Some(font_weight) = font_weight {
        attrs = attrs.weight(GlyphonWeight(font_weight.0));
    }

    // cosmic-text 0.15 does NOT synthesize italic automatically — it passes
    // cache_key_flags through as-is from attrs to glyphs.  We must decide here
    // whether to request a native italic face or to ask for synthetic skew.
    //
    // Strategy:
    //   • If the resolved family owns an italic face → set style=Italic so
    //     cosmic-text matches the real face.  No FAKE_ITALIC needed.
    //   • Otherwise → keep style=Normal (so font matching finds the Regular
    //     face) and set FAKE_ITALIC for the swash 14-degree skew.
    let mut flags = glyphon::cosmic_text::CacheKeyFlags::DISABLE_HINTING;
    if let Some(font_style) = font_style {
        match font_style {
            cranpose_ui::text::FontStyle::Normal => {}
            cranpose_ui::text::FontStyle::Italic => {
                if family_has_italic_face(font_system, &family_owned) {
                    attrs = attrs.style(GlyphonStyle::Italic);
                } else {
                    flags |= glyphon::cosmic_text::CacheKeyFlags::FAKE_ITALIC;
                }
            }
        }
    }

    attrs = match letter_spacing {
        cranpose_ui::text::TextUnit::Em(value) => attrs.letter_spacing(value),
        cranpose_ui::text::TextUnit::Sp(value) if font_size_px > 0.0 => {
            attrs.letter_spacing((value * scale) / font_size_px)
        }
        _ => attrs,
    };
    attrs = attrs.cache_key_flags(flags);

    AttrsOwned::new(&attrs)
}

// Text measurer implementation for WGPU

#[derive(Clone)]
struct WgpuTextMeasurer {
    text_state: SharedTextSystemState,
    size_cache: TextSizeCache,
    prepared_layout_cache: PreparedTextLayoutCache,
}

impl WgpuTextMeasurer {
    fn new(text_state: SharedTextSystemState) -> Self {
        Self {
            text_state,
            // Larger cache size (1024) reduces misses, FxHasher for faster lookups
            size_cache: Arc::new(Mutex::new(LruCache::new(NonZeroUsize::new(1024).unwrap()))),
            prepared_layout_cache: Rc::new(RefCell::new(LruCache::new(
                NonZeroUsize::new(256).unwrap(),
            ))),
        }
    }

    fn text_buffer_key(
        node_id: Option<NodeId>,
        text: &str,
        font_size: f32,
        style_hash: u64,
    ) -> TextCacheKey {
        match node_id {
            Some(node_id) => TextCacheKey::for_node(node_id, font_size, style_hash),
            None => TextCacheKey::new(text, font_size, style_hash),
        }
    }

    fn try_measure_with_options_fast_path(
        &self,
        node_id: Option<NodeId>,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        options: cranpose_ui::text::TextLayoutOptions,
        max_width: Option<f32>,
    ) -> Option<cranpose_ui::TextMetrics> {
        let options = options.normalized();
        let max_width = max_width.filter(|w| w.is_finite() && *w > 0.0)?;
        if !Self::supports_fast_wrap_options(style, options) {
            return None;
        }

        let text_str = text.text.as_str();
        let font_size = resolve_font_size(style);
        let line_height = resolve_effective_line_height(style, text, font_size);
        let size_style_hash = style.measurement_hash()
            ^ text.span_styles_hash()
            ^ (max_width.to_bits() as u64).rotate_left(17)
            ^ 0x9f4c_3314_2d5b_79e1;
        let buffer_style_hash = text_buffer_style_hash(style, text);
        let size_int = (font_size * 100.0) as i32;

        let mut hasher = FxHasher::default();
        text_str.hash(&mut hasher);
        let text_hash = hasher.finish();
        let cache_key = (text_hash, size_int, size_style_hash);

        {
            let mut cache = self.size_cache.lock().unwrap();
            if let Some((cached_text, size)) = cache.get(&cache_key) {
                if cached_text == text_str {
                    let width = size.width.min(max_width);
                    let min_height = options.min_lines as f32 * line_height;
                    let height = size.height.max(min_height);
                    let line_count =
                        ((height / line_height).ceil() as usize).max(options.min_lines);
                    return Some(cranpose_ui::TextMetrics {
                        width,
                        height,
                        line_height,
                        line_count,
                    });
                }
            }
        }

        let text_buffer_key =
            Self::text_buffer_key(node_id, text_str, font_size, buffer_style_hash);
        let mut text_state = self.text_state.lock().unwrap();
        let (font_system, font_family_resolver, text_cache) = text_state.parts_mut();

        let (size, wrapped_line_count) = {
            let (_, _, _, buffer) = shared_text_buffer_mut(
                text_cache,
                text_buffer_key,
                font_system,
                font_size,
                line_height,
            );

            let _ = buffer.ensure(
                font_system,
                font_family_resolver,
                EnsureTextBufferParams {
                    annotated_text: text,
                    font_size_px: font_size,
                    line_height_px: line_height,
                    style_hash: buffer_style_hash,
                    style,
                    scale: 1.0,
                },
            );

            buffer
                .buffer
                .set_size(font_system, Some(max_width), Some(f32::MAX));
            buffer.buffer.shape_until_scroll(font_system, false);
            buffer.cached_size = None;
            let size = buffer.size();
            let line_count = buffer.buffer.layout_runs().count();
            (size, line_count)
        };
        drop(text_state);

        let mut size_cache = self.size_cache.lock().unwrap();
        size_cache.put(cache_key, (text_str.to_string(), size));

        let width = size.width.min(max_width);
        let min_height = options.min_lines as f32 * line_height;
        let height = size.height.max(min_height);
        let line_count = wrapped_line_count.max(options.min_lines).max(1);

        Some(cranpose_ui::TextMetrics {
            width,
            height,
            line_height,
            line_count,
        })
    }

    fn try_prepare_with_options_fast_path(
        &self,
        node_id: Option<NodeId>,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        options: cranpose_ui::text::TextLayoutOptions,
        max_width: Option<f32>,
    ) -> Option<cranpose_ui::text::PreparedTextLayout> {
        let options = options.normalized();
        let max_width = max_width.filter(|w| w.is_finite() && *w > 0.0)?;
        if !Self::supports_fast_wrap_options(style, options) {
            return None;
        }

        let text_str = text.text.as_str();
        let font_size = resolve_font_size(style);
        let line_height = resolve_effective_line_height(style, text, font_size);
        let style_hash = text_buffer_style_hash(style, text);

        let text_buffer_key = Self::text_buffer_key(node_id, text_str, font_size, style_hash);
        let mut text_state = self.text_state.lock().unwrap();
        let (font_system, font_family_resolver, text_cache) = text_state.parts_mut();

        let (size, wrapped_ranges) = {
            let (_, _, _, buffer) = shared_text_buffer_mut(
                text_cache,
                text_buffer_key,
                font_system,
                font_size,
                line_height,
            );

            let _ = buffer.ensure(
                font_system,
                font_family_resolver,
                EnsureTextBufferParams {
                    annotated_text: text,
                    font_size_px: font_size,
                    line_height_px: line_height,
                    style_hash,
                    style,
                    scale: 1.0,
                },
            );

            buffer
                .buffer
                .set_size(font_system, Some(max_width), Some(f32::MAX));
            buffer.buffer.shape_until_scroll(font_system, false);
            buffer.cached_size = None;
            let size = buffer.size();
            let wrapped_ranges = collect_wrapped_ranges(text_str, &buffer.buffer)?;
            (size, wrapped_ranges)
        };

        let mut builder = cranpose_ui::text::AnnotatedString::builder();
        for (idx, (start, end)) in wrapped_ranges.iter().enumerate() {
            builder = builder.append_annotated_subsequence(text, *start..*end);
            if idx + 1 < wrapped_ranges.len() {
                builder = builder.append("\n");
            }
        }
        let wrapped_annotated = builder.to_annotated_string();

        let line_count = wrapped_ranges.len().max(options.min_lines).max(1);
        let min_height = options.min_lines as f32 * line_height;
        let height = (line_count as f32 * line_height).max(min_height);

        Some(cranpose_ui::text::PreparedTextLayout {
            text: wrapped_annotated,
            visual_style: style.clone(),
            metrics: cranpose_ui::TextMetrics {
                width: size.width.min(max_width),
                height,
                line_height,
                line_count,
            },
            did_overflow: false,
        })
    }

    fn supports_fast_wrap_options(
        style: &cranpose_ui::text::TextStyle,
        options: cranpose_ui::text::TextLayoutOptions,
    ) -> bool {
        if options.overflow != cranpose_ui::text::TextOverflow::Clip || !options.soft_wrap {
            return false;
        }
        if options.max_lines != usize::MAX {
            return false;
        }

        let line_break = style
            .paragraph_style
            .line_break
            .take_or_else(|| cranpose_ui::text::LineBreak::Simple);
        let hyphens = style
            .paragraph_style
            .hyphens
            .take_or_else(|| cranpose_ui::text::Hyphens::None);
        line_break == cranpose_ui::text::LineBreak::Simple
            && hyphens == cranpose_ui::text::Hyphens::None
    }
}

fn collect_wrapped_ranges(text: &str, buffer: &Buffer) -> Option<Vec<(usize, usize)>> {
    if text.is_empty() {
        return Some(vec![(0, 0)]);
    }

    let text_lines: Vec<&str> = text.split('\n').collect();
    let line_offsets: Vec<(usize, usize)> = text_lines
        .iter()
        .scan(0usize, |line_start, line| {
            let start = *line_start;
            let end = start + line.len();
            *line_start = end.saturating_add(1);
            Some((start, end))
        })
        .collect();

    let mut wrapped_ranges = Vec::new();
    for run in buffer.layout_runs() {
        let (line_start, line_end) = line_offsets
            .get(run.line_i)
            .copied()
            .unwrap_or((0usize, text.len()));
        let line_len = line_end.saturating_sub(line_start);

        if run.glyphs.is_empty() {
            wrapped_ranges.push((line_start, line_start));
            continue;
        }

        let mut local_start = line_len;
        let mut local_end = 0usize;
        for glyph in run.glyphs.iter() {
            local_start = local_start.min(glyph.start.min(line_len));
            local_end = local_end.max(glyph.end.min(line_len));
        }

        let range_start = line_start.saturating_add(local_start.min(line_len));
        let range_end = line_start.saturating_add(local_end.min(line_len));
        if range_start > range_end
            || range_end > text.len()
            || !text.is_char_boundary(range_start)
            || !text.is_char_boundary(range_end)
        {
            return None;
        }
        wrapped_ranges.push((range_start, range_end));
    }

    if wrapped_ranges.is_empty() {
        Some(vec![(0, text.len())])
    } else {
        Some(wrapped_ranges)
    }
}

/// Convenience function for tests to initialize an accurate wgpu text measurer without launching a window.
pub fn setup_headless_text_measurer() {
    let mut font_system = FontSystem::new();
    let mut font_family_resolver_impl = WgpuFontFamilyResolver::default();
    font_family_resolver_impl.prime(&mut font_system);
    let text_state = Arc::new(Mutex::new(TextSystemState::from_parts(
        font_system,
        font_family_resolver_impl,
    )));
    cranpose_ui::text::set_text_measurer(WgpuTextMeasurer::new(text_state));
}

// Base font size in logical units (dp) - shared between measurement and rendering

impl TextMeasurer for WgpuTextMeasurer {
    fn measure(
        &self,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
    ) -> cranpose_ui::TextMetrics {
        self.measure_for_node(None, text, style)
    }

    fn measure_for_node(
        &self,
        node_id: Option<NodeId>,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
    ) -> cranpose_ui::TextMetrics {
        let telemetry = text_measure_telemetry_enabled().then_some(text_measure_telemetry());
        let telemetry_sequence = telemetry
            .map(|t| t.measure_calls.fetch_add(1, Ordering::Relaxed) + 1)
            .unwrap_or(0);
        let text_str = text.text.as_str();
        let font_size = resolve_font_size(style);
        let line_height = resolve_effective_line_height(style, text, font_size);
        let size_style_hash = style.measurement_hash() ^ text.span_styles_hash();
        let buffer_style_hash = text_buffer_style_hash(style, text);
        let size_int = (font_size * 100.0) as i32;

        // Calculate hash to avoid allocating String for lookup
        // FxHasher is ~3x faster than DefaultHasher for short strings
        let mut hasher = FxHasher::default();
        text_str.hash(&mut hasher);
        let text_hash = hasher.finish();
        let cache_key = (text_hash, size_int, size_style_hash);

        // Check size cache first (fastest path)
        {
            let mut cache = self.size_cache.lock().unwrap();
            if let Some((cached_text, size)) = cache.get(&cache_key) {
                // Verify partial collision
                if cached_text == text_str {
                    if let Some(t) = telemetry {
                        t.size_cache_hits.fetch_add(1, Ordering::Relaxed);
                        maybe_report_text_measure_telemetry(telemetry_sequence);
                    }
                    let line_count = text_str.split('\n').count().max(1);
                    return cranpose_ui::TextMetrics {
                        width: size.width,
                        height: size.height,
                        line_height,
                        line_count,
                    };
                }
            }
        }
        if let Some(t) = telemetry {
            t.size_cache_misses.fetch_add(1, Ordering::Relaxed);
        }

        // Get or create text buffer
        let text_buffer_key =
            Self::text_buffer_key(node_id, text_str, font_size, buffer_style_hash);
        let mut text_state = self.text_state.lock().unwrap();
        let (font_system, font_family_resolver, text_cache) = text_state.parts_mut();

        // Get or create buffer and calculate size
        let size = {
            let (text_cache_hit, evicted, cache_len, buffer) = shared_text_buffer_mut(
                text_cache,
                text_buffer_key,
                font_system,
                font_size,
                line_height,
            );
            if let Some(t) = telemetry {
                if text_cache_hit {
                    t.text_cache_hits.fetch_add(1, Ordering::Relaxed);
                } else {
                    t.text_cache_misses.fetch_add(1, Ordering::Relaxed);
                }
                if evicted {
                    t.text_cache_evictions.fetch_add(1, Ordering::Relaxed);
                }
                t.text_cache_occupancy
                    .store(cache_len as u64, Ordering::Relaxed);
            }

            // Ensure buffer has the correct text
            let reshaped = buffer.ensure(
                font_system,
                font_family_resolver,
                EnsureTextBufferParams {
                    annotated_text: text,
                    font_size_px: font_size,
                    line_height_px: line_height,
                    style_hash: buffer_style_hash,
                    style,
                    scale: 1.0,
                },
            );
            if let Some(t) = telemetry {
                if reshaped {
                    t.ensure_reshapes.fetch_add(1, Ordering::Relaxed);
                } else {
                    t.ensure_reuses.fetch_add(1, Ordering::Relaxed);
                }
            }

            // Calculate size if not cached
            buffer.size()
        };

        drop(text_state);

        // Cache the size result
        let mut size_cache = self.size_cache.lock().unwrap();
        // Only allocate string on cache miss
        size_cache.put(cache_key, (text_str.to_string(), size));

        // Calculate line info for multiline support
        let line_count = text_str.split('\n').count().max(1);
        if telemetry.is_some() {
            maybe_report_text_measure_telemetry(telemetry_sequence);
        }

        cranpose_ui::TextMetrics {
            width: size.width,
            height: size.height,
            line_height,
            line_count,
        }
    }

    fn measure_with_options(
        &self,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        options: cranpose_ui::text::TextLayoutOptions,
        max_width: Option<f32>,
    ) -> cranpose_ui::TextMetrics {
        self.measure_with_options_for_node(None, text, style, options, max_width)
    }

    fn measure_with_options_for_node(
        &self,
        node_id: Option<NodeId>,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        options: cranpose_ui::text::TextLayoutOptions,
        max_width: Option<f32>,
    ) -> cranpose_ui::TextMetrics {
        let telemetry = text_measure_telemetry_enabled().then_some(text_measure_telemetry());
        let telemetry_sequence = telemetry
            .map(|t| t.measure_with_options_calls.fetch_add(1, Ordering::Relaxed) + 1)
            .unwrap_or(0);
        if let Some(metrics) =
            self.try_measure_with_options_fast_path(node_id, text, style, options, max_width)
        {
            if let Some(t) = telemetry {
                t.measure_fast_path_hits.fetch_add(1, Ordering::Relaxed);
                maybe_report_text_measure_telemetry(telemetry_sequence);
            }
            return metrics;
        }
        if let Some(t) = telemetry {
            t.measure_fast_path_misses.fetch_add(1, Ordering::Relaxed);
            maybe_report_text_measure_telemetry(telemetry_sequence);
        }
        self.prepare_with_options_for_node(node_id, text, style, options, max_width)
            .metrics
    }

    fn prepare_with_options(
        &self,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        options: cranpose_ui::text::TextLayoutOptions,
        max_width: Option<f32>,
    ) -> cranpose_ui::text::PreparedTextLayout {
        self.prepare_with_options_for_node(None, text, style, options, max_width)
    }

    fn prepare_with_options_for_node(
        &self,
        node_id: Option<NodeId>,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        options: cranpose_ui::text::TextLayoutOptions,
        max_width: Option<f32>,
    ) -> cranpose_ui::text::PreparedTextLayout {
        let telemetry = text_measure_telemetry_enabled().then_some(text_measure_telemetry());
        let telemetry_sequence = telemetry
            .map(|t| t.prepare_with_options_calls.fetch_add(1, Ordering::Relaxed) + 1)
            .unwrap_or(0);
        let normalized_options = options.normalized();
        let normalized_max_width = max_width.filter(|w| w.is_finite() && *w > 0.0);
        let text_str = text.text.as_str();
        let font_size = resolve_font_size(style);
        let style_hash = text_buffer_style_hash(style, text);
        let size_int = (font_size * 100.0) as i32;

        let mut hasher = FxHasher::default();
        text_str.hash(&mut hasher);
        let text_hash = hasher.finish();
        let cache_key = PreparedTextLayoutCacheKey {
            text_hash,
            size_int,
            style_hash,
            options: normalized_options,
            max_width_bits: normalized_max_width.map(f32::to_bits),
        };

        {
            let mut cache = self.prepared_layout_cache.borrow_mut();
            if let Some((cached_text, prepared)) = cache.get(&cache_key) {
                if cached_text == text_str {
                    if let Some(t) = telemetry {
                        t.prepared_layout_cache_hits.fetch_add(1, Ordering::Relaxed);
                        maybe_report_text_measure_telemetry(telemetry_sequence);
                    }
                    return prepared.clone();
                }
            }
        }
        if let Some(t) = telemetry {
            t.prepared_layout_cache_misses
                .fetch_add(1, Ordering::Relaxed);
        }

        let prepared = if let Some(prepared) = self.try_prepare_with_options_fast_path(
            node_id,
            text,
            style,
            normalized_options,
            normalized_max_width,
        ) {
            if let Some(t) = telemetry {
                t.prepare_fast_path_hits.fetch_add(1, Ordering::Relaxed);
            }
            prepared
        } else {
            if let Some(t) = telemetry {
                t.prepare_fast_path_misses.fetch_add(1, Ordering::Relaxed);
            }
            cranpose_ui::text::measure::prepare_text_layout_with_measurer_for_node(
                self,
                node_id,
                text,
                style,
                normalized_options,
                normalized_max_width,
            )
        };

        let mut cache = self.prepared_layout_cache.borrow_mut();
        cache.put(cache_key, (text_str.to_string(), prepared.clone()));
        if telemetry.is_some() {
            maybe_report_text_measure_telemetry(telemetry_sequence);
        }

        prepared
    }

    fn get_offset_for_position(
        &self,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        x: f32,
        y: f32,
    ) -> usize {
        let telemetry = text_measure_telemetry_enabled().then_some(text_measure_telemetry());
        let telemetry_sequence = telemetry
            .map(|t| t.offset_calls.fetch_add(1, Ordering::Relaxed) + 1)
            .unwrap_or(0);
        let text_str = text.text.as_str();
        let font_size = resolve_font_size(style);
        let line_height = resolve_effective_line_height(style, text, font_size);
        let style_hash = text_buffer_style_hash(style, text);
        if text_str.is_empty() {
            return 0;
        }

        let cache_key = TextCacheKey::new(text_str, font_size, style_hash);

        let mut text_state = self.text_state.lock().unwrap();
        let (font_system, font_family_resolver, text_cache) = text_state.parts_mut();

        let (text_cache_hit, evicted, cache_len, buffer) =
            shared_text_buffer_mut(text_cache, cache_key, font_system, font_size, line_height);
        if let Some(t) = telemetry {
            if text_cache_hit {
                t.text_cache_hits.fetch_add(1, Ordering::Relaxed);
            } else {
                t.text_cache_misses.fetch_add(1, Ordering::Relaxed);
            }
            if evicted {
                t.text_cache_evictions.fetch_add(1, Ordering::Relaxed);
            }
            t.text_cache_occupancy
                .store(cache_len as u64, Ordering::Relaxed);
        }

        let reshaped = buffer.ensure(
            font_system,
            font_family_resolver,
            EnsureTextBufferParams {
                annotated_text: text,
                font_size_px: font_size,
                line_height_px: line_height,
                style_hash,
                style,
                scale: 1.0,
            },
        );
        if let Some(t) = telemetry {
            if reshaped {
                t.ensure_reshapes.fetch_add(1, Ordering::Relaxed);
            } else {
                t.ensure_reuses.fetch_add(1, Ordering::Relaxed);
            }
            maybe_report_text_measure_telemetry(telemetry_sequence);
        }

        let line_offsets: Vec<(usize, usize)> = text_str
            .split('\n')
            .scan(0usize, |line_start, line| {
                let start = *line_start;
                let end = start + line.len();
                *line_start = end.saturating_add(1);
                Some((start, end))
            })
            .collect();

        let mut target_line = None;
        let mut best_vertical_distance = f32::INFINITY;

        for run in buffer.buffer.layout_runs() {
            let mut run_height = run.line_height;
            for glyph in run.glyphs.iter() {
                run_height = run_height.max(glyph.font_size * 1.4);
            }

            let top = run.line_top;
            let bottom = top + run_height.max(1.0);
            let vertical_distance = if y < top {
                top - y
            } else if y > bottom {
                y - bottom
            } else {
                0.0
            };

            if vertical_distance < best_vertical_distance {
                best_vertical_distance = vertical_distance;
                target_line = Some(run.line_i);
                if vertical_distance == 0.0 {
                    break;
                }
            }
        }

        let fallback_line = (y / line_height).floor().max(0.0) as usize;
        let target_line = target_line
            .unwrap_or(fallback_line)
            .min(line_offsets.len().saturating_sub(1));
        let (line_start, line_end) = line_offsets
            .get(target_line)
            .copied()
            .unwrap_or((0, text_str.len()));
        let line_len = line_end.saturating_sub(line_start);

        let mut best_offset = line_offsets
            .get(target_line)
            .map(|(_, end)| *end)
            .unwrap_or(text_str.len());
        let mut best_distance = f32::INFINITY;
        let mut found_glyph = false;

        for run in buffer.buffer.layout_runs() {
            if run.line_i != target_line {
                continue;
            }
            for glyph in run.glyphs.iter() {
                found_glyph = true;
                let glyph_start = line_start.saturating_add(glyph.start.min(line_len));
                let glyph_end = line_start.saturating_add(glyph.end.min(line_len));
                let left_dist = (x - glyph.x).abs();
                if left_dist < best_distance {
                    best_distance = left_dist;
                    best_offset = glyph_start;
                }

                let right_x = glyph.x + glyph.w;
                let right_dist = (x - right_x).abs();
                if right_dist < best_distance {
                    best_distance = right_dist;
                    best_offset = glyph_end;
                }
            }
        }

        if !found_glyph {
            if let Some((start, end)) = line_offsets.get(target_line) {
                best_offset = if x <= 0.0 { *start } else { *end };
            }
        }

        best_offset.min(text_str.len())
    }

    fn get_cursor_x_for_offset(
        &self,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
        offset: usize,
    ) -> f32 {
        let text = text.text.as_str();
        let clamped_offset = offset.min(text.len());
        if clamped_offset == 0 {
            return 0.0;
        }

        // Measure text up to offset
        let prefix = &text[..clamped_offset];
        self.measure(&cranpose_ui::text::AnnotatedString::from(prefix), style)
            .width
    }

    fn choose_auto_hyphen_break(
        &self,
        line: &str,
        style: &cranpose_ui::text::TextStyle,
        segment_start_char: usize,
        measured_break_char: usize,
    ) -> Option<usize> {
        choose_shared_auto_hyphen_break(line, style, segment_start_char, measured_break_char)
    }

    fn layout(
        &self,
        text: &cranpose_ui::text::AnnotatedString,
        style: &cranpose_ui::text::TextStyle,
    ) -> cranpose_ui::text_layout_result::TextLayoutResult {
        let telemetry = text_measure_telemetry_enabled().then_some(text_measure_telemetry());
        let telemetry_sequence = telemetry
            .map(|t| t.layout_calls.fetch_add(1, Ordering::Relaxed) + 1)
            .unwrap_or(0);
        let text_str = text.text.as_str();
        use cranpose_ui::text_layout_result::{
            GlyphLayout, LineLayout, TextLayoutData, TextLayoutResult,
        };

        let font_size = resolve_font_size(style);
        let line_height = resolve_effective_line_height(style, text, font_size);
        let style_hash = text_buffer_style_hash(style, text);

        let cache_key = TextCacheKey::new(text_str, font_size, style_hash);
        let mut text_state = self.text_state.lock().unwrap();
        let (font_system, font_family_resolver, text_cache) = text_state.parts_mut();

        let (text_cache_hit, evicted, cache_len, buffer) = shared_text_buffer_mut(
            text_cache,
            cache_key.clone(),
            font_system,
            font_size,
            line_height,
        );
        if let Some(t) = telemetry {
            if text_cache_hit {
                t.text_cache_hits.fetch_add(1, Ordering::Relaxed);
            } else {
                t.text_cache_misses.fetch_add(1, Ordering::Relaxed);
            }
            if evicted {
                t.text_cache_evictions.fetch_add(1, Ordering::Relaxed);
            }
            t.text_cache_occupancy
                .store(cache_len as u64, Ordering::Relaxed);
        }
        let reshaped = buffer.ensure(
            font_system,
            font_family_resolver,
            EnsureTextBufferParams {
                annotated_text: text,
                font_size_px: font_size,
                line_height_px: line_height,
                style_hash,
                style,
                scale: 1.0,
            },
        );
        if let Some(t) = telemetry {
            if reshaped {
                t.ensure_reshapes.fetch_add(1, Ordering::Relaxed);
            } else {
                t.ensure_reuses.fetch_add(1, Ordering::Relaxed);
            }
            maybe_report_text_measure_telemetry(telemetry_sequence);
        }
        let measured_size = buffer.size();

        // Extract glyph positions from layout runs
        let mut glyph_x_positions = Vec::new();
        let mut char_to_byte = Vec::new();
        let mut glyph_layouts = Vec::new();
        let mut lines = Vec::new();
        let text_lines: Vec<&str> = text_str.split('\n').collect();
        let line_offsets: Vec<(usize, usize)> = text_lines
            .iter()
            .scan(0usize, |line_start, line| {
                let start = *line_start;
                let end = start + line.len();
                *line_start = end.saturating_add(1);
                Some((start, end))
            })
            .collect();

        for run in buffer.buffer.layout_runs() {
            let line_idx = run.line_i;
            let run_height = run
                .glyphs
                .iter()
                .fold(run.line_height, |acc, glyph| acc.max(glyph.font_size * 1.4))
                .max(1.0);

            for glyph in run.glyphs.iter() {
                let (line_start, line_end) = line_offsets
                    .get(line_idx)
                    .copied()
                    .unwrap_or((0, text_str.len()));
                let line_len = line_end.saturating_sub(line_start);
                let glyph_start = line_start.saturating_add(glyph.start.min(line_len));
                let glyph_end = line_start.saturating_add(glyph.end.min(line_len));

                glyph_x_positions.push(glyph.x);
                char_to_byte.push(glyph_start);
                if glyph_end > glyph_start {
                    glyph_layouts.push(GlyphLayout {
                        line_index: line_idx,
                        start_offset: glyph_start,
                        end_offset: glyph_end,
                        x: glyph.x,
                        y: run.line_top,
                        width: glyph.w.max(0.0),
                        height: run_height,
                    });
                }
            }
        }

        // Add end position
        glyph_x_positions.push(measured_size.width);
        char_to_byte.push(text_str.len());

        // Build lines from text newlines
        let mut y = 0.0f32;
        let mut line_start = 0usize;
        for (i, line_text) in text_lines.iter().enumerate() {
            let line_end = if i == text_lines.len() - 1 {
                text_str.len()
            } else {
                line_start + line_text.len()
            };

            lines.push(LineLayout {
                start_offset: line_start,
                end_offset: line_end,
                y,
                height: line_height,
            });

            line_start = line_end + 1;
            y += line_height;
        }

        if lines.is_empty() {
            lines.push(LineLayout {
                start_offset: 0,
                end_offset: 0,
                y: 0.0,
                height: line_height,
            });
        }

        let metrics = cranpose_ui::TextMetrics {
            width: measured_size.width,
            height: measured_size.height,
            line_height,
            line_count: text_lines.len().max(1),
        };
        TextLayoutResult::new(
            text_str,
            TextLayoutData {
                width: metrics.width,
                height: metrics.height,
                line_height,
                glyph_x_positions,
                char_to_byte,
                lines,
                glyph_layouts,
            },
        )
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use std::sync::mpsc;
    use std::time::Duration;

    const WORKER_TEST_TIMEOUT_SECS: u64 = 15;

    fn seeded_font_system_and_resolver() -> (FontSystem, WgpuFontFamilyResolver) {
        let mut db = glyphon::fontdb::Database::new();
        db.load_font_data(TEST_FONT.to_vec());
        let mut font_system = FontSystem::new_with_locale_and_db("en-US".to_string(), db);
        let mut resolver = WgpuFontFamilyResolver::default();
        resolver.prime(&mut font_system);
        (font_system, resolver)
    }

    fn seeded_text_state() -> SharedTextSystemState {
        let (font_system, resolver) = seeded_font_system_and_resolver();
        Arc::new(Mutex::new(TextSystemState::from_parts(
            font_system,
            resolver,
        )))
    }

    #[test]
    fn attrs_resolution_falls_back_for_missing_named_family() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let style = cranpose_ui::text::TextStyle {
            span_style: cranpose_ui::text::SpanStyle {
                font_family: Some(cranpose_ui::text::FontFamily::named("Missing Family Name")),
                ..Default::default()
            },
            ..Default::default()
        };

        let attrs = attrs_from_text_style(&style, 14.0, 1.0, &mut font_system, &mut resolver);
        assert_eq!(attrs.family_owned, FamilyOwned::SansSerif);
    }

    #[test]
    fn attrs_resolution_seeds_generic_families_from_loaded_fonts() {
        let (font_system, resolver) = seeded_font_system_and_resolver();
        assert!(
            resolver.generic_fallback_seeded,
            "expected generic fallback seeding after resolver prime"
        );
        let query = glyphon::fontdb::Query {
            families: &[glyphon::fontdb::Family::Monospace],
            weight: glyphon::fontdb::Weight::NORMAL,
            stretch: glyphon::fontdb::Stretch::Normal,
            style: glyphon::fontdb::Style::Normal,
        };
        assert!(
            font_system.db().query(&query).is_some(),
            "generic monospace query should resolve after fallback seeding"
        );
    }

    #[test]
    fn attrs_resolution_named_family_lookup_is_case_insensitive() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let style = cranpose_ui::text::TextStyle {
            span_style: cranpose_ui::text::SpanStyle {
                font_family: Some(cranpose_ui::text::FontFamily::named("noto sans")),
                ..Default::default()
            },
            ..Default::default()
        };

        let attrs = attrs_from_text_style(&style, 14.0, 1.0, &mut font_system, &mut resolver);
        assert!(
            matches!(attrs.family_owned, FamilyOwned::Name(_)),
            "case-insensitive family lookup should resolve to a concrete family name"
        );
    }

    #[test]
    fn attrs_resolution_synthesizes_italic_when_no_italic_face_available() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let style = cranpose_ui::text::TextStyle {
            span_style: cranpose_ui::text::SpanStyle {
                font_family: Some(cranpose_ui::text::FontFamily::named("Noto Sans")),
                font_style: Some(cranpose_ui::text::FontStyle::Italic),
                ..Default::default()
            },
            ..Default::default()
        };

        let attrs = attrs_from_text_style(&style, 14.0, 1.0, &mut font_system, &mut resolver);
        // Noto Sans (test font) has no italic face → style stays Normal,
        // FAKE_ITALIC is set so the swash renderer applies 14° skew.
        assert_eq!(
            attrs.style,
            GlyphonStyle::Normal,
            "style must stay Normal for font matching when no italic face exists"
        );
        assert!(
            attrs
                .cache_key_flags
                .contains(glyphon::cosmic_text::CacheKeyFlags::FAKE_ITALIC),
            "FAKE_ITALIC must be set when the font family lacks a native italic face"
        );
    }

    #[test]
    fn attrs_resolution_preserves_requested_bold_for_synthesis() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let style = cranpose_ui::text::TextStyle {
            span_style: cranpose_ui::text::SpanStyle {
                font_family: Some(cranpose_ui::text::FontFamily::named("Noto Sans")),
                font_weight: Some(cranpose_ui::text::FontWeight::BOLD),
                ..Default::default()
            },
            ..Default::default()
        };

        let attrs = attrs_from_text_style(&style, 14.0, 1.0, &mut font_system, &mut resolver);
        assert_eq!(
            attrs.weight,
            GlyphonWeight(cranpose_ui::text::FontWeight::BOLD.0),
            "requested bold must be preserved in attrs so glyphon can synthesize it"
        );
    }

    #[test]
    fn span_level_italic_propagates_through_rich_text_ensure() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let mut text = cranpose_ui::text::AnnotatedString::from("normal italic");
        text.span_styles.push(cranpose_ui::text::RangeStyle {
            item: cranpose_ui::text::SpanStyle {
                font_style: Some(cranpose_ui::text::FontStyle::Italic),
                ..Default::default()
            },
            range: 7..13, // "italic"
        });
        let style = cranpose_ui::text::TextStyle::default();
        let style_hash = text_buffer_style_hash(&style, &text);
        let mut buffer = new_shared_text_buffer(&mut font_system, 14.0, 14.0 * 1.4);
        buffer.ensure(
            &mut font_system,
            &mut resolver,
            EnsureTextBufferParams {
                annotated_text: &text,
                font_size_px: 14.0,
                line_height_px: 14.0 * 1.4,
                style_hash,
                style: &style,
                scale: 1.0,
            },
        );
        // Check that the buffer's layout lines have FAKE_ITALIC flag on the italic span
        let has_fake_italic = buffer.buffer.layout_runs().any(|run| {
            run.glyphs.iter().any(|glyph| {
                glyph.start >= 7
                    && glyph
                        .cache_key_flags
                        .contains(glyphon::cosmic_text::CacheKeyFlags::FAKE_ITALIC)
            })
        });
        assert!(
            has_fake_italic,
            "span-level italic must produce FAKE_ITALIC glyphs when the font lacks native italic"
        );
    }

    #[test]
    fn bold_text_uses_bold_font_face_when_available() {
        let mut db = glyphon::fontdb::Database::new();
        db.load_font_data(TEST_FONT.to_vec());
        db.load_font_data(TEST_BOLD_FONT.to_vec());
        let mut font_system = FontSystem::new_with_locale_and_db("en-US".to_string(), db);
        let mut resolver = WgpuFontFamilyResolver::default();
        resolver.prime(&mut font_system);

        let style = cranpose_ui::text::TextStyle {
            span_style: cranpose_ui::text::SpanStyle {
                font_weight: Some(cranpose_ui::text::FontWeight::BOLD),
                ..Default::default()
            },
            ..Default::default()
        };
        let text = cranpose_ui::text::AnnotatedString::from("bold text");
        let style_hash = text_buffer_style_hash(&style, &text);
        let mut buffer = new_shared_text_buffer(&mut font_system, 14.0, 14.0 * 1.4);
        buffer.ensure(
            &mut font_system,
            &mut resolver,
            EnsureTextBufferParams {
                annotated_text: &text,
                font_size_px: 14.0,
                line_height_px: 14.0 * 1.4,
                style_hash,
                style: &style,
                scale: 1.0,
            },
        );
        let bold_face_used = buffer.buffer.layout_runs().any(|run| {
            run.glyphs.iter().any(|glyph| {
                font_system
                    .db()
                    .face(glyph.font_id)
                    .is_some_and(|face| face.weight.0 == 700)
            })
        });
        assert!(
            bold_face_used,
            "bold text must use the bold font face (weight 700) when available"
        );
    }

    #[test]
    fn attrs_from_text_style_applies_alpha_to_foreground_color() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let style = cranpose_ui::text::TextStyle::from_span_style(cranpose_ui::text::SpanStyle {
            color: Some(cranpose_ui::Color(0.2, 0.4, 0.6, 1.0)),
            alpha: Some(0.25),
            ..Default::default()
        });

        let attrs = attrs_from_text_style(&style, 14.0, 1.0, &mut font_system, &mut resolver);

        assert_eq!(
            attrs.color_opt,
            Some(glyphon::Color::rgba(51, 102, 153, 63)),
            "glyph attrs must track alpha-adjusted foreground color"
        );
    }

    #[test]
    fn attrs_from_text_style_disables_native_hinting() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let attrs = attrs_from_text_style(
            &cranpose_ui::text::TextStyle::default(),
            14.0,
            1.0,
            &mut font_system,
            &mut resolver,
        );

        assert!(
            attrs
                .cache_key_flags
                .contains(glyphon::cosmic_text::CacheKeyFlags::DISABLE_HINTING),
            "renderer text attrs should disable native hinting to keep glyph rasterization stable across scroll phases"
        );
    }

    #[test]
    fn text_buffer_style_hash_changes_when_top_level_color_changes() {
        let text = cranpose_ui::text::AnnotatedString::from("theme");
        let dark = cranpose_ui::text::TextStyle::from_span_style(cranpose_ui::text::SpanStyle {
            color: Some(cranpose_ui::Color::BLACK),
            ..Default::default()
        });
        let light = cranpose_ui::text::TextStyle::from_span_style(cranpose_ui::text::SpanStyle {
            color: Some(cranpose_ui::Color::WHITE),
            ..Default::default()
        });

        assert_ne!(
            text_buffer_style_hash(&dark, &text),
            text_buffer_style_hash(&light, &text),
            "color-only theme flips must invalidate glyph buffer caches"
        );
    }

    #[test]
    fn text_buffer_style_hash_changes_when_span_alpha_changes() {
        let mut opaque = cranpose_ui::text::AnnotatedString::from("theme");
        opaque.span_styles.push(cranpose_ui::text::RangeStyle {
            item: cranpose_ui::text::SpanStyle {
                color: Some(cranpose_ui::Color::BLACK),
                alpha: Some(1.0),
                ..Default::default()
            },
            range: 0..5,
        });

        let mut translucent = cranpose_ui::text::AnnotatedString::from("theme");
        translucent.span_styles.push(cranpose_ui::text::RangeStyle {
            item: cranpose_ui::text::SpanStyle {
                color: Some(cranpose_ui::Color::BLACK),
                alpha: Some(0.2),
                ..Default::default()
            },
            range: 0..5,
        });

        assert_ne!(
            text_buffer_style_hash(&cranpose_ui::text::TextStyle::default(), &opaque),
            text_buffer_style_hash(&cranpose_ui::text::TextStyle::default(), &translucent),
            "span alpha changes must invalidate glyph buffer caches"
        );
    }

    #[test]
    fn select_text_shaping_uses_basic_for_simple_text_when_requested() {
        let style =
            cranpose_ui::text::TextStyle::from_paragraph_style(cranpose_ui::text::ParagraphStyle {
                platform_style: Some(cranpose_ui::text::PlatformParagraphStyle {
                    include_font_padding: None,
                    shaping: Some(cranpose_ui::text::TextShaping::Basic),
                }),
                ..Default::default()
            });
        let text = cranpose_ui::text::AnnotatedString::from("• Item 0042: basic markdown text");

        assert_eq!(select_text_shaping(&text, &style), Shaping::Basic);
    }

    #[test]
    fn select_text_shaping_falls_back_to_advanced_for_complex_text() {
        let style =
            cranpose_ui::text::TextStyle::from_paragraph_style(cranpose_ui::text::ParagraphStyle {
                platform_style: Some(cranpose_ui::text::PlatformParagraphStyle {
                    include_font_padding: None,
                    shaping: Some(cranpose_ui::text::TextShaping::Basic),
                }),
                ..Default::default()
            });
        let text = cranpose_ui::text::AnnotatedString::from("emoji 😀 requires fallback");

        assert_eq!(select_text_shaping(&text, &style), Shaping::Advanced);
    }

    #[test]
    fn layout_matches_measure_without_reentrant_mutex_lock() {
        use std::sync::mpsc;
        use std::time::Duration;

        let (tx, rx) = mpsc::channel();
        std::thread::spawn(move || {
            let measurer = WgpuTextMeasurer::new(seeded_text_state());
            let text = cranpose_ui::text::AnnotatedString::from("hello\nworld");
            let style = cranpose_ui::text::TextStyle::default();

            let layout = measurer.layout(&text, &style);
            let metrics = measurer.measure(&text, &style);
            tx.send((
                layout.width,
                layout.height,
                layout.lines.len(),
                metrics.width,
                metrics.height,
                metrics.line_count,
            ))
            .expect("send layout metrics");
        });

        let (
            layout_width,
            layout_height,
            layout_lines,
            measured_width,
            measured_height,
            measured_lines,
        ) = rx
            .recv_timeout(Duration::from_secs(WORKER_TEST_TIMEOUT_SECS))
            .expect("layout timed out; possible recursive mutex acquisition");

        assert!((layout_width - measured_width).abs() < 0.5);
        assert!((layout_height - measured_height).abs() < 0.5);
        assert_eq!(layout_lines, measured_lines.max(1));
    }

    #[test]
    fn measure_with_options_fast_path_wraps_to_width() {
        use std::sync::mpsc;
        use std::time::Duration;

        let (tx, rx) = mpsc::channel();
        std::thread::spawn(move || {
            let measurer = WgpuTextMeasurer::new(seeded_text_state());
            let text = cranpose_ui::text::AnnotatedString::from("wrap me ".repeat(120));
            let style = cranpose_ui::text::TextStyle::default();
            let options = cranpose_ui::text::TextLayoutOptions {
                overflow: cranpose_ui::text::TextOverflow::Clip,
                soft_wrap: true,
                max_lines: usize::MAX,
                min_lines: 1,
            };
            let metrics =
                TextMeasurer::measure_with_options(&measurer, &text, &style, options, Some(120.0));
            tx.send((metrics.width, metrics.line_count))
                .expect("send wrapped metrics");
        });

        let (width, line_count) = rx
            .recv_timeout(Duration::from_secs(WORKER_TEST_TIMEOUT_SECS))
            .expect("measure_with_options timed out");
        assert!(width <= 120.5, "wrapped width should honor max width");
        assert!(line_count > 1, "wrapped text should produce multiple lines");
    }

    #[test]
    fn prepare_with_options_reuses_cached_layout() {
        use std::sync::mpsc;
        use std::time::Duration;

        let (tx, rx) = mpsc::channel();
        std::thread::spawn(move || {
            let measurer = WgpuTextMeasurer::new(seeded_text_state());
            let text = cranpose_ui::text::AnnotatedString::from(
                "This paragraph demonstrates wrapping with a cached prepared layout.",
            );
            let style = cranpose_ui::text::TextStyle::default();
            let options = cranpose_ui::text::TextLayoutOptions {
                overflow: cranpose_ui::text::TextOverflow::Clip,
                soft_wrap: true,
                max_lines: usize::MAX,
                min_lines: 1,
            };

            let first =
                TextMeasurer::prepare_with_options(&measurer, &text, &style, options, Some(96.0));
            let first_cache_len = measurer.prepared_layout_cache.borrow().len();

            let second =
                TextMeasurer::prepare_with_options(&measurer, &text, &style, options, Some(96.0));
            let second_cache_len = measurer.prepared_layout_cache.borrow().len();

            tx.send((
                first == second,
                first.text.text.contains('\n'),
                first_cache_len,
                second_cache_len,
            ))
            .expect("send prepared layout cache result");
        });

        let (same_layout, wrapped_text, first_cache_len, second_cache_len) = rx
            .recv_timeout(Duration::from_secs(WORKER_TEST_TIMEOUT_SECS))
            .expect("prepare_with_options timed out");
        assert!(same_layout, "cached prepared layout should be identical");
        assert!(
            wrapped_text,
            "prepared layout should preserve wrapped text output"
        );
        assert_eq!(first_cache_len, 1);
        assert_eq!(second_cache_len, 1);
    }

    #[test]
    fn measure_for_node_uses_node_cache_identity() {
        use std::sync::mpsc;
        use std::time::Duration;

        let (tx, rx) = mpsc::channel();
        std::thread::spawn(move || {
            let measurer = WgpuTextMeasurer::new(seeded_text_state());
            let text = cranpose_ui::text::AnnotatedString::from("shared node identity");
            let style = cranpose_ui::text::TextStyle::default();
            let node_id = 4242;

            let _ = TextMeasurer::measure_for_node(&measurer, Some(node_id), &text, &style);

            let font_size = resolve_font_size(&style);
            let style_hash = text_buffer_style_hash(&style, &text);
            let expected_key = TextCacheKey::for_node(node_id, font_size, style_hash);
            let text_state = measurer.text_state.lock().expect("text state lock");
            let cache = &text_state.text_cache;

            tx.send((
                cache.len(),
                cache.contains(&expected_key),
                cache
                    .iter()
                    .any(|(key, _)| matches!(key.key, TextKey::Content(_))),
            ))
            .expect("send node cache result");
        });

        let (cache_len, has_node_key, has_content_key) = rx
            .recv_timeout(Duration::from_secs(WORKER_TEST_TIMEOUT_SECS))
            .expect("measure_for_node timed out");
        assert_eq!(cache_len, 1);
        assert!(
            has_node_key,
            "node-aware measurement should populate node cache key"
        );
        assert!(
            !has_content_key,
            "node-aware measurement should not populate content cache keys"
        );
    }

    #[test]
    fn renderer_measurement_keeps_render_text_cache_empty() {
        let (tx, rx) = mpsc::channel();
        std::thread::spawn(move || {
            let renderer = WgpuRenderer::new(&[TEST_FONT]);
            let text = cranpose_ui::text::AnnotatedString::from("phase local text cache");
            let style = cranpose_ui::text::TextStyle::default();

            let _ = cranpose_ui::text::measure_text(&text, &style);

            tx.send(renderer.render_text_state.lock().unwrap().text_cache.len())
                .expect("send render text cache size");
        });

        let render_text_cache_len = rx
            .recv_timeout(Duration::from_secs(WORKER_TEST_TIMEOUT_SECS))
            .expect("renderer measurement isolation timed out");
        assert_eq!(
            render_text_cache_len, 0,
            "measurement should not populate render-owned text cache"
        );
    }

    #[test]
    fn shared_text_cache_uses_bounded_lru_eviction() {
        let mut font_system = FontSystem::new();
        let mut cache = LruCache::new(NonZeroUsize::new(SHARED_TEXT_CACHE_CAPACITY).unwrap());

        for index in 0..=SHARED_TEXT_CACHE_CAPACITY {
            let text = format!("cache-entry-{index}");
            let key = TextCacheKey::new(text.as_str(), 14.0, 7);
            let _ = shared_text_buffer_mut(&mut cache, key, &mut font_system, 14.0, 16.0);
        }

        let oldest = TextCacheKey::new("cache-entry-0", 14.0, 7);
        let newest = TextCacheKey::new(
            format!("cache-entry-{}", SHARED_TEXT_CACHE_CAPACITY).as_str(),
            14.0,
            7,
        );

        assert_eq!(cache.len(), SHARED_TEXT_CACHE_CAPACITY);
        assert!(!cache.contains(&oldest));
        assert!(cache.contains(&newest));
    }

    // Font bytes used by tests — the same file the demo app ships.
    static TEST_FONT: &[u8] =
        include_bytes!("../../../../apps/desktop-demo/assets/NotoSansMerged.ttf");
    static TEST_BOLD_FONT: &[u8] =
        include_bytes!("../../../../apps/desktop-demo/assets/NotoSansBold.ttf");
    static TEST_EMOJI_FONT: &[u8] =
        include_bytes!("../../../../apps/desktop-demo/assets/TwemojiMozilla.ttf");

    fn empty_font_system() -> FontSystem {
        let db = glyphon::fontdb::Database::new();
        FontSystem::new_with_locale_and_db("en-US".to_string(), db)
    }

    #[test]
    fn load_fonts_populates_face_db() {
        let mut fs = empty_font_system();
        load_fonts(&mut fs, &[TEST_FONT]);
        assert!(
            fs.db().faces().count() > 0,
            "load_fonts must load at least one face"
        );
    }

    #[test]
    fn load_fonts_empty_slice_leaves_db_empty() {
        let mut fs = empty_font_system();
        load_fonts(&mut fs, &[]);
        assert_eq!(
            fs.db().faces().count(),
            0,
            "empty slice must not load any faces"
        );
    }

    fn queried_family_name(font_system: &FontSystem, family: glyphon::fontdb::Family) -> String {
        let query = glyphon::fontdb::Query {
            families: &[family],
            weight: glyphon::fontdb::Weight::NORMAL,
            stretch: glyphon::fontdb::Stretch::Normal,
            style: glyphon::fontdb::Style::Normal,
        };
        let face_id = font_system
            .db()
            .query(&query)
            .expect("generic family should resolve to a face");
        let face = font_system
            .db()
            .face(face_id)
            .expect("queried face id should exist");
        face.families
            .first()
            .map(|(name, _)| name.clone())
            .expect("queried face should carry a family name")
    }

    #[test]
    fn generic_fallbacks_prefer_loaded_font_family_over_existing_faces() {
        let mut font_system = empty_font_system();
        load_fonts(&mut font_system, &[TEST_EMOJI_FONT, TEST_FONT]);
        let mut resolver = WgpuFontFamilyResolver::default();
        resolver.set_preferred_generic_family(primary_family_name_from_bytes(TEST_FONT));
        resolver.prime(&mut font_system);

        let generic_serif = queried_family_name(&font_system, glyphon::fontdb::Family::Serif);
        let expected = primary_family_name_from_bytes(TEST_FONT)
            .expect("test font should resolve to a family name");
        assert_eq!(generic_serif, expected);
    }

    #[test]
    fn resolver_logs_warning_if_font_db_is_empty() {
        // With no fonts loaded the resolver should not panic; it just warns.
        let mut font_system = empty_font_system();
        let mut resolver = WgpuFontFamilyResolver::default();
        let span_style = cranpose_ui::text::SpanStyle::default();
        // Must not panic even with an empty DB.
        let _ = resolver.resolve_family_owned(&mut font_system, &span_style);
    }

    #[test]
    #[cfg(not(target_arch = "wasm32"))]
    fn attrs_resolution_loads_file_backed_family_from_path() {
        let (mut font_system, mut resolver) = seeded_font_system_and_resolver();
        let nonce = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .map(|duration| duration.as_nanos())
            .unwrap_or_default();
        let unique_path = format!(
            "{}/cranpose-font-resolver-{}-{}.ttf",
            std::env::temp_dir().display(),
            std::process::id(),
            nonce
        );
        std::fs::write(&unique_path, TEST_FONT).expect("write font fixture");

        let style = cranpose_ui::text::TextStyle {
            span_style: cranpose_ui::text::SpanStyle {
                font_family: Some(cranpose_ui::text::FontFamily::file_backed(vec![
                    cranpose_ui::text::FontFile::new(unique_path.clone()),
                ])),
                ..Default::default()
            },
            ..Default::default()
        };

        let attrs = attrs_from_text_style(&style, 14.0, 1.0, &mut font_system, &mut resolver);
        assert!(
            matches!(attrs.family_owned, FamilyOwned::Name(_)),
            "file-backed font family should resolve to an installed family name"
        );

        let _ = std::fs::remove_file(&unique_path);
    }
}