Move decoder to playback crate

Johannesd3 · Johannesd3 · commit 555274b5afee · 2021-05-11T20:36:53.000+02:00
diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml
@@ -99,7 +99,6 @@ jobs:
       - run: cargo hack  --workspace --remove-dev-deps
       - run: cargo build -p librespot-core --no-default-features
       - run: cargo build -p librespot-core
-      - run: cargo hack build --each-feature -p librespot-audio
       - run: cargo build -p librespot-connect
       - run: cargo build -p librespot-connect --no-default-features --features with-dns-sd
       - run: cargo hack build --each-feature
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Removed
+
+* [librespot-audio] Removed `VorbisDecoder`, `VorbisError`, `AudioPacket`, `PassthroughDecoder`, `PassthroughError`, `AudioError`, `AudioDecoder` and the `convert` module from `librespot_audio`. The underlying crates `vorbis`, `librespot-tremor`, `lewton` and `ogg` should be used directly.
+
 ## [0.2.0] - 2021-05-04
 
 ## [0.1.6] - 2021-02-22
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -69,8 +69,8 @@ rodiojack-backend = ["librespot-playback/rodiojack-backend"]
 sdl-backend = ["librespot-playback/sdl-backend"]
 gstreamer-backend = ["librespot-playback/gstreamer-backend"]
 
-with-tremor = ["librespot-audio/with-tremor"]
-with-vorbis = ["librespot-audio/with-vorbis"]
+with-tremor = ["librespot-playback/with-tremor"]
+with-vorbis = ["librespot-playback/with-vorbis"]
 
 with-dns-sd = ["librespot-connect/with-dns-sd"]
 
diff --git a/audio/Cargo.toml b/audio/Cargo.toml
@@ -14,18 +14,7 @@ version = "0.2.0"
 aes-ctr = "0.6"
 byteorder = "1.4"
 bytes = "1.0"
-cfg-if = "1"
-lewton = "0.10"
 log = "0.4"
 futures-util = { version = "0.3", default_features = false }
-ogg = "0.8"
 tempfile = "3.1"
 tokio = { version = "1", features = ["sync", "macros"] }
-zerocopy = "0.3"
-
-librespot-tremor = { version = "0.2", optional = true }
-vorbis = { version ="0.0", optional = true }
-
-[features]
-with-tremor = ["librespot-tremor"]
-with-vorbis = ["vorbis"]
diff --git a/audio/src/lib.rs b/audio/src/lib.rs
@@ -3,25 +3,9 @@
 #[macro_use]
 extern crate log;
 
-pub mod convert;
 mod decrypt;
 mod fetch;
 
-use cfg_if::cfg_if;
-
-cfg_if! {
-    if #[cfg(any(feature = "with-tremor", feature = "with-vorbis"))] {
-        mod libvorbis_decoder;
-        pub use crate::libvorbis_decoder::{VorbisDecoder, VorbisError};
-    } else {
-        mod lewton_decoder;
-        pub use lewton_decoder::{VorbisDecoder, VorbisError};
-    }
-}
-
-mod passthrough_decoder;
-pub use passthrough_decoder::{PassthroughDecoder, PassthroughError};
-
 mod range_set;
 
 pub use decrypt::AudioDecrypt;
@@ -30,64 +14,3 @@ pub use fetch::{
     READ_AHEAD_BEFORE_PLAYBACK_ROUNDTRIPS, READ_AHEAD_BEFORE_PLAYBACK_SECONDS,
     READ_AHEAD_DURING_PLAYBACK_ROUNDTRIPS, READ_AHEAD_DURING_PLAYBACK_SECONDS,
 };
