ivabus/lonelyradio
1
0
Fork 0
mirror of https://github.com/ivabus/lonelyradio synced 2024-11-09 18:15:17 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Encode PCM the same way as any other encoder

Browse source 
Signed-off-by: Ivan Bushchik <ivabus@ivabus.dev>
This commit is contained in:
Ivan Bushchik 2024-08-27 12:38:50 +03:00
parent dfb86522fb
commit 3804653512
No known key found for this signature in database
GPG key ID: 2F16FBF3262E090C
2 changed files with 7 additions and 35 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lonelyradio_types/src/lib.rs
View file

@ -103,7 +103,7 @@ pub enum Encoder {
#[derive(Deserialize, Serialize, Clone, Debug, PartialEq)]
pub struct FragmentMetadata {
// In bytes or samples, depends on encoder: Pcm* - samples, any compressed - bytes
// In bytes
#[serde(rename = "le")]
pub length: u64,

40
src/main.rs
View file

@ -102,46 +102,18 @@ async fn stream_track(
let mut _samples = _samples.concat();
match md.encoder {
Encoder::Pcm16 => {
let _md = PlayMessage::F(FragmentMetadata {
length: _samples.len() as u64 * 2,
magic_cookie: None,
});
if s.write_all(rmp_serde::to_vec(&_md).unwrap().as_slice()).is_err() {
return true;
}
if s.write_all(
&encode(Encoder::Pcm16, _samples, md.sample_rate, md.channels).unwrap().0,
)
.is_err()
{
return true;
}
}
Encoder::PcmFloat => {
let _md = PlayMessage::F(FragmentMetadata {
length: _samples.len() as u64 * 4,
magic_cookie: None,
});
if s.write_all(rmp_serde::to_vec(&_md).unwrap().as_slice()).is_err() {
return true;
}
if s.write_all(
&encode(Encoder::PcmFloat, _samples, md.sample_rate, md.channels).unwrap().0,
)
.is_err()
{
return true;
}
}
Encoder::Flac | Encoder::Alac | Encoder::Vorbis => {
Encoder::Pcm16
| Encoder::PcmFloat
| Encoder::Flac
| Encoder::Alac
| Encoder::Vorbis => {
let (encoded, magic_cookie) =
encode(md.encoder, _samples, md.sample_rate, md.channels).unwrap();
let _md = PlayMessage::F(FragmentMetadata {
length: encoded.as_slice().len() as u64,
magic_cookie,
});
if s.write_all(rmp_serde::to_vec(&_md).unwrap().as_slice()).is_err() {
if s.write_all(rmp_serde::to_vec_named(&_md).unwrap().as_slice()).is_err() {
return true;
}
if s.write_all(encoded.as_slice()).is_err() {