relay_event_normalization/

event.rs

//! Event normalization.
//!
//! This module provides a function to normalize events.

use std::collections::hash_map::DefaultHasher;

use std::hash::{Hash, Hasher};
use std::mem;
use std::sync::OnceLock;

use itertools::Itertools;
use regex::Regex;
use relay_base_schema::metrics::{
    DurationUnit, FractionUnit, MetricUnit, can_be_valid_metric_name,
};
use relay_conventions::attributes::{
    APP__VITALS__START__COLD__VALUE, APP__VITALS__START__SCREEN, APP__VITALS__START__TYPE,
    APP__VITALS__START__VALUE, APP__VITALS__START__WARM__VALUE, SCORE__TOTAL,
};
use relay_conventions::interpolate;
use relay_conventions::measurements::{
    APP_START_COLD, APP_START_WARM, FRAMES_FROZEN, FRAMES_FROZEN_RATE, FRAMES_SLOW,
    FRAMES_SLOW_RATE, FRAMES_TOTAL, STALL_PERCENTAGE,
};
use relay_event_schema::processor::{self, ProcessingAction, ProcessingState, Processor};
use relay_event_schema::protocol::{
    AsPair, Attributes, AutoInferSetting, ClientSdkInfo, Contexts, DebugImage, DeviceClass, Event,
    EventId, EventType, Exception, Headers, IpAddr, Level, LogEntry, Measurement, Measurements,
    PerformanceScoreContext, ReplayContext, Request, Span, SpanId, SpanV2, Tags, Timestamp,
    TraceContext, TraceId, User, VALID_PLATFORMS,
};
use relay_protocol::{
    Annotated, Empty, Error, ErrorKind, FiniteF64, FromValue, Getter, Meta, Object, Remark,
    RemarkType, TryFromFloatError, Value,
};
use smallvec::SmallVec;
use uuid::Uuid;

use crate::normalize::request;
use crate::span::ai::enrich_ai_event_data;
use crate::span::tag_extraction::{extract_segment_name_from_event, extract_span_tags_from_event};
use crate::utils::{self, MAX_DURATION_MOBILE_MS, get_event_user_tag};
use crate::{
    BorrowedSpanOpDefaults, BreakdownsConfig, CombinedMeasurementsConfig, EnrichedDsc, GeoIpLookup,
    MaxChars, ModelMetadata, PerformanceScoreConfig, RawUserAgentInfo, SpanDescriptionRule,
    TransactionNameConfig, breakdowns, event_error, legacy, mechanism, remove_other, schema, span,
    stacktrace, transactions, trimming, user_agent,
};

/// Configuration for [`normalize_event`].
#[derive(Clone, Debug)]
pub struct NormalizationConfig<'a> {
    /// The identifier of the target project, which gets added to the payload.
    pub project_id: Option<u64>,

    /// The name and version of the SDK that sent the event.
    pub client: Option<String>,

    /// The internal identifier of the DSN, which gets added to the payload.
    ///
    /// Note that this is different from the DSN's public key. The ID is usually numeric.
    pub key_id: Option<String>,

    /// The version of the protocol.
    ///
    /// This is a deprecated field, as there is no more versioning of Relay event payloads.
    pub protocol_version: Option<String>,

    /// Configuration for issue grouping.
    ///
    /// This configuration is persisted into the event payload to achieve idempotency in the
    /// processing pipeline and for reprocessing.
    pub grouping_config: Option<serde_json::Value>,

    /// The IP address of the SDK that sent the event.
    ///
    /// When `{{auto}}` is specified and there is no other IP address in the payload, such as in the
    /// `request` context, this IP address gets added to the `user` context.
    pub client_ip: Option<&'a IpAddr>,

    /// Specifies whether the client_ip should be used to determine the ip address of the user.
    pub infer_ip_address: bool,

    /// The SDK's sample rate as communicated via envelope headers.
    ///
    /// It is persisted into the event payload.
    pub client_sample_rate: Option<f64>,

    /// The user-agent and client hints obtained from the submission request headers.
    ///
    /// Client hints are the preferred way to infer device, operating system, and browser
    /// information should the event payload contain no such data. If no client hints are present,
    /// normalization falls back to the user agent.
    pub user_agent: RawUserAgentInfo<&'a str>,

    /// The maximum length for names of custom measurements.
    ///
    /// Measurements with longer names are removed from the transaction event and replaced with a
    /// metadata entry.
    pub max_name_and_unit_len: Option<usize>,

    /// Configuration for measurement normalization in transaction events.
    ///
    /// Has an optional [`crate::MeasurementsConfig`] from both the project and the global level.
    /// If at least one is provided, then normalization will truncate custom measurements
    /// and add units of known built-in measurements.
    pub measurements: Option<CombinedMeasurementsConfig<'a>>,

    /// Emit breakdowns based on given configuration.
    pub breakdowns_config: Option<&'a BreakdownsConfig>,

    /// When `Some(true)`, context information is extracted from the user agent.
    pub normalize_user_agent: Option<bool>,

    /// Configuration to apply to transaction names, especially around sanitizing.
    pub transaction_name_config: TransactionNameConfig<'a>,

    /// When `true`, it is assumed that the event has been normalized before.
    ///
    /// This disables certain normalizations, especially all that are not idempotent. The
    /// renormalize mode is intended for the use in the processing pipeline, so an event modified
    /// during ingestion can be validated against the schema and large data can be trimmed. However,
    /// advanced normalizations such as inferring contexts or clock drift correction are disabled.
    pub is_renormalize: bool,

    /// Overrides the default flag for other removal.
    pub remove_other: bool,

    /// When enabled, adds errors in the meta to the event's errors.
    pub emit_event_errors: bool,

    /// When `true`, extracts tags from event and spans and materializes them into `span.data`.
    pub enrich_spans: bool,

    /// The maximum allowed size of tag values in bytes. Longer values will be cropped.
    pub max_tag_value_length: usize, // TODO: move span related fields into separate config.

    /// Configuration for replacing identifiers in the span description with placeholders.
    ///
    /// This is similar to `transaction_name_config`, but applies to span descriptions.
    pub span_description_rules: Option<&'a Vec<SpanDescriptionRule>>,

    /// Configuration for generating performance score measurements for web vitals.
    pub performance_score: Option<&'a PerformanceScoreConfig>,

    /// Metadata for AI models including costs and context size.
    pub ai_model_metadata: Option<&'a ModelMetadata>,

    /// An initialized GeoIP lookup.
    pub geoip_lookup: Option<&'a GeoIpLookup>,

    /// When `Some(true)`, individual parts of the event payload is trimmed to a maximum size.
    ///
    /// See the event schema for size declarations.
    pub enable_trimming: bool,

    /// Controls whether spans should be normalized (e.g. normalizing the exclusive time).
    ///
    /// To normalize spans, `is_renormalize` must be disabled _and_ `normalize_spans` enabled.
    pub normalize_spans: bool,

    /// The identifier of the Replay running while this event was created.
    ///
    /// It is persisted into the event payload for correlation.
    pub replay_id: Option<Uuid>,

    /// Controls list of hosts to be excluded from scrubbing.
    pub span_allowed_hosts: &'a [String],

    /// Rules to infer `span.op` from other span fields.
    pub span_op_defaults: BorrowedSpanOpDefaults<'a>,

    /// Forces a valid trace context for error events.
    ///
    /// Sentry requires a valid trace context for events. This ensures a valid trace context always
    /// exists.
    ///
    /// If the error does not contain a trace context, one will be created. If there is already an
    /// existing trace context, it ensures it's valid and has a trace id.
    ///
    /// This is never applied to transaction events, which require a valid transaction context from
    /// the SDK.
    pub force_trace_context: bool,

    /// Dynamic sampling context and additional attributes used for dsc span normalization.
    pub dsc: Option<EnrichedDsc<'a>>,
}

impl Default for NormalizationConfig<'_> {
    fn default() -> Self {
        Self {
            project_id: Default::default(),
            client: Default::default(),
            key_id: Default::default(),
            protocol_version: Default::default(),
            grouping_config: Default::default(),
            client_ip: Default::default(),
            infer_ip_address: true,
            client_sample_rate: Default::default(),
            user_agent: Default::default(),
            max_name_and_unit_len: Default::default(),
            breakdowns_config: Default::default(),
            normalize_user_agent: Default::default(),
            transaction_name_config: Default::default(),
            is_renormalize: Default::default(),
            remove_other: Default::default(),
            emit_event_errors: Default::default(),
            enrich_spans: Default::default(),
            max_tag_value_length: usize::MAX,
            span_description_rules: Default::default(),
            performance_score: Default::default(),
            geoip_lookup: Default::default(),
            ai_model_metadata: Default::default(),
            enable_trimming: false,
            measurements: None,
            normalize_spans: true,
            replay_id: Default::default(),
            span_allowed_hosts: Default::default(),
            span_op_defaults: Default::default(),
            force_trace_context: Default::default(),
            dsc: None,
        }
    }
}

/// Normalizes an event.
///
/// Normalization consists of applying a series of transformations on the event
/// payload based on the given configuration.
pub fn normalize_event(event: &mut Annotated<Event>, config: &NormalizationConfig) {
    let Annotated(Some(event), meta) = event else {
        return;
    };

    let is_renormalize = config.is_renormalize;

    // Convert legacy data structures to current format
    let _ = legacy::LegacyProcessor.process_event(event, meta, ProcessingState::root());

    if !is_renormalize {
        // Check for required and non-empty values
        let _ = schema::SchemaProcessor::new().process_event(event, meta, ProcessingState::root());

        normalize(event, meta, config);
    }

    if config.enable_trimming {
        // Trim large strings and databags down
        let _ =
            trimming::TrimmingProcessor::new().process_event(event, meta, ProcessingState::root());
    }

    if config.remove_other {
        // Remove unknown attributes at every level
        let _ =
            remove_other::RemoveOtherProcessor.process_event(event, meta, ProcessingState::root());
    }

    if config.emit_event_errors {
        // Add event errors for top-level keys
        let _ =
            event_error::EmitEventErrors::new().process_event(event, meta, ProcessingState::root());
    }
}

/// Normalizes the given event based on the given config.
fn normalize(event: &mut Event, meta: &mut Meta, config: &NormalizationConfig) {
    // Normalize the transaction.
    // (internally noops for non-transaction events).
    // TODO: Parts of this processor should probably be a filter so we
    // can revert some changes to ProcessingAction)
    let mut transactions_processor = transactions::TransactionsProcessor::new(
        config.transaction_name_config,
        config.span_op_defaults,
    );
    let _ = transactions_processor.process_event(event, meta, ProcessingState::root());

    let client_ip = config.client_ip.filter(|_| config.infer_ip_address);

    // Process security reports first to ensure all props.
    normalize_security_report(event, client_ip, &config.user_agent);

    // Insert IP addrs before recursing, since geo lookup depends on it.
    normalize_ip_addresses(
        &mut event.request,
        &mut event.user,
        event.platform.as_str(),
        client_ip,
        event.client_sdk.value(),
    );

    if let Some(geoip_lookup) = config.geoip_lookup {
        normalize_user_geoinfo(geoip_lookup, &mut event.user, config.client_ip);
    }

    // Validate the basic attributes we extract metrics from
    let _ = processor::apply(&mut event.release, |release, meta| {
        if crate::validate_release(release).is_ok() {
            Ok(())
        } else {
            meta.add_error(ErrorKind::InvalidData);
            Err(ProcessingAction::DeleteValueSoft)
        }
    });
    let _ = processor::apply(&mut event.environment, |environment, meta| {
        if crate::validate_environment(environment).is_ok() {
            Ok(())
        } else {
            meta.add_error(ErrorKind::InvalidData);
            Err(ProcessingAction::DeleteValueSoft)
        }
    });

    // Default required attributes, even if they have errors
    normalize_user(event);
    normalize_logentry(&mut event.logentry, meta);
    normalize_debug_meta(event);
    normalize_breadcrumbs(event);
    normalize_release_dist(event); // dist is a tag extracted along with other metrics from transactions
    normalize_event_tags(event); // Tags are added to every metric

    // TODO: Consider moving to store normalization
    normalize_device_class(event);
    normalize_stacktraces(event);
    normalize_exceptions(event); // Browser extension filters look at the stacktrace
    normalize_user_agent(event, config.normalize_user_agent); // Legacy browsers filter
    normalize_event_measurements(event, config.measurements, config.max_name_and_unit_len); // Measurements are part of the metric extraction
    backfill_app_vitals_start(event);
    if let Some(version) = normalize_performance_score(event, config.performance_score) {
        event
            .contexts
            .get_or_insert_with(Contexts::new)
            .get_or_default::<PerformanceScoreContext>()
            .score_profile_version = Annotated::new(version);
    }
    enrich_ai_event_data(event, config.ai_model_metadata);
    normalize_breakdowns(event, config.breakdowns_config); // Breakdowns are part of the metric extraction too
    normalize_default_attributes(event, meta, config);
    normalize_trace_context_tags(event);
    normalize_replay_context(event, config.replay_id);

    let _ = processor::apply(&mut event.request, |request, _| {
        request::normalize_request(request);
        Ok(())
    });

    if config.force_trace_context && event.ty.value() != Some(&EventType::Transaction) {
        normalize_force_trace_context(event);
    }

    // Some contexts need to be normalized before metrics extraction takes place.
    normalize_contexts(&mut event.contexts);

    if config.normalize_spans && event.ty.value() == Some(&EventType::Transaction) {
        span::normalize_dsc_for_event_spans(event, config.dsc);
        span::normalize_app_start_spans(event);
        span::exclusive_time::compute_span_exclusive_time(event);
    }

    if config.enrich_spans {
        extract_span_tags_from_event(
            event,
            config.max_tag_value_length,
            config.span_allowed_hosts,
        );
        extract_segment_name_from_event(event);
    }

    if let Some(context) = event.context_mut::<TraceContext>() {
        context.client_sample_rate = Annotated::from(config.client_sample_rate);
    }
}

fn normalize_replay_context(event: &mut Event, replay_id: Option<Uuid>) {
    if let Some(replay_id) = replay_id {
        let contexts = event.contexts.get_or_insert_with(Contexts::default);
        contexts.add(ReplayContext {
            replay_id: Annotated::new(EventId(replay_id)),
            other: Object::default(),
        });
    }
}

/// Backfills common security report attributes.
fn normalize_security_report(
    event: &mut Event,
    client_ip: Option<&IpAddr>,
    user_agent: &RawUserAgentInfo<&str>,
) {
    if !is_security_report(event) {
        // This event is not a security report, exit here.
        return;
    }

    event.logger.get_or_insert_with(|| "csp".to_owned());

    if let Some(client_ip) = client_ip {
        let user = event.user.value_mut().get_or_insert_with(User::default);
        user.ip_address = Annotated::new(client_ip.to_owned());
    }

    if !user_agent.is_empty() {
        let headers = event
            .request
            .value_mut()
            .get_or_insert_with(Request::default)
            .headers
            .value_mut()
            .get_or_insert_with(Headers::default);

        user_agent.populate_event_headers(headers);
    }
}

fn is_security_report(event: &Event) -> bool {
    event.csp.value().is_some()
        || event.expectct.value().is_some()
        || event.expectstaple.value().is_some()
        || event.hpkp.value().is_some()
}

/// Backfills IP addresses in various places.
pub fn normalize_ip_addresses(
    request: &mut Annotated<Request>,
    user: &mut Annotated<User>,
    platform: Option<&str>,
    client_ip: Option<&IpAddr>,
    client_sdk_settings: Option<&ClientSdkInfo>,
) {
    let infer_ip = client_sdk_settings
        .and_then(|c| c.settings.0.as_ref())
        .map(|s| s.infer_ip())
        .unwrap_or_default();

    // If infer_ip is set to Never then we just remove auto and don't continue
    if let AutoInferSetting::Never = infer_ip {
        // No user means there is also no IP so we can stop here
        let Some(user) = user.value_mut() else {
            return;
        };
        // If there is no IP we can also stop
        let Some(ip) = user.ip_address.value() else {
            return;
        };
        if ip.is_auto() {
            user.ip_address.0 = None;
            return;
        }
    }

    let remote_addr_ip = request
        .value()
        .and_then(|r| r.env.value())
        .and_then(|env| env.get("REMOTE_ADDR"))
        .and_then(Annotated::<Value>::as_str)
        .and_then(|ip| IpAddr::parse(ip).ok());

    // IP address in REMOTE_ADDR will have precedence over client_ip because it's explicitly
    // sent while client_ip is taken from X-Forwarded-For headers or the connection IP.
    let inferred_ip = remote_addr_ip.as_ref().or(client_ip);

    // We will infer IP addresses if:
    // * The IP address is {{auto}}
    // * the infer_ip setting is set to "auto"
    let should_be_inferred = match user.value() {
        Some(user) => match user.ip_address.value() {
            Some(ip) => ip.is_auto(),
            None => matches!(infer_ip, AutoInferSetting::Auto),
        },
        None => matches!(infer_ip, AutoInferSetting::Auto),
    };

    if should_be_inferred && let Some(ip) = inferred_ip {
        let user = user.get_or_insert_with(User::default);
        user.ip_address.set_value(Some(ip.to_owned()));
    }

    // Legacy behaviour:
    // * Backfill if there is a REMOTE_ADDR and the user.ip_address was not backfilled until now
    // * Empty means {{auto}} for some SDKs
    if infer_ip == AutoInferSetting::Legacy {
        if let Some(http_ip) = remote_addr_ip {
            let user = user.get_or_insert_with(User::default);
            user.ip_address.value_mut().get_or_insert(http_ip);
        } else if let Some(client_ip) = inferred_ip {
            let user = user.get_or_insert_with(User::default);
            // auto is already handled above
            if user.ip_address.value().is_none() {
                // Only assume that empty means {{auto}} if there is no remark that the IP address has been removed.
                let scrubbed_before = user
                    .ip_address
                    .meta()
                    .iter_remarks()
                    .any(|r| r.ty == RemarkType::Removed);
                if !scrubbed_before {
                    // In an ideal world all SDKs would set {{auto}} explicitly.
                    if let Some("javascript") | Some("cocoa") | Some("objc") = platform {
                        user.ip_address = Annotated::new(client_ip.to_owned());
                    }
                }
            }
        }
    }
}

