Nickiel/Sousa
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

feat: Added support for song-switching

Browse source
This commit is contained in:
Nickiel12 2022-12-23 15:06:31 -08:00
parent 156afe9545
commit 8ba2983142
1 changed files with 70 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

72
src/main.rs
View file

@ -89,7 +89,7 @@ fn main() {
// Get a output stream handle to the default physical sound device // Get a output stream handle to the default physical sound device
let (_stream, stream_handle) = OutputStream::try_default().unwrap(); let (_stream, stream_handle) = OutputStream::try_default().unwrap();
// open an audio sink // open an audio sink
let sink = Sink::try_new(&stream_handle).unwrap(); let mut sink = Sink::try_new(&stream_handle).unwrap();
// Load a sound from a file, using a path relative to Cargo.toml // Load a sound from a file, using a path relative to Cargo.toml
let file = BufReader::new(File::open(test_file[0].path.clone()).unwrap()); let file = BufReader::new(File::open(test_file[0].path.clone()).unwrap());
// Decode that sound file into a source // Decode that sound file into a source
@ -176,7 +176,75 @@ fn main() {
//println!("got from db: {:?}", items); //println!("got from db: {:?}", items);
} }
UIRequest::SwitchTo(partial_tag) => todo!(), UIRequest::SwitchTo(partial_tag) => {
let items = dbo
.get(&DatabaseRequest {
search_type: db_operations::SearchType::Like,
search_tag: partial_tag,
})
.unwrap();
match items {
None => {
sockets[i]
.write_message(
serde_json::to_string(&ServerResponse {
message: "No song found with that title!"
.to_string(),
search_results: vec![],
})
.unwrap()
.into(),
)
.unwrap();
}
Some(items) => {
if items.len() > 1 {
sockets[i]
.write_message(
serde_json::to_string(&ServerResponse {
message: "Please be more specific"
.to_string(),
search_results: items,
})
.unwrap()
.into(),
)
.unwrap();
} else {
println!(
"Switching song to: '{}'",
items.get(0).unwrap().title.clone()
);
sink.stop();
sink = Sink::try_new(&stream_handle).unwrap();
let file = BufReader::new(
File::open(items.get(0).unwrap().path.clone())
.unwrap(),
);
// Decode that sound file into a source
let source = Decoder::new(file).unwrap();
sink.append(source);
println!("{}", items.get(0).unwrap().path.clone());
sockets[i]
.write_message(
serde_json::to_string(&ServerResponse {
message: "Switching now playing"
.to_string(),
search_results: items,
})
.unwrap()
.into(),
)
.unwrap();
sink.play();
println!("{}", sink.is_paused());
}
}
}
}
UIRequest::GetStatus => todo!(), UIRequest::GetStatus => todo!(),
}, },
} }