-use std::fmt;
-
-pub enum AudioPacket {
-    Samples(Vec<f32>),
-    OggData(Vec<u8>),
-}
-
-impl AudioPacket {
-    pub fn samples(&self) -> &[f32] {
-        match self {
-            AudioPacket::Samples(s) => s,
-            AudioPacket::OggData(_) => panic!("can't return OggData on samples"),
-        }
-    }
-
-    pub fn oggdata(&self) -> &[u8] {
-        match self {
-            AudioPacket::Samples(_) => panic!("can't return samples on OggData"),
-            AudioPacket::OggData(d) => d,
-        }
-    }
-
-    pub fn is_empty(&self) -> bool {
-        match self {
-            AudioPacket::Samples(s) => s.is_empty(),
-            AudioPacket::OggData(d) => d.is_empty(),
-        }
-    }
-}
-
-#[derive(Debug)]
-pub enum AudioError {
-    PassthroughError(PassthroughError),
-    VorbisError(VorbisError),
-}
-
-impl fmt::Display for AudioError {
-    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
-        match self {
-            AudioError::PassthroughError(err) => write!(f, "PassthroughError({})", err),
-            AudioError::VorbisError(err) => write!(f, "VorbisError({})", err),
-        }
-    }
-}
-
-impl From<VorbisError> for AudioError {
-    fn from(err: VorbisError) -> AudioError {
-        AudioError::VorbisError(err)
-    }
-}
-
-impl From<PassthroughError> for AudioError {
-    fn from(err: PassthroughError) -> AudioError {
-        AudioError::PassthroughError(err)
-    }
-}
-
-pub trait AudioDecoder {
-    fn seek(&mut self, ms: i64) -> Result<(), AudioError>;
-    fn next_packet(&mut self) -> Result<Option<AudioPacket>, AudioError>;
-}
diff --git a/playback/Cargo.toml b/playback/Cargo.toml
@@ -18,12 +18,14 @@ path = "../metadata"
 version = "0.2.0"
 
 [dependencies]
+cfg-if = "1.0"
 futures-executor = "0.3"
 futures-util = { version = "0.3", default_features = false, features = ["alloc"] }
 log = "0.4"
 byteorder = "1.4"
 shell-words = "1.0.0"
 tokio = { version = "1", features = ["sync"] }
+zerocopy        = { version = "0.3" }
 
 alsa            = { version = "0.5", optional = true }
 portaudio-rs    = { version = "0.3", optional = true }
@@ -34,13 +36,18 @@ sdl2            = { version = "0.34.3", optional = true }
 gstreamer       = { version = "0.16", optional = true }
 gstreamer-app   = { version = "0.16", optional = true }
 glib            = { version = "0.10", optional = true }
-zerocopy        = { version = "0.3" }
 
 # Rodio dependencies
 rodio           = { version = "0.13", optional = true, default-features = false }
 cpal            = { version = "0.13", optional = true }
 thiserror       = { version = "1", optional = true }
 
+# Decoders
+lewton = "0.10"  # Currently not optional because of limitations of cargo features
+librespot-tremor = { version = "0.2", optional = true }
+ogg = "0.8"
+vorbis = { version ="0.0", optional = true }
+
 [features]
 alsa-backend = ["alsa"]
 portaudio-backend = ["portaudio-rs"]
@@ -50,3 +57,6 @@ rodio-backend = ["rodio", "cpal", "thiserror"]
 rodiojack-backend = ["rodio", "cpal/jack", "thiserror"]
 sdl-backend = ["sdl2"]
 gstreamer-backend = ["gstreamer", "gstreamer-app", "glib"]
+
+with-tremor = ["librespot-tremor"]
+with-vorbis = ["vorbis"]
diff --git a/playback/src/audio_backend/alsa.rs b/playback/src/audio_backend/alsa.rs
@@ -1,6 +1,6 @@
 use super::{Open, Sink, SinkAsBytes};
-use crate::audio::AudioPacket;
 use crate::config::AudioFormat;
+use crate::decoder::AudioPacket;
 use crate::player::{NUM_CHANNELS, SAMPLES_PER_SECOND, SAMPLE_RATE};
 use alsa::device_name::HintIter;
 use alsa::pcm::{Access, Format, Frames, HwParams, PCM};
diff --git a/playback/src/audio_backend/gstreamer.rs b/playback/src/audio_backend/gstreamer.rs
@@ -1,6 +1,6 @@
 use super::{Open, Sink, SinkAsBytes};
-use crate::audio::AudioPacket;
 use crate::config::AudioFormat;
+use crate::decoder::AudioPacket;
 use crate::player::{NUM_CHANNELS, SAMPLE_RATE};
 
 use gstreamer as gst;
diff --git a/playback/src/audio_backend/jackaudio.rs b/playback/src/audio_backend/jackaudio.rs
@@ -1,6 +1,6 @@
 use super::{Open, Sink};
-use crate::audio::AudioPacket;
 use crate::config::AudioFormat;