/// Sets the user's GeoIp info based on user's IP address.
pub fn normalize_user_geoinfo(
    geoip_lookup: &GeoIpLookup,
    user: &mut Annotated<User>,
    ip_addr: Option<&IpAddr>,
) {
    let user = user.value_mut().get_or_insert_with(User::default);
    // The event was already populated with geo information so we don't have to do anything.
    if user.geo.value().is_some() {
        return;
    }
    if let Some(ip_address) = user
        .ip_address
        .value()
        .filter(|ip| !ip.is_auto())
        .or(ip_addr)
        .and_then(|ip| ip.as_str().parse().ok())
        && let Some(geo) = geoip_lookup.lookup(ip_address)
    {
        user.geo.set_value(Some(geo));
    }
}

fn normalize_user(event: &mut Event) {
    let Annotated(Some(user), _) = &mut event.user else {
        return;
    };

    if !user.other.is_empty() {
        let data = user.data.value_mut().get_or_insert_with(Object::new);
        data.extend(std::mem::take(&mut user.other));
    }

    // We set the `sentry_user` field in the `Event` payload in order to have it ready for the extraction
    // pipeline.
    let event_user_tag = get_event_user_tag(user);
    user.sentry_user.set_value(event_user_tag);
}

fn normalize_logentry(logentry: &mut Annotated<LogEntry>, _meta: &mut Meta) {
    let _ = processor::apply(logentry, |logentry, meta| {
        crate::logentry::normalize_logentry(logentry, meta)
    });
}

/// Normalizes the debug images in the event's debug meta.
fn normalize_debug_meta(event: &mut Event) {
    let Annotated(Some(debug_meta), _) = &mut event.debug_meta else {
        return;
    };
    let Annotated(Some(debug_images), _) = &mut debug_meta.images else {
        return;
    };

    for annotated_image in debug_images {
        let _ = processor::apply(annotated_image, |image, meta| match image {
            DebugImage::Other(_) => {
                meta.add_error(Error::invalid("unsupported debug image type"));
                Err(ProcessingAction::DeleteValueSoft)
            }
            _ => Ok(()),
        });
    }
}

fn normalize_breadcrumbs(event: &mut Event) {
    let Annotated(Some(breadcrumbs), _) = &mut event.breadcrumbs else {
        return;
    };
    let Some(breadcrumbs) = breadcrumbs.values.value_mut() else {
        return;
    };

    for annotated_breadcrumb in breadcrumbs {
        let Annotated(Some(breadcrumb), _) = annotated_breadcrumb else {
            continue;
        };

        if breadcrumb.ty.value().is_empty() {
            breadcrumb.ty.set_value(Some("default".to_owned()));
        }
        if breadcrumb.level.value().is_none() {
            breadcrumb.level.set_value(Some(Level::Info));
        }
    }
}

/// Ensures that the `release` and `dist` fields match up.
fn normalize_release_dist(event: &mut Event) {
    normalize_dist(&mut event.dist);
}

fn normalize_dist(distribution: &mut Annotated<String>) {
    let _ = processor::apply(distribution, |dist, meta| {
        let trimmed = dist.trim();
        if trimmed.is_empty() {
            return Err(ProcessingAction::DeleteValueHard);
        } else if bytecount::num_chars(trimmed.as_bytes()) > MaxChars::Distribution.limit() {
            meta.add_error(Error::new(ErrorKind::ValueTooLong));
            return Err(ProcessingAction::DeleteValueSoft);
        } else if trimmed != dist {
            *dist = trimmed.to_owned();
        }
        Ok(())
    });
}

struct DedupCache(SmallVec<[u64; 16]>);

impl DedupCache {
    pub fn new() -> Self {
        Self(SmallVec::default())
    }

    pub fn probe<H: Hash>(&mut self, element: H) -> bool {
        let mut hasher = DefaultHasher::new();
        element.hash(&mut hasher);
        let hash = hasher.finish();

        if self.0.contains(&hash) {
            false
        } else {
            self.0.push(hash);
            true
        }
    }
}

/// Removes internal tags and adds tags for well-known attributes.
fn normalize_event_tags(event: &mut Event) {
    let tags = &mut event.tags.value_mut().get_or_insert_with(Tags::default).0;
    let environment = &mut event.environment;
    if environment.is_empty() {
        *environment = Annotated::empty();
    }

    // Fix case where legacy apps pass environment as a tag instead of a top level key
    if let Some(tag) = tags.remove("environment").and_then(Annotated::into_value) {
        environment.get_or_insert_with(|| tag);
    }

    // Remove internal tags, that are generated with a `sentry:` prefix when saving the event.
    // They are not allowed to be set by the client due to ambiguity. Also, deduplicate tags.
    let mut tag_cache = DedupCache::new();
    tags.retain(|entry| {
        match entry.value() {
            Some(tag) => match tag.key() {
                Some("release") | Some("dist") | Some("user") | Some("filename")
                | Some("function") => false,
                name => tag_cache.probe(name),
            },
            // ToValue will decide if we should skip serializing Annotated::empty()
            None => true,
        }
    });

    for tag in tags.iter_mut() {
        let _ = processor::apply(tag, |tag, _| {
            if let Some(key) = tag.key()
                && key.is_empty()
            {
                tag.0 = Annotated::from_error(Error::nonempty(), None);
            }

            if let Some(value) = tag.value()
                && value.is_empty()
            {
                tag.1 = Annotated::from_error(Error::nonempty(), None);
            }

            Ok(())
        });
    }

    let server_name = std::mem::take(&mut event.server_name);
    if server_name.value().is_some() {
        let tag_name = "server_name".to_owned();
        tags.insert(tag_name, server_name);
    }

    let site = std::mem::take(&mut event.site);
    if site.value().is_some() {
        let tag_name = "site".to_owned();
        tags.insert(tag_name, site);
    }
}

// Reads device specs (family, memory, cpu, etc) from context and sets the device.class tag to high,
// medium, or low.
fn normalize_device_class(event: &mut Event) {
    let tags = &mut event.tags.value_mut().get_or_insert_with(Tags::default).0;
    let tag_name = "device.class".to_owned();
    // Remove any existing device.class tag set by the client, since this should only be set by relay.
    tags.remove("device.class");
    if let Some(contexts) = event.contexts.value()
        && let Some(device_class) = DeviceClass::from_contexts(contexts)
    {
        tags.insert(tag_name, Annotated::new(device_class.to_string()));
    }
}

/// Normalizes all the stack traces in the given event.
///
/// Normalized stack traces are `event.stacktrace`, `event.exceptions.stacktrace`, and
/// `event.thread.stacktrace`. Raw stack traces are not normalized.
fn normalize_stacktraces(event: &mut Event) {
    normalize_event_stacktrace(event);
    normalize_exception_stacktraces(event);
    normalize_thread_stacktraces(event);
}

/// Normalizes an event's stack trace, in `event.stacktrace`.
fn normalize_event_stacktrace(event: &mut Event) {
    let Annotated(Some(stacktrace), meta) = &mut event.stacktrace else {
        return;
    };
    stacktrace::normalize_stacktrace(&mut stacktrace.0, meta);
}

/// Normalizes the stack traces in an event's exceptions, in `event.exceptions.stacktraces`.
///
/// Note: the raw stack traces, in `event.exceptions.raw_stacktraces` is not normalized.
fn normalize_exception_stacktraces(event: &mut Event) {
    let Some(event_exception) = event.exceptions.value_mut() else {
        return;
    };
    let Some(exceptions) = event_exception.values.value_mut() else {
        return;
    };
    for annotated_exception in exceptions {
        let Some(exception) = annotated_exception.value_mut() else {
            continue;
        };
        if let Annotated(Some(stacktrace), meta) = &mut exception.stacktrace {
            stacktrace::normalize_stacktrace(&mut stacktrace.0, meta);
        }
    }
}

/// Normalizes the stack traces in an event's threads, in `event.threads.stacktraces`.
///
/// Note: the raw stack traces, in `event.threads.raw_stacktraces`, is not normalized.
fn normalize_thread_stacktraces(event: &mut Event) {
    let Some(event_threads) = event.threads.value_mut() else {
        return;
    };
    let Some(threads) = event_threads.values.value_mut() else {
        return;
    };
    for annotated_thread in threads {
        let Some(thread) = annotated_thread.value_mut() else {
            continue;
        };
        if let Annotated(Some(stacktrace), meta) = &mut thread.stacktrace {
            stacktrace::normalize_stacktrace(&mut stacktrace.0, meta);
        }
    }
}

fn normalize_exceptions(event: &mut Event) {
    let os_hint = mechanism::OsHint::from_event(event);

    if let Some(exception_values) = event.exceptions.value_mut()
        && let Some(exceptions) = exception_values.values.value_mut()
    {
        if exceptions.len() == 1
            && event.stacktrace.value().is_some()
            && let Some(exception) = exceptions.get_mut(0)
            && let Some(exception) = exception.value_mut()
        {
            mem::swap(&mut exception.stacktrace, &mut event.stacktrace);
            event.stacktrace = Annotated::empty();
        }

        // Exception mechanism needs SDK information to resolve proper names in
        // exception meta (such as signal names). "SDK Information" really means
        // the operating system version the event was generated on. Some
        // normalization still works without sdk_info, such as mach_exception
        // names (they can only occur on macOS).
        //
        // We also want to validate some other aspects of it.
        for exception in exceptions {
            normalize_exception(exception);
            if let Some(exception) = exception.value_mut()
                && let Some(mechanism) = exception.mechanism.value_mut()
            {
                mechanism::normalize_mechanism(mechanism, os_hint);
            }
        }
    }
}

fn normalize_exception(exception: &mut Annotated<Exception>) {
    static TYPE_VALUE_RE: OnceLock<Regex> = OnceLock::new();
    let regex = TYPE_VALUE_RE.get_or_init(|| Regex::new(r"^(\w+):(.*)$").unwrap());

    let _ = processor::apply(exception, |exception, meta| {
        if exception.ty.value().is_empty()
            && let Some(value_str) = exception.value.value_mut()
        {
            let new_values = regex
                .captures(value_str)
                .map(|cap| (cap[1].to_string(), cap[2].trim().to_owned().into()));

            if let Some((new_type, new_value)) = new_values {
                exception.ty.set_value(Some(new_type));
                *value_str = new_value;
            }
        }

        if exception.ty.value().is_empty() && exception.value.value().is_empty() {
            meta.add_error(Error::with(ErrorKind::MissingAttribute, |error| {
                error.insert("attribute", "type or value");
            }));
            return Err(ProcessingAction::DeleteValueSoft);
        }

        Ok(())
    });
}

fn normalize_user_agent(_event: &mut Event, normalize_user_agent: Option<bool>) {
    if normalize_user_agent.unwrap_or(false) {
        user_agent::normalize_user_agent(_event);
    }
}

/// Ensures measurements interface is only present for transaction events.
fn normalize_event_measurements(
    event: &mut Event,
    measurements_config: Option<CombinedMeasurementsConfig>,
    max_mri_len: Option<usize>,
) {
    if event.ty.value() != Some(&EventType::Transaction) {
        // Only transaction events may have a measurements interface
        event.measurements = Annotated::empty();
    } else if let Annotated(Some(ref mut measurements), ref mut meta) = event.measurements {
        normalize_measurements(
            measurements,
            meta,
            measurements_config,
            max_mri_len,
            event.start_timestamp.0,
            event.timestamp.0,
        );
    }
}

/// Ensure only valid measurements are ingested.
pub fn normalize_measurements(
    measurements: &mut Measurements,
    meta: &mut Meta,
    measurements_config: Option<CombinedMeasurementsConfig>,
    max_mri_len: Option<usize>,
    start_timestamp: Option<Timestamp>,
    end_timestamp: Option<Timestamp>,
) {
    normalize_mobile_measurements(measurements);
    normalize_units(measurements);

    let duration_millis = start_timestamp.zip(end_timestamp).and_then(|(start, end)| {
        FiniteF64::new(relay_common::time::chrono_to_positive_millis(end - start))
    });

    compute_measurements(duration_millis, measurements);
    if let Some(measurements_config) = measurements_config {
        remove_invalid_measurements(measurements, meta, measurements_config, max_mri_len);
    }
}

/// Trait for containers that behave like a collection of [`Measurement`]s.
///
/// This exists to make [`normalize_performance_score`] work for both
/// [`Measurements`] and [`Attributes`].
pub trait MeasurementsLike {
    /// Returns `true` if this collection contains the named measurement.
    fn contains_measurement(&self, key: &str) -> bool;
    /// Gets the value of the named measurement if this collection contains it.
    fn get_measurement_value(&self, key: &str) -> Option<FiniteF64>;
    /// Inserts a measurement into this collection.
    fn insert_measurement(&mut self, key: String, value: Measurement);
}

impl MeasurementsLike for Measurements {
    fn contains_measurement(&self, key: &str) -> bool {
        self.contains_key(key)
    }

    fn get_measurement_value(&self, key: &str) -> Option<FiniteF64> {
        self.get_value(key)
    }

    fn insert_measurement(&mut self, key: String, value: Measurement) {
        self.insert(key, value.into());
    }
}

impl MeasurementsLike for Attributes {
    fn contains_measurement(&self, key: &str) -> bool {
        self.0
            .contains_key(relay_conventions::canonical(key).unwrap_or(key))
    }

    fn get_measurement_value(&self, key: &str) -> Option<FiniteF64> {
        let value = self.get_value(relay_conventions::canonical(key).unwrap_or(key))?;
        match value {
            Value::F64(v) => FiniteF64::new(*v),
            Value::U64(v) => FiniteF64::new(*v as f64),
            Value::I64(v) => FiniteF64::new(*v as f64),
            _ => None,
        }
    }

    fn insert_measurement(&mut self, key: String, measurement: Measurement) {
        self.0
            .insert(key, measurement.value.map_value(|v| v.to_f64().into()));
    }
}

/// Trait for types that provide mutable access to a collection of [`Measurement`]s.
///
/// This exists to make [`normalize_performance_score`] work for [`Event`]s,
/// [`V1 Spans`](Span), and [`V2 Spans`](SpanV2).
pub trait MutMeasurements {
    type MeasurementsContainer: MeasurementsLike;
    fn measurements(&mut self) -> &mut Annotated<Self::MeasurementsContainer>;
}

impl MutMeasurements for Event {
    type MeasurementsContainer = Measurements;
    fn measurements(&mut self) -> &mut Annotated<Self::MeasurementsContainer> {
        &mut self.measurements
    }
}

impl MutMeasurements for Span {
    type MeasurementsContainer = Measurements;
    fn measurements(&mut self) -> &mut Annotated<Self::MeasurementsContainer> {
        &mut self.measurements
    }
}

impl MutMeasurements for SpanV2 {
    type MeasurementsContainer = Attributes;

    fn measurements(&mut self) -> &mut Annotated<Self::MeasurementsContainer> {
        &mut self.attributes
    }
}

/// Computes performance score measurements for an event.
///
/// This computes score from vital measurements, using config options to define how it is
/// calculated.
pub fn normalize_performance_score(
    event: &mut (impl Getter + MutMeasurements),
    performance_score: Option<&PerformanceScoreConfig>,
) -> Option<String> {
    let mut version = None;
    let Some(performance_score) = performance_score else {
        return version;
    };
    for profile in &performance_score.profiles {
        if let Some(condition) = &profile.condition {
            if !condition.matches(event) {
                continue;
            }
            if let Some(measurements) = event.measurements().value_mut() {
                let mut should_add_total = false;
                if profile.score_components.iter().any(|c| {
                    !measurements.contains_measurement(c.measurement.as_str())
                        && c.weight.abs() >= f64::EPSILON
                        && !c.optional
                }) {
                    // All non-optional measurements with a profile weight greater than 0 are
                    // required to exist on the event. Skip this profile if
                    // a measurement with weight is missing.
                    continue;
                }
                let mut score_total = FiniteF64::ZERO;
                let mut weight_total = FiniteF64::ZERO;
                for component in &profile.score_components {
                    // Skip optional components if they are not present on the event.
                    if component.optional
                        && !measurements.contains_measurement(component.measurement.as_str())
                    {
                        continue;
                    }
                    weight_total += component.weight;
                }
                if weight_total.abs() < FiniteF64::EPSILON {
                    // All components are optional or have a weight of `0`. We cannot compute
                    // component weights, so we bail.
                    continue;
                }
                for component in &profile.score_components {
                    // Optional measurements that are not present are given a weight of 0.
                    let mut normalized_component_weight = FiniteF64::ZERO;

                    if let Some(value) =
                        measurements.get_measurement_value(component.measurement.as_str())
                    {
                        normalized_component_weight = component.weight.saturating_div(weight_total);
                        let cdf = utils::calculate_cdf_score(
                            value.to_f64().max(0.0), // Webvitals can't be negative, but we need to clamp in case of bad data.
                            component.p10.to_f64(),
                            component.p50.to_f64(),
                        );

                        let cdf = Annotated::try_from(cdf);

                        measurements.insert_measurement(
                            interpolate::score__ratio__key(&component.measurement),
                            Measurement {
                                value: cdf.clone(),
                                unit: (MetricUnit::Fraction(FractionUnit::Ratio)).into(),
                            },
                        );

                        let component_score =
                            cdf.and_then(|cdf| match cdf * normalized_component_weight {
                                Some(v) => Annotated::new(v),
                                None => Annotated::from_error(TryFromFloatError, None),
                            });

                        if let Some(component_score) = component_score.value() {
                            score_total += *component_score;
                            should_add_total = true;
                        }

                        measurements.insert_measurement(
                            interpolate::score__key(&component.measurement),
                            Measurement {
                                value: component_score,
                                unit: (MetricUnit::Fraction(FractionUnit::Ratio)).into(),
                            },
                        );
                    }

                    measurements.insert_measurement(
                        interpolate::score__weight__key(&component.measurement),
                        Measurement {
                            value: normalized_component_weight.into(),
                            unit: (MetricUnit::Fraction(FractionUnit::Ratio)).into(),
                        },
                    );
                }
                if should_add_total {
                    version.clone_from(&profile.version);
                    measurements.insert_measurement(
                        SCORE__TOTAL.to_owned(),
                        Measurement {
                            value: score_total.into(),
                            unit: (MetricUnit::Fraction(FractionUnit::Ratio)).into(),
                        },
                    );
                }
            }
            break; // Stop after the first matching profile.
        }
    }
    version
}

