Skip to main content

acorde_core/model/
playback.rs

1use super::duration::Duration;
2use super::notation::{Articulation, ChordSymbol, GuitarTechnique, TabPosition};
3use super::repeat::measure_sequence;
4use super::score::{GuitarBendPoint, NoteAddr, Score};
5use serde::{Deserialize, Serialize};
6use std::collections::{BTreeMap, BTreeSet};
7
8fn default_fermata_multiplier() -> f64 {
9    1.5
10}
11fn default_fermata_hold_beats() -> f64 {
12    0.0
13}
14fn default_swing_unit() -> Duration {
15    Duration::Eighth
16}
17fn default_metronome_channel() -> u8 {
18    9
19}
20fn default_accent_pitch() -> u8 {
21    76
22}
23fn default_beat_pitch() -> u8 {
24    77
25}
26fn default_accent_velocity() -> u8 {
27    100
28}
29fn default_beat_velocity() -> u8 {
30    70
31}
32
33/// Explicit opt-in event realization policy.
34///
35/// [`Authored`](Self::Authored) is the default: ornaments and arpeggiation remain notation
36/// semantics on one event. The versioned realization profile is deliberately opt-in so hosts
37/// never receive invented attacks merely by upgrading acorde.
38#[derive(Debug, Clone, Copy, Default, Serialize, Deserialize, PartialEq, Eq)]
39#[serde(rename_all = "kebab-case")]
40pub enum PlaybackRealizationProfile {
41    /// Preserve authored event semantics without generating auxiliary attacks.
42    #[default]
43    Authored,
44    /// Deterministic chromatic ornament attacks and chord arpeggiation for preview providers.
45    ///
46    /// Trills and shakes alternate the written pitch with one chromatic semitone above; mordents
47    /// and turns use a fixed four-attack figure. Chord tones marked `arpeggiate` are staggered
48    /// low-to-high (or high-to-low) by at most 0.18 beats. This is a reproducible preview policy,
49    /// not a claim about historical performance practice.
50    OrnamentArpeggioV1,
51}
52
53/// Click-track injected into [`to_playback_events`] output.
54///
55/// Metronome events are tagged with `PlaybackEvent.is_metronome = true` and can be
56/// routed separately by checking `channel` (default 9 = GM drums).
57#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
58pub struct MetronomeConfig {
59    /// MIDI channel for the click track. Default 9 (GM drum channel).
60    #[serde(default = "default_metronome_channel")]
61    pub channel: u8,
62    /// MIDI note for the accented first beat. Default 76 (High Wood Block).
63    #[serde(default = "default_accent_pitch")]
64    pub accent_pitch: u8,
65    /// MIDI note for regular beats. Default 77 (Low Wood Block).
66    #[serde(default = "default_beat_pitch")]
67    pub beat_pitch: u8,
68    /// Velocity for the accented first beat. Default 100.
69    #[serde(default = "default_accent_velocity")]
70    pub accent_velocity: u8,
71    /// Velocity for regular beats. Default 70.
72    #[serde(default = "default_beat_velocity")]
73    pub beat_velocity: u8,
74}
75
76impl Default for MetronomeConfig {
77    fn default() -> Self {
78        Self {
79            channel: 9,
80            accent_pitch: 76,
81            beat_pitch: 77,
82            accent_velocity: 100,
83            beat_velocity: 70,
84        }
85    }
86}
87
88/// Options for [`to_playback_events`].
89#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
90pub struct PlaybackOptions {
91    /// Replaces the score's tempo when `Some`; `None` uses `score.settings.tempo_bpm`.
92    pub bpm_override: Option<u16>,
93    /// Part indices to silence. Events from these parts are omitted entirely.
94    pub muted_parts: Vec<usize>,
95    /// Restrict playback to measures in the inclusive range `[start, end]`.
96    /// Physical measure indices (0-based). `None` plays the full sequence.
97    /// Events within the region start at `time_beats = 0`.
98    #[serde(default)]
99    pub loop_region: Option<(usize, usize)>,
100    /// Duration multiplier for notes with `Fermata` articulation. Default 1.5.
101    #[serde(default = "default_fermata_multiplier")]
102    pub fermata_multiplier: f64,
103    /// Additional beat-domain hold requested after a fermata note. Default 0 keeps legacy
104    /// multiplier-only behavior; hosts decide how to realize the resulting silence.
105    #[serde(default = "default_fermata_hold_beats")]
106    pub fermata_hold_beats: f64,
107    /// Swing ratio for pairs of plain notes of [`swing_unit`] duration. `None` = straight.
108    /// `0.67` ≈ triplet swing (2:1). Valid range: (0.5, 1.0).
109    /// Applied only to notes matching `swing_unit`, no tuplet, no dot.
110    #[serde(default)]
111    pub swing: Option<f64>,
112    /// Note duration that swing is applied to. Defaults to `Duration::Eighth`.
113    /// Set to `Duration::Sixteenth` for Latin/funk 16th-note swing.
114    #[serde(default = "default_swing_unit")]
115    pub swing_unit: Duration,
116    /// When `Some`, injects metronome click events into the event list.
117    /// Clicks are tagged with `PlaybackEvent.is_metronome = true`.
118    #[serde(default)]
119    pub metronome: Option<MetronomeConfig>,
120    /// Optional realization policy. The default retains authored ornament and arpeggio marks
121    /// without synthesizing extra events.
122    #[serde(default)]
123    pub realization_profile: PlaybackRealizationProfile,
124}
125
126impl Default for PlaybackOptions {
127    fn default() -> Self {
128        Self {
129            bpm_override: None,
130            muted_parts: Vec::new(),
131            loop_region: None,
132            fermata_multiplier: 1.5,
133            fermata_hold_beats: 0.0,
134            swing: None,
135            swing_unit: Duration::Eighth,
136            metronome: None,
137            realization_profile: PlaybackRealizationProfile::Authored,
138        }
139    }
140}
141
142/// A single sounding event suitable for audio playback engines (e.g. Web Audio, Tone.js).
143///
144/// Grace notes and rests are excluded. Chords are expanded to one event per pitch.
145#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
146pub struct PlaybackEvent {
147    /// Stable source note address (`part:staff:measure:voice:note`), or `None` for metronome events.
148    /// Chord pitches share the address of their source note.
149    #[serde(default, skip_serializing_if = "Option::is_none")]
150    pub address: Option<String>,
151    /// Typed source address for notation hosts; `None` for metronome events.
152    #[serde(default, skip_serializing_if = "Option::is_none")]
153    pub source: Option<NoteAddr>,
154    /// Original MusicXML voice number when the source used a non-default identifier.
155    /// `source` remains the stable four-slot canonical address used by editing APIs.
156    #[serde(default, skip_serializing_if = "Option::is_none")]
157    pub source_voice_number: Option<u32>,
158    /// Absolute beat position from the start of the score.
159    pub time_beats: f64,
160    /// Absolute time in seconds from the start of the score.
161    pub time_secs: f64,
162    /// MIDI pitch number (0–127).
163    pub pitch_midi: u8,
164    /// Exact sounding pitch in hundredths of a MIDI semitone.
165    ///
166    /// `pitch_midi` is retained as a compatibility convenience for integer-MIDI hosts;
167    /// microtonal-capable hosts should use this field.
168    #[serde(default)]
169    pub pitch_midi_cents: i32,
170    /// Authored normalized pitch-bend curve for a bend-capable host. Each point is relative to
171    /// `pitch_midi_cents` and positioned within this event's sounding duration. Empty means the
172    /// event has no authored continuous bend.
173    #[serde(default)]
174    pub pitch_bend_curve: Vec<GuitarBendPoint>,
175    /// Authored pause requested after this note by a breath mark or caesura. The host decides
176    /// how to realize the silence while preserving this deterministic beat-domain contract.
177    #[serde(default)]
178    pub post_note_pause_beats: f64,
179    /// Authored articulation and ornament marks for a provider to interpret. The core schedule
180    /// deliberately does not invent auxiliary pitches for trill, mordent, or turn.
181    #[serde(default)]
182    pub articulations: Vec<Articulation>,
183    /// Authored chord symbol at this note position. It is a semantic cue for accompaniment or
184    /// harmonic playback providers; acorde does not invent accompaniment notes.
185    #[serde(default, skip_serializing_if = "Option::is_none")]
186    pub chord_symbol: Option<ChordSymbol>,
187    /// Authored guitar playing technique, when present. Providers may map this stable semantic
188    /// value to keyswitches or synthesis behavior without score re-parsing.
189    #[serde(default, skip_serializing_if = "Option::is_none")]
190    pub guitar_technique: Option<GuitarTechnique>,
191    /// MIDI velocity (1–127). Derived from [`Dynamic`](crate::Dynamic); defaults to 64.
192    /// Boosted by +20 for Accent / Marcato articulations (clamped to 127).
193    pub velocity: u8,
194    /// Sounding duration in beats. Halved for Staccato / Staccatissimo.
195    pub duration_beats: f64,
196    /// Sounding duration in seconds.
197    pub duration_secs: f64,
198    /// True when the note has `pedal_start` set (sustain pedal down).
199    pub pedal: bool,
200    /// Index of the part this event originates from (useful for per-channel MIDI routing).
201    pub part_index: usize,
202    /// MIDI channel of the originating part (`part.midi_channel`). For Tone.js channel routing.
203    pub channel: u8,
204    /// Effective General MIDI program after applying any measure-local instrument change.
205    #[serde(default)]
206    pub program: u8,
207    /// Stable effective instrument ID when the part or measure declares one.
208    #[serde(default, skip_serializing_if = "Option::is_none")]
209    pub instrument_id: Option<String>,
210    /// `true` for metronome click events injected via [`MetronomeConfig`].
211    #[serde(default)]
212    pub is_metronome: bool,
213}
214
215/// Version of the host-neutral playback timing comparison contract.
216pub const PLAYBACK_COMPARISON_CONTRACT_VERSION: u16 = 2;
217/// Maximum number of events accepted by one comparison operation.
218pub const MAX_PLAYBACK_COMPARISON_EVENTS: usize = 1_000_000;
219const MAX_PLAYBACK_MISMATCHES: usize = 256;
220/// Maximum number of projected tablature events retained in one report.
221pub const MAX_TAB_PERFORMANCE_EVENTS: usize = 1_000_000;
222const MAX_TAB_PERFORMANCE_DIAGNOSTICS: usize = 1_024;
223
224/// Version of the host-neutral offline rendering manifest contract.
225pub const OFFLINE_RENDER_CONTRACT_VERSION: u16 = 3;
226
227/// Score material selected for an offline render.  Addresses remain those of the
228/// source score even when a view or a range is selected.
229#[derive(Debug, Clone, Default, Serialize, Deserialize, PartialEq, Eq)]
230#[serde(rename_all = "kebab-case")]
231pub enum OfflineRenderScope {
232    #[default]
233    FullScore,
234    MeasureRange {
235        start: usize,
236        end: usize,
237    },
238    Selection {
239        addresses: Vec<NoteAddr>,
240    },
241}
242
243/// Navigation realization selected by an offline-render request.
244#[derive(Debug, Clone, Copy, Default, Serialize, Deserialize, PartialEq, Eq)]
245#[serde(rename_all = "kebab-case")]
246pub enum OfflineRenderNavigationPolicy {
247    /// Follow the score's authored repeats, jumps and endings.
248    #[default]
249    Authored,
250}
251
252/// One event with integer sample-frame boundaries for an offline renderer.
253#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
254pub struct OfflineRenderFrameEvent {
255    pub event: PlaybackEvent,
256    pub start_frame: u64,
257    pub duration_frames: u64,
258    pub end_frame: u64,
259}
260
261/// A non-note semantic action expressed on the same sample-frame clock as
262/// [`OfflineRenderFrameEvent`].  Audio providers can consume these without
263/// reverse-engineering notation from a note schedule.
264#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
265#[serde(rename_all = "kebab-case")]
266pub enum OfflineRenderSemanticEventKind {
267    /// A measure-local instrument routing change. Providers apply this before
268    /// attacks at the same frame rather than inferring it from note events.
269    InstrumentChange {
270        instrument_id: String,
271        channel: u8,
272        program: u8,
273        transpose_semitones: i8,
274    },
275    Controller {
276        channel: u8,
277        controller: u8,
278        value: u8,
279    },
280    /// Signed MIDI 14-bit pitch bend retained from the interchange timeline.
281    PitchBend {
282        channel: u8,
283        value: i16,
284    },
285    /// MIDI program selection at a canonical score tick.
286    ProgramChange {
287        channel: u8,
288        program: u8,
289    },
290    /// Channel pressure or key pressure at a canonical score tick.
291    Aftertouch {
292        channel: u8,
293        #[serde(default, skip_serializing_if = "Option::is_none")]
294        key: Option<u8>,
295        value: u8,
296    },
297    Tempo {
298        bpm: u16,
299        #[serde(default, skip_serializing_if = "Option::is_none")]
300        ramp_to_bpm: Option<u16>,
301    },
302    Navigation {
303        marker: String,
304    },
305    Pedal {
306        down: bool,
307    },
308    Articulation {
309        articulation: Articulation,
310    },
311    GuitarBend {
312        points: Vec<GuitarBendPoint>,
313    },
314    /// A semantic release boundary.  It intentionally has no synthesis
315    /// parameters: providers decide how a release tail is rendered.
316    ReleaseTail,
317}
318
319/// A source-addressable non-note action in an offline render manifest.
320#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
321pub struct OfflineRenderSemanticFrameEvent {
322    pub kind: OfflineRenderSemanticEventKind,
323    pub frame: u64,
324    #[serde(default, skip_serializing_if = "Option::is_none")]
325    pub source: Option<NoteAddr>,
326    #[serde(default, skip_serializing_if = "Option::is_none")]
327    pub measure: Option<OfflineRenderMeasureAddress>,
328}
329
330/// Stable source location for a measure-scoped offline action.
331#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
332pub struct OfflineRenderMeasureAddress {
333    pub part: usize,
334    pub staff: usize,
335    pub measure: usize,
336}
337
338/// Machine-readable condition observed while deriving an offline schedule.
339#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
340#[serde(rename_all = "kebab-case")]
341pub enum OfflineRenderDiagnosticKind {
342    /// A selected canonical note address did not yield a sounding event.
343    UnresolvedSelectionAddress,
344    /// A valid selection contained no sounding events after scheduling.
345    EmptySelection,
346}
347
348/// Source-located diagnostic for a provider-neutral offline manifest.
349#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
350pub struct OfflineRenderDiagnostic {
351    pub kind: OfflineRenderDiagnosticKind,
352    #[serde(default, skip_serializing_if = "Option::is_none")]
353    pub source: Option<NoteAddr>,
354}
355
356/// Encoded audio format requested from a host-side offline renderer.
357///
358/// acorde does not encode audio; this keeps the requested output explicit in the deterministic
359/// schedule handed to a Composer or other host.
360#[derive(Debug, Clone, Copy, Default, Serialize, Deserialize, PartialEq, Eq)]
361pub enum OfflineRenderFormat {
362    #[default]
363    Wav,
364    Flac,
365    Mp3,
366}
367
368/// Host-neutral parameters for an offline render operation.
369#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
370pub struct OfflineRenderRequest {
371    /// Requested encoded format. The host reports unsupported formats explicitly.
372    #[serde(default)]
373    pub format: OfflineRenderFormat,
374    /// PCM sample rate used to convert event seconds to exact sample frames.
375    #[serde(default = "default_offline_render_sample_rate")]
376    pub sample_rate_hz: u32,
377    /// Requested interleaved output channel count.
378    #[serde(default = "default_offline_render_channels")]
379    pub channels: u8,
380    /// Stable name/version of the selected host provider, when already chosen.
381    #[serde(default, skip_serializing_if = "Option::is_none")]
382    pub provider_identity: Option<String>,
383    /// Stable provider asset identifier (for example a host preset or sample set).
384    #[serde(default, skip_serializing_if = "Option::is_none")]
385    pub asset_identity: Option<String>,
386    /// Optional linked view to resolve before event scheduling.
387    #[serde(default, skip_serializing_if = "Option::is_none")]
388    pub view_id: Option<String>,
389    #[serde(default)]
390    pub scope: OfflineRenderScope,
391    #[serde(default)]
392    pub navigation_policy: OfflineRenderNavigationPolicy,
393    /// Extra release tail after the final sounding event, in milliseconds.
394    #[serde(default)]
395    pub release_tail_millis: u32,
396    /// Full reproducible playback policy. When omitted, the legacy function
397    /// argument is used and copied into the manifest for migration clarity.
398    #[serde(default, skip_serializing_if = "Option::is_none")]
399    pub playback_options: Option<PlaybackOptions>,
400}
401
402fn default_offline_render_sample_rate() -> u32 {
403    48_000
404}
405
406fn default_offline_render_channels() -> u8 {
407    2
408}
409
410impl Default for OfflineRenderRequest {
411    fn default() -> Self {
412        Self {
413            format: OfflineRenderFormat::Wav,
414            sample_rate_hz: default_offline_render_sample_rate(),
415            channels: default_offline_render_channels(),
416            provider_identity: None,
417            asset_identity: None,
418            view_id: None,
419            scope: OfflineRenderScope::FullScore,
420            navigation_policy: OfflineRenderNavigationPolicy::Authored,
421            release_tail_millis: 0,
422            playback_options: None,
423        }
424    }
425}
426
427/// Sample-accurate event schedule for a host-side offline render.
428///
429/// `duration_frames` is derived from the final event's end time and deliberately excludes codec
430/// padding. A host owns synthesis, tail policy, file creation, and encoded bytes.
431#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
432pub struct OfflineRenderManifest {
433    pub contract_version: u16,
434    pub playback_contract_version: u16,
435    pub format: OfflineRenderFormat,
436    pub sample_rate_hz: u32,
437    pub channels: u8,
438    #[serde(default, skip_serializing_if = "Option::is_none")]
439    pub provider_identity: Option<String>,
440    #[serde(default, skip_serializing_if = "Option::is_none")]
441    pub asset_identity: Option<String>,
442    #[serde(default, skip_serializing_if = "Option::is_none")]
443    pub view_id: Option<String>,
444    #[serde(default)]
445    pub scope: OfflineRenderScope,
446    #[serde(default)]
447    pub navigation_policy: OfflineRenderNavigationPolicy,
448    #[serde(default)]
449    pub release_tail_frames: u64,
450    /// The exact timing policy that produced this manifest.
451    #[serde(default)]
452    pub playback_options: PlaybackOptions,
453    pub duration_frames: u64,
454    pub events: Vec<PlaybackEvent>,
455    /// Frame-quantized equivalents of `events`; retained alongside the legacy
456    /// seconds schedule so v1 clients can migrate without losing semantics.
457    #[serde(default)]
458    pub frame_events: Vec<OfflineRenderFrameEvent>,
459    /// Pedal, articulation, bend and release semantics on the exact output
460    /// sample clock.  Note attacks remain in [`Self::frame_events`].
461    #[serde(default)]
462    pub semantic_events: Vec<OfflineRenderSemanticFrameEvent>,
463    #[serde(default)]
464    pub diagnostics: Vec<OfflineRenderDiagnostic>,
465}
466
467impl OfflineRenderManifest {
468    /// Validate a persisted provider-neutral schedule before a host hands it to
469    /// a synthesizer. Legacy v1/v2 manifests remain readable; current manifests
470    /// additionally require a one-to-one frame schedule for every note event.
471    pub fn validate(&self) -> Result<(), crate::Error> {
472        if !(1..=OFFLINE_RENDER_CONTRACT_VERSION).contains(&self.contract_version)
473            || !(8_000..=384_000).contains(&self.sample_rate_hz)
474            || !(1..=8).contains(&self.channels)
475            || self.release_tail_frames > self.duration_frames
476        {
477            return Err(crate::Error::InvalidOfflineRenderRequest);
478        }
479
480        if self.contract_version >= 2 && self.frame_events.len() != self.events.len() {
481            return Err(crate::Error::InvalidOfflineRenderRequest);
482        }
483        let mut latest_event_end = 0_u64;
484        for (index, frame_event) in self.frame_events.iter().enumerate() {
485            let Some(expected_event) = self.events.get(index) else {
486                return Err(crate::Error::InvalidOfflineRenderRequest);
487            };
488            if frame_event.event != *expected_event
489                || frame_event
490                    .start_frame
491                    .checked_add(frame_event.duration_frames)
492                    != Some(frame_event.end_frame)
493                || frame_event.end_frame > self.duration_frames
494            {
495                return Err(crate::Error::InvalidOfflineRenderRequest);
496            }
497            latest_event_end = latest_event_end.max(frame_event.end_frame);
498        }
499        let latest_semantic_frame = self
500            .semantic_events
501            .iter()
502            .map(|event| event.frame)
503            .max()
504            .unwrap_or(0);
505        if latest_semantic_frame > self.duration_frames {
506            return Err(crate::Error::InvalidOfflineRenderRequest);
507        }
508        if self.contract_version >= 2
509            && latest_event_end
510                .max(latest_semantic_frame)
511                .checked_add(self.release_tail_frames)
512                != Some(self.duration_frames)
513        {
514            return Err(crate::Error::InvalidOfflineRenderRequest);
515        }
516        Ok(())
517    }
518}
519
520/// Host-reported result metadata for an [`OfflineRenderManifest`].
521///
522/// This is a result contract, not proof of audio quality or device-independent equivalence.
523#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
524pub struct OfflineRenderResult {
525    pub contract_version: u16,
526    pub format: OfflineRenderFormat,
527    pub sample_rate_hz: u32,
528    pub channels: u8,
529    #[serde(default, skip_serializing_if = "Option::is_none")]
530    pub provider_identity: Option<String>,
531    pub duration_frames: u64,
532    pub output_bytes: u64,
533}
534
535/// A host-side auxiliary send between two logical playback buses.
536#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
537pub struct PlaybackAuxSend {
538    pub source_bus: String,
539    pub destination_bus: String,
540    /// Gain applied before the destination effect chain, in dB.
541    pub gain_db: f64,
542}
543
544/// Identifies a host effect attached to a logical bus without carrying provider-specific settings.
545#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
546pub struct PlaybackEffectRoute {
547    pub bus_id: String,
548    pub effect_id: String,
549    #[serde(default = "default_effect_enabled")]
550    pub enabled: bool,
551}
552
553fn default_effect_enabled() -> bool {
554    true
555}
556
557/// Host-neutral routing choices resolved after score playback events are generated.
558#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
559pub struct PlaybackRoutingConfig {
560    #[serde(default, skip_serializing_if = "Option::is_none")]
561    pub provider_identity: Option<String>,
562    #[serde(default = "default_master_bus")]
563    pub master_bus: String,
564    #[serde(default = "default_metronome_bus")]
565    pub metronome_bus: String,
566    /// Part-index routes, overridden by a matching stable instrument ID.
567    #[serde(default)]
568    pub part_buses: BTreeMap<usize, String>,
569    #[serde(default)]
570    pub instrument_buses: BTreeMap<String, String>,
571    #[serde(default)]
572    pub aux_sends: Vec<PlaybackAuxSend>,
573    #[serde(default)]
574    pub effect_routes: Vec<PlaybackEffectRoute>,
575}
576
577fn default_master_bus() -> String {
578    "master".into()
579}
580
581fn default_metronome_bus() -> String {
582    "metronome".into()
583}
584
585impl Default for PlaybackRoutingConfig {
586    fn default() -> Self {
587        Self {
588            provider_identity: None,
589            master_bus: default_master_bus(),
590            metronome_bus: default_metronome_bus(),
591            part_buses: BTreeMap::new(),
592            instrument_buses: BTreeMap::new(),
593            aux_sends: Vec::new(),
594            effect_routes: Vec::new(),
595        }
596    }
597}
598
599/// One unique event source route in a [`PlaybackRoutingManifest`].
600#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq, PartialOrd, Ord)]
601pub struct PlaybackBusRoute {
602    pub part_index: usize,
603    pub channel: u8,
604    pub program: u8,
605    #[serde(default, skip_serializing_if = "Option::is_none")]
606    pub instrument_id: Option<String>,
607    pub is_metronome: bool,
608    pub bus_id: String,
609}
610
611/// Deterministic logical routing graph for score playback events.
612#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
613pub struct PlaybackRoutingManifest {
614    pub contract_version: u16,
615    #[serde(default, skip_serializing_if = "Option::is_none")]
616    pub provider_identity: Option<String>,
617    pub master_bus: String,
618    pub metronome_bus: String,
619    pub routes: Vec<PlaybackBusRoute>,
620    pub aux_sends: Vec<PlaybackAuxSend>,
621    pub effect_routes: Vec<PlaybackEffectRoute>,
622}
623
624/// Version of the host-neutral routing manifest contract.
625pub const PLAYBACK_ROUTING_CONTRACT_VERSION: u16 = 1;
626
627fn valid_routing_id(value: &str) -> bool {
628    !value.is_empty()
629        && value.len() <= 64
630        && value
631            .bytes()
632            .all(|byte| byte.is_ascii_alphanumeric() || matches!(byte, b'.' | b'_' | b'-'))
633}
634
635fn validate_playback_routing(config: &PlaybackRoutingConfig) -> Result<(), crate::Error> {
636    if !valid_routing_id(&config.master_bus)
637        || !valid_routing_id(&config.metronome_bus)
638        || config.part_buses.values().any(|bus| !valid_routing_id(bus))
639        || config
640            .instrument_buses
641            .values()
642            .any(|bus| !valid_routing_id(bus))
643        || config.aux_sends.len() > 64
644        || config.effect_routes.len() > 128
645    {
646        return Err(crate::Error::InvalidPlaybackRouting);
647    }
648    for send in &config.aux_sends {
649        if !valid_routing_id(&send.source_bus)
650            || !valid_routing_id(&send.destination_bus)
651            || !send.gain_db.is_finite()
652            || !(-120.0..=24.0).contains(&send.gain_db)
653        {
654            return Err(crate::Error::InvalidPlaybackRouting);
655        }
656    }
657    if config
658        .effect_routes
659        .iter()
660        .any(|effect| !valid_routing_id(&effect.bus_id) || !valid_routing_id(&effect.effect_id))
661    {
662        return Err(crate::Error::InvalidPlaybackRouting);
663    }
664    Ok(())
665}
666
667/// Resolve a bounded, deterministic logical routing graph for a score schedule.
668pub fn build_playback_routing_manifest(
669    score: &Score,
670    playback_options: &PlaybackOptions,
671    config: &PlaybackRoutingConfig,
672) -> Result<PlaybackRoutingManifest, crate::Error> {
673    validate_playback_routing(config)?;
674    let events = to_playback_events_bounded(score, playback_options)?;
675    let mut routes = BTreeMap::new();
676    for event in events {
677        let bus_id = if event.is_metronome {
678            config.metronome_bus.clone()
679        } else if let Some(bus) = event
680            .instrument_id
681            .as_ref()
682            .and_then(|instrument_id| config.instrument_buses.get(instrument_id))
683        {
684            bus.clone()
685        } else if let Some(bus) = config.part_buses.get(&event.part_index) {
686            bus.clone()
687        } else {
688            config.master_bus.clone()
689        };
690        let route = PlaybackBusRoute {
691            part_index: event.part_index,
692            channel: event.channel,
693            program: event.program,
694            instrument_id: event.instrument_id,
695            is_metronome: event.is_metronome,
696            bus_id,
697        };
698        routes.insert(route.clone(), route);
699    }
700    Ok(PlaybackRoutingManifest {
701        contract_version: PLAYBACK_ROUTING_CONTRACT_VERSION,
702        provider_identity: config.provider_identity.clone(),
703        master_bus: config.master_bus.clone(),
704        metronome_bus: config.metronome_bus.clone(),
705        routes: routes.into_values().collect(),
706        aux_sends: config.aux_sends.clone(),
707        effect_routes: config.effect_routes.clone(),
708    })
709}
710
711/// Build a bounded sample-accurate schedule for a host-side offline render.
712pub fn build_offline_render_manifest(
713    score: &Score,
714    playback_options: &PlaybackOptions,
715    request: &OfflineRenderRequest,
716) -> Result<OfflineRenderManifest, crate::Error> {
717    if !(8_000..=384_000).contains(&request.sample_rate_hz) || !(1..=8).contains(&request.channels)
718    {
719        return Err(crate::Error::InvalidOfflineRenderRequest);
720    }
721    let resolved_score = match request.view_id.as_deref() {
722        Some(view_id) => score.resolve_view(view_id)?,
723        None => score.clone(),
724    };
725    let mut effective_options = request
726        .playback_options
727        .clone()
728        .unwrap_or_else(|| playback_options.clone());
729    if let OfflineRenderScope::MeasureRange { start, end } = request.scope {
730        if start > end {
731            return Err(crate::Error::InvalidOfflineRenderRequest);
732        }
733        effective_options.loop_region = Some((start, end));
734    }
735    let mut events = to_playback_events_bounded(&resolved_score, &effective_options)?;
736    let mut diagnostics = Vec::new();
737    let mut selection_origin_secs = 0.0;
738    if let OfflineRenderScope::Selection { ref addresses } = request.scope {
739        if addresses.is_empty() {
740            return Err(crate::Error::InvalidOfflineRenderRequest);
741        }
742        for address in addresses {
743            if !events
744                .iter()
745                .any(|event| event.source.as_ref() == Some(address))
746            {
747                diagnostics.push(OfflineRenderDiagnostic {
748                    kind: OfflineRenderDiagnosticKind::UnresolvedSelectionAddress,
749                    source: Some(address.clone()),
750                });
751            }
752        }
753        events.retain(|event| {
754            event
755                .source
756                .as_ref()
757                .is_some_and(|source| addresses.contains(source))
758        });
759        let origin_secs = events
760            .iter()
761            .map(|event| event.time_secs)
762            .fold(f64::INFINITY, f64::min);
763        if origin_secs.is_finite() {
764            selection_origin_secs = origin_secs;
765            for event in &mut events {
766                event.time_secs -= origin_secs;
767            }
768        }
769        if events.is_empty() {
770            diagnostics.push(OfflineRenderDiagnostic {
771                kind: OfflineRenderDiagnosticKind::EmptySelection,
772                source: None,
773            });
774        }
775    }
776    let duration_secs = events
777        .iter()
778        .map(|event| event.time_secs + event.duration_secs)
779        .fold(0.0_f64, f64::max);
780    if !duration_secs.is_finite() || duration_secs < 0.0 {
781        return Err(crate::Error::InvalidOfflineRenderRequest);
782    }
783    let release_tail_frames =
784        (f64::from(request.release_tail_millis) * f64::from(request.sample_rate_hz) / 1_000.0)
785            .ceil();
786    let duration_frames = (duration_secs * f64::from(request.sample_rate_hz)).ceil();
787    if !duration_frames.is_finite() || duration_frames > u64::MAX as f64 {
788        return Err(crate::Error::InvalidOfflineRenderRequest);
789    }
790    if !release_tail_frames.is_finite()
791        || release_tail_frames > u64::MAX as f64
792        || duration_frames > (u64::MAX as f64 - release_tail_frames)
793    {
794        return Err(crate::Error::InvalidOfflineRenderRequest);
795    }
796    let frame_events = events
797        .iter()
798        .cloned()
799        .map(|event| {
800            let start_frame = (event.time_secs * f64::from(request.sample_rate_hz)).round() as u64;
801            let end_frame = ((event.time_secs + event.duration_secs)
802                * f64::from(request.sample_rate_hz))
803            .ceil() as u64;
804            OfflineRenderFrameEvent {
805                duration_frames: end_frame.saturating_sub(start_frame),
806                event,
807                start_frame,
808                end_frame,
809            }
810        })
811        .collect::<Vec<_>>();
812    let mut semantic_events = Vec::new();
813    for event in &frame_events {
814        let source = event.event.source.clone();
815        if event.event.pedal {
816            semantic_events.push(OfflineRenderSemanticFrameEvent {
817                kind: OfflineRenderSemanticEventKind::Pedal { down: true },
818                frame: event.start_frame,
819                source: source.clone(),
820                measure: None,
821            });
822        }
823        if source.as_ref().is_some_and(|address| {
824            resolved_score
825                .parts
826                .get(address.part)
827                .and_then(|part| part.staves.get(address.staff))
828                .and_then(|staff| staff.measures.get(address.measure))
829                .and_then(|measure| measure.voices.get(address.voice))
830                .and_then(|voice| voice.get(address.note))
831                .is_some_and(|note| note.pedal_end)
832        }) {
833            semantic_events.push(OfflineRenderSemanticFrameEvent {
834                kind: OfflineRenderSemanticEventKind::Pedal { down: false },
835                frame: event.start_frame,
836                source: source.clone(),
837                measure: None,
838            });
839        }
840        for articulation in &event.event.articulations {
841            semantic_events.push(OfflineRenderSemanticFrameEvent {
842                kind: OfflineRenderSemanticEventKind::Articulation {
843                    articulation: articulation.clone(),
844                },
845                frame: event.start_frame,
846                source: source.clone(),
847                measure: None,
848            });
849        }
850        if !event.event.pitch_bend_curve.is_empty() {
851            semantic_events.push(OfflineRenderSemanticFrameEvent {
852                kind: OfflineRenderSemanticEventKind::GuitarBend {
853                    points: event.event.pitch_bend_curve.clone(),
854                },
855                frame: event.start_frame,
856                source,
857                measure: None,
858            });
859        }
860    }
861    append_measure_semantic_events(
862        &resolved_score,
863        &effective_options,
864        request.sample_rate_hz,
865        &request.scope,
866        selection_origin_secs,
867        &mut semantic_events,
868    );
869    // Automation can outlive the final sounding note (for example an imported
870    // program change on an otherwise silent measure). The manifest duration
871    // must retain those actions before adding any host release tail.
872    let semantic_end_frame = semantic_events
873        .iter()
874        .map(|event| event.frame)
875        .max()
876        .unwrap_or(0);
877    let content_duration_frames = (duration_frames as u64).max(semantic_end_frame);
878    if release_tail_frames > 0.0 {
879        semantic_events.push(OfflineRenderSemanticFrameEvent {
880            kind: OfflineRenderSemanticEventKind::ReleaseTail,
881            frame: content_duration_frames,
882            source: None,
883            measure: None,
884        });
885    }
886    let manifest = OfflineRenderManifest {
887        contract_version: OFFLINE_RENDER_CONTRACT_VERSION,
888        playback_contract_version: PLAYBACK_COMPARISON_CONTRACT_VERSION,
889        format: request.format,
890        sample_rate_hz: request.sample_rate_hz,
891        channels: request.channels,
892        provider_identity: request.provider_identity.clone(),
893        asset_identity: request.asset_identity.clone(),
894        view_id: request.view_id.clone(),
895        scope: request.scope.clone(),
896        navigation_policy: request.navigation_policy,
897        release_tail_frames: release_tail_frames as u64,
898        playback_options: effective_options,
899        duration_frames: content_duration_frames + release_tail_frames as u64,
900        events,
901        frame_events,
902        semantic_events,
903        diagnostics,
904    };
905    manifest.validate()?;
906    Ok(manifest)
907}
908
909#[derive(Clone, Copy)]
910struct OfflineMeasureTime {
911    measure: usize,
912    start_secs: f64,
913    bpm: f64,
914    ramp_to_bpm: Option<f64>,
915    beats: f64,
916}
917
918fn offline_measure_times(
919    score: &Score,
920    options: &PlaybackOptions,
921    part: usize,
922    staff: usize,
923) -> Vec<OfflineMeasureTime> {
924    let Some(staff_ref) = score
925        .parts
926        .get(part)
927        .and_then(|part| part.staves.get(staff))
928    else {
929        return Vec::new();
930    };
931    let sequence = measure_sequence(score).into_iter().filter(|measure| {
932        options
933            .loop_region
934            .is_none_or(|(start, end)| *measure >= start && *measure <= end)
935    });
936    let mut bpm = options
937        .bpm_override
938        .unwrap_or(score.settings.tempo_bpm)
939        .max(1) as f64;
940    let mut secs = 0.0;
941    let mut result = Vec::new();
942    for measure_index in sequence {
943        let Some(measure) = staff_ref.measures.get(measure_index) else {
944            continue;
945        };
946        if let Some(tempo) = measure.tempo {
947            bpm = tempo.max(1) as f64;
948        }
949        let beats = measure.duration_beats(&score.settings.time_signature);
950        let ramp_to_bpm = measure
951            .tempo_ramp_to
952            .map(f64::from)
953            .filter(|tempo| *tempo > 0.0);
954        result.push(OfflineMeasureTime {
955            measure: measure_index,
956            start_secs: secs,
957            bpm,
958            ramp_to_bpm,
959            beats,
960        });
961        secs += tempo_ramp_seconds(bpm, ramp_to_bpm, beats, beats);
962        if let Some(end_bpm) = ramp_to_bpm {
963            bpm = end_bpm;
964        }
965    }
966    result
967}
968
969fn append_measure_semantic_events(
970    score: &Score,
971    options: &PlaybackOptions,
972    sample_rate_hz: u32,
973    scope: &OfflineRenderScope,
974    origin_secs: f64,
975    events: &mut Vec<OfflineRenderSemanticFrameEvent>,
976) {
977    for (part_index, part) in score.parts.iter().enumerate() {
978        let timeline = offline_measure_times(score, options, part_index, 0);
979        let Some(staff) = part.staves.first() else {
980            continue;
981        };
982        let mut tick_starts = Vec::with_capacity(staff.measures.len());
983        let mut tick = 0u64;
984        for measure in &staff.measures {
985            tick_starts.push(tick);
986            let beats = measure.duration_beats(&score.settings.time_signature);
987            tick = tick.saturating_add((beats * 480.0).round() as u64);
988        }
989        for time in timeline {
990            if let OfflineRenderScope::Selection { addresses } = scope
991                && !addresses
992                    .iter()
993                    .any(|address| address.part == part_index && address.measure == time.measure)
994            {
995                continue;
996            }
997            let address = OfflineRenderMeasureAddress {
998                part: part_index,
999                staff: 0,
1000                measure: time.measure,
1001            };
1002            let frame = ((time.start_secs - origin_secs).max(0.0) * f64::from(sample_rate_hz))
1003                .round() as u64;
1004            let measure = &staff.measures[time.measure];
1005            if part_index == 0 && (measure.tempo.is_some() || measure.tempo_ramp_to.is_some()) {
1006                events.push(OfflineRenderSemanticFrameEvent {
1007                    kind: OfflineRenderSemanticEventKind::Tempo {
1008                        bpm: time.bpm.round() as u16,
1009                        ramp_to_bpm: measure.tempo_ramp_to,
1010                    },
1011                    frame,
1012                    source: None,
1013                    measure: Some(address.clone()),
1014                });
1015            }
1016            if part_index == 0
1017                && let Some(marker) = &measure.navigation
1018            {
1019                events.push(OfflineRenderSemanticFrameEvent {
1020                    kind: OfflineRenderSemanticEventKind::Navigation {
1021                        marker: marker.clone(),
1022                    },
1023                    frame,
1024                    source: None,
1025                    measure: Some(address.clone()),
1026                });
1027            }
1028            if let Some(instrument) = &measure.instrument_change {
1029                events.push(OfflineRenderSemanticFrameEvent {
1030                    kind: OfflineRenderSemanticEventKind::InstrumentChange {
1031                        instrument_id: instrument.id.clone(),
1032                        channel: instrument.midi_channel,
1033                        program: instrument.midi_program,
1034                        transpose_semitones: instrument.transpose_semitones,
1035                    },
1036                    frame,
1037                    source: None,
1038                    measure: Some(address.clone()),
1039                });
1040            }
1041            let start_tick = tick_starts[time.measure];
1042            let end_tick = start_tick.saturating_add((time.beats * 480.0).round() as u64);
1043            for control in &part.midi_control_changes {
1044                if control.tick < start_tick || control.tick >= end_tick {
1045                    continue;
1046                }
1047                let local_beats = (control.tick - start_tick) as f64 / 480.0;
1048                let secs = time.start_secs
1049                    + tempo_ramp_seconds(time.bpm, time.ramp_to_bpm, time.beats, local_beats);
1050                events.push(OfflineRenderSemanticFrameEvent {
1051                    kind: OfflineRenderSemanticEventKind::Controller {
1052                        channel: control.channel,
1053                        controller: control.controller,
1054                        value: control.value,
1055                    },
1056                    frame: ((secs - origin_secs).max(0.0) * f64::from(sample_rate_hz)).round()
1057                        as u64,
1058                    source: None,
1059                    measure: Some(address.clone()),
1060                });
1061            }
1062            for bend in &part.midi_pitch_bends {
1063                if bend.tick < start_tick || bend.tick >= end_tick {
1064                    continue;
1065                }
1066                let local_beats = (bend.tick - start_tick) as f64 / 480.0;
1067                let secs = time.start_secs
1068                    + tempo_ramp_seconds(time.bpm, time.ramp_to_bpm, time.beats, local_beats);
1069                events.push(OfflineRenderSemanticFrameEvent {
1070                    kind: OfflineRenderSemanticEventKind::PitchBend {
1071                        channel: bend.channel,
1072                        value: bend.value,
1073                    },
1074                    frame: ((secs - origin_secs).max(0.0) * f64::from(sample_rate_hz)).round()
1075                        as u64,
1076                    source: None,
1077                    measure: Some(address.clone()),
1078                });
1079            }
1080            for program in &part.midi_program_changes {
1081                if program.tick < start_tick || program.tick >= end_tick {
1082                    continue;
1083                }
1084                let local_beats = (program.tick - start_tick) as f64 / 480.0;
1085                let secs = time.start_secs
1086                    + tempo_ramp_seconds(time.bpm, time.ramp_to_bpm, time.beats, local_beats);
1087                events.push(OfflineRenderSemanticFrameEvent {
1088                    kind: OfflineRenderSemanticEventKind::ProgramChange {
1089                        channel: program.channel,
1090                        program: program.program,
1091                    },
1092                    frame: ((secs - origin_secs).max(0.0) * f64::from(sample_rate_hz)).round()
1093                        as u64,
1094                    source: None,
1095                    measure: Some(address.clone()),
1096                });
1097            }
1098            for aftertouch in &part.midi_aftertouch {
1099                if aftertouch.tick < start_tick || aftertouch.tick >= end_tick {
1100                    continue;
1101                }
1102                let local_beats = (aftertouch.tick - start_tick) as f64 / 480.0;
1103                let secs = time.start_secs
1104                    + tempo_ramp_seconds(time.bpm, time.ramp_to_bpm, time.beats, local_beats);
1105                events.push(OfflineRenderSemanticFrameEvent {
1106                    kind: OfflineRenderSemanticEventKind::Aftertouch {
1107                        channel: aftertouch.channel,
1108                        key: aftertouch.key,
1109                        value: aftertouch.value,
1110                    },
1111                    frame: ((secs - origin_secs).max(0.0) * f64::from(sample_rate_hz)).round()
1112                        as u64,
1113                    source: None,
1114                    measure: Some(address.clone()),
1115                });
1116            }
1117        }
1118    }
1119    events.sort_by_key(|event| event.frame);
1120}
1121
1122/// Timing tolerances for comparing a host/backend event trace with acorde's schedule.
1123#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1124pub struct PlaybackTimingTolerance {
1125    pub start_secs: f64,
1126    pub duration_secs: f64,
1127}
1128
1129impl Default for PlaybackTimingTolerance {
1130    fn default() -> Self {
1131        Self {
1132            start_secs: 0.005,
1133            duration_secs: 0.005,
1134        }
1135    }
1136}
1137
1138/// A typed difference in a host playback trace. Audio rendering is deliberately not compared.
1139#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1140pub enum PlaybackTimingMismatch {
1141    EventCount { expected: usize, actual: usize },
1142    EventIdentity { index: usize },
1143    StartTime { index: usize, error_secs: f64 },
1144    Duration { index: usize, error_secs: f64 },
1145}
1146
1147/// Deterministic report for a bounded playback timing comparison.
1148#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1149pub struct PlaybackTimingReport {
1150    pub contract_version: u16,
1151    pub expected_events: usize,
1152    pub actual_events: usize,
1153    pub matched_events: usize,
1154    pub max_start_error_secs: f64,
1155    pub max_duration_error_secs: f64,
1156    pub within_tolerance: bool,
1157    pub mismatches: Vec<PlaybackTimingMismatch>,
1158}
1159
1160/// Compare a host-provided event trace with the deterministic score schedule.
1161///
1162/// This contract covers event identity and timing only. Web Audio scheduling,
1163/// SoundFont decoding, device latency, and rendered PCM remain host/provider concerns.
1164pub fn compare_playback_timing(
1165    expected: &[PlaybackEvent],
1166    actual: &[PlaybackEvent],
1167    tolerance: &PlaybackTimingTolerance,
1168) -> Result<PlaybackTimingReport, crate::Error> {
1169    if !tolerance.start_secs.is_finite()
1170        || tolerance.start_secs < 0.0
1171        || !tolerance.duration_secs.is_finite()
1172        || tolerance.duration_secs < 0.0
1173    {
1174        return Err(crate::Error::InvalidPlaybackComparison);
1175    }
1176    if expected.len() > MAX_PLAYBACK_COMPARISON_EVENTS {
1177        return Err(crate::Error::PlaybackComparisonTooLarge(expected.len()));
1178    }
1179    if actual.len() > MAX_PLAYBACK_COMPARISON_EVENTS {
1180        return Err(crate::Error::PlaybackComparisonTooLarge(actual.len()));
1181    }
1182    let mut mismatches = Vec::new();
1183    if expected.len() != actual.len() {
1184        mismatches.push(PlaybackTimingMismatch::EventCount {
1185            expected: expected.len(),
1186            actual: actual.len(),
1187        });
1188    }
1189    let mut matched_events = 0;
1190    let mut max_start_error_secs: f64 = 0.0;
1191    let mut max_duration_error_secs: f64 = 0.0;
1192    for (index, (expected_event, actual_event)) in expected.iter().zip(actual).enumerate() {
1193        let source_identity_matches = match (&expected_event.source, &actual_event.source) {
1194            (Some(expected), Some(actual)) => expected == actual,
1195            _ => expected_event.address == actual_event.address,
1196        };
1197        let identity_matches = source_identity_matches
1198            && expected_event.pitch_midi_cents == actual_event.pitch_midi_cents
1199            && expected_event.velocity == actual_event.velocity
1200            && expected_event.part_index == actual_event.part_index
1201            && expected_event.channel == actual_event.channel
1202            && expected_event.program == actual_event.program
1203            && expected_event.instrument_id == actual_event.instrument_id
1204            && expected_event.pitch_bend_curve == actual_event.pitch_bend_curve
1205            && expected_event.post_note_pause_beats == actual_event.post_note_pause_beats
1206            && expected_event.articulations == actual_event.articulations
1207            && expected_event.chord_symbol == actual_event.chord_symbol
1208            && expected_event.guitar_technique == actual_event.guitar_technique
1209            && expected_event.is_metronome == actual_event.is_metronome;
1210        let start_error_secs = (expected_event.time_secs - actual_event.time_secs).abs();
1211        let duration_error_secs = (expected_event.duration_secs - actual_event.duration_secs).abs();
1212        if start_error_secs.is_finite() {
1213            max_start_error_secs = max_start_error_secs.max(start_error_secs);
1214        }
1215        if duration_error_secs.is_finite() {
1216            max_duration_error_secs = max_duration_error_secs.max(duration_error_secs);
1217        }
1218        let start_matches =
1219            start_error_secs.is_finite() && start_error_secs <= tolerance.start_secs;
1220        let duration_matches =
1221            duration_error_secs.is_finite() && duration_error_secs <= tolerance.duration_secs;
1222        if identity_matches && start_matches && duration_matches {
1223            matched_events += 1;
1224            continue;
1225        }
1226        if mismatches.len() < MAX_PLAYBACK_MISMATCHES {
1227            if !identity_matches {
1228                mismatches.push(PlaybackTimingMismatch::EventIdentity { index });
1229            }
1230            if !start_matches && mismatches.len() < MAX_PLAYBACK_MISMATCHES {
1231                mismatches.push(PlaybackTimingMismatch::StartTime {
1232                    index,
1233                    error_secs: start_error_secs,
1234                });
1235            }
1236            if !duration_matches && mismatches.len() < MAX_PLAYBACK_MISMATCHES {
1237                mismatches.push(PlaybackTimingMismatch::Duration {
1238                    index,
1239                    error_secs: duration_error_secs,
1240                });
1241            }
1242        }
1243    }
1244    Ok(PlaybackTimingReport {
1245        contract_version: PLAYBACK_COMPARISON_CONTRACT_VERSION,
1246        expected_events: expected.len(),
1247        actual_events: actual.len(),
1248        matched_events,
1249        max_start_error_secs,
1250        max_duration_error_secs,
1251        within_tolerance: mismatches.is_empty(),
1252        mismatches,
1253    })
1254}
1255
1256/// Version of the score-schedule timing corpus contract.
1257pub const PLAYBACK_TIMING_CORPUS_CONTRACT_VERSION: u16 = 1;
1258const MAX_PLAYBACK_TIMING_CORPUS_CASES: usize = 256;
1259
1260/// One score-backed timing case, independent from an audio synthesis backend.
1261#[derive(Debug, Clone, Serialize, Deserialize)]
1262pub struct PlaybackTimingCase {
1263    pub id: String,
1264    pub score: Score,
1265    #[serde(default)]
1266    pub options: PlaybackOptions,
1267    pub expected_events: Vec<PlaybackEvent>,
1268    #[serde(default)]
1269    pub tolerance: PlaybackTimingTolerance,
1270}
1271
1272/// Result for one [`PlaybackTimingCase`].
1273#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1274pub struct PlaybackTimingCaseReport {
1275    pub id: String,
1276    pub report: PlaybackTimingReport,
1277}
1278
1279/// Deterministic aggregate result for a score-schedule timing corpus.
1280#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1281pub struct PlaybackTimingCorpusReport {
1282    pub contract_version: u16,
1283    pub total_cases: usize,
1284    pub passed_cases: usize,
1285    pub cases: Vec<PlaybackTimingCaseReport>,
1286}
1287
1288/// Compare score-generated schedules against a bounded corpus of expected event traces.
1289///
1290/// The corpus verifies notation-to-event semantics only. It makes no assertion about synthesized
1291/// PCM, codec output, browser scheduling, or real-time device latency.
1292pub fn evaluate_playback_timing_corpus(
1293    cases: &[PlaybackTimingCase],
1294) -> Result<PlaybackTimingCorpusReport, crate::Error> {
1295    if cases.is_empty() || cases.len() > MAX_PLAYBACK_TIMING_CORPUS_CASES {
1296        return Err(crate::Error::InvalidPlaybackTimingCorpus);
1297    }
1298    let mut ids = BTreeSet::new();
1299    let mut reports = Vec::with_capacity(cases.len());
1300    let mut passed_cases = 0;
1301    for case in cases {
1302        if !valid_routing_id(&case.id) || !ids.insert(case.id.clone()) {
1303            return Err(crate::Error::InvalidPlaybackTimingCorpus);
1304        }
1305        let actual = to_playback_events_bounded(&case.score, &case.options)?;
1306        let report = compare_playback_timing(&case.expected_events, &actual, &case.tolerance)?;
1307        if report.within_tolerance {
1308            passed_cases += 1;
1309        }
1310        reports.push(PlaybackTimingCaseReport {
1311            id: case.id.clone(),
1312            report,
1313        });
1314    }
1315    Ok(PlaybackTimingCorpusReport {
1316        contract_version: PLAYBACK_TIMING_CORPUS_CONTRACT_VERSION,
1317        total_cases: cases.len(),
1318        passed_cases,
1319        cases: reports,
1320    })
1321}
1322
1323/// Version of the host-neutral tablature performance projection contract.
1324pub const TAB_PERFORMANCE_CONTRACT_VERSION: u16 = 4;
1325
1326#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1327pub struct TablaturePerformanceEvent {
1328    pub playback: PlaybackEvent,
1329    pub string: u8,
1330    pub fret: u8,
1331    /// Authored guitar technique for the host playback adapter, when present.
1332    #[serde(default)]
1333    pub technique: Option<GuitarTechnique>,
1334    /// Authored bend alteration in cents, when the technique is `Bend`.
1335    #[serde(default)]
1336    pub bend_alter_cents: Option<i16>,
1337    /// Normalized bend/hold/release curve for a bend-capable host. Positions are per-mille of
1338    /// this event's sounding duration and values are cents relative to the written pitch.
1339    #[serde(default)]
1340    pub bend_curve: Vec<GuitarBendPoint>,
1341    pub expected_pitch_midi_cents: i32,
1342    pub pitch_error_cents: i32,
1343}
1344
1345#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1346pub enum TablaturePerformanceDiagnostic {
1347    NoTablatureStaff {
1348        address: String,
1349    },
1350    MissingPosition {
1351        address: String,
1352        pitch_index: usize,
1353    },
1354    StringOutOfRange {
1355        address: String,
1356        string: u8,
1357        lines: u8,
1358    },
1359    TuningUnavailable {
1360        address: String,
1361        string: u8,
1362    },
1363    PitchMismatch {
1364        address: String,
1365        pitch_index: usize,
1366        error_cents: i32,
1367    },
1368}
1369
1370#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1371pub struct TablaturePerformanceReport {
1372    pub contract_version: u16,
1373    pub events: Vec<TablaturePerformanceEvent>,
1374    pub diagnostics: Vec<TablaturePerformanceDiagnostic>,
1375}
1376
1377/// Version of the score-model tablature round-trip diagnostic contract.
1378pub const TAB_ROUND_TRIP_CONTRACT_VERSION: u16 = 1;
1379
1380#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1381pub struct TablatureRoundTripReport {
1382    pub contract_version: u16,
1383    pub checked_notes: usize,
1384    pub positioned_notes: usize,
1385    pub equivalent: bool,
1386    pub diagnostics: Vec<TablatureRoundTripDiagnostic>,
1387}
1388
1389#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
1390pub enum TablatureRoundTripDiagnostic {
1391    StructureMismatch {
1392        address: String,
1393    },
1394    TablatureConfigMismatch {
1395        address: String,
1396    },
1397    PositionMismatch {
1398        address: String,
1399        pitch_index: usize,
1400        expected: Option<TabPosition>,
1401        actual: Option<TabPosition>,
1402    },
1403}
1404
1405/// Verify that authored tablature survives the canonical score JSON round-trip.
1406///
1407/// This checks score-model persistence only. It does not claim MusicXML/MSCX or external
1408/// application equivalence; those format and host comparisons remain separate gates.
1409pub fn tablature_round_trip_report(
1410    score: &Score,
1411) -> Result<TablatureRoundTripReport, crate::Error> {
1412    let encoded = serde_json::to_string(score)
1413        .map_err(|error| crate::Error::TabRoundTripSerialization(error.to_string()))?;
1414    let restored: Score = serde_json::from_str(&encoded)
1415        .map_err(|error| crate::Error::TabRoundTripSerialization(error.to_string()))?;
1416    let mut checked_notes = 0;
1417    let mut positioned_notes = 0;
1418    let mut diagnostics = Vec::new();
1419    for (part_index, part) in score.parts.iter().enumerate() {
1420        let Some(restored_part) = restored.parts.get(part_index) else {
1421            diagnostics.push(TablatureRoundTripDiagnostic::StructureMismatch {
1422                address: format!("{part_index}"),
1423            });
1424            continue;
1425        };
1426        for (staff_index, staff) in part.staves.iter().enumerate() {
1427            let address = format!("{part_index}:{staff_index}");
1428            let Some(restored_staff) = restored_part.staves.get(staff_index) else {
1429                diagnostics.push(TablatureRoundTripDiagnostic::StructureMismatch { address });
1430                continue;
1431            };
1432            if staff.tablature != restored_staff.tablature {
1433                diagnostics.push(TablatureRoundTripDiagnostic::TablatureConfigMismatch {
1434                    address: address.clone(),
1435                });
1436            }
1437            for (measure_index, measure) in staff.measures.iter().enumerate() {
1438                let Some(restored_measure) = restored_staff.measures.get(measure_index) else {
1439                    diagnostics.push(TablatureRoundTripDiagnostic::StructureMismatch {
1440                        address: format!("{address}:{measure_index}"),
1441                    });
1442                    continue;
1443                };
1444                for (voice_index, voice) in measure.voices.iter().enumerate() {
1445                    let Some(restored_voice) = restored_measure.voices.get(voice_index) else {
1446                        diagnostics.push(TablatureRoundTripDiagnostic::StructureMismatch {
1447                            address: format!("{address}:{measure_index}:{voice_index}"),
1448                        });
1449                        continue;
1450                    };
1451                    for (note_index, note) in voice.iter().enumerate() {
1452                        checked_notes += 1;
1453                        if !note.tab_positions.is_empty() || note.tab_position.is_some() {
1454                            positioned_notes += 1;
1455                        }
1456                        let note_address =
1457                            format!("{address}:{measure_index}:{voice_index}:{note_index}");
1458                        let Some(restored_note) = restored_voice.get(note_index) else {
1459                            diagnostics.push(TablatureRoundTripDiagnostic::StructureMismatch {
1460                                address: note_address,
1461                            });
1462                            continue;
1463                        };
1464                        let pitch_count = note.pitches.len().max(note.tab_positions.len()).max(1);
1465                        for pitch_index in 0..pitch_count {
1466                            let expected = note
1467                                .tab_positions
1468                                .get(pitch_index)
1469                                .cloned()
1470                                .or_else(|| note.tab_position.clone());
1471                            let actual = restored_note
1472                                .tab_positions
1473                                .get(pitch_index)
1474                                .cloned()
1475                                .or_else(|| restored_note.tab_position.clone());
1476                            if expected != actual {
1477                                diagnostics.push(TablatureRoundTripDiagnostic::PositionMismatch {
1478                                    address: note_address.clone(),
1479                                    pitch_index,
1480                                    expected,
1481                                    actual,
1482                                });
1483                            }
1484                        }
1485                    }
1486                }
1487            }
1488        }
1489    }
1490    Ok(TablatureRoundTripReport {
1491        contract_version: TAB_ROUND_TRIP_CONTRACT_VERSION,
1492        checked_notes,
1493        positioned_notes,
1494        equivalent: diagnostics.is_empty(),
1495        diagnostics,
1496    })
1497}
1498
1499/// Project score playback events onto authored tablature positions.
1500///
1501/// This operation never invents a string or fret. Callers may run
1502/// [`assign_tablature_positions`](crate::assign_tablature_positions) before this
1503/// projection when automatic positions are desired.
1504pub fn project_tablature_performance(
1505    score: &Score,
1506    options: &PlaybackOptions,
1507) -> Result<TablaturePerformanceReport, crate::Error> {
1508    let playback = to_playback_events(score, options);
1509    if playback.len() > MAX_TAB_PERFORMANCE_EVENTS {
1510        return Err(crate::Error::TabPerformanceTooLarge(playback.len()));
1511    }
1512    let mut events = Vec::new();
1513    let mut diagnostics = Vec::new();
1514    for event in playback {
1515        let Some(address) = event.address.as_deref() else {
1516            continue;
1517        };
1518        let Some((part_index, staff_index, measure_index, voice_index, note_index)) =
1519            parse_playback_address(address)
1520        else {
1521            continue;
1522        };
1523        let Some(staff) = score
1524            .parts
1525            .get(part_index)
1526            .and_then(|part| part.staves.get(staff_index))
1527        else {
1528            continue;
1529        };
1530        let Some(note) = staff
1531            .measures
1532            .get(measure_index)
1533            .and_then(|measure| measure.voices.get(voice_index))
1534            .and_then(|voice| voice.get(note_index))
1535        else {
1536            continue;
1537        };
1538        let Some(tab) = staff.tablature_at(measure_index) else {
1539            push_tab_diagnostic(
1540                &mut diagnostics,
1541                TablaturePerformanceDiagnostic::NoTablatureStaff {
1542                    address: address.into(),
1543                },
1544            );
1545            continue;
1546        };
1547        let transpose_cents = if event.channel == 9 {
1548            0
1549        } else {
1550            i32::from(staff.transpose_semitones) * 100
1551        };
1552        let written_pitch_cents = event.pitch_midi_cents - transpose_cents;
1553        let pitch_index = note
1554            .pitches
1555            .iter()
1556            .position(|pitch| pitch.to_midi_cents() == written_pitch_cents)
1557            .unwrap_or(0);
1558        let position = note
1559            .tab_positions
1560            .get(pitch_index)
1561            .or(note.tab_position.as_ref());
1562        let Some(position) = position else {
1563            push_tab_diagnostic(
1564                &mut diagnostics,
1565                TablaturePerformanceDiagnostic::MissingPosition {
1566                    address: address.into(),
1567                    pitch_index,
1568                },
1569            );
1570            continue;
1571        };
1572        if position.string == 0 || position.string > tab.lines {
1573            push_tab_diagnostic(
1574                &mut diagnostics,
1575                TablaturePerformanceDiagnostic::StringOutOfRange {
1576                    address: address.into(),
1577                    string: position.string,
1578                    lines: tab.lines,
1579                },
1580            );
1581            continue;
1582        }
1583        let Some(tuning) = tab.tuning_midi.get(usize::from(position.string - 1)) else {
1584            push_tab_diagnostic(
1585                &mut diagnostics,
1586                TablaturePerformanceDiagnostic::TuningUnavailable {
1587                    address: address.into(),
1588                    string: position.string,
1589                },
1590            );
1591            continue;
1592        };
1593        let expected_pitch_midi_cents =
1594            tuning.saturating_add(i16::from(position.fret) + i16::from(tab.capo)) as i32 * 100;
1595        let pitch_error_cents = event.pitch_midi_cents - expected_pitch_midi_cents;
1596        if pitch_error_cents != 0 {
1597            push_tab_diagnostic(
1598                &mut diagnostics,
1599                TablaturePerformanceDiagnostic::PitchMismatch {
1600                    address: address.into(),
1601                    pitch_index,
1602                    error_cents: pitch_error_cents,
1603                },
1604            );
1605        }
1606        events.push(TablaturePerformanceEvent {
1607            playback: event,
1608            string: position.string,
1609            fret: position.fret,
1610            technique: note.guitar_technique.clone(),
1611            bend_alter_cents: note.guitar_bend_alter_cents,
1612            bend_curve: note.guitar_bend_curve.clone(),
1613            expected_pitch_midi_cents,
1614            pitch_error_cents,
1615        });
1616    }
1617    Ok(TablaturePerformanceReport {
1618        contract_version: TAB_PERFORMANCE_CONTRACT_VERSION,
1619        events,
1620        diagnostics,
1621    })
1622}
1623
1624fn parse_playback_address(address: &str) -> Option<(usize, usize, usize, usize, usize)> {
1625    let mut fields = address.split(':').map(|field| field.parse::<usize>().ok());
1626    Some((
1627        fields.next()??,
1628        fields.next()??,
1629        fields.next()??,
1630        fields.next()??,
1631        fields.next()??,
1632    ))
1633}
1634
1635fn push_tab_diagnostic(
1636    diagnostics: &mut Vec<TablaturePerformanceDiagnostic>,
1637    diagnostic: TablaturePerformanceDiagnostic,
1638) {
1639    if diagnostics.len() < MAX_TAB_PERFORMANCE_DIAGNOSTICS {
1640        diagnostics.push(diagnostic);
1641    }
1642}
1643
1644/// Convert a [`Score`] into a flat, time-ordered list of [`PlaybackEvent`]s.
1645///
1646/// All parts, staves, and voices are included unless excluded via [`PlaybackOptions`].
1647/// Repeat sections and volta brackets are expanded using [`measure_sequence`].
1648/// Events are sorted by `time_beats`.
1649pub fn to_playback_events(score: &Score, options: &PlaybackOptions) -> Vec<PlaybackEvent> {
1650    let bpm = options
1651        .bpm_override
1652        .unwrap_or(score.settings.tempo_bpm)
1653        .max(1) as f64;
1654    let full_seq = measure_sequence(score);
1655    let seq: Vec<usize> = if let Some((lo, hi)) = options.loop_region {
1656        full_seq
1657            .into_iter()
1658            .filter(|&idx| idx >= lo && idx <= hi)
1659            .collect()
1660    } else {
1661        full_seq
1662    };
1663    let mut events: Vec<PlaybackEvent> = Vec::new();
1664
1665    for (part_index, part) in score.parts.iter().enumerate() {
1666        if options.muted_parts.contains(&part_index) {
1667            continue;
1668        }
1669        for (staff_index, staff) in part.staves.iter().enumerate() {
1670            for voice_idx in 0..4usize {
1671                let mut time_beats = 0.0f64;
1672                let mut time_secs_cursor = 0.0f64;
1673                let mut current_bpm = bpm;
1674                for &idx in &seq {
1675                    let measure = match staff.measures.get(idx) {
1676                        Some(m) => m,
1677                        None => continue,
1678                    };
1679                    let instrument = measure
1680                        .instrument_change
1681                        .as_ref()
1682                        .or(part.instrument.as_ref());
1683                    let channel = instrument.map_or(part.midi_channel, |value| value.midi_channel);
1684                    let program = instrument.map_or(part.midi_program, |value| value.midi_program);
1685                    let instrument_id = instrument.map(|value| value.id.clone());
1686                    if let Some(b) = measure.tempo {
1687                        current_bpm = b.max(1) as f64;
1688                    }
1689                    let measure_beats = measure.duration_beats(&score.settings.time_signature);
1690                    let ramp_end_bpm = measure
1691                        .tempo_ramp_to
1692                        .map(f64::from)
1693                        .filter(|bpm| *bpm > 0.0);
1694                    let measure_start_beats = time_beats;
1695                    let measure_start_secs = time_secs_cursor;
1696                    let mut local_beats = 0.0f64;
1697                    let mut swing_first = true;
1698                    for (note_index, note) in measure.voices[voice_idx].iter().enumerate() {
1699                        if note.is_grace {
1700                            continue;
1701                        }
1702                        let dur = match options.swing {
1703                            Some(ratio)
1704                                if note.tuplet.is_none()
1705                                    && note.dot_count == 0
1706                                    && note.duration == options.swing_unit =>
1707                            {
1708                                let pair = note.beats() * 2.0;
1709                                let d = if swing_first {
1710                                    ratio * pair
1711                                } else {
1712                                    (1.0 - ratio) * pair
1713                                };
1714                                swing_first = !swing_first;
1715                                d
1716                            }
1717                            Some(_) => {
1718                                swing_first = true;
1719                                note.beats()
1720                            }
1721                            None => note.beats(),
1722                        };
1723                        if !note.is_rest {
1724                            let mut velocity = note
1725                                .dynamic
1726                                .as_ref()
1727                                .map(|d| d.to_velocity())
1728                                .unwrap_or(64u8);
1729                            let mut sounding_dur = dur;
1730                            for art in &note.articulations {
1731                                match art {
1732                                    Articulation::Staccato | Articulation::Staccatissimo => {
1733                                        sounding_dur *= 0.5;
1734                                    }
1735                                    Articulation::Accent | Articulation::Marcato => {
1736                                        velocity = velocity.saturating_add(20).min(127);
1737                                    }
1738                                    Articulation::Fermata => {
1739                                        sounding_dur *= options.fermata_multiplier;
1740                                    }
1741                                    _ => {}
1742                                }
1743                            }
1744                            let pedal = note.pedal_start;
1745                            let fermata_hold_beats = if options.fermata_hold_beats.is_finite() {
1746                                options.fermata_hold_beats.max(0.0)
1747                            } else {
1748                                0.0
1749                            };
1750                            let post_note_pause_beats =
1751                                note.articulations
1752                                    .iter()
1753                                    .fold(0.0f64, |pause, articulation| {
1754                                        pause.max(match articulation {
1755                                            Articulation::BreathMark => 0.25,
1756                                            Articulation::Caesura => 0.5,
1757                                            Articulation::Fermata => fermata_hold_beats,
1758                                            _ => 0.0,
1759                                        })
1760                                    });
1761                            let transpose = if channel == 9 {
1762                                0i8
1763                            } else {
1764                                staff.transpose_semitones.saturating_add(
1765                                    instrument.map_or(0, |value| value.transpose_semitones),
1766                                )
1767                            };
1768                            for pitch in &note.pitches {
1769                                let midi = (pitch.to_midi() + transpose as i16).clamp(0, 127) as u8;
1770                                events.push(PlaybackEvent {
1771                                    address: Some(format!(
1772                                        "{part_index}:{staff_index}:{idx}:{voice_idx}:{note_index}"
1773                                    )),
1774                                    source: Some(NoteAddr {
1775                                        part: part_index,
1776                                        staff: staff_index,
1777                                        measure: idx,
1778                                        voice: voice_idx,
1779                                        note: note_index,
1780                                    }),
1781                                    source_voice_number: measure.source_voice_numbers[voice_idx],
1782                                    time_beats: measure_start_beats + local_beats,
1783                                    time_secs: measure_start_secs
1784                                        + tempo_ramp_seconds(
1785                                            current_bpm,
1786                                            ramp_end_bpm,
1787                                            measure_beats,
1788                                            local_beats,
1789                                        ),
1790                                    pitch_midi: midi,
1791                                    pitch_midi_cents: pitch.to_midi_cents()
1792                                        + transpose as i32 * 100,
1793                                    pitch_bend_curve: note.guitar_bend_curve.clone(),
1794                                    post_note_pause_beats,
1795                                    articulations: note.articulations.clone(),
1796                                    chord_symbol: note.chord_symbol.clone(),
1797                                    guitar_technique: note.guitar_technique.clone(),
1798                                    velocity,
1799                                    duration_beats: sounding_dur,
1800                                    duration_secs: tempo_ramp_seconds(
1801                                        current_bpm,
1802                                        ramp_end_bpm,
1803                                        measure_beats,
1804                                        local_beats + sounding_dur,
1805                                    ) - tempo_ramp_seconds(
1806                                        current_bpm,
1807                                        ramp_end_bpm,
1808                                        measure_beats,
1809                                        local_beats,
1810                                    ),
1811                                    pedal,
1812                                    part_index,
1813                                    channel,
1814                                    program,
1815                                    instrument_id: instrument_id.clone(),
1816                                    is_metronome: false,
1817                                });
1818                            }
1819                        }
1820                        local_beats += dur;
1821                    }
1822                    // A voice may omit rests, but the next measure still starts
1823                    // at the notated bar boundary. This also keeps sparse voices
1824                    // aligned with compute_playback_position and other voices.
1825                    time_beats = measure_start_beats + measure_beats;
1826                    time_secs_cursor = measure_start_secs
1827                        + tempo_ramp_seconds(
1828                            current_bpm,
1829                            ramp_end_bpm,
1830                            measure_beats,
1831                            measure_beats,
1832                        );
1833                    if let Some(end_bpm) = ramp_end_bpm {
1834                        current_bpm = end_bpm;
1835                    }
1836                }
1837            }
1838        }
1839    }
1840
1841    if let Some(ref metro) = options.metronome {
1842        let mut cursor_secs = 0.0f64;
1843        let mut cursor_beats = 0.0f64;
1844        let mut metro_bpm = bpm;
1845        for &idx in &seq {
1846            let first_staff = score.parts.first().and_then(|p| p.staves.first());
1847            let measure = first_staff.and_then(|staff| staff.measures.get(idx));
1848            if let Some(t) = first_staff
1849                .and_then(|s| s.measures.get(idx))
1850                .and_then(|m| m.tempo)
1851            {
1852                metro_bpm = t.max(1) as f64;
1853            }
1854            let ts = first_staff
1855                .and_then(|s| s.measures.get(idx))
1856                .and_then(|m| m.time_sig.as_ref())
1857                .unwrap_or(&score.settings.time_signature);
1858            let measure_beats = first_staff
1859                .and_then(|s| s.measures.get(idx))
1860                .map_or_else(|| ts.total_beats(), |m| m.duration_beats(ts));
1861            let ramp_end_bpm = measure
1862                .and_then(|measure| measure.tempo_ramp_to)
1863                .map(f64::from)
1864                .filter(|bpm| *bpm > 0.0);
1865            let beat_unit = ts.beat_unit_beats();
1866            let num_beats = (measure_beats / beat_unit).round() as u32;
1867            for b in 0..num_beats {
1868                let is_accent = b == 0;
1869                let beat_offset_beats = b as f64 * beat_unit;
1870                let beat_offset_secs =
1871                    tempo_ramp_seconds(metro_bpm, ramp_end_bpm, measure_beats, beat_offset_beats);
1872                events.push(PlaybackEvent {
1873                    address: None,
1874                    source: None,
1875                    source_voice_number: None,
1876                    time_beats: cursor_beats + b as f64 * beat_unit,
1877                    time_secs: cursor_secs + beat_offset_secs,
1878                    pitch_midi: if is_accent {
1879                        metro.accent_pitch
1880                    } else {
1881                        metro.beat_pitch
1882                    },
1883                    pitch_midi_cents: i32::from(if is_accent {
1884                        metro.accent_pitch
1885                    } else {
1886                        metro.beat_pitch
1887                    }) * 100,
1888                    pitch_bend_curve: Vec::new(),
1889                    post_note_pause_beats: 0.0,
1890                    articulations: Vec::new(),
1891                    chord_symbol: None,
1892                    guitar_technique: None,
1893                    velocity: if is_accent {
1894                        metro.accent_velocity
1895                    } else {
1896                        metro.beat_velocity
1897                    },
1898                    duration_beats: beat_unit * 0.1,
1899                    duration_secs: tempo_ramp_seconds(
1900                        metro_bpm,
1901                        ramp_end_bpm,
1902                        measure_beats,
1903                        beat_offset_beats + beat_unit * 0.1,
1904                    ) - beat_offset_secs,
1905                    pedal: false,
1906                    part_index: usize::MAX,
1907                    channel: metro.channel,
1908                    program: 0,
1909                    instrument_id: None,
1910                    is_metronome: true,
1911                });
1912            }
1913            cursor_secs +=
1914                tempo_ramp_seconds(metro_bpm, ramp_end_bpm, measure_beats, measure_beats);
1915            cursor_beats += measure_beats;
1916            if let Some(end_bpm) = ramp_end_bpm {
1917                metro_bpm = end_bpm;
1918            }
1919        }
1920    }
1921
1922    events = merge_tied_events(score, events);
1923    events = apply_realization_profile(score, events, options.realization_profile);
1924    events.sort_by(|a, b| {
1925        a.time_beats
1926            .partial_cmp(&b.time_beats)
1927            .unwrap_or(std::cmp::Ordering::Equal)
1928    });
1929    events
1930}
1931
1932const ORNAMENT_ATTACK_COUNT: usize = 4;
1933const ARPEGGIO_MAX_SPREAD_BEATS: f64 = 0.18;
1934
1935fn apply_realization_profile(
1936    score: &Score,
1937    mut events: Vec<PlaybackEvent>,
1938    profile: PlaybackRealizationProfile,
1939) -> Vec<PlaybackEvent> {
1940    if profile == PlaybackRealizationProfile::Authored {
1941        return events;
1942    }
1943
1944    let mut chord_groups: BTreeMap<String, Vec<usize>> = BTreeMap::new();
1945    for (index, event) in events.iter().enumerate() {
1946        if !event.is_metronome {
1947            if let Some(address) = &event.address {
1948                chord_groups.entry(address.clone()).or_default().push(index);
1949            }
1950        }
1951    }
1952    for indices in chord_groups.into_values() {
1953        let Some(source) = events[indices[0]].source.as_ref() else {
1954            continue;
1955        };
1956        let Some(direction) = score
1957            .parts
1958            .get(source.part)
1959            .and_then(|part| part.staves.get(source.staff))
1960            .and_then(|staff| staff.measures.get(source.measure))
1961            .and_then(|measure| measure.voices.get(source.voice))
1962            .and_then(|voice| voice.get(source.note))
1963            .and_then(|note| note.arpeggiate)
1964        else {
1965            continue;
1966        };
1967        if indices.len() < 2 {
1968            continue;
1969        }
1970        let mut ordered = indices;
1971        ordered.sort_by_key(|&index| events[index].pitch_midi_cents);
1972        if !direction {
1973            ordered.reverse();
1974        }
1975        let max_spread = events[ordered[0]]
1976            .duration_beats
1977            .max(0.0)
1978            .mul_add(0.5, 0.0)
1979            .min(ARPEGGIO_MAX_SPREAD_BEATS);
1980        let step = max_spread / (ordered.len() - 1) as f64;
1981        for (ordinal, index) in ordered.into_iter().enumerate() {
1982            shift_event_time(&mut events[index], step * ordinal as f64);
1983        }
1984    }
1985
1986    let mut realized = Vec::with_capacity(events.len());
1987    for event in events {
1988        let offsets = ornament_offsets(&event.articulations);
1989        if offsets.is_empty() || event.is_metronome || event.duration_beats <= 0.0 {
1990            realized.push(event);
1991            continue;
1992        }
1993        let attack_beats = event.duration_beats / ORNAMENT_ATTACK_COUNT as f64;
1994        let attack_secs = event.duration_secs / ORNAMENT_ATTACK_COUNT as f64;
1995        for (ordinal, semitones) in offsets.into_iter().enumerate() {
1996            let mut attack = event.clone();
1997            let displacement = i32::from(semitones) * 100;
1998            attack.pitch_midi_cents = (attack.pitch_midi_cents + displacement).clamp(0, 12_700);
1999            attack.pitch_midi =
2000                ((i32::from(attack.pitch_midi) + i32::from(semitones)).clamp(0, 127)) as u8;
2001            attack.time_beats += attack_beats * ordinal as f64;
2002            attack.time_secs += attack_secs * ordinal as f64;
2003            attack.duration_beats = attack_beats;
2004            attack.duration_secs = attack_secs;
2005            if ordinal > 0 {
2006                attack.chord_symbol = None;
2007            }
2008            realized.push(attack);
2009        }
2010    }
2011    realized
2012}
2013
2014fn shift_event_time(event: &mut PlaybackEvent, offset_beats: f64) {
2015    if offset_beats <= 0.0 || event.duration_beats <= 0.0 {
2016        return;
2017    }
2018    event.time_beats += offset_beats;
2019    event.time_secs += event.duration_secs * (offset_beats / event.duration_beats);
2020}
2021
2022fn ornament_offsets(articulations: &[Articulation]) -> Vec<i8> {
2023    if articulations
2024        .iter()
2025        .any(|articulation| matches!(articulation, Articulation::Trill | Articulation::Shake))
2026    {
2027        return vec![0, 1, 0, 1];
2028    }
2029    if articulations
2030        .iter()
2031        .any(|articulation| matches!(articulation, Articulation::Mordent))
2032    {
2033        return vec![0, 1, 0, 0];
2034    }
2035    if articulations
2036        .iter()
2037        .any(|articulation| matches!(articulation, Articulation::InvertedMordent))
2038    {
2039        return vec![0, -1, 0, 0];
2040    }
2041    if articulations
2042        .iter()
2043        .any(|articulation| matches!(articulation, Articulation::Turn))
2044    {
2045        return vec![1, 0, -1, 0];
2046    }
2047    if articulations
2048        .iter()
2049        .any(|articulation| matches!(articulation, Articulation::InvertedTurn))
2050    {
2051        return vec![-1, 0, 1, 0];
2052    }
2053    Vec::new()
2054}
2055
2056/// Integrate seconds over `beats` while BPM changes linearly across a measure.
2057fn tempo_ramp_seconds(start_bpm: f64, end_bpm: Option<f64>, measure_beats: f64, beats: f64) -> f64 {
2058    let beats = beats.max(0.0);
2059    let Some(end_bpm) = end_bpm else {
2060        return beats / start_bpm * 60.0;
2061    };
2062    if measure_beats <= 0.0 || (end_bpm - start_bpm).abs() < f64::EPSILON {
2063        return beats / start_bpm * 60.0;
2064    }
2065    let delta = end_bpm - start_bpm;
2066    let bpm_at_beats = start_bpm + delta * beats / measure_beats;
2067    if bpm_at_beats <= 0.0 {
2068        return beats / start_bpm * 60.0;
2069    }
2070    60.0 * measure_beats / delta * (bpm_at_beats / start_bpm).ln()
2071}
2072
2073/// Coalesce adjacent playback events that are connected by authored ties.
2074///
2075/// Ties are a notational continuation, not repeated attacks. The event keeps the first
2076/// source address and accumulates the sounding duration of each contiguous segment. Malformed
2077/// or non-contiguous tie endings remain as independent events so playback never silently drops
2078/// a note.
2079fn merge_tied_events(score: &Score, events: Vec<PlaybackEvent>) -> Vec<PlaybackEvent> {
2080    use std::collections::HashMap;
2081
2082    let mut merged = Vec::with_capacity(events.len());
2083    let mut pending: HashMap<(usize, usize, usize, i32), usize> = HashMap::new();
2084    for event in events {
2085        let Some(source) = event.source.as_ref() else {
2086            merged.push(event);
2087            continue;
2088        };
2089        let tied_note = score
2090            .parts
2091            .get(source.part)
2092            .and_then(|part| part.staves.get(source.staff))
2093            .and_then(|staff| staff.measures.get(source.measure))
2094            .and_then(|measure| measure.voices.get(source.voice))
2095            .and_then(|voice| voice.get(source.note));
2096        let Some(note) = tied_note else {
2097            merged.push(event);
2098            continue;
2099        };
2100        let key = (
2101            source.part,
2102            source.staff,
2103            source.voice,
2104            event.pitch_midi_cents,
2105        );
2106        if note.tie_end
2107            && pending.get(&key).is_some_and(|&index| {
2108                merged.get(index).is_some_and(|previous| {
2109                    (previous.time_beats + previous.duration_beats - event.time_beats).abs() < 1e-9
2110                })
2111            })
2112        {
2113            let index = pending[&key];
2114            let previous = &mut merged[index];
2115            previous.duration_beats += event.duration_beats;
2116            previous.duration_secs += event.duration_secs;
2117            if !note.tie_start {
2118                pending.remove(&key);
2119            }
2120            continue;
2121        }
2122
2123        let index = merged.len();
2124        merged.push(event);
2125        if note.tie_start {
2126            pending.insert(key, index);
2127        } else {
2128            pending.remove(&key);
2129        }
2130    }
2131    merged
2132}
2133
2134/// Convert a score into playback events while enforcing the host-comparison event bound.
2135pub fn to_playback_events_bounded(
2136    score: &Score,
2137    options: &PlaybackOptions,
2138) -> Result<Vec<PlaybackEvent>, crate::Error> {
2139    let events = to_playback_events(score, options);
2140    if events.len() > MAX_PLAYBACK_COMPARISON_EVENTS {
2141        return Err(crate::Error::PlaybackComparisonTooLarge(events.len()));
2142    }
2143    Ok(events)
2144}
2145
2146// ── PlaybackPosition + compute_playback_position ──────────────────────────────
2147
2148/// Score position at a specific elapsed time.
2149#[derive(Debug, Clone, Serialize, Deserialize)]
2150pub struct PlaybackPosition {
2151    /// Physical measure index (0-based), same coordinate space as [`PlaybackEvent`] fields.
2152    pub measure_index: usize,
2153    /// Beat offset within the measure (`0.0 … time_sig.total_beats()`).
2154    pub beat: f64,
2155}
2156
2157struct MeasureSegment {
2158    measure_idx: usize,
2159    start_secs: f64,
2160    duration_secs: f64,
2161    beats: f64,
2162    bpm: f64,
2163}
2164
2165fn build_measure_segments(score: &Score, options: &PlaybackOptions) -> Vec<MeasureSegment> {
2166    let init_bpm = options
2167        .bpm_override
2168        .unwrap_or(score.settings.tempo_bpm)
2169        .max(1) as f64;
2170    let full_seq = measure_sequence(score);
2171    let seq: Vec<usize> = if let Some((lo, hi)) = options.loop_region {
2172        full_seq
2173            .into_iter()
2174            .filter(|&i| i >= lo && i <= hi)
2175            .collect()
2176    } else {
2177        full_seq
2178    };
2179
2180    let mut segments = Vec::with_capacity(seq.len());
2181    let mut cursor_secs = 0.0f64;
2182    let mut current_bpm = init_bpm;
2183
2184    for idx in seq {
2185        let first_measure = score
2186            .parts
2187            .first()
2188            .and_then(|p| p.staves.first())
2189            .and_then(|s| s.measures.get(idx));
2190        if let Some(t) = first_measure.and_then(|m| m.tempo) {
2191            current_bpm = t.max(1) as f64;
2192        }
2193        let ts = first_measure
2194            .and_then(|m| m.time_sig.as_ref())
2195            .unwrap_or(&score.settings.time_signature);
2196        let beats = first_measure.map_or_else(|| ts.total_beats(), |m| m.duration_beats(ts));
2197        let duration_secs = beats / current_bpm * 60.0;
2198
2199        segments.push(MeasureSegment {
2200            measure_idx: idx,
2201            start_secs: cursor_secs,
2202            duration_secs,
2203            beats,
2204            bpm: current_bpm,
2205        });
2206        cursor_secs += duration_secs;
2207    }
2208    segments
2209}
2210
2211/// Map `elapsed_secs` to a position within the score.
2212///
2213/// Returns `None` if `elapsed_secs` is negative or past the end of the last measure.
2214/// Pass the same [`PlaybackOptions`] used for [`to_playback_events`] so that `loop_region`
2215/// and tempo overrides are applied consistently.
2216pub fn compute_playback_position(
2217    score: &Score,
2218    options: &PlaybackOptions,
2219    elapsed_secs: f64,
2220) -> Option<PlaybackPosition> {
2221    if elapsed_secs < 0.0 {
2222        return None;
2223    }
2224    let segments = build_measure_segments(score, options);
2225    for seg in &segments {
2226        if elapsed_secs < seg.start_secs + seg.duration_secs + 1e-9 {
2227            let beat = ((elapsed_secs - seg.start_secs) * seg.bpm / 60.0).clamp(0.0, seg.beats);
2228            return Some(PlaybackPosition {
2229                measure_index: seg.measure_idx,
2230                beat,
2231            });
2232        }
2233    }
2234    None
2235}
2236
2237#[cfg(test)]
2238mod tests {
2239    use super::*;
2240    use crate::model::{
2241        duration::Duration,
2242        pitch::{Pitch, Step},
2243        score::{MidiAftertouch, MidiControlChange, MidiPitchBend, MidiProgramChange, Note, Score},
2244    };
2245
2246    fn opts(bpm: Option<u16>) -> PlaybackOptions {
2247        PlaybackOptions {
2248            bpm_override: bpm,
2249            ..Default::default()
2250        }
2251    }
2252
2253    #[test]
2254    fn bounded_playback_events_match_unbounded_schedule_within_limit() {
2255        let score = Score::new("bounded", 120, 4, 4, 0, 1);
2256        let options = opts(Some(120));
2257        let unbounded = to_playback_events(&score, &options);
2258        let bounded = to_playback_events_bounded(&score, &options).expect("bounded schedule");
2259        assert_eq!(bounded, unbounded);
2260    }
2261
2262    #[test]
2263    fn empty_score_no_events() {
2264        let score = Score::new("T", 120, 4, 4, 0, 1);
2265        assert!(to_playback_events(&score, &opts(None)).is_empty());
2266    }
2267
2268    #[test]
2269    fn single_note_at_beat_zero() {
2270        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2271        score.parts[0].staves[0].measures[0].voices[0] =
2272            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2273        let events = to_playback_events(&score, &opts(None));
2274        assert_eq!(events.len(), 1);
2275        assert_eq!(events[0].address.as_deref(), Some("0:0:0:0:0"));
2276        assert_eq!(
2277            events[0].source,
2278            Some(NoteAddr {
2279                part: 0,
2280                staff: 0,
2281                measure: 0,
2282                voice: 0,
2283                note: 0,
2284            })
2285        );
2286        assert!((events[0].time_beats).abs() < 1e-9);
2287        assert_eq!(events[0].pitch_midi, 60);
2288        assert_eq!(events[0].velocity, 64);
2289        assert!((events[0].duration_beats - 1.0).abs() < 1e-9);
2290        assert_eq!(events[0].part_index, 0);
2291    }
2292
2293    #[test]
2294    fn tied_notes_are_one_continuous_playback_event() {
2295        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2296        let mut first = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2297        first.tie_start = true;
2298        let mut second = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2299        second.tie_end = true;
2300        score.parts[0].staves[0].measures[0].voices[0] = vec![first, second];
2301
2302        let events = to_playback_events(&score, &opts(None));
2303        assert_eq!(events.len(), 1);
2304        assert_eq!(
2305            events[0].source.as_ref().map(|address| address.note),
2306            Some(0)
2307        );
2308        assert!((events[0].time_beats).abs() < 1e-9);
2309        assert!((events[0].duration_beats - 2.0).abs() < 1e-9);
2310        assert!((events[0].duration_secs - 1.0).abs() < 1e-9);
2311    }
2312
2313    #[test]
2314    fn ties_cross_measure_boundaries_and_tempo_changes_without_retriggering() {
2315        let mut score = Score::new("T", 120, 4, 4, 0, 2);
2316        let first_measure = &mut score.parts[0].staves[0].measures[0];
2317        let mut first = Note::new(Pitch::new(Step::C, 4), Duration::Whole);
2318        first.tie_start = true;
2319        first_measure.voices[0] = vec![first];
2320
2321        let second_measure = &mut score.parts[0].staves[0].measures[1];
2322        second_measure.tempo = Some(60);
2323        let mut second = Note::new(Pitch::new(Step::C, 4), Duration::Whole);
2324        second.tie_end = true;
2325        second_measure.voices[0] = vec![second];
2326
2327        let events = to_playback_events(&score, &opts(None));
2328        assert_eq!(events.len(), 1);
2329        assert_eq!(
2330            events[0].source.as_ref().map(|address| address.measure),
2331            Some(0)
2332        );
2333        assert!((events[0].time_beats).abs() < 1e-9);
2334        assert!((events[0].duration_beats - 8.0).abs() < 1e-9);
2335        assert!((events[0].duration_secs - 6.0).abs() < 1e-9);
2336    }
2337
2338    #[test]
2339    fn malformed_tie_end_does_not_drop_playback_event() {
2340        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2341        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2342        note.tie_end = true;
2343        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2344        let events = to_playback_events(&score, &opts(None));
2345        assert_eq!(events.len(), 1);
2346        assert!((events[0].duration_beats - 1.0).abs() < 1e-9);
2347    }
2348
2349    #[test]
2350    fn microtonal_playback_event_keeps_exact_midi_cents() {
2351        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2352        score.parts[0].staves[0].measures[0].voices[0] = vec![Note::new(
2353            Pitch::with_microtone(Step::C, 4, 0, 50),
2354            Duration::Quarter,
2355        )];
2356        let events = to_playback_events(&score, &opts(None));
2357        assert_eq!(events[0].pitch_midi, 61);
2358        assert_eq!(events[0].pitch_midi_cents, 6050);
2359    }
2360
2361    #[test]
2362    fn chord_expands_to_multiple_events() {
2363        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2364        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2365        note.pitches.push(Pitch::new(Step::E, 4));
2366        note.pitches.push(Pitch::new(Step::G, 4));
2367        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2368        let events = to_playback_events(&score, &opts(None));
2369        assert_eq!(events.len(), 3);
2370        assert!(
2371            events
2372                .iter()
2373                .all(|event| event.address.as_deref() == Some("0:0:0:0:0"))
2374        );
2375        assert!(events.iter().all(|e| e.time_beats.abs() < 1e-9));
2376    }
2377
2378    #[test]
2379    fn playback_events_preserve_authored_chord_symbol_without_inventing_notes() {
2380        let mut score = Score::new("Harmony", 120, 4, 4, 0, 1);
2381        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2382        note.chord_symbol = Some(ChordSymbol {
2383            root: "C".into(),
2384            kind: "major-seventh".into(),
2385            bass: Some("E".into()),
2386            placement: None,
2387            extender: false,
2388            harmonic_degree: None,
2389            harmony_function: None,
2390            harmony_type: None,
2391            chord_ref: None,
2392            range_end: None,
2393            degrees: Vec::new(),
2394        });
2395        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2396
2397        let events = to_playback_events(&score, &PlaybackOptions::default());
2398        assert_eq!(events.len(), 1);
2399        assert_eq!(events[0].pitch_midi, 60);
2400        assert_eq!(
2401            events[0]
2402                .chord_symbol
2403                .as_ref()
2404                .map(ChordSymbol::display_text),
2405            Some("Cmaj7/E".into())
2406        );
2407    }
2408
2409    #[test]
2410    fn authored_realization_default_keeps_ornament_as_one_semantic_event() {
2411        let mut score = Score::new("authored ornament", 120, 4, 4, 0, 1);
2412        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2413        note.articulations.push(Articulation::Trill);
2414        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2415
2416        let events = to_playback_events(&score, &PlaybackOptions::default());
2417        assert_eq!(events.len(), 1);
2418        assert_eq!(events[0].pitch_midi, 60);
2419        assert_eq!(events[0].articulations, vec![Articulation::Trill]);
2420    }
2421
2422    #[test]
2423    fn ornament_arpeggio_profile_realizes_trill_with_pinned_timing() {
2424        let mut score = Score::new("realized ornament", 120, 4, 4, 0, 1);
2425        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2426        note.articulations.push(Articulation::Trill);
2427        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2428
2429        let events = to_playback_events(
2430            &score,
2431            &PlaybackOptions {
2432                realization_profile: PlaybackRealizationProfile::OrnamentArpeggioV1,
2433                ..Default::default()
2434            },
2435        );
2436        assert_eq!(events.len(), 4);
2437        assert_eq!(
2438            events
2439                .iter()
2440                .map(|event| event.pitch_midi)
2441                .collect::<Vec<_>>(),
2442            vec![60, 61, 60, 61]
2443        );
2444        for (index, event) in events.iter().enumerate() {
2445            assert!((event.time_beats - index as f64 * 0.25).abs() < 1e-9);
2446            assert!((event.duration_beats - 0.25).abs() < 1e-9);
2447            assert!((event.time_secs - index as f64 * 0.125).abs() < 1e-9);
2448            assert!((event.duration_secs - 0.125).abs() < 1e-9);
2449        }
2450    }
2451
2452    #[test]
2453    fn ornament_arpeggio_profile_staggers_chord_in_authored_direction() {
2454        let mut score = Score::new("realized arpeggio", 120, 4, 4, 0, 1);
2455        let mut chord = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2456        chord.pitches.push(Pitch::new(Step::E, 4));
2457        chord.pitches.push(Pitch::new(Step::G, 4));
2458        chord.arpeggiate = Some(false);
2459        score.parts[0].staves[0].measures[0].voices[0] = vec![chord];
2460
2461        let events = to_playback_events(
2462            &score,
2463            &PlaybackOptions {
2464                realization_profile: PlaybackRealizationProfile::OrnamentArpeggioV1,
2465                ..Default::default()
2466            },
2467        );
2468        assert_eq!(events.len(), 3);
2469        let by_pitch: BTreeMap<_, _> = events
2470            .iter()
2471            .map(|event| (event.pitch_midi, event.time_beats))
2472            .collect();
2473        assert!((by_pitch[&67] - 0.0).abs() < 1e-9);
2474        assert!((by_pitch[&64] - 0.09).abs() < 1e-9);
2475        assert!((by_pitch[&60] - 0.18).abs() < 1e-9);
2476    }
2477
2478    #[test]
2479    fn grace_notes_excluded() {
2480        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2481        let mut grace = Note::new(Pitch::new(Step::D, 4), Duration::Eighth);
2482        grace.is_grace = true;
2483        let regular = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2484        score.parts[0].staves[0].measures[0].voices[0] = vec![grace, regular];
2485        let events = to_playback_events(&score, &opts(None));
2486        assert_eq!(events.len(), 1);
2487        assert_eq!(events[0].pitch_midi, 60);
2488    }
2489
2490    #[test]
2491    fn metronome_events_have_no_source_address() {
2492        let score = Score::new("T", 120, 4, 4, 0, 1);
2493        let options = PlaybackOptions {
2494            metronome: Some(MetronomeConfig::default()),
2495            ..Default::default()
2496        };
2497        let events = to_playback_events(&score, &options);
2498        assert!(!events.is_empty());
2499        assert!(events.iter().all(|event| event.address.is_none()));
2500    }
2501
2502    #[test]
2503    fn second_note_has_correct_time() {
2504        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2505        score.parts[0].staves[0].measures[0].voices[0] = vec![
2506            Note::new(Pitch::new(Step::C, 4), Duration::Quarter),
2507            Note::new(Pitch::new(Step::D, 4), Duration::Quarter),
2508        ];
2509        let events = to_playback_events(&score, &opts(None));
2510        assert_eq!(events.len(), 2);
2511        assert!((events[0].time_beats).abs() < 1e-9);
2512        assert!((events[1].time_beats - 1.0).abs() < 1e-9);
2513    }
2514
2515    #[test]
2516    fn sparse_voice_keeps_measure_boundaries() {
2517        let mut score = Score::new("T", 120, 4, 4, 0, 2);
2518        let note = || Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2519        score.parts[0].staves[0].measures[0].voices[1] = vec![note()];
2520        score.parts[0].staves[0].measures[1].voices[1] = vec![note()];
2521
2522        let events = to_playback_events(&score, &opts(None));
2523        assert_eq!(events.len(), 2);
2524        assert!((events[0].time_beats).abs() < 1e-9);
2525        assert!((events[1].time_beats - 4.0).abs() < 1e-9);
2526        assert!((events[1].time_secs - 2.0).abs() < 1e-9);
2527    }
2528
2529    #[test]
2530    fn time_secs_120_bpm_quarter_note_is_half_second() {
2531        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2532        score.parts[0].staves[0].measures[0].voices[0] =
2533            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2534        let events = to_playback_events(&score, &opts(None));
2535        assert!((events[0].time_secs).abs() < 1e-9);
2536        assert!((events[0].duration_secs - 0.5).abs() < 1e-9);
2537    }
2538
2539    #[test]
2540    fn bpm_override_changes_time_secs() {
2541        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2542        score.parts[0].staves[0].measures[0].voices[0] = vec![
2543            Note::new(Pitch::new(Step::C, 4), Duration::Quarter),
2544            Note::new(Pitch::new(Step::D, 4), Duration::Quarter),
2545        ];
2546        let events = to_playback_events(&score, &opts(Some(60)));
2547        assert!((events[0].time_secs).abs() < 1e-9);
2548        assert!((events[1].time_secs - 1.0).abs() < 1e-9);
2549    }
2550
2551    #[test]
2552    fn transpose_semitones_shifts_midi_output() {
2553        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2554        score.parts[0].staves[0].transpose_semitones = -2;
2555        score.parts[0].staves[0].measures[0].voices[0] =
2556            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2557        let events = to_playback_events(&score, &opts(None));
2558        assert_eq!(events.len(), 1);
2559        assert_eq!(events[0].pitch_midi, 58);
2560    }
2561
2562    #[test]
2563    fn percussion_channel_9_ignores_transpose_semitones() {
2564        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2565        score.parts[0].midi_channel = 9;
2566        score.parts[0].staves[0].transpose_semitones = -2;
2567        score.parts[0].staves[0].measures[0].voices[0] =
2568            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2569        let events = to_playback_events(&score, &opts(None));
2570        assert_eq!(events.len(), 1);
2571        assert_eq!(events[0].pitch_midi, 60);
2572    }
2573
2574    #[test]
2575    fn staccato_halves_duration_beats() {
2576        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2577        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2578        note.articulations
2579            .push(crate::model::notation::Articulation::Staccato);
2580        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2581        let events = to_playback_events(&score, &opts(None));
2582        assert_eq!(events.len(), 1);
2583        assert!((events[0].duration_beats - 0.5).abs() < 1e-9);
2584    }
2585
2586    #[test]
2587    fn staccatissimo_also_halves_duration() {
2588        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2589        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2590        note.articulations
2591            .push(crate::model::notation::Articulation::Staccatissimo);
2592        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2593        let events = to_playback_events(&score, &opts(None));
2594        assert!((events[0].duration_beats - 0.5).abs() < 1e-9);
2595    }
2596
2597    #[test]
2598    fn staccato_does_not_shift_next_note_time() {
2599        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2600        let mut n1 = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2601        n1.articulations
2602            .push(crate::model::notation::Articulation::Staccato);
2603        let n2 = Note::new(Pitch::new(Step::D, 4), Duration::Quarter);
2604        score.parts[0].staves[0].measures[0].voices[0] = vec![n1, n2];
2605        let events = to_playback_events(&score, &opts(None));
2606        assert_eq!(events.len(), 2);
2607        assert!((events[1].time_beats - 1.0).abs() < 1e-9);
2608    }
2609
2610    #[test]
2611    fn accent_boosts_velocity_clamped() {
2612        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2613        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2614        note.articulations
2615            .push(crate::model::notation::Articulation::Accent);
2616        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2617        let events = to_playback_events(&score, &opts(None));
2618        assert_eq!(events[0].velocity, 84);
2619    }
2620
2621    #[test]
2622    fn accent_clamped_at_127() {
2623        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2624        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2625        note.dynamic = Some(crate::model::notation::Dynamic::Ffff);
2626        note.articulations
2627            .push(crate::model::notation::Articulation::Accent);
2628        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2629        let events = to_playback_events(&score, &opts(None));
2630        assert_eq!(events[0].velocity, 127);
2631    }
2632
2633    #[test]
2634    fn tenuto_keeps_full_duration() {
2635        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2636        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2637        note.articulations
2638            .push(crate::model::notation::Articulation::Tenuto);
2639        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2640        let events = to_playback_events(&score, &opts(None));
2641        assert!((events[0].duration_beats - 1.0).abs() < 1e-9);
2642    }
2643
2644    #[test]
2645    fn pedal_start_sets_pedal_field() {
2646        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2647        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2648        note.pedal_start = true;
2649        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2650        let events = to_playback_events(&score, &opts(None));
2651        assert!(events[0].pedal);
2652    }
2653
2654    #[test]
2655    fn no_pedal_start_pedal_is_false() {
2656        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2657        score.parts[0].staves[0].measures[0].voices[0] =
2658            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2659        let events = to_playback_events(&score, &opts(None));
2660        assert!(!events[0].pedal);
2661    }
2662
2663    #[test]
2664    fn set_tempo_at_measure_changes_time_secs() {
2665        let mut score = Score::new("T", 120, 4, 4, 0, 2);
2666        score.parts[0].staves[0].measures[0].voices[0] =
2667            vec![Note::new(Pitch::new(Step::C, 4), Duration::Whole)];
2668        score.parts[0].staves[0].measures[1].tempo = Some(60);
2669        score.parts[0].staves[0].measures[1].voices[0] =
2670            vec![Note::new(Pitch::new(Step::D, 4), Duration::Whole)];
2671        let events = to_playback_events(&score, &opts(None));
2672        assert_eq!(events.len(), 2);
2673        assert!((events[0].time_secs).abs() < 1e-9);
2674        assert!((events[0].duration_secs - 2.0).abs() < 1e-9);
2675        assert!((events[1].time_secs - 2.0).abs() < 1e-9);
2676        assert!((events[1].duration_secs - 4.0).abs() < 1e-9);
2677    }
2678
2679    #[test]
2680    fn muted_part_produces_no_events() {
2681        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2682        score.parts[0].staves[0].measures[0].voices[0] =
2683            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2684        let options = PlaybackOptions {
2685            muted_parts: vec![0],
2686            ..Default::default()
2687        };
2688        assert!(to_playback_events(&score, &options).is_empty());
2689    }
2690
2691    #[test]
2692    fn part_index_field_set_correctly() {
2693        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2694        score.parts[0].staves[0].measures[0].voices[0] =
2695            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2696        let events = to_playback_events(&score, &opts(None));
2697        assert_eq!(events[0].part_index, 0);
2698    }
2699
2700    // ── loop_region ───────────────────────────────────────────────────────────
2701
2702    #[test]
2703    fn loop_region_filters_measures() {
2704        // 3 measures; notes in measures 0, 1, 2. Loop on [1,2] → only events from 1,2.
2705        let mut score = Score::new("T", 120, 4, 4, 0, 3);
2706        for mi in 0..3 {
2707            score.parts[0].staves[0].measures[mi].voices[0] =
2708                vec![Note::new(Pitch::new(Step::C, 4), Duration::Whole)];
2709        }
2710        let options = PlaybackOptions {
2711            loop_region: Some((1, 2)),
2712            ..Default::default()
2713        };
2714        let events = to_playback_events(&score, &options);
2715        assert_eq!(events.len(), 2);
2716        // First event in the region should start at beat 0 (region-relative)
2717        assert!((events[0].time_beats).abs() < 1e-9);
2718    }
2719
2720    #[test]
2721    fn loop_region_none_plays_all_measures() {
2722        let mut score = Score::new("T", 120, 4, 4, 0, 3);
2723        for mi in 0..3 {
2724            score.parts[0].staves[0].measures[mi].voices[0] =
2725                vec![Note::new(Pitch::new(Step::C, 4), Duration::Whole)];
2726        }
2727        let events = to_playback_events(&score, &opts(None));
2728        assert_eq!(events.len(), 3);
2729    }
2730
2731    // ── Fermata ───────────────────────────────────────────────────────────────
2732
2733    #[test]
2734    fn fermata_multiplier_extends_duration() {
2735        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2736        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2737        note.articulations
2738            .push(crate::model::notation::Articulation::Fermata);
2739        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2740        let options = PlaybackOptions {
2741            fermata_multiplier: 2.0,
2742            ..Default::default()
2743        };
2744        let events = to_playback_events(&score, &options);
2745        assert_eq!(events.len(), 1);
2746        assert!((events[0].duration_beats - 2.0).abs() < 1e-9);
2747    }
2748
2749    #[test]
2750    fn fermata_default_multiplier_is_1_5() {
2751        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2752        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2753        note.articulations
2754            .push(crate::model::notation::Articulation::Fermata);
2755        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2756        let events = to_playback_events(&score, &PlaybackOptions::default());
2757        assert_eq!(events.len(), 1);
2758        assert!((events[0].duration_beats - 1.5).abs() < 1e-9);
2759    }
2760
2761    #[test]
2762    fn fermata_hold_is_an_explicit_post_note_request_separate_from_extension() {
2763        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2764        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2765        note.articulations
2766            .push(crate::model::notation::Articulation::Fermata);
2767        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2768        let options = PlaybackOptions {
2769            fermata_multiplier: 2.0,
2770            fermata_hold_beats: 0.75,
2771            ..Default::default()
2772        };
2773        let events = to_playback_events(&score, &options);
2774        assert!((events[0].duration_beats - 2.0).abs() < 1e-9);
2775        assert!((events[0].post_note_pause_beats - 0.75).abs() < 1e-9);
2776    }
2777
2778    #[test]
2779    fn invalid_fermata_hold_is_safely_ignored() {
2780        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2781        let mut note = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
2782        note.articulations
2783            .push(crate::model::notation::Articulation::Fermata);
2784        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
2785        let options = PlaybackOptions {
2786            fermata_hold_beats: f64::NAN,
2787            ..Default::default()
2788        };
2789        assert_eq!(
2790            to_playback_events(&score, &options)[0].post_note_pause_beats,
2791            0.0
2792        );
2793    }
2794
2795    #[test]
2796    fn non_fermata_note_unaffected_by_fermata_multiplier() {
2797        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2798        score.parts[0].staves[0].measures[0].voices[0] =
2799            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2800        let options = PlaybackOptions {
2801            fermata_multiplier: 3.0,
2802            ..Default::default()
2803        };
2804        let events = to_playback_events(&score, &options);
2805        assert!((events[0].duration_beats - 1.0).abs() < 1e-9);
2806    }
2807
2808    // ── swing ─────────────────────────────────────────────────────────────────
2809
2810    #[test]
2811    fn swing_triplet_first_eighth_is_long() {
2812        // Two eighth notes in one measure; swing=0.67 → first=0.67, second=0.33
2813        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2814        score.parts[0].staves[0].measures[0].voices[0] = vec![
2815            Note::new(Pitch::new(Step::C, 4), Duration::Eighth),
2816            Note::new(Pitch::new(Step::D, 4), Duration::Eighth),
2817        ];
2818        let options = PlaybackOptions {
2819            swing: Some(0.67),
2820            ..Default::default()
2821        };
2822        let events = to_playback_events(&score, &options);
2823        // events are sorted by time_beats; C comes first (time_beats=0), D second
2824        let e_c = events.iter().find(|e| e.pitch_midi == 60).unwrap();
2825        let e_d = events.iter().find(|e| e.pitch_midi == 62).unwrap();
2826        assert!(
2827            (e_c.duration_beats - 0.67).abs() < 1e-9,
2828            "first eighth should be 0.67"
2829        );
2830        assert!(
2831            (e_d.duration_beats - 0.33).abs() < 1e-9,
2832            "second eighth should be 0.33"
2833        );
2834        // D starts at 0.67, not 0.5
2835        assert!(
2836            (e_d.time_beats - 0.67).abs() < 1e-9,
2837            "second note start should be at 0.67"
2838        );
2839    }
2840
2841    #[test]
2842    fn swing_non_eighth_not_affected() {
2843        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2844        score.parts[0].staves[0].measures[0].voices[0] =
2845            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2846        let options = PlaybackOptions {
2847            swing: Some(0.67),
2848            ..Default::default()
2849        };
2850        let events = to_playback_events(&score, &options);
2851        assert!(
2852            (events[0].duration_beats - 1.0).abs() < 1e-9,
2853            "quarter note unaffected"
2854        );
2855    }
2856
2857    #[test]
2858    fn swing_none_is_straight() {
2859        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2860        score.parts[0].staves[0].measures[0].voices[0] =
2861            vec![Note::new(Pitch::new(Step::C, 4), Duration::Eighth)];
2862        let options = PlaybackOptions {
2863            swing: None,
2864            ..Default::default()
2865        };
2866        let events = to_playback_events(&score, &options);
2867        assert!(
2868            (events[0].duration_beats - 0.5).abs() < 1e-9,
2869            "no swing = straight eighth"
2870        );
2871    }
2872
2873    #[test]
2874    fn channel_matches_part_midi_channel() {
2875        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2876        score.parts[0].midi_channel = 3;
2877        score.parts[0].staves[0].measures[0].voices[0] =
2878            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2879        let events = to_playback_events(&score, &opts(None));
2880        assert_eq!(events[0].channel, 3);
2881    }
2882
2883    #[test]
2884    fn swing_unit_default_is_eighth() {
2885        assert_eq!(PlaybackOptions::default().swing_unit, Duration::Eighth);
2886    }
2887
2888    #[test]
2889    fn swing_unit_sixteenth() {
2890        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2891        score.parts[0].staves[0].measures[0].voices[0] = vec![
2892            Note::new(Pitch::new(Step::C, 4), Duration::Sixteenth),
2893            Note::new(Pitch::new(Step::D, 4), Duration::Sixteenth),
2894        ];
2895        let options = PlaybackOptions {
2896            swing: Some(0.67),
2897            swing_unit: Duration::Sixteenth,
2898            ..Default::default()
2899        };
2900        let events = to_playback_events(&score, &options);
2901        let e_c = events.iter().find(|e| e.pitch_midi == 60).unwrap();
2902        let e_d = events.iter().find(|e| e.pitch_midi == 62).unwrap();
2903        assert!(
2904            (e_c.duration_beats - 0.335).abs() < 1e-9,
2905            "first 16th should be 0.335"
2906        );
2907        assert!(
2908            (e_d.duration_beats - 0.165).abs() < 1e-9,
2909            "second 16th should be 0.165"
2910        );
2911    }
2912
2913    #[test]
2914    fn swing_resets_per_measure() {
2915        // 2 measures each with 2 eighth notes; each measure's first eighth should be "long"
2916        let mut score = Score::new("T", 120, 4, 4, 0, 2);
2917        let pair = || {
2918            vec![
2919                Note::new(Pitch::new(Step::C, 4), Duration::Eighth),
2920                Note::new(Pitch::new(Step::D, 4), Duration::Eighth),
2921            ]
2922        };
2923        score.parts[0].staves[0].measures[0].voices[0] = pair();
2924        score.parts[0].staves[0].measures[1].voices[0] = pair();
2925        let options = PlaybackOptions {
2926            swing: Some(0.67),
2927            ..Default::default()
2928        };
2929        let events = to_playback_events(&score, &options);
2930        // Four events sorted by time: m0-C, m0-D, m1-C, m1-D
2931        let durations: Vec<f64> = events.iter().map(|e| e.duration_beats).collect();
2932        // m0 first (long)
2933        assert!((durations[0] - 0.67).abs() < 1e-9, "m0 first note long");
2934        // m0 second (short)
2935        assert!((durations[1] - 0.33).abs() < 1e-9, "m0 second note short");
2936        // m1 first (long again — reset)
2937        assert!(
2938            (durations[2] - 0.67).abs() < 1e-9,
2939            "m1 first note long (reset)"
2940        );
2941        // m1 second (short)
2942        assert!((durations[3] - 0.33).abs() < 1e-9, "m1 second note short");
2943    }
2944
2945    #[test]
2946    fn multi_voice_events_preserve_source_voice_addresses() {
2947        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2948        score.parts[0].staves[0].measures[0].voices[0] =
2949            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
2950        score.parts[0].staves[0].measures[0].voices[1] =
2951            vec![Note::new(Pitch::new(Step::E, 4), Duration::Quarter)];
2952
2953        let events = to_playback_events(&score, &PlaybackOptions::default());
2954        let addresses: Vec<&str> = events
2955            .iter()
2956            .filter_map(|event| event.address.as_deref())
2957            .collect();
2958        assert!(addresses.contains(&"0:0:0:0:0"));
2959        assert!(addresses.contains(&"0:0:0:1:0"));
2960    }
2961
2962    #[test]
2963    fn playback_exposes_original_musicxml_voice_number_alongside_slot_address() {
2964        let mut score = Score::new("T", 120, 4, 4, 0, 1);
2965        let measure = &mut score.parts[0].staves[0].measures[0];
2966        measure.voices[1] = vec![Note::new(Pitch::new(Step::E, 4), Duration::Quarter)];
2967        measure.source_voice_numbers[1] = Some(5);
2968
2969        let events = to_playback_events(&score, &PlaybackOptions::default());
2970        let event = events
2971            .iter()
2972            .find(|event| event.address.as_deref() == Some("0:0:0:1:0"))
2973            .expect("event from slot 1");
2974        assert_eq!(event.source.as_ref().map(|source| source.voice), Some(1));
2975        assert_eq!(event.source_voice_number, Some(5));
2976    }
2977
2978    // ── compute_playback_position ─────────────────────────────────────────────
2979
2980    #[test]
2981    fn playback_position_at_zero_is_measure_0_beat_0() {
2982        let score = Score::new("T", 120, 4, 4, 0, 4);
2983        let pos = compute_playback_position(&score, &PlaybackOptions::default(), 0.0).unwrap();
2984        assert_eq!(pos.measure_index, 0);
2985        assert!(pos.beat.abs() < 1e-9);
2986    }
2987
2988    #[test]
2989    fn playback_position_at_half_measure_is_beat_2() {
2990        // 4/4, 120 BPM → 1 measure = 2.0 s; 0.5 s = beat 1.0
2991        let score = Score::new("T", 120, 4, 4, 0, 4);
2992        let pos = compute_playback_position(&score, &PlaybackOptions::default(), 0.5).unwrap();
2993        assert_eq!(pos.measure_index, 0);
2994        assert!(
2995            (pos.beat - 1.0).abs() < 1e-9,
2996            "expected beat 1.0, got {}",
2997            pos.beat
2998        );
2999    }
3000
3001    #[test]
3002    fn playback_position_beyond_score_is_none() {
3003        // 4/4, 120 BPM, 1 measure = 2.0 s; 10.0 s is beyond
3004        let score = Score::new("T", 120, 4, 4, 0, 1);
3005        assert!(compute_playback_position(&score, &PlaybackOptions::default(), 10.0).is_none());
3006    }
3007
3008    #[test]
3009    fn playback_position_tempo_change_takes_effect() {
3010        // measure 0: 120 BPM (2.0 s), measure 1: 60 BPM (4.0 s)
3011        // At elapsed=2.5 s → inside measure 1, 0.5 s into it → beat 0.5
3012        let mut score = Score::new("T", 120, 4, 4, 0, 2);
3013        score.parts[0].staves[0].measures[1].tempo = Some(60);
3014        let pos = compute_playback_position(&score, &PlaybackOptions::default(), 2.5).unwrap();
3015        assert_eq!(pos.measure_index, 1);
3016        assert!(
3017            (pos.beat - 0.5).abs() < 1e-9,
3018            "expected beat 0.5, got {}",
3019            pos.beat
3020        );
3021    }
3022
3023    #[test]
3024    fn playback_position_loop_region_starts_at_zero() {
3025        // loop_region=[1,2] → elapsed=0 should map to measure 1, beat 0
3026        let score = Score::new("T", 120, 4, 4, 0, 4);
3027        let options = PlaybackOptions {
3028            loop_region: Some((1, 2)),
3029            ..Default::default()
3030        };
3031        let pos = compute_playback_position(&score, &options, 0.0).unwrap();
3032        assert_eq!(pos.measure_index, 1);
3033        assert!(pos.beat.abs() < 1e-9);
3034    }
3035
3036    // ── MetronomeConfig ───────────────────────────────────────────────────────
3037
3038    #[test]
3039    fn metronome_injects_beat_events() {
3040        // 4/4, 1 measure → should inject 4 metronome events
3041        let score = Score::new("T", 120, 4, 4, 0, 1);
3042        let options = PlaybackOptions {
3043            metronome: Some(MetronomeConfig::default()),
3044            ..Default::default()
3045        };
3046        let events = to_playback_events(&score, &options);
3047        let metro_events: Vec<_> = events.iter().filter(|e| e.is_metronome).collect();
3048        assert_eq!(metro_events.len(), 4, "expected 4 metronome clicks in 4/4");
3049    }
3050
3051    #[test]
3052    fn metronome_accent_is_first_beat() {
3053        let score = Score::new("T", 120, 4, 4, 0, 1);
3054        let metro = MetronomeConfig::default();
3055        let options = PlaybackOptions {
3056            metronome: Some(metro.clone()),
3057            ..Default::default()
3058        };
3059        let events = to_playback_events(&score, &options);
3060        let mut metro_events: Vec<_> = events.iter().filter(|e| e.is_metronome).collect();
3061        metro_events.sort_by(|a, b| a.time_beats.partial_cmp(&b.time_beats).unwrap());
3062        assert_eq!(metro_events[0].pitch_midi, metro.accent_pitch);
3063        assert_eq!(metro_events[0].velocity, metro.accent_velocity);
3064    }
3065
3066    #[test]
3067    fn metronome_regular_beat_pitch() {
3068        let score = Score::new("T", 120, 4, 4, 0, 1);
3069        let metro = MetronomeConfig::default();
3070        let options = PlaybackOptions {
3071            metronome: Some(metro.clone()),
3072            ..Default::default()
3073        };
3074        let events = to_playback_events(&score, &options);
3075        let mut metro_events: Vec<_> = events.iter().filter(|e| e.is_metronome).collect();
3076        metro_events.sort_by(|a, b| a.time_beats.partial_cmp(&b.time_beats).unwrap());
3077        for ev in &metro_events[1..] {
3078            assert_eq!(ev.pitch_midi, metro.beat_pitch);
3079            assert_eq!(ev.velocity, metro.beat_velocity);
3080        }
3081    }
3082
3083    #[test]
3084    fn metronome_integrates_measure_tempo_ramp_and_carries_ending_tempo() {
3085        let mut score = Score::new("T", 120, 4, 4, 0, 2);
3086        score.parts[0].staves[0].measures[0].tempo_ramp_to = Some(60);
3087        let options = PlaybackOptions {
3088            metronome: Some(MetronomeConfig::default()),
3089            ..Default::default()
3090        };
3091
3092        let mut clicks: Vec<_> = to_playback_events(&score, &options)
3093            .into_iter()
3094            .filter(|event| event.is_metronome)
3095            .collect();
3096        clicks.sort_by(|left, right| left.time_beats.total_cmp(&right.time_beats));
3097
3098        let expected_second_beat = tempo_ramp_seconds(120.0, Some(60.0), 4.0, 1.0);
3099        let expected_second_measure = tempo_ramp_seconds(120.0, Some(60.0), 4.0, 4.0);
3100        assert!((clicks[1].time_secs - expected_second_beat).abs() < 1e-9);
3101        assert!((clicks[4].time_secs - expected_second_measure).abs() < 1e-9);
3102        assert!((clicks[5].time_secs - (expected_second_measure + 1.0)).abs() < 1e-9);
3103    }
3104
3105    #[test]
3106    fn metronome_events_are_marked() {
3107        let score = Score::new("T", 120, 4, 4, 0, 1);
3108        let options = PlaybackOptions {
3109            metronome: Some(MetronomeConfig::default()),
3110            ..Default::default()
3111        };
3112        let events = to_playback_events(&score, &options);
3113        assert!(events.iter().any(|e| e.is_metronome));
3114    }
3115
3116    #[test]
3117    fn metronome_none_produces_no_extra_events() {
3118        let score = Score::new("T", 120, 4, 4, 0, 1);
3119        let events = to_playback_events(&score, &PlaybackOptions::default());
3120        assert!(events.iter().all(|e| !e.is_metronome));
3121    }
3122
3123    #[test]
3124    fn offline_render_manifest_uses_event_end_as_exact_frame_length() {
3125        let mut score = Score::new("T", 120, 4, 4, 0, 1);
3126        score.parts[0].staves[0].measures[0].voices[0][0] =
3127            Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
3128        let request = OfflineRenderRequest {
3129            format: OfflineRenderFormat::Flac,
3130            sample_rate_hz: 48_000,
3131            channels: 2,
3132            provider_identity: Some("test-provider@1".into()),
3133            ..Default::default()
3134        };
3135
3136        let manifest = build_offline_render_manifest(&score, &PlaybackOptions::default(), &request)
3137            .expect("valid render manifest");
3138        assert_eq!(manifest.contract_version, OFFLINE_RENDER_CONTRACT_VERSION);
3139        assert!(manifest.validate().is_ok());
3140        assert_eq!(manifest.format, OfflineRenderFormat::Flac);
3141        assert_eq!(manifest.duration_frames, 24_000);
3142        assert_eq!(manifest.events.len(), 1);
3143        assert_eq!(manifest.frame_events.len(), 1);
3144        assert_eq!(manifest.frame_events[0].start_frame, 0);
3145        assert_eq!(manifest.frame_events[0].duration_frames, 24_000);
3146        assert_eq!(manifest.frame_events[0].end_frame, 24_000);
3147        assert_eq!(manifest.playback_options, PlaybackOptions::default());
3148        assert_eq!(
3149            manifest.provider_identity.as_deref(),
3150            Some("test-provider@1")
3151        );
3152    }
3153
3154    #[test]
3155    fn offline_render_manifest_rejects_out_of_range_audio_shape() {
3156        let score = Score::new("T", 120, 4, 4, 0, 1);
3157        let request = OfflineRenderRequest {
3158            sample_rate_hz: 0,
3159            ..Default::default()
3160        };
3161        assert!(matches!(
3162            build_offline_render_manifest(&score, &PlaybackOptions::default(), &request),
3163            Err(crate::Error::InvalidOfflineRenderRequest)
3164        ));
3165    }
3166
3167    #[test]
3168    fn offline_render_manifest_selection_keeps_source_address_and_release_tail() {
3169        let mut score = Score::new("T", 120, 4, 4, 0, 1);
3170        score.parts[0].staves[0].measures[0].voices[0] = vec![
3171            Note::new(Pitch::new(Step::C, 4), Duration::Quarter),
3172            Note::new(Pitch::new(Step::D, 4), Duration::Quarter),
3173        ];
3174        let events = to_playback_events(&score, &PlaybackOptions::default());
3175        score.parts[0].midi_control_changes.push(MidiControlChange {
3176            tick: 480,
3177            channel: 0,
3178            controller: 7,
3179            value: 100,
3180        });
3181        let request = OfflineRenderRequest {
3182            sample_rate_hz: 8_000,
3183            release_tail_millis: 125,
3184            scope: OfflineRenderScope::Selection {
3185                addresses: vec![events[1].source.clone().expect("source address")],
3186            },
3187            ..Default::default()
3188        };
3189        let manifest = build_offline_render_manifest(&score, &PlaybackOptions::default(), &request)
3190            .expect("selection manifest");
3191        assert_eq!(manifest.events.len(), 1);
3192        assert_eq!(manifest.events[0].source, events[1].source);
3193        assert_eq!(manifest.frame_events[0].start_frame, 0);
3194        assert!(manifest.semantic_events.iter().any(|event| matches!(
3195            event.kind,
3196            OfflineRenderSemanticEventKind::Controller {
3197                channel: 0,
3198                controller: 7,
3199                value: 100
3200            }
3201        ) && event.frame == 0));
3202        assert_eq!(manifest.release_tail_frames, 1_000);
3203        assert_eq!(manifest.duration_frames, 5_000);
3204    }
3205
3206    #[test]
3207    fn offline_render_request_owned_options_override_legacy_argument() {
3208        let mut score = Score::new("T", 120, 4, 4, 0, 1);
3209        score.parts[0].staves[0].measures[0].voices[0][0] =
3210            Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
3211        let request_options = PlaybackOptions {
3212            bpm_override: Some(60),
3213            ..Default::default()
3214        };
3215        let manifest = build_offline_render_manifest(
3216            &score,
3217            &PlaybackOptions::default(),
3218            &OfflineRenderRequest {
3219                sample_rate_hz: 48_000,
3220                playback_options: Some(request_options.clone()),
3221                ..Default::default()
3222            },
3223        )
3224        .expect("request-owned playback options");
3225        assert_eq!(manifest.playback_options, request_options);
3226        assert_eq!(manifest.frame_events[0].duration_frames, 48_000);
3227    }
3228
3229    #[test]
3230    fn offline_manifest_projects_typed_midi_events_to_exact_frames() {
3231        let mut score = Score::new("MIDI semantics", 120, 4, 4, 0, 1);
3232        score.parts[0].midi_pitch_bends.push(MidiPitchBend {
3233            tick: 480,
3234            channel: 2,
3235            value: -512,
3236        });
3237        score.parts[0].midi_program_changes.push(MidiProgramChange {
3238            tick: 480,
3239            channel: 2,
3240            program: 41,
3241        });
3242        score.parts[0].midi_aftertouch.push(MidiAftertouch {
3243            tick: 480,
3244            channel: 2,
3245            key: Some(64),
3246            value: 88,
3247        });
3248        let manifest = build_offline_render_manifest(
3249            &score,
3250            &PlaybackOptions::default(),
3251            &OfflineRenderRequest {
3252                sample_rate_hz: 48_000,
3253                ..Default::default()
3254            },
3255        )
3256        .expect("manifest builds");
3257        for kind in [
3258            OfflineRenderSemanticEventKind::PitchBend {
3259                channel: 2,
3260                value: -512,
3261            },
3262            OfflineRenderSemanticEventKind::ProgramChange {
3263                channel: 2,
3264                program: 41,
3265            },
3266            OfflineRenderSemanticEventKind::Aftertouch {
3267                channel: 2,
3268                key: Some(64),
3269                value: 88,
3270            },
3271        ] {
3272            assert!(manifest.semantic_events.iter().any(|event| {
3273                event.kind == kind
3274                    && event.frame == 24_000
3275                    && event
3276                        .measure
3277                        .as_ref()
3278                        .is_some_and(|address| address.part == 0 && address.measure == 0)
3279            }));
3280        }
3281    }
3282
3283    #[test]
3284    fn offline_manifest_frames_cover_repeat_ramp_fermata_pedal_bend_and_instrument_change() {
3285        let mut score = Score::new("fixture", 120, 4, 4, 0, 2);
3286        let mut first = Note::new(Pitch::new(Step::C, 4), Duration::Quarter);
3287        first.pedal_start = true;
3288        first.articulations = vec![Articulation::Fermata, Articulation::BreathMark];
3289        first.guitar_bend_curve = vec![GuitarBendPoint {
3290            position_per_mille: 500,
3291            alter_cents: 100,
3292        }];
3293        score.parts[0].staves[0].measures[0].voices[0] = vec![first];
3294        score.parts[0].staves[0].measures[0].barline_left =
3295            super::super::notation::Barline::RepeatStart;
3296        score.parts[0].staves[0].measures[0].tempo_ramp_to = Some(60);
3297        score.parts[0].staves[0].measures[0].navigation = Some("Segno".to_string());
3298        score.parts[0].midi_control_changes.push(MidiControlChange {
3299            tick: 480,
3300            channel: 0,
3301            controller: 11,
3302            value: 96,
3303        });
3304
3305        let mut second = Note::new(Pitch::new(Step::D, 4), Duration::Quarter);
3306        second.pedal_end = true;
3307        score.parts[0].staves[0].measures[1].voices[0] = vec![second];
3308        score.parts[0].staves[0].measures[1].barline_right =
3309            super::super::notation::Barline::RepeatEnd;
3310        let mut flute = crate::InstrumentDefinition::new("flute", "Flute");
3311        flute.midi_channel = 2;
3312        flute.midi_program = 73;
3313        score.parts[0].staves[0].measures[1].instrument_change = Some(flute);
3314
3315        let request = OfflineRenderRequest {
3316            sample_rate_hz: 48_000,
3317            playback_options: Some(PlaybackOptions {
3318                fermata_multiplier: 1.5,
3319                fermata_hold_beats: 0.25,
3320                ..Default::default()
3321            }),
3322            ..Default::default()
3323        };
3324        let manifest = build_offline_render_manifest(&score, &PlaybackOptions::default(), &request)
3325            .expect("fixture manifest");
3326        assert_eq!(manifest.frame_events.len(), 4);
3327        let measures: Vec<usize> = manifest
3328            .frame_events
3329            .iter()
3330            .map(|event| event.event.source.as_ref().unwrap().measure)
3331            .collect();
3332        assert_eq!(measures, vec![0, 1, 0, 1]);
3333        assert!(manifest.frame_events[0].event.pedal);
3334        assert_eq!(manifest.frame_events[0].event.post_note_pause_beats, 0.25);
3335        assert_eq!(manifest.frame_events[0].event.pitch_bend_curve.len(), 1);
3336        assert_eq!(
3337            manifest.frame_events[1].event.instrument_id.as_deref(),
3338            Some("flute")
3339        );
3340        assert_eq!(manifest.frame_events[3].event.program, 73);
3341        assert!(manifest.semantic_events.iter().any(|event| {
3342            matches!(
3343                &event.kind,
3344                OfflineRenderSemanticEventKind::InstrumentChange {
3345                    instrument_id,
3346                    channel: 2,
3347                    program: 73,
3348                    transpose_semitones: 0,
3349                } if instrument_id == "flute"
3350            ) && event
3351                .measure
3352                .as_ref()
3353                .is_some_and(|address| address.measure == 1)
3354                && event.frame == manifest.frame_events[1].start_frame
3355        }));
3356        assert!(manifest.semantic_events.iter().any(|event| matches!(
3357            event.kind,
3358            OfflineRenderSemanticEventKind::Pedal { down: true }
3359        ) && event.frame
3360            == manifest.frame_events[0].start_frame));
3361        assert!(manifest.semantic_events.iter().any(|event| matches!(
3362            event.kind,
3363            OfflineRenderSemanticEventKind::Pedal { down: false }
3364        ) && event.frame
3365            == manifest.frame_events[1].start_frame));
3366        assert!(manifest.semantic_events.iter().any(|event| matches!(
3367            event.kind,
3368            OfflineRenderSemanticEventKind::Articulation {
3369                articulation: Articulation::Fermata
3370            }
3371        )));
3372        assert!(manifest.semantic_events.iter().any(|event| matches!(
3373            event.kind,
3374            OfflineRenderSemanticEventKind::GuitarBend { .. }
3375        )));
3376        let tempo_events = manifest
3377            .semantic_events
3378            .iter()
3379            .filter(|event| matches!(event.kind, OfflineRenderSemanticEventKind::Tempo { .. }))
3380            .count();
3381        let navigation_events = manifest
3382            .semantic_events
3383            .iter()
3384            .filter(|event| {
3385                matches!(
3386                    event.kind,
3387                    OfflineRenderSemanticEventKind::Navigation { .. }
3388                )
3389            })
3390            .count();
3391        let control_frames: Vec<u64> = manifest
3392            .semantic_events
3393            .iter()
3394            .filter_map(|event| {
3395                matches!(
3396                    event.kind,
3397                    OfflineRenderSemanticEventKind::Controller {
3398                        channel: 0,
3399                        controller: 11,
3400                        value: 96
3401                    }
3402                )
3403                .then_some(event.frame)
3404            })
3405            .collect();
3406        assert_eq!(tempo_events, 2);
3407        assert_eq!(navigation_events, 2);
3408        assert_eq!(control_frames.len(), 2);
3409        let ramp_duration = tempo_ramp_seconds(120.0, Some(60.0), 4.0, 4.0);
3410        assert_eq!(
3411            control_frames[0],
3412            (tempo_ramp_seconds(120.0, Some(60.0), 4.0, 1.0) * 48_000.0).round() as u64
3413        );
3414        assert_eq!(control_frames[1], 373_084);
3415
3416        let expected_starts = [0.0, ramp_duration, ramp_duration + 4.0, ramp_duration + 8.0];
3417        for (frame_event, expected_secs) in manifest.frame_events.iter().zip(expected_starts) {
3418            assert_eq!(
3419                frame_event.start_frame,
3420                (expected_secs * 48_000.0).round() as u64
3421            );
3422        }
3423    }
3424
3425    #[test]
3426    fn offline_render_manifest_reports_unresolved_selection_address() {
3427        let score = Score::new("T", 120, 4, 4, 0, 1);
3428        let request = OfflineRenderRequest {
3429            scope: OfflineRenderScope::Selection {
3430                addresses: vec![NoteAddr {
3431                    part: 0,
3432                    staff: 0,
3433                    measure: 0,
3434                    voice: 0,
3435                    note: 99,
3436                }],
3437            },
3438            ..Default::default()
3439        };
3440        let manifest = build_offline_render_manifest(&score, &PlaybackOptions::default(), &request)
3441            .expect("empty selection is representable");
3442        assert_eq!(manifest.events.len(), 0);
3443        assert_eq!(
3444            manifest.diagnostics,
3445            vec![
3446                OfflineRenderDiagnostic {
3447                    kind: OfflineRenderDiagnosticKind::UnresolvedSelectionAddress,
3448                    source: Some(NoteAddr {
3449                        part: 0,
3450                        staff: 0,
3451                        measure: 0,
3452                        voice: 0,
3453                        note: 99,
3454                    }),
3455                },
3456                OfflineRenderDiagnostic {
3457                    kind: OfflineRenderDiagnosticKind::EmptySelection,
3458                    source: None,
3459                },
3460            ]
3461        );
3462    }
3463
3464    #[test]
3465    fn offline_render_manifest_v1_json_migrates_with_v2_defaults() {
3466        let legacy = serde_json::json!({
3467            "contract_version": 1,
3468            "playback_contract_version": 2,
3469            "format": "Wav",
3470            "sample_rate_hz": 48_000,
3471            "channels": 2,
3472            "duration_frames": 0,
3473            "events": []
3474        });
3475        let manifest: OfflineRenderManifest =
3476            serde_json::from_value(legacy).expect("v1 manifest remains readable");
3477        assert_eq!(manifest.contract_version, 1);
3478        assert_eq!(manifest.scope, OfflineRenderScope::FullScore);
3479        assert_eq!(manifest.release_tail_frames, 0);
3480        assert_eq!(manifest.playback_options, PlaybackOptions::default());
3481        assert!(manifest.frame_events.is_empty());
3482        assert!(manifest.diagnostics.is_empty());
3483        assert!(manifest.validate().is_ok());
3484    }
3485
3486    #[test]
3487    fn offline_render_manifest_validation_rejects_tampered_frame_and_tail_boundaries() {
3488        let mut score = Score::new("T", 120, 4, 4, 0, 1);
3489        score.parts[0].staves[0].measures[0].voices[0] =
3490            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
3491        let manifest = build_offline_render_manifest(
3492            &score,
3493            &PlaybackOptions::default(),
3494            &OfflineRenderRequest {
3495                sample_rate_hz: 48_000,
3496                release_tail_millis: 100,
3497                ..Default::default()
3498            },
3499        )
3500        .expect("manifest builds");
3501        assert!(manifest.validate().is_ok());
3502
3503        let mut invalid_tail = manifest.clone();
3504        invalid_tail.duration_frames = invalid_tail.duration_frames.saturating_sub(1);
3505        assert!(matches!(
3506            invalid_tail.validate(),
3507            Err(crate::Error::InvalidOfflineRenderRequest)
3508        ));
3509
3510        let mut invalid_frame = manifest;
3511        invalid_frame.frame_events[0].end_frame =
3512            invalid_frame.frame_events[0].end_frame.saturating_add(1);
3513        assert!(matches!(
3514            invalid_frame.validate(),
3515            Err(crate::Error::InvalidOfflineRenderRequest)
3516        ));
3517    }
3518
3519    #[test]
3520    fn routing_manifest_prefers_instrument_bus_and_isolates_metronome() {
3521        let mut score = Score::new("routing", 120, 4, 4, 0, 1);
3522        let mut instrument = crate::InstrumentDefinition::new("flute", "Flute");
3523        instrument.midi_channel = 2;
3524        instrument.midi_program = 73;
3525        score.parts[0].instrument = Some(instrument);
3526        score.parts[0].staves[0].measures[0].voices[0] =
3527            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
3528        let options = PlaybackOptions {
3529            metronome: Some(MetronomeConfig::default()),
3530            ..Default::default()
3531        };
3532        let mut config = PlaybackRoutingConfig {
3533            provider_identity: Some("sf2-host@1".into()),
3534            ..Default::default()
3535        };
3536        config.part_buses.insert(0, "parts".into());
3537        config
3538            .instrument_buses
3539            .insert("flute".into(), "winds".into());
3540        config.aux_sends.push(PlaybackAuxSend {
3541            source_bus: "winds".into(),
3542            destination_bus: "reverb".into(),
3543            gain_db: -12.0,
3544        });
3545        config.effect_routes.push(PlaybackEffectRoute {
3546            bus_id: "reverb".into(),
3547            effect_id: "convolution".into(),
3548            enabled: true,
3549        });
3550
3551        let manifest = build_playback_routing_manifest(&score, &options, &config)
3552            .expect("valid routing manifest");
3553        assert_eq!(manifest.contract_version, PLAYBACK_ROUTING_CONTRACT_VERSION);
3554        assert_eq!(manifest.provider_identity.as_deref(), Some("sf2-host@1"));
3555        assert!(manifest.routes.iter().any(|route| {
3556            route.instrument_id.as_deref() == Some("flute") && route.bus_id == "winds"
3557        }));
3558        assert!(
3559            manifest
3560                .routes
3561                .iter()
3562                .any(|route| route.is_metronome && route.bus_id == "metronome")
3563        );
3564        assert_eq!(manifest.aux_sends.len(), 1);
3565        assert_eq!(manifest.effect_routes.len(), 1);
3566    }
3567
3568    #[test]
3569    fn routing_manifest_rejects_unsafe_bus_and_non_finite_send_gain() {
3570        let score = Score::new("routing", 120, 4, 4, 0, 1);
3571        let config = PlaybackRoutingConfig {
3572            master_bus: "not a bus".into(),
3573            ..Default::default()
3574        };
3575        assert!(matches!(
3576            build_playback_routing_manifest(&score, &PlaybackOptions::default(), &config),
3577            Err(crate::Error::InvalidPlaybackRouting)
3578        ));
3579
3580        let mut config = PlaybackRoutingConfig::default();
3581        config.aux_sends.push(PlaybackAuxSend {
3582            source_bus: "part".into(),
3583            destination_bus: "master".into(),
3584            gain_db: f64::NAN,
3585        });
3586        assert!(matches!(
3587            build_playback_routing_manifest(&score, &PlaybackOptions::default(), &config),
3588            Err(crate::Error::InvalidPlaybackRouting)
3589        ));
3590    }
3591
3592    #[test]
3593    fn timing_corpus_reports_score_schedule_results_without_audio_claims() {
3594        let mut score = Score::new("corpus", 120, 4, 4, 0, 1);
3595        score.parts[0].staves[0].measures[0].voices[0] =
3596            vec![Note::new(Pitch::new(Step::C, 4), Duration::Quarter)];
3597        let expected_events = to_playback_events(&score, &PlaybackOptions::default());
3598        let report = evaluate_playback_timing_corpus(&[PlaybackTimingCase {
3599            id: "quarter-note".into(),
3600            score,
3601            options: PlaybackOptions::default(),
3602            expected_events,
3603            tolerance: PlaybackTimingTolerance::default(),
3604        }])
3605        .expect("valid timing corpus");
3606        assert_eq!(
3607            report.contract_version,
3608            PLAYBACK_TIMING_CORPUS_CONTRACT_VERSION
3609        );
3610        assert_eq!(report.total_cases, 1);
3611        assert_eq!(report.passed_cases, 1);
3612        assert!(report.cases[0].report.within_tolerance);
3613    }
3614
3615    #[test]
3616    fn timing_corpus_rejects_empty_or_duplicate_case_ids() {
3617        assert!(matches!(
3618            evaluate_playback_timing_corpus(&[]),
3619            Err(crate::Error::InvalidPlaybackTimingCorpus)
3620        ));
3621        let score = Score::new("corpus", 120, 4, 4, 0, 1);
3622        let case = PlaybackTimingCase {
3623            id: "duplicate".into(),
3624            expected_events: to_playback_events(&score, &PlaybackOptions::default()),
3625            score,
3626            options: PlaybackOptions::default(),
3627            tolerance: PlaybackTimingTolerance::default(),
3628        };
3629        assert!(matches!(
3630            evaluate_playback_timing_corpus(&[case.clone(), case]),
3631            Err(crate::Error::InvalidPlaybackTimingCorpus)
3632        ));
3633    }
3634
3635    fn comparison_event(time_secs: f64, duration_secs: f64) -> PlaybackEvent {
3636        PlaybackEvent {
3637            address: Some("0:0:0:0:0".into()),
3638            source: Some(NoteAddr {
3639                part: 0,
3640                staff: 0,
3641                measure: 0,
3642                voice: 0,
3643                note: 0,
3644            }),
3645            source_voice_number: None,
3646            time_beats: 0.0,
3647            time_secs,
3648            pitch_midi: 60,
3649            pitch_midi_cents: 6000,
3650            pitch_bend_curve: Vec::new(),
3651            post_note_pause_beats: 0.0,
3652            articulations: Vec::new(),
3653            chord_symbol: None,
3654            guitar_technique: None,
3655            velocity: 64,
3656            duration_beats: 1.0,
3657            duration_secs,
3658            pedal: false,
3659            part_index: 0,
3660            channel: 0,
3661            program: 0,
3662            instrument_id: None,
3663            is_metronome: false,
3664        }
3665    }
3666
3667    #[test]
3668    fn legacy_playback_event_json_defaults_bend_curve() {
3669        let event: PlaybackEvent = serde_json::from_str(
3670            r#"{"address":null,"source":null,"source_voice_number":null,"time_beats":0.0,"time_secs":0.0,"pitch_midi":60,"pitch_midi_cents":6000,"velocity":64,"duration_beats":1.0,"duration_secs":0.5,"pedal":false,"part_index":0,"channel":0,"is_metronome":false}"#,
3671        )
3672        .expect("legacy playback event remains readable");
3673        assert!(event.pitch_bend_curve.is_empty());
3674        assert_eq!(event.guitar_technique, None);
3675    }
3676
3677    #[test]
3678    fn tempo_ramp_uses_integrated_event_timing_and_carries_target_forward() {
3679        let mut score = Score::new("ramp", 120, 4, 4, 0, 2);
3680        for measure in &mut score.parts[0].staves[0].measures {
3681            measure.voices[0] = vec![
3682                crate::Note::new(crate::Pitch::new(crate::Step::C, 4), crate::Duration::Half),
3683                crate::Note::new(crate::Pitch::new(crate::Step::D, 4), crate::Duration::Half),
3684            ];
3685        }
3686        score.parts[0].staves[0].measures[0].tempo_ramp_to = Some(60);
3687        let events = to_playback_events(&score, &PlaybackOptions::default());
3688        assert_eq!(events.len(), 4);
3689        let expected_measure_secs = 4.0 * 60.0 / (60.0 - 120.0) * (60.0f64 / 120.0).ln();
3690        assert!((events[2].time_secs - expected_measure_secs).abs() < 1e-9);
3691        assert!((events[0].duration_secs - 1.1507282898).abs() < 1e-6);
3692        assert!((events[2].duration_secs - 2.0).abs() < 1e-9);
3693    }
3694
3695    #[test]
3696    fn breath_and_caesura_expose_deterministic_post_note_pause() {
3697        let mut score = Score::new("pause", 120, 4, 4, 0, 1);
3698        let mut breath = crate::Note::new(
3699            crate::Pitch::new(crate::Step::C, 4),
3700            crate::Duration::Quarter,
3701        );
3702        breath.articulations.push(Articulation::BreathMark);
3703        let mut caesura = crate::Note::new(
3704            crate::Pitch::new(crate::Step::D, 4),
3705            crate::Duration::Quarter,
3706        );
3707        caesura
3708            .articulations
3709            .extend([Articulation::BreathMark, Articulation::Caesura]);
3710        score.parts[0].staves[0].measures[0].voices[0] = vec![breath, caesura];
3711
3712        let events = to_playback_events(&score, &PlaybackOptions::default());
3713        assert_eq!(events.len(), 2);
3714        assert_eq!(events[0].post_note_pause_beats, 0.25);
3715        assert_eq!(events[1].post_note_pause_beats, 0.5);
3716        assert_eq!(
3717            events[1].articulations,
3718            vec![Articulation::BreathMark, Articulation::Caesura]
3719        );
3720    }
3721
3722    #[test]
3723    fn measure_instrument_change_resolves_on_playback_events() {
3724        let mut score = Score::new("instrument", 120, 4, 4, 0, 2);
3725        let mut base = crate::InstrumentDefinition::new("piano", "Piano");
3726        base.midi_channel = 1;
3727        base.midi_program = 0;
3728        score.parts[0].instrument = Some(base);
3729        let mut change = crate::InstrumentDefinition::new("flute", "Flute");
3730        change.midi_channel = 2;
3731        change.midi_program = 73;
3732        change.transpose_semitones = -2;
3733        score.parts[0].staves[0].measures[1].instrument_change = Some(change);
3734        for measure in &mut score.parts[0].staves[0].measures {
3735            measure.voices[0] = vec![crate::Note::new(
3736                crate::Pitch::new(crate::Step::C, 4),
3737                crate::Duration::Whole,
3738            )];
3739        }
3740
3741        let events = to_playback_events(&score, &PlaybackOptions::default());
3742        assert_eq!(events.len(), 2);
3743        assert_eq!(
3744            (
3745                events[0].channel,
3746                events[0].program,
3747                events[0].instrument_id.as_deref()
3748            ),
3749            (1, 0, Some("piano"))
3750        );
3751        assert_eq!(
3752            (
3753                events[1].channel,
3754                events[1].program,
3755                events[1].instrument_id.as_deref()
3756            ),
3757            (2, 73, Some("flute"))
3758        );
3759        assert_eq!(events[0].pitch_midi, 60);
3760        assert_eq!(events[1].pitch_midi, 58);
3761    }
3762
3763    #[test]
3764    fn generic_playback_event_preserves_authored_guitar_technique() {
3765        let mut score = Score::new("technique", 120, 4, 4, 0, 1);
3766        let mut note = Note::new(Pitch::new(Step::E, 4), Duration::Quarter);
3767        note.guitar_technique = Some(GuitarTechnique::HammerOn);
3768        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
3769
3770        let event = to_playback_events(&score, &PlaybackOptions::default())
3771            .into_iter()
3772            .next()
3773            .expect("one note event");
3774        assert_eq!(event.guitar_technique, Some(GuitarTechnique::HammerOn));
3775    }
3776
3777    #[test]
3778    fn playback_timing_comparison_reports_tolerance_and_identity() {
3779        let expected = [comparison_event(1.0, 0.5)];
3780        let actual = [comparison_event(1.004, 0.503)];
3781        let report = compare_playback_timing(
3782            &expected,
3783            &actual,
3784            &PlaybackTimingTolerance {
3785                start_secs: 0.005,
3786                duration_secs: 0.005,
3787            },
3788        )
3789        .expect("comparison");
3790        assert!(report.within_tolerance);
3791        assert_eq!(report.matched_events, 1);
3792        assert_eq!(
3793            report.contract_version,
3794            PLAYBACK_COMPARISON_CONTRACT_VERSION
3795        );
3796
3797        let mut typed_only = comparison_event(1.004, 0.503);
3798        typed_only.address = None;
3799        let report = compare_playback_timing(
3800            &expected,
3801            &[typed_only],
3802            &PlaybackTimingTolerance::default(),
3803        )
3804        .expect("typed source comparison");
3805        assert_eq!(report.matched_events, 1);
3806
3807        let actual = [comparison_event(1.02, 0.6)];
3808        let report =
3809            compare_playback_timing(&expected, &actual, &PlaybackTimingTolerance::default())
3810                .expect("comparison");
3811        assert!(!report.within_tolerance);
3812        assert!(
3813            report
3814                .mismatches
3815                .iter()
3816                .any(|m| matches!(m, PlaybackTimingMismatch::StartTime { index: 0, .. }))
3817        );
3818        assert!(
3819            report
3820                .mismatches
3821                .iter()
3822                .any(|m| matches!(m, PlaybackTimingMismatch::Duration { index: 0, .. }))
3823        );
3824    }
3825
3826    #[test]
3827    fn playback_timing_comparison_rejects_instrument_route_mismatch() {
3828        let expected = comparison_event(0.0, 0.5);
3829        let mut actual = expected.clone();
3830        actual.program = 73;
3831        assert!(
3832            compare_playback_timing(&[expected], &[actual], &PlaybackTimingTolerance::default(),)
3833                .expect("comparison")
3834                .mismatches
3835                .iter()
3836                .any(|mismatch| matches!(
3837                    mismatch,
3838                    PlaybackTimingMismatch::EventIdentity { index: 0 }
3839                ))
3840        );
3841    }
3842
3843    #[test]
3844    fn playback_timing_comparison_rejects_invalid_tolerance() {
3845        let error = compare_playback_timing(
3846            &[],
3847            &[],
3848            &PlaybackTimingTolerance {
3849                start_secs: -0.1,
3850                duration_secs: 0.0,
3851            },
3852        );
3853        assert!(matches!(
3854            error,
3855            Err(crate::Error::InvalidPlaybackComparison)
3856        ));
3857    }
3858
3859    #[test]
3860    fn tablature_performance_projection_keeps_position_and_reports_pitch_error() {
3861        let mut score = Score::new("Tab", 120, 4, 4, 0, 1);
3862        score.parts[0].staves[0].tablature = Some(super::super::notation::TablatureConfig {
3863            lines: 6,
3864            tuning_midi: vec![40, 45, 50, 55, 59, 64],
3865            capo: 0,
3866        });
3867        let notes = &mut score.parts[0].staves[0].measures[0].voices[0];
3868        *notes = vec![crate::Note::new(
3869            crate::Pitch::new(crate::Step::C, 4),
3870            crate::Duration::Quarter,
3871        )];
3872        notes[0].tab_position = Some(super::super::notation::TabPosition {
3873            string: 1,
3874            fret: 20,
3875        });
3876        notes[0].guitar_technique = Some(super::super::notation::GuitarTechnique::Bend);
3877        notes[0].guitar_bend_alter_cents = Some(150);
3878        notes[0].guitar_bend_curve = vec![
3879            super::super::score::GuitarBendPoint {
3880                position_per_mille: 0,
3881                alter_cents: 0,
3882            },
3883            super::super::score::GuitarBendPoint {
3884                position_per_mille: 500,
3885                alter_cents: 150,
3886            },
3887            super::super::score::GuitarBendPoint {
3888                position_per_mille: 1_000,
3889                alter_cents: 0,
3890            },
3891        ];
3892        let report = project_tablature_performance(&score, &PlaybackOptions::default())
3893            .expect("tablature projection");
3894        assert_eq!(report.events.len(), 1);
3895        assert_eq!(report.events[0].string, 1);
3896        assert_eq!(report.events[0].fret, 20);
3897        assert_eq!(
3898            report.events[0].technique,
3899            Some(super::super::notation::GuitarTechnique::Bend)
3900        );
3901        assert_eq!(report.events[0].bend_alter_cents, Some(150));
3902        assert_eq!(report.events[0].bend_curve.len(), 3);
3903        assert_eq!(report.events[0].bend_curve[1].position_per_mille, 500);
3904        assert_eq!(report.events[0].bend_curve[1].alter_cents, 150);
3905        assert_eq!(
3906            report.events[0].playback.pitch_bend_curve,
3907            report.events[0].bend_curve
3908        );
3909        assert!(report.diagnostics.is_empty());
3910
3911        score.parts[0].staves[0].measures[0].voices[0][0].tab_position =
3912            Some(super::super::notation::TabPosition {
3913                string: 1,
3914                fret: 19,
3915            });
3916        let report = project_tablature_performance(&score, &PlaybackOptions::default())
3917            .expect("tablature projection");
3918        assert_eq!(report.events[0].pitch_error_cents, 100);
3919        assert!(matches!(
3920            report.diagnostics[0],
3921            TablaturePerformanceDiagnostic::PitchMismatch {
3922                error_cents: 100,
3923                ..
3924            }
3925        ));
3926    }
3927
3928    #[test]
3929    fn tablature_performance_projection_does_not_invent_missing_positions() {
3930        let mut score = Score::new("Tab", 120, 4, 4, 0, 1);
3931        score.parts[0].staves[0].tablature = Some(super::super::notation::TablatureConfig {
3932            lines: 6,
3933            tuning_midi: vec![40, 45, 50, 55, 59, 64],
3934            capo: 0,
3935        });
3936        score.parts[0].staves[0].measures[0].voices[0].push(crate::Note::new(
3937            crate::Pitch::new(crate::Step::C, 4),
3938            crate::Duration::Quarter,
3939        ));
3940        let report = project_tablature_performance(&score, &PlaybackOptions::default())
3941            .expect("tablature projection");
3942        assert!(report.events.is_empty());
3943        assert!(matches!(
3944            report.diagnostics[0],
3945            TablaturePerformanceDiagnostic::MissingPosition { .. }
3946        ));
3947    }
3948
3949    #[test]
3950    fn tablature_performance_event_accepts_legacy_json_without_technique() {
3951        let mut score = Score::new("Tab", 120, 4, 4, 0, 1);
3952        score.parts[0].staves[0].tablature = Some(super::super::notation::TablatureConfig {
3953            lines: 6,
3954            tuning_midi: vec![40, 45, 50, 55, 59, 64],
3955            capo: 0,
3956        });
3957        let mut note = crate::Note::new(
3958            crate::Pitch::new(crate::Step::C, 4),
3959            crate::Duration::Quarter,
3960        );
3961        note.tab_position = Some(super::super::notation::TabPosition {
3962            string: 1,
3963            fret: 20,
3964        });
3965        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
3966        let report = project_tablature_performance(&score, &PlaybackOptions::default())
3967            .expect("tablature projection");
3968        let mut legacy = serde_json::to_value(&report.events[0]).expect("event JSON");
3969        legacy
3970            .as_object_mut()
3971            .expect("event object")
3972            .remove("technique");
3973        let restored: TablaturePerformanceEvent =
3974            serde_json::from_value(legacy).expect("legacy event JSON");
3975        assert_eq!(restored.technique, None);
3976    }
3977
3978    #[test]
3979    fn tablature_round_trip_report_preserves_authored_positions() {
3980        let mut score = Score::new("Tab", 120, 4, 4, 0, 1);
3981        score.parts[0].staves[0].tablature = Some(super::super::notation::TablatureConfig {
3982            lines: 6,
3983            tuning_midi: vec![40, 45, 50, 55, 59, 64],
3984            capo: 2,
3985        });
3986        let mut note = crate::Note::new(
3987            crate::Pitch::new(crate::Step::C, 4),
3988            crate::Duration::Quarter,
3989        );
3990        note.tab_positions = vec![crate::TabPosition { string: 5, fret: 1 }];
3991        score.parts[0].staves[0].measures[0].voices[0] = vec![note];
3992        let report = tablature_round_trip_report(&score).expect("tab round-trip report");
3993        assert!(report.equivalent);
3994        assert_eq!(report.checked_notes, 1);
3995        assert_eq!(report.positioned_notes, 1);
3996        assert!(report.diagnostics.is_empty());
3997    }
3998
3999    #[test]
4000    fn tablature_performance_uses_measure_local_tuning_change() {
4001        let mut score = Score::new("Local tuning", 120, 4, 4, 0, 2);
4002        let staff = &mut score.parts[0].staves[0];
4003        staff.tablature = Some(super::super::notation::TablatureConfig {
4004            lines: 6,
4005            tuning_midi: vec![40, 45, 50, 55, 59, 64],
4006            capo: 0,
4007        });
4008        staff.measures[1].tablature_change = Some(super::super::notation::TablatureConfig {
4009            lines: 6,
4010            tuning_midi: vec![38, 45, 50, 55, 59, 64],
4011            capo: 0,
4012        });
4013        let mut note = Note::new(Pitch::new(Step::C, 3), Duration::Quarter);
4014        note.tab_position = Some(TabPosition {
4015            string: 1,
4016            fret: 10,
4017        });
4018        staff.measures[1].voices[0] = vec![note];
4019
4020        let report = project_tablature_performance(&score, &PlaybackOptions::default())
4021            .expect("tablature projection");
4022        assert_eq!(report.events.len(), 1);
4023        assert_eq!(report.events[0].expected_pitch_midi_cents, 4_800);
4024        assert!(!report.diagnostics.iter().any(|diagnostic| matches!(
4025            diagnostic,
4026            TablaturePerformanceDiagnostic::PitchMismatch { .. }
4027        )));
4028    }
4029}