+use crate::decoder::AudioPacket;
 use crate::player::NUM_CHANNELS;
 use jack::{
     AsyncClient, AudioOut, Client, ClientOptions, Control, Port, ProcessHandler, ProcessScope,
diff --git a/playback/src/audio_backend/mod.rs b/playback/src/audio_backend/mod.rs
@@ -1,5 +1,5 @@
-use crate::audio::AudioPacket;
 use crate::config::AudioFormat;
+use crate::decoder::AudioPacket;
 use std::io;
 
 pub trait Open {
@@ -26,7 +26,7 @@ fn mk_sink<S: Sink + Open + 'static>(device: Option<String>, format: AudioFormat
 macro_rules! sink_as_bytes {
     () => {
         fn write(&mut self, packet: &AudioPacket) -> io::Result<()> {
-            use crate::audio::convert::{self, i24};
+            use crate::convert::{self, i24};
             use zerocopy::AsBytes;
             match packet {
                 AudioPacket::Samples(samples) => match self.format {
diff --git a/playback/src/audio_backend/pipe.rs b/playback/src/audio_backend/pipe.rs
@@ -1,6 +1,6 @@
 use super::{Open, Sink, SinkAsBytes};
-use crate::audio::AudioPacket;
 use crate::config::AudioFormat;
+use crate::decoder::AudioPacket;
 use std::fs::OpenOptions;
 use std::io::{self, Write};
 
diff --git a/playback/src/audio_backend/portaudio.rs b/playback/src/audio_backend/portaudio.rs
@@ -1,6 +1,7 @@
 use super::{Open, Sink};
-use crate::audio::{convert, AudioPacket};
 use crate::config::AudioFormat;
+use crate::convert;
+use crate::decoder::AudioPacket;
 use crate::player::{NUM_CHANNELS, SAMPLE_RATE};
 use portaudio_rs::device::{get_default_output_index, DeviceIndex, DeviceInfo};
 use portaudio_rs::stream::*;
diff --git a/playback/src/audio_backend/pulseaudio.rs b/playback/src/audio_backend/pulseaudio.rs
@@ -1,6 +1,6 @@
 use super::{Open, Sink, SinkAsBytes};
-use crate::audio::AudioPacket;
 use crate::config::AudioFormat;
+use crate::decoder::AudioPacket;
 use crate::player::{NUM_CHANNELS, SAMPLE_RATE};
 use libpulse_binding::{self as pulse, stream::Direction};
 use libpulse_simple_binding::Simple;
diff --git a/playback/src/audio_backend/rodio.rs b/playback/src/audio_backend/rodio.rs
@@ -5,8 +5,9 @@ use cpal::traits::{DeviceTrait, HostTrait};
 use thiserror::Error;
 
 use super::Sink;
-use crate::audio::{convert, AudioPacket};
 use crate::config::AudioFormat;
+use crate::convert;
+use crate::decoder::AudioPacket;
 use crate::player::{NUM_CHANNELS, SAMPLE_RATE};
 
 #[cfg(all(
diff --git a/playback/src/audio_backend/sdl.rs b/playback/src/audio_backend/sdl.rs
@@ -1,6 +1,7 @@
 use super::{Open, Sink};
-use crate::audio::{convert, AudioPacket};
 use crate::config::AudioFormat;
+use crate::convert;
+use crate::decoder::AudioPacket;
 use crate::player::{NUM_CHANNELS, SAMPLE_RATE};
 use sdl2::audio::{AudioQueue, AudioSpecDesired};
 use std::{io, thread, time};
diff --git a/playback/src/audio_backend/subprocess.rs b/playback/src/audio_backend/subprocess.rs
@@ -1,6 +1,6 @@
 use super::{Open, Sink, SinkAsBytes};
-use crate::audio::AudioPacket;
 use crate::config::AudioFormat;
+use crate::decoder::AudioPacket;
 use shell_words::split;
 
 use std::io::{self, Write};
diff --git a/playback/src/config.rs b/playback/src/config.rs
@@ -1,4 +1,4 @@
-use crate::audio::convert::i24;
+use crate::convert::i24;
 use std::convert::TryFrom;
 use std::mem;
 use std::str::FromStr;
diff --git a/playback/src/convert.rs b/playback/src/convert.rs
diff --git a/playback/src/decoder/lewton_decoder.rs b/playback/src/decoder/lewton_decoder.rs
diff --git a/playback/src/decoder/libvorbis_decoder.rs b/playback/src/decoder/libvorbis_decoder.rs
diff --git a/playback/src/decoder/mod.rs b/playback/src/decoder/mod.rs
diff --git a/playback/src/decoder/passthrough_decoder.rs b/playback/src/decoder/passthrough_decoder.rs
diff --git a/playback/src/lib.rs b/playback/src/lib.rs
diff --git a/playback/src/player.rs b/playback/src/player.rs