// Extracts lcp related tags from the trace context.
fn normalize_trace_context_tags(event: &mut Event) {
    let tags = &mut event.tags.value_mut().get_or_insert_with(Tags::default).0;
    if let Some(contexts) = event.contexts.value()
        && let Some(trace_context) = contexts.get::<TraceContext>()
        && let Some(data) = trace_context.data.value()
    {
        if let Some(lcp_element) = data.lcp_element.value()
            && !tags.contains("lcp.element")
        {
            let tag_name = "lcp.element".to_owned();
            tags.insert(tag_name, Annotated::new(lcp_element.clone()));
        }
        if let Some(lcp_size) = data.lcp_size.value()
            && !tags.contains("lcp.size")
        {
            let tag_name = "lcp.size".to_owned();
            tags.insert(tag_name, Annotated::new(lcp_size.to_string()));
        }
        if let Some(lcp_id) = data.lcp_id.value() {
            let tag_name = "lcp.id".to_owned();
            if !tags.contains("lcp.id") {
                tags.insert(tag_name, Annotated::new(lcp_id.clone()));
            }
        }
        if let Some(lcp_url) = data.lcp_url.value() {
            let tag_name = "lcp.url".to_owned();
            if !tags.contains("lcp.url") {
                tags.insert(tag_name, Annotated::new(lcp_url.clone()));
            }
        }
    }
}

/// Compute additional measurements derived from existing ones.
///
/// The added measurements are:
///
/// ```text
/// frames_slow_rate := measurements.frames_slow / measurements.frames_total
/// frames_frozen_rate := measurements.frames_frozen / measurements.frames_total
/// stall_percentage := measurements.stall_total_time / transaction.duration
/// ```
fn compute_measurements(
    transaction_duration_ms: Option<FiniteF64>,
    measurements: &mut Measurements,
) {
    if let Some(frames_total) = measurements.get_value(FRAMES_TOTAL)
        && frames_total > 0.0
    {
        if let Some(frames_frozen) = measurements.get_value(FRAMES_FROZEN) {
            let frames_frozen_rate = Measurement {
                value: (frames_frozen / frames_total).into(),
                unit: (MetricUnit::Fraction(FractionUnit::Ratio)).into(),
            };
            measurements.insert(FRAMES_FROZEN_RATE.to_owned(), frames_frozen_rate.into());
        }
        if let Some(frames_slow) = measurements.get_value(FRAMES_SLOW) {
            let frames_slow_rate = Measurement {
                value: (frames_slow / frames_total).into(),
                unit: MetricUnit::Fraction(FractionUnit::Ratio).into(),
            };
            measurements.insert(FRAMES_SLOW_RATE.to_owned(), frames_slow_rate.into());
        }
    }

    // Get stall_percentage
    if let Some(transaction_duration_ms) = transaction_duration_ms
        && transaction_duration_ms > 0.0
        && let Some(stall_total_time) = measurements
            .get("stall_total_time")
            .and_then(Annotated::value)
        && matches!(
            stall_total_time.unit.value(),
            // Accept milliseconds or None, but not other units
            Some(&MetricUnit::Duration(DurationUnit::MilliSecond) | &MetricUnit::None) | None
        )
        && let Some(stall_total_time) = stall_total_time.value.0
    {
        let stall_percentage = Measurement {
            value: (stall_total_time / transaction_duration_ms).into(),
            unit: (MetricUnit::Fraction(FractionUnit::Ratio)).into(),
        };
        measurements.insert(STALL_PERCENTAGE.to_owned(), stall_percentage.into());
    }
}

/// Emit any breakdowns
fn normalize_breakdowns(event: &mut Event, breakdowns_config: Option<&BreakdownsConfig>) {
    match breakdowns_config {
        None => {}
        Some(config) => breakdowns::normalize_breakdowns(event, config),
    }
}

fn normalize_default_attributes(event: &mut Event, meta: &mut Meta, config: &NormalizationConfig) {
    let event_type = infer_event_type(event);
    event.ty = Annotated::from(event_type);
    event.project = Annotated::from(config.project_id);
    event.key_id = Annotated::from(config.key_id.clone());
    event.version = Annotated::from(config.protocol_version.clone());
    event.grouping_config = config
        .grouping_config
        .clone()
        .map_or(Annotated::empty(), |x| {
            FromValue::from_value(Annotated::<Value>::from(x))
        });

    let _ = relay_event_schema::processor::apply(&mut event.platform, |platform, _| {
        if is_valid_platform(platform) {
            Ok(())
        } else {
            Err(ProcessingAction::DeleteValueSoft)
        }
    });

    // Default required attributes, even if they have errors
    event.errors.get_or_insert_with(Vec::new);
    event.id.get_or_insert_with(EventId::new);
    event.platform.get_or_insert_with(|| "other".to_owned());
    event.logger.get_or_insert_with(String::new);
    event.extra.get_or_insert_with(Object::new);
    event.level.get_or_insert_with(|| match event_type {
        EventType::Transaction => Level::Info,
        _ => Level::Error,
    });
    if event.client_sdk.value().is_none() {
        event.client_sdk.set_value(get_sdk_info(config));
    }

    if event.platform.as_str() == Some("java")
        && let Some(event_logger) = event.logger.value_mut().take()
    {
        let shortened = shorten_logger(event_logger, meta);
        event.logger.set_value(Some(shortened));
    }
}

/// Returns `true` if the given platform string is a known platform identifier.
///
/// See [`VALID_PLATFORMS`] for a list of all known platforms.
pub fn is_valid_platform(platform: &str) -> bool {
    VALID_PLATFORMS.contains(&platform)
}

/// Infers the `EventType` from the event's interfaces.
fn infer_event_type(event: &Event) -> EventType {
    // The event type may be set explicitly when constructing the event items from specific
    // items. This is DEPRECATED, and each distinct event type may get its own base class. For
    // the time being, this is only implemented for transactions, so be specific:
    if event.ty.value() == Some(&EventType::Transaction) {
        return EventType::Transaction;
    }
    if event.ty.value() == Some(&EventType::UserReportV2) {
        return EventType::UserReportV2;
    }

    // The SDKs do not describe event types, and we must infer them from available attributes.
    let has_exceptions = event
        .exceptions
        .value()
        .and_then(|exceptions| exceptions.values.value())
        .filter(|values| !values.is_empty())
        .is_some();

    if has_exceptions {
        EventType::Error
    } else if event.csp.value().is_some() {
        EventType::Csp
    } else if event.hpkp.value().is_some() {
        EventType::Hpkp
    } else if event.expectct.value().is_some() {
        EventType::ExpectCt
    } else if event.expectstaple.value().is_some() {
        EventType::ExpectStaple
    } else {
        EventType::Default
    }
}

/// Returns the SDK info from the config.
fn get_sdk_info(config: &NormalizationConfig) -> Option<ClientSdkInfo> {
    config.client.as_ref().and_then(|client| {
        client
            .splitn(2, '/')
            .collect_tuple()
            .or_else(|| client.splitn(2, ' ').collect_tuple())
            .map(|(name, version)| ClientSdkInfo {
                name: Annotated::new(name.to_owned()),
                version: Annotated::new(version.to_owned()),
                ..Default::default()
            })
    })
}

/// If the logger is longer than [`MaxChars::Logger`], it returns a String with
/// a shortened version of the logger. If not, the same logger is returned as a
/// String. The resulting logger is always trimmed.
///
/// To shorten the logger, all extra chars that don't fit into the maximum limit
/// are removed, from the beginning of the logger.  Then, if the remaining
/// substring contains a `.` somewhere but in the end, all chars until `.`
/// (exclusive) are removed.
///
/// Additionally, the new logger is prefixed with `*`, to indicate it was
/// shortened.
fn shorten_logger(logger: String, meta: &mut Meta) -> String {
    let original_len = bytecount::num_chars(logger.as_bytes());
    let trimmed = logger.trim();
    let logger_len = bytecount::num_chars(trimmed.as_bytes());
    if logger_len <= MaxChars::Logger.limit() {
        if trimmed == logger {
            return logger;
        } else {
            if trimmed.is_empty() {
                meta.add_remark(Remark {
                    ty: RemarkType::Removed,
                    rule_id: "@logger:remove".to_owned(),
                    range: Some((0, original_len)),
                });
            } else {
                meta.add_remark(Remark {
                    ty: RemarkType::Substituted,
                    rule_id: "@logger:trim".to_owned(),
                    range: None,
                });
            }
            meta.set_original_length(Some(original_len));
            return trimmed.to_owned();
        };
    }

    let mut tokens = trimmed.split("").collect_vec();
    // Remove empty str tokens from the beginning and end.
    tokens.pop();
    tokens.reverse(); // Prioritize chars from the end of the string.
    tokens.pop();

    let word_cut = remove_logger_extra_chars(&mut tokens);
    if word_cut {
        remove_logger_word(&mut tokens);
    }

    tokens.reverse();
    meta.add_remark(Remark {
        ty: RemarkType::Substituted,
        rule_id: "@logger:replace".to_owned(),
        range: Some((0, logger_len - tokens.len())),
    });
    meta.set_original_length(Some(original_len));

    format!("*{}", tokens.join(""))
}

/// Remove as many tokens as needed to match the maximum char limit defined in
/// [`MaxChars::Logger`], and an extra token for the logger prefix. Returns
/// whether a word has been cut.
///
/// A word is considered any non-empty substring that doesn't contain a `.`.
fn remove_logger_extra_chars(tokens: &mut Vec<&str>) -> bool {
    // Leave one slot of space for the prefix
    let mut remove_chars = tokens.len() - MaxChars::Logger.limit() + 1;
    let mut word_cut = false;
    while remove_chars > 0 {
        if let Some(c) = tokens.pop() {
            if !word_cut && c != "." {
                word_cut = true;
            } else if word_cut && c == "." {
                word_cut = false;
            }
        }
        remove_chars -= 1;
    }
    word_cut
}

/// If the `.` token is present, removes all tokens from the end of the vector
/// until `.`. If it isn't present, nothing is removed.
fn remove_logger_word(tokens: &mut Vec<&str>) {
    let mut delimiter_found = false;
    for token in tokens.iter() {
        if *token == "." {
            delimiter_found = true;
            break;
        }
    }
    if !delimiter_found {
        return;
    }
    while let Some(i) = tokens.last() {
        if *i == "." {
            break;
        }
        tokens.pop();
    }
}

/// Creates a new trace context if it is missing and ensures the context has a valid trace and span id.
///
/// The function keeps existing meta on trace and span id intact, still surfacing user errors in the
/// original payload.
fn normalize_force_trace_context(event: &mut Event) {
    let contexts = event.contexts.get_or_insert_with(Contexts::new);
    let trace = contexts.get_or_default::<TraceContext>();

    let trace_id = trace
        .trace_id
        .get_or_insert_with(|| TraceId::from(*event.id.get_or_insert_with(Default::default)));
    let _ = trace
        .span_id
        .get_or_insert_with(|| SpanId::derive_from_trace_id(trace_id));
}

/// Normalizes incoming contexts for the downstream metric extraction.
fn normalize_contexts(contexts: &mut Annotated<Contexts>) {
    let _ = processor::apply(contexts, |contexts, _meta| {
        // Reprocessing context sent from SDKs must not be accepted, it is a Sentry-internal
        // construct.
        // [`normalize`] does not run on renormalization anyway.
        contexts.0.remove("reprocessing");

        for annotated in &mut contexts.0.values_mut() {
            if let Some(context_inner) = annotated.value_mut() {
                crate::normalize::contexts::normalize_context(&mut context_inner.0);
            }
        }

        Ok(())
    });
}

/// New SDKs do not send measurements when they exceed 180 seconds.
///
/// Drop those outlier measurements for older SDKs.
fn filter_mobile_outliers(measurements: &mut Measurements) {
    for key in [
        APP_START_COLD,
        APP_START_WARM,
        // TODO: Regrettably, these measurements are not defined in conventions.
        "time_to_initial_display",
        "time_to_full_display",
    ] {
        if let Some(value) = measurements.get_value(key)
            && value > MAX_DURATION_MOBILE_MS
        {
            measurements.remove(key);
        }
    }
}

fn normalize_mobile_measurements(measurements: &mut Measurements) {
    normalize_app_start_measurements(measurements);
    filter_mobile_outliers(measurements);
}

const APP_START_SOURCES: [(&str, Option<&str>); 5] = [
    ("app_start_cold", Some("cold")),
    ("app_start_warm", Some("warm")),
    (APP__VITALS__START__VALUE, None),
    (APP__VITALS__START__COLD__VALUE, None),
    (APP__VITALS__START__WARM__VALUE, None),
];

fn backfill_app_vitals_start(event: &mut Event) {
    if event.ty.value() != Some(&EventType::Transaction) {
        return;
    }

    backfill_app_vitals_start_screen(event);

    let already_set = event
        .tags
        .value()
        .is_some_and(|tags| tags.get(APP__VITALS__START__TYPE).is_some())
        || event
            .measurements
            .value()
            .is_some_and(|m| m.contains_key(APP__VITALS__START__VALUE));
    if already_set {
        return;
    }

    let Some((start_type, value)) =
        APP_START_SOURCES
            .iter()
            .find_map(|(measurement_name, start_type)| {
                let start_type = (*start_type)?;
                let measurement = event
                    .measurements
                    .value()?
                    .get(*measurement_name)?
                    .value()?;
                if measurement.unit.value()
                    != Some(&MetricUnit::Duration(DurationUnit::MilliSecond))
                {
                    return None;
                }

                let value = *measurement.value.value()?;
                Some((start_type, value))
            })
    else {
        return;
    };

    event
        .measurements
        .get_or_insert_with(Default::default)
        .insert(
            APP__VITALS__START__VALUE.to_owned(),
            Annotated::new(Measurement {
                value: Annotated::new(value),
                unit: Annotated::new(MetricUnit::Duration(DurationUnit::MilliSecond)),
            }),
        );

    event
        .tags
        .value_mut()
        .get_or_insert_with(Tags::default)
        .0
        .insert(
            String::from(APP__VITALS__START__TYPE),
            Annotated::new(start_type.to_owned()),
        );
}

/// Backfills `app.vitals.start.screen` into root span data.
///
/// This runs from the transaction-only app-start backfill and writes only when:
/// - the transaction name is a concrete screen name;
/// - the trace op is `"ui.load"`;
/// - the event contains an app-start measurement;
/// - the SDK did not already provide `app.vitals.start.screen`.
fn backfill_app_vitals_start_screen(event: &mut Event) {
    let Some(screen) = event.transaction.value() else {
        return;
    };
    // TransactionsProcessor writes this placeholder for missing names before this backfill runs.
    if screen.is_empty() || screen == "<unlabeled transaction>" {
        return;
    }

    let has_app_start_measurement = event.measurements.value().is_some_and(|measurements| {
        APP_START_SOURCES
            .iter()
            .any(|(measurement_name, _)| measurements.contains_key(*measurement_name))
    });
    if !has_app_start_measurement {
        return;
    }

    let screen = screen.to_owned();
    let Some(trace_context) = event.context_mut::<TraceContext>() else {
        return;
    };
    if trace_context.op.as_str() != Some("ui.load")
        || trace_context
            .data
            .value()
            .is_some_and(|data| data.other.contains_key(APP__VITALS__START__SCREEN))
    {
        return;
    }

    let data = trace_context.data.get_or_insert_with(Default::default);
    data.other.insert(
        APP__VITALS__START__SCREEN.to_owned(),
        Annotated::new(Value::String(screen)),
    );
}

fn normalize_units(measurements: &mut Measurements) {
    for (name, measurement) in measurements.iter_mut() {
        let measurement = match measurement.value_mut() {
            Some(m) => m,
            None => continue,
        };

        let stated_unit = measurement.unit.value().copied();
        let default_unit = get_metric_measurement_unit(name);
        measurement
            .unit
            .set_value(Some(stated_unit.or(default_unit).unwrap_or_default()))
    }
}

