spatial_test.mbt

// Copyright 2026 International Digital Economy Academy
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

///|
test "rodio::source::spatial_source_balance" {
  let src = SamplesBuffer::new(1, 44_100, [1.0, 1.0])
  let spatial = SpatialSource::new(src, [-1.0, 0.0, 0.0], [-1.0, 0.0, 0.0], [
    1.0, 0.0, 0.0,
  ])

  @debug.assert_eq(spatial.channels(), 2)
  @debug.assert_eq(spatial.sample_rate(), 44_100)

  let l0 = spatial.next().unwrap()
  let r0 = spatial.next().unwrap()
  assert_true(l0 > r0)
}

///|
test "rodio::source::spatial_sink_append" {
  let (mix_tx, mix_rx) = mixer(2, 44_100)
  let sink = SpatialSink::connect_new(
    mix_tx,
    [0.0, 0.0, 0.0],
    [-1.0, 0.0, 0.0],
    [1.0, 0.0, 0.0],
  )

  sink.append(SamplesBuffer::new(1, 44_100, [1.0, 1.0]))
  @debug.assert_eq(sink.len(), 1)
  assert_true(!sink.empty())

  let a = mix_rx.next().unwrap()
  let b = mix_rx.next().unwrap()
  assert_true(a > 0.0)
  assert_true(b > 0.0)
}

///|
test "rodio::source::spatial_sink_seek_and_pos" {
  let (mix_tx, mix_rx) = mixer(2, 1)
  let sink = SpatialSink::connect_new(
    mix_tx,
    [0.0, 0.0, 0.0],
    [-1.0, 0.0, 0.0],
    [1.0, 0.0, 0.0],
  )

  sink.append(SamplesBuffer::new(1, 1, [1.0, 2.0]))
  let l0 = mix_rx.next().unwrap()
  let r0 = mix_rx.next().unwrap()
  sink.try_seek(@moon_cpal.Duration::from_secs((0 : UInt64)))
  @debug.assert_eq(sink.get_pos().secs, (0 : UInt64))
  let l1 = mix_rx.next().unwrap()
  let r1 = mix_rx.next().unwrap()
  @debug.assert_eq(l1, l0)
  @debug.assert_eq(r1, r0)
}

///|
test "rodio::spatial_player::compat_wrapper_controls" {
  let (mix_tx, mix_rx) = mixer(2, 44_100)
  let player = SpatialPlayer::connect_new(
    mix_tx,
    [0.0, 0.0, 0.0],
    [-1.0, 0.0, 0.0],
    [1.0, 0.0, 0.0],
  )
  player.append(SamplesBuffer::new(1, 44_100, [1.0, 1.0]))
  @debug.assert_eq(player.len(), 1)
  assert_true(!player.empty())
  player.set_volume(0.5)
  @debug.assert_eq(player.volume(), 0.5)
  player.pause()
  assert_true(player.is_paused())
  player.play()
  assert_true(!player.is_paused())
  ignore(mix_rx.next())
  ignore(mix_rx.next())
}