Grzegorz/mpvipc-async
Grzegorz/mpvipc-async
1
0
Fork 0
Code Issues 7 Pull Requests Actions Releases 1 Activity

test/util: allow tests to run mpv non-headless for debugging

Browse Source
This commit is contained in:
Oystein Kristoffer Tveit 2024-12-14 14:53:55 +01:00
parent 44d7e15fb1
commit 77d4e80eec
Signed by: oysteikt
GPG Key ID: 9F2F7D8250F35146
3 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration_tests/event_property_parser.rs
View File

@ -115,7 +115,7 @@ async fn graceful_shutdown(
#[test(tokio::test)] #[test(tokio::test)]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_highlevel_event_pause() -> Result<(), MpvError> { async fn test_highlevel_event_pause() -> Result<(), MpvError> {
let (proc, mpv) = spawn_headless_mpv().await?; let (proc, mpv) = spawn_mpv(true).await?;
mpv.observe_property(MPV_CHANNEL_ID, "pause").await?; mpv.observe_property(MPV_CHANNEL_ID, "pause").await?;
@ -144,7 +144,7 @@ async fn test_highlevel_event_pause() -> Result<(), MpvError> {
#[test(tokio::test)] #[test(tokio::test)]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_highlevel_event_volume() -> Result<(), MpvError> { async fn test_highlevel_event_volume() -> Result<(), MpvError> {
let (proc, mpv) = spawn_headless_mpv().await?; let (proc, mpv) = spawn_mpv(true).await?;
mpv.observe_property(1337, "volume").await?; mpv.observe_property(1337, "volume").await?;
let events = mpv.get_event_stream().await; let events = mpv.get_event_stream().await;
@ -174,7 +174,7 @@ async fn test_highlevel_event_volume() -> Result<(), MpvError> {
#[test(tokio::test)] #[test(tokio::test)]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_highlevel_event_mute() -> Result<(), MpvError> { async fn test_highlevel_event_mute() -> Result<(), MpvError> {
let (proc, mpv) = spawn_headless_mpv().await?; let (proc, mpv) = spawn_mpv(true).await?;
mpv.observe_property(1337, "mute").await?; mpv.observe_property(1337, "mute").await?;
let events = mpv.get_event_stream().await; let events = mpv.get_event_stream().await;
@ -202,7 +202,7 @@ async fn test_highlevel_event_mute() -> Result<(), MpvError> {
#[test(tokio::test)] #[test(tokio::test)]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_highlevel_event_duration() -> Result<(), MpvError> { async fn test_highlevel_event_duration() -> Result<(), MpvError> {
let (proc, mpv) = spawn_headless_mpv().await?; let (proc, mpv) = spawn_mpv(true).await?;
mpv.observe_property(1337, "duration").await?; mpv.observe_property(1337, "duration").await?;

8
tests/integration_tests/misc.rs
View File

@ -5,7 +5,7 @@ use super::*;
#[tokio::test] #[tokio::test]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_get_mpv_version() -> Result<(), MpvError> { async fn test_get_mpv_version() -> Result<(), MpvError> {
let (mut proc, mpv) = spawn_headless_mpv().await.unwrap(); let (mut proc, mpv) = spawn_mpv(true).await.unwrap();
let version: String = mpv.get_property("mpv-version").await?.unwrap(); let version: String = mpv.get_property("mpv-version").await?.unwrap();
assert!(version.starts_with("mpv")); assert!(version.starts_with("mpv"));
@ -18,7 +18,7 @@ async fn test_get_mpv_version() -> Result<(), MpvError> {
#[tokio::test] #[tokio::test]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_set_property() -> Result<(), MpvError> { async fn test_set_property() -> Result<(), MpvError> {
let (mut proc, mpv) = spawn_headless_mpv().await.unwrap(); let (mut proc, mpv) = spawn_mpv(true).await.unwrap();
mpv.set_property("pause", true).await.unwrap(); mpv.set_property("pause", true).await.unwrap();
let paused: bool = mpv.get_property("pause").await?.unwrap(); let paused: bool = mpv.get_property("pause").await?.unwrap();
assert!(paused); assert!(paused);
@ -32,7 +32,7 @@ async fn test_set_property() -> Result<(), MpvError> {
#[tokio::test] #[tokio::test]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_get_unavailable_property() -> Result<(), MpvError> { async fn test_get_unavailable_property() -> Result<(), MpvError> {
let (mut proc, mpv) = spawn_headless_mpv().await.unwrap(); let (mut proc, mpv) = spawn_mpv(true).await.unwrap();
let time_pos = mpv.get_property::<f64>("time-pos").await; let time_pos = mpv.get_property::<f64>("time-pos").await;
assert_eq!(time_pos, Ok(None)); assert_eq!(time_pos, Ok(None));
@ -45,7 +45,7 @@ async fn test_get_unavailable_property() -> Result<(), MpvError> {
#[tokio::test] #[tokio::test]
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
async fn test_get_nonexistent_property() -> Result<(), MpvError> { async fn test_get_nonexistent_property() -> Result<(), MpvError> {
let (mut proc, mpv) = spawn_headless_mpv().await.unwrap(); let (mut proc, mpv) = spawn_mpv(true).await.unwrap();
let nonexistent = mpv.get_property::<f64>("nonexistent").await; let nonexistent = mpv.get_property::<f64>("nonexistent").await;
match nonexistent { match nonexistent {

9
tests/integration_tests/util.rs
View File

@ -34,7 +34,7 @@ pub fn get_test_asset(file_name: &str) -> String {
} }
#[cfg(target_family = "unix")] #[cfg(target_family = "unix")]
pub async fn spawn_headless_mpv() -> Result<(Child, Mpv), MpvError> { pub async fn spawn_mpv(headless: bool) -> Result<(Child, Mpv), MpvError> {
let socket_path_str = format!("/tmp/mpv-ipc-{}", uuid::Uuid::new_v4()); let socket_path_str = format!("/tmp/mpv-ipc-{}", uuid::Uuid::new_v4());
let socket_path = Path::new(&socket_path_str); let socket_path = Path::new(&socket_path_str);
@ -42,8 +42,11 @@ pub async fn spawn_headless_mpv() -> Result<(Child, Mpv), MpvError> {
let process_handle = Command::new("mpv") let process_handle = Command::new("mpv")
.arg("--no-config") .arg("--no-config")
.arg("--idle") .arg("--idle")
.arg("--no-video") .args(if headless {
.arg("--no-audio") vec!["--no-video", "--no-audio"]
} else {
vec![]
})
.arg(format!( .arg(format!(
"--input-ipc-server={}", "--input-ipc-server={}",
&socket_path.to_str().unwrap() &socket_path.to_str().unwrap()