/// Remove measurements that do not conform to the given config.
///
/// Built-in measurements are accepted if their unit is correct, dropped otherwise.
/// Custom measurements are accepted up to a limit.
///
/// Note that [`Measurements`] is a BTreeMap, which means its keys are sorted.
/// This ensures that for two events with the same measurement keys, the same set of custom
/// measurements is retained.
fn remove_invalid_measurements(
    measurements: &mut Measurements,
    meta: &mut Meta,
    measurements_config: CombinedMeasurementsConfig,
    max_name_and_unit_len: Option<usize>,
) {
    // If there is no project or global config allow all the custom measurements through.
    let max_custom_measurements = measurements_config
        .max_custom_measurements()
        .unwrap_or(usize::MAX);

    let mut custom_measurements_count = 0;
    let mut removed_measurements = Object::new();

    measurements.retain(|name, value| {
        let measurement = match value.value_mut() {
            Some(m) => m,
            None => return false,
        };

        if !can_be_valid_metric_name(name) {
            meta.add_error(Error::invalid(format!(
                "Metric name contains invalid characters: \"{name}\""
            )));
            removed_measurements.insert(name.clone(), Annotated::new(std::mem::take(measurement)));
            return false;
        }

        // TODO(jjbayer): Should we actually normalize the unit into the event?
        let unit = measurement.unit.value().unwrap_or(&MetricUnit::None);

        if let Some(max_name_and_unit_len) = max_name_and_unit_len {
            let max_name_len = max_name_and_unit_len - unit.to_string().len();

            if name.len() > max_name_len {
                meta.add_error(Error::invalid(format!(
                    "Metric name too long {}/{max_name_len}: \"{name}\"",
                    name.len(),
                )));
                removed_measurements
                    .insert(name.clone(), Annotated::new(std::mem::take(measurement)));
                return false;
            }
        }

        // Check if this is a builtin measurement:
        if let Some(builtin_measurement) = measurements_config
            .builtin_measurement_keys()
            .find(|builtin| builtin.name() == name)
        {
            let value = measurement.value.value().unwrap_or(&FiniteF64::ZERO);
            // Drop negative values if the builtin measurement does not allow them.
            if !builtin_measurement.allow_negative() && *value < 0.0 {
                meta.add_error(Error::invalid(format!(
                    "Negative value for measurement {name} not allowed: {value}",
                )));
                removed_measurements
                    .insert(name.clone(), Annotated::new(std::mem::take(measurement)));
                return false;
            }
            // If the unit matches a built-in measurement, we allow it.
            // If the name matches but the unit is wrong, we do not even accept it as a custom measurement,
            // and just drop it instead.
            return builtin_measurement.unit() == unit;
        }

        // For custom measurements, check the budget:
        if custom_measurements_count < max_custom_measurements {
            custom_measurements_count += 1;
            return true;
        }

        meta.add_error(Error::invalid(format!("Too many measurements: {name}")));
        removed_measurements.insert(name.clone(), Annotated::new(std::mem::take(measurement)));

        false
    });

    if !removed_measurements.is_empty() {
        meta.set_original_value(Some(removed_measurements));
    }
}

/// Returns the unit of the provided metric.
///
/// For known measurements, this returns `Some(MetricUnit)`, which can also include
/// `Some(MetricUnit::None)`. For unknown measurement names, this returns `None`.
fn get_metric_measurement_unit(measurement_name: &str) -> Option<MetricUnit> {
    // TODO: Might be neat to resolve this via conventions, but might also not
    // be worth the trouble.
    match measurement_name {
        // Web
        "fcp" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "lcp" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "fid" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "fp" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "inp" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "ttfb" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "ttfb.requesttime" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "cls" => Some(MetricUnit::None),

        // Mobile
        "app_start_cold" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "app_start_warm" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "frames_total" => Some(MetricUnit::None),
        "frames_slow" => Some(MetricUnit::None),
        "frames_slow_rate" => Some(MetricUnit::Fraction(FractionUnit::Ratio)),
        "frames_frozen" => Some(MetricUnit::None),
        "frames_frozen_rate" => Some(MetricUnit::Fraction(FractionUnit::Ratio)),
        "time_to_initial_display" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "time_to_full_display" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),

        // React-Native
        "stall_count" => Some(MetricUnit::None),
        "stall_total_time" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "stall_longest_time" => Some(MetricUnit::Duration(DurationUnit::MilliSecond)),
        "stall_percentage" => Some(MetricUnit::Fraction(FractionUnit::Ratio)),

        // Default
        _ => None,
    }
}

/// Replaces dot.case app start measurements keys with snake_case keys.
///
/// The dot.case app start measurements keys are treated as custom measurements.
/// The snake_case is the key expected by the Sentry UI to aggregate and display in graphs.
fn normalize_app_start_measurements(measurements: &mut Measurements) {
    use relay_conventions::measurements::{APP_START_COLD, APP_START_WARM};
    if let Some(app_start_cold_value) = measurements.remove("app.start.cold") {
        measurements.insert(APP_START_COLD.to_owned(), app_start_cold_value);
    }
    if let Some(app_start_warm_value) = measurements.remove("app.start.warm") {
        measurements.insert(APP_START_WARM.to_owned(), app_start_warm_value);
    }
}

#[cfg(test)]
mod tests {

    use relay_event_schema::protocol::SpanData;
    use relay_pattern::Pattern;
    use relay_protocol::assert_annotated_snapshot;
    use std::collections::BTreeMap;
    use std::collections::HashMap;

    use insta::assert_debug_snapshot;
    use itertools::Itertools;
    use relay_event_schema::protocol::{Breadcrumb, Csp, DebugMeta, DeviceContext, Values};
    use relay_protocol::{SerializableAnnotated, get_value};
    use serde_json::json;

    use super::*;
    use crate::eap;
    use crate::{ClientHints, MeasurementsConfig, ModelCostV2, ModelMetadataEntry};

    const IOS_MOBILE_EVENT: &str = r#"
        {
            "sdk": {"name": "sentry.cocoa"},
            "contexts": {
                "trace": {
                    "op": "ui.load"
                }
            },
            "measurements": {
                "app_start_warm": {
                    "value": 8049.345970153808,
                    "unit": "millisecond"
                },
                "time_to_full_display": {
                    "value": 8240.571022033691,
                    "unit": "millisecond"
                },
                "time_to_initial_display": {
                    "value": 8049.345970153808,
                    "unit": "millisecond"
                }
            }
        }
        "#;

    const ANDROID_MOBILE_EVENT: &str = r#"
        {
            "sdk": {"name": "sentry.java.android"},
            "contexts": {
                "trace": {
                    "op": "ui.load"
                }
            },
            "measurements": {
                "app_start_cold": {
                    "value": 22648,
                    "unit": "millisecond"
                },
                "time_to_full_display": {
                    "value": 22647,
                    "unit": "millisecond"
                },
                "time_to_initial_display": {
                    "value": 22647,
                    "unit": "millisecond"
                }
            }
        }
        "#;

    fn collect_span_data<const N: usize>(event: Annotated<Event>) -> [Annotated<SpanData>; N] {
        get_value!(event.spans!)
            .iter()
            .map(|span| Annotated::new(get_value!(span.data!).clone()))
            .collect::<Vec<_>>()
            .try_into()
            .unwrap()
    }

    fn trace_context_data(event: &Event) -> &Annotated<SpanData> {
        &event.context::<TraceContext>().unwrap().data
    }

    fn app_vitals_start_screen_event(
        ty: &str,
        transaction: Option<&str>,
        trace_op: &str,
        measurement: Option<&str>,
        existing_screen: Option<&str>,
    ) -> Event {
        let mut payload = json!({
            "type": ty,
            "contexts": {"trace": {"op": trace_op}},
            "measurements": {},
        });

        if let Some(transaction) = transaction {
            payload["transaction"] = json!(transaction);
        }

        if let Some(measurement) = measurement {
            payload["measurements"] = json!({
                measurement: {"value": 1234.0, "unit": "millisecond"}
            });
        }

        if let Some(screen) = existing_screen {
            payload["contexts"]["trace"]["data"] = json!({APP__VITALS__START__SCREEN: screen});
        }

        Annotated::<Event>::from_json(&payload.to_string())
            .unwrap()
            .into_value()
            .unwrap()
    }

    #[test]
    fn test_normalize_dist_none() {
        let mut dist = Annotated::default();
        normalize_dist(&mut dist);
        assert_eq!(dist.value(), None);
    }

    #[test]
    fn test_normalize_dist_empty() {
        let mut dist = Annotated::new("".to_owned());
        normalize_dist(&mut dist);
        assert_eq!(dist.value(), None);
    }

    #[test]
    fn test_normalize_dist_trim() {
        let mut dist = Annotated::new(" foo  ".to_owned());
        normalize_dist(&mut dist);
        assert_eq!(dist.value(), Some(&"foo".to_owned()));
    }

    #[test]
    fn test_normalize_dist_whitespace() {
        let mut dist = Annotated::new(" ".to_owned());
        normalize_dist(&mut dist);
        assert_eq!(dist.value(), None);
    }

    #[test]
    fn test_normalize_platform_and_level_with_transaction_event() {
        let json = r#"
        {
            "type": "transaction"
        }
        "#;

        let Annotated(Some(mut event), mut meta) = Annotated::<Event>::from_json(json).unwrap()
        else {
            panic!("Invalid transaction json");
        };

        normalize_default_attributes(&mut event, &mut meta, &NormalizationConfig::default());

        assert_eq!(event.level.value().unwrap().to_string(), "info");
        assert_eq!(event.ty.value().unwrap().to_string(), "transaction");
        assert_eq!(event.platform.as_str().unwrap(), "other");
    }

    #[test]
    fn test_normalize_platform_and_level_with_error_event() {
        let json = r#"
        {
            "type": "error",
            "exception": {
                "values": [{"type": "ValueError", "value": "Should not happen"}]
            }
        }
        "#;

        let Annotated(Some(mut event), mut meta) = Annotated::<Event>::from_json(json).unwrap()
        else {
            panic!("Invalid error json");
        };

        normalize_default_attributes(&mut event, &mut meta, &NormalizationConfig::default());

        assert_eq!(event.level.value().unwrap().to_string(), "error");
        assert_eq!(event.ty.value().unwrap().to_string(), "error");
        assert_eq!(event.platform.value().unwrap().to_owned(), "other");
    }

    #[test]
    fn test_computed_measurements() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "frames_slow": {"value": 1},
                "frames_frozen": {"value": 2},
                "frames_total": {"value": 4},
                "stall_total_time": {"value": 4000, "unit": "millisecond"}
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        normalize_event_measurements(&mut event, None, None);

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "measurements": {
            "frames_frozen": {
              "value": 2.0,
              "unit": "none",
            },
            "frames_frozen_rate": {
              "value": 0.5,
              "unit": "ratio",
            },
            "frames_slow": {
              "value": 1.0,
              "unit": "none",
            },
            "frames_slow_rate": {
              "value": 0.25,
              "unit": "ratio",
            },
            "frames_total": {
              "value": 4.0,
              "unit": "none",
            },
            "stall_percentage": {
              "value": 0.8,
              "unit": "ratio",
            },
            "stall_total_time": {
              "value": 4000.0,
              "unit": "millisecond",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_filter_custom_measurements() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "my_custom_measurement_1": {"value": 123},
                "frames_frozen": {"value": 666, "unit": "invalid_unit"},
                "frames_slow": {"value": 1},
                "my_custom_measurement_3": {"value": 456},
                "my_custom_measurement_2": {"value": 789}
            }
        }
        "#;
        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let project_measurement_config: MeasurementsConfig = serde_json::from_value(json!({
            "builtinMeasurements": [
                {"name": "frames_frozen", "unit": "none"},
                {"name": "frames_slow", "unit": "none"}
            ],
            "maxCustomMeasurements": 2,
            "stray_key": "zzz"
        }))
        .unwrap();

        let dynamic_measurement_config =
            CombinedMeasurementsConfig::new(Some(&project_measurement_config), None);

        normalize_event_measurements(&mut event, Some(dynamic_measurement_config), None);

