aboutsummaryrefslogtreecommitdiff
path: root/server/src/main.rs
diff options
context:
space:
mode:
Diffstat (limited to 'server/src/main.rs')
-rw-r--r--server/src/main.rs8
1 files changed, 7 insertions, 1 deletions
diff --git a/server/src/main.rs b/server/src/main.rs
index 5a9c6cf..2fc6406 100644
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -1,6 +1,7 @@
#![feature(box_syntax)]
use crate::frontend::{pages::MyError, style::CSS_BUNDLE};
+use anyhow::anyhow;
use database::Database;
use frontend::pages::{home::page_home, node::page_library_node};
use jellyremuxer::{RemuxerContext, SendWriter};
@@ -44,6 +45,11 @@ fn stream(
let (a, b) = duplex(8196);
let item = state.library.nested("mili-bento-box-bivouac")?.get_item()?;
let remuxer = state.remuxer.clone();
+ let selection = selection
+ .split(",")
+ .map(|e| e.parse().map_err(|_| anyhow!("invalid number")))
+ .into_iter()
+ .collect::<Result<Vec<_>, _>>()?;
let b = SyncIoBridge::new(b);
tokio::task::spawn_blocking(move || {
@@ -51,7 +57,7 @@ fn stream(
b,
item.fs_path.parent().unwrap().to_path_buf(),
item.data.clone(),
- selection.split(",").map(|e| e.parse().unwrap()).collect(),
+ selection,
) {
warn!("stream stopped: {e}")
}