        // Only two custom measurements are retained, in alphabetic order (1 and 2)
        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "measurements": {
            "frames_slow": {
              "value": 1.0,
              "unit": "none",
            },
            "my_custom_measurement_1": {
              "value": 123.0,
              "unit": "none",
            },
            "my_custom_measurement_2": {
              "value": 789.0,
              "unit": "none",
            },
          },
          "_meta": {
            "measurements": {
              "": Meta(Some(MetaInner(
                err: [
                  [
                    "invalid_data",
                    {
                      "reason": "Too many measurements: my_custom_measurement_3",
                    },
                  ],
                ],
                val: Some({
                  "my_custom_measurement_3": {
                    "unit": "none",
                    "value": 456.0,
                  },
                }),
              ))),
            },
          },
        }
        "###);
    }

    #[test]
    fn test_normalize_units() {
        let mut measurements = Annotated::<Measurements>::from_json(
            r#"{
                "fcp": {"value": 1.1},
                "stall_count": {"value": 3.3},
                "foo": {"value": 8.8}
            }"#,
        )
        .unwrap()
        .into_value()
        .unwrap();
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {
                "fcp": Measurement {
                    value: 1.1,
                    unit: ~,
                },
                "foo": Measurement {
                    value: 8.8,
                    unit: ~,
                },
                "stall_count": Measurement {
                    value: 3.3,
                    unit: ~,
                },
            },
        )
        "###);
        normalize_units(&mut measurements);
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {
                "fcp": Measurement {
                    value: 1.1,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
                "foo": Measurement {
                    value: 8.8,
                    unit: None,
                },
                "stall_count": Measurement {
                    value: 3.3,
                    unit: None,
                },
            },
        )
        "###);
    }

    #[test]
    fn test_normalize_security_report() {
        let mut event = Event {
            csp: Annotated::from(Csp::default()),
            ..Default::default()
        };
        let ipaddr = IpAddr("213.164.1.114".to_owned());

        let client_ip = Some(&ipaddr);

        let user_agent = RawUserAgentInfo {
            user_agent: Some(
                "Mozilla/5.0 (Macintosh; Intel Mac OS X 10.15; rv:109.0) Gecko/20100101 Firefox/109.0",
            ),
            client_hints: ClientHints {
                sec_ch_ua_platform: Some("macOS"),
                sec_ch_ua_platform_version: Some("13.2.0"),
                sec_ch_ua: Some(
                    r#""Chromium";v="110", "Not A(Brand";v="24", "Google Chrome";v="110""#,
                ),
                sec_ch_ua_model: Some("some model"),
            },
        };

        // This call should fill the event headers with info from the user_agent which is
        // tested below.
        normalize_security_report(&mut event, client_ip, &user_agent);

        let headers = event
            .request
            .value_mut()
            .get_or_insert_with(Request::default)
            .headers
            .value_mut()
            .get_or_insert_with(Headers::default);

        assert_eq!(
            event.user.value().unwrap().ip_address,
            Annotated::from(ipaddr)
        );
        assert_eq!(
            headers.get_header(RawUserAgentInfo::USER_AGENT),
            user_agent.user_agent
        );
        assert_eq!(
            headers.get_header(ClientHints::SEC_CH_UA),
            user_agent.client_hints.sec_ch_ua,
        );
        assert_eq!(
            headers.get_header(ClientHints::SEC_CH_UA_MODEL),
            user_agent.client_hints.sec_ch_ua_model,
        );
        assert_eq!(
            headers.get_header(ClientHints::SEC_CH_UA_PLATFORM),
            user_agent.client_hints.sec_ch_ua_platform,
        );
        assert_eq!(
            headers.get_header(ClientHints::SEC_CH_UA_PLATFORM_VERSION),
            user_agent.client_hints.sec_ch_ua_platform_version,
        );

        assert!(
            std::mem::size_of_val(&ClientHints::<&str>::default()) == 64,
            "If you add new fields, update the test accordingly"
        );
    }

    #[test]
    fn test_no_device_class() {
        let mut event = Event {
            ..Default::default()
        };
        normalize_device_class(&mut event);
        let tags = &event.tags.value_mut().get_or_insert_with(Tags::default).0;
        assert_eq!(None, tags.get("device_class"));
    }

    #[test]
    fn test_apple_low_device_class() {
        let mut event = Event {
            contexts: {
                let mut contexts = Contexts::new();
                contexts.add(DeviceContext {
                    family: "iPhone".to_owned().into(),
                    model: "iPhone8,4".to_owned().into(),
                    ..Default::default()
                });
                Annotated::new(contexts)
            },
            ..Default::default()
        };
        normalize_device_class(&mut event);
        assert_debug_snapshot!(event.tags, @r###"
        Tags(
            PairList(
                [
                    TagEntry(
                        "device.class",
                        "1",
                    ),
                ],
            ),
        )
        "###);
    }

    #[test]
    fn test_apple_medium_device_class() {
        let mut event = Event {
            contexts: {
                let mut contexts = Contexts::new();
                contexts.add(DeviceContext {
                    family: "iPhone".to_owned().into(),
                    model: "iPhone12,8".to_owned().into(),
                    ..Default::default()
                });
                Annotated::new(contexts)
            },
            ..Default::default()
        };
        normalize_device_class(&mut event);
        assert_debug_snapshot!(event.tags, @r###"
        Tags(
            PairList(
                [
                    TagEntry(
                        "device.class",
                        "2",
                    ),
                ],
            ),
        )
        "###);
    }

    #[test]
    fn test_android_low_device_class() {
        let mut event = Event {
            contexts: {
                let mut contexts = Contexts::new();
                contexts.add(DeviceContext {
                    family: "android".to_owned().into(),
                    processor_frequency: 1000.into(),
                    processor_count: 6.into(),
                    memory_size: (2 * 1024 * 1024 * 1024).into(),
                    ..Default::default()
                });
                Annotated::new(contexts)
            },
            ..Default::default()
        };
        normalize_device_class(&mut event);
        assert_debug_snapshot!(event.tags, @r###"
        Tags(
            PairList(
                [
                    TagEntry(
                        "device.class",
                        "1",
                    ),
                ],
            ),
        )
        "###);
    }

    #[test]
    fn test_android_medium_device_class() {
        let mut event = Event {
            contexts: {
                let mut contexts = Contexts::new();
                contexts.add(DeviceContext {
                    family: "android".to_owned().into(),
                    processor_frequency: 2000.into(),
                    processor_count: 8.into(),
                    memory_size: (6 * 1024 * 1024 * 1024).into(),
                    ..Default::default()
                });
                Annotated::new(contexts)
            },
            ..Default::default()
        };
        normalize_device_class(&mut event);
        assert_debug_snapshot!(event.tags, @r###"
        Tags(
            PairList(
                [
                    TagEntry(
                        "device.class",
                        "2",
                    ),
                ],
            ),
        )
        "###);
    }

    #[test]
    fn test_android_high_device_class() {
        let mut event = Event {
            contexts: {
                let mut contexts = Contexts::new();
                contexts.add(DeviceContext {
                    family: "android".to_owned().into(),
                    processor_frequency: 2500.into(),
                    processor_count: 8.into(),
                    memory_size: (6 * 1024 * 1024 * 1024).into(),
                    ..Default::default()
                });
                Annotated::new(contexts)
            },
            ..Default::default()
        };
        normalize_device_class(&mut event);
        assert_debug_snapshot!(event.tags, @r###"
        Tags(
            PairList(
                [
                    TagEntry(
                        "device.class",
                        "3",
                    ),
                ],
            ),
        )
        "###);
    }

    #[test]
    fn test_keeps_valid_measurement() {
        let name = "lcp";
        let measurement = Measurement {
            value: Annotated::new(420.69.try_into().unwrap()),
            unit: Annotated::new(MetricUnit::Duration(DurationUnit::MilliSecond)),
        };

        assert!(!is_measurement_dropped(name, measurement));
    }

    #[test]
    fn test_drops_too_long_measurement_names() {
        let name = "lcpppppppppppppppppppppppppppp";
        let measurement = Measurement {
            value: Annotated::new(420.69.try_into().unwrap()),
            unit: Annotated::new(MetricUnit::Duration(DurationUnit::MilliSecond)),
        };

        assert!(is_measurement_dropped(name, measurement));
    }

    #[test]
    fn test_drops_measurements_with_invalid_characters() {
        let name = "i æm frøm nørwåy";
        let measurement = Measurement {
            value: Annotated::new(420.69.try_into().unwrap()),
            unit: Annotated::new(MetricUnit::Duration(DurationUnit::MilliSecond)),
        };

        assert!(is_measurement_dropped(name, measurement));
    }

    fn is_measurement_dropped(name: &str, measurement: Measurement) -> bool {
        let max_name_and_unit_len = Some(30);

        let mut measurements: BTreeMap<String, Annotated<Measurement>> = Object::new();
        measurements.insert(name.to_owned(), Annotated::new(measurement));

        let mut measurements = Measurements(measurements);
        let mut meta = Meta::default();
        let measurements_config = MeasurementsConfig {
            max_custom_measurements: 1,
            ..Default::default()
        };

        let dynamic_config = CombinedMeasurementsConfig::new(Some(&measurements_config), None);

        // Just for clarity.
        // Checks that there is 1 measurement before processing.
        assert_eq!(measurements.len(), 1);

        remove_invalid_measurements(
            &mut measurements,
            &mut meta,
            dynamic_config,
            max_name_and_unit_len,
        );

        // Checks whether the measurement is dropped.
        measurements.is_empty()
    }

    #[test]
    fn test_custom_measurements_not_dropped() {
        let mut measurements = Measurements(BTreeMap::from([(
            "custom_measurement".to_owned(),
            Annotated::new(Measurement {
                value: Annotated::new(42.0.try_into().unwrap()),
                unit: Annotated::new(MetricUnit::Duration(DurationUnit::MilliSecond)),
            }),
        )]));

        let original = measurements.clone();
        remove_invalid_measurements(
            &mut measurements,
            &mut Meta::default(),
            CombinedMeasurementsConfig::new(None, None),
            Some(30),
        );

        assert_eq!(original, measurements);
    }

    #[test]
    fn test_normalize_app_start_measurements_does_not_add_measurements() {
        let mut measurements = Annotated::<Measurements>::from_json(r###"{}"###)
            .unwrap()
            .into_value()
            .unwrap();
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {},
        )
        "###);
        normalize_app_start_measurements(&mut measurements);
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {},
        )
        "###);
    }

    #[test]
    fn test_normalize_app_start_cold_measurements() {
        let mut measurements =
            Annotated::<Measurements>::from_json(r#"{"app.start.cold": {"value": 1.1}}"#)
                .unwrap()
                .into_value()
                .unwrap();
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {
                "app.start.cold": Measurement {
                    value: 1.1,
                    unit: ~,
                },
            },
        )
        "###);
        normalize_app_start_measurements(&mut measurements);
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {
                "app_start_cold": Measurement {
                    value: 1.1,
                    unit: ~,
                },
            },
        )
        "###);
    }

    #[test]
    fn test_normalize_app_start_warm_measurements() {
        let mut measurements =
            Annotated::<Measurements>::from_json(r#"{"app.start.warm": {"value": 1.1}}"#)
                .unwrap()
                .into_value()
                .unwrap();
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {
                "app.start.warm": Measurement {
                    value: 1.1,
                    unit: ~,
                },
            },
        )
        "###);
        normalize_app_start_measurements(&mut measurements);
        insta::assert_debug_snapshot!(measurements, @r###"
        Measurements(
            {
                "app_start_warm": Measurement {
                    value: 1.1,
                    unit: ~,
                },
            },
        )
        "###);
    }

    #[test]
    fn test_ai_legacy_measurements() {
        let json = r#"
            {
                "spans": [
                    {
                        "timestamp": 1702474613.0495,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "ai.chat_completions.openai",
                        "span_id": "9c01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "measurements": {
                            "ai_prompt_tokens_used": {
                                "value": 1000
                            },
                            "ai_completion_tokens_used": {
                                "value": 2000
                            }
                        },
                        "data": {
                            "ai.model_id": "claude-2.1"
                        }
                    },
                    {
                        "timestamp": 1702474613.0495,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "ai.chat_completions.openai",
                        "span_id": "ac01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "measurements": {
                            "ai_prompt_tokens_used": {
                                "value": 1000
                            },
                            "ai_completion_tokens_used": {
                                "value": 2000
                            }
                        },
                        "data": {
                            "ai.model_id": "gpt4-21-04"
                        }
                    }
                ]
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(
            &mut event,
            &NormalizationConfig {
                ai_model_metadata: Some(&ModelMetadata {
                    version: 1,
                    models: HashMap::from([
                        (
                            Pattern::new("claude-2.1").unwrap(),
                            ModelMetadataEntry {
                                costs: Some(ModelCostV2 {
                                    input_per_token: 0.01,
                                    output_per_token: 0.02,
                                    output_reasoning_per_token: 0.03,
                                    input_cached_per_token: 0.0,
                                    input_cache_write_per_token: 0.0,
                                }),
                                context_size: None,
                            },
                        ),
                        (
                            Pattern::new("gpt4-21-04").unwrap(),
                            ModelMetadataEntry {
                                costs: Some(ModelCostV2 {
                                    input_per_token: 0.02,
                                    output_per_token: 0.03,
                                    output_reasoning_per_token: 0.04,
                                    input_cached_per_token: 0.0,
                                    input_cache_write_per_token: 0.0,
                                }),
                                context_size: None,
                            },
                        ),
                    ]),
                }),
                ..NormalizationConfig::default()
            },
        );

        let [span1, span2] = collect_span_data(event);

        assert_annotated_snapshot!(span1, @r#"
        {
          "gen_ai.usage.total_tokens": 3000.0,
          "gen_ai.usage.input_tokens": 1000.0,
          "gen_ai.usage.output_tokens": 2000.0,
          "gen_ai.response.model": "claude-2.1",
          "gen_ai.request.model": "claude-2.1",
          "gen_ai.cost.total_tokens": 50.0,
          "gen_ai.cost.input_tokens": 10.0,
          "gen_ai.cost.output_tokens": 40.0,
          "gen_ai.response.tokens_per_second": 62500.0,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
        assert_annotated_snapshot!(span2, @r#"
        {
          "gen_ai.usage.total_tokens": 3000.0,
          "gen_ai.usage.input_tokens": 1000.0,
          "gen_ai.usage.output_tokens": 2000.0,
          "gen_ai.response.model": "gpt4-21-04",
          "gen_ai.request.model": "gpt4-21-04",
          "gen_ai.cost.total_tokens": 80.0,
          "gen_ai.cost.input_tokens": 20.0,
          "gen_ai.cost.output_tokens": 60.0,
          "gen_ai.response.tokens_per_second": 62500.0,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
    }

    #[test]
    fn test_ai_data() {
        let json = r#"
            {
                "spans": [
                    {
                        "timestamp": 1702474614.0175,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "gen_ai.chat_completions.openai",
                        "span_id": "9c01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.usage.input_tokens": 1000,
                            "gen_ai.usage.output_tokens": 2000,
                            "gen_ai.usage.output_tokens.reasoning": 1000,
                            "gen_ai.usage.input_tokens.cached": 500,
                            "gen_ai.request.model": "claude-2.1"
                        }
                    },
                    {
                        "timestamp": 1702474614.0175,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "gen_ai.chat_completions.openai",
                        "span_id": "ac01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.usage.input_tokens": 1000,
                            "gen_ai.usage.output_tokens": 2000,
                            "gen_ai.request.model": "gpt4-21-04"
                        }
                    },
                    {
                        "timestamp": 1702474614.0175,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "gen_ai.chat_completions.openai",
                        "span_id": "ac01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.usage.input_tokens": 1000,
                            "gen_ai.usage.output_tokens": 2000,
                            "gen_ai.response.model": "gpt4-21-04"
                        }
                    }
                ]
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(
            &mut event,
            &NormalizationConfig {
                ai_model_metadata: Some(&ModelMetadata {
                    version: 1,
                    models: HashMap::from([
                        (
                            Pattern::new("claude-2.1").unwrap(),
                            ModelMetadataEntry {
                                costs: Some(ModelCostV2 {
                                    input_per_token: 0.01,
                                    output_per_token: 0.02,
                                    output_reasoning_per_token: 0.03,
                                    input_cached_per_token: 0.04,
                                    input_cache_write_per_token: 0.0,
                                }),
                                context_size: None,
                            },
                        ),
                        (
                            Pattern::new("gpt4-21-04").unwrap(),
                            ModelMetadataEntry {
                                costs: Some(ModelCostV2 {
                                    input_per_token: 0.09,
                                    output_per_token: 0.05,
                                    output_reasoning_per_token: 0.0,
                                    input_cached_per_token: 0.0,
                                    input_cache_write_per_token: 0.0,
                                }),
                                context_size: None,
                            },
                        ),
                    ]),
                }),
                ..NormalizationConfig::default()
            },
        );

        let [span1, span2, span3] = collect_span_data(event);

        assert_annotated_snapshot!(span1, @r#"
        {
          "gen_ai.usage.total_tokens": 3000.0,
          "gen_ai.usage.input_tokens": 1000,
          "gen_ai.usage.input_tokens.cached": 500,
          "gen_ai.usage.output_tokens": 2000,
          "gen_ai.usage.output_tokens.reasoning": 1000,
          "gen_ai.response.model": "claude-2.1",
          "gen_ai.request.model": "claude-2.1",
          "gen_ai.cost.total_tokens": 75.0,
          "gen_ai.cost.input_tokens": 25.0,
          "gen_ai.cost.output_tokens": 50.0,
          "gen_ai.response.tokens_per_second": 2000.0,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
        assert_annotated_snapshot!(span2, @r#"
        {
          "gen_ai.usage.total_tokens": 3000.0,
          "gen_ai.usage.input_tokens": 1000,
          "gen_ai.usage.output_tokens": 2000,
          "gen_ai.response.model": "gpt4-21-04",
          "gen_ai.request.model": "gpt4-21-04",
          "gen_ai.cost.total_tokens": 190.0,
          "gen_ai.cost.input_tokens": 90.0,
          "gen_ai.cost.output_tokens": 100.0,
          "gen_ai.response.tokens_per_second": 2000.0,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
        assert_annotated_snapshot!(span3, @r#"
        {
          "gen_ai.usage.total_tokens": 3000.0,
          "gen_ai.usage.input_tokens": 1000,
          "gen_ai.usage.output_tokens": 2000,
          "gen_ai.response.model": "gpt4-21-04",
          "gen_ai.cost.total_tokens": 190.0,
          "gen_ai.cost.input_tokens": 90.0,
          "gen_ai.cost.output_tokens": 100.0,
          "gen_ai.response.tokens_per_second": 2000.0,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
    }

    #[test]
    fn test_ai_data_with_no_tokens() {
        let json = r#"
            {
                "spans": [
                    {
                        "timestamp": 1702474613.0495,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "gen_ai.invoke_agent",
                        "span_id": "9c01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.request.model": "claude-2.1"
                        }
                    }
                ]
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(
            &mut event,
            &NormalizationConfig {
                ai_model_metadata: Some(&ModelMetadata {
                    version: 1,
                    models: HashMap::from([(
                        Pattern::new("claude-2.1").unwrap(),
                        ModelMetadataEntry {
                            costs: Some(ModelCostV2 {
                                input_per_token: 0.01,
                                output_per_token: 0.02,
                                output_reasoning_per_token: 0.03,
                                input_cached_per_token: 0.0,
                                input_cache_write_per_token: 0.0,
                            }),
                            context_size: None,
                        },
                    )]),
                }),
                ..NormalizationConfig::default()
            },
        );

        let [span] = collect_span_data(event);

        assert_annotated_snapshot!(span, @r#"
        {
          "gen_ai.response.model": "claude-2.1",
          "gen_ai.request.model": "claude-2.1",
          "gen_ai.operation.type": "agent"
        }
        "#);
    }

    #[test]
    fn test_ai_data_with_ai_op_prefix() {
        let json = r#"
            {
                "spans": [
                    {
                        "timestamp": 1702474613.0495,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "ai.chat_completions.openai",
                        "span_id": "9c01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.usage.input_tokens": 1000,
                            "gen_ai.usage.output_tokens": 2000,
                            "gen_ai.usage.output_tokens.reasoning": 1000,
                            "gen_ai.usage.input_tokens.cached": 500,
                            "gen_ai.request.model": "claude-2.1"
                        }
                    },
                    {
                        "timestamp": 1702474613.0495,
                        "start_timestamp": 1702474613.0175,
                        "description": "OpenAI ",
                        "op": "ai.chat_completions.openai",
                        "span_id": "ac01bd820a083e63",
                        "parent_span_id": "a1e13f3f06239d69",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.usage.input_tokens": 1000,
                            "gen_ai.usage.output_tokens": 2000,
                            "gen_ai.request.model": "gpt4-21-04"
                        }
                    }
                ]
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(
            &mut event,
            &NormalizationConfig {
                ai_model_metadata: Some(&ModelMetadata {
                    version: 1,
                    models: HashMap::from([
                        (
                            Pattern::new("claude-2.1").unwrap(),
                            ModelMetadataEntry {
                                costs: Some(ModelCostV2 {
                                    input_per_token: 0.01,
                                    output_per_token: 0.02,
                                    output_reasoning_per_token: 0.0,
                                    input_cached_per_token: 0.04,
                                    input_cache_write_per_token: 0.0,
                                }),
                                context_size: None,
                            },
                        ),
                        (
                            Pattern::new("gpt4-21-04").unwrap(),
                            ModelMetadataEntry {
                                costs: Some(ModelCostV2 {
                                    input_per_token: 0.09,
                                    output_per_token: 0.05,
                                    output_reasoning_per_token: 0.06,
                                    input_cached_per_token: 0.0,
                                    input_cache_write_per_token: 0.0,
                                }),
                                context_size: None,
                            },
                        ),
                    ]),
                }),
                ..NormalizationConfig::default()
            },
        );

        let [span1, span2] = collect_span_data(event);

        assert_annotated_snapshot!(span1, @r#"
        {
          "gen_ai.usage.total_tokens": 3000.0,
          "gen_ai.usage.input_tokens": 1000,
          "gen_ai.usage.input_tokens.cached": 500,
          "gen_ai.usage.output_tokens": 2000,
          "gen_ai.usage.output_tokens.reasoning": 1000,
          "gen_ai.response.model": "claude-2.1",
          "gen_ai.request.model": "claude-2.1",
          "gen_ai.cost.total_tokens": 65.0,
          "gen_ai.cost.input_tokens": 25.0,
          "gen_ai.cost.output_tokens": 40.0,
          "gen_ai.response.tokens_per_second": 62500.0,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
        assert_annotated_snapshot!(span2, @r#"
        {
          "gen_ai.usage.total_tokens": 3000.0,
          "gen_ai.usage.input_tokens": 1000,
          "gen_ai.usage.output_tokens": 2000,
          "gen_ai.response.model": "gpt4-21-04",
          "gen_ai.request.model": "gpt4-21-04",
          "gen_ai.cost.total_tokens": 190.0,
          "gen_ai.cost.input_tokens": 90.0,
          "gen_ai.cost.output_tokens": 100.0,
          "gen_ai.response.tokens_per_second": 62500.0,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
    }

    #[test]
    fn test_ai_response_tokens_per_second_no_output_tokens() {
        let json = r#"
            {
                "spans": [
                    {
                        "timestamp": 1702474614.0175,
                        "start_timestamp": 1702474613.0175,
                        "op": "gen_ai.chat_completions",
                        "span_id": "9c01bd820a083e63",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.usage.input_tokens": 500
                        }
                    }
                ]
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(
            &mut event,
            &NormalizationConfig {
                ai_model_metadata: Some(&ModelMetadata {
                    version: 1,
                    models: HashMap::new(),
                }),
                ..NormalizationConfig::default()
            },
        );

        let [span] = collect_span_data(event);

        // Should not set response_tokens_per_second when there are no output tokens
        assert_annotated_snapshot!(span, @r#"
        {
          "gen_ai.usage.total_tokens": 500.0,
          "gen_ai.usage.input_tokens": 500,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
    }

    #[test]
    fn test_ai_response_tokens_per_second_zero_duration() {
        let json = r#"
            {
                "spans": [
                    {
                        "timestamp": 1702474613.0175,
                        "start_timestamp": 1702474613.0175,
                        "op": "gen_ai.chat_completions",
                        "span_id": "9c01bd820a083e63",
                        "trace_id": "922dda2462ea4ac2b6a4b339bee90863",
                        "data": {
                            "gen_ai.usage.output_tokens": 1000
                        }
                    }
                ]
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(
            &mut event,
            &NormalizationConfig {
                ai_model_metadata: Some(&ModelMetadata {
                    version: 1,
                    models: HashMap::new(),
                }),
                ..NormalizationConfig::default()
            },
        );

        let [span] = collect_span_data(event);

        // Should not set response_tokens_per_second when duration is zero
        assert_annotated_snapshot!(span, @r#"
        {
          "gen_ai.usage.total_tokens": 1000.0,
          "gen_ai.usage.output_tokens": 1000,
          "gen_ai.operation.type": "ai_client"
        }
        "#);
    }

    #[test]
    fn test_ai_operation_type_mapping() {
        let json = r#"
            {
                "type": "transaction",
                "transaction": "test-transaction",
                "spans": [
                    {
                        "op": "gen_ai.chat",
                        "description": "AI chat completion",
                        "data": {}
                    },
                    {
                        "op": "gen_ai.handoff",
                        "description": "AI agent handoff",
                        "data": {}
                    },
                    {
                        "op": "gen_ai.unknown",
                        "description": "Unknown AI operation",
                        "data": {}
                    }
                ]
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(&mut event, &NormalizationConfig::default());

        let [span1, span2, span3] = collect_span_data(event);

        assert_annotated_snapshot!(span1, @r#"
        {
          "gen_ai.operation.type": "ai_client"
        }
        "#);
        assert_annotated_snapshot!(span2, @r#"
        {
          "gen_ai.operation.type": "handoff"
        }
        "#);
        assert_annotated_snapshot!(span3, @r#"
        {
          "gen_ai.operation.type": "ai_client"
        }
        "#);
    }

    #[test]
    fn test_apple_high_device_class() {
        let mut event = Event {
            contexts: {
                let mut contexts = Contexts::new();
                contexts.add(DeviceContext {
                    family: "iPhone".to_owned().into(),
                    model: "iPhone15,3".to_owned().into(),
                    ..Default::default()
                });
                Annotated::new(contexts)
            },
            ..Default::default()
        };
        normalize_device_class(&mut event);
        assert_debug_snapshot!(event.tags, @r###"
        Tags(
            PairList(
                [
                    TagEntry(
                        "device.class",
                        "3",
                    ),
                ],
            ),
        )
        "###);
    }

    #[test]
    fn test_filter_mobile_outliers() {
        let mut measurements =
            Annotated::<Measurements>::from_json(r#"{"app_start_warm": {"value": 180001}}"#)
                .unwrap()
                .into_value()
                .unwrap();
        assert_eq!(measurements.len(), 1);
        filter_mobile_outliers(&mut measurements);
        assert_eq!(measurements.len(), 0);
    }

    #[test]
    fn test_backfill_app_vitals_start_cold() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {"app_start_cold": {"value": 1234.0, "unit": "millisecond"}}
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "app.vitals.start.value": Measurement {
                    value: 1234.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
                "app_start_cold": Measurement {
                    value: 1234.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @r#"
        Tags(
            PairList(
                [
                    TagEntry(
                        "app.vitals.start.type",
                        "cold",
                    ),
                ],
            ),
        )
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_warm() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {"app_start_warm": {"value": 567.0, "unit": "millisecond"}}
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "app.vitals.start.value": Measurement {
                    value: 567.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
                "app_start_warm": Measurement {
                    value: 567.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @r#"
        Tags(
            PairList(
                [
                    TagEntry(
                        "app.vitals.start.type",
                        "warm",
                    ),
                ],
            ),
        )
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_cold_preferred_over_warm() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "app_start_cold": {"value": 100.0, "unit": "millisecond"},
                "app_start_warm": {"value": 200.0, "unit": "millisecond"}
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "app.vitals.start.value": Measurement {
                    value: 100.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
                "app_start_cold": Measurement {
                    value: 100.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
                "app_start_warm": Measurement {
                    value: 200.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @r#"
        Tags(
            PairList(
                [
                    TagEntry(
                        "app.vitals.start.type",
                        "cold",
                    ),
                ],
            ),
        )
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_no_app_start_noop() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {"lcp": {"value": 100.0}}
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "lcp": Measurement {
                    value: 100.0,
                    unit: ~,
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @"~");
    }

    #[test]
    fn test_backfill_app_vitals_start_respects_outlier_filter() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {"app_start_cold": {"value": 180001.0, "unit": "millisecond"}}
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        normalize_event_measurements(&mut event, None, None);
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @"
        Measurements(
            {},
        )
        ");
        assert_debug_snapshot!(event.tags, @"~");
    }

    #[test]
    fn test_backfill_app_vitals_start_non_transaction_payload_noop() {
        let json = r#"{
            "type": "error",
            "measurements": {
                "app_start_cold": {"value": 1234.0, "unit": "millisecond"}
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "app_start_cold": Measurement {
                    value: 1234.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @"~");
    }

    #[test]
    fn test_backfill_app_vitals_start_does_not_overwrite_value() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "app_start_cold": {"value": 100.0, "unit": "millisecond"},
                "app.vitals.start.value": {"value": 999.0, "unit": "millisecond"}
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "app.vitals.start.value": Measurement {
                    value: 999.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
                "app_start_cold": Measurement {
                    value: 100.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @"~");
    }

    #[test]
    fn test_backfill_app_vitals_start_does_not_overwrite_type() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {"app_start_cold": {"value": 100.0, "unit": "millisecond"}}
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        event
            .tags
            .value_mut()
            .get_or_insert_with(Tags::default)
            .0
            .insert(
                String::from(APP__VITALS__START__TYPE),
                Annotated::new("warm".to_owned()),
            );

        backfill_app_vitals_start(&mut event);

        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "app_start_cold": Measurement {
                    value: 100.0,
                    unit: Duration(
                        MilliSecond,
                    ),
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @r#"
        Tags(
            PairList(
                [
                    TagEntry(
                        "app.vitals.start.type",
                        "warm",
                    ),
                ],
            ),
        )
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_invalid_unit_noop() {
        let json = r#"{
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {"app_start_cold": {"value": 1.5, "unit": "second"}}
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();
        backfill_app_vitals_start(&mut event);
        assert_debug_snapshot!(event.measurements, @r#"
        Measurements(
            {
                "app_start_cold": Measurement {
                    value: 1.5,
                    unit: Duration(
                        Second,
                    ),
                },
            },
        )
        "#);
        assert_debug_snapshot!(event.tags, @"~");
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_from_legacy_measurement() {
        let json = r#"{
            "type": "transaction",
            "transaction": "MainActivity",
            "contexts": {
                "trace": {
                    "op": "ui.load"
                }
            },
            "measurements": {
                "app_start_cold": {
                    "value": 1234.0,
                    "unit": "millisecond"
                }
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @r#"
        {
          "app.vitals.start.screen": "MainActivity"
        }
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_from_dotted_measurement() {
        let mut event = app_vitals_start_screen_event(
            "transaction",
            Some("SettingsActivity"),
            "ui.load",
            Some(APP__VITALS__START__WARM__VALUE),
            None,
        );

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @r#"
        {
          "app.vitals.start.screen": "SettingsActivity"
        }
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_from_start_value_measurement() {
        let mut event = app_vitals_start_screen_event(
            "transaction",
            Some("ProfileActivity"),
            "ui.load",
            Some(APP__VITALS__START__VALUE),
            None,
        );

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @r#"
        {
          "app.vitals.start.screen": "ProfileActivity"
        }
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_requires_ui_load() {
        let mut event = app_vitals_start_screen_event(
            "transaction",
            Some("MainActivity"),
            "navigation",
            Some("app_start_cold"),
            None,
        );

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @"{}");
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_requires_app_start_measurement() {
        let mut event = app_vitals_start_screen_event(
            "transaction",
            Some("MainActivity"),
            "ui.load",
            None,
            None,
        );

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @"{}");
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_only_requires_measurement_key() {
        let json = r#"{
            "type": "transaction",
            "transaction": "MainActivity",
            "contexts": {
                "trace": {
                    "op": "ui.load"
                }
            },
            "measurements": {
                "app_start_cold": {
                    "unit": "millisecond"
                }
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json)
            .unwrap()
            .into_value()
            .unwrap();

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @r#"
        {
          "app.vitals.start.screen": "MainActivity"
        }
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_preserves_existing_value() {
        let mut event = app_vitals_start_screen_event(
            "transaction",
            Some("MainActivity"),
            "ui.load",
            Some("app_start_cold"),
            Some("SDKScreen"),
        );

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @r#"
        {
          "app.vitals.start.screen": "SDKScreen"
        }
        "#);
    }

    #[test]
    fn test_backfill_app_vitals_start_screen_requires_transaction_name() {
        let mut event = app_vitals_start_screen_event(
            "transaction",
            Some("<unlabeled transaction>"),
            "ui.load",
            Some("app_start_cold"),
            None,
        );

        backfill_app_vitals_start(&mut event);

        assert_annotated_snapshot!(trace_context_data(&event), @"{}");
    }

    #[test]
    fn test_computed_performance_score_transaction() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "fid": {"value": 213, "unit": "millisecond"},
                "fcp": {"value": 1237, "unit": "millisecond"},
                "lcp": {"value": 6596, "unit": "millisecond"},
                "cls": {"value": 0.11}
            },
            "contexts": {
                "browser": {
                    "name": "Chrome",
                    "version": "120.1.1",
                    "type": "browser"
                }
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "fcp",
                            "weight": 0.15,
                            "p10": 900,
                            "p50": 1600
                        },
                        {
                            "measurement": "lcp",
                            "weight": 0.30,
                            "p10": 1200,
                            "p50": 2400
                        },
                        {
                            "measurement": "fid",
                            "weight": 0.30,
                            "p10": 100,
                            "p50": 300
                        },
                        {
                            "measurement": "cls",
                            "weight": 0.25,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                        {
                            "measurement": "ttfb",
                            "weight": 0.0,
                            "p10": 0.2,
                            "p50": 0.4
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome"
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "contexts": {
            "browser": {
              "name": "Chrome",
              "version": "120.1.1",
              "type": "browser",
            },
          },
          "measurements": {
            "cls": {
              "value": 0.11,
            },
            "fcp": {
              "value": 1237.0,
              "unit": "millisecond",
            },
            "fid": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "lcp": {
              "value": 6596.0,
              "unit": "millisecond",
            },
            "score.cls": {
              "value": 0.21864170607444863,
              "unit": "ratio",
            },
            "score.fcp": {
              "value": 0.10750855443790831,
              "unit": "ratio",
            },
            "score.fid": {
              "value": 0.19657361348282545,
              "unit": "ratio",
            },
            "score.lcp": {
              "value": 0.009238896571386584,
              "unit": "ratio",
            },
            "score.ratio.cls": {
              "value": 0.8745668242977945,
              "unit": "ratio",
            },
            "score.ratio.fcp": {
              "value": 0.7167236962527221,
              "unit": "ratio",
            },
            "score.ratio.fid": {
              "value": 0.6552453782760849,
              "unit": "ratio",
            },
            "score.ratio.lcp": {
              "value": 0.03079632190462195,
              "unit": "ratio",
            },
            "score.total": {
              "value": 0.531962770566569,
              "unit": "ratio",
            },
            "score.weight.cls": {
              "value": 0.25,
              "unit": "ratio",
            },
            "score.weight.fcp": {
              "value": 0.15,
              "unit": "ratio",
            },
            "score.weight.fid": {
              "value": 0.3,
              "unit": "ratio",
            },
            "score.weight.lcp": {
              "value": 0.3,
              "unit": "ratio",
            },
            "score.weight.ttfb": {
              "value": 0.0,
              "unit": "ratio",
            },
          },
        }
        "###);
    }

    /// A version of `test_computed_performance_score_transaction` for
    /// V2 spans. Results are _mutatis mutandis_ the same.
    ///
    /// The `"condition"` on the profile is written as a disjunction,
    /// checking for the browser name in both `event.context` and in
    /// `span.attributes`.
    #[test]
    fn test_computed_performance_score_spanv2() {
        let json = r#"
        {
            "end_timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "attributes": {
                "browser.name": {"value": "Chrome", "type": "string"},
                "browser.version": {"value": "120.1.1", "type": "string"},
                "fid": {"value": 213, "type": "double"},
                "browser.web_vital.fcp.value": {"value": 1237.0, "type": "double"},
                "lcp": {"value": 6596, "type": "double"},
                "browser.web_vital.cls.value": {"value": 0.11, "type": "double"}
            }
        }
        "#;

        let mut span = Annotated::<SpanV2>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "fcp",
                            "weight": 0.15,
                            "p10": 900,
                            "p50": 1600
                        },
                        {
                            "measurement": "lcp",
                            "weight": 0.30,
                            "p10": 1200,
                            "p50": 2400
                        },
                        {
                            "measurement": "fid",
                            "weight": 0.30,
                            "p10": 100,
                            "p50": 300
                        },
                        {
                            "measurement": "cls",
                            "weight": 0.25,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                        {
                            "measurement": "ttfb",
                            "weight": 0.0,
                            "p10": 0.2,
                            "p50": 0.4
                        },
                    ],
                    "condition": {
                        "op": "or",
                        "inner": [{
                            "op":"eq",
                            "name": "event.context.browser.name",
                            "value": "Chrome"
                        }, {
                            "op":"eq",
                            "name": "span.attributes.browser.name.value",
                            "value": "Chrome"
                        }]
                    }
                }
            ]
        }))
        .unwrap();

        eap::normalize_attribute_names(&mut span.attributes);
        normalize_performance_score(&mut span, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(span)), {}, @r###"
        {
          "start_timestamp": 1619420400.0,
          "end_timestamp": 1619420405.0,
          "attributes": {
            "browser.name": {
              "type": "string",
              "value": "Chrome",
            },
            "browser.version": {
              "type": "string",
              "value": "120.1.1",
            },
            "browser.web_vital.cls.value": {
              "type": "double",
              "value": 0.11,
            },
            "browser.web_vital.fcp.value": {
              "type": "double",
              "value": 1237.0,
            },
            "browser.web_vital.lcp.value": {
              "type": "double",
              "value": 6596,
            },
            "fid": {
              "type": "double",
              "value": 213,
            },
            "lcp": {
              "type": "double",
              "value": 6596,
            },
            "score.cls": {
              "type": "double",
              "value": 0.21864170607444863,
            },
            "score.fcp": {
              "type": "double",
              "value": 0.10750855443790831,
            },
            "score.fid": {
              "type": "double",
              "value": 0.19657361348282545,
            },
            "score.lcp": {
              "type": "double",
              "value": 0.009238896571386584,
            },
            "score.ratio.cls": {
              "type": "double",
              "value": 0.8745668242977945,
            },
            "score.ratio.fcp": {
              "type": "double",
              "value": 0.7167236962527221,
            },
            "score.ratio.fid": {
              "type": "double",
              "value": 0.6552453782760849,
            },
            "score.ratio.lcp": {
              "type": "double",
              "value": 0.03079632190462195,
            },
            "score.total": {
              "type": "double",
              "value": 0.531962770566569,
            },
            "score.weight.cls": {
              "type": "double",
              "value": 0.25,
            },
            "score.weight.fcp": {
              "type": "double",
              "value": 0.15,
            },
            "score.weight.fid": {
              "type": "double",
              "value": 0.3,
            },
            "score.weight.lcp": {
              "type": "double",
              "value": 0.3,
            },
            "score.weight.ttfb": {
              "type": "double",
              "value": 0.0,
            },
          },
        }
        "###);
    }

    // Test performance score is calculated correctly when the sum of weights is under 1.
    // The expected result should normalize the weights to a sum of 1 and scale the weight measurements accordingly.
    #[test]
    fn test_computed_performance_score_with_under_normalized_weights() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "fid": {"value": 213, "unit": "millisecond"},
                "fcp": {"value": 1237, "unit": "millisecond"},
                "lcp": {"value": 6596, "unit": "millisecond"},
                "cls": {"value": 0.11}
            },
            "contexts": {
                "browser": {
                    "name": "Chrome",
                    "version": "120.1.1",
                    "type": "browser"
                }
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "fcp",
                            "weight": 0.03,
                            "p10": 900,
                            "p50": 1600
                        },
                        {
                            "measurement": "lcp",
                            "weight": 0.06,
                            "p10": 1200,
                            "p50": 2400
                        },
                        {
                            "measurement": "fid",
                            "weight": 0.06,
                            "p10": 100,
                            "p50": 300
                        },
                        {
                            "measurement": "cls",
                            "weight": 0.05,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                        {
                            "measurement": "ttfb",
                            "weight": 0.0,
                            "p10": 0.2,
                            "p50": 0.4
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome"
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "contexts": {
            "browser": {
              "name": "Chrome",
              "version": "120.1.1",
              "type": "browser",
            },
          },
          "measurements": {
            "cls": {
              "value": 0.11,
            },
            "fcp": {
              "value": 1237.0,
              "unit": "millisecond",
            },
            "fid": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "lcp": {
              "value": 6596.0,
              "unit": "millisecond",
            },
            "score.cls": {
              "value": 0.21864170607444863,
              "unit": "ratio",
            },
            "score.fcp": {
              "value": 0.10750855443790831,
              "unit": "ratio",
            },
            "score.fid": {
              "value": 0.19657361348282545,
              "unit": "ratio",
            },
            "score.lcp": {
              "value": 0.009238896571386584,
              "unit": "ratio",
            },
            "score.ratio.cls": {
              "value": 0.8745668242977945,
              "unit": "ratio",
            },
            "score.ratio.fcp": {
              "value": 0.7167236962527221,
              "unit": "ratio",
            },
            "score.ratio.fid": {
              "value": 0.6552453782760849,
              "unit": "ratio",
            },
            "score.ratio.lcp": {
              "value": 0.03079632190462195,
              "unit": "ratio",
            },
            "score.total": {
              "value": 0.531962770566569,
              "unit": "ratio",
            },
            "score.weight.cls": {
              "value": 0.25,
              "unit": "ratio",
            },
            "score.weight.fcp": {
              "value": 0.15,
              "unit": "ratio",
            },
            "score.weight.fid": {
              "value": 0.3,
              "unit": "ratio",
            },
            "score.weight.lcp": {
              "value": 0.3,
              "unit": "ratio",
            },
            "score.weight.ttfb": {
              "value": 0.0,
              "unit": "ratio",
            },
          },
        }
        "###);
    }

    // Test performance score is calculated correctly when the sum of weights is over 1.
    // The expected result should normalize the weights to a sum of 1 and scale the weight measurements accordingly.
    #[test]
    fn test_computed_performance_score_with_over_normalized_weights() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "fid": {"value": 213, "unit": "millisecond"},
                "fcp": {"value": 1237, "unit": "millisecond"},
                "lcp": {"value": 6596, "unit": "millisecond"},
                "cls": {"value": 0.11}
            },
            "contexts": {
                "browser": {
                    "name": "Chrome",
                    "version": "120.1.1",
                    "type": "browser"
                }
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "fcp",
                            "weight": 0.30,
                            "p10": 900,
                            "p50": 1600
                        },
                        {
                            "measurement": "lcp",
                            "weight": 0.60,
                            "p10": 1200,
                            "p50": 2400
                        },
                        {
                            "measurement": "fid",
                            "weight": 0.60,
                            "p10": 100,
                            "p50": 300
                        },
                        {
                            "measurement": "cls",
                            "weight": 0.50,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                        {
                            "measurement": "ttfb",
                            "weight": 0.0,
                            "p10": 0.2,
                            "p50": 0.4
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome"
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "contexts": {
            "browser": {
              "name": "Chrome",
              "version": "120.1.1",
              "type": "browser",
            },
          },
          "measurements": {
            "cls": {
              "value": 0.11,
            },
            "fcp": {
              "value": 1237.0,
              "unit": "millisecond",
            },
            "fid": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "lcp": {
              "value": 6596.0,
              "unit": "millisecond",
            },
            "score.cls": {
              "value": 0.21864170607444863,
              "unit": "ratio",
            },
            "score.fcp": {
              "value": 0.10750855443790831,
              "unit": "ratio",
            },
            "score.fid": {
              "value": 0.19657361348282545,
              "unit": "ratio",
            },
            "score.lcp": {
              "value": 0.009238896571386584,
              "unit": "ratio",
            },
            "score.ratio.cls": {
              "value": 0.8745668242977945,
              "unit": "ratio",
            },
            "score.ratio.fcp": {
              "value": 0.7167236962527221,
              "unit": "ratio",
            },
            "score.ratio.fid": {
              "value": 0.6552453782760849,
              "unit": "ratio",
            },
            "score.ratio.lcp": {
              "value": 0.03079632190462195,
              "unit": "ratio",
            },
            "score.total": {
              "value": 0.531962770566569,
              "unit": "ratio",
            },
            "score.weight.cls": {
              "value": 0.25,
              "unit": "ratio",
            },
            "score.weight.fcp": {
              "value": 0.15,
              "unit": "ratio",
            },
            "score.weight.fid": {
              "value": 0.3,
              "unit": "ratio",
            },
            "score.weight.lcp": {
              "value": 0.3,
              "unit": "ratio",
            },
            "score.weight.ttfb": {
              "value": 0.0,
              "unit": "ratio",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_computed_performance_score_missing_measurement() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "a": {"value": 213, "unit": "millisecond"}
            },
            "contexts": {
                "browser": {
                    "name": "Chrome",
                    "version": "120.1.1",
                    "type": "browser"
                }
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 900,
                            "p50": 1600
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 1200,
                            "p50": 2400
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome"
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "contexts": {
            "browser": {
              "name": "Chrome",
              "version": "120.1.1",
              "type": "browser",
            },
          },
          "measurements": {
            "a": {
              "value": 213.0,
              "unit": "millisecond",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_computed_performance_score_optional_measurement() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "a": {"value": 213, "unit": "millisecond"},
                "b": {"value": 213, "unit": "millisecond"}
            },
            "contexts": {
                "browser": {
                    "name": "Chrome",
                    "version": "120.1.1",
                    "type": "browser"
                }
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 900,
                            "p50": 1600,
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                        {
                            "measurement": "c",
                            "weight": 0.55,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome"
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "contexts": {
            "browser": {
              "name": "Chrome",
              "version": "120.1.1",
              "type": "browser",
            },
          },
          "measurements": {
            "a": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "b": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "score.a": {
              "value": 0.33333215313291975,
              "unit": "ratio",
            },
            "score.b": {
              "value": 0.66666415149198,
              "unit": "ratio",
            },
            "score.ratio.a": {
              "value": 0.9999964593987591,
              "unit": "ratio",
            },
            "score.ratio.b": {
              "value": 0.9999962272379699,
              "unit": "ratio",
            },
            "score.total": {
              "value": 0.9999963046248997,
              "unit": "ratio",
            },
            "score.weight.a": {
              "value": 0.33333333333333337,
              "unit": "ratio",
            },
            "score.weight.b": {
              "value": 0.6666666666666667,
              "unit": "ratio",
            },
            "score.weight.c": {
              "value": 0.0,
              "unit": "ratio",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_computed_performance_score_weight_0() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "cls": {"value": 0.11}
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "cls",
                            "weight": 0,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                    ],
                    "condition": {
                        "op":"and",
                        "inner": []
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "measurements": {
            "cls": {
              "value": 0.11,
            },
          },
        }
        "###);
    }

    #[test]
    fn test_computed_performance_score_negative_value() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "ttfb": {"value": -100, "unit": "millisecond"}
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "ttfb",
                            "weight": 1.0,
                            "p10": 100.0,
                            "p50": 250.0
                        },
                    ],
                    "condition": {
                        "op":"and",
                        "inner": []
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "measurements": {
            "score.ratio.ttfb": {
              "value": 1.0,
              "unit": "ratio",
            },
            "score.total": {
              "value": 1.0,
              "unit": "ratio",
            },
            "score.ttfb": {
              "value": 1.0,
              "unit": "ratio",
            },
            "score.weight.ttfb": {
              "value": 1.0,
              "unit": "ratio",
            },
            "ttfb": {
              "value": -100.0,
              "unit": "millisecond",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_filter_negative_web_vital_measurements() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "ttfb": {"value": -100, "unit": "millisecond"}
            }
        }
        "#;
        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        // Allow ttfb as a builtinMeasurement with allow_negative defaulted to false.
        let project_measurement_config: MeasurementsConfig = serde_json::from_value(json!({
            "builtinMeasurements": [
                {"name": "ttfb", "unit": "millisecond"},
            ],
        }))
        .unwrap();

        let dynamic_measurement_config =
            CombinedMeasurementsConfig::new(Some(&project_measurement_config), None);

        normalize_event_measurements(&mut event, Some(dynamic_measurement_config), None);

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "measurements": {},
          "_meta": {
            "measurements": {
              "": Meta(Some(MetaInner(
                err: [
                  [
                    "invalid_data",
                    {
                      "reason": "Negative value for measurement ttfb not allowed: -100",
                    },
                  ],
                ],
                val: Some({
                  "ttfb": {
                    "unit": "millisecond",
                    "value": -100.0,
                  },
                }),
              ))),
            },
          },
        }
        "###);
    }

    #[test]
    fn test_computed_performance_score_multiple_profiles() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "cls": {"value": 0.11},
                "inp": {"value": 120.0}
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "cls",
                            "weight": 0,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                    ],
                    "condition": {
                        "op":"and",
                        "inner": []
                    }
                },
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "inp",
                            "weight": 1.0,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                    ],
                    "condition": {
                        "op":"and",
                        "inner": []
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "measurements": {
            "cls": {
              "value": 0.11,
            },
            "inp": {
              "value": 120.0,
            },
            "score.inp": {
              "value": 0.0,
              "unit": "ratio",
            },
            "score.ratio.inp": {
              "value": 0.0,
              "unit": "ratio",
            },
            "score.total": {
              "value": 0.0,
              "unit": "ratio",
            },
            "score.weight.inp": {
              "value": 1.0,
              "unit": "ratio",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_compute_performance_score_for_mobile_ios_profile() {
        let mut event = Annotated::<Event>::from_json(IOS_MOBILE_EVENT)
            .unwrap()
            .0
            .unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Mobile",
                    "scoreComponents": [
                        {
                            "measurement": "time_to_initial_display",
                            "weight": 0.25,
                            "p10": 1800.0,
                            "p50": 3000.0,
                            "optional": true
                        },
                        {
                            "measurement": "time_to_full_display",
                            "weight": 0.25,
                            "p10": 2500.0,
                            "p50": 4000.0,
                            "optional": true
                        },
                        {
                            "measurement": "app_start_warm",
                            "weight": 0.25,
                            "p10": 200.0,
                            "p50": 500.0,
                            "optional": true
                        },
                        {
                            "measurement": "app_start_cold",
                            "weight": 0.25,
                            "p10": 200.0,
                            "p50": 500.0,
                            "optional": true
                        }
                    ],
                    "condition": {
                        "op": "and",
                        "inner": [
                            {
                                "op": "or",
                                "inner": [
                                    {
                                        "op": "eq",
                                        "name": "event.sdk.name",
                                        "value": "sentry.cocoa"
                                    },
                                    {
                                        "op": "eq",
                                        "name": "event.sdk.name",
                                        "value": "sentry.java.android"
                                    }
                                ]
                            },
                            {
                                "op": "eq",
                                "name": "event.contexts.trace.op",
                                "value": "ui.load"
                            }
                        ]
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {});
    }

    #[test]
    fn test_compute_performance_score_for_mobile_android_profile() {
        let mut event = Annotated::<Event>::from_json(ANDROID_MOBILE_EVENT)
            .unwrap()
            .0
            .unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Mobile",
                    "scoreComponents": [
                        {
                            "measurement": "time_to_initial_display",
                            "weight": 0.25,
                            "p10": 1800.0,
                            "p50": 3000.0,
                            "optional": true
                        },
                        {
                            "measurement": "time_to_full_display",
                            "weight": 0.25,
                            "p10": 2500.0,
                            "p50": 4000.0,
                            "optional": true
                        },
                        {
                            "measurement": "app_start_warm",
                            "weight": 0.25,
                            "p10": 200.0,
                            "p50": 500.0,
                            "optional": true
                        },
                        {
                            "measurement": "app_start_cold",
                            "weight": 0.25,
                            "p10": 200.0,
                            "p50": 500.0,
                            "optional": true
                        }
                    ],
                    "condition": {
                        "op": "and",
                        "inner": [
                            {
                                "op": "or",
                                "inner": [
                                    {
                                        "op": "eq",
                                        "name": "event.sdk.name",
                                        "value": "sentry.cocoa"
                                    },
                                    {
                                        "op": "eq",
                                        "name": "event.sdk.name",
                                        "value": "sentry.java.android"
                                    }
                                ]
                            },
                            {
                                "op": "eq",
                                "name": "event.contexts.trace.op",
                                "value": "ui.load"
                            }
                        ]
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {});
    }

    #[test]
    fn test_computes_performance_score_and_tags_with_profile_version() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "inp": {"value": 120.0}
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "inp",
                            "weight": 1.0,
                            "p10": 0.1,
                            "p50": 0.25
                        },
                    ],
                    "condition": {
                        "op":"and",
                        "inner": []
                    },
                    "version": "beta"
                }
            ]
        }))
        .unwrap();

        normalize(
            &mut event,
            &mut Meta::default(),
            &NormalizationConfig {
                performance_score: Some(&performance_score),
                ..Default::default()
            },
        );

        insta::assert_ron_snapshot!(SerializableAnnotated(&event.contexts), {}, @r###"
        {
          "performance_score": {
            "score_profile_version": "beta",
            "type": "performancescore",
          },
        }
        "###);
        insta::assert_ron_snapshot!(SerializableAnnotated(&event.measurements), {}, @r###"
        {
          "inp": {
            "value": 120.0,
            "unit": "millisecond",
          },
          "score.inp": {
            "value": 0.0,
            "unit": "ratio",
          },
          "score.ratio.inp": {
            "value": 0.0,
            "unit": "ratio",
          },
          "score.total": {
            "value": 0.0,
            "unit": "ratio",
          },
          "score.weight.inp": {
            "value": 1.0,
            "unit": "ratio",
          },
        }
        "###);
    }

    #[test]
    fn test_normalize_adds_trace_context() {
        let json = r#"
        {
            "type": "error",
            "exception": {
                "values": [{"type": "ValueError", "value": "Should not happen"}]
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        normalize(
            &mut event,
            &mut Meta::default(),
            &NormalizationConfig {
                force_trace_context: true,
                ..Default::default()
            },
        );

        insta::assert_ron_snapshot!(SerializableAnnotated(&event.contexts), {
            ".event_id" => "[event-id]",
            ".trace.trace_id" => "[trace-id]",
            ".trace.span_id" => "[span-id]"
        }, @r#"
        {
          "trace": {
            "trace_id": "[trace-id]",
            "span_id": "[span-id]",
            "status": "unknown",
            "type": "trace",
          },
        }
        "#);
    }

    #[test]
    fn test_computes_standalone_cls_performance_score() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "cls": {"value": 0.5}
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
            {
                "name": "Default",
                "scoreComponents": [
                    {
                        "measurement": "fcp",
                        "weight": 0.15,
                        "p10": 900.0,
                        "p50": 1600.0,
                        "optional": true,
                    },
                    {
                        "measurement": "lcp",
                        "weight": 0.30,
                        "p10": 1200.0,
                        "p50": 2400.0,
                        "optional": true,
                    },
                    {
                        "measurement": "cls",
                        "weight": 0.15,
                        "p10": 0.1,
                        "p50": 0.25,
                        "optional": true,
                    },
                    {
                        "measurement": "ttfb",
                        "weight": 0.10,
                        "p10": 200.0,
                        "p50": 400.0,
                        "optional": true,
                    },
                ],
                "condition": {
                    "op": "and",
                    "inner": [],
                },
            }
            ]
        }))
        .unwrap();

        normalize(
            &mut event,
            &mut Meta::default(),
            &NormalizationConfig {
                performance_score: Some(&performance_score),
                ..Default::default()
            },
        );

        insta::assert_ron_snapshot!(SerializableAnnotated(&event.measurements), {}, @r###"
        {
          "cls": {
            "value": 0.5,
            "unit": "none",
          },
          "score.cls": {
            "value": 0.16615877613713903,
            "unit": "ratio",
          },
          "score.ratio.cls": {
            "value": 0.16615877613713903,
            "unit": "ratio",
          },
          "score.total": {
            "value": 0.16615877613713903,
            "unit": "ratio",
          },
          "score.weight.cls": {
            "value": 1.0,
            "unit": "ratio",
          },
          "score.weight.fcp": {
            "value": 0.0,
            "unit": "ratio",
          },
          "score.weight.lcp": {
            "value": 0.0,
            "unit": "ratio",
          },
          "score.weight.ttfb": {
            "value": 0.0,
            "unit": "ratio",
          },
        }
        "###);
    }

    #[test]
    fn test_computes_standalone_lcp_performance_score() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "lcp": {"value": 1200.0}
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
            {
                "name": "Default",
                "scoreComponents": [
                    {
                        "measurement": "fcp",
                        "weight": 0.15,
                        "p10": 900.0,
                        "p50": 1600.0,
                        "optional": true,
                    },
                    {
                        "measurement": "lcp",
                        "weight": 0.30,
                        "p10": 1200.0,
                        "p50": 2400.0,
                        "optional": true,
                    },
                    {
                        "measurement": "cls",
                        "weight": 0.15,
                        "p10": 0.1,
                        "p50": 0.25,
                        "optional": true,
                    },
                    {
                        "measurement": "ttfb",
                        "weight": 0.10,
                        "p10": 200.0,
                        "p50": 400.0,
                        "optional": true,
                    },
                ],
                "condition": {
                    "op": "and",
                    "inner": [],
                },
            }
            ]
        }))
        .unwrap();

        normalize(
            &mut event,
            &mut Meta::default(),
            &NormalizationConfig {
                performance_score: Some(&performance_score),
                ..Default::default()
            },
        );

        insta::assert_ron_snapshot!(SerializableAnnotated(&event.measurements), {}, @r###"
        {
          "lcp": {
            "value": 1200.0,
            "unit": "millisecond",
          },
          "score.lcp": {
            "value": 0.8999999314038525,
            "unit": "ratio",
          },
          "score.ratio.lcp": {
            "value": 0.8999999314038525,
            "unit": "ratio",
          },
          "score.total": {
            "value": 0.8999999314038525,
            "unit": "ratio",
          },
          "score.weight.cls": {
            "value": 0.0,
            "unit": "ratio",
          },
          "score.weight.fcp": {
            "value": 0.0,
            "unit": "ratio",
          },
          "score.weight.lcp": {
            "value": 1.0,
            "unit": "ratio",
          },
          "score.weight.ttfb": {
            "value": 0.0,
            "unit": "ratio",
          },
        }
        "###);
    }

    #[test]
    fn test_computed_performance_score_uses_first_matching_profile() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "a": {"value": 213, "unit": "millisecond"},
                "b": {"value": 213, "unit": "millisecond"}
            },
            "contexts": {
                "browser": {
                    "name": "Chrome",
                    "version": "120.1.1",
                    "type": "browser"
                }
            }
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Mobile",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 100,
                            "p50": 200,
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 100,
                            "p50": 200,
                            "optional": true
                        },
                        {
                            "measurement": "c",
                            "weight": 0.55,
                            "p10": 100,
                            "p50": 200,
                            "optional": true
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome Mobile"
                    }
                },
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 900,
                            "p50": 1600,
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                        {
                            "measurement": "c",
                            "weight": 0.55,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome"
                    }
                },
                {
                    "name": "Default",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 100,
                            "p50": 200,
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 100,
                            "p50": 200,
                            "optional": true
                        },
                        {
                            "measurement": "c",
                            "weight": 0.55,
                            "p10": 100,
                            "p50": 200,
                            "optional": true
                        },
                    ],
                    "condition": {
                        "op": "and",
                        "inner": [],
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "contexts": {
            "browser": {
              "name": "Chrome",
              "version": "120.1.1",
              "type": "browser",
            },
          },
          "measurements": {
            "a": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "b": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "score.a": {
              "value": 0.33333215313291975,
              "unit": "ratio",
            },
            "score.b": {
              "value": 0.66666415149198,
              "unit": "ratio",
            },
            "score.ratio.a": {
              "value": 0.9999964593987591,
              "unit": "ratio",
            },
            "score.ratio.b": {
              "value": 0.9999962272379699,
              "unit": "ratio",
            },
            "score.total": {
              "value": 0.9999963046248997,
              "unit": "ratio",
            },
            "score.weight.a": {
              "value": 0.33333333333333337,
              "unit": "ratio",
            },
            "score.weight.b": {
              "value": 0.6666666666666667,
              "unit": "ratio",
            },
            "score.weight.c": {
              "value": 0.0,
              "unit": "ratio",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_computed_performance_score_falls_back_to_default_profile() {
        let json = r#"
        {
            "type": "transaction",
            "timestamp": "2021-04-26T08:00:05+0100",
            "start_timestamp": "2021-04-26T08:00:00+0100",
            "measurements": {
                "a": {"value": 213, "unit": "millisecond"},
                "b": {"value": 213, "unit": "millisecond"}
            },
            "contexts": {}
        }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();

        let performance_score: PerformanceScoreConfig = serde_json::from_value(json!({
            "profiles": [
                {
                    "name": "Mobile",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 900,
                            "p50": 1600,
                            "optional": true
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                        {
                            "measurement": "c",
                            "weight": 0.55,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome Mobile"
                    }
                },
                {
                    "name": "Desktop",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 900,
                            "p50": 1600,
                            "optional": true
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                        {
                            "measurement": "c",
                            "weight": 0.55,
                            "p10": 1200,
                            "p50": 2400,
                            "optional": true
                        },
                    ],
                    "condition": {
                        "op":"eq",
                        "name": "event.contexts.browser.name",
                        "value": "Chrome"
                    }
                },
                {
                    "name": "Default",
                    "scoreComponents": [
                        {
                            "measurement": "a",
                            "weight": 0.15,
                            "p10": 100,
                            "p50": 200,
                            "optional": true
                        },
                        {
                            "measurement": "b",
                            "weight": 0.30,
                            "p10": 100,
                            "p50": 200,
                            "optional": true
                        },
                        {
                            "measurement": "c",
                            "weight": 0.55,
                            "p10": 100,
                            "p50": 200,
                            "optional": true
                        },
                    ],
                    "condition": {
                        "op": "and",
                        "inner": [],
                    }
                }
            ]
        }))
        .unwrap();

        normalize_performance_score(&mut event, Some(&performance_score));

        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 1619420405.0,
          "start_timestamp": 1619420400.0,
          "contexts": {},
          "measurements": {
            "a": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "b": {
              "value": 213.0,
              "unit": "millisecond",
            },
            "score.a": {
              "value": 0.15121816827413334,
              "unit": "ratio",
            },
            "score.b": {
              "value": 0.3024363365482667,
              "unit": "ratio",
            },
            "score.ratio.a": {
              "value": 0.45365450482239994,
              "unit": "ratio",
            },
            "score.ratio.b": {
              "value": 0.45365450482239994,
              "unit": "ratio",
            },
            "score.total": {
              "value": 0.4536545048224,
              "unit": "ratio",
            },
            "score.weight.a": {
              "value": 0.33333333333333337,
              "unit": "ratio",
            },
            "score.weight.b": {
              "value": 0.6666666666666667,
              "unit": "ratio",
            },
            "score.weight.c": {
              "value": 0.0,
              "unit": "ratio",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_normalization_removes_reprocessing_context() {
        let json = r#"{
            "contexts": {
                "reprocessing": {}
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json).unwrap();
        assert!(get_value!(event.contexts!).contains_key("reprocessing"));
        normalize_event(&mut event, &NormalizationConfig::default());
        assert!(!get_value!(event.contexts!).contains_key("reprocessing"));
    }

    #[test]
    fn test_renormalization_does_not_remove_reprocessing_context() {
        let json = r#"{
            "contexts": {
                "reprocessing": {}
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json).unwrap();
        assert!(get_value!(event.contexts!).contains_key("reprocessing"));
        normalize_event(
            &mut event,
            &NormalizationConfig {
                is_renormalize: true,
                ..Default::default()
            },
        );
        assert!(get_value!(event.contexts!).contains_key("reprocessing"));
    }

    #[test]
    fn test_normalize_user() {
        let json = r#"{
            "user": {
                "id": "123456",
                "username": "john",
                "other": "value"
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json).unwrap();
        normalize_user(event.value_mut().as_mut().unwrap());

        let user = event.value().unwrap().user.value().unwrap();
        assert_eq!(user.data, {
            let mut map = Object::new();
            map.insert(
                "other".to_owned(),
                Annotated::new(Value::String("value".to_owned())),
            );
            Annotated::new(map)
        });
        assert_eq!(user.other, Object::new());
        assert_eq!(user.username, Annotated::new("john".to_owned().into()));
        assert_eq!(user.sentry_user, Annotated::new("id:123456".to_owned()));
    }

    #[test]
    fn test_handle_types_in_spaced_exception_values() {
        let mut exception = Annotated::new(Exception {
            value: Annotated::new("ValueError: unauthorized".to_owned().into()),
            ..Exception::default()
        });
        normalize_exception(&mut exception);

        let exception = exception.value().unwrap();
        assert_eq!(exception.value.as_str(), Some("unauthorized"));
        assert_eq!(exception.ty.as_str(), Some("ValueError"));
    }

    #[test]
    fn test_handle_types_in_non_spaced_excepton_values() {
        let mut exception = Annotated::new(Exception {
            value: Annotated::new("ValueError:unauthorized".to_owned().into()),
            ..Exception::default()
        });
        normalize_exception(&mut exception);

        let exception = exception.value().unwrap();
        assert_eq!(exception.value.as_str(), Some("unauthorized"));
        assert_eq!(exception.ty.as_str(), Some("ValueError"));
    }

    #[test]
    fn test_rejects_empty_exception_fields() {
        let mut exception = Annotated::new(Exception {
            value: Annotated::new("".to_owned().into()),
            ty: Annotated::new("".to_owned()),
            ..Default::default()
        });

        normalize_exception(&mut exception);

        assert!(exception.value().is_none());
        assert!(exception.meta().has_errors());
    }

    #[test]
    fn test_json_value() {
        let mut exception = Annotated::new(Exception {
            value: Annotated::new(r#"{"unauthorized":true}"#.to_owned().into()),
            ..Exception::default()
        });

        normalize_exception(&mut exception);

        let exception = exception.value().unwrap();

        // Don't split a json-serialized value on the colon
        assert_eq!(exception.value.as_str(), Some(r#"{"unauthorized":true}"#));
        assert_eq!(exception.ty.value(), None);
    }

    #[test]
    fn test_exception_invalid() {
        let mut exception = Annotated::new(Exception::default());

        normalize_exception(&mut exception);

        let expected = Error::with(ErrorKind::MissingAttribute, |error| {
            error.insert("attribute", "type or value");
        });
        assert_eq!(
            exception.meta().iter_errors().collect_tuple(),
            Some((&expected,))
        );
    }

    #[test]
    fn test_normalize_exception() {
        let mut event = Annotated::new(Event {
            exceptions: Annotated::new(Values::new(vec![Annotated::new(Exception {
                // Exception with missing type and value
                ty: Annotated::empty(),
                value: Annotated::empty(),
                ..Default::default()
            })])),
            ..Default::default()
        });

        normalize_event(&mut event, &NormalizationConfig::default());

        let exception = event
            .value()
            .unwrap()
            .exceptions
            .value()
            .unwrap()
            .values
            .value()
            .unwrap()
            .first()
            .unwrap();

        assert_debug_snapshot!(exception.meta(), @r###"
        Meta {
            remarks: [],
            errors: [
                Error {
                    kind: MissingAttribute,
                    data: {
                        "attribute": String(
                            "type or value",
                        ),
                    },
                },
            ],
            original_length: None,
            original_value: Some(
                Object(
                    {
                        "mechanism": ~,
                        "module": ~,
                        "raw_stacktrace": ~,
                        "stacktrace": ~,
                        "thread_id": ~,
                        "type": ~,
                        "value": ~,
                    },
                ),
            ),
        }
        "###);
    }

    #[test]
    fn test_normalize_breadcrumbs() {
        let mut event = Event {
            breadcrumbs: Annotated::new(Values {
                values: Annotated::new(vec![Annotated::new(Breadcrumb::default())]),
                ..Default::default()
            }),
            ..Default::default()
        };
        normalize_breadcrumbs(&mut event);

        let breadcrumb = event
            .breadcrumbs
            .value()
            .unwrap()
            .values
            .value()
            .unwrap()
            .first()
            .unwrap()
            .value()
            .unwrap();
        assert_eq!(breadcrumb.ty.value().unwrap(), "default");
        assert_eq!(&breadcrumb.level.value().unwrap().to_string(), "info");
    }

    #[test]
    fn test_other_debug_images_have_meta_errors() {
        let mut event = Event {
            debug_meta: Annotated::new(DebugMeta {
                images: Annotated::new(vec![Annotated::new(
                    DebugImage::Other(BTreeMap::default()),
                )]),
                ..Default::default()
            }),
            ..Default::default()
        };
        normalize_debug_meta(&mut event);

        let debug_image_meta = event
            .debug_meta
            .value()
            .unwrap()
            .images
            .value()
            .unwrap()
            .first()
            .unwrap()
            .meta();
        assert_debug_snapshot!(debug_image_meta, @r###"
        Meta {
            remarks: [],
            errors: [
                Error {
                    kind: InvalidData,
                    data: {
                        "reason": String(
                            "unsupported debug image type",
                        ),
                    },
                },
            ],
            original_length: None,
            original_value: Some(
                Object(
                    {},
                ),
            ),
        }
        "###);
    }

    #[test]
    fn test_skip_span_normalization_when_configured() {
        let json = r#"{
            "type": "transaction",
            "start_timestamp": 1,
            "timestamp": 2,
            "contexts": {
                "trace": {
                    "trace_id": "4c79f60c11214eb38604f4ae0781bfb2",
                    "span_id": "aaaaaaaaaaaaaaaa"
                }
            },
            "spans": [
                {
                    "op": "db",
                    "description": "SELECT * FROM table;",
                    "start_timestamp": 1,
                    "timestamp": 2,
                    "trace_id": "4c79f60c11214eb38604f4ae0781bfb2",
                    "span_id": "bbbbbbbbbbbbbbbb",
                    "parent_span_id": "aaaaaaaaaaaaaaaa"
                }
            ]
        }"#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();
        assert!(get_value!(event.spans[0].exclusive_time).is_none());
        normalize_event(
            &mut event,
            &NormalizationConfig {
                is_renormalize: true,
                ..Default::default()
            },
        );
        assert!(get_value!(event.spans[0].exclusive_time).is_none());
        normalize_event(
            &mut event,
            &NormalizationConfig {
                is_renormalize: false,
                ..Default::default()
            },
        );
        assert!(get_value!(event.spans[0].exclusive_time).is_some());
    }

    #[test]
    fn test_normalize_trace_context_tags_extracts_lcp_info() {
        let json = r#"{
            "type": "transaction",
            "start_timestamp": 1,
            "timestamp": 2,
            "contexts": {
                "trace": {
                    "data": {
                        "lcp.element": "body > div#app > div > h1#header",
                        "lcp.size": 24827,
                        "lcp.id": "header",
                        "lcp.url": "http://example.com/image.jpg"
                    }
                }
            },
            "measurements": {
                "lcp": { "value": 146.20000000298023, "unit": "millisecond" }
            }
        }"#;
        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();
        normalize_trace_context_tags(&mut event);
        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 2.0,
          "start_timestamp": 1.0,
          "contexts": {
            "trace": {
              "data": {
                "lcp.element": "body > div#app > div > h1#header",
                "lcp.size": 24827,
                "lcp.id": "header",
                "lcp.url": "http://example.com/image.jpg",
              },
              "type": "trace",
            },
          },
          "tags": [
            [
              "lcp.element",
              "body > div#app > div > h1#header",
            ],
            [
              "lcp.size",
              "24827",
            ],
            [
              "lcp.id",
              "header",
            ],
            [
              "lcp.url",
              "http://example.com/image.jpg",
            ],
          ],
          "measurements": {
            "lcp": {
              "value": 146.20000000298023,
              "unit": "millisecond",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_normalize_trace_context_tags_does_not_overwrite_lcp_tags() {
        let json = r#"{
          "type": "transaction",
          "start_timestamp": 1,
          "timestamp": 2,
          "contexts": {
              "trace": {
                  "data": {
                      "lcp.element": "body > div#app > div > h1#id",
                      "lcp.size": 33333,
                      "lcp.id": "id",
                      "lcp.url": "http://example.com/another-image.jpg"
                  }
              }
          },
          "tags": {
              "lcp.element": "body > div#app > div > h1#header",
              "lcp.size": 24827,
              "lcp.id": "header",
              "lcp.url": "http://example.com/image.jpg"
          },
          "measurements": {
              "lcp": { "value": 146.20000000298023, "unit": "millisecond" }
          }
        }"#;
        let mut event = Annotated::<Event>::from_json(json).unwrap().0.unwrap();
        normalize_trace_context_tags(&mut event);
        insta::assert_ron_snapshot!(SerializableAnnotated(&Annotated::new(event)), {}, @r###"
        {
          "type": "transaction",
          "timestamp": 2.0,
          "start_timestamp": 1.0,
          "contexts": {
            "trace": {
              "data": {
                "lcp.element": "body > div#app > div > h1#id",
                "lcp.size": 33333,
                "lcp.id": "id",
                "lcp.url": "http://example.com/another-image.jpg",
              },
              "type": "trace",
            },
          },
          "tags": [
            [
              "lcp.element",
              "body > div#app > div > h1#header",
            ],
            [
              "lcp.id",
              "header",
            ],
            [
              "lcp.size",
              "24827",
            ],
            [
              "lcp.url",
              "http://example.com/image.jpg",
            ],
          ],
          "measurements": {
            "lcp": {
              "value": 146.20000000298023,
              "unit": "millisecond",
            },
          },
        }
        "###);
    }

    #[test]
    fn test_tags_are_trimmed() {
        let json = r#"
            {
                "tags": {
                    "key": "too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_",
                    "too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_": "value"
                }
            }
        "#;

        let mut event = Annotated::<Event>::from_json(json).unwrap();

        normalize_event(
            &mut event,
            &NormalizationConfig {
                enable_trimming: true,
                ..NormalizationConfig::default()
            },
        );

        insta::assert_debug_snapshot!(get_value!(event.tags!), @r###"
        Tags(
            PairList(
                [
                    TagEntry(
                        "key",
                        Annotated(
                            "too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__lo...",
                            Meta {
                                remarks: [
                                    Remark {
                                        ty: Substituted,
                                        rule_id: "!limit",
                                        range: Some(
                                            (
                                                197,
                                                200,
                                            ),
                                        ),
                                    },
                                ],
                                errors: [],
                                original_length: Some(
                                    210,
                                ),
                                original_value: None,
                            },
                        ),
                    ),
                    TagEntry(
                        Annotated(
                            "too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__long_too__lo...",
                            Meta {
                                remarks: [
                                    Remark {
                                        ty: Substituted,
                                        rule_id: "!limit",
                                        range: Some(
                                            (
                                                197,
                                                200,
                                            ),
                                        ),
                                    },
                                ],
                                errors: [],
                                original_length: Some(
                                    210,
                                ),
                                original_value: None,
                            },
                        ),
                        "value",
                    ),
                ],
            ),
        )
        "###);
